v1alpha2

package
v0.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 15, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APIServerSourceBuilder added in v0.14.0 

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

APIServerSourceBuilder is for building the source

func NewAPIServerSourceBuilder added in v0.14.0 

func NewAPIServerSourceBuilder(name string) *APIServerSourceBuilder

NewAPIServerSourceBuilder for building ApiServer source object

func NewAPIServerSourceBuilderFromExisting added in v0.14.0 

func NewAPIServerSourceBuilderFromExisting(apiServerSource *v1alpha2.ApiServerSource) *APIServerSourceBuilder

NewAPIServerSourceBuilderFromExisting for building the object from existing ApiServerSource object

func (*APIServerSourceBuilder) Build added in v0.14.0 

func (b *APIServerSourceBuilder) Build() *v1alpha2.ApiServerSource

Build the ApiServerSource object

func (*APIServerSourceBuilder) CloudEventOverrides added in v0.15.0 

func (b *APIServerSourceBuilder) CloudEventOverrides(ceo map[string]string, toRemove []string) *APIServerSourceBuilder

CloudEventOverrides adds given Cloud Event override extensions map to source spec

func (*APIServerSourceBuilder) EventMode added in v0.14.0 

func (b *APIServerSourceBuilder) EventMode(eventMode string) *APIServerSourceBuilder

EventMode for whether to send resource 'Ref' or complete 'Resource'

func (*APIServerSourceBuilder) Resources added in v0.14.0 

func (b *APIServerSourceBuilder) Resources(resources []v1alpha2.APIVersionKindSelector) *APIServerSourceBuilder

Resources which should be streamed

func (*APIServerSourceBuilder) ServiceAccount added in v0.14.0 

func (b *APIServerSourceBuilder) ServiceAccount(sa string) *APIServerSourceBuilder

ServiceAccount with which this source should operate

func (*APIServerSourceBuilder) Sink added in v0.14.0 

func (b *APIServerSourceBuilder) Sink(sink duckv1.Destination) *APIServerSourceBuilder

Sink or destination of the source

type APIServerSourcesRecorder added in v0.14.0 

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

APIServerSourcesRecorder for recording actions on source

func (*APIServerSourcesRecorder) CreateAPIServerSource added in v0.14.0 

func (sr *APIServerSourcesRecorder) CreateAPIServerSource(apiServerSource interface{}, err error)

CreateAPIServerSource records a call for CreateApiServerSource with the expected error

func (*APIServerSourcesRecorder) DeleteAPIServerSource added in v0.14.0 

func (sr *APIServerSourcesRecorder) DeleteAPIServerSource(name interface{}, err error)

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

func (*APIServerSourcesRecorder) GetAPIServerSource added in v0.14.0 

func (sr *APIServerSourcesRecorder) GetAPIServerSource(name interface{}, apiServerSource *v1alpha2.ApiServerSource, err error)

GetAPIServerSource records a call for GetApiServerSource with the expected object or error. Either apiServerSource or err should be nil

func (*APIServerSourcesRecorder) ListAPIServerSource added in v0.14.0 

func (sr *APIServerSourcesRecorder) ListAPIServerSource(apiJobSourceList *v1alpha2.ApiServerSourceList, err error)

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

func (*APIServerSourcesRecorder) UpdateAPIServerSource added in v0.14.0 

func (sr *APIServerSourcesRecorder) UpdateAPIServerSource(apiServerSource interface{}, err error)

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

func (*APIServerSourcesRecorder) Validate added in v0.14.0 

func (sr *APIServerSourcesRecorder) Validate()

Validate validates whether every recorded action has been called

type EventingRecorder 

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

EventingRecorder is recorder for eventing objects

func (*EventingRecorder) CreateSinkBinding 

func (sr *EventingRecorder) CreateSinkBinding(binding interface{}, err error)

CreateSinkBinding records a call for CreateSinkBinding with the expected error

func (*EventingRecorder) DeleteSinkBinding 

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

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

func (*EventingRecorder) GetSinkBinding 

func (sr *EventingRecorder) GetSinkBinding(name interface{}, binding *v1alpha2.SinkBinding, err error)

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

func (*EventingRecorder) ListSinkBindings 

func (sr *EventingRecorder) ListSinkBindings(bindingList *v1alpha2.SinkBindingList, err error)

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

func (*EventingRecorder) UpdateSinkBinding 

func (sr *EventingRecorder) UpdateSinkBinding(binding interface{}, err error)

UpdateSinkBinding records a call for ListSinkBindings 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 KnAPIServerSourcesClient added in v0.14.0 

type KnAPIServerSourcesClient interface {

	// Get an ApiServerSource by name
	GetAPIServerSource(name string) (*v1alpha2.ApiServerSource, error)

	// Create an ApiServerSource by object
	CreateAPIServerSource(apiSource *v1alpha2.ApiServerSource) error

	// Update an ApiServerSource by object
	UpdateAPIServerSource(apiSource *v1alpha2.ApiServerSource) error

	// Delete an ApiServerSource by name
	DeleteAPIServerSource(name string) error

	// List ApiServerSource
	// TODO: Support list configs like in service list
	ListAPIServerSource() (*v1alpha2.ApiServerSourceList, error)

	// Get namespace for this client
	Namespace() string
}

KnAPIServerSourcesClient interface for working with ApiServer sources

type KnPingSourcesClient 

type KnPingSourcesClient interface {

	// GetPingSource fetches a Ping source by its name
	GetPingSource(name string) (*v1alpha2.PingSource, error)

	// CreatePingSource creates a Ping source
	CreatePingSource(pingSource *v1alpha2.PingSource) error

	// UpdatePingSource updates a Ping source
	UpdatePingSource(pingSource *v1alpha2.PingSource) error

	// DeletePingSource deletes a Ping source
	DeletePingSource(name string) error

	// ListPingSource lists all Ping sources
	// TODO: Support list configs like in service list
	ListPingSource() (*v1alpha2.PingSourceList, error)

	// Get namespace for this source
	Namespace() string
}

Interface for interacting with a Ping source

type KnSinkBindingClient 

type KnSinkBindingClient interface {
	// Namespace in which this client is operating for
	Namespace() string
	// CreateSinkBinding is used to create an instance of binding
	CreateSinkBinding(binding *v1alpha2.SinkBinding) error
	// DeleteSinkBinding is used to delete an instance of binding
	DeleteSinkBinding(name string) error
	// GetSinkBinding is used to get an instance of binding
	GetSinkBinding(name string) (*v1alpha2.SinkBinding, error)
	// ListSinkBinding returns list of binding CRDs
	ListSinkBindings() (*v1alpha2.SinkBindingList, error)
	// UpdateSinkBinding is used to update an instance of binding
	UpdateSinkBinding(binding *v1alpha2.SinkBinding) error
}

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

type KnSourcesClient 

type KnSourcesClient interface {
	// Get client for Ping sources
	PingSourcesClient() KnPingSourcesClient

	// Get client for sink binding sources
	SinkBindingClient() KnSinkBindingClient

	// Get client for ApiServer sources
	APIServerSourcesClient() KnAPIServerSourcesClient
}

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

func NewKnSourcesClient 

func NewKnSourcesClient(client clientv1alpha2.SourcesV1alpha2Interface, namespace string) KnSourcesClient

NewKnSourcesClient for managing all eventing built-in sources

type MockKnAPIServerSourceClient added in v0.14.0 

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

MockKnAPIServerSourceClient for mocking the client

func NewMockKnAPIServerSourceClient added in v0.14.0 

func NewMockKnAPIServerSourceClient(t *testing.T, ns ...string) *MockKnAPIServerSourceClient

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

func (*MockKnAPIServerSourceClient) CreateAPIServerSource added in v0.14.0 

func (c *MockKnAPIServerSourceClient) CreateAPIServerSource(apiServerSource *v1alpha2.ApiServerSource) error

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

func (*MockKnAPIServerSourceClient) DeleteAPIServerSource added in v0.14.0 

func (c *MockKnAPIServerSourceClient) DeleteAPIServerSource(name string) error

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

func (*MockKnAPIServerSourceClient) GetAPIServerSource added in v0.14.0 

func (c *MockKnAPIServerSourceClient) GetAPIServerSource(name string) (*v1alpha2.ApiServerSource, error)

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

func (*MockKnAPIServerSourceClient) ListAPIServerSource added in v0.14.0 

func (c *MockKnAPIServerSourceClient) ListAPIServerSource() (*v1alpha2.ApiServerSourceList, error)

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

func (*MockKnAPIServerSourceClient) Namespace added in v0.14.0 

func (c *MockKnAPIServerSourceClient) Namespace() string

Namespace of this client

func (*MockKnAPIServerSourceClient) Recorder added in v0.14.0 

func (c *MockKnAPIServerSourceClient) Recorder() *APIServerSourcesRecorder

Recorder returns the recorder for registering API calls

func (*MockKnAPIServerSourceClient) UpdateAPIServerSource added in v0.14.0 

func (c *MockKnAPIServerSourceClient) UpdateAPIServerSource(apiServerSource *v1alpha2.ApiServerSource) error

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

type MockKnPingSourceClient 

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

func NewMockKnPingSourceClient 

func NewMockKnPingSourceClient(t *testing.T, ns ...string) *MockKnPingSourceClient

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

func (*MockKnPingSourceClient) CreatePingSource 

func (c *MockKnPingSourceClient) CreatePingSource(pingSource *v1alpha2.PingSource) error

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

func (*MockKnPingSourceClient) DeletePingSource 

func (c *MockKnPingSourceClient) DeletePingSource(name string) error

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

func (*MockKnPingSourceClient) GetPingSource 

func (c *MockKnPingSourceClient) GetPingSource(name string) (*v1alpha2.PingSource, error)

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

func (*MockKnPingSourceClient) ListPingSource 

func (c *MockKnPingSourceClient) ListPingSource() (*v1alpha2.PingSourceList, error)

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

func (*MockKnPingSourceClient) Namespace 

func (c *MockKnPingSourceClient) Namespace() string

Namespace of this client

func (*MockKnPingSourceClient) Recorder 

func (c *MockKnPingSourceClient) Recorder() *PingSourcesRecorder

Recorder returns the recorder for registering API calls

func (*MockKnPingSourceClient) UpdatePingSource 

func (c *MockKnPingSourceClient) UpdatePingSource(pingSource *v1alpha2.PingSource) error

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

type MockKnSinkBindingClient 

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

MockKnSinkBindingClient is a combine of test object and recorder

func NewMockKnSinkBindingClient 

func NewMockKnSinkBindingClient(t *testing.T, ns ...string) *MockKnSinkBindingClient

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

func (*MockKnSinkBindingClient) CreateSinkBinding 

func (c *MockKnSinkBindingClient) CreateSinkBinding(binding *v1alpha2.SinkBinding) error

CreateSinkBinding performs a previously recorded action

func (*MockKnSinkBindingClient) DeleteSinkBinding 

func (c *MockKnSinkBindingClient) DeleteSinkBinding(name string) error

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

func (*MockKnSinkBindingClient) GetSinkBinding 

func (c *MockKnSinkBindingClient) GetSinkBinding(name string) (*v1alpha2.SinkBinding, error)

GetSinkBinding performs a previously recorded action

func (*MockKnSinkBindingClient) ListSinkBindings 

func (c *MockKnSinkBindingClient) ListSinkBindings() (*v1alpha2.SinkBindingList, error)

ListSinkBindings performs a previously recorded action

func (*MockKnSinkBindingClient) Namespace 

func (c *MockKnSinkBindingClient) Namespace() string

Namespace of this client

func (*MockKnSinkBindingClient) Recorder 

func (c *MockKnSinkBindingClient) Recorder() *EventingRecorder

Recorder returns the recorder for registering API calls

func (*MockKnSinkBindingClient) UpdateSinkBinding 

func (c *MockKnSinkBindingClient) UpdateSinkBinding(binding *v1alpha2.SinkBinding) error

UpdateSinkBinding performs a previously recorded action

type PingSourceBuilder 

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

func NewPingSourceBuilder 

func NewPingSourceBuilder(name string) *PingSourceBuilder

func NewPingSourceBuilderFromExisting 

func NewPingSourceBuilderFromExisting(pingsource *v1alpha2.PingSource) *PingSourceBuilder

func (*PingSourceBuilder) Build 

func (b *PingSourceBuilder) Build() *v1alpha2.PingSource

func (*PingSourceBuilder) CloudEventOverrides added in v0.15.0 

func (b *PingSourceBuilder) CloudEventOverrides(ceo map[string]string, toRemove []string) *PingSourceBuilder

CloudEventOverrides adds given Cloud Event override extensions map to source spec

func (*PingSourceBuilder) JsonData 

func (b *PingSourceBuilder) JsonData(data string) *PingSourceBuilder

func (*PingSourceBuilder) Schedule 

func (b *PingSourceBuilder) Schedule(schedule string) *PingSourceBuilder

func (*PingSourceBuilder) Sink 

func (b *PingSourceBuilder) Sink(sink duckv1.Destination) *PingSourceBuilder

type PingSourcesRecorder 

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

recorder for service

func (*PingSourcesRecorder) CreatePingSource 

func (sr *PingSourcesRecorder) CreatePingSource(pingSource interface{}, err error)

CreatePingSource records a call for CreatePingSource with the expected error

func (*PingSourcesRecorder) DeletePingSource 

func (sr *PingSourcesRecorder) DeletePingSource(name interface{}, err error)

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

func (*PingSourcesRecorder) GetPingSource 

func (sr *PingSourcesRecorder) GetPingSource(name interface{}, pingSource *v1alpha2.PingSource, err error)

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

func (*PingSourcesRecorder) ListPingSource 

func (sr *PingSourcesRecorder) ListPingSource(pingSourceList *v1alpha2.PingSourceList, err error)

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

func (*PingSourcesRecorder) UpdatePingSource 

func (sr *PingSourcesRecorder) UpdatePingSource(pingSource interface{}, err error)

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

func (*PingSourcesRecorder) Validate 

func (sr *PingSourcesRecorder) Validate()

Validates validates whether every recorded action has been called

type SinkBindingBuilder 

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

SinkBindingBuilder is for building the binding

func NewSinkBindingBuilder 

func NewSinkBindingBuilder(name string) *SinkBindingBuilder

NewSinkBindingBuilder for building binding object

func NewSinkBindingBuilderFromExisting 

func NewSinkBindingBuilderFromExisting(binding *v1alpha2.SinkBinding) *SinkBindingBuilder

NewSinkBindingBuilderFromExisting for building the object from existing SinkBinding object

func (*SinkBindingBuilder) AddSubjectMatchLabel 

func (b *SinkBindingBuilder) AddSubjectMatchLabel(labelKey, labelValue string) *SinkBindingBuilder

Add a label match part for building up the subject

func (*SinkBindingBuilder) Build 

func (b *SinkBindingBuilder) Build() (*v1alpha2.SinkBinding, error)

Build to return an instance of binding object

func (*SinkBindingBuilder) CloudEventOverrides added in v0.15.0 

func (b *SinkBindingBuilder) CloudEventOverrides(ceo map[string]string, toRemove []string) *SinkBindingBuilder

CloudEventOverrides adds given Cloud Event override extensions map to source spec

func (*SinkBindingBuilder) Namespace 

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

Namespace for this binding

func (*SinkBindingBuilder) Sink 

func (b *SinkBindingBuilder) Sink(sink *duckv1.Destination) *SinkBindingBuilder

Broker to set the broker of binding object

func (*SinkBindingBuilder) Subject 

func (b *SinkBindingBuilder) Subject(subject *tracker.Reference) *SinkBindingBuilder

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

func (*SinkBindingBuilder) SubjectGVK 

func (b *SinkBindingBuilder) SubjectGVK(gvk *schema.GroupVersionKind) *SinkBindingBuilder

Add a GVK of the subject

func (*SinkBindingBuilder) SubjectName 

func (b *SinkBindingBuilder) SubjectName(name string) *SinkBindingBuilder

Add a subject name for building up the name

func (*SinkBindingBuilder) SubjectNamespace 

func (b *SinkBindingBuilder) SubjectNamespace(ns string) *SinkBindingBuilder

Add a subject namespace for building up the name

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.