sse

Jan 18, 2023

Changes in this version

type Client

+ LastEventID atomic.Value

type Server

+ func (s *Server) TryPublish(id string, event *Event) bool

Nov 15, 2022

Changes in this version

type Client

+ Connected bool

+ func (c *Client) OnConnect(fn ConnCallback)

Jul 13, 2022

Changes in this version

type Event

+ Comment []byte

May 12, 2022

Changes in this version

type Server

+ OnSubscribe func(streamID string, sub *Subscriber)

+ OnUnsubscribe func(streamID string, sub *Subscriber)

+ func NewWithCallback(onSubscribe, onUnsubscribe func(streamID string, sub *Subscriber)) *Server

type Stream

+ ID string

+ OnSubscribe func(streamID string, sub *Subscriber)

+ OnUnsubscribe func(streamID string, sub *Subscriber)

type Subscriber

+ URL *url.URL

Nov 10, 2021

Changes in this version

+ func ClientMaxBufferSize(s int) func(c *Client)

Nov 8, 2021

Changes in this version

type Server

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

May 24, 2021

Changes in this version

type Server

+ SplitData bool

Oct 7, 2020

Changes in this version

+ const DefaultBufferSize

+ type Client struct

+ Connection *http.Client

+ EncodingBase64 bool

+ EventID string

+ Headers map[string]string

+ ReconnectNotify backoff.Notify

+ ReconnectStrategy backoff.BackOff

+ ResponseValidator ResponseValidator

+ Retry time.Time

+ URL string

+ func NewClient(url string) *Client

+ func (c *Client) OnDisconnect(fn ConnCallback)

+ func (c *Client) Subscribe(stream string, handler func(msg *Event)) error

+ func (c *Client) SubscribeChan(stream string, ch chan *Event) error

+ func (c *Client) SubscribeChanRaw(ch chan *Event) error

+ func (c *Client) SubscribeChanRawWithContext(ctx context.Context, ch chan *Event) error

+ func (c *Client) SubscribeChanWithContext(ctx context.Context, stream string, ch chan *Event) error

+ func (c *Client) SubscribeRaw(handler func(msg *Event)) error

+ func (c *Client) SubscribeRawWithContext(ctx context.Context, handler func(msg *Event)) error

+ func (c *Client) SubscribeWithContext(ctx context.Context, stream string, handler func(msg *Event)) error

+ func (c *Client) Unsubscribe(ch chan *Event)

+ type ConnCallback func(c *Client)

+ type Event struct

+ Data []byte

+ Event []byte

+ ID []byte

+ Retry []byte

+ type EventLog []*Event

+ func (e *EventLog) Add(ev *Event)

+ func (e *EventLog) Clear()

+ func (e *EventLog) Replay(s *Subscriber)

+ type EventStreamReader struct

+ func NewEventStreamReader(eventStream io.Reader) *EventStreamReader

+ func (e *EventStreamReader) ReadEvent() ([]byte, error)

+ type ResponseValidator func(c *Client, resp *http.Response) error

+ type Server struct

+ AutoReplay bool

+ AutoStream bool

+ BufferSize int

+ EncodeBase64 bool

+ EventTTL time.Duration

+ Headers map[string]string

+ Streams map[string]*Stream

+ func New() *Server

+ func (s *Server) Close()

+ func (s *Server) CreateStream(id string) *Stream

+ func (s *Server) HTTPHandler(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Publish(id string, event *Event)

+ func (s *Server) RemoveStream(id string)

+ func (s *Server) StreamExists(id string) bool

+ type Stream struct

+ AutoReplay bool

+ Eventlog EventLog

+ type StreamRegistration struct

+ type Subscriber struct