sse

Documentation

Index

• func Stream(handler handlerFunc) func(writer http.ResponseWriter, request *http.Request, methodType int) error
• type Event
• type Handler
  • func NewHandler(txSource sources.TransactionSource, memPool sources.MemPoolSource) *Handler
  • func (h *Handler) SubscribeToMessages(session *session, request *http.Request) error
  • func (h *Handler) SubscribeToTransactions(session *session, request *http.Request) error

Functions

func Stream

func Stream(handler handlerFunc) func(writer http.ResponseWriter, request *http.Request, methodType int) 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(txSource sources.TransactionSource, memPool sources.MemPoolSource) *Handler

func (*Handler) SubscribeToMessages

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

func (*Handler) SubscribeToTransactions

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