websockets

Documentation

Index

• Constants
• type WebSockets
  • func (ws *WebSockets) Capabilities() *events.Capabilities
  • func (ws *WebSockets) DeliveryRequest(connID string, sub *core.Subscription, event *core.EventDelivery, ...) 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) ServeHTTP(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(options *core.SubscriptionOptions) error
  • func (ws *WebSockets) WaitClosed()

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) Capabilities

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

func (*WebSockets) DeliveryRequest

func (ws *WebSockets) DeliveryRequest(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) ServeHTTP

func (ws *WebSockets) ServeHTTP(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(options *core.SubscriptionOptions) error

func (*WebSockets) WaitClosed

func (ws *WebSockets) WaitClosed()