ms

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	MessageStatus_name = map[int32]string{
		0: "FAIL",
		1: "SUCCESS",
		2: "UNKNOWN",
	}
	MessageStatus_value = map[string]int32{
		"FAIL":    0,
		"SUCCESS": 1,
		"UNKNOWN": 2,
	}
)

Enum value maps for MessageStatus.

View Source 
var AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ms.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "requireReRegister",
			Handler:    _AgentService_RequireReRegister_Handler,
		},
		{
			MethodName: "registerAck",
			Handler:    _AgentService_RegisterAck_Handler,
		},
		{
			MethodName: "changeClusterState",
			Handler:    _AgentService_ChangeClusterState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pcm-ms.proto",
}

AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pcm_ms_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServiceServer 

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

Types

type AgentServiceClient 

type AgentServiceClient 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)
}

AgentServiceClient is the client API for AgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAgentServiceClient 

func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient

type AgentServiceServer 

type AgentServiceServer interface {
	RequireReRegister(context.Context, *ClusterReRegisterMessageProto) (*MessageResponseProto, error)
	RegisterAck(context.Context, *ClusterRegisterAckMessageProto) (*MessageResponseProto, error)
	ChangeClusterState(context.Context, *ClusterStateChangeMessageProto) (*MessageResponseProto, error)
	// contains filtered or unexported methods
}

AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility

type ClusterReRegisterMessageProto 

type ClusterReRegisterMessageProto struct {
	MsgProducer *MessageProducerProto `protobuf:"bytes,1,opt,name=msg_producer,json=msgProducer,proto3" json:"msg_producer,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterReRegisterMessageProto) Descriptor deprecated 

func (*ClusterReRegisterMessageProto) Descriptor() ([]byte, []int)

Deprecated: Use ClusterReRegisterMessageProto.ProtoReflect.Descriptor instead.

func (*ClusterReRegisterMessageProto) GetMsgProducer 

func (x *ClusterReRegisterMessageProto) GetMsgProducer() *MessageProducerProto

func (*ClusterReRegisterMessageProto) ProtoMessage 

func (*ClusterReRegisterMessageProto) ProtoMessage()

func (*ClusterReRegisterMessageProto) ProtoReflect 

func (x *ClusterReRegisterMessageProto) ProtoReflect() protoreflect.Message

func (*ClusterReRegisterMessageProto) Reset 

func (x *ClusterReRegisterMessageProto) Reset()

func (*ClusterReRegisterMessageProto) String 

func (x *ClusterReRegisterMessageProto) String() string

type ClusterRegisterAckMessageProto 

type ClusterRegisterAckMessageProto struct {
	MsgProducer *MessageProducerProto   `protobuf:"bytes,1,opt,name=msg_producer,json=msgProducer,proto3" json:"msg_producer,omitempty"`
	Configs     []*StringStringMapProto `protobuf:"bytes,3,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterRegisterAckMessageProto) Descriptor deprecated 

func (*ClusterRegisterAckMessageProto) Descriptor() ([]byte, []int)

Deprecated: Use ClusterRegisterAckMessageProto.ProtoReflect.Descriptor instead.

func (*ClusterRegisterAckMessageProto) GetConfigs 

func (x *ClusterRegisterAckMessageProto) GetConfigs() []*StringStringMapProto

func (*ClusterRegisterAckMessageProto) GetMsgProducer 

func (x *ClusterRegisterAckMessageProto) GetMsgProducer() *MessageProducerProto

func (*ClusterRegisterAckMessageProto) ProtoMessage 

func (*ClusterRegisterAckMessageProto) ProtoMessage()

func (*ClusterRegisterAckMessageProto) ProtoReflect 

func (x *ClusterRegisterAckMessageProto) ProtoReflect() protoreflect.Message

func (*ClusterRegisterAckMessageProto) Reset 

func (x *ClusterRegisterAckMessageProto) Reset()

func (*ClusterRegisterAckMessageProto) String 

func (x *ClusterRegisterAckMessageProto) String() string

type ClusterStateChangeMessageProto 

type ClusterStateChangeMessageProto struct {
	MsgProducer  *MessageProducerProto `protobuf:"bytes,1,opt,name=msg_producer,json=msgProducer,proto3" json:"msg_producer,omitempty"`
	ClusterState int32                 `protobuf:"varint,2,opt,name=cluster_state,json=clusterState,proto3" json:"cluster_state,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterStateChangeMessageProto) Descriptor deprecated 

func (*ClusterStateChangeMessageProto) Descriptor() ([]byte, []int)

Deprecated: Use ClusterStateChangeMessageProto.ProtoReflect.Descriptor instead.

func (*ClusterStateChangeMessageProto) GetClusterState 

func (x *ClusterStateChangeMessageProto) GetClusterState() int32

func (*ClusterStateChangeMessageProto) GetMsgProducer 

func (x *ClusterStateChangeMessageProto) GetMsgProducer() *MessageProducerProto

func (*ClusterStateChangeMessageProto) ProtoMessage 

func (*ClusterStateChangeMessageProto) ProtoMessage()

func (*ClusterStateChangeMessageProto) ProtoReflect 

func (x *ClusterStateChangeMessageProto) ProtoReflect() protoreflect.Message

func (*ClusterStateChangeMessageProto) Reset 

func (x *ClusterStateChangeMessageProto) Reset()

func (*ClusterStateChangeMessageProto) String 

func (x *ClusterStateChangeMessageProto) String() string

type MessageProducerProto 

type MessageProducerProto struct {
	MsNetId          string `protobuf:"bytes,1,opt,name=ms_net_id,json=msNetId,proto3" json:"ms_net_id,omitempty"`
	ClusterId        string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	AgentServiceHost string `protobuf:"bytes,3,opt,name=agent_service_host,json=agentServiceHost,proto3" json:"agent_service_host,omitempty"`
	AgentServicePort int32  `protobuf:"varint,4,opt,name=agent_service_port,json=agentServicePort,proto3" json:"agent_service_port,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageProducerProto) Descriptor deprecated 

func (*MessageProducerProto) Descriptor() ([]byte, []int)

Deprecated: Use MessageProducerProto.ProtoReflect.Descriptor instead.

func (*MessageProducerProto) GetAgentServiceHost 

func (x *MessageProducerProto) GetAgentServiceHost() string

func (*MessageProducerProto) GetAgentServicePort 

func (x *MessageProducerProto) GetAgentServicePort() int32

func (*MessageProducerProto) GetClusterId 

func (x *MessageProducerProto) GetClusterId() string

func (*MessageProducerProto) GetMsNetId 

func (x *MessageProducerProto) GetMsNetId() string

func (*MessageProducerProto) ProtoMessage 

func (*MessageProducerProto) ProtoMessage()

func (*MessageProducerProto) ProtoReflect 

func (x *MessageProducerProto) ProtoReflect() protoreflect.Message

func (*MessageProducerProto) Reset 

func (x *MessageProducerProto) Reset()

func (*MessageProducerProto) String 

func (x *MessageProducerProto) String() string

type MessageResponseProto 

type MessageResponseProto struct {
	MessageStatus MessageStatus `protobuf:"varint,1,opt,name=message_status,json=messageStatus,proto3,enum=ms.MessageStatus" json:"message_status,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageResponseProto) Descriptor deprecated 

func (*MessageResponseProto) Descriptor() ([]byte, []int)

Deprecated: Use MessageResponseProto.ProtoReflect.Descriptor instead.

func (*MessageResponseProto) GetMessageStatus 

func (x *MessageResponseProto) GetMessageStatus() MessageStatus

func (*MessageResponseProto) ProtoMessage 

func (*MessageResponseProto) ProtoMessage()

func (*MessageResponseProto) ProtoReflect 

func (x *MessageResponseProto) ProtoReflect() protoreflect.Message

func (*MessageResponseProto) Reset 

func (x *MessageResponseProto) Reset()

func (*MessageResponseProto) String 

func (x *MessageResponseProto) String() string

type MessageStatus 

type MessageStatus int32
const (
	MessageStatus_FAIL    MessageStatus = 0
	MessageStatus_SUCCESS MessageStatus = 1
	MessageStatus_UNKNOWN MessageStatus = 2
)

func (MessageStatus) Descriptor 

func (MessageStatus) Descriptor() protoreflect.EnumDescriptor

func (MessageStatus) Enum 

func (x MessageStatus) Enum() *MessageStatus

func (MessageStatus) EnumDescriptor deprecated 

func (MessageStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageStatus.Descriptor instead.

func (MessageStatus) Number 

func (x MessageStatus) Number() protoreflect.EnumNumber

func (MessageStatus) String 

func (x MessageStatus) String() string

func (MessageStatus) Type 

func (MessageStatus) Type() protoreflect.EnumType

type StringStringMapProto 

type StringStringMapProto struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringStringMapProto) Descriptor deprecated 

func (*StringStringMapProto) Descriptor() ([]byte, []int)

Deprecated: Use StringStringMapProto.ProtoReflect.Descriptor instead.

func (*StringStringMapProto) GetKey 

func (x *StringStringMapProto) GetKey() string

func (*StringStringMapProto) GetValue 

func (x *StringStringMapProto) GetValue() string

func (*StringStringMapProto) ProtoMessage 

func (*StringStringMapProto) ProtoMessage()

func (*StringStringMapProto) ProtoReflect 

func (x *StringStringMapProto) ProtoReflect() protoreflect.Message

func (*StringStringMapProto) Reset 

func (x *StringStringMapProto) Reset()

func (*StringStringMapProto) String 

func (x *StringStringMapProto) String() string

type UnimplementedAgentServiceServer 

type UnimplementedAgentServiceServer struct {
}

UnimplementedAgentServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServiceServer) ChangeClusterState 

func (UnimplementedAgentServiceServer) ChangeClusterState(context.Context, *ClusterStateChangeMessageProto) (*MessageResponseProto, error)

func (UnimplementedAgentServiceServer) RegisterAck 

func (UnimplementedAgentServiceServer) RegisterAck(context.Context, *ClusterRegisterAckMessageProto) (*MessageResponseProto, error)

func (UnimplementedAgentServiceServer) RequireReRegister 

func (UnimplementedAgentServiceServer) RequireReRegister(context.Context, *ClusterReRegisterMessageProto) (*MessageResponseProto, error)

type UnsafeAgentServiceServer 

type UnsafeAgentServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.