lbagent

Documentation

Index

• Constants
• func StartService()
• type ApiHelper
  • func NewApiHelper(opts *Options) (*ApiHelper, error)
  • func (h *ApiHelper) Run(ctx context.Context)
  • func (h *ApiHelper) SetHaStateProvider(hsp HaStateProvider)
• type Bar
  • func NewBar() *Bar
  • func (b *Bar) Cancel()
  • func (b *Bar) Cancelled() <-chan struct{}
  • func (b *Bar) Done()
  • func (b *Bar) Init()
• type HaStateProvider
• type HaStateWatcher
  • func NewHaStateWatcher(opts *Options) (hsw *HaStateWatcher, err error)
  • func (hsw *HaStateWatcher) Run(ctx context.Context)
  • func (hsw *HaStateWatcher) StateChannel() <-chan string
  • func (hsw *HaStateWatcher) StateScript() string
• 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
• type OvnHost
  • func (ovnHost *OvnHost) Refresh(ctx context.Context, lb *agentmodels.Loadbalancer) error
  • func (ovnHost *OvnHost) SetAddrIdx(inner, outer uint16)
  • func (ovnHost *OvnHost) Start(ctx context.Context)
  • func (ovnHost *OvnHost) Stop()
• type OvnWorker
  • func NewOvnWorker() *OvnWorker
  • func (ovn *OvnWorker) Refresh(ctx context.Context, lbs agentmodels.Loadbalancers) error
  • func (ovn *OvnWorker) Start(ctx context.Context)
  • func (ovn *OvnWorker) Stop()

Constants

const (
	HA_STATE_SCRIPT_NAME    = "ha_state.sh"
	HA_STATE_SCRIPT_CONTENT = `
#!/bin/bash
echo "$@" >%s
`
	HA_STATE_FILENAME = "ha_state"
)

Functions

func StartService

func StartService()

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)

func (*ApiHelper) SetHaStateProvider

func (h *ApiHelper) SetHaStateProvider(hsp HaStateProvider)

type Bar

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

func NewBar

func NewBar() *Bar

func (*Bar) Cancel

func (b *Bar) Cancel()

func (*Bar) Cancelled

func (b *Bar) Cancelled() <-chan struct{}

func (*Bar) Done

func (b *Bar) Done()

func (*Bar) Init

func (b *Bar) Init()

type HaStateProvider

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

type HaStateWatcher

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

	C chan string
	// contains filtered or unexported fields
}

func NewHaStateWatcher

func NewHaStateWatcher(opts *Options) (hsw *HaStateWatcher, err error)

func (*HaStateWatcher) Run

func (hsw *HaStateWatcher) Run(ctx context.Context)

func (*HaStateWatcher) StateChannel

func (hsw *HaStateWatcher) StateChannel() <-chan string

func (*HaStateWatcher) StateScript

func (hsw *HaStateWatcher) StateScript() string

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
	LbagentCmdStopDaemons
)

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 */

	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

type Options struct {
	common_options.CommonOptions

	LbagentOptions
}

func (*Options) ValidateThenInit

func (opts *Options) ValidateThenInit() error

type OvnHost

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

func (*OvnHost) Refresh

func (ovnHost *OvnHost) Refresh(ctx context.Context, lb *agentmodels.Loadbalancer) error

func (*OvnHost) SetAddrIdx

func (ovnHost *OvnHost) SetAddrIdx(inner, outer uint16)

func (*OvnHost) Start

func (ovnHost *OvnHost) Start(ctx context.Context)

func (*OvnHost) Stop

func (ovnHost *OvnHost) Stop()

type OvnWorker

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

func NewOvnWorker

func NewOvnWorker() *OvnWorker

func (*OvnWorker) Refresh

func (ovn *OvnWorker) Refresh(ctx context.Context, lbs agentmodels.Loadbalancers) error

func (*OvnWorker) Start

func (ovn *OvnWorker) Start(ctx context.Context)

func (*OvnWorker) Stop

func (ovn *OvnWorker) Stop()