websockets

Documentation

Index

• type Config
  • func NewDefaultWebsocketConfig() Config
• type Controller
  • func NewWebSocketController(logger zerolog.Logger, config Config, streamApi state_stream.API, ...) *Controller
  • func (c *Controller) HandleConnection(ctx context.Context)
• type Handler
  • func NewWebSocketHandler(logger zerolog.Logger, config Config, chain flow.Chain, ...) *Handler
  • func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type Config

type Config struct {
	MaxSubscriptionsPerConnection uint64
	MaxResponsesPerSecond         uint64
	SendMessageTimeout            time.Duration
	MaxRequestSize                int64
}

func NewDefaultWebsocketConfig

func NewDefaultWebsocketConfig() Config

type Controller

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

func NewWebSocketController

func NewWebSocketController(
	logger zerolog.Logger,
	config Config,
	streamApi state_stream.API,
	streamConfig backend.Config,
	conn *websocket.Conn,
) *Controller

func (*Controller) HandleConnection

func (c *Controller) HandleConnection(ctx context.Context)

HandleConnection manages the WebSocket connection, adding context and error handling.

type Handler

type Handler struct {
	*common.HttpHandler
	// contains filtered or unexported fields
}

func NewWebSocketHandler

func NewWebSocketHandler(
	logger zerolog.Logger,
	config Config,
	chain flow.Chain,
	streamApi state_stream.API,
	streamConfig backend.Config,
	maxRequestSize int64,
) *Handler

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)