pubsub

Documentation

Index

• type Event
• type EventPublisher
  • func CreateNewEventPublisher() *EventPublisher
  • func (e *EventPublisher) AppendNewConnection(conn *websocket.Conn)
  • func (e *EventPublisher) Full() bool
  • func (e *EventPublisher) Publish(data []byte)
  • func (e *EventPublisher) SelectPosition() int
• type EventRequest
  • func DeserializeEventRequest(requestStr []byte) (*EventRequest, error)
• type EventRouter
  • func CreateNewEventRouter() *EventRouter
  • func (e *EventRouter) AppendEvent(event Event)
  • func (e *EventRouter) HandleConnect(w http.ResponseWriter, r *http.Request)
  • func (e *EventRouter) Process()
• type EventTopic

Types

type Event

type Event struct {
	Type    string            `json:"type"`
	Hash    string            `json:"hash"`
	Height  string            `json:"height"`
	Address string            `json:"address"`
	Params  map[string]string `json:"params"`
}

type EventPublisher

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

func CreateNewEventPublisher

func CreateNewEventPublisher() *EventPublisher

func (*EventPublisher) AppendNewConnection

func (e *EventPublisher) AppendNewConnection(conn *websocket.Conn)

func (*EventPublisher) Full

func (e *EventPublisher) Full() bool

func (*EventPublisher) Publish

func (e *EventPublisher) Publish(data []byte)

func (*EventPublisher) SelectPosition

func (e *EventPublisher) SelectPosition() int

type EventRequest

type EventRequest struct {
	Address   string `json:"address"`
	EventType string `json:"type"`
}

func DeserializeEventRequest

func DeserializeEventRequest(requestStr []byte) (*EventRequest, error)

type EventRouter

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

func CreateNewEventRouter

func CreateNewEventRouter() *EventRouter

func (*EventRouter) AppendEvent

func (e *EventRouter) AppendEvent(event Event)

func (*EventRouter) HandleConnect

func (e *EventRouter) HandleConnect(w http.ResponseWriter, r *http.Request)

func (*EventRouter) Process

func (e *EventRouter) Process()

type EventTopic

type EventTopic string