stream

Documentation

Index

• type API
  • func New(pingPeriod, pongTimeout time.Duration) *API
  • func (a *API) Close()
  • func (a *API) Handle(ctx *gin.Context)
  • func (a *API) Notify(userID uint, msg *model.Message)
  • func (a *API) NotifyDeletedClient(userID uint, token string)
  • func (a *API) NotifyDeletedUser(userID uint)

Types

type API

type API struct {
	// contains filtered or unexported fields
}

The API provides a handler for a WebSocket stream API.

func New

func New(pingPeriod, pongTimeout time.Duration) *API

New creates a new instance of API. pingPeriod: is the interval, in which is server sends the a ping to the client. pongTimeout: is the duration after the connection will be terminated, when the client does not respond with the pong command.

func (*API) Close

func (a *API) Close()

Close closes all client connections and stops answering new connections.

func (*API) Handle

func (a *API) Handle(ctx *gin.Context)

Handle handles incoming requests. First it upgrades the protocol to the WebSocket protocol and then starts listening for read and writes.

func (*API) Notify

func (a *API) Notify(userID uint, msg *model.Message)

Notify notifies the clients with the given userID that a new messages was created.

func (*API) NotifyDeletedClient

func (a *API) NotifyDeletedClient(userID uint, token string)

NotifyDeletedClient closes existing connections with the given token.

func (*API) NotifyDeletedUser

func (a *API) NotifyDeletedUser(userID uint)

NotifyDeletedUser closes existing connections for the given user.