v1alpha1

Documentation

Index

• type EventingRecorder
  • func (sr *EventingRecorder) CreateTrigger(trigger interface{}, err error)
  • func (sr *EventingRecorder) DeleteTrigger(name interface{}, err error)
  • func (sr *EventingRecorder) GetTrigger(name interface{}, trigger *v1alpha1.Trigger, err error)
  • func (sr *EventingRecorder) ListTriggers(triggerList *v1alpha1.TriggerList, err error)
  • func (sr *EventingRecorder) UpdateTrigger(trigger interface{}, err error)
  • func (sr *EventingRecorder) Validate()
• type KnEventingClient
  • func NewKnEventingClient(client client_v1alpha1.EventingV1alpha1Interface, namespace string) KnEventingClient
• type MockKnEventingClient
  • func NewMockKnEventingClient(t *testing.T, ns ...string) *MockKnEventingClient
  • func (c *MockKnEventingClient) CreateTrigger(trigger *v1alpha1.Trigger) error
  • func (c *MockKnEventingClient) DeleteTrigger(name string) error
  • func (c *MockKnEventingClient) GetTrigger(name string) (*v1alpha1.Trigger, error)
  • func (c *MockKnEventingClient) ListTriggers() (*v1alpha1.TriggerList, error)
  • func (c *MockKnEventingClient) Namespace() string
  • func (c *MockKnEventingClient) Recorder() *EventingRecorder
  • func (c *MockKnEventingClient) UpdateTrigger(trigger *v1alpha1.Trigger) error
• type TriggerBuilder
  • func NewTriggerBuilder(name string) *TriggerBuilder
  • func NewTriggerBuilderFromExisting(trigger *v1alpha1.Trigger) *TriggerBuilder
  • func (b *TriggerBuilder) Broker(broker string) *TriggerBuilder
  • func (b *TriggerBuilder) Build() *v1alpha1.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

Types

type EventingRecorder

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

EventingRecorder is recorder for eventing objects

func (*EventingRecorder) CreateTrigger

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

CreateTrigger records a call for CreatePingSource with the expected error

func (*EventingRecorder) DeleteTrigger

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

DeleteTrigger records a call for DeleteTrigger with the expected error (nil if none)

func (*EventingRecorder) GetTrigger

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

GetTrigger records a call for GetTrigger with the expected object or error. Either trigger or err should be nil

func (*EventingRecorder) ListTriggers

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

ListTriggers records a call for ListTriggers with the expected result and error (nil if none)

func (*EventingRecorder) UpdateTrigger

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

UpdateTrigger records a call for ListTriggers with the expected result and error (nil if none)

func (*EventingRecorder) Validate

func (sr *EventingRecorder) Validate()

Validate validates whether every recorded action has been called

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(trigger *v1alpha1.Trigger) error
	// DeleteTrigger is used to delete an instance of trigger
	DeleteTrigger(name string) error
	// GetTrigger is used to get an instance of trigger
	GetTrigger(name string) (*v1alpha1.Trigger, error)
	// ListTrigger returns list of trigger CRDs
	ListTriggers() (*v1alpha1.TriggerList, error)
	// UpdateTrigger is used to update an instance of trigger
	UpdateTrigger(trigger *v1alpha1.Trigger) error
}

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

func NewKnEventingClient

func NewKnEventingClient(client client_v1alpha1.EventingV1alpha1Interface, namespace string) KnEventingClient

NewKnEventingClient is to invoke Eventing Sources Client API to create object

type MockKnEventingClient

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

MockKnEventingClient is a combine of test object and recorder

func NewMockKnEventingClient

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

NewMockKnEventingClient returns a new mock instance which you need to record for

func (*MockKnEventingClient) CreateTrigger

func (c *MockKnEventingClient) CreateTrigger(trigger *v1alpha1.Trigger) error

CreateTrigger performs a previously recorded action

func (*MockKnEventingClient) DeleteTrigger

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

DeleteTrigger performs a previously recorded action, failing if non has been registered

func (*MockKnEventingClient) GetTrigger

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

GetTrigger performs a previously recorded action

func (*MockKnEventingClient) ListTriggers

func (c *MockKnEventingClient) ListTriggers() (*v1alpha1.TriggerList, error)

ListTriggers performs a previously recorded action

func (*MockKnEventingClient) Namespace

func (c *MockKnEventingClient) Namespace() string

Namespace of this client

func (*MockKnEventingClient) Recorder

func (c *MockKnEventingClient) Recorder() *EventingRecorder

Recorder returns the recorder for registering API calls

func (*MockKnEventingClient) UpdateTrigger

func (c *MockKnEventingClient) UpdateTrigger(trigger *v1alpha1.Trigger) error

UpdateTrigger performs a previously recorded action

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 *v1alpha1.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() *v1alpha1.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)