v1alpha2

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: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 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
}

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 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) 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) AddCloudEventOverrides 

func (b *SinkBindingBuilder) AddCloudEventOverrides(ceo map[string]string) *SinkBindingBuilder

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) 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.