Documentation
¶
Index ¶
- type KinesisDispatcher
- func (s *KinesisDispatcher) CreateKinesisSession(ctx context.Context, channel *v1alpha1.KinesisChannel, secret *corev1.Secret) error
- func (s *KinesisDispatcher) DeleteKinesisSession(ctx context.Context, channel *v1alpha1.KinesisChannel)
- func (s *KinesisDispatcher) KinesisSessionExist(ctx context.Context, channel *v1alpha1.KinesisChannel) bool
- func (s *KinesisDispatcher) Start(ctx context.Context) error
- func (s *KinesisDispatcher) UpdateHostToChannelMap(config *multichannelfanout.Config) error
- func (s *KinesisDispatcher) UpdateSubscriptions(ctx context.Context, channel *v1alpha1.KinesisChannel, isFinalizer bool) (map[eventingduckv1.SubscriberSpec]error, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KinesisDispatcher ¶
type KinesisDispatcher struct {
// contains filtered or unexported fields
}
KinesisDispatcher manages the state of Kinesis Streaming subscriptions.
func NewDispatcher ¶
func NewDispatcher(ctx context.Context) (*KinesisDispatcher, error)
NewDispatcher returns a new KinesisDispatcher.
func (*KinesisDispatcher) CreateKinesisSession ¶
func (s *KinesisDispatcher) CreateKinesisSession(ctx context.Context, channel *v1alpha1.KinesisChannel, secret *corev1.Secret) error
func (*KinesisDispatcher) DeleteKinesisSession ¶
func (s *KinesisDispatcher) DeleteKinesisSession(ctx context.Context, channel *v1alpha1.KinesisChannel)
func (*KinesisDispatcher) KinesisSessionExist ¶
func (s *KinesisDispatcher) KinesisSessionExist(ctx context.Context, channel *v1alpha1.KinesisChannel) bool
func (*KinesisDispatcher) UpdateHostToChannelMap ¶
func (s *KinesisDispatcher) UpdateHostToChannelMap(config *multichannelfanout.Config) error
UpdateHostToChannelMap will be called from the controller that watches kinesis channels. It will update internal hostToChannelMap which is used to resolve the hostHeader of the incoming request to the correct ChannelReference in the receiver function.
func (*KinesisDispatcher) UpdateSubscriptions ¶
func (s *KinesisDispatcher) UpdateSubscriptions(ctx context.Context, channel *v1alpha1.KinesisChannel, isFinalizer bool) (map[eventingduckv1.SubscriberSpec]error, error)
UpdateSubscriptions creates/deletes the kinesis subscriptions based on channel.Spec.Subscribable.Subscribers.
Source Files
Click to show internal directories.
Click to hide internal directories.