stream

Documentation

Index

• type EventData
• type RorEvent
  • func NewRorEvent(eventType string, data string) RorEvent
• type StreamInterface

Types

type EventData

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

type RorEvent

type RorEvent struct {
	Type string
	Data []byte
}

func NewRorEvent

func NewRorEvent(eventType string, data string) RorEvent

type StreamInterface

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