backend

Sep 30, 2024

Changes in this version

+ type WSBackendOptions func(*WSBackend)

+ func WithWSDialler(dialer WSDialler) WSBackendOptions

+ type WSDialler func(ctx context.Context, baseURL string) (*websocket.Conn, error)

Jun 30, 2024

Changes in this version

+ var ErrNotEnoughBackends = fmt.Errorf("load balancer requires at least 2 backends")

+ type LoadBalancer struct

+ func NewLoadBalancer(backends []wasabi.RequestHandler) (*LoadBalancer, error)

+ func (lb *LoadBalancer) Handle(conn wasabi.Connection, r wasabi.Request) error

+ type LoadBalancerNode struct

Jun 13, 2024

Changes in this version

type HTTPBackendOption

+ func WithMaxRequestsPerHost(maxReqPerHost int) HTTPBackendOption

May 25, 2024

Changes in this version

+ type OnRequestCallback func(conn wasabi.Connection, req wasabi.Request, id string) error

+ type QueueBackend struct

+ func NewQueueBackend(onRequest OnRequestCallback) *QueueBackend

+ func (b *QueueBackend) Handle(conn wasabi.Connection, r wasabi.Request) error

+ func (b *QueueBackend) OnResponse(id string, msgType websocket.MessageType, data []byte)

May 18, 2024

Changes in this version

+ type WSBackend struct

+ URL string

+ func NewWSBackend(url string, factory WSRequestFactory) *WSBackend

+ func (b *WSBackend) Handle(conn wasabi.Connection, r wasabi.Request) error

+ type WSRequestFactory func(r wasabi.Request) (websocket.MessageType, []byte, error)

Apr 29, 2024

Changes in this version

+ type HTTPBackend struct

+ func NewBackend(factory RequestFactory, options ...HTTPBackendOption) *HTTPBackend

+ func (b *HTTPBackend) Handle(conn wasabi.Connection, r wasabi.Request) error

+ type HTTPBackendOption func(*httpBackendConfig)

+ func WithTimeout(timeout time.Duration) HTTPBackendOption

+ type RequestFactory func(req wasabi.Request) (*http.Request, error)