platform

Documentation

Index

• Variables
• func NewBroker(conf config.Broker) (broker.Broker, error)
• func NewEventProcessor(conf config.Processor) (processor.EventProcessor, error)
• func NewEventProcessorSet(conf []config.Processor) ([]processor.EventProcessor, error)
• func RegisterEventProcessor(name string, proc processor.Constructor)

Variables

var (
	Brokers = map[string]func(...broker.Option) broker.Broker{
		"nsq": nsq.NewDefault,
	}
)

var ErrInvalidBroker = errors.New("invalid broker")

Functions

func NewBroker

func NewBroker(conf config.Broker) (broker.Broker, error)

func NewEventProcessor

func NewEventProcessor(conf config.Processor) (processor.EventProcessor, error)

func NewEventProcessorSet

func NewEventProcessorSet(conf []config.Processor) ([]processor.EventProcessor, error)

func RegisterEventProcessor

func RegisterEventProcessor(name string, proc processor.Constructor)