worker

Documentation

Index

• type EventPoolWorker
• type LoggingEventPoolWorker
  • func (worker *LoggingEventPoolWorker) IsActive() bool
  • func (worker *LoggingEventPoolWorker) OnEvent(event *models.Event)
  • func (worker *LoggingEventPoolWorker) SetUp()
  • func (worker *LoggingEventPoolWorker) Shutdown()
• type RabbitMqEventPoolWorker
  • func (w *RabbitMqEventPoolWorker) IsActive() bool
  • func (w *RabbitMqEventPoolWorker) OnEvent(event *models.Event)
  • func (w *RabbitMqEventPoolWorker) SetUp()
  • func (w *RabbitMqEventPoolWorker) Shutdown()

Types

type EventPoolWorker

type EventPoolWorker interface {
	SetUp()
	Shutdown()
	IsActive() bool
	OnEvent(event *models.Event)
}

type LoggingEventPoolWorker

type LoggingEventPoolWorker struct {
}

func (*LoggingEventPoolWorker) IsActive

func (worker *LoggingEventPoolWorker) IsActive() bool

func (*LoggingEventPoolWorker) OnEvent

func (worker *LoggingEventPoolWorker) OnEvent(event *models.Event)

func (*LoggingEventPoolWorker) SetUp

func (worker *LoggingEventPoolWorker) SetUp()

func (*LoggingEventPoolWorker) Shutdown

func (worker *LoggingEventPoolWorker) Shutdown()

type RabbitMqEventPoolWorker

type RabbitMqEventPoolWorker struct {
	Endpoint string
	// contains filtered or unexported fields
}

func (*RabbitMqEventPoolWorker) IsActive

func (w *RabbitMqEventPoolWorker) IsActive() bool

func (*RabbitMqEventPoolWorker) OnEvent

func (w *RabbitMqEventPoolWorker) OnEvent(event *models.Event)

func (*RabbitMqEventPoolWorker) SetUp

func (w *RabbitMqEventPoolWorker) SetUp()

func (*RabbitMqEventPoolWorker) Shutdown

func (w *RabbitMqEventPoolWorker) Shutdown()