sse

Documentation

Index

• func Stream(logger *zap.Logger, handler handlerFunc) func(http.ResponseWriter, *http.Request, int, bool) error
• type Event
• type Handler
  • func NewHandler(blockSource sources.BlockSource, blockHeadersSource sources.BlockHeadersSource, ...) *Handler
  • func (h *Handler) SubscribeToBlockHeaders(session *session, request *http.Request) error
  • func (h *Handler) SubscribeToBlocks(session *session, request *http.Request) error
  • func (h *Handler) SubscribeToMessages(session *session, request *http.Request) error
  • func (h *Handler) SubscribeToTraces(session *session, request *http.Request) error
  • func (h *Handler) SubscribeToTransactions(session *session, request *http.Request) error

Functions

func Stream

func Stream(logger *zap.Logger, handler handlerFunc) func(http.ResponseWriter, *http.Request, int, bool) error

Types

type Event

type Event struct {
	Name    events.Name
	EventID int64  `json:"event_id"`
	Data    []byte `json:"data"`
}

type Handler

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

Handler handles http methods for sse.

func NewHandler

func NewHandler(blockSource sources.BlockSource, blockHeadersSource sources.BlockHeadersSource, txSource sources.TransactionSource, traceSource sources.TraceSource, memPool sources.MemPoolSource) *Handler

func (*Handler) SubscribeToBlockHeaders

func (h *Handler) SubscribeToBlockHeaders(session *session, request *http.Request) error

func (*Handler) SubscribeToBlocks

func (h *Handler) SubscribeToBlocks(session *session, request *http.Request) error

func (*Handler) SubscribeToMessages

func (h *Handler) SubscribeToMessages(session *session, request *http.Request) error

func (*Handler) SubscribeToTraces

func (h *Handler) SubscribeToTraces(session *session, request *http.Request) error

func (*Handler) SubscribeToTransactions

func (h *Handler) SubscribeToTransactions(session *session, request *http.Request) error