dispatcher

Documentation

Index

• type KinesisDispatcher
  • func NewDispatcher(ctx context.Context) (*KinesisDispatcher, error)
  • 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)

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) Start

func (s *KinesisDispatcher) Start(ctx context.Context) error

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.