events

Documentation

Index

• Variables
• type EventReceiver
  • func NewDefaultReceiver() EventReceiver
  • func NewReceiver(protocol string, address string) EventReceiver
• type Receiver
  • func (receiver *Receiver) GetAddress() string
  • func (receiver *Receiver) GetEventQueue() chan *eventmessages.FactomEvent
  • func (receiver *Receiver) GetState() runstate.RunState
  • func (receiver *Receiver) Start()
  • func (receiver *Receiver) Stop()

Variables

var (
	StandardChannelSize = 5000
)

Types

type EventReceiver

type EventReceiver interface {
	Start()
	Stop()
	GetState() runstate.RunState
	GetEventQueue() chan *eventmessages.FactomEvent
	GetAddress() string
}

func NewDefaultReceiver

func NewDefaultReceiver() EventReceiver

func NewReceiver

func NewReceiver(protocol string, address string) EventReceiver

type Receiver

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

func (*Receiver) GetAddress

func (receiver *Receiver) GetAddress() string

func (*Receiver) GetEventQueue

func (receiver *Receiver) GetEventQueue() chan *eventmessages.FactomEvent

func (*Receiver) GetState

func (receiver *Receiver) GetState() runstate.RunState

func (*Receiver) Start

func (receiver *Receiver) Start()

func (*Receiver) Stop

func (receiver *Receiver) Stop()