inmemorychannel

Documentation

Index

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

Types

type InMemoryMessageDispatcher

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

func NewMessageDispatcher

func NewMessageDispatcher(args *InMemoryMessageDispatcherArgs) *InMemoryMessageDispatcher

func (*InMemoryMessageDispatcher) GetHandler

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

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

func (*InMemoryMessageDispatcher) Start

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

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

func (*InMemoryMessageDispatcher) WaitReady

func (d *InMemoryMessageDispatcher) WaitReady()

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

type InMemoryMessageDispatcherArgs

type InMemoryMessageDispatcherArgs 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
}