websockets

Documentation

Index

• Constants
• type WebSockets
  • func (ws *WebSockets) BatchDeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, ...) error
  • func (ws *WebSockets) Capabilities() *events.Capabilities
  • func (ws *WebSockets) DeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, ...) error
  • func (ws *WebSockets) GetStatus() *core.WebSocketStatus
  • func (ws *WebSockets) Init(ctx context.Context, config config.Section) error
  • func (ws *WebSockets) InitConfig(config config.Section)
  • func (ws *WebSockets) Name() string
  • func (ws *WebSockets) NamespaceRestarted(ns string, startTime time.Time)
  • func (ws *WebSockets) ServeHTTP(res http.ResponseWriter, req *http.Request)
  • func (ws *WebSockets) ServeHTTPNamespaced(namespace string, res http.ResponseWriter, req *http.Request)
  • func (ws *WebSockets) SetAuthorizer(auth core.Authorizer)
  • func (ws *WebSockets) SetHandler(namespace string, handler events.Callbacks) error
  • func (ws *WebSockets) ValidateOptions(ctx context.Context, options *core.SubscriptionOptions) error
  • func (ws *WebSockets) WaitClosed()
• type WebSocketsNamespaced

Constants

const (
	// ReadBufferSize is the read buffer size for the socket
	ReadBufferSize = "readBufferSize"
	// WriteBufferSize is the write buffer size for the socket
	WriteBufferSize = "writeBufferSize"
)

Types

type WebSockets

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

func (*WebSockets) BatchDeliveryRequest

func (ws *WebSockets) BatchDeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, events []*core.CombinedEventDataDelivery) error

func (*WebSockets) Capabilities

func (ws *WebSockets) Capabilities() *events.Capabilities

func (*WebSockets) DeliveryRequest

func (ws *WebSockets) DeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, event *core.EventDelivery, data core.DataArray) error

func (*WebSockets) GetStatus

func (ws *WebSockets) GetStatus() *core.WebSocketStatus

func (*WebSockets) Init

func (ws *WebSockets) Init(ctx context.Context, config config.Section) error

func (*WebSockets) InitConfig

func (ws *WebSockets) InitConfig(config config.Section)

func (*WebSockets) Name

func (ws *WebSockets) Name() string

func (*WebSockets) NamespaceRestarted

func (ws *WebSockets) NamespaceRestarted(ns string, startTime time.Time)

func (*WebSockets) ServeHTTP

func (ws *WebSockets) ServeHTTP(res http.ResponseWriter, req *http.Request)

func (*WebSockets) ServeHTTPNamespaced

func (ws *WebSockets) ServeHTTPNamespaced(namespace string, res http.ResponseWriter, req *http.Request)

func (*WebSockets) SetAuthorizer

func (ws *WebSockets) SetAuthorizer(auth core.Authorizer)

func (*WebSockets) SetHandler

func (ws *WebSockets) SetHandler(namespace string, handler events.Callbacks) error

func (*WebSockets) ValidateOptions

func (ws *WebSockets) ValidateOptions(ctx context.Context, options *core.SubscriptionOptions) error

func (*WebSockets) WaitClosed

func (ws *WebSockets) WaitClosed()

type WebSocketsNamespaced

type WebSocketsNamespaced interface {
	ServeHTTPNamespaced(namespace string, res http.ResponseWriter, req *http.Request)
}