protocol

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2021 License: BSD-3-Clause Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	InstanceAuto = 0          // 自动分配实例
	InstanceAll  = 0xFF       // 选取所有实例
	DistrictAll  = 0x0FFF     // 所有区服
	SessionAll   = 0xFFFFFFFF // 广播给所有session
	ServiceAll   = 0xFF       // 所有服务
)
View Source 
const (
	ErrDataCodecFailure      = 106 // 数据编码错误
	ErrRpcTimeout            = 108 // RPC超时
	ErrDuplicateRegistration = 201 // 服务重复注册
	ErrRegistrationDenied    = 202 // 服务注册被拒绝
)

与errno.proto一致

Variables

View Source 
var (
	ErrInvalidLengthInternalMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInternalMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupInternalMsg = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthInternalStruct        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInternalStruct          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupInternalStruct = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var InternalMsgType_name = map[int32]string{
	0:   "MSG_INTERNAL_RESERVED",
	101: "MSG_INTERNAL_KEEP_ALIVE",
	102: "MSG_INTERNAL_KEEP_ALIVE_STATUS",
	103: "MSG_INTERNAL_INSTANCE_STATE_NOTIFY",
	104: "MSG_INTERNAL_REGISTER",
	105: "MSG_INTERNAL_REGISTER_STATUS",
	106: "MSG_INTERNAL_INTRODUCE",
	107: "MSG_INTERNAL_INTRODUCE_STATUS",
	123: "MSG_INTERNAL_SUBSCRIBE",
	124: "MSG_INTERNAL_SUBSCRIBE_STATUS",
}
View Source 
var InternalMsgType_value = map[string]int32{
	"MSG_INTERNAL_RESERVED":              0,
	"MSG_INTERNAL_KEEP_ALIVE":            101,
	"MSG_INTERNAL_KEEP_ALIVE_STATUS":     102,
	"MSG_INTERNAL_INSTANCE_STATE_NOTIFY": 103,
	"MSG_INTERNAL_REGISTER":              104,
	"MSG_INTERNAL_REGISTER_STATUS":       105,
	"MSG_INTERNAL_INTRODUCE":             106,
	"MSG_INTERNAL_INTRODUCE_STATUS":      107,
	"MSG_INTERNAL_SUBSCRIBE":             123,
	"MSG_INTERNAL_SUBSCRIBE_STATUS":      124,
}
View Source 
var NodeState_name = map[int32]string{
	0: "StateDown",
	1: "StateUp",
}
View Source 
var NodeState_value = map[string]int32{
	"StateDown": 0,
	"StateUp":   1,
}

Functions

func CreateMessageBy 

func CreateMessageBy(msgId int32) proto.Message

根据消息ID创建message

func GetMessageIDOf 

func GetMessageIDOf(msg proto.Message) int32

根据message获取消息ID

func InitMsgRegistry added in v1.0.2 

func InitMsgRegistry(ext *proto.ExtensionDesc, pbFiles ...string)

注册消息反射

func RetrieveFileMessages added in v1.0.2 

func RetrieveFileMessages(ext *proto.ExtensionDesc, filename string) error

根据反射拿到每一个Message的消息ID

Types

type InstanceStateNtf added in v1.0.2 

type InstanceStateNtf struct {
	State NodeState `protobuf:"varint,1,opt,name=state,proto3,enum=protocol.NodeState" json:"state,omitempty"`
	Peers []uint32  `protobuf:"varint,2,rep,packed,name=peers,proto3" json:"peers,omitempty"`
}

节点状态变化通知

func (*InstanceStateNtf) Descriptor added in v1.0.2 

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

func (*InstanceStateNtf) GetPeers added in v1.0.2 

func (m *InstanceStateNtf) GetPeers() []uint32

func (*InstanceStateNtf) GetState added in v1.0.2 

func (m *InstanceStateNtf) GetState() NodeState

func (*InstanceStateNtf) Marshal added in v1.0.2 

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

func (*InstanceStateNtf) MarshalTo added in v1.0.2 

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

func (*InstanceStateNtf) MarshalToSizedBuffer added in v1.0.2 

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

func (*InstanceStateNtf) ProtoMessage added in v1.0.2 

func (*InstanceStateNtf) ProtoMessage()

func (*InstanceStateNtf) Reset added in v1.0.2 

func (m *InstanceStateNtf) Reset()

func (*InstanceStateNtf) Size added in v1.0.2 

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

func (*InstanceStateNtf) String added in v1.0.2 

func (m *InstanceStateNtf) String() string

func (*InstanceStateNtf) Unmarshal added in v1.0.2 

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

func (*InstanceStateNtf) XXX_DiscardUnknown added in v1.0.2 

func (m *InstanceStateNtf) XXX_DiscardUnknown()

func (*InstanceStateNtf) XXX_Marshal added in v1.0.2 

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

func (*InstanceStateNtf) XXX_Merge added in v1.0.2 

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

func (*InstanceStateNtf) XXX_Size added in v1.0.2 

func (m *InstanceStateNtf) XXX_Size() int

func (*InstanceStateNtf) XXX_Unmarshal added in v1.0.2 

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

type InternalMsgType added in v1.0.2 

type InternalMsgType int32

内部通信协议 [100 - 1000) 

const (
	MSG_INTERNAL_RESERVED              InternalMsgType = 0
	MSG_INTERNAL_KEEP_ALIVE            InternalMsgType = 101
	MSG_INTERNAL_KEEP_ALIVE_STATUS     InternalMsgType = 102
	MSG_INTERNAL_INSTANCE_STATE_NOTIFY InternalMsgType = 103
	MSG_INTERNAL_REGISTER              InternalMsgType = 104
	MSG_INTERNAL_REGISTER_STATUS       InternalMsgType = 105
	MSG_INTERNAL_INTRODUCE             InternalMsgType = 106
	MSG_INTERNAL_INTRODUCE_STATUS      InternalMsgType = 107
	MSG_INTERNAL_SUBSCRIBE             InternalMsgType = 123
	MSG_INTERNAL_SUBSCRIBE_STATUS      InternalMsgType = 124
)

func (InternalMsgType) EnumDescriptor added in v1.0.2 

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

func (InternalMsgType) String added in v1.0.2 

func (x InternalMsgType) String() string

type KeepAliveAck added in v1.0.2 

type KeepAliveAck struct {
	Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
}

func (*KeepAliveAck) Descriptor added in v1.0.2 

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

func (*KeepAliveAck) GetTime added in v1.0.2 

func (m *KeepAliveAck) GetTime() int64

func (*KeepAliveAck) Marshal added in v1.0.2 

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

func (*KeepAliveAck) MarshalTo added in v1.0.2 

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

func (*KeepAliveAck) MarshalToSizedBuffer added in v1.0.2 

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

func (*KeepAliveAck) ProtoMessage added in v1.0.2 

func (*KeepAliveAck) ProtoMessage()

func (*KeepAliveAck) Reset added in v1.0.2 

func (m *KeepAliveAck) Reset()

func (*KeepAliveAck) Size added in v1.0.2 

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

func (*KeepAliveAck) String added in v1.0.2 

func (m *KeepAliveAck) String() string

func (*KeepAliveAck) Unmarshal added in v1.0.2 

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

func (*KeepAliveAck) XXX_DiscardUnknown added in v1.0.2 

func (m *KeepAliveAck) XXX_DiscardUnknown()

func (*KeepAliveAck) XXX_Marshal added in v1.0.2 

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

func (*KeepAliveAck) XXX_Merge added in v1.0.2 

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

func (*KeepAliveAck) XXX_Size added in v1.0.2 

func (m *KeepAliveAck) XXX_Size() int

func (*KeepAliveAck) XXX_Unmarshal added in v1.0.2 

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

type KeepAliveReq added in v1.0.2 

type KeepAliveReq struct {
	Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Load int64 `protobuf:"varint,2,opt,name=load,proto3" json:"load,omitempty"`
}

心跳

func (*KeepAliveReq) Descriptor added in v1.0.2 

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

func (*KeepAliveReq) GetLoad added in v1.0.2 

func (m *KeepAliveReq) GetLoad() int64

func (*KeepAliveReq) GetTime added in v1.0.2 

func (m *KeepAliveReq) GetTime() int64

func (*KeepAliveReq) Marshal added in v1.0.2 

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

func (*KeepAliveReq) MarshalTo added in v1.0.2 

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

func (*KeepAliveReq) MarshalToSizedBuffer added in v1.0.2 

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

func (*KeepAliveReq) ProtoMessage added in v1.0.2 

func (*KeepAliveReq) ProtoMessage()

func (*KeepAliveReq) Reset added in v1.0.2 

func (m *KeepAliveReq) Reset()

func (*KeepAliveReq) Size added in v1.0.2 

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

func (*KeepAliveReq) String added in v1.0.2 

func (m *KeepAliveReq) String() string

func (*KeepAliveReq) Unmarshal added in v1.0.2 

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

func (*KeepAliveReq) XXX_DiscardUnknown added in v1.0.2 

func (m *KeepAliveReq) XXX_DiscardUnknown()

func (*KeepAliveReq) XXX_Marshal added in v1.0.2 

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

func (*KeepAliveReq) XXX_Merge added in v1.0.2 

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

func (*KeepAliveReq) XXX_Size added in v1.0.2 

func (m *KeepAliveReq) XXX_Size() int

func (*KeepAliveReq) XXX_Unmarshal added in v1.0.2 

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

type NodeInfo added in v1.0.2 

type NodeInfo struct {
	Node      uint32 `protobuf:"varint,1,opt,name=node,proto3" json:"node,omitempty"`
	Interface string `protobuf:"bytes,2,opt,name=interface,proto3" json:"interface,omitempty"`
}

节点信息

func (*NodeInfo) Descriptor added in v1.0.2 

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

func (*NodeInfo) GetInterface added in v1.0.2 

func (m *NodeInfo) GetInterface() string

func (*NodeInfo) GetNode added in v1.0.2 

func (m *NodeInfo) GetNode() uint32

func (*NodeInfo) Marshal added in v1.0.2 

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

func (*NodeInfo) MarshalTo added in v1.0.2 

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

func (*NodeInfo) MarshalToSizedBuffer added in v1.0.2 

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

func (*NodeInfo) ProtoMessage added in v1.0.2 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset added in v1.0.2 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size added in v1.0.2 

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

func (*NodeInfo) String added in v1.0.2 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal added in v1.0.2 

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

func (*NodeInfo) XXX_DiscardUnknown added in v1.0.2 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal added in v1.0.2 

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

func (*NodeInfo) XXX_Merge added in v1.0.2 

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

func (*NodeInfo) XXX_Size added in v1.0.2 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal added in v1.0.2 

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

type NodeState added in v1.0.2 

type NodeState int32

节点状态 

const (
	StateDown NodeState = 0
	StateUp   NodeState = 1
)

func (NodeState) EnumDescriptor added in v1.0.2 

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

func (NodeState) String added in v1.0.2 

func (x NodeState) String() string

type RegisterAck added in v1.0.2 

type RegisterAck struct {
	Node uint32 `protobuf:"varint,2,opt,name=node,proto3" json:"node,omitempty"`
}

func (*RegisterAck) Descriptor added in v1.0.2 

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

func (*RegisterAck) GetNode added in v1.0.2 

func (m *RegisterAck) GetNode() uint32

func (*RegisterAck) Marshal added in v1.0.2 

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

func (*RegisterAck) MarshalTo added in v1.0.2 

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

func (*RegisterAck) MarshalToSizedBuffer added in v1.0.2 

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

func (*RegisterAck) ProtoMessage added in v1.0.2 

func (*RegisterAck) ProtoMessage()

func (*RegisterAck) Reset added in v1.0.2 

func (m *RegisterAck) Reset()

func (*RegisterAck) Size added in v1.0.2 

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

func (*RegisterAck) String added in v1.0.2 

func (m *RegisterAck) String() string

func (*RegisterAck) Unmarshal added in v1.0.2 

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

func (*RegisterAck) XXX_DiscardUnknown added in v1.0.2 

func (m *RegisterAck) XXX_DiscardUnknown()

func (*RegisterAck) XXX_Marshal added in v1.0.2 

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

func (*RegisterAck) XXX_Merge added in v1.0.2 

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

func (*RegisterAck) XXX_Size added in v1.0.2 

func (m *RegisterAck) XXX_Size() int

func (*RegisterAck) XXX_Unmarshal added in v1.0.2 

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

type RegisterReq added in v1.0.2 

type RegisterReq struct {
	AccessToken     string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	Node            uint32 `protobuf:"varint,2,opt,name=node,proto3" json:"node,omitempty"`
	IsCrossDistrict bool   `protobuf:"varint,4,opt,name=is_cross_district,json=isCrossDistrict,proto3" json:"is_cross_district,omitempty"`
}

注册节点

func (*RegisterReq) Descriptor added in v1.0.2 

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

func (*RegisterReq) GetAccessToken added in v1.0.2 

func (m *RegisterReq) GetAccessToken() string

func (*RegisterReq) GetIsCrossDistrict added in v1.0.2 

func (m *RegisterReq) GetIsCrossDistrict() bool

func (*RegisterReq) GetNode added in v1.0.2 

func (m *RegisterReq) GetNode() uint32

func (*RegisterReq) Marshal added in v1.0.2 

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

func (*RegisterReq) MarshalTo added in v1.0.2 

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

func (*RegisterReq) MarshalToSizedBuffer added in v1.0.2 

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

func (*RegisterReq) ProtoMessage added in v1.0.2 

func (*RegisterReq) ProtoMessage()

func (*RegisterReq) Reset added in v1.0.2 

func (m *RegisterReq) Reset()

func (*RegisterReq) Size added in v1.0.2 

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

func (*RegisterReq) String added in v1.0.2 

func (m *RegisterReq) String() string

func (*RegisterReq) Unmarshal added in v1.0.2 

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

func (*RegisterReq) XXX_DiscardUnknown added in v1.0.2 

func (m *RegisterReq) XXX_DiscardUnknown()

func (*RegisterReq) XXX_Marshal added in v1.0.2 

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

func (*RegisterReq) XXX_Merge added in v1.0.2 

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

func (*RegisterReq) XXX_Size added in v1.0.2 

func (m *RegisterReq) XXX_Size() int

func (*RegisterReq) XXX_Unmarshal added in v1.0.2 

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

type SubscribeAck added in v1.0.2 

type SubscribeAck struct {
}

func (*SubscribeAck) Descriptor added in v1.0.2 

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

func (*SubscribeAck) Marshal added in v1.0.2 

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

func (*SubscribeAck) MarshalTo added in v1.0.2 

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

func (*SubscribeAck) MarshalToSizedBuffer added in v1.0.2 

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

func (*SubscribeAck) ProtoMessage added in v1.0.2 

func (*SubscribeAck) ProtoMessage()

func (*SubscribeAck) Reset added in v1.0.2 

func (m *SubscribeAck) Reset()

func (*SubscribeAck) Size added in v1.0.2 

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

func (*SubscribeAck) String added in v1.0.2 

func (m *SubscribeAck) String() string

func (*SubscribeAck) Unmarshal added in v1.0.2 

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

func (*SubscribeAck) XXX_DiscardUnknown added in v1.0.2 

func (m *SubscribeAck) XXX_DiscardUnknown()

func (*SubscribeAck) XXX_Marshal added in v1.0.2 

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

func (*SubscribeAck) XXX_Merge added in v1.0.2 

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

func (*SubscribeAck) XXX_Size added in v1.0.2 

func (m *SubscribeAck) XXX_Size() int

func (*SubscribeAck) XXX_Unmarshal added in v1.0.2 

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

type SubscribeReq added in v1.0.2 

type SubscribeReq struct {
	MsgStart int32 `protobuf:"varint,1,opt,name=msg_start,json=msgStart,proto3" json:"msg_start,omitempty"`
	MsgEnd   int32 `protobuf:"varint,2,opt,name=msg_end,json=msgEnd,proto3" json:"msg_end,omitempty"`
}

订阅消息处理

func (*SubscribeReq) Descriptor added in v1.0.2 

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

func (*SubscribeReq) GetMsgEnd added in v1.0.2 

func (m *SubscribeReq) GetMsgEnd() int32

func (*SubscribeReq) GetMsgStart added in v1.0.2 

func (m *SubscribeReq) GetMsgStart() int32

func (*SubscribeReq) Marshal added in v1.0.2 

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

func (*SubscribeReq) MarshalTo added in v1.0.2 

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

func (*SubscribeReq) MarshalToSizedBuffer added in v1.0.2 

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

func (*SubscribeReq) ProtoMessage added in v1.0.2 

func (*SubscribeReq) ProtoMessage()

func (*SubscribeReq) Reset added in v1.0.2 

func (m *SubscribeReq) Reset()

func (*SubscribeReq) Size added in v1.0.2 

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

func (*SubscribeReq) String added in v1.0.2 

func (m *SubscribeReq) String() string

func (*SubscribeReq) Unmarshal added in v1.0.2 

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

func (*SubscribeReq) XXX_DiscardUnknown added in v1.0.2 

func (m *SubscribeReq) XXX_DiscardUnknown()

func (*SubscribeReq) XXX_Marshal added in v1.0.2 

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

func (*SubscribeReq) XXX_Merge added in v1.0.2 

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

func (*SubscribeReq) XXX_Size added in v1.0.2 

func (m *SubscribeReq) XXX_Size() int

func (*SubscribeReq) XXX_Unmarshal added in v1.0.2 

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