Versions in this module Expand all Collapse all v2 v2.0.1 Jun 3, 2020 Changes in this version + var ErrRateLimited = errors.New("Rate limit exceeded") + func WriteEvent(ctx context.Context, w http.ResponseWriter, e Event) + func WritePreamble(ctx context.Context, w http.ResponseWriter) bool + type Event struct + Data interface{} + Error error + Event string + ID string + Retry int + func (e Event) SseEvent() Event + type Eventable interface + SseEvent func() Event + type GenerateEventsFunc func() ([]Event, error) + type LedgerSourceFactory interface + Get func() ledger.Source + type Stream struct + func NewStream(ctx context.Context, w http.ResponseWriter) *Stream + func (s *Stream) Done() + func (s *Stream) Err(err error) + func (s *Stream) Init() + func (s *Stream) IsDone() bool + func (s *Stream) Send(e Event) + func (s *Stream) SentCount() int + func (s *Stream) SetLimit(limit int) + type StreamHandler struct + LedgerSourceFactory LedgerSourceFactory + RateLimiter *throttled.HTTPRateLimiter + func (handler StreamHandler) ServeStream(w http.ResponseWriter, r *http.Request, limit int, ...)