Documentation
¶
Overview ¶
Copyright 2018 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 ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelConfig ¶ added in v0.17.0
type ChannelConfig struct { Namespace string Name string HostName string Subscriptions []Subscription }
type Config ¶ added in v0.17.0
type Config struct { // The configuration of each channel in this handler. ChannelConfigs []ChannelConfig }
type KafkaDispatcher ¶
type KafkaDispatcher struct {
// contains filtered or unexported fields
}
func NewDispatcher ¶
func NewDispatcher(ctx context.Context, args *KafkaDispatcherArgs) (*KafkaDispatcher, error)
func (*KafkaDispatcher) Start ¶
func (d *KafkaDispatcher) Start(ctx context.Context) error
Start starts the kafka dispatcher's message processing.
func (*KafkaDispatcher) UpdateHostToChannelMap ¶
func (d *KafkaDispatcher) UpdateHostToChannelMap(config *Config) error
UpdateHostToChannelMap will be called by new CRD based kafka channel dispatcher controller.
func (*KafkaDispatcher) UpdateKafkaConsumers ¶
UpdateKafkaConsumers will be called by new CRD based kafka channel dispatcher controller.
type KafkaDispatcherArgs ¶
type KafkaDispatcherArgs struct { KnCEConnectionArgs *kncloudevents.ConnectionArgs ClientID string Brokers []string TopicFunc TopicFunc Logger *zap.SugaredLogger }
type Subscription ¶ added in v0.17.0
type Subscription struct { UID types.UID fanout.Subscription }
func (Subscription) String ¶ added in v0.17.0
func (sub Subscription) String() string