Versions in this module Expand all Collapse all v0 v0.1.0 Nov 28, 2019 Changes in this version + var CommandType_name = map[int32]string + var CommandType_value = map[string]int32 + type ClusterMessage struct + Body []byte + Head *MessageHead + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterMessage) Descriptor() ([]byte, []int) + func (*ClusterMessage) ProtoMessage() + func (c *ClusterMessage) Deserialize(data []byte) error + func (c *ClusterMessage) Serialize() ([]byte, error) + func (m *ClusterMessage) GetBody() []byte + func (m *ClusterMessage) GetHead() *MessageHead + func (m *ClusterMessage) Reset() + func (m *ClusterMessage) String() string + func (m *ClusterMessage) XXX_DiscardUnknown() + func (m *ClusterMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterMessage) XXX_Merge(src proto.Message) + func (m *ClusterMessage) XXX_Size() int + func (m *ClusterMessage) XXX_Unmarshal(b []byte) error + type CommandType int32 + const CommandType_ClusterRegist + const CommandType_ClusterUnregist + const CommandType_ControlMultiReq + const CommandType_ControlReq + const CommandType_ControlResp + const CommandType_DeployReq + const CommandType_DeployResp + const CommandType_EdgeReport + const CommandType_NeighborRoute + const CommandType_Reserved + const CommandType_SubTreeRoute + func (CommandType) EnumDescriptor() ([]byte, []int) + func (x CommandType) String() string + type ControlMultiTask struct + Body [][]byte + Destination string + Method string + URI string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ControlMultiTask) Descriptor() ([]byte, []int) + func (*ControlMultiTask) ProtoMessage() + func (c *ControlMultiTask) ToClusterMessage(head *MessageHead) (*ClusterMessage, error) + func (m *ControlMultiTask) GetBody() [][]byte + func (m *ControlMultiTask) GetDestination() string + func (m *ControlMultiTask) GetMethod() string + func (m *ControlMultiTask) GetURI() string + func (m *ControlMultiTask) Reset() + func (m *ControlMultiTask) String() string + func (m *ControlMultiTask) XXX_DiscardUnknown() + func (m *ControlMultiTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ControlMultiTask) XXX_Merge(src proto.Message) + func (m *ControlMultiTask) XXX_Size() int + func (m *ControlMultiTask) XXX_Unmarshal(b []byte) error + type ControllerTask struct + Body []byte + Destination string + Method string + URI string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ControllerTask) Descriptor() ([]byte, []int) + func (*ControllerTask) ProtoMessage() + func (c *ControllerTask) ToClusterMessage(head *MessageHead) (*ClusterMessage, error) + func (m *ControllerTask) GetBody() []byte + func (m *ControllerTask) GetDestination() string + func (m *ControllerTask) GetMethod() string + func (m *ControllerTask) GetURI() string + func (m *ControllerTask) Reset() + func (m *ControllerTask) String() string + func (m *ControllerTask) XXX_DiscardUnknown() + func (m *ControllerTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ControllerTask) XXX_Merge(src proto.Message) + func (m *ControllerTask) XXX_Size() int + func (m *ControllerTask) XXX_Unmarshal(b []byte) error + type ControllerTaskResponse struct + Body []byte + StatusCode int32 + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ControllerTaskResponse) Descriptor() ([]byte, []int) + func (*ControllerTaskResponse) ProtoMessage() + func (m *ControllerTaskResponse) GetBody() []byte + func (m *ControllerTaskResponse) GetStatusCode() int32 + func (m *ControllerTaskResponse) GetTimestamp() int64 + func (m *ControllerTaskResponse) Reset() + func (m *ControllerTaskResponse) String() string + func (m *ControllerTaskResponse) XXX_DiscardUnknown() + func (m *ControllerTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ControllerTaskResponse) XXX_Merge(src proto.Message) + func (m *ControllerTaskResponse) XXX_Size() int + func (m *ControllerTaskResponse) XXX_Unmarshal(b []byte) error + type DeployTask struct + PodParams map[string]string + Replicas int32 + Status string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeployTask) Descriptor() ([]byte, []int) + func (*DeployTask) ProtoMessage() + func (m *DeployTask) GetPodParams() map[string]string + func (m *DeployTask) GetReplicas() int32 + func (m *DeployTask) GetStatus() string + func (m *DeployTask) Reset() + func (m *DeployTask) String() string + func (m *DeployTask) XXX_DiscardUnknown() + func (m *DeployTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeployTask) XXX_Merge(src proto.Message) + func (m *DeployTask) XXX_Size() int + func (m *DeployTask) XXX_Unmarshal(b []byte) error + type MessageHead struct + ClusterName string + ClusterSelector string + Command CommandType + MessageID string + ParentClusterName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MessageHead) Descriptor() ([]byte, []int) + func (*MessageHead) ProtoMessage() + func (m *MessageHead) GetClusterName() string + func (m *MessageHead) GetClusterSelector() string + func (m *MessageHead) GetCommand() CommandType + func (m *MessageHead) GetMessageID() string + func (m *MessageHead) GetParentClusterName() string + func (m *MessageHead) Reset() + func (m *MessageHead) String() string + func (m *MessageHead) XXX_DiscardUnknown() + func (m *MessageHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MessageHead) XXX_Merge(src proto.Message) + func (m *MessageHead) XXX_Size() int + func (m *MessageHead) XXX_Unmarshal(b []byte) error
Go to main page