Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelConfig ¶
type ChannelConfig struct {
Namespace string
Name string
HostName string
Subscriptions []Subscription
}
func (ChannelConfig) SubscriptionsUIDs ¶
func (cc ChannelConfig) SubscriptionsUIDs() []string
type KafkaDispatcher ¶
type KafkaDispatcher struct {
// contains filtered or unexported fields
}
func NewDispatcher ¶
func NewDispatcher(ctx context.Context, args *KafkaDispatcherArgs) (*KafkaDispatcher, error)
func (*KafkaDispatcher) CleanupChannel ¶
func (d *KafkaDispatcher) CleanupChannel(name, namespace, hostname string) error
func (*KafkaDispatcher) ReconcileConsumers ¶
func (d *KafkaDispatcher) ReconcileConsumers(config *ChannelConfig) error
ReconcileConsumers will be called by new CRD based kafka channel dispatcher controller.
func (*KafkaDispatcher) RegisterChannelHost ¶
func (d *KafkaDispatcher) RegisterChannelHost(channelConfig *ChannelConfig) error
RegisterChannelHost adds a new channel to the host-channel mapping.
type KafkaDispatcherArgs ¶
type KafkaDispatcherArgs struct {
KnCEConnectionArgs *kncloudevents.ConnectionArgs
ClientID string
Brokers []string
KafkaConfig *sarama.Config
TopicFunc TopicFunc
}
type KafkaSubscription ¶
type KafkaSubscription struct {
// contains filtered or unexported fields
}
func NewKafkaSubscription ¶
func NewKafkaSubscription(logger *zap.SugaredLogger) *KafkaSubscription
type Subscription ¶
type Subscription struct {
UID types.UID
fanout.Subscription
}
func (Subscription) String ¶
func (sub Subscription) String() string
type UpdateError ¶
UpdateError is the error returned from the ReconcileConsumers method, with the details of which subscriptions failed to subscribe to.
func (UpdateError) Error ¶
func (k UpdateError) Error() string
Source Files
Click to show internal directories.
Click to hide internal directories.