websocket

package

v1.2.40 Latest Latest Go to latest Published: Feb 17, 2026 License: AGPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func CreateCallsWebsocket(dmrHub *hub.Hub, db *gorm.DB, pubsub pubsub.PubSub) *CallsWebsocket

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

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

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

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

NetsWebsocket streams net start/stop events and optionally check-in events to connected clients.

func CreateNetsWebsocket(ps pubsub.PubSub) *NetsWebsocket

CreateNetsWebsocket creates a new NetsWebsocket.

func (n *NetsWebsocket) OnConnect(ctx context.Context, r *http.Request, w websocket.Writer, _ sessions.Session)

func (n *NetsWebsocket) OnDisconnect(_ context.Context, _ *http.Request, _ sessions.Session)

func (n *NetsWebsocket) OnMessage(_ context.Context, _ *http.Request, _ websocket.Writer, _ sessions.Session, _ []byte, _ int)

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

func CreatePeersWebsocket(db *gorm.DB, pubsub pubsub.PubSub) *PeersWebsocket

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

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

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

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

func CreateRepeatersWebsocket(db *gorm.DB, pubsub pubsub.PubSub) *RepeatersWebsocket

func (c *RepeatersWebsocket) OnConnect(_ context.Context, _ *http.Request, _ websocket.Writer, _ sessions.Session)

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

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