command

Documentation

Index

• type CommandPlugin
  • func NewCommandPlugin(agentConfig *config.Config, grpcConnection grpc.GrpcConnectionInterface) *CommandPlugin
  • func (cp *CommandPlugin) Close(ctx context.Context) error
  • func (cp *CommandPlugin) Info() *bus.Info
  • func (cp *CommandPlugin) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error
  • func (cp *CommandPlugin) Process(ctx context.Context, msg *bus.Message)
  • func (cp *CommandPlugin) Subscriptions() []string
• type CommandService
  • func NewCommandService(ctx context.Context, commandServiceClient mpi.CommandServiceClient, ...) *CommandService
  • func (cs *CommandService) CancelSubscription(ctx context.Context)
  • func (cs *CommandService) CreateConnection(ctx context.Context, resource *mpi.Resource) (*mpi.CreateConnectionResponse, error)
  • func (cs *CommandService) IsConnected() bool
  • func (cs *CommandService) SendDataPlaneResponse(ctx context.Context, response *mpi.DataPlaneResponse) error
  • func (cs *CommandService) UpdateDataPlaneHealth(ctx context.Context, instanceHealths []*mpi.InstanceHealth) error
  • func (cs *CommandService) UpdateDataPlaneStatus(ctx context.Context, resource *mpi.Resource) error

Types

type CommandPlugin

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

func NewCommandPlugin

func NewCommandPlugin(agentConfig *config.Config, grpcConnection grpc.GrpcConnectionInterface) *CommandPlugin

func (*CommandPlugin) Close

func (cp *CommandPlugin) Close(ctx context.Context) error

func (*CommandPlugin) Info

func (cp *CommandPlugin) Info() *bus.Info

func (*CommandPlugin) Init

func (cp *CommandPlugin) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error

func (*CommandPlugin) Process

func (cp *CommandPlugin) Process(ctx context.Context, msg *bus.Message)

func (*CommandPlugin) Subscriptions

func (cp *CommandPlugin) Subscriptions() []string

type CommandService

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

func NewCommandService

func NewCommandService(
	ctx context.Context,
	commandServiceClient mpi.CommandServiceClient,
	agentConfig *config.Config,
	subscribeChannel chan *mpi.ManagementPlaneRequest,
) *CommandService

func (*CommandService) CancelSubscription

func (cs *CommandService) CancelSubscription(ctx context.Context)

func (*CommandService) CreateConnection

func (cs *CommandService) CreateConnection(
	ctx context.Context,
	resource *mpi.Resource,
) (*mpi.CreateConnectionResponse, error)

func (*CommandService) IsConnected

func (cs *CommandService) IsConnected() bool

func (*CommandService) SendDataPlaneResponse

func (cs *CommandService) SendDataPlaneResponse(ctx context.Context, response *mpi.DataPlaneResponse) error

func (*CommandService) UpdateDataPlaneHealth

func (cs *CommandService) UpdateDataPlaneHealth(ctx context.Context, instanceHealths []*mpi.InstanceHealth) error

func (*CommandService) UpdateDataPlaneStatus

func (cs *CommandService) UpdateDataPlaneStatus(
	ctx context.Context,
	resource *mpi.Resource,
) error