Documentation
¶
Index ¶
- func NewEventHandler(channel chan<- *gqlschema.SubscriptionEvent, ...) resource.EventHandlerProvider
- func NewService(serviceFactory *resource.GenericServiceFactory) (*resource.GenericService, error)
- type EventHandler
- type EventSubscriptionList
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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 (*Resolver) EventSubscriptionsQuery ¶
func (*Resolver) Service ¶
func (r *Resolver) Service() *resource.GenericService
func (*Resolver) SubscribeEventSubscription ¶
func (*Resolver) UpdateEventSubscription ¶
func (r *Resolver) UpdateEventSubscription(ctx context.Context, namespace string, name string, params gqlschema.EventSubscriptionSpecInput) (*v1alpha1.Subscription, error)
Source Files
Click to show internal directories.
Click to hide internal directories.