eventing

Documentation

Index

• func NewEventHandler(channel chan<- *gqlschema.TriggerEvent, ...) 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 Resolver
  • func New(factory *resource.GenericServiceFactory) *Resolver
  • func (r *Resolver) CreateTrigger(ctx context.Context, namespace string, in gqlschema.TriggerCreateInput, ...) (*v1alpha1.Trigger, error)
  • func (r *Resolver) CreateTriggers(ctx context.Context, namespace string, ...) ([]*v1alpha1.Trigger, error)
  • func (r *Resolver) DeleteTrigger(ctx context.Context, namespace string, name string) (*v1alpha1.Trigger, error)
  • func (r *Resolver) DeleteTriggers(ctx context.Context, namespace string, names []string) ([]*v1alpha1.Trigger, error)
  • func (r *Resolver) FilterField(ctx context.Context, obj *v1alpha1.TriggerSpec) (gqlschema.JSON, error)
  • func (r *Resolver) PathField(ctx context.Context, obj *v1alpha1.TriggerSpec) (string, error)
  • func (r *Resolver) PortField(ctx context.Context, obj *v1alpha1.TriggerSpec) (uint32, error)
  • func (r *Resolver) Service() *resource.GenericService
  • func (r *Resolver) StatusField(ctx context.Context, obj *v1alpha1.Trigger) (*gqlschema.TriggerStatus, error)
  • func (r *Resolver) TriggerEventSubscription(ctx context.Context, namespace, serviceName string) (<-chan *gqlschema.TriggerEvent, error)
  • func (r *Resolver) TriggersQuery(ctx context.Context, namespace string, serviceName string) ([]*v1alpha1.Trigger, error)
• type Service
• type TriggerList
  • func (l *TriggerList) Append() interface{}

Functions

func NewEventHandler

func NewEventHandler(channel chan<- *gqlschema.TriggerEvent, filter func(trigger v1alpha1.Trigger) 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 Resolver

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

func New

func New(factory *resource.GenericServiceFactory) *Resolver

func (*Resolver) CreateTrigger

func (r *Resolver) CreateTrigger(ctx context.Context, namespace string, in gqlschema.TriggerCreateInput, ownerRef []*v1.OwnerReference) (*v1alpha1.Trigger, error)

func (*Resolver) CreateTriggers

func (r *Resolver) CreateTriggers(ctx context.Context, namespace string, triggers []*gqlschema.TriggerCreateInput, ref []*v1.OwnerReference) ([]*v1alpha1.Trigger, error)

func (*Resolver) DeleteTrigger

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

func (*Resolver) DeleteTriggers

func (r *Resolver) DeleteTriggers(ctx context.Context, namespace string, names []string) ([]*v1alpha1.Trigger, error)

func (*Resolver) FilterField

func (r *Resolver) FilterField(ctx context.Context, obj *v1alpha1.TriggerSpec) (gqlschema.JSON, error)

func (*Resolver) PathField

func (r *Resolver) PathField(ctx context.Context, obj *v1alpha1.TriggerSpec) (string, error)

func (*Resolver) PortField

func (r *Resolver) PortField(ctx context.Context, obj *v1alpha1.TriggerSpec) (uint32, error)

func (*Resolver) Service

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

func (*Resolver) StatusField

func (r *Resolver) StatusField(ctx context.Context, obj *v1alpha1.Trigger) (*gqlschema.TriggerStatus, error)

func (*Resolver) TriggerEventSubscription

func (r *Resolver) TriggerEventSubscription(ctx context.Context, namespace, serviceName string) (<-chan *gqlschema.TriggerEvent, error)

func (*Resolver) TriggersQuery

func (r *Resolver) TriggersQuery(ctx context.Context, namespace string, serviceName string) ([]*v1alpha1.Trigger, error)

type Service

type Service struct {
	*resource.Service
}

type TriggerList

type TriggerList []*v1alpha1.Trigger

func (*TriggerList) Append

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