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
• 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.

type InMemoryMessageDispatcherArgs

type InMemoryMessageDispatcherArgs struct {
	Port         int
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	Handler      multichannelfanout.MultiChannelMessageHandler
	Logger       *zap.Logger
}

type MessageDispatcher

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