websocket

Documentation

Index

• type CallsWebsocket
  • func CreateCallsWebsocket(db *gorm.DB, redis *redis.Client) *CallsWebsocket
  • func (c *CallsWebsocket) OnConnect(ctx context.Context, r *http.Request, w websocket.Writer, ...)
  • func (c *CallsWebsocket) OnDisconnect(ctx context.Context, r *http.Request, _ sessions.Session)
  • func (c *CallsWebsocket) OnMessage(ctx context.Context, r *http.Request, w websocket.Writer, _ sessions.Session, ...)
• type PeersWebsocket
  • func CreatePeersWebsocket(db *gorm.DB, redis *redis.Client) *PeersWebsocket
  • func (c *PeersWebsocket) OnConnect(ctx context.Context, r *http.Request, w websocket.Writer, ...)
  • func (c *PeersWebsocket) OnDisconnect(ctx context.Context, r *http.Request, _ sessions.Session)
  • func (c *PeersWebsocket) OnMessage(ctx context.Context, r *http.Request, w websocket.Writer, _ sessions.Session, ...)
• type RepeatersWebsocket
  • func CreateRepeatersWebsocket(db *gorm.DB, redis *redis.Client) *RepeatersWebsocket
  • func (c *RepeatersWebsocket) OnConnect(ctx context.Context, r *http.Request, w websocket.Writer, ...)
  • func (c *RepeatersWebsocket) OnDisconnect(ctx context.Context, r *http.Request, _ sessions.Session)
  • func (c *RepeatersWebsocket) OnMessage(ctx context.Context, r *http.Request, w websocket.Writer, _ sessions.Session, ...)

Types

type CallsWebsocket

type CallsWebsocket struct {
	websocket.Websocket
	// contains filtered or unexported fields
}

func CreateCallsWebsocket

func CreateCallsWebsocket(db *gorm.DB, redis *redis.Client) *CallsWebsocket

func (*CallsWebsocket) OnConnect

func (c *CallsWebsocket) OnConnect(ctx context.Context, r *http.Request, w websocket.Writer, session sessions.Session)

func (*CallsWebsocket) OnDisconnect

func (c *CallsWebsocket) OnDisconnect(ctx context.Context, r *http.Request, _ sessions.Session)

func (*CallsWebsocket) OnMessage

func (c *CallsWebsocket) OnMessage(ctx context.Context, r *http.Request, w websocket.Writer, _ sessions.Session, msg []byte, t int)

type PeersWebsocket

type PeersWebsocket struct {
	websocket.Websocket
	// contains filtered or unexported fields
}

func CreatePeersWebsocket

func CreatePeersWebsocket(db *gorm.DB, redis *redis.Client) *PeersWebsocket

func (*PeersWebsocket) OnConnect

func (c *PeersWebsocket) OnConnect(ctx context.Context, r *http.Request, w websocket.Writer, session sessions.Session)

func (*PeersWebsocket) OnDisconnect

func (c *PeersWebsocket) OnDisconnect(ctx context.Context, r *http.Request, _ sessions.Session)

func (*PeersWebsocket) OnMessage

func (c *PeersWebsocket) OnMessage(ctx context.Context, r *http.Request, w websocket.Writer, _ sessions.Session, msg []byte, t int)

type RepeatersWebsocket

type RepeatersWebsocket struct {
	websocket.Websocket
	// contains filtered or unexported fields
}

func CreateRepeatersWebsocket

func CreateRepeatersWebsocket(db *gorm.DB, redis *redis.Client) *RepeatersWebsocket

func (*RepeatersWebsocket) OnConnect

func (c *RepeatersWebsocket) OnConnect(ctx context.Context, r *http.Request, w websocket.Writer, session sessions.Session)

func (*RepeatersWebsocket) OnDisconnect

func (c *RepeatersWebsocket) OnDisconnect(ctx context.Context, r *http.Request, _ sessions.Session)

func (*RepeatersWebsocket) OnMessage

func (c *RepeatersWebsocket) OnMessage(ctx context.Context, r *http.Request, w websocket.Writer, _ sessions.Session, msg []byte, t int)