Documentation ¶
Index ¶
- Constants
- type Request
- func (r *Request) GetData() types.IoBuffer
- func (r *Request) GetHeader() types.HeaderMap
- func (r *Request) GetRequestId() uint64
- func (r *Request) GetStreamType() api.StreamType
- func (r *Request) GetTimeout() int32
- func (r *Request) IsHeartbeatFrame() bool
- func (r *Request) SetData(data types.IoBuffer)
- func (r *Request) SetRequestId(id uint64)
- type RequestHeader
- type Response
- func (r *Response) GetData() types.IoBuffer
- func (r *Response) GetHeader() types.HeaderMap
- func (r *Response) GetRequestId() uint64
- func (r *Response) GetStatusCode() uint32
- func (r *Response) GetStreamType() api.StreamType
- func (r *Response) GetTimeout() int32
- func (r *Response) IsHeartbeatFrame() bool
- func (r *Response) SetData(data types.IoBuffer)
- func (r *Response) SetRequestId(id uint64)
- type ResponseHeader
Constants ¶
View Source
const ( ProtocolName types.ProtocolName = "boltv2" // protocol ProtocolCode byte = 2 ProtocolVersion byte = 2 RequestHeaderLen int = 24 // protocol header fields length ResponseHeaderLen int = 22 LessLen int = ResponseHeaderLen // minimal length for decoding RequestIdIndex = 6 RequestHeaderLenIndex = 18 ResponseHeaderLenIndex = 16 )
boltv2 constants
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Request ¶
type Request struct { RequestHeader Data types.IoBuffer // wrapper of raw data Content types.IoBuffer // wrapper of raw content ContentChanged bool // indicate that content changed // contains filtered or unexported fields }
Request is the cmd struct of bolt v2 request
func (*Request) GetStreamType ¶
func (r *Request) GetStreamType() api.StreamType
func (*Request) GetTimeout ¶ added in v0.22.0
func (*Request) IsHeartbeatFrame ¶
func (*Request) SetRequestId ¶
type RequestHeader ¶
type RequestHeader struct { bolt.RequestHeader Version1 byte //00 SwitchCode byte }
type Response ¶
type Response struct { ResponseHeader Data types.IoBuffer // wrapper of raw data Content types.IoBuffer // wrapper of raw content ContentChanged bool // indicate that content changed // contains filtered or unexported fields }
Response is the cmd struct of bolt v2 response
func (*Response) GetStatusCode ¶
func (*Response) GetStreamType ¶
func (r *Response) GetStreamType() api.StreamType
func (*Response) GetTimeout ¶ added in v0.22.0
response contains no timeout
func (*Response) IsHeartbeatFrame ¶
func (*Response) SetRequestId ¶
type ResponseHeader ¶
type ResponseHeader struct { bolt.ResponseHeader Version1 byte //00 SwitchCode byte }
Click to show internal directories.
Click to hide internal directories.