Documentation ¶
Index ¶
- func WriteUserBody(writer io.Writer, message UserBody) error
- func WriteUserHeader(writer io.Writer, message UserHeader) error
- type Cancel
- type CloseCode
- type Event
- type Frame
- type FrameType
- type Parser
- type Request
- type Response
- type ResponseType
- type SystemClose
- type SystemHandshake
- type SystemPing
- type UserBody
- type UserHeader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WriteUserHeader ¶
func WriteUserHeader(writer io.Writer, message UserHeader) error
Types ¶
type Frame ¶
type Frame interface { // Returns frame type GetType() FrameType // Parse itself from reader Parse(reader io.Reader) error // Write itself to writer Serialize(writer io.Writer) error }
Frame is transferred frame with concrete type
type FrameType ¶
type FrameType uint8
Frame type represents specific frame
const CANCEL FrameType = 0x12
const EVENT FrameType = 0x10
const REQUEST FrameType = 0x11
const RESPONSE FrameType = 0x13
const SYSTEM_CLOSE FrameType = 0x01
const SYSTEM_HANDSHAKE FrameType = 0x00
const SYSTEM_PING FrameType = 0x02
type Parser ¶
type Parser struct { // Channel to push parsed frames Frames chan Frame // Error to push reason of parser stop Error chan error // contains filtered or unexported fields }
Frames Parser
type Response ¶
type Response struct { UserHeader RequestUid [16]byte Type ResponseType UserBody }
Response frame
type ResponseType ¶
type ResponseType uint8
const ( RESPONSE_DONE ResponseType = 0x00 RESPONSE_ERROR ResponseType = 0x01 RESPONSE_PROGRESS ResponseType = 0x02 RESPONSE_CANCELLED ResponseType = 0x03 )
type SystemClose ¶
SystemClose frame
func (*SystemClose) GetType ¶
func (this *SystemClose) GetType() FrameType
type SystemHandshake ¶
type SystemHandshake struct {
Version uint16
}
SystemHandshake frame
func (*SystemHandshake) GetType ¶
func (this *SystemHandshake) GetType() FrameType
type SystemPing ¶
SystemPing frame
func (*SystemPing) GetType ¶
func (this *SystemPing) GetType() FrameType
type UserHeader ¶
UserHeader frame part
func ParseUserHeader ¶
func ParseUserHeader(buffer io.Reader) (*UserHeader, error)
Click to show internal directories.
Click to hide internal directories.