agentservice

Documentation

Index

• type AgentService
  • func NewAgentService(cli zrpc.Client) AgentService
• type ClusterReRegisterMessageProto
• type ClusterRegisterAckMessageProto
• type ClusterStateChangeMessageProto
• type MessageProducerProto
• type MessageResponseProto
• type StringStringMapProto

Types

type AgentService

type AgentService interface {
	RequireReRegister(ctx context.Context, in *ClusterReRegisterMessageProto, opts ...grpc.CallOption) (*MessageResponseProto, error)
	RegisterAck(ctx context.Context, in *ClusterRegisterAckMessageProto, opts ...grpc.CallOption) (*MessageResponseProto, error)
	ChangeClusterState(ctx context.Context, in *ClusterStateChangeMessageProto, opts ...grpc.CallOption) (*MessageResponseProto, error)
}

func NewAgentService

func NewAgentService(cli zrpc.Client) AgentService

type ClusterReRegisterMessageProto

type ClusterReRegisterMessageProto = ms.ClusterReRegisterMessageProto

type ClusterRegisterAckMessageProto

type ClusterRegisterAckMessageProto = ms.ClusterRegisterAckMessageProto

type ClusterStateChangeMessageProto

type ClusterStateChangeMessageProto = ms.ClusterStateChangeMessageProto

type MessageProducerProto

type MessageProducerProto = ms.MessageProducerProto

type MessageResponseProto

type MessageResponseProto = ms.MessageResponseProto

type StringStringMapProto

type StringStringMapProto = ms.StringStringMapProto