// Copyright 2022 Google LLC

//

// Licensed under the Apache License, Version 2.0 (the "License");

// you may not use this file except in compliance with the License.

// You may obtain a copy of the License at

//

// http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing, software

// distributed under the License is distributed on an "AS IS" BASIS,

// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

// See the License for the specific language governing permissions and

// limitations under the License.

#include <memory>

#include <string>

#include <thread>

#include "absl/container/flat_hash_map.h"

#include "absl/flags/flag.h"

#include "absl/flags/marshalling.h"

#include "absl/status/status.h"

#include "absl/status/statusor.h"

#include "absl/strings/string_view.h"

#include "components/cloud_config/parameter_client.h"

#include "public/constants.h"

ABSL_FLAG(std::string, delta_directory, "",

"Local directory to watch for files.");

ABSL_FLAG(absl::Duration, export_interval, absl::Seconds(30),

"Frequency to export local metrics.");

ABSL_FLAG(absl::Duration, export_timeout, absl::Seconds(5),

"Timeout for exporting local metrics.");

ABSL_FLAG(std::string, launch_hook, "", "Launch hook.");

ABSL_FLAG(absl::Duration, local_poll_frequency, absl::Seconds(5),

"Frequency to poll for local file changes.");

ABSL_FLAG(std::string, realtime_directory, "",

"Local directory to watch for realtime file changes.");

ABSL_FLAG(int32_t, local_realtime_updater_num_threads, 1,

"Amount of realtime updates threads locally.");

ABSL_FLAG(int32_t, data_loading_num_threads,

std::min(std::thread::hardware_concurrency(), 8u),

"Number of parallel threads for reading and loading data files.");

ABSL_FLAG(int32_t, s3client_max_connections, 1,

"S3Client max connections for reading data files.");

ABSL_FLAG(int32_t, s3client_max_range_bytes, 1,

"S3Client max range bytes for reading data files.");

ABSL_FLAG(int32_t, num_shards, 1, "Total number of shards.");

ABSL_FLAG(int32_t, udf_num_workers, 2, "Number of workers for UDF execution.");

ABSL_FLAG(bool, route_v1_to_v2, false,

"Whether to route V1 requests through V2.");

ABSL_FLAG(std::string, data_loading_file_format,

std::string(kv_server::kFileFormats[static_cast<int>(

kv_server::FileFormat::kRiegeli)]),

"File format of the input data files. See /public/constants.h for "

"possible values.");

ABSL_FLAG(std::int32_t, logging_verbosity_level, 0,

"Loggging verbosity level.");

ABSL_FLAG(absl::Duration, udf_timeout, absl::Seconds(5),

"Timeout for one UDF invocation");

ABSL_FLAG(absl::Duration, udf_update_timeout, absl::Seconds(30),

"Timeout for UDF code update");

ABSL_FLAG(int32_t, udf_min_log_level, 0,

"Minimum logging level for UDFs. Info=0, Warn=1, Error=2. Default is "

"0(info).");

ABSL_FLAG(bool, enable_otel_logger, false, "Whether to enable otel logger.");

ABSL_FLAG(std::string, telemetry_config, "mode: EXPERIMENT",

"Telemetry configuration for exporting raw or noised metrics");

ABSL_FLAG(std::string, data_loading_prefix_allowlist, "",

"Allowlist for blob prefixes.");

ABSL_FLAG(bool, add_missing_keys_v1, false,

"Whether to add missing keys for v1.");

ABSL_FLAG(bool, enable_consented_log, false, "Whether to enable consented log");

ABSL_FLAG(std::string, consented_debug_token, "", "Consented debug token");

namespace kv_server {

namespace {

// Initialize a static map of flag values and use those to look up parameters.

//

// TODO(b/237669491) The values here are hardcoded with a server prefix of

// "kv-server" and an environment of "local". This is safe because these

// parameters should only work in that configuration but it's not elegant, see

// if there's a better way.

class LocalParameterClient : public ParameterClient {

};

} // namespace

std::unique_ptr<ParameterClient> ParameterClient::Create(

}

} // namespace kv_server