v2stream

Documentation

Index

• type EventData
• type RorEvent
  • func NewRorEvent(eventType string, data []byte) RorEvent
  • func NewRorEventAsJSON(eventType string, data string) RorEvent
• type StreamInterface

Types

type EventData

type EventData struct {
	Id    string `json:"id"`
	Event string `json:"event"`
	Data  string `json:"data"`
}

type RorEvent

type RorEvent struct {
	Type string `json:"event"`
	Data []byte `json:"data"`
}

func NewRorEvent

func NewRorEvent(eventType string, data []byte) RorEvent

func NewRorEventAsJSON

func NewRorEventAsJSON(eventType string, data string) RorEvent

type StreamInterface

type StreamInterface interface {
	StartEventstream() (<-chan RorEvent, error)
	StartEventstreamWithCallback(callbackfunc func(RorEvent)) (<-chan struct{}, error)
	BroadcastEvent(event RorEvent) error
}