websockets

Documentation

Index

• Constants
• type WebSockets
  • func (ws *WebSockets) Capabilities() *events.Capabilities
  • func (ws *WebSockets) ChangeEvent(connID string, ce *fftypes.ChangeEvent)
  • func (ws *WebSockets) DeliveryRequest(connID string, sub *fftypes.Subscription, event *fftypes.EventDelivery, ...) error
  • func (ws *WebSockets) GetOptionsSchema(ctx context.Context) string
  • func (ws *WebSockets) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) error
  • func (ws *WebSockets) InitPrefix(prefix config.Prefix)
  • func (ws *WebSockets) Name() string
  • func (ws *WebSockets) ServeHTTP(res http.ResponseWriter, req *http.Request)
  • func (ws *WebSockets) ValidateOptions(options *fftypes.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) ChangeEvent

func (ws *WebSockets) ChangeEvent(connID string, ce *fftypes.ChangeEvent)

func (*WebSockets) DeliveryRequest

func (ws *WebSockets) DeliveryRequest(connID string, sub *fftypes.Subscription, event *fftypes.EventDelivery, data []*fftypes.Data) error

func (*WebSockets) GetOptionsSchema

func (ws *WebSockets) GetOptionsSchema(ctx context.Context) string

func (*WebSockets) Init

func (ws *WebSockets) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) error

func (*WebSockets) InitPrefix

func (ws *WebSockets) InitPrefix(prefix config.Prefix)

func (*WebSockets) Name

func (ws *WebSockets) Name() string

func (*WebSockets) ServeHTTP

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

func (*WebSockets) ValidateOptions

func (ws *WebSockets) ValidateOptions(options *fftypes.SubscriptionOptions) error

func (*WebSockets) WaitClosed

func (ws *WebSockets) WaitClosed()