v1alpha1

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APIServerSourceBuilder 

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

APIServerSourceBuilder is for building the source

func NewAPIServerSourceBuilder 

func NewAPIServerSourceBuilder(name string) *APIServerSourceBuilder

NewAPIServerSourceBuilder for building ApiServer source object

func NewAPIServerSourceBuilderFromExisting 

func NewAPIServerSourceBuilderFromExisting(apiServerSource *v1alpha1.ApiServerSource) *APIServerSourceBuilder

NewAPIServerSourceBuilderFromExisting for building the object from existing ApiServerSource object

func (*APIServerSourceBuilder) Build 

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

Build the ApiServerSource object

func (*APIServerSourceBuilder) Mode 

func (b *APIServerSourceBuilder) Mode(mode string) *APIServerSourceBuilder

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

func (*APIServerSourceBuilder) Resources 

func (b *APIServerSourceBuilder) Resources(resources []v1alpha1.ApiServerResource) *APIServerSourceBuilder

Resources which should be streamed

func (*APIServerSourceBuilder) ServiceAccount 

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

ServiceAccount with which this source should operate

func (*APIServerSourceBuilder) Sink 

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

Sink or destination of the source

type APIServerSourcesRecorder 

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

APIServerSourcesRecorder for recording actions on source

func (*APIServerSourcesRecorder) CreateAPIServerSource 

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

CreateAPIServerSource records a call for CreateApiServerSource with the expected error

func (*APIServerSourcesRecorder) DeleteAPIServerSource 

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

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

func (*APIServerSourcesRecorder) GetAPIServerSource 

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 

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 

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

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

func (*APIServerSourcesRecorder) Validate 

func (sr *APIServerSourcesRecorder) Validate()

Validate validates whether every recorded action has been called

type CronJobSourceBuilder 

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

func NewCronJobSourceBuilder 

func NewCronJobSourceBuilder(name string) *CronJobSourceBuilder

func NewCronJobSourceBuilderFromExisting 

func NewCronJobSourceBuilderFromExisting(cronjobsource *v1alpha1.CronJobSource) *CronJobSourceBuilder

func (*CronJobSourceBuilder) Build 

func (b *CronJobSourceBuilder) Build() *v1alpha1.CronJobSource

func (*CronJobSourceBuilder) Data 

func (b *CronJobSourceBuilder) Data(data string) *CronJobSourceBuilder

func (*CronJobSourceBuilder) Schedule 

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

func (*CronJobSourceBuilder) Sink 

func (b *CronJobSourceBuilder) Sink(sink *duckv1beta1.Destination) *CronJobSourceBuilder

type CronJobSourcesRecorder 

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

recorder for service

func (*CronJobSourcesRecorder) CreateCronJobSource 

func (sr *CronJobSourcesRecorder) CreateCronJobSource(cronjobSource interface{}, err error)

CreateCronJobSource records a call for CreateCronJobSource with the expected error

func (*CronJobSourcesRecorder) DeleteCronJobSource 

func (sr *CronJobSourcesRecorder) DeleteCronJobSource(name interface{}, err error)

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

func (*CronJobSourcesRecorder) GetCronJobSource 

func (sr *CronJobSourcesRecorder) GetCronJobSource(name interface{}, cronjobSource *v1alpha1.CronJobSource, err error)

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

func (*CronJobSourcesRecorder) ListCronJobSource 

func (sr *CronJobSourcesRecorder) ListCronJobSource(cronJobSourceList *v1alpha1.CronJobSourceList, err error)

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

func (*CronJobSourcesRecorder) UpdateCronJobSource 

func (sr *CronJobSourcesRecorder) UpdateCronJobSource(cronjobSource interface{}, err error)

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

func (*CronJobSourcesRecorder) Validate 

func (sr *CronJobSourcesRecorder) Validate()

Validates validates whether every recorded action has been called

type KnAPIServerSourcesClient 

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 KnCronJobSourcesClient 

type KnCronJobSourcesClient interface {

	// Get a single cronjob source by name
	GetCronJobSource(name string) (*v1alpha1.CronJobSource, error)

	// Create a cronjob source by providing the schedule, data and sink
	CreateCronJobSource(cronjobSource *v1alpha1.CronJobSource) error

	// Update a cronjob source by providing the schedule, data and sink
	UpdateCronJobSource(cronjobSource *v1alpha1.CronJobSource) error

	// Delete a cronjob source by name
	DeleteCronJobSource(name string) error

	// List CronJob sources
	// TODO: Support list configs like in service list
	ListCronJobSource() (*v1alpha1.CronJobSourceList, error)

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

Interface for interacting with a cronjob source

type KnSourcesClient 

type KnSourcesClient interface {
	// Get client for ApiServer sources
	APIServerSourcesClient() KnAPIServerSourcesClient

	// Get client for CronJob sources
	CronJobSourcesClient() KnCronJobSourcesClient
}

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

func NewKnSourcesClient 

func NewKnSourcesClient(client client_v1alpha1.SourcesV1alpha1Interface, namespace string) KnSourcesClient

NewKnSourcesClient for managing all eventing built-in sources

type MockKnAPIServerSourceClient 

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

MockKnAPIServerSourceClient for mocking the client

func NewMockKnAPIServerSourceClient 

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

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

func (*MockKnAPIServerSourceClient) CreateAPIServerSource 

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

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

func (*MockKnAPIServerSourceClient) DeleteAPIServerSource 

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

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

func (*MockKnAPIServerSourceClient) GetAPIServerSource 

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

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

func (*MockKnAPIServerSourceClient) ListAPIServerSource 

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

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

func (*MockKnAPIServerSourceClient) Namespace 

func (c *MockKnAPIServerSourceClient) Namespace() string

Namespace of this client

func (*MockKnAPIServerSourceClient) Recorder 

func (c *MockKnAPIServerSourceClient) Recorder() *APIServerSourcesRecorder

Recorder returns the recorder for registering API calls

func (*MockKnAPIServerSourceClient) UpdateAPIServerSource 

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

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

type MockKnCronJobSourceClient 

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

func NewMockKnCronJobSourceClient 

func NewMockKnCronJobSourceClient(t *testing.T, ns ...string) *MockKnCronJobSourceClient

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

func (*MockKnCronJobSourceClient) CreateCronJobSource 

func (c *MockKnCronJobSourceClient) CreateCronJobSource(cronjobSource *v1alpha1.CronJobSource) error

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

func (*MockKnCronJobSourceClient) DeleteCronJobSource 

func (c *MockKnCronJobSourceClient) DeleteCronJobSource(name string) error

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

func (*MockKnCronJobSourceClient) GetCronJobSource 

func (c *MockKnCronJobSourceClient) GetCronJobSource(name string) (*v1alpha1.CronJobSource, error)

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

func (*MockKnCronJobSourceClient) ListCronJobSource 

func (c *MockKnCronJobSourceClient) ListCronJobSource() (*v1alpha1.CronJobSourceList, error)

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

func (*MockKnCronJobSourceClient) Namespace 

func (c *MockKnCronJobSourceClient) Namespace() string

Namespace of this client

func (*MockKnCronJobSourceClient) Recorder 

func (c *MockKnCronJobSourceClient) Recorder() *CronJobSourcesRecorder

Recorder returns the recorder for registering API calls

func (*MockKnCronJobSourceClient) UpdateCronJobSource 

func (c *MockKnCronJobSourceClient) UpdateCronJobSource(cronjobSource *v1alpha1.CronJobSource) error

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

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.