eventsplitter

Documentation

Index

• type EventSplitter
  • func New(in chan *api.EventMessage, outs ...chan *api.EventMessage) *EventSplitter
  • func (srv *EventSplitter) Run(ctx context.Context) error

Types

type EventSplitter

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

EventSplitter is a service for duplicating incoming events onto several outgoing channels.

func New

func New(in chan *api.EventMessage, outs ...chan *api.EventMessage) *EventSplitter

func (*EventSplitter) Run

func (srv *EventSplitter) Run(ctx context.Context) error