controller

Documentation

Index

• type Controller
  • func NewController(port string, hbCh chan *HeartBeat) *Controller
  • func (ctr *Controller) GetAgentHeartBeat(rpcAddr string) (*agentpb.HeartBeat, error)
  • func (ctr *Controller) Run()
  • func (ctr *Controller) UpdateAgentStatusRequest(ctx context.Context, heartbeat *agentpb.HeartBeat) (*ctrpb.ControllerRequestDone, error)
  • func (ctr *Controller) UpdateConfig(rpcAddr string, configBytes []byte) (*agentpb.UpdateConfigResponse, error)
• type HeartBeat

Types

type Controller

type Controller struct {
	ctrpb.UnimplementedControllerServer

	RpcPort string
	// contains filtered or unexported fields
}

func NewController

func NewController(port string, hbCh chan *HeartBeat) *Controller

func (*Controller) GetAgentHeartBeat

func (ctr *Controller) GetAgentHeartBeat(rpcAddr string) (*agentpb.HeartBeat, error)

func (*Controller) Run

func (ctr *Controller) Run()

func (*Controller) UpdateAgentStatusRequest

func (ctr *Controller) UpdateAgentStatusRequest(ctx context.Context, heartbeat *agentpb.HeartBeat) (*ctrpb.ControllerRequestDone, error)

func (*Controller) UpdateConfig

func (ctr *Controller) UpdateConfig(rpcAddr string, configBytes []byte) (*agentpb.UpdateConfigResponse, error)

type HeartBeat

type HeartBeat struct {
	HeartBeat *agentpb.HeartBeat
	Addr      string
}