v1

Jul 13, 2022

Changes in this version

type BrokerBuilder

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

May 31, 2022

Changes in this version

type 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) DlSink(dlSink *duckv1.Destination) *BrokerBuilder

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

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

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

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

type EventingRecorder

+ func (sr *EventingRecorder) UpdateBroker(broker *eventingv1.Broker, err error)

type KnEventingClient

+ UpdateBroker func(ctx context.Context, broker *eventingv1.Broker) error

+ UpdateBrokerWithRetry func(ctx context.Context, name string, updateFunc BrokerUpdateFunc, nrRetries int) error

type MockKnEventingClient

+ func (c *MockKnEventingClient) UpdateBroker(ctx context.Context, broker *eventingv1.Broker) error

+ func (c *MockKnEventingClient) UpdateBrokerWithRetry(ctx context.Context, name string, updateFunc BrokerUpdateFunc, nrRetries int) error

Sep 22, 2021

Changes in this version

type BrokerBuilder

+ func (b *BrokerBuilder) WithGvk() *BrokerBuilder

type KnEventingClient

+ UpdateTriggerWithRetry func(ctx context.Context, name string, updateFunc TriggerUpdateFunc, nrRetries int) error

type MockKnEventingClient

+ func (c *MockKnEventingClient) UpdateTriggerWithRetry(ctx context.Context, name string, updateFunc TriggerUpdateFunc, nrRetries int) error

type TriggerBuilder

+ func (b *TriggerBuilder) WithGvk() *TriggerBuilder

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

Aug 11, 2021

Changes in this version

type BrokerBuilder

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

May 19, 2021

Changes in this version

+ type BrokerBuilder struct

+ func NewBrokerBuilder(name string) *BrokerBuilder

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

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

+ type EventingRecorder struct

+ func (sr *EventingRecorder) CreateBroker(broker interface{}, err error)

+ func (sr *EventingRecorder) CreateTrigger(trigger interface{}, err error)

+ func (sr *EventingRecorder) DeleteBroker(name, timeout interface{}, err error)

+ func (sr *EventingRecorder) DeleteTrigger(name interface{}, err error)

+ func (sr *EventingRecorder) GetBroker(name interface{}, broker *eventingv1.Broker, err error)

+ func (sr *EventingRecorder) GetTrigger(name interface{}, trigger *eventingv1.Trigger, err error)

+ func (sr *EventingRecorder) ListBrokers(brokerList *eventingv1.BrokerList, err error)

+ func (sr *EventingRecorder) ListTriggers(triggerList *eventingv1.TriggerList, err error)

+ func (sr *EventingRecorder) UpdateTrigger(trigger interface{}, err error)

+ func (sr *EventingRecorder) Validate()

+ type KnEventingClient interface

+ CreateBroker func(ctx context.Context, broker *eventingv1.Broker) error

+ CreateTrigger func(ctx context.Context, trigger *eventingv1.Trigger) error

+ DeleteBroker func(ctx context.Context, name string, timeout time.Duration) error

+ DeleteTrigger func(ctx context.Context, name string) error

+ GetBroker func(ctx context.Context, name string) (*eventingv1.Broker, error)

+ GetTrigger func(ctx context.Context, name string) (*eventingv1.Trigger, error)

+ ListBrokers func(ctx context.Context) (*eventingv1.BrokerList, error)

+ ListTriggers func(ctx context.Context) (*eventingv1.TriggerList, error)

+ Namespace func() string

+ UpdateTrigger func(ctx context.Context, trigger *eventingv1.Trigger) error

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

+ type MockKnEventingClient struct

+ func NewMockKnEventingClient(t *testing.T, ns ...string) *MockKnEventingClient

+ func (c *MockKnEventingClient) CreateBroker(ctx context.Context, broker *eventingv1.Broker) error

+ func (c *MockKnEventingClient) CreateTrigger(ctx context.Context, trigger *eventingv1.Trigger) error

+ func (c *MockKnEventingClient) DeleteBroker(ctx context.Context, name string, timeout time.Duration) error

+ func (c *MockKnEventingClient) DeleteTrigger(ctx context.Context, name string) error

+ func (c *MockKnEventingClient) GetBroker(ctx context.Context, name string) (*eventingv1.Broker, error)

+ func (c *MockKnEventingClient) GetTrigger(ctx context.Context, name string) (*eventingv1.Trigger, error)

+ func (c *MockKnEventingClient) ListBrokers(context.Context) (*eventingv1.BrokerList, error)

+ func (c *MockKnEventingClient) ListTriggers(context.Context) (*eventingv1.TriggerList, error)

+ func (c *MockKnEventingClient) Namespace() string

+ func (c *MockKnEventingClient) Recorder() *EventingRecorder

+ func (c *MockKnEventingClient) UpdateTrigger(ctx context.Context, trigger *eventingv1.Trigger) error

+ type TriggerBuilder struct

+ 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