pbim

Jun 15, 2021

Changes in this version

+ var ErrIntOverflowPbim = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPbim = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPbim = fmt.Errorf("proto: unexpected end of group")

+ func RegisterImServer(s *server.RocServer, h ImServer)

+ type ConnectReq struct

+ UserName string

+ func (*ConnectReq) Descriptor() ([]byte, []int)

+ func (*ConnectReq) ProtoMessage()

+ func (m *ConnectReq) GetUserName() string

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

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

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

+ func (m *ConnectReq) Reset()

+ func (m *ConnectReq) Size() (n int)

+ func (m *ConnectReq) String() string

+ func (m *ConnectReq) Unmarshal(dAtA []byte) error

+ func (m *ConnectReq) XXX_DiscardUnknown()

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

+ func (m *ConnectReq) XXX_Merge(src proto.Message)

+ func (m *ConnectReq) XXX_Size() int

+ func (m *ConnectReq) XXX_Unmarshal(b []byte) error

+ type ConnectRsp struct

+ IsConnect bool

+ func (*ConnectRsp) Descriptor() ([]byte, []int)

+ func (*ConnectRsp) ProtoMessage()

+ func (m *ConnectRsp) GetIsConnect() bool

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

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

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

+ func (m *ConnectRsp) Reset()

+ func (m *ConnectRsp) Size() (n int)

+ func (m *ConnectRsp) String() string

+ func (m *ConnectRsp) Unmarshal(dAtA []byte) error

+ func (m *ConnectRsp) XXX_DiscardUnknown()

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

+ func (m *ConnectRsp) XXX_Merge(src proto.Message)

+ func (m *ConnectRsp) XXX_Size() int

+ func (m *ConnectRsp) XXX_Unmarshal(b []byte) error

+ type CountReq struct

+ Prefix string

+ func (*CountReq) Descriptor() ([]byte, []int)

+ func (*CountReq) ProtoMessage()

+ func (m *CountReq) GetPrefix() string

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

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

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

+ func (m *CountReq) Reset()

+ func (m *CountReq) Size() (n int)

+ func (m *CountReq) String() string

+ func (m *CountReq) Unmarshal(dAtA []byte) error

+ func (m *CountReq) XXX_DiscardUnknown()

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

+ func (m *CountReq) XXX_Merge(src proto.Message)

+ func (m *CountReq) XXX_Size() int

+ func (m *CountReq) XXX_Unmarshal(b []byte) error

+ type CountRsp struct

+ Count uint32

+ func (*CountRsp) Descriptor() ([]byte, []int)

+ func (*CountRsp) ProtoMessage()

+ func (m *CountRsp) GetCount() uint32

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

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

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

+ func (m *CountRsp) Reset()

+ func (m *CountRsp) Size() (n int)

+ func (m *CountRsp) String() string

+ func (m *CountRsp) Unmarshal(dAtA []byte) error

+ func (m *CountRsp) XXX_DiscardUnknown()

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

+ func (m *CountRsp) XXX_Merge(src proto.Message)

+ func (m *CountRsp) XXX_Size() int

+ func (m *CountRsp) XXX_Unmarshal(b []byte) error

+ type ImClient interface

+ Connect func(c *context.Context, req *ConnectReq, opts ...client.InvokeOptions) (*ConnectRsp, error)

+ Count func(c *context.Context, req *CountReq, opts ...client.InvokeOptions) (*CountRsp, error)

+ SendMessage func(c *context.Context, req chan *SendMessageReq, errIn chan error, ...) (chan *SendMessageRsp, chan error)

+ func NewImClient(c *client.RocClient) ImClient

+ type ImServer interface

+ Connect func(c *context.Context, req *ConnectReq) (rsp *ConnectRsp, err error)

+ Count func(c *context.Context, req *CountReq) (rsp *CountRsp, err error)

+ SendMessage func(c *context.Context, req chan *SendMessageReq, errIn chan error) (chan *SendMessageRsp, chan error)

+ type SendMessageReq struct

+ Message string

+ func (*SendMessageReq) Descriptor() ([]byte, []int)

+ func (*SendMessageReq) ProtoMessage()

+ func (m *SendMessageReq) GetMessage() string

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

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

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

+ func (m *SendMessageReq) Reset()

+ func (m *SendMessageReq) Size() (n int)

+ func (m *SendMessageReq) String() string

+ func (m *SendMessageReq) Unmarshal(dAtA []byte) error

+ func (m *SendMessageReq) XXX_DiscardUnknown()

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

+ func (m *SendMessageReq) XXX_Merge(src proto.Message)

+ func (m *SendMessageReq) XXX_Size() int

+ func (m *SendMessageReq) XXX_Unmarshal(b []byte) error

+ type SendMessageRsp struct

+ Message string

+ func (*SendMessageRsp) Descriptor() ([]byte, []int)

+ func (*SendMessageRsp) ProtoMessage()

+ func (m *SendMessageRsp) GetMessage() string

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

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

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

+ func (m *SendMessageRsp) Reset()

+ func (m *SendMessageRsp) Size() (n int)

+ func (m *SendMessageRsp) String() string

+ func (m *SendMessageRsp) Unmarshal(dAtA []byte) error

+ func (m *SendMessageRsp) XXX_DiscardUnknown()

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

+ func (m *SendMessageRsp) XXX_Merge(src proto.Message)

+ func (m *SendMessageRsp) XXX_Size() int

+ func (m *SendMessageRsp) XXX_Unmarshal(b []byte) error