outboundAdapters

Documentation

Index

• type ContextBoxConnector
  • func (c *ContextBoxConnector) Connect() error
  • func (c *ContextBoxConnector) Disconnect()
  • func (c ContextBoxConnector) GetConfigScheduler(contextBoxGrpcClient pb.ContextBoxServiceClient) (*pb.GetConfigResponse, error)
  • func (c ContextBoxConnector) SaveConfigScheduler(config *pb.Config, contextBoxGrpcClient pb.ContextBoxServiceClient) error

Types

type ContextBoxConnector

type ContextBoxConnector struct {
	Connection *grpc.ClientConn
}

func (*ContextBoxConnector) Connect

func (c *ContextBoxConnector) Connect() error

Connect establishes a gRPC connection with the context-box microservice

func (*ContextBoxConnector) Disconnect

func (c *ContextBoxConnector) Disconnect()

Disconnect closes the underlying gRPC connection to context-box microservice

func (ContextBoxConnector) GetConfigScheduler

func (c ContextBoxConnector) GetConfigScheduler(contextBoxGrpcClient pb.ContextBoxServiceClient) (*pb.GetConfigResponse, error)

The context-box microservice has a scheduler queue(FIFO) containing ConfigInfos of those configs whose desired state needs to be built. GetConfigScheduler gets config from context-box DB corresponding to the configInfo present in the front of the scheduler queue.

func (ContextBoxConnector) SaveConfigScheduler

func (c ContextBoxConnector) SaveConfigScheduler(config *pb.Config, contextBoxGrpcClient pb.ContextBoxServiceClient) error

SaveConfigScheduler saves a config into context-box DB