v1alpha1

package
v0.13.2 Latest Latest
Warning

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

Go to latest
Published: Apr 15, 2020 License: Apache-2.0 Imports: 10 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.13.0

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

APIServerSourceBuilder is for building the source

func NewAPIServerSourceBuilder added in v0.13.0

func NewAPIServerSourceBuilder(name string) *APIServerSourceBuilder

NewAPIServerSourceBuilder for building ApiServer source object

func NewAPIServerSourceBuilderFromExisting added in v0.13.0

func NewAPIServerSourceBuilderFromExisting(apiServerSource *v1alpha1.ApiServerSource) *APIServerSourceBuilder

NewAPIServerSourceBuilderFromExisting for building the object from existing ApiServerSource object

func (*APIServerSourceBuilder) Build added in v0.13.0

Build the ApiServerSource object

func (*APIServerSourceBuilder) Mode added in v0.13.0

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

func (*APIServerSourceBuilder) Resources added in v0.13.0

Resources which should be streamed

func (*APIServerSourceBuilder) ServiceAccount added in v0.13.0

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

ServiceAccount with which this source should operate

func (*APIServerSourceBuilder) Sink added in v0.13.0

Sink or destination of the source

type APIServerSourcesRecorder added in v0.13.0

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

APIServerSourcesRecorder for recording actions on source

func (*APIServerSourcesRecorder) CreateAPIServerSource added in v0.13.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.13.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.13.0

func (sr *APIServerSourcesRecorder) GetAPIServerSource(name interface{}, apiServerSource *v1alpha1.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.13.0

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

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

func (*APIServerSourcesRecorder) UpdateAPIServerSource added in v0.13.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.13.0

func (sr *APIServerSourcesRecorder) Validate()

Validate validates whether every recorded action has been called

type KnAPIServerSourcesClient added in v0.13.0

type KnAPIServerSourcesClient interface {

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

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

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

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

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

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

KnAPIServerSourcesClient interface for working with ApiServer sources

type KnSourcesClient

type KnSourcesClient interface {
	// 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 clientv1alpha1.SourcesV1alpha1Interface, namespace string) KnSourcesClient

NewKnSourcesClient for managing all eventing built-in sources

type MockKnAPIServerSourceClient added in v0.13.0

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

MockKnAPIServerSourceClient for mocking the client

func NewMockKnAPIServerSourceClient added in v0.13.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.13.0

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

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

func (*MockKnAPIServerSourceClient) DeleteAPIServerSource added in v0.13.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.13.0

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

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

func (*MockKnAPIServerSourceClient) ListAPIServerSource added in v0.13.0

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

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

func (*MockKnAPIServerSourceClient) Namespace added in v0.13.0

func (c *MockKnAPIServerSourceClient) Namespace() string

Namespace of this client

func (*MockKnAPIServerSourceClient) Recorder added in v0.13.0

Recorder returns the recorder for registering API calls

func (*MockKnAPIServerSourceClient) UpdateAPIServerSource added in v0.13.0

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL