eventservices

Documentation

Index

• func ConvertTimeToTimestamp(t time.Time) *types.Timestamp
• func MapAdminBlock(block interfaces.IAdminBlock) *eventmessages.AdminBlock
• func MapToFactomEvent(eventInput eventinput.EventInput, ...) (*eventmessages.FactomEvent, error)
• type EventSender
  • func NewEventSender(config *util.FactomdConfig, factomParams *globals.FactomParams) EventSender
  • func NewEventSenderTo(params *EventServiceParams) EventSender
• type EventServiceParams
• type RCD

Functions

func ConvertTimeToTimestamp

func ConvertTimeToTimestamp(t time.Time) *types.Timestamp

func MapAdminBlock

func MapAdminBlock(block interfaces.IAdminBlock) *eventmessages.AdminBlock

func MapToFactomEvent

func MapToFactomEvent(eventInput eventinput.EventInput, broadcastContent eventconfig.BroadcastContent, sendStateChangeEvents bool) (*eventmessages.FactomEvent, error)

Types

type EventSender

type EventSender interface {
	// Send(event eventinput.EventInput) error
	GetBroadcastContent() eventconfig.BroadcastContent
	Shutdown()
	IsSendStateChangeEvents() bool
	ReplayDuringStartup() bool
	GetEventQueue() chan *eventmessages.FactomEvent
	IncreaseDroppedFromQueueCounter()
}

func NewEventSender

func NewEventSender(config *util.FactomdConfig, factomParams *globals.FactomParams) EventSender

func NewEventSenderTo

func NewEventSenderTo(params *EventServiceParams) EventSender

type EventServiceParams

type EventServiceParams struct {
	EnableLiveFeedAPI     bool
	Protocol              string
	Address               string
	ClientPort            string
	OutputFormat          eventconfig.EventFormat
	ReplayDuringStartup   bool
	SendStateChangeEvents bool
	BroadcastContent      eventconfig.BroadcastContent
	PersistentReconnect   bool
}

type RCD

type RCD interface {
	GetPublicKey() []byte
}