lbagent

type ApiHelper struct {
	// contains filtered or unexported fields
}

type Bar struct {
	// contains filtered or unexported fields
}

type HaStateProvider interface {
	StateChannel() <-chan string
	StateScript() string
}

type HaStateWatcher struct {
	HaStateScriptPath string
	HaStatePath       string
	CurrentState      string // TODO hide it

	C chan string
	// contains filtered or unexported fields
}

type HaproxyHelper struct {
	// contains filtered or unexported fields
}

type LbagentCmd struct {
	Type LbagentCmdType
	Data interface{}
}

type LbagentCmdType uintptr

type LbagentCmdUseCorpusData struct {
	Corpus      *agentmodels.LoadbalancerCorpus
	AgentParams *agentmodels.AgentParams
	Wg          sync.WaitGroup
}

type LbagentOptions struct {
	ApiLbagentId                  string `require:"true"`
	ApiLbagentHbInterval          int    `default:"10"`
	ApiLbagentHbTimeoutRelaxation int    `` /* 162-byte string literal not displayed */

	ApiSyncIntervalSeconds  int `default:"10"`
	ApiRunDelayMilliseconds int `default:"10"`

	ApiListBatchSize int `default:"1024"`

	DataPreserveN int `default:"8" help:"number of recent data to preserve on disk"`

	BaseDataDir string // `required:"true"`

	KeepalivedBin string `default:"keepalived"`
	HaproxyBin    string `default:"haproxy"`
	GobetweenBin  string `default:"gobetween"`
	TelegrafBin   string `default:"telegraf"`
	// contains filtered or unexported fields
}

type Options struct {
	common_options.CommonOptions

	LbagentOptions
}

type OvnHost struct {
	Bar *Bar
	// contains filtered or unexported fields
}

type OvnWorker struct {
	Bar *Bar
	// contains filtered or unexported fields
}