sse

Documentation

Index

• type Config
• type Logger
• type Transport
  • func NewTransport(s server.Server, config *Config) *Transport
  • func (t *Transport) GetHandler() http.Handler
  • func (t *Transport) Publish(eventType string, data interface{}) error
  • func (t *Transport) Start() error
  • func (t *Transport) StartAsync() error
  • func (t *Transport) Stop() error

Types

type Config

type Config struct {
	// Address to listen on (e.g. ":8080")
	Address string
	// Path for SSE events endpoint (e.g. "/events")
	EventsPath string
	// Path for JSON-RPC endpoint (e.g. "/rpc")
	RPCPath string
	// Optional logger
	Logger Logger
}

Config holds the configuration for the SSE transport

type Logger

type Logger interface {
	Printf(format string, v ...interface{})
}

Logger interface for transport logging

type Transport

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

Transport implements a server transport using Server-Sent Events (SSE)

func NewTransport

func NewTransport(s server.Server, config *Config) *Transport

NewTransport creates a new SSE transport

func (*Transport) GetHandler

func (t *Transport) GetHandler() http.Handler

GetHandler returns the HTTP handler for the transport

func (*Transport) Publish

func (t *Transport) Publish(eventType string, data interface{}) error

Publish publishes an event to all connected clients

func (*Transport) Start

func (t *Transport) Start() error

Start starts the transport

func (*Transport) StartAsync

func (t *Transport) StartAsync() error

Start starts the transport in a goroutine

func (*Transport) Stop

func (t *Transport) Stop() error

Stop stops the transport