bebEventing

Documentation

Index

• func NewEventHandler(channel chan<- *gqlschema.SubscriptionEvent, ...) resource.EventHandlerProvider
• func NewService(serviceFactory *resource.GenericServiceFactory) (*resource.GenericService, error)
• type EventHandler
  • func (h *EventHandler) K8sResource() interface{}
  • func (h *EventHandler) Notify(eventType gqlschema.SubscriptionEventType)
  • func (h *EventHandler) ShouldNotify() bool
• type EventSubscriptionList
  • func (l *EventSubscriptionList) Append() interface{}
• type Resolver
  • func New(factory *resource.GenericServiceFactory, client kubernetes.Interface) *Resolver
  • func (r *Resolver) CreateEventSubscription(ctx context.Context, namespace string, name string, ...) (*v1alpha1.Subscription, error)
  • func (r *Resolver) DeleteEventSubscription(ctx context.Context, namespace string, name string) (*v1alpha1.Subscription, error)
  • func (r *Resolver) EventSubscriptionsQuery(ctx context.Context, ownerName string, namespace string) ([]*v1alpha1.Subscription, error)
  • func (r *Resolver) Service() *resource.GenericService
  • func (r *Resolver) SubscribeEventSubscription(ctx context.Context, ownerName, namespace string) (<-chan *gqlschema.SubscriptionEvent, error)
  • func (r *Resolver) UpdateEventSubscription(ctx context.Context, namespace string, name string, ...) (*v1alpha1.Subscription, error)
• type Service

Functions

func NewEventHandler

func NewEventHandler(channel chan<- *gqlschema.SubscriptionEvent, filter func(subscription v1alpha1.Subscription) bool) resource.EventHandlerProvider

func NewService

func NewService(serviceFactory *resource.GenericServiceFactory) (*resource.GenericService, error)

Types

type EventHandler

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

func (*EventHandler) K8sResource

func (h *EventHandler) K8sResource() interface{}

func (*EventHandler) Notify

func (h *EventHandler) Notify(eventType gqlschema.SubscriptionEventType)

func (*EventHandler) ShouldNotify

func (h *EventHandler) ShouldNotify() bool

type EventSubscriptionList

type EventSubscriptionList []*v1alpha1.Subscription

func (*EventSubscriptionList) Append

func (l *EventSubscriptionList) Append() interface{}

type Resolver

type Resolver struct {
	*resource.Module
	// contains filtered or unexported fields
}

func New

func New(factory *resource.GenericServiceFactory, client kubernetes.Interface) *Resolver

func (*Resolver) CreateEventSubscription

func (r *Resolver) CreateEventSubscription(ctx context.Context, namespace string, name string, params gqlschema.EventSubscriptionSpecInput) (*v1alpha1.Subscription, error)

func (*Resolver) DeleteEventSubscription

func (r *Resolver) DeleteEventSubscription(ctx context.Context, namespace string, name string) (*v1alpha1.Subscription, error)

func (*Resolver) EventSubscriptionsQuery

func (r *Resolver) EventSubscriptionsQuery(ctx context.Context, ownerName string, namespace string) ([]*v1alpha1.Subscription, error)

func (*Resolver) Service

func (r *Resolver) Service() *resource.GenericService

func (*Resolver) SubscribeEventSubscription

func (r *Resolver) SubscribeEventSubscription(ctx context.Context, ownerName, namespace string) (<-chan *gqlschema.SubscriptionEvent, error)

func (*Resolver) UpdateEventSubscription

func (r *Resolver) UpdateEventSubscription(ctx context.Context, namespace string, name string, params gqlschema.EventSubscriptionSpecInput) (*v1alpha1.Subscription, error)

type Service

type Service struct {
	*resource.Service
}