dispatcher

Documentation

Index

• type AzureDispatcher
  • func NewDispatcher(ctx context.Context) (*AzureDispatcher, error)
  • func (s *AzureDispatcher) AzureSessionExist(ctx context.Context, channel *v1alpha1.AzureChannel) bool
  • func (s *AzureDispatcher) CreateAzureSession(ctx context.Context, channel *v1alpha1.AzureChannel, secret *corev1.Secret) error
  • func (s *AzureDispatcher) DeleteAzureSession(ctx context.Context, channel *v1alpha1.AzureChannel)
  • func (s *AzureDispatcher) Start(ctx context.Context) error
  • func (s *AzureDispatcher) UpdateHostToChannelMap(config *multichannelfanout.Config) error
  • func (s *AzureDispatcher) UpdateSubscriptions(ctx context.Context, channel *v1alpha1.AzureChannel, isFinalizer bool) (map[eventingduckv1beta1.SubscriberSpec]error, error)

Types

type AzureDispatcher

type AzureDispatcher struct {
	// contains filtered or unexported fields
}

AzureDispatcher manages the state of Azure Streaming subscriptions.

func NewDispatcher

func NewDispatcher(ctx context.Context) (*AzureDispatcher, error)

NewDispatcher returns a new AzureDispatcher.

func (*AzureDispatcher) AzureSessionExist

func (s *AzureDispatcher) AzureSessionExist(ctx context.Context, channel *v1alpha1.AzureChannel) bool

AzureSessionExist checks if azure session exists.

func (*AzureDispatcher) CreateAzureSession

func (s *AzureDispatcher) CreateAzureSession(ctx context.Context, channel *v1alpha1.AzureChannel, secret *corev1.Secret) error

CreateAzureSession creates azure session.

func (*AzureDispatcher) DeleteAzureSession

func (s *AzureDispatcher) DeleteAzureSession(ctx context.Context, channel *v1alpha1.AzureChannel)

DeleteAzureSession removes azure session.

func (*AzureDispatcher) Start

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

Start receiver.

func (*AzureDispatcher) UpdateHostToChannelMap

func (s *AzureDispatcher) UpdateHostToChannelMap(config *multichannelfanout.Config) error

UpdateHostToChannelMap will be called from the controller that watches azure 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 (*AzureDispatcher) UpdateSubscriptions

func (s *AzureDispatcher) UpdateSubscriptions(ctx context.Context, channel *v1alpha1.AzureChannel, isFinalizer bool) (map[eventingduckv1beta1.SubscriberSpec]error, error)

UpdateSubscriptions creates/deletes the azure subscriptions based on channel.Spec.Subscribable.Subscribers.