clientproto

Documentation

Index

• func NewConnectPush(data protocol.Raw) *protocol.Push
• func NewDisconnectPush(data protocol.Raw) *protocol.Push
• 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 NewRefreshPush(data protocol.Raw) *protocol.Push
• func NewSubscribePush(ch string, data protocol.Raw) *protocol.Push
• func NewUnsubscribePush(ch string, data protocol.Raw) *protocol.Push

Functions

func NewConnectPush

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

NewConnPush returns initialized async connect message.

func NewDisconnectPush

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

NewDisconnectPush returns initialized async disconnect message.

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 NewRefreshPush

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

NewRefreshPush returns initialized async refresh message.

func NewSubscribePush

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

NewSubscribePush returns initialized async subscribe message.

func NewUnsubscribePush

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

NewUnsubscribePush returns initialized async unsubscribe message.