inmemorychannel

Documentation

Index

• type EventDispatcher
• type InMemoryEventDispatcher
  • func NewEventDispatcher(args *InMemoryEventDispatcherArgs) *InMemoryEventDispatcher
  • func (d *InMemoryEventDispatcher) GetHandler(ctx context.Context) multichannelfanout.MultiChannelEventHandler
  • func (d *InMemoryEventDispatcher) GetReceiver() kncloudevents.HTTPEventReceiver
  • func (d *InMemoryEventDispatcher) Start(ctx context.Context) error
  • func (d *InMemoryEventDispatcher) WaitReady()
• type InMemoryEventDispatcherArgs

Types

type EventDispatcher

type EventDispatcher interface {
	GetHandler(ctx context.Context) multichannelfanout.MultiChannelEventHandler
}

type InMemoryEventDispatcher

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

func NewEventDispatcher

func NewEventDispatcher(args *InMemoryEventDispatcherArgs) *InMemoryEventDispatcher

func (*InMemoryEventDispatcher) GetHandler

func (d *InMemoryEventDispatcher) GetHandler(ctx context.Context) multichannelfanout.MultiChannelEventHandler

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

func (*InMemoryEventDispatcher) GetReceiver

func (d *InMemoryEventDispatcher) GetReceiver() kncloudevents.HTTPEventReceiver

func (*InMemoryEventDispatcher) Start

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

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

func (*InMemoryEventDispatcher) WaitReady

func (d *InMemoryEventDispatcher) WaitReady()

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

type InMemoryEventDispatcherArgs

type InMemoryEventDispatcherArgs struct {
	Port                     int
	ReadTimeout              time.Duration
	WriteTimeout             time.Duration
	Handler                  multichannelfanout.MultiChannelEventHandler
	Logger                   *zap.Logger
	HTTPEventReceiverOptions []kncloudevents.HTTPEventReceiverOption
}