inmemorychannel

Documentation

Overview

Copyright 2020 The Knative Authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type InMemoryMessageDispatcher
  • func NewMessageDispatcher(args *InMemoryMessageDispatcherArgs) *InMemoryMessageDispatcher
  • func (d *InMemoryMessageDispatcher) Start(ctx context.Context) error
  • func (d *InMemoryMessageDispatcher) UpdateConfig(ctx context.Context, dispatcherConfig channel.EventDispatcherConfig, ...) 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) Start

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

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

func (*InMemoryMessageDispatcher) UpdateConfig

func (d *InMemoryMessageDispatcher) UpdateConfig(ctx context.Context, dispatcherConfig channel.EventDispatcherConfig, config *multichannelfanout.Config) error

type InMemoryMessageDispatcherArgs

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

type MessageDispatcher

type MessageDispatcher interface {
	UpdateConfig(ctx context.Context, dispatcherConfig channel.EventDispatcherConfig, config *multichannelfanout.Config) error
}