agent

Documentation

Index

• type Agent
  • func NewAgent(ctx context.Context, loadbot *lbot.Lbot) *Agent
  • func (a *Agent) ApplyConfig(request *lbot.ConfigRequest) error
  • func (a *Agent) ApplyConfigFromFile(path string) error
  • func (a *Agent) Heartbeat() error
  • func (a *Agent) Listen() error
  • func (a *Agent) Metrics() error
  • func (a *Agent) ServeGrpc() error
  • func (a *Agent) Start() error
  • func (a *Agent) WatchConfigFile(configFile string) (err error)
• type AgentState
  • func (i AgentState) String() string

Types

type Agent

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

func NewAgent

func NewAgent(ctx context.Context, loadbot *lbot.Lbot) *Agent

func (*Agent) ApplyConfig

func (a *Agent) ApplyConfig(request *lbot.ConfigRequest) error

remove from here

func (*Agent) ApplyConfigFromFile

func (a *Agent) ApplyConfigFromFile(path string) error

func (*Agent) Heartbeat

func (a *Agent) Heartbeat() error

func (*Agent) Listen

func (a *Agent) Listen() error

func (*Agent) Metrics

func (a *Agent) Metrics() error

remove from here

func (*Agent) ServeGrpc

func (a *Agent) ServeGrpc() error

właściwie to nie ma potrzeby nasłuchiwać na grpc dla każdego followera

func (*Agent) Start

func (a *Agent) Start() error

func (*Agent) WatchConfigFile

func (a *Agent) WatchConfigFile(configFile string) (err error)

type AgentState

type AgentState int

const (
	AgentStateLeader AgentState = iota
	AgentStateFollower
)

func (AgentState) String

func (i AgentState) String() string