blob: f87d8ce4d6ae83f5dc706d8bfe24c6bcdb26d79d [file] [log] [blame]
khenaidoobf6e7bb2018-08-14 22:27:29 -04001/*
2 * Copyright 2018-present Open Networking Foundation
3
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7
8 * http://www.apache.org/licenses/LICENSE-2.0
9
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
khenaidoocfee5f42018-07-19 22:47:38 -040016package config
17
18import (
khenaidoocfee5f42018-07-19 22:47:38 -040019 "flag"
20 "fmt"
khenaidoob9203542018-09-17 22:56:37 -040021 "github.com/opencord/voltha-go/common/log"
khenaidoocfee5f42018-07-19 22:47:38 -040022 "os"
khenaidoocfee5f42018-07-19 22:47:38 -040023)
24
khenaidoo5c11af72018-07-20 17:21:05 -040025// RW Core service default constants
khenaidoocfee5f42018-07-19 22:47:38 -040026const (
khenaidoo79232702018-12-04 11:00:41 -050027 ConsulStoreName = "consul"
28 EtcdStoreName = "etcd"
khenaidoo9cdc1a62019-01-24 21:57:40 -050029 default_InstanceID = "rwcore001"
30 default_GrpcPort = 50057
31 default_GrpcHost = ""
32 default_KafkaAdapterHost = "127.0.0.1"
33 default_KafkaAdapterPort = 9092
34 default_KafkaClusterHost = "127.0.0.1"
35 default_KafkaClusterPort = 9094
36 default_KVStoreType = EtcdStoreName
37 default_KVStoreTimeout = 5 //in seconds
38 default_KVStoreHost = "127.0.0.1"
39 default_KVStorePort = 2379 // Consul = 8500; Etcd = 2379
40 default_KVTxnKeyDelTime = 60
41 default_KVStoreDataPrefix = "service/voltha"
42 default_LogLevel = 0
43 default_Banner = false
44 default_CoreTopic = "rwcore"
45 default_RWCoreEndpoint = "rwcore"
46 default_RWCoreKey = "pki/voltha.key"
47 default_RWCoreCert = "pki/voltha.crt"
48 default_RWCoreCA = "pki/voltha-CA.pem"
49 default_AffinityRouterTopic = "affinityRouter"
50 default_InCompetingMode = true
khenaidoob6080322019-01-29 21:47:38 -050051 default_LongRunningRequestTimeout = int64(2000)
52 default_DefaultRequestTimeout = int64(500)
Richard Jankowski46464e92019-03-05 11:53:55 -050053 default_CoreBindingKey = "voltha_backend_name"
khenaidoocfee5f42018-07-19 22:47:38 -040054)
55
khenaidoo5c11af72018-07-20 17:21:05 -040056// RWCoreFlags represents the set of configurations used by the read-write core service
khenaidoocfee5f42018-07-19 22:47:38 -040057type RWCoreFlags struct {
58 // Command line parameters
khenaidoo9cdc1a62019-01-24 21:57:40 -050059 InstanceID string
60 RWCoreEndpoint string
khenaidoo79232702018-12-04 11:00:41 -050061 GrpcHost string
62 GrpcPort int
63 KafkaAdapterHost string
64 KafkaAdapterPort int
65 KafkaClusterHost string
66 KafkaClusterPort int
67 KVStoreType string
68 KVStoreTimeout int // in seconds
69 KVStoreHost string
70 KVStorePort int
71 KVTxnKeyDelTime int
khenaidoo9cdc1a62019-01-24 21:57:40 -050072 KVStoreDataPrefix string
khenaidoo79232702018-12-04 11:00:41 -050073 CoreTopic string
74 LogLevel int
75 Banner bool
76 RWCoreKey string
77 RWCoreCert string
78 RWCoreCA string
79 AffinityRouterTopic string
khenaidoo9cdc1a62019-01-24 21:57:40 -050080 InCompetingMode bool
khenaidoob6080322019-01-29 21:47:38 -050081 LongRunningRequestTimeout int64
82 DefaultRequestTimeout int64
Richard Jankowski46464e92019-03-05 11:53:55 -050083 CoreBindingKey string
khenaidoocfee5f42018-07-19 22:47:38 -040084}
85
khenaidoob9203542018-09-17 22:56:37 -040086func init() {
87 log.AddPackage(log.JSON, log.WarnLevel, nil)
88}
89
khenaidoo5c11af72018-07-20 17:21:05 -040090// NewRWCoreFlags returns a new RWCore config
khenaidoocfee5f42018-07-19 22:47:38 -040091func NewRWCoreFlags() *RWCoreFlags {
92 var rwCoreFlag = RWCoreFlags{ // Default values
khenaidoo79232702018-12-04 11:00:41 -050093 InstanceID: default_InstanceID,
94 RWCoreEndpoint: default_RWCoreEndpoint,
95 GrpcHost: default_GrpcHost,
96 GrpcPort: default_GrpcPort,
97 KafkaAdapterHost: default_KafkaAdapterHost,
98 KafkaAdapterPort: default_KafkaAdapterPort,
99 KafkaClusterHost: default_KafkaClusterHost,
khenaidoo9cdc1a62019-01-24 21:57:40 -0500100 KafkaClusterPort: default_KafkaClusterPort,
101 KVStoreType: default_KVStoreType,
khenaidoo79232702018-12-04 11:00:41 -0500102 KVStoreTimeout: default_KVStoreTimeout,
103 KVStoreHost: default_KVStoreHost,
104 KVStorePort: default_KVStorePort,
khenaidoo9cdc1a62019-01-24 21:57:40 -0500105 KVStoreDataPrefix: default_KVStoreDataPrefix,
khenaidoo79232702018-12-04 11:00:41 -0500106 KVTxnKeyDelTime: default_KVTxnKeyDelTime,
107 CoreTopic: default_CoreTopic,
108 LogLevel: default_LogLevel,
109 Banner: default_Banner,
110 RWCoreKey: default_RWCoreKey,
111 RWCoreCert: default_RWCoreCert,
112 RWCoreCA: default_RWCoreCA,
khenaidoo9cdc1a62019-01-24 21:57:40 -0500113 AffinityRouterTopic: default_AffinityRouterTopic,
114 InCompetingMode: default_InCompetingMode,
khenaidoob6080322019-01-29 21:47:38 -0500115 DefaultRequestTimeout:default_DefaultRequestTimeout,
116 LongRunningRequestTimeout:default_LongRunningRequestTimeout,
Richard Jankowski46464e92019-03-05 11:53:55 -0500117 CoreBindingKey: default_CoreBindingKey,
khenaidoocfee5f42018-07-19 22:47:38 -0400118 }
119 return &rwCoreFlag
120}
121
khenaidoo5c11af72018-07-20 17:21:05 -0400122// ParseCommandArguments parses the arguments when running read-write core service
khenaidoocfee5f42018-07-19 22:47:38 -0400123func (cf *RWCoreFlags) ParseCommandArguments() {
khenaidoocfee5f42018-07-19 22:47:38 -0400124
khenaidoo5c11af72018-07-20 17:21:05 -0400125 var help string
khenaidoocfee5f42018-07-19 22:47:38 -0400126
Stephane Barbariec53a2752019-03-08 17:50:10 -0500127 help = fmt.Sprintf("RW instance id")
128 flag.StringVar(&(cf.InstanceID), "instance-id", default_InstanceID, help)
129
khenaidoo5c11af72018-07-20 17:21:05 -0400130 help = fmt.Sprintf("RW core endpoint address")
131 flag.StringVar(&(cf.RWCoreEndpoint), "vcore-endpoint", default_RWCoreEndpoint, help)
khenaidoocfee5f42018-07-19 22:47:38 -0400132
khenaidoo5c11af72018-07-20 17:21:05 -0400133 help = fmt.Sprintf("GRPC server - host")
134 flag.StringVar(&(cf.GrpcHost), "grpc_host", default_GrpcHost, help)
khenaidoocfee5f42018-07-19 22:47:38 -0400135
khenaidoo5c11af72018-07-20 17:21:05 -0400136 help = fmt.Sprintf("GRPC server - port")
137 flag.IntVar(&(cf.GrpcPort), "grpc_port", default_GrpcPort, help)
138
139 help = fmt.Sprintf("Kafka - Adapter messaging host")
140 flag.StringVar(&(cf.KafkaAdapterHost), "kafka_adapter_host", default_KafkaAdapterHost, help)
141
142 help = fmt.Sprintf("Kafka - Adapter messaging port")
143 flag.IntVar(&(cf.KafkaAdapterPort), "kafka_adapter_port", default_KafkaAdapterPort, help)
144
145 help = fmt.Sprintf("Kafka - Cluster messaging host")
146 flag.StringVar(&(cf.KafkaClusterHost), "kafka_cluster_host", default_KafkaClusterHost, help)
147
148 help = fmt.Sprintf("Kafka - Cluster messaging port")
149 flag.IntVar(&(cf.KafkaClusterPort), "kafka_cluster_port", default_KafkaClusterPort, help)
150
151 help = fmt.Sprintf("RW Core topic")
152 flag.StringVar(&(cf.CoreTopic), "rw_core_topic", default_CoreTopic, help)
153
khenaidoo79232702018-12-04 11:00:41 -0500154 help = fmt.Sprintf("Affinity Router topic")
khenaidoo9cdc1a62019-01-24 21:57:40 -0500155 flag.StringVar(&(cf.AffinityRouterTopic), "affinity_router_topic", default_AffinityRouterTopic, help)
156
157 help = fmt.Sprintf("In competing Mode - two cores competing to handle a transaction ")
158 flag.BoolVar(&cf.InCompetingMode, "in_competing_mode", default_InCompetingMode, help)
khenaidoo79232702018-12-04 11:00:41 -0500159
khenaidoo5c11af72018-07-20 17:21:05 -0400160 help = fmt.Sprintf("KV store type")
161 flag.StringVar(&(cf.KVStoreType), "kv_store_type", default_KVStoreType, help)
162
163 help = fmt.Sprintf("The default timeout when making a kv store request")
164 flag.IntVar(&(cf.KVStoreTimeout), "kv_store_request_timeout", default_KVStoreTimeout, help)
165
166 help = fmt.Sprintf("KV store host")
167 flag.StringVar(&(cf.KVStoreHost), "kv_store_host", default_KVStoreHost, help)
168
169 help = fmt.Sprintf("KV store port")
170 flag.IntVar(&(cf.KVStorePort), "kv_store_port", default_KVStorePort, help)
171
Richard Jankowskie4d77662018-10-17 13:53:21 -0400172 help = fmt.Sprintf("The time to wait before deleting a completed transaction key")
173 flag.IntVar(&(cf.KVTxnKeyDelTime), "kv_txn_delete_time", default_KVTxnKeyDelTime, help)
174
khenaidoo9cdc1a62019-01-24 21:57:40 -0500175 help = fmt.Sprintf("KV store data prefix")
176 flag.StringVar(&(cf.KVStoreDataPrefix), "kv_store_data_prefix", default_KVStoreDataPrefix, help)
177
khenaidoo5c11af72018-07-20 17:21:05 -0400178 help = fmt.Sprintf("Log level")
179 flag.IntVar(&(cf.LogLevel), "log_level", default_LogLevel, help)
180
khenaidoob6080322019-01-29 21:47:38 -0500181 help = fmt.Sprintf("Timeout for long running request")
182 flag.Int64Var(&(cf.LongRunningRequestTimeout), "timeout_long_request", default_LongRunningRequestTimeout, help)
183
184 help = fmt.Sprintf("Default timeout for regular request")
185 flag.Int64Var(&(cf.DefaultRequestTimeout), "timeout_request", default_DefaultRequestTimeout, help)
186
khenaidoo5c11af72018-07-20 17:21:05 -0400187 help = fmt.Sprintf("Show startup banner log lines")
188 flag.BoolVar(&cf.Banner, "banner", default_Banner, help)
khenaidoocfee5f42018-07-19 22:47:38 -0400189
Richard Jankowski46464e92019-03-05 11:53:55 -0500190 help = fmt.Sprintf("The name of the meta-key whose value is the rw-core group to which the ofagent is bound")
191 flag.StringVar(&(cf.CoreBindingKey), "core_binding_key", default_CoreBindingKey, help)
192
khenaidoocfee5f42018-07-19 22:47:38 -0400193 flag.Parse()
194
khenaidoocfee5f42018-07-19 22:47:38 -0400195 containerName := getContainerInfo()
khenaidoocfee5f42018-07-19 22:47:38 -0400196 if len(containerName) > 0 {
197 cf.InstanceID = containerName
198 }
199
khenaidoocfee5f42018-07-19 22:47:38 -0400200}
201
202func getContainerInfo() string {
203 return os.Getenv("HOSTNAME")
204}