websocket

Documentation

Index

• type EventsWebsocket
  • func CreateEventsWebsocket(eventsChannel chan events.Event) *EventsWebsocket
  • func (c *EventsWebsocket) OnConnect(ctx context.Context, _ *http.Request, w websocket.Writer, ...)
  • func (c *EventsWebsocket) OnDisconnect(ctx context.Context, _ *http.Request, messageType events.EventType, ...)
  • func (c *EventsWebsocket) OnMessage(_ context.Context, _ *http.Request, _ websocket.Writer, _ []byte, _ int)

Types

type EventsWebsocket

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

func CreateEventsWebsocket

func CreateEventsWebsocket(eventsChannel chan events.Event) *EventsWebsocket

func (*EventsWebsocket) OnConnect

func (c *EventsWebsocket) OnConnect(ctx context.Context, _ *http.Request, w websocket.Writer, messageType events.EventType, station string, sqsListener *sqs.Listener)

func (*EventsWebsocket) OnDisconnect

func (c *EventsWebsocket) OnDisconnect(ctx context.Context, _ *http.Request, messageType events.EventType, station string, sqsListener *sqs.Listener)

func (*EventsWebsocket) OnMessage

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