Documentation
¶
Index ¶
- type APIServerSourceBuilder
- func (b *APIServerSourceBuilder) Build() *v1alpha1.ApiServerSource
- func (b *APIServerSourceBuilder) Mode(mode string) *APIServerSourceBuilder
- func (b *APIServerSourceBuilder) Resources(resources []v1alpha1.ApiServerResource) *APIServerSourceBuilder
- func (b *APIServerSourceBuilder) ServiceAccount(sa string) *APIServerSourceBuilder
- func (b *APIServerSourceBuilder) Sink(sink *duckv1beta1.Destination) *APIServerSourceBuilder
- type APIServerSourcesRecorder
- func (sr *APIServerSourcesRecorder) CreateAPIServerSource(apiServerSource interface{}, err error)
- func (sr *APIServerSourcesRecorder) DeleteAPIServerSource(name interface{}, err error)
- func (sr *APIServerSourcesRecorder) GetAPIServerSource(name interface{}, apiServerSource *v1alpha1.ApiServerSource, err error)
- func (sr *APIServerSourcesRecorder) ListAPIServerSource(apiJobSourceList *v1alpha1.ApiServerSourceList, err error)
- func (sr *APIServerSourcesRecorder) UpdateAPIServerSource(apiServerSource interface{}, err error)
- func (sr *APIServerSourcesRecorder) Validate()
- type KnAPIServerSourcesClient
- type KnSourcesClient
- type MockKnAPIServerSourceClient
- func (c *MockKnAPIServerSourceClient) CreateAPIServerSource(apiServerSource *v1alpha1.ApiServerSource) error
- func (c *MockKnAPIServerSourceClient) DeleteAPIServerSource(name string) error
- func (c *MockKnAPIServerSourceClient) GetAPIServerSource(name string) (*v1alpha1.ApiServerSource, error)
- func (c *MockKnAPIServerSourceClient) ListAPIServerSource() (*v1alpha1.ApiServerSourceList, error)
- func (c *MockKnAPIServerSourceClient) Namespace() string
- func (c *MockKnAPIServerSourceClient) Recorder() *APIServerSourcesRecorder
- func (c *MockKnAPIServerSourceClient) UpdateAPIServerSource(apiServerSource *v1alpha1.ApiServerSource) error
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
func (b *APIServerSourceBuilder) Build() *v1alpha1.ApiServerSource
Build the ApiServerSource object
func (*APIServerSourceBuilder) Mode ¶ added in v0.13.0
func (b *APIServerSourceBuilder) Mode(mode string) *APIServerSourceBuilder
Mode for whether to send resource 'Ref' or complete 'Resource'
func (*APIServerSourceBuilder) Resources ¶ added in v0.13.0
func (b *APIServerSourceBuilder) Resources(resources []v1alpha1.ApiServerResource) *APIServerSourceBuilder
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
func (b *APIServerSourceBuilder) Sink(sink *duckv1beta1.Destination) *APIServerSourceBuilder
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
func (c *MockKnAPIServerSourceClient) Recorder() *APIServerSourcesRecorder
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