clustermessage

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CommandType_name = map[int32]string{
	0:  "Reserved",
	1:  "ClusterRegist",
	2:  "ClusterUnregist",
	3:  "NeighborRoute",
	4:  "SubTreeRoute",
	5:  "DeployReq",
	6:  "DeployResp",
	7:  "ControlReq",
	8:  "ControlResp",
	9:  "EdgeReport",
	10: "ControlMultiReq",
}
View Source 
var CommandType_value = map[string]int32{
	"Reserved":        0,
	"ClusterRegist":   1,
	"ClusterUnregist": 2,
	"NeighborRoute":   3,
	"SubTreeRoute":    4,
	"DeployReq":       5,
	"DeployResp":      6,
	"ControlReq":      7,
	"ControlResp":     8,
	"EdgeReport":      9,
	"ControlMultiReq": 10,
}

Functions

This section is empty.

Types

type ClusterMessage 

type ClusterMessage struct {
	Head                 *MessageHead `protobuf:"bytes,1,opt,name=Head,proto3" json:"Head,omitempty"`
	Body                 []byte       `protobuf:"bytes,2,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ClusterMessage is the message between cluster controllers and maybe cc and cluster shim.

func (*ClusterMessage) Descriptor 

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

func (*ClusterMessage) Deserialize 

func (c *ClusterMessage) Deserialize(data []byte) error

Deserialize deserializes data to a ClusterMessage, and return nil if no error.

func (*ClusterMessage) GetBody 

func (m *ClusterMessage) GetBody() []byte

func (*ClusterMessage) GetHead 

func (m *ClusterMessage) GetHead() *MessageHead

func (*ClusterMessage) ProtoMessage 

func (*ClusterMessage) ProtoMessage()

func (*ClusterMessage) Reset 

func (m *ClusterMessage) Reset()

func (*ClusterMessage) Serialize 

func (c *ClusterMessage) Serialize() ([]byte, error)

Serialize serializes a ClusterMessage to []byte, and return nil error if no error.

func (*ClusterMessage) String 

func (m *ClusterMessage) String() string

func (*ClusterMessage) XXX_DiscardUnknown 

func (m *ClusterMessage) XXX_DiscardUnknown()

func (*ClusterMessage) XXX_Marshal 

func (m *ClusterMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterMessage) XXX_Merge 

func (m *ClusterMessage) XXX_Merge(src proto.Message)

func (*ClusterMessage) XXX_Size 

func (m *ClusterMessage) XXX_Size() int

func (*ClusterMessage) XXX_Unmarshal 

func (m *ClusterMessage) XXX_Unmarshal(b []byte) error

type CommandType 

type CommandType int32
const (
	CommandType_Reserved        CommandType = 0
	CommandType_ClusterRegist   CommandType = 1
	CommandType_ClusterUnregist CommandType = 2
	CommandType_NeighborRoute   CommandType = 3
	CommandType_SubTreeRoute    CommandType = 4
	CommandType_DeployReq       CommandType = 5
	CommandType_DeployResp      CommandType = 6
	CommandType_ControlReq      CommandType = 7
	CommandType_ControlResp     CommandType = 8
	CommandType_EdgeReport      CommandType = 9
	CommandType_ControlMultiReq CommandType = 10
)

func (CommandType) EnumDescriptor 

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

func (CommandType) String 

func (x CommandType) String() string

type ControlMultiTask 

type ControlMultiTask struct {
	Destination          string   `protobuf:"bytes,1,opt,name=Destination,proto3" json:"Destination,omitempty"`
	Method               string   `protobuf:"bytes,2,opt,name=Method,proto3" json:"Method,omitempty"`
	URI                  string   `protobuf:"bytes,3,opt,name=URI,proto3" json:"URI,omitempty"`
	Body                 [][]byte `protobuf:"bytes,4,rep,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControlMultiTask) Descriptor 

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

func (*ControlMultiTask) GetBody 

func (m *ControlMultiTask) GetBody() [][]byte

func (*ControlMultiTask) GetDestination 

func (m *ControlMultiTask) GetDestination() string

func (*ControlMultiTask) GetMethod 

func (m *ControlMultiTask) GetMethod() string

func (*ControlMultiTask) GetURI 

func (m *ControlMultiTask) GetURI() string

func (*ControlMultiTask) ProtoMessage 

func (*ControlMultiTask) ProtoMessage()

func (*ControlMultiTask) Reset 

func (m *ControlMultiTask) Reset()

func (*ControlMultiTask) String 

func (m *ControlMultiTask) String() string

func (*ControlMultiTask) ToClusterMessage 

func (c *ControlMultiTask) ToClusterMessage(head *MessageHead) (*ClusterMessage, error)

ToClusterMessage makes ControlMultiTask to ClusterMessage.

func (*ControlMultiTask) XXX_DiscardUnknown 

func (m *ControlMultiTask) XXX_DiscardUnknown()

func (*ControlMultiTask) XXX_Marshal 

func (m *ControlMultiTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlMultiTask) XXX_Merge 

func (m *ControlMultiTask) XXX_Merge(src proto.Message)

func (*ControlMultiTask) XXX_Size 

func (m *ControlMultiTask) XXX_Size() int

func (*ControlMultiTask) XXX_Unmarshal 

func (m *ControlMultiTask) XXX_Unmarshal(b []byte) error

type ControllerTask 

type ControllerTask struct {
	Destination          string   `protobuf:"bytes,1,opt,name=Destination,proto3" json:"Destination,omitempty"`
	Method               string   `protobuf:"bytes,2,opt,name=Method,proto3" json:"Method,omitempty"`
	URI                  string   `protobuf:"bytes,3,opt,name=URI,proto3" json:"URI,omitempty"`
	Body                 []byte   `protobuf:"bytes,4,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControllerTask) Descriptor 

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

func (*ControllerTask) GetBody 

func (m *ControllerTask) GetBody() []byte

func (*ControllerTask) GetDestination 

func (m *ControllerTask) GetDestination() string

func (*ControllerTask) GetMethod 

func (m *ControllerTask) GetMethod() string

func (*ControllerTask) GetURI 

func (m *ControllerTask) GetURI() string

func (*ControllerTask) ProtoMessage 

func (*ControllerTask) ProtoMessage()

func (*ControllerTask) Reset 

func (m *ControllerTask) Reset()

func (*ControllerTask) String 

func (m *ControllerTask) String() string

func (*ControllerTask) ToClusterMessage 

func (c *ControllerTask) ToClusterMessage(head *MessageHead) (*ClusterMessage, error)

ToClusterMessage makes ControllerTask to ClusterMessage.

func (*ControllerTask) XXX_DiscardUnknown 

func (m *ControllerTask) XXX_DiscardUnknown()

func (*ControllerTask) XXX_Marshal 

func (m *ControllerTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerTask) XXX_Merge 

func (m *ControllerTask) XXX_Merge(src proto.Message)

func (*ControllerTask) XXX_Size 

func (m *ControllerTask) XXX_Size() int

func (*ControllerTask) XXX_Unmarshal 

func (m *ControllerTask) XXX_Unmarshal(b []byte) error

type ControllerTaskResponse 

type ControllerTaskResponse struct {
	Timestamp            int64    `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	StatusCode           int32    `protobuf:"varint,2,opt,name=StatusCode,proto3" json:"StatusCode,omitempty"`
	Body                 []byte   `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControllerTaskResponse) Descriptor 

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

func (*ControllerTaskResponse) GetBody 

func (m *ControllerTaskResponse) GetBody() []byte

func (*ControllerTaskResponse) GetStatusCode 

func (m *ControllerTaskResponse) GetStatusCode() int32

func (*ControllerTaskResponse) GetTimestamp 

func (m *ControllerTaskResponse) GetTimestamp() int64

func (*ControllerTaskResponse) ProtoMessage 

func (*ControllerTaskResponse) ProtoMessage()

func (*ControllerTaskResponse) Reset 

func (m *ControllerTaskResponse) Reset()

func (*ControllerTaskResponse) String 

func (m *ControllerTaskResponse) String() string

func (*ControllerTaskResponse) XXX_DiscardUnknown 

func (m *ControllerTaskResponse) XXX_DiscardUnknown()

func (*ControllerTaskResponse) XXX_Marshal 

func (m *ControllerTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerTaskResponse) XXX_Merge 

func (m *ControllerTaskResponse) XXX_Merge(src proto.Message)

func (*ControllerTaskResponse) XXX_Size 

func (m *ControllerTaskResponse) XXX_Size() int

func (*ControllerTaskResponse) XXX_Unmarshal 

func (m *ControllerTaskResponse) XXX_Unmarshal(b []byte) error

type DeployTask 

type DeployTask struct {
	Replicas             int32             `protobuf:"varint,1,opt,name=Replicas,proto3" json:"Replicas,omitempty"`
	PodParams            map[string]string `` /* 159-byte string literal not displayed */
	Status               string            `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DeployTask) Descriptor 

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

func (*DeployTask) GetPodParams 

func (m *DeployTask) GetPodParams() map[string]string

func (*DeployTask) GetReplicas 

func (m *DeployTask) GetReplicas() int32

func (*DeployTask) GetStatus 

func (m *DeployTask) GetStatus() string

func (*DeployTask) ProtoMessage 

func (*DeployTask) ProtoMessage()

func (*DeployTask) Reset 

func (m *DeployTask) Reset()

func (*DeployTask) String 

func (m *DeployTask) String() string

func (*DeployTask) XXX_DiscardUnknown 

func (m *DeployTask) XXX_DiscardUnknown()

func (*DeployTask) XXX_Marshal 

func (m *DeployTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeployTask) XXX_Merge 

func (m *DeployTask) XXX_Merge(src proto.Message)

func (*DeployTask) XXX_Size 

func (m *DeployTask) XXX_Size() int

func (*DeployTask) XXX_Unmarshal 

func (m *DeployTask) XXX_Unmarshal(b []byte) error

type MessageHead 

type MessageHead struct {
	// MessageID is the uuid of a cluster message.
	// if the message comes from a crd, the messageid is the name of the crd.
	MessageID            string      `protobuf:"bytes,1,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	Command              CommandType `protobuf:"varint,2,opt,name=Command,proto3,enum=clustermessage.CommandType" json:"Command,omitempty"`
	ClusterSelector      string      `protobuf:"bytes,3,opt,name=ClusterSelector,proto3" json:"ClusterSelector,omitempty"`
	ClusterName          string      `protobuf:"bytes,4,opt,name=ClusterName,proto3" json:"ClusterName,omitempty"`
	ParentClusterName    string      `protobuf:"bytes,5,opt,name=ParentClusterName,proto3" json:"ParentClusterName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*MessageHead) Descriptor 

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

func (*MessageHead) GetClusterName 

func (m *MessageHead) GetClusterName() string

func (*MessageHead) GetClusterSelector 

func (m *MessageHead) GetClusterSelector() string

func (*MessageHead) GetCommand 

func (m *MessageHead) GetCommand() CommandType

func (*MessageHead) GetMessageID 

func (m *MessageHead) GetMessageID() string

func (*MessageHead) GetParentClusterName 

func (m *MessageHead) GetParentClusterName() string

func (*MessageHead) ProtoMessage 

func (*MessageHead) ProtoMessage()

func (*MessageHead) Reset 

func (m *MessageHead) Reset()

func (*MessageHead) String 

func (m *MessageHead) String() string

func (*MessageHead) XXX_DiscardUnknown 

func (m *MessageHead) XXX_DiscardUnknown()

func (*MessageHead) XXX_Marshal 

func (m *MessageHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageHead) XXX_Merge 

func (m *MessageHead) XXX_Merge(src proto.Message)

func (*MessageHead) XXX_Size 

func (m *MessageHead) XXX_Size() int

func (*MessageHead) XXX_Unmarshal 

func (m *MessageHead) XXX_Unmarshal(b []byte) error

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.