sse

Documentation

Index

• func CreateQueryHandler(cmd cmds.Command, middlewares_ ...middlewares.Middleware) echo.HandlerFunc
• type QueryHandler
  • func NewQueryHandler(cmd cmds.Command, options ...QueryHandlerOption) *QueryHandler
  • func (h *QueryHandler) Handle(c echo.Context) error
• type QueryHandlerOption
  • func WithMiddlewares(middlewares ...middlewares.Middleware) QueryHandlerOption
• type SSEWriter
  • func NewSSEWriter() *SSEWriter
  • func (w *SSEWriter) Close()
  • func (w *SSEWriter) Write(p []byte) (int, error)

Functions

func CreateQueryHandler

func CreateQueryHandler(
	cmd cmds.Command,
	middlewares_ ...middlewares.Middleware,
) echo.HandlerFunc

Types

type QueryHandler

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

func NewQueryHandler

func NewQueryHandler(cmd cmds.Command, options ...QueryHandlerOption) *QueryHandler

func (*QueryHandler) Handle

func (h *QueryHandler) Handle(c echo.Context) error

type QueryHandlerOption

type QueryHandlerOption func(*QueryHandler)

func WithMiddlewares

func WithMiddlewares(middlewares ...middlewares.Middleware) QueryHandlerOption

type SSEWriter

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

SSEWriter implements io.Writer to emit written bytes as SSE over HTTP.

func NewSSEWriter

func NewSSEWriter() *SSEWriter

func (*SSEWriter) Close

func (w *SSEWriter) Close()

func (*SSEWriter) Write

func (w *SSEWriter) Write(p []byte) (int, error)