Documentation
¶
Index ¶
- Constants
- type Call
- type CallCancel
- type CallReturn
- type HandshakeArgs
- func (z *HandshakeArgs) DecodeMsg(dc *msgp.Reader) (err error)
- func (z HandshakeArgs) EncodeMsg(en *msgp.Writer) (err error)
- func (z HandshakeArgs) MarshalMsg(b []byte) (o []byte, err error)
- func (z HandshakeArgs) Msgsize() (s int)
- func (z *HandshakeArgs) UnmarshalMsg(bts []byte) (o []byte, err error)
- type HandshakeCode
- func (z *HandshakeCode) DecodeMsg(dc *msgp.Reader) (err error)
- func (z HandshakeCode) EncodeMsg(en *msgp.Writer) (err error)
- func (z HandshakeCode) MarshalMsg(b []byte) (o []byte, err error)
- func (z HandshakeCode) Msgsize() (s int)
- func (z *HandshakeCode) UnmarshalMsg(bts []byte) (o []byte, err error)
- type HandshakeRet
- type InitStream
- type StreamType
Constants ¶
const ( StreamTypeRaw = 0 StreamTypeCallAsync = 1 StreamTypeCallInit = 2 )
const (
// The version of the application.
Version = 2
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Call ¶ added in v0.2.0
func (Call) MarshalMsg ¶ added in v0.2.0
MarshalMsg implements msgp.Marshaler
type CallCancel ¶ added in v0.2.0
type CallCancel struct {
Key uint32
}
func (*CallCancel) DecodeMsg ¶ added in v0.2.0
func (z *CallCancel) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (CallCancel) EncodeMsg ¶ added in v0.2.0
func (z CallCancel) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (CallCancel) MarshalMsg ¶ added in v0.2.0
func (z CallCancel) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (CallCancel) Msgsize ¶ added in v0.2.0
func (z CallCancel) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*CallCancel) UnmarshalMsg ¶ added in v0.2.0
func (z *CallCancel) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type CallReturn ¶ added in v0.2.0
func (*CallReturn) DecodeMsg ¶ added in v0.2.0
func (z *CallReturn) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (CallReturn) EncodeMsg ¶ added in v0.2.0
func (z CallReturn) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (CallReturn) MarshalMsg ¶ added in v0.2.0
func (z CallReturn) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (CallReturn) Msgsize ¶ added in v0.2.0
func (z CallReturn) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*CallReturn) UnmarshalMsg ¶ added in v0.2.0
func (z *CallReturn) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type HandshakeArgs ¶ added in v0.2.0
type HandshakeArgs struct {
Version byte
}
func (*HandshakeArgs) DecodeMsg ¶ added in v0.2.0
func (z *HandshakeArgs) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (HandshakeArgs) EncodeMsg ¶ added in v0.2.0
func (z HandshakeArgs) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (HandshakeArgs) MarshalMsg ¶ added in v0.2.0
func (z HandshakeArgs) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (HandshakeArgs) Msgsize ¶ added in v0.2.0
func (z HandshakeArgs) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*HandshakeArgs) UnmarshalMsg ¶ added in v0.2.0
func (z *HandshakeArgs) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type HandshakeCode ¶ added in v0.2.0
type HandshakeCode int
const ( HSOk HandshakeCode = 0 HSInvalidVersion HandshakeCode = 1 )
func (*HandshakeCode) DecodeMsg ¶ added in v0.2.0
func (z *HandshakeCode) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (HandshakeCode) EncodeMsg ¶ added in v0.2.0
func (z HandshakeCode) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (HandshakeCode) MarshalMsg ¶ added in v0.2.0
func (z HandshakeCode) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (HandshakeCode) Msgsize ¶ added in v0.2.0
func (z HandshakeCode) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*HandshakeCode) UnmarshalMsg ¶ added in v0.2.0
func (z *HandshakeCode) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type HandshakeRet ¶ added in v0.2.0
type HandshakeRet struct {
Code HandshakeCode
SessionID string
}
func (*HandshakeRet) DecodeMsg ¶ added in v0.2.0
func (z *HandshakeRet) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (HandshakeRet) EncodeMsg ¶ added in v0.2.0
func (z HandshakeRet) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (HandshakeRet) MarshalMsg ¶ added in v0.2.0
func (z HandshakeRet) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (HandshakeRet) Msgsize ¶ added in v0.2.0
func (z HandshakeRet) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*HandshakeRet) UnmarshalMsg ¶ added in v0.2.0
func (z *HandshakeRet) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type InitStream ¶
type InitStream struct {
Service string
ID string
Type StreamType
}
func (*InitStream) DecodeMsg ¶
func (z *InitStream) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (InitStream) EncodeMsg ¶
func (z InitStream) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (InitStream) MarshalMsg ¶
func (z InitStream) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (InitStream) Msgsize ¶
func (z InitStream) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*InitStream) UnmarshalMsg ¶
func (z *InitStream) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type StreamType ¶ added in v0.2.0
type StreamType int
func (*StreamType) DecodeMsg ¶ added in v0.2.0
func (z *StreamType) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (StreamType) EncodeMsg ¶ added in v0.2.0
func (z StreamType) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (StreamType) MarshalMsg ¶ added in v0.2.0
func (z StreamType) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (StreamType) Msgsize ¶ added in v0.2.0
func (z StreamType) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*StreamType) UnmarshalMsg ¶ added in v0.2.0
func (z *StreamType) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler