|
|
@@ -55,6 +55,8 @@ const (
|
|
55
|
55
|
OptionTypeWriteBufferSize
|
|
56
|
56
|
OptionTypeReadBufferSize
|
|
57
|
57
|
|
|
|
58
|
+ OptionTypeCloakPort
|
|
|
59
|
+
|
|
58
|
60
|
OptionTypeAntiReplayMaxSize
|
|
59
|
61
|
OptionTypeAntiReplayEvictionTime
|
|
60
|
62
|
|
|
|
@@ -71,10 +73,12 @@ type Config struct {
|
|
71
|
73
|
|
|
72
|
74
|
StatsNamespace string `json:"stats_namespace"`
|
|
73
|
75
|
StatsdNetwork string `json:"statsd_network"`
|
|
|
76
|
+ CloakHost string `json:"cloak_host"`
|
|
74
|
77
|
StatsdTags map[string]string `json:"statsd_tags"`
|
|
75
|
78
|
|
|
76
|
79
|
WriteBuffer int `json:"write_buffer"`
|
|
77
|
80
|
ReadBuffer int `json:"read_buffer"`
|
|
|
81
|
+ CloakPort int `json:"cloak_port"`
|
|
78
|
82
|
|
|
79
|
83
|
AntiReplayMaxSize int `json:"anti_replay_max_size"`
|
|
80
|
84
|
AntiReplayEvictionTime time.Duration `json:"anti_replay_eviction_time"`
|
|
|
@@ -144,6 +148,8 @@ func Init(options ...Opt) error { // nolint: gocyclo, funlen
|
|
144
|
148
|
C.WriteBuffer = int(opt.Value.(units.Base2Bytes))
|
|
145
|
149
|
case OptionTypeReadBufferSize:
|
|
146
|
150
|
C.ReadBuffer = int(opt.Value.(units.Base2Bytes))
|
|
|
151
|
+ case OptionTypeCloakPort:
|
|
|
152
|
+ C.CloakPort = int(opt.Value.(uint16))
|
|
147
|
153
|
case OptionTypeAntiReplayMaxSize:
|
|
148
|
154
|
C.AntiReplayMaxSize = opt.Value.(int)
|
|
149
|
155
|
case OptionTypeAntiReplayEvictionTime:
|