loudvents

Documentation

Index

• type LoudVentsMessageDispatcher
  • func NewMessageDispatcher(args *LoudVentsMessageDispatcherArgs) *LoudVentsMessageDispatcher
  • func (d *LoudVentsMessageDispatcher) GetHandler(ctx context.Context) multichannelfanout.MultiChannelMessageHandler
  • func (d *LoudVentsMessageDispatcher) Start(ctx context.Context) error
  • func (d *LoudVentsMessageDispatcher) WaitReady()
• type LoudVentsMessageDispatcherArgs
• type MessageDispatcher

Types

type LoudVentsMessageDispatcher

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

func NewMessageDispatcher

func NewMessageDispatcher(args *LoudVentsMessageDispatcherArgs) *LoudVentsMessageDispatcher

func (*LoudVentsMessageDispatcher) GetHandler

func (d *LoudVentsMessageDispatcher) GetHandler(ctx context.Context) multichannelfanout.MultiChannelMessageHandler

GetHandler gets the current multichannelfanout.MessageHandler to delegate all HTTP requests to.

func (*LoudVentsMessageDispatcher) Start

func (d *LoudVentsMessageDispatcher) Start(ctx context.Context) error

Start starts the loudvents dispatcher's message processing. This is a blocking call.

func (*LoudVentsMessageDispatcher) WaitReady

func (d *LoudVentsMessageDispatcher) WaitReady()

WaitReady blocks until the dispatcher's server is ready to receive requests.

type LoudVentsMessageDispatcherArgs

type LoudVentsMessageDispatcherArgs struct {
	Port                       int
	ReadTimeout                time.Duration
	WriteTimeout               time.Duration
	Handler                    multichannelfanout.MultiChannelMessageHandler
	Logger                     *zap.Logger
	HTTPMessageReceiverOptions []kncloudevents.HTTPMessageReceiverOption
}

type MessageDispatcher

type MessageDispatcher interface {
	GetHandler(ctx context.Context) multichannelfanout.MultiChannelMessageHandler
}