events

Documentation

Index

• type EventStreamer
  • func NewEventStreamer() *EventStreamer
  • func (e *EventStreamer) Publish(i interface{})
  • func (e *EventStreamer) Subscribe(ch chan interface{})

Types

type EventStreamer

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

func NewEventStreamer

func NewEventStreamer() *EventStreamer

func (*EventStreamer) Publish

func (e *EventStreamer) Publish(i interface{})

func (*EventStreamer) Subscribe

func (e *EventStreamer) Subscribe(ch chan interface{})