v1beta1

Mar 8, 2022

Changes in this version

+ type EventingV1beta1Recorder struct

+ func (sr *EventingV1beta1Recorder) CreateEventtype(eventtype interface{}, err error)

+ func (sr *EventingV1beta1Recorder) DeleteEventtype(name interface{}, err error)

+ func (sr *EventingV1beta1Recorder) GetEventtype(name string, eventtype *eventingv1beta1.EventType, err error)

+ func (sr *EventingV1beta1Recorder) ListEventtypes(eventtypeList *eventingv1beta1.EventTypeList, err error)

+ func (sr *EventingV1beta1Recorder) Validate()

+ type EventtypeBuilder struct

+ func NewEventtypeBuilder(name string) *EventtypeBuilder

+ func (e *EventtypeBuilder) Broker(broker string) *EventtypeBuilder

+ func (e *EventtypeBuilder) Build() *eventingv1beta1.EventType

+ func (e *EventtypeBuilder) Namespace(ns string) *EventtypeBuilder

+ func (e *EventtypeBuilder) Source(source *apis.URL) *EventtypeBuilder

+ func (e *EventtypeBuilder) Type(ceType string) *EventtypeBuilder

+ func (e *EventtypeBuilder) WithGvk() *EventtypeBuilder

+ type KnEventingV1Beta1Client interface

+ CreateEventtype func(ctx context.Context, eventtype *eventingv1beta1.EventType) error

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

+ GetEventtype func(ctx context.Context, name string) (*eventingv1beta1.EventType, error)

+ ListEventtypes func(ctx context.Context) (*eventingv1beta1.EventTypeList, error)

+ Namespace func() string

+ func NewKnEventingV1Beta1Client(client beta1.EventingV1beta1Interface, namespace string) KnEventingV1Beta1Client

+ type MockKnEventingV1beta1Client struct

+ func NewMockKnEventingV1beta1Client(t *testing.T, ns ...string) *MockKnEventingV1beta1Client

+ func (c *MockKnEventingV1beta1Client) CreateEventtype(ctx context.Context, eventtype *eventingv1beta1.EventType) error

+ func (c *MockKnEventingV1beta1Client) DeleteEventtype(ctx context.Context, name string) error

+ func (c *MockKnEventingV1beta1Client) GetEventtype(ctx context.Context, name string) (*eventingv1beta1.EventType, error)

+ func (c *MockKnEventingV1beta1Client) ListEventtypes(ctx context.Context) (*eventingv1beta1.EventTypeList, error)

+ func (c *MockKnEventingV1beta1Client) Namespace() string

+ func (c *MockKnEventingV1beta1Client) Recorder() *EventingV1beta1Recorder

Jul 15, 2020

Changes in this version

+ type BrokerBuilder struct

+ func NewBrokerBuilder(name string) *BrokerBuilder

+ func (b *BrokerBuilder) Build() *v1beta1.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 *v1beta1.Broker, err error)

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

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

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

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

+ func (sr *EventingRecorder) Validate()

+ type KnEventingClient interface

+ CreateBroker func(broker *v1beta1.Broker) error

+ CreateTrigger func(trigger *v1beta1.Trigger) error

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

+ DeleteTrigger func(name string) error

+ GetBroker func(name string) (*v1beta1.Broker, error)

+ GetTrigger func(name string) (*v1beta1.Trigger, error)

+ ListBrokers func() (*v1beta1.BrokerList, error)

+ ListTriggers func() (*v1beta1.TriggerList, error)

+ Namespace func() string

+ UpdateTrigger func(trigger *v1beta1.Trigger) error

+ func NewKnEventingClient(client client_v1beta1.EventingV1beta1Interface, namespace string) KnEventingClient

+ type MockKnEventingClient struct

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

+ func (c *MockKnEventingClient) CreateBroker(broker *v1beta1.Broker) error

+ func (c *MockKnEventingClient) CreateTrigger(trigger *v1beta1.Trigger) error

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

+ func (c *MockKnEventingClient) DeleteTrigger(name string) error

+ func (c *MockKnEventingClient) GetBroker(name string) (*v1beta1.Broker, error)

+ func (c *MockKnEventingClient) GetTrigger(name string) (*v1beta1.Trigger, error)

+ func (c *MockKnEventingClient) ListBrokers() (*v1beta1.BrokerList, error)

+ func (c *MockKnEventingClient) ListTriggers() (*v1beta1.TriggerList, error)

+ func (c *MockKnEventingClient) Namespace() string

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

+ func (c *MockKnEventingClient) UpdateTrigger(trigger *v1beta1.Trigger) error

+ type TriggerBuilder struct

+ func NewTriggerBuilder(name string) *TriggerBuilder

+ func NewTriggerBuilderFromExisting(trigger *v1beta1.Trigger) *TriggerBuilder

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

+ func (b *TriggerBuilder) Build() *v1beta1.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