lbagent

Documentation

Index

• type ApiHelper
  • func NewApiHelper(opts *Options) (*ApiHelper, error)
  • func (h *ApiHelper) Run(ctx context.Context)
• type HaproxyHelper
  • func NewHaproxyHelper(opts *Options) (*HaproxyHelper, error)
  • func (h *HaproxyHelper) Run(ctx context.Context)
• type LbagentCmd
• type LbagentCmdType
• type LbagentCmdUseCorpusData
• type LbagentOptions
• type Options
  • func (opts *Options) ValidateThenInit() error

Types

type ApiHelper

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

func NewApiHelper

func NewApiHelper(opts *Options) (*ApiHelper, error)

func (*ApiHelper) Run

func (h *ApiHelper) Run(ctx context.Context)

type HaproxyHelper

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

func NewHaproxyHelper

func NewHaproxyHelper(opts *Options) (*HaproxyHelper, error)

func (*HaproxyHelper) Run

func (h *HaproxyHelper) Run(ctx context.Context)

type LbagentCmd

type LbagentCmd struct {
	Type LbagentCmdType
	Data interface{}
}

type LbagentCmdType

type LbagentCmdType uintptr

const (
	LbagentCmdUseCorpus LbagentCmdType = iota
)

type LbagentCmdUseCorpusData

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

type LbagentOptions

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

	ApiSyncInterval  int
	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

type Options struct {
	CommonOpts cloudcommon.Options

	LbagentOptions
}

func (*Options) ValidateThenInit

func (opts *Options) ValidateThenInit() error