Documentation
¶
Index ¶
- type AzureDispatcher
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.