multiplexing

Documentation

Index

• Variables
• type Service
  • func NewService(destinationService *destinations.Service) *Service
  • func (s *Service) AcceptRequest(processor events.Processor, reqContext *events.RequestContext, token string, ...) ([]map[string]interface{}, error)

Variables

var (
	ErrNoDestinations = errors.New("No destination is configured for token")
)

Types

type Service

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

Service is a service for accepting, multiplexing events and sending to consumers

func NewService

func NewService(destinationService *destinations.Service) *Service

NewService returns configured Service instance

func (*Service) AcceptRequest

func (s *Service) AcceptRequest(processor events.Processor, reqContext *events.RequestContext, token string, eventsArray []events.Event) ([]map[string]interface{}, error)

AcceptRequest multiplexes input events, enriches with context and sends to consumers