Versions in this module Expand all Collapse all v0 v0.0.4 Apr 29, 2024 v0.0.3 Apr 18, 2024 v0.0.2 Apr 2, 2024 v0.0.1 Apr 2, 2024 Changes in this version + var ErrIntOverflowGate = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowNode = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGate = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupGate = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupNode = fmt.Errorf("proto: unexpected end of group") + type BindReply struct + ErrorCode int32 + ErrorMessage string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BindReply) Descriptor() ([]byte, []int) + func (*BindReply) ProtoMessage() + func (m *BindReply) GetErrorCode() int32 + func (m *BindReply) GetErrorMessage() string + func (m *BindReply) Marshal() (dAtA []byte, err error) + func (m *BindReply) MarshalTo(dAtA []byte) (int, error) + func (m *BindReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BindReply) Reset() + func (m *BindReply) Size() (n int) + func (m *BindReply) String() string + func (m *BindReply) Unmarshal(dAtA []byte) error + func (m *BindReply) XXX_DiscardUnknown() + func (m *BindReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BindReply) XXX_Merge(src proto.Message) + func (m *BindReply) XXX_Size() int + func (m *BindReply) XXX_Unmarshal(b []byte) error + type BindRequest struct + CID int64 + UID int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BindRequest) Descriptor() ([]byte, []int) + func (*BindRequest) ProtoMessage() + func (m *BindRequest) GetCID() int64 + func (m *BindRequest) GetUID() int64 + func (m *BindRequest) Marshal() (dAtA []byte, err error) + func (m *BindRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BindRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BindRequest) Reset() + func (m *BindRequest) Size() (n int) + func (m *BindRequest) String() string + func (m *BindRequest) Unmarshal(dAtA []byte) error + func (m *BindRequest) XXX_DiscardUnknown() + func (m *BindRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BindRequest) XXX_Merge(src proto.Message) + func (m *BindRequest) XXX_Size() int + func (m *BindRequest) XXX_Unmarshal(b []byte) error + type BlockConnRequest struct + NNid string + ONid string + Target uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BlockConnRequest) Descriptor() ([]byte, []int) + func (*BlockConnRequest) ProtoMessage() + func (m *BlockConnRequest) GetNNid() string + func (m *BlockConnRequest) GetONid() string + func (m *BlockConnRequest) GetTarget() uint64 + func (m *BlockConnRequest) Marshal() (dAtA []byte, err error) + func (m *BlockConnRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BlockConnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BlockConnRequest) Reset() + func (m *BlockConnRequest) Size() (n int) + func (m *BlockConnRequest) String() string + func (m *BlockConnRequest) Unmarshal(dAtA []byte) error + func (m *BlockConnRequest) XXX_DiscardUnknown() + func (m *BlockConnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockConnRequest) XXX_Merge(src proto.Message) + func (m *BlockConnRequest) XXX_Size() int + func (m *BlockConnRequest) XXX_Unmarshal(b []byte) error + type BroadcastReply struct + ErrorCode int32 + ErrorMessage string + Total int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BroadcastReply) Descriptor() ([]byte, []int) + func (*BroadcastReply) ProtoMessage() + func (m *BroadcastReply) GetErrorCode() int32 + func (m *BroadcastReply) GetErrorMessage() string + func (m *BroadcastReply) GetTotal() int64 + func (m *BroadcastReply) Marshal() (dAtA []byte, err error) + func (m *BroadcastReply) MarshalTo(dAtA []byte) (int, error) + func (m *BroadcastReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BroadcastReply) Reset() + func (m *BroadcastReply) Size() (n int) + func (m *BroadcastReply) String() string + func (m *BroadcastReply) Unmarshal(dAtA []byte) error + func (m *BroadcastReply) XXX_DiscardUnknown() + func (m *BroadcastReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BroadcastReply) XXX_Merge(src proto.Message) + func (m *BroadcastReply) XXX_Size() int + func (m *BroadcastReply) XXX_Unmarshal(b []byte) error + type BroadcastRequest struct + Kind int32 + Message *Message + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BroadcastRequest) Descriptor() ([]byte, []int) + func (*BroadcastRequest) ProtoMessage() + func (m *BroadcastRequest) GetKind() int32 + func (m *BroadcastRequest) GetMessage() *Message + func (m *BroadcastRequest) Marshal() (dAtA []byte, err error) + func (m *BroadcastRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BroadcastRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BroadcastRequest) Reset() + func (m *BroadcastRequest) Size() (n int) + func (m *BroadcastRequest) String() string + func (m *BroadcastRequest) Unmarshal(dAtA []byte) error + func (m *BroadcastRequest) XXX_DiscardUnknown() + func (m *BroadcastRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BroadcastRequest) XXX_Merge(src proto.Message) + func (m *BroadcastRequest) XXX_Size() int + func (m *BroadcastRequest) XXX_Unmarshal(b []byte) error + type DeliverReply struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeliverReply) Descriptor() ([]byte, []int) + func (*DeliverReply) ProtoMessage() + func (m *DeliverReply) Marshal() (dAtA []byte, err error) + func (m *DeliverReply) MarshalTo(dAtA []byte) (int, error) + func (m *DeliverReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeliverReply) Reset() + func (m *DeliverReply) Size() (n int) + func (m *DeliverReply) String() string + func (m *DeliverReply) Unmarshal(dAtA []byte) error + func (m *DeliverReply) XXX_DiscardUnknown() + func (m *DeliverReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeliverReply) XXX_Merge(src proto.Message) + func (m *DeliverReply) XXX_Size() int + func (m *DeliverReply) XXX_Unmarshal(b []byte) error + type DeliverRequest struct + CID int64 + GID string + Message *Message + NID string + UID int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeliverRequest) Descriptor() ([]byte, []int) + func (*DeliverRequest) ProtoMessage() + func (m *DeliverRequest) GetCID() int64 + func (m *DeliverRequest) GetGID() string + func (m *DeliverRequest) GetMessage() *Message + func (m *DeliverRequest) GetNID() string + func (m *DeliverRequest) GetUID() int64 + func (m *DeliverRequest) Marshal() (dAtA []byte, err error) + func (m *DeliverRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeliverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeliverRequest) Reset() + func (m *DeliverRequest) Size() (n int) + func (m *DeliverRequest) String() string + func (m *DeliverRequest) Unmarshal(dAtA []byte) error + func (m *DeliverRequest) XXX_DiscardUnknown() + func (m *DeliverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeliverRequest) XXX_Merge(src proto.Message) + func (m *DeliverRequest) XXX_Size() int + func (m *DeliverRequest) XXX_Unmarshal(b []byte) error + type DisconnectReply struct + ErrorCode int32 + ErrorMessage string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DisconnectReply) Descriptor() ([]byte, []int) + func (*DisconnectReply) ProtoMessage() + func (m *DisconnectReply) GetErrorCode() int32 + func (m *DisconnectReply) GetErrorMessage() string + func (m *DisconnectReply) Marshal() (dAtA []byte, err error) + func (m *DisconnectReply) MarshalTo(dAtA []byte) (int, error) + func (m *DisconnectReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DisconnectReply) Reset() + func (m *DisconnectReply) Size() (n int) + func (m *DisconnectReply) String() string + func (m *DisconnectReply) Unmarshal(dAtA []byte) error + func (m *DisconnectReply) XXX_DiscardUnknown() + func (m *DisconnectReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DisconnectReply) XXX_Merge(src proto.Message) + func (m *DisconnectReply) XXX_Size() int + func (m *DisconnectReply) XXX_Unmarshal(b []byte) error + type DisconnectRequest struct + IsForce bool + Kind int32 + Target int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DisconnectRequest) Descriptor() ([]byte, []int) + func (*DisconnectRequest) ProtoMessage() + func (m *DisconnectRequest) GetIsForce() bool + func (m *DisconnectRequest) GetKind() int32 + func (m *DisconnectRequest) GetTarget() int64 + func (m *DisconnectRequest) Marshal() (dAtA []byte, err error) + func (m *DisconnectRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DisconnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DisconnectRequest) Reset() + func (m *DisconnectRequest) Size() (n int) + func (m *DisconnectRequest) String() string + func (m *DisconnectRequest) Unmarshal(dAtA []byte) error + func (m *DisconnectRequest) XXX_DiscardUnknown() + func (m *DisconnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DisconnectRequest) XXX_Merge(src proto.Message) + func (m *DisconnectRequest) XXX_Size() int + func (m *DisconnectRequest) XXX_Unmarshal(b []byte) error + type GetIPReply struct + ErrorCode int32 + ErrorMessage string + IP string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetIPReply) Descriptor() ([]byte, []int) + func (*GetIPReply) ProtoMessage() + func (m *GetIPReply) GetErrorCode() int32 + func (m *GetIPReply) GetErrorMessage() string + func (m *GetIPReply) GetIP() string + func (m *GetIPReply) Marshal() (dAtA []byte, err error) + func (m *GetIPReply) MarshalTo(dAtA []byte) (int, error) + func (m *GetIPReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetIPReply) Reset() + func (m *GetIPReply) Size() (n int) + func (m *GetIPReply) String() string + func (m *GetIPReply) Unmarshal(dAtA []byte) error + func (m *GetIPReply) XXX_DiscardUnknown() + func (m *GetIPReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetIPReply) XXX_Merge(src proto.Message) + func (m *GetIPReply) XXX_Size() int + func (m *GetIPReply) XXX_Unmarshal(b []byte) error + type GetIPRequest struct + Kind int32 + Target int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetIPRequest) Descriptor() ([]byte, []int) + func (*GetIPRequest) ProtoMessage() + func (m *GetIPRequest) GetKind() int32 + func (m *GetIPRequest) GetTarget() int64 + func (m *GetIPRequest) Marshal() (dAtA []byte, err error) + func (m *GetIPRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetIPRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetIPRequest) Reset() + func (m *GetIPRequest) Size() (n int) + func (m *GetIPRequest) String() string + func (m *GetIPRequest) Unmarshal(dAtA []byte) error + func (m *GetIPRequest) XXX_DiscardUnknown() + func (m *GetIPRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetIPRequest) XXX_Merge(src proto.Message) + func (m *GetIPRequest) XXX_Size() int + func (m *GetIPRequest) XXX_Unmarshal(b []byte) error + type GetIdReply struct + ErrorCode int32 + ErrorMessage string + Id int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetIdReply) Descriptor() ([]byte, []int) + func (*GetIdReply) ProtoMessage() + func (m *GetIdReply) GetErrorCode() int32 + func (m *GetIdReply) GetErrorMessage() string + func (m *GetIdReply) GetId() int64 + func (m *GetIdReply) Marshal() (dAtA []byte, err error) + func (m *GetIdReply) MarshalTo(dAtA []byte) (int, error) + func (m *GetIdReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetIdReply) Reset() + func (m *GetIdReply) Size() (n int) + func (m *GetIdReply) String() string + func (m *GetIdReply) Unmarshal(dAtA []byte) error + func (m *GetIdReply) XXX_DiscardUnknown() + func (m *GetIdReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetIdReply) XXX_Merge(src proto.Message) + func (m *GetIdReply) XXX_Size() int + func (m *GetIdReply) XXX_Unmarshal(b []byte) error + type GetIdRequest struct + Kind int32 + Target int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetIdRequest) Descriptor() ([]byte, []int) + func (*GetIdRequest) ProtoMessage() + func (m *GetIdRequest) GetKind() int32 + func (m *GetIdRequest) GetTarget() int64 + func (m *GetIdRequest) Marshal() (dAtA []byte, err error) + func (m *GetIdRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetIdRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetIdRequest) Reset() + func (m *GetIdRequest) Size() (n int) + func (m *GetIdRequest) String() string + func (m *GetIdRequest) Unmarshal(dAtA []byte) error + func (m *GetIdRequest) XXX_DiscardUnknown() + func (m *GetIdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetIdRequest) XXX_Merge(src proto.Message) + func (m *GetIdRequest) XXX_Size() int + func (m *GetIdRequest) XXX_Unmarshal(b []byte) error + type IsOnlineReply struct + ErrorCode int32 + ErrorMessage string + IsOnline bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsOnlineReply) Descriptor() ([]byte, []int) + func (*IsOnlineReply) ProtoMessage() + func (m *IsOnlineReply) GetErrorCode() int32 + func (m *IsOnlineReply) GetErrorMessage() string + func (m *IsOnlineReply) GetIsOnline() bool + func (m *IsOnlineReply) Marshal() (dAtA []byte, err error) + func (m *IsOnlineReply) MarshalTo(dAtA []byte) (int, error) + func (m *IsOnlineReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IsOnlineReply) Reset() + func (m *IsOnlineReply) Size() (n int) + func (m *IsOnlineReply) String() string + func (m *IsOnlineReply) Unmarshal(dAtA []byte) error + func (m *IsOnlineReply) XXX_DiscardUnknown() + func (m *IsOnlineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IsOnlineReply) XXX_Merge(src proto.Message) + func (m *IsOnlineReply) XXX_Size() int + func (m *IsOnlineReply) XXX_Unmarshal(b []byte) error + type IsOnlineRequest struct + Kind int32 + Target int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsOnlineRequest) Descriptor() ([]byte, []int) + func (*IsOnlineRequest) ProtoMessage() + func (m *IsOnlineRequest) GetKind() int32 + func (m *IsOnlineRequest) GetTarget() int64 + func (m *IsOnlineRequest) Marshal() (dAtA []byte, err error) + func (m *IsOnlineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *IsOnlineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IsOnlineRequest) Reset() + func (m *IsOnlineRequest) Size() (n int) + func (m *IsOnlineRequest) String() string + func (m *IsOnlineRequest) Unmarshal(dAtA []byte) error + func (m *IsOnlineRequest) XXX_DiscardUnknown() + func (m *IsOnlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IsOnlineRequest) XXX_Merge(src proto.Message) + func (m *IsOnlineRequest) XXX_Size() int + func (m *IsOnlineRequest) XXX_Unmarshal(b []byte) error + type Message struct + Buffer []byte + Compress bool + Route int32 + Seq int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetBuffer() []byte + func (m *Message) GetCompress() bool + func (m *Message) GetRoute() int32 + func (m *Message) GetSeq() int32 + func (m *Message) Marshal() (dAtA []byte, err error) + func (m *Message) MarshalTo(dAtA []byte) (int, error) + func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message) Reset() + func (m *Message) Size() (n int) + func (m *Message) String() string + func (m *Message) Unmarshal(dAtA []byte) error + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Merge(src proto.Message) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + type MulticastReply struct + Total int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MulticastReply) Descriptor() ([]byte, []int) + func (*MulticastReply) ProtoMessage() + func (m *MulticastReply) GetTotal() int64 + func (m *MulticastReply) Marshal() (dAtA []byte, err error) + func (m *MulticastReply) MarshalTo(dAtA []byte) (int, error) + func (m *MulticastReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MulticastReply) Reset() + func (m *MulticastReply) Size() (n int) + func (m *MulticastReply) String() string + func (m *MulticastReply) Unmarshal(dAtA []byte) error + func (m *MulticastReply) XXX_DiscardUnknown() + func (m *MulticastReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MulticastReply) XXX_Merge(src proto.Message) + func (m *MulticastReply) XXX_Size() int + func (m *MulticastReply) XXX_Unmarshal(b []byte) error + type MulticastRequest struct + Kind int32 + Message *Message + Targets []int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MulticastRequest) Descriptor() ([]byte, []int) + func (*MulticastRequest) ProtoMessage() + func (m *MulticastRequest) GetKind() int32 + func (m *MulticastRequest) GetMessage() *Message + func (m *MulticastRequest) GetTargets() []int64 + func (m *MulticastRequest) Marshal() (dAtA []byte, err error) + func (m *MulticastRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MulticastRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MulticastRequest) Reset() + func (m *MulticastRequest) Size() (n int) + func (m *MulticastRequest) String() string + func (m *MulticastRequest) Unmarshal(dAtA []byte) error + func (m *MulticastRequest) XXX_DiscardUnknown() + func (m *MulticastRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MulticastRequest) XXX_Merge(src proto.Message) + func (m *MulticastRequest) XXX_Size() int + func (m *MulticastRequest) XXX_Unmarshal(b []byte) error + type PingReply struct + ErrorCode int32 + ErrorMessage string + Reply string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PingReply) Descriptor() ([]byte, []int) + func (*PingReply) ProtoMessage() + func (m *PingReply) GetErrorCode() int32 + func (m *PingReply) GetErrorMessage() string + func (m *PingReply) GetReply() string + func (m *PingReply) Marshal() (dAtA []byte, err error) + func (m *PingReply) MarshalTo(dAtA []byte) (int, error) + func (m *PingReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PingReply) Reset() + func (m *PingReply) Size() (n int) + func (m *PingReply) String() string + func (m *PingReply) Unmarshal(dAtA []byte) error + func (m *PingReply) XXX_DiscardUnknown() + func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PingReply) XXX_Merge(src proto.Message) + func (m *PingReply) XXX_Size() int + func (m *PingReply) XXX_Unmarshal(b []byte) error + type PingRequest struct + Message string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PingRequest) Descriptor() ([]byte, []int) + func (*PingRequest) ProtoMessage() + func (m *PingRequest) GetMessage() string + func (m *PingRequest) Marshal() (dAtA []byte, err error) + func (m *PingRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PingRequest) Reset() + func (m *PingRequest) Size() (n int) + func (m *PingRequest) String() string + func (m *PingRequest) Unmarshal(dAtA []byte) error + func (m *PingRequest) XXX_DiscardUnknown() + func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PingRequest) XXX_Merge(src proto.Message) + func (m *PingRequest) XXX_Size() int + func (m *PingRequest) XXX_Unmarshal(b []byte) error + type PushReply struct + ErrorCode int32 + ErrorMessage string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PushReply) Descriptor() ([]byte, []int) + func (*PushReply) ProtoMessage() + func (m *PushReply) GetErrorCode() int32 + func (m *PushReply) GetErrorMessage() string + func (m *PushReply) Marshal() (dAtA []byte, err error) + func (m *PushReply) MarshalTo(dAtA []byte) (int, error) + func (m *PushReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PushReply) Reset() + func (m *PushReply) Size() (n int) + func (m *PushReply) String() string + func (m *PushReply) Unmarshal(dAtA []byte) error + func (m *PushReply) XXX_DiscardUnknown() + func (m *PushReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PushReply) XXX_Merge(src proto.Message) + func (m *PushReply) XXX_Size() int + func (m *PushReply) XXX_Unmarshal(b []byte) error + type PushRequest struct + Kind int32 + Message *Message + Target int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PushRequest) Descriptor() ([]byte, []int) + func (*PushRequest) ProtoMessage() + func (m *PushRequest) GetKind() int32 + func (m *PushRequest) GetMessage() *Message + func (m *PushRequest) GetTarget() int64 + func (m *PushRequest) Marshal() (dAtA []byte, err error) + func (m *PushRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PushRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PushRequest) Reset() + func (m *PushRequest) Size() (n int) + func (m *PushRequest) String() string + func (m *PushRequest) Unmarshal(dAtA []byte) error + func (m *PushRequest) XXX_DiscardUnknown() + func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PushRequest) XXX_Merge(src proto.Message) + func (m *PushRequest) XXX_Size() int + func (m *PushRequest) XXX_Unmarshal(b []byte) error + type ReleaseConnRequest struct + Target uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReleaseConnRequest) Descriptor() ([]byte, []int) + func (*ReleaseConnRequest) ProtoMessage() + func (m *ReleaseConnRequest) GetTarget() uint64 + func (m *ReleaseConnRequest) Marshal() (dAtA []byte, err error) + func (m *ReleaseConnRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ReleaseConnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReleaseConnRequest) Reset() + func (m *ReleaseConnRequest) Size() (n int) + func (m *ReleaseConnRequest) String() string + func (m *ReleaseConnRequest) Unmarshal(dAtA []byte) error + func (m *ReleaseConnRequest) XXX_DiscardUnknown() + func (m *ReleaseConnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReleaseConnRequest) XXX_Merge(src proto.Message) + func (m *ReleaseConnRequest) XXX_Size() int + func (m *ReleaseConnRequest) XXX_Unmarshal(b []byte) error + type StatReply struct + ErrorCode int32 + ErrorMessage string + Total int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatReply) Descriptor() ([]byte, []int) + func (*StatReply) ProtoMessage() + func (m *StatReply) GetErrorCode() int32 + func (m *StatReply) GetErrorMessage() string + func (m *StatReply) GetTotal() int64 + func (m *StatReply) Marshal() (dAtA []byte, err error) + func (m *StatReply) MarshalTo(dAtA []byte) (int, error) + func (m *StatReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatReply) Reset() + func (m *StatReply) Size() (n int) + func (m *StatReply) String() string + func (m *StatReply) Unmarshal(dAtA []byte) error + func (m *StatReply) XXX_DiscardUnknown() + func (m *StatReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatReply) XXX_Merge(src proto.Message) + func (m *StatReply) XXX_Size() int + func (m *StatReply) XXX_Unmarshal(b []byte) error + type StatRequest struct + Kind int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatRequest) Descriptor() ([]byte, []int) + func (*StatRequest) ProtoMessage() + func (m *StatRequest) GetKind() int32 + func (m *StatRequest) Marshal() (dAtA []byte, err error) + func (m *StatRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatRequest) Reset() + func (m *StatRequest) Size() (n int) + func (m *StatRequest) String() string + func (m *StatRequest) Unmarshal(dAtA []byte) error + func (m *StatRequest) XXX_DiscardUnknown() + func (m *StatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatRequest) XXX_Merge(src proto.Message) + func (m *StatRequest) XXX_Size() int + func (m *StatRequest) XXX_Unmarshal(b []byte) error + type TriggerReply struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TriggerReply) Descriptor() ([]byte, []int) + func (*TriggerReply) ProtoMessage() + func (m *TriggerReply) Marshal() (dAtA []byte, err error) + func (m *TriggerReply) MarshalTo(dAtA []byte) (int, error) + func (m *TriggerReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TriggerReply) Reset() + func (m *TriggerReply) Size() (n int) + func (m *TriggerReply) String() string + func (m *TriggerReply) Unmarshal(dAtA []byte) error + func (m *TriggerReply) XXX_DiscardUnknown() + func (m *TriggerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TriggerReply) XXX_Merge(src proto.Message) + func (m *TriggerReply) XXX_Size() int + func (m *TriggerReply) XXX_Unmarshal(b []byte) error + type TriggerRequest struct + CID int64 + Event int32 + GID string + UID int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TriggerRequest) Descriptor() ([]byte, []int) + func (*TriggerRequest) ProtoMessage() + func (m *TriggerRequest) GetCID() int64 + func (m *TriggerRequest) GetEvent() int32 + func (m *TriggerRequest) GetGID() string + func (m *TriggerRequest) GetUID() int64 + func (m *TriggerRequest) Marshal() (dAtA []byte, err error) + func (m *TriggerRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TriggerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TriggerRequest) Reset() + func (m *TriggerRequest) Size() (n int) + func (m *TriggerRequest) String() string + func (m *TriggerRequest) Unmarshal(dAtA []byte) error + func (m *TriggerRequest) XXX_DiscardUnknown() + func (m *TriggerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TriggerRequest) XXX_Merge(src proto.Message) + func (m *TriggerRequest) XXX_Size() int + func (m *TriggerRequest) XXX_Unmarshal(b []byte) error + type UnbindReply struct + ErrorCode int32 + ErrorMessage string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UnbindReply) Descriptor() ([]byte, []int) + func (*UnbindReply) ProtoMessage() + func (m *UnbindReply) GetErrorCode() int32 + func (m *UnbindReply) GetErrorMessage() string + func (m *UnbindReply) Marshal() (dAtA []byte, err error) + func (m *UnbindReply) MarshalTo(dAtA []byte) (int, error) + func (m *UnbindReply) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UnbindReply) Reset() + func (m *UnbindReply) Size() (n int) + func (m *UnbindReply) String() string + func (m *UnbindReply) Unmarshal(dAtA []byte) error + func (m *UnbindReply) XXX_DiscardUnknown() + func (m *UnbindReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UnbindReply) XXX_Merge(src proto.Message) + func (m *UnbindReply) XXX_Size() int + func (m *UnbindReply) XXX_Unmarshal(b []byte) error + type UnbindRequest struct + UID int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UnbindRequest) Descriptor() ([]byte, []int) + func (*UnbindRequest) ProtoMessage() + func (m *UnbindRequest) GetUID() int64 + func (m *UnbindRequest) Marshal() (dAtA []byte, err error) + func (m *UnbindRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UnbindRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UnbindRequest) Reset() + func (m *UnbindRequest) Size() (n int) + func (m *UnbindRequest) String() string + func (m *UnbindRequest) Unmarshal(dAtA []byte) error + func (m *UnbindRequest) XXX_DiscardUnknown() + func (m *UnbindRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UnbindRequest) XXX_Merge(src proto.Message) + func (m *UnbindRequest) XXX_Size() int + func (m *UnbindRequest) XXX_Unmarshal(b []byte) error
Go to main page