inmemorychannel

package
v0.40.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 7, 2024 License: Apache-2.0 Imports: 5 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventDispatcher added in v0.39.0

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

type InMemoryEventDispatcher added in v0.39.0

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

func NewEventDispatcher added in v0.39.0

func NewEventDispatcher(args *InMemoryEventDispatcherArgs) *InMemoryEventDispatcher

func (*InMemoryEventDispatcher) GetHandler added in v0.39.0

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

func (*InMemoryEventDispatcher) GetReceiver added in v0.39.0

func (*InMemoryEventDispatcher) Start added in v0.39.0

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

func (*InMemoryEventDispatcher) WaitReady added in v0.39.0

func (d *InMemoryEventDispatcher) WaitReady()

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

type InMemoryEventDispatcherArgs added in v0.39.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL