protocol

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: May 30, 2022 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var MessageType_name = map[int32]string{
	0: "Frame",
	1: "Send",
	2: "Call",
	3: "Resp",
}
View Source 
var MessageType_value = map[string]int32{
	"Frame": 0,
	"Send":  1,
	"Call":  2,
	"Resp":  3,
}

Functions

This section is empty.

Types

type CallMessage added in v0.0.3 

type CallMessage struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

测试Call功能的消息结构

func (*CallMessage) Descriptor added in v0.0.3 

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

func (*CallMessage) GetData added in v0.0.3 

func (m *CallMessage) GetData() string

func (*CallMessage) Marshal added in v0.0.3 

func (m *CallMessage) Marshal() (dAtA []byte, err error)

func (*CallMessage) MarshalTo added in v0.0.3 

func (m *CallMessage) MarshalTo(dAtA []byte) (int, error)

func (*CallMessage) MarshalToSizedBuffer added in v0.0.3 

func (m *CallMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CallMessage) ProtoMessage added in v0.0.3 

func (*CallMessage) ProtoMessage()

func (*CallMessage) Reset added in v0.0.3 

func (m *CallMessage) Reset()

func (*CallMessage) Size added in v0.0.3 

func (m *CallMessage) Size() (n int)

func (*CallMessage) String added in v0.0.3 

func (m *CallMessage) String() string

func (*CallMessage) Unmarshal added in v0.0.3 

func (m *CallMessage) Unmarshal(dAtA []byte) error

func (*CallMessage) XXX_DiscardUnknown added in v0.0.3 

func (m *CallMessage) XXX_DiscardUnknown()

func (*CallMessage) XXX_Marshal added in v0.0.3 

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

func (*CallMessage) XXX_Merge added in v0.0.3 

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

func (*CallMessage) XXX_Size added in v0.0.3 

func (m *CallMessage) XXX_Size() int

func (*CallMessage) XXX_Unmarshal added in v0.0.3 

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

type CallTimeout added in v0.0.3 

type CallTimeout struct {
}

Call超时

func (*CallTimeout) Descriptor added in v0.0.3 

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

func (*CallTimeout) Marshal added in v0.0.3 

func (m *CallTimeout) Marshal() (dAtA []byte, err error)

func (*CallTimeout) MarshalTo added in v0.0.3 

func (m *CallTimeout) MarshalTo(dAtA []byte) (int, error)

func (*CallTimeout) MarshalToSizedBuffer added in v0.0.3 

func (m *CallTimeout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CallTimeout) ProtoMessage added in v0.0.3 

func (*CallTimeout) ProtoMessage()

func (*CallTimeout) Reset added in v0.0.3 

func (m *CallTimeout) Reset()

func (*CallTimeout) Size added in v0.0.3 

func (m *CallTimeout) Size() (n int)

func (*CallTimeout) String added in v0.0.3 

func (m *CallTimeout) String() string

func (*CallTimeout) Unmarshal added in v0.0.3 

func (m *CallTimeout) Unmarshal(dAtA []byte) error

func (*CallTimeout) XXX_DiscardUnknown added in v0.0.3 

func (m *CallTimeout) XXX_DiscardUnknown()

func (*CallTimeout) XXX_Marshal added in v0.0.3 

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

func (*CallTimeout) XXX_Merge added in v0.0.3 

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

func (*CallTimeout) XXX_Size added in v0.0.3 

func (m *CallTimeout) XXX_Size() int

func (*CallTimeout) XXX_Unmarshal added in v0.0.3 

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

type MessageType 

type MessageType int32
const (
	MessageType_Frame MessageType = 0
	MessageType_Send  MessageType = 1
	MessageType_Call  MessageType = 2
	MessageType_Resp  MessageType = 3
)

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

type RespMessage added in v0.0.3 

type RespMessage struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

测试Response功能的消息结构

func (*RespMessage) Descriptor added in v0.0.3 

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

func (*RespMessage) GetData added in v0.0.3 

func (m *RespMessage) GetData() string

func (*RespMessage) Marshal added in v0.0.3 

func (m *RespMessage) Marshal() (dAtA []byte, err error)

func (*RespMessage) MarshalTo added in v0.0.3 

func (m *RespMessage) MarshalTo(dAtA []byte) (int, error)

func (*RespMessage) MarshalToSizedBuffer added in v0.0.3 

func (m *RespMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespMessage) ProtoMessage added in v0.0.3 

func (*RespMessage) ProtoMessage()

func (*RespMessage) Reset added in v0.0.3 

func (m *RespMessage) Reset()

func (*RespMessage) Size added in v0.0.3 

func (m *RespMessage) Size() (n int)

func (*RespMessage) String added in v0.0.3 

func (m *RespMessage) String() string

func (*RespMessage) Unmarshal added in v0.0.3 

func (m *RespMessage) Unmarshal(dAtA []byte) error

func (*RespMessage) XXX_DiscardUnknown added in v0.0.3 

func (m *RespMessage) XXX_DiscardUnknown()

func (*RespMessage) XXX_Marshal added in v0.0.3 

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

func (*RespMessage) XXX_Merge added in v0.0.3 

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

func (*RespMessage) XXX_Size added in v0.0.3 

func (m *RespMessage) XXX_Size() int

func (*RespMessage) XXX_Unmarshal added in v0.0.3 

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

type SSMessage 

type SSMessage struct {
	Type        MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	Source      uint64      `protobuf:"fixed64,2,opt,name=source,proto3" json:"source,omitempty"`
	Destination uint64      `protobuf:"fixed64,3,opt,name=destination,proto3" json:"destination,omitempty"`
	Sequence    uint64      `protobuf:"fixed64,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Name        string      `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Body        []byte      `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
}

集群间通信消息结构

func (*SSMessage) Descriptor 

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

func (*SSMessage) GetBody 

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

func (*SSMessage) GetDestination 

func (m *SSMessage) GetDestination() uint64

func (*SSMessage) GetName 

func (m *SSMessage) GetName() string

func (*SSMessage) GetSequence 

func (m *SSMessage) GetSequence() uint64

func (*SSMessage) GetSource 

func (m *SSMessage) GetSource() uint64

func (*SSMessage) GetType 

func (m *SSMessage) GetType() MessageType

func (*SSMessage) Marshal 

func (m *SSMessage) Marshal() (dAtA []byte, err error)

func (*SSMessage) MarshalTo 

func (m *SSMessage) MarshalTo(dAtA []byte) (int, error)

func (*SSMessage) MarshalToSizedBuffer 

func (m *SSMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SSMessage) ProtoMessage 

func (*SSMessage) ProtoMessage()

func (*SSMessage) Reset 

func (m *SSMessage) Reset()

func (*SSMessage) Size 

func (m *SSMessage) Size() (n int)

func (*SSMessage) String 

func (m *SSMessage) String() string

func (*SSMessage) Unmarshal 

func (m *SSMessage) Unmarshal(dAtA []byte) error

func (*SSMessage) XXX_DiscardUnknown 

func (m *SSMessage) XXX_DiscardUnknown()

func (*SSMessage) XXX_Marshal 

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

func (*SSMessage) XXX_Merge 

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

func (*SSMessage) XXX_Size 

func (m *SSMessage) XXX_Size() int

func (*SSMessage) XXX_Unmarshal 

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

type SendMessage added in v0.0.3 

type SendMessage struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

测试Send功能的消息结构

func (*SendMessage) Descriptor added in v0.0.3 

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

func (*SendMessage) GetData added in v0.0.3 

func (m *SendMessage) GetData() string

func (*SendMessage) Marshal added in v0.0.3 

func (m *SendMessage) Marshal() (dAtA []byte, err error)

func (*SendMessage) MarshalTo added in v0.0.3 

func (m *SendMessage) MarshalTo(dAtA []byte) (int, error)

func (*SendMessage) MarshalToSizedBuffer added in v0.0.3 

func (m *SendMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SendMessage) ProtoMessage added in v0.0.3 

func (*SendMessage) ProtoMessage()

func (*SendMessage) Reset added in v0.0.3 

func (m *SendMessage) Reset()

func (*SendMessage) Size added in v0.0.3 

func (m *SendMessage) Size() (n int)

func (*SendMessage) String added in v0.0.3 

func (m *SendMessage) String() string

func (*SendMessage) Unmarshal added in v0.0.3 

func (m *SendMessage) Unmarshal(dAtA []byte) error

func (*SendMessage) XXX_DiscardUnknown added in v0.0.3 

func (m *SendMessage) XXX_DiscardUnknown()

func (*SendMessage) XXX_Marshal added in v0.0.3 

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

func (*SendMessage) XXX_Merge added in v0.0.3 

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

func (*SendMessage) XXX_Size added in v0.0.3 

func (m *SendMessage) XXX_Size() int

func (*SendMessage) XXX_Unmarshal added in v0.0.3 

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

type ServiceInfo 

type ServiceInfo struct {
	ID   uint64 `protobuf:"fixed64,1,opt,name=i_d,json=iD,proto3" json:"i_d,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

服务信息

func (*ServiceInfo) Descriptor 

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

func (*ServiceInfo) GetID 

func (m *ServiceInfo) GetID() uint64

func (*ServiceInfo) GetName 

func (m *ServiceInfo) GetName() string

func (*ServiceInfo) Marshal 

func (m *ServiceInfo) Marshal() (dAtA []byte, err error)

func (*ServiceInfo) MarshalTo 

func (m *ServiceInfo) MarshalTo(dAtA []byte) (int, error)

func (*ServiceInfo) MarshalToSizedBuffer 

func (m *ServiceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset 

func (m *ServiceInfo) Reset()

func (*ServiceInfo) Size 

func (m *ServiceInfo) Size() (n int)

func (*ServiceInfo) String 

func (m *ServiceInfo) String() string

func (*ServiceInfo) Unmarshal 

func (m *ServiceInfo) Unmarshal(dAtA []byte) error

func (*ServiceInfo) XXX_DiscardUnknown 

func (m *ServiceInfo) XXX_DiscardUnknown()

func (*ServiceInfo) XXX_Marshal 

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

func (*ServiceInfo) XXX_Merge 

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

func (*ServiceInfo) XXX_Size 

func (m *ServiceInfo) XXX_Size() int

func (*ServiceInfo) XXX_Unmarshal 

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

type ServiceLaunch 

type ServiceLaunch struct {
	Info *ServiceInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

服务启动

func (*ServiceLaunch) Descriptor 

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

func (*ServiceLaunch) GetInfo 

func (m *ServiceLaunch) GetInfo() *ServiceInfo

func (*ServiceLaunch) Marshal 

func (m *ServiceLaunch) Marshal() (dAtA []byte, err error)

func (*ServiceLaunch) MarshalTo 

func (m *ServiceLaunch) MarshalTo(dAtA []byte) (int, error)

func (*ServiceLaunch) MarshalToSizedBuffer 

func (m *ServiceLaunch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceLaunch) ProtoMessage 

func (*ServiceLaunch) ProtoMessage()

func (*ServiceLaunch) Reset 

func (m *ServiceLaunch) Reset()

func (*ServiceLaunch) Size 

func (m *ServiceLaunch) Size() (n int)

func (*ServiceLaunch) String 

func (m *ServiceLaunch) String() string

func (*ServiceLaunch) Unmarshal 

func (m *ServiceLaunch) Unmarshal(dAtA []byte) error

func (*ServiceLaunch) XXX_DiscardUnknown 

func (m *ServiceLaunch) XXX_DiscardUnknown()

func (*ServiceLaunch) XXX_Marshal 

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

func (*ServiceLaunch) XXX_Merge 

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

func (*ServiceLaunch) XXX_Size 

func (m *ServiceLaunch) XXX_Size() int

func (*ServiceLaunch) XXX_Unmarshal 

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

type ServiceList 

type ServiceList struct {
	ServiceList []*ServiceInfo `protobuf:"bytes,1,rep,name=service_list,json=serviceList,proto3" json:"service_list,omitempty"`
}

服务列表同步

func (*ServiceList) Descriptor 

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

func (*ServiceList) GetServiceList 

func (m *ServiceList) GetServiceList() []*ServiceInfo

func (*ServiceList) Marshal 

func (m *ServiceList) Marshal() (dAtA []byte, err error)

func (*ServiceList) MarshalTo 

func (m *ServiceList) MarshalTo(dAtA []byte) (int, error)

func (*ServiceList) MarshalToSizedBuffer 

func (m *ServiceList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceList) ProtoMessage 

func (*ServiceList) ProtoMessage()

func (*ServiceList) Reset 

func (m *ServiceList) Reset()

func (*ServiceList) Size 

func (m *ServiceList) Size() (n int)

func (*ServiceList) String 

func (m *ServiceList) String() string

func (*ServiceList) Unmarshal 

func (m *ServiceList) Unmarshal(dAtA []byte) error

func (*ServiceList) XXX_DiscardUnknown 

func (m *ServiceList) XXX_DiscardUnknown()

func (*ServiceList) XXX_Marshal 

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

func (*ServiceList) XXX_Merge 

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

func (*ServiceList) XXX_Size 

func (m *ServiceList) XXX_Size() int

func (*ServiceList) XXX_Unmarshal 

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

type ServiceShutdown 

type ServiceShutdown struct {
	Info *ServiceInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

服务关闭

func (*ServiceShutdown) Descriptor 

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

func (*ServiceShutdown) GetInfo 

func (m *ServiceShutdown) GetInfo() *ServiceInfo

func (*ServiceShutdown) Marshal 

func (m *ServiceShutdown) Marshal() (dAtA []byte, err error)

func (*ServiceShutdown) MarshalTo 

func (m *ServiceShutdown) MarshalTo(dAtA []byte) (int, error)

func (*ServiceShutdown) MarshalToSizedBuffer 

func (m *ServiceShutdown) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceShutdown) ProtoMessage 

func (*ServiceShutdown) ProtoMessage()

func (*ServiceShutdown) Reset 

func (m *ServiceShutdown) Reset()

func (*ServiceShutdown) Size 

func (m *ServiceShutdown) Size() (n int)

func (*ServiceShutdown) String 

func (m *ServiceShutdown) String() string

func (*ServiceShutdown) Unmarshal 

func (m *ServiceShutdown) Unmarshal(dAtA []byte) error

func (*ServiceShutdown) XXX_DiscardUnknown 

func (m *ServiceShutdown) XXX_DiscardUnknown()

func (*ServiceShutdown) XXX_Marshal 

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

func (*ServiceShutdown) XXX_Merge 

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

func (*ServiceShutdown) XXX_Size 

func (m *ServiceShutdown) XXX_Size() int

func (*ServiceShutdown) XXX_Unmarshal 

func (m *ServiceShutdown) 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.