v1

Documentation

Index

• type BrokerBuilder
  • func NewBrokerBuilder(name string) *BrokerBuilder
  • func NewBrokerBuilderFromExisting(broker *eventingv1.Broker) *BrokerBuilder
  • func (b *BrokerBuilder) BackoffDelay(backoffDelay *string) *BrokerBuilder
  • func (b *BrokerBuilder) BackoffPolicy(policyType *v1.BackoffPolicyType) *BrokerBuilder
  • func (b *BrokerBuilder) Build() *eventingv1.Broker
  • func (b *BrokerBuilder) Class(class string) *BrokerBuilder
  • func (b *BrokerBuilder) Config(config *duckv1.KReference) *BrokerBuilder
  • func (b *BrokerBuilder) DlSink(dlSink *duckv1.Destination) *BrokerBuilder
  • func (b *BrokerBuilder) Namespace(ns string) *BrokerBuilder
  • func (b *BrokerBuilder) Retry(retry *int32) *BrokerBuilder
  • func (b *BrokerBuilder) RetryAfterMax(max *string) *BrokerBuilder
  • func (b *BrokerBuilder) Timeout(timeout *string) *BrokerBuilder
  • func (b *BrokerBuilder) WithGvk() *BrokerBuilder
• type BrokerUpdateFunc
• type KnEventingClient
  • func NewKnEventingClient(client clientv1.EventingV1Interface, namespace string) KnEventingClient
• type TriggerBuilder
  • func NewTriggerBuilder(name string) *TriggerBuilder
  • func NewTriggerBuilderFromExisting(trigger *eventingv1.Trigger) *TriggerBuilder
  • func (b *TriggerBuilder) Broker(broker string) *TriggerBuilder
  • func (b *TriggerBuilder) Build() *eventingv1.Trigger
  • func (b *TriggerBuilder) Filters(filters map[string]string) *TriggerBuilder
  • func (b *TriggerBuilder) InjectBroker(inject bool) *TriggerBuilder
  • func (b *TriggerBuilder) Namespace(ns string) *TriggerBuilder
  • func (b *TriggerBuilder) Subscriber(subscriber *duckv1.Destination) *TriggerBuilder
  • func (b *TriggerBuilder) WithGvk() *TriggerBuilder
• type TriggerUpdateFunc

Types

type BrokerBuilder

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

BrokerBuilder is for building the broker

func NewBrokerBuilder

func NewBrokerBuilder(name string) *BrokerBuilder

NewBrokerBuilder for building broker object

func NewBrokerBuilderFromExisting

func NewBrokerBuilderFromExisting(broker *eventingv1.Broker) *BrokerBuilder

NewBrokerBuilderFromExisting returns broker builder from original broker

func (*BrokerBuilder) BackoffDelay

func (b *BrokerBuilder) BackoffDelay(backoffDelay *string) *BrokerBuilder

BackoffDelay for the broker builder

func (*BrokerBuilder) BackoffPolicy

func (b *BrokerBuilder) BackoffPolicy(policyType *v1.BackoffPolicyType) *BrokerBuilder

BackoffPolicy for the broker builder

func (*BrokerBuilder) Build

func (b *BrokerBuilder) Build() *eventingv1.Broker

Build to return an instance of broker object

func (*BrokerBuilder) Class

func (b *BrokerBuilder) Class(class string) *BrokerBuilder

Class for broker builder

func (*BrokerBuilder) Config

func (b *BrokerBuilder) Config(config *duckv1.KReference) *BrokerBuilder

Config for the broker builder

func (*BrokerBuilder) DlSink

func (b *BrokerBuilder) DlSink(dlSink *duckv1.Destination) *BrokerBuilder

DlSink for the broker builder

func (*BrokerBuilder) Namespace

func (b *BrokerBuilder) Namespace(ns string) *BrokerBuilder

Namespace for broker builder

func (*BrokerBuilder) Retry

func (b *BrokerBuilder) Retry(retry *int32) *BrokerBuilder

Retry for the broker builder

func (*BrokerBuilder) RetryAfterMax

func (b *BrokerBuilder) RetryAfterMax(max *string) *BrokerBuilder

RetryAfterMax for the broker builder

func (*BrokerBuilder) Timeout

func (b *BrokerBuilder) Timeout(timeout *string) *BrokerBuilder

Timeout for the broker builder

func (*BrokerBuilder) WithGvk

func (b *BrokerBuilder) WithGvk() *BrokerBuilder

WithGvk add the GVK coordinates for read tests

type BrokerUpdateFunc

type BrokerUpdateFunc func(origBroker *eventingv1.Broker) (*eventingv1.Broker, error)

type KnEventingClient

type KnEventingClient interface {
	// Namespace in which this client is operating for
	Namespace() string
	// CreateTrigger is used to create an instance of trigger
	CreateTrigger(ctx context.Context, trigger *eventingv1.Trigger) error
	// DeleteTrigger is used to delete an instance of trigger
	DeleteTrigger(ctx context.Context, name string) error
	// GetTrigger is used to get an instance of trigger
	GetTrigger(ctx context.Context, name string) (*eventingv1.Trigger, error)
	// ListTriggers returns list of trigger CRDs
	ListTriggers(ctx context.Context) (*eventingv1.TriggerList, error)
	// UpdateTrigger is used to update an instance of trigger
	UpdateTrigger(ctx context.Context, trigger *eventingv1.Trigger) error
	// UpdateTriggerWithRetry is used to update an instance of trigger
	UpdateTriggerWithRetry(ctx context.Context, name string, updateFunc TriggerUpdateFunc, nrRetries int) error
	// CreateBroker is used to create an instance of broker
	CreateBroker(ctx context.Context, broker *eventingv1.Broker) error
	// GetBroker is used to get an instance of broker
	GetBroker(ctx context.Context, name string) (*eventingv1.Broker, error)
	// DeleteBroker is used to delete an instance of broker
	DeleteBroker(ctx context.Context, name string, timeout time.Duration) error
	// ListBrokers returns list of broker CRDs
	ListBrokers(ctx context.Context) (*eventingv1.BrokerList, error)
	// UpdateBroker is used to update an instance of broker
	UpdateBroker(ctx context.Context, broker *eventingv1.Broker) error
	// UpdateBrokerWithRetry is used to update an instance of broker
	UpdateBrokerWithRetry(ctx context.Context, name string, updateFunc BrokerUpdateFunc, nrRetries int) error
}

KnEventingClient to Eventing Sources. All methods are relative to the namespace specified during construction

func NewKnEventingClient

func NewKnEventingClient(client clientv1.EventingV1Interface, namespace string) KnEventingClient

NewKnEventingClient is to invoke Eventing Sources Client API to create object

type TriggerBuilder

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

TriggerBuilder is for building the trigger

func NewTriggerBuilder

func NewTriggerBuilder(name string) *TriggerBuilder

NewTriggerBuilder for building trigger object

func NewTriggerBuilderFromExisting

func NewTriggerBuilderFromExisting(trigger *eventingv1.Trigger) *TriggerBuilder

NewTriggerBuilderFromExisting for building the object from existing Trigger object

func (*TriggerBuilder) Broker

func (b *TriggerBuilder) Broker(broker string) *TriggerBuilder

Broker to set the broker of trigger object

func (*TriggerBuilder) Build

func (b *TriggerBuilder) Build() *eventingv1.Trigger

Build to return an instance of trigger object

func (*TriggerBuilder) Filters

func (b *TriggerBuilder) Filters(filters map[string]string) *TriggerBuilder

func (*TriggerBuilder) InjectBroker

func (b *TriggerBuilder) InjectBroker(inject bool) *TriggerBuilder

InjectBroker to add annotation to setup default broker

func (*TriggerBuilder) Namespace

func (b *TriggerBuilder) Namespace(ns string) *TriggerBuilder

Namespace for this trigger

func (*TriggerBuilder) Subscriber

func (b *TriggerBuilder) Subscriber(subscriber *duckv1.Destination) *TriggerBuilder

Subscriber for the trigger to send to (it's a Sink actually)

func (*TriggerBuilder) WithGvk

func (b *TriggerBuilder) WithGvk() *TriggerBuilder

WithGvk sets the GVK for the triggers (which otherwise remains empty

type TriggerUpdateFunc

type TriggerUpdateFunc func(origTrigger *eventingv1.Trigger) (*eventingv1.Trigger, error)