clientproto

Documentation

Index

• func NewJoinPush(ch string, data protocol.Raw) *protocol.Push
• func NewLeavePush(ch string, data protocol.Raw) *protocol.Push
• func NewMessagePush(data protocol.Raw) *protocol.Push
• func NewPublicationPush(ch string, data protocol.Raw) *protocol.Push
• func NewSubPush(ch string, data protocol.Raw) *protocol.Push
• func NewUnsubPush(ch string, data protocol.Raw) *protocol.Push
• type ConnectResponse
• type HistoryResponse
• type PingResponse
• type PresenceResponse
• type PresenceStatsResponse
• type PublishResponse
• type RPCResponse
• type RefreshResponse
• type SubRefreshResponse
• type SubscribeResponse
• type UnsubscribeResponse

Functions

func NewJoinPush

func NewJoinPush(ch string, data protocol.Raw) *protocol.Push

NewJoinPush returns initialized async join message.

func NewLeavePush

func NewLeavePush(ch string, data protocol.Raw) *protocol.Push

NewLeavePush returns initialized async leave message.

func NewMessagePush

func NewMessagePush(data protocol.Raw) *protocol.Push

NewMessagePush returns initialized async push message.

func NewPublicationPush

func NewPublicationPush(ch string, data protocol.Raw) *protocol.Push

NewPublicationPush returns initialized async publication message.

func NewSubPush

func NewSubPush(ch string, data protocol.Raw) *protocol.Push

NewSubPush returns initialized async subscribe message.

func NewUnsubPush

func NewUnsubPush(ch string, data protocol.Raw) *protocol.Push

NewUnsubPush returns initialized async unsubscribe message.

Types

type ConnectResponse

type ConnectResponse struct {
	Error  *protocol.Error         `json:"error,omitempty"`
	Result *protocol.ConnectResult `json:"result,omitempty"`
}

ConnectResponse ...

type HistoryResponse

type HistoryResponse struct {
	Error  *protocol.Error         `json:"error,omitempty"`
	Result *protocol.HistoryResult `json:"result,omitempty"`
}

HistoryResponse ...

type PingResponse

type PingResponse struct {
	Error  *protocol.Error      `json:"error,omitempty"`
	Result *protocol.PingResult `json:"result,omitempty"`
}

PingResponse ...

type PresenceResponse

type PresenceResponse struct {
	Error  *protocol.Error          `json:"error,omitempty"`
	Result *protocol.PresenceResult `json:"result,omitempty"`
}

PresenceResponse ...

type PresenceStatsResponse

type PresenceStatsResponse struct {
	Error  *protocol.Error               `json:"error,omitempty"`
	Result *protocol.PresenceStatsResult `json:"result,omitempty"`
}

PresenceStatsResponse ...

type PublishResponse

type PublishResponse struct {
	Error  *protocol.Error         `json:"error,omitempty"`
	Result *protocol.PublishResult `json:"result,omitempty"`
}

PublishResponse ...

type RPCResponse

type RPCResponse struct {
	Error  *protocol.Error     `json:"error,omitempty"`
	Result *protocol.RPCResult `json:"result,omitempty"`
}

RPCResponse ...

type RefreshResponse

type RefreshResponse struct {
	Error  *protocol.Error         `json:"error,omitempty"`
	Result *protocol.RefreshResult `json:"result,omitempty"`
}

RefreshResponse ...

type SubRefreshResponse

type SubRefreshResponse struct {
	Error  *protocol.Error            `json:"error,omitempty"`
	Result *protocol.SubRefreshResult `json:"result,omitempty"`
}

SubRefreshResponse ...

type SubscribeResponse

type SubscribeResponse struct {
	Error  *protocol.Error           `json:"error,omitempty"`
	Result *protocol.SubscribeResult `json:"result,omitempty"`
}

SubscribeResponse ...

type UnsubscribeResponse

type UnsubscribeResponse struct {
	Error  *protocol.Error             `json:"error,omitempty"`
	Result *protocol.UnsubscribeResult `json:"result,omitempty"`
}

UnsubscribeResponse ...