v1beta1

Documentation

Index

• type ChannelBuilder
  • func NewChannelBuilder(name string) *ChannelBuilder
  • func (c *ChannelBuilder) Build() *v1beta1.Channel
  • func (c *ChannelBuilder) Type(gvk *schema.GroupVersionKind) *ChannelBuilder
• type ChannelsRecorder
  • func (sr *ChannelsRecorder) CreateChannel(channels interface{}, err error)
  • func (sr *ChannelsRecorder) DeleteChannel(name interface{}, err error)
  • func (sr *ChannelsRecorder) GetChannel(name interface{}, channels *v1beta1.Channel, err error)
  • func (sr *ChannelsRecorder) ListChannel(channelsList *v1beta1.ChannelList, err error)
  • func (sr *ChannelsRecorder) Validate()
• type KnChannelsClient
• type KnMessagingClient
  • func NewKnMessagingClient(client clientv1beta1.MessagingV1beta1Interface, namespace string) KnMessagingClient
• type MockKnChannelsClient
  • func NewMockKnChannelsClient(t *testing.T, ns ...string) *MockKnChannelsClient
  • func (c *MockKnChannelsClient) CreateChannel(channels *v1beta1.Channel) error
  • func (c *MockKnChannelsClient) DeleteChannel(name string) error
  • func (c *MockKnChannelsClient) GetChannel(name string) (*v1beta1.Channel, error)
  • func (c *MockKnChannelsClient) ListChannel() (*v1beta1.ChannelList, error)
  • func (c *MockKnChannelsClient) Namespace() string
  • func (c *MockKnChannelsClient) Recorder() *ChannelsRecorder

Types

type ChannelBuilder

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

ChannelBuilder is for building the Channel object

func NewChannelBuilder

func NewChannelBuilder(name string) *ChannelBuilder

NewChannelBuilder for building Channel object

func (*ChannelBuilder) Build

func (c *ChannelBuilder) Build() *v1beta1.Channel

Build returns the Channel object from the builder

func (*ChannelBuilder) Type

func (c *ChannelBuilder) Type(gvk *schema.GroupVersionKind) *ChannelBuilder

Type sets the type of the channel to create

type ChannelsRecorder

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

recorder for service

func (*ChannelsRecorder) CreateChannel

func (sr *ChannelsRecorder) CreateChannel(channels interface{}, err error)

CreateChannel records a call for CreateChannel with the expected error

func (*ChannelsRecorder) DeleteChannel

func (sr *ChannelsRecorder) DeleteChannel(name interface{}, err error)

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

func (*ChannelsRecorder) GetChannel

func (sr *ChannelsRecorder) GetChannel(name interface{}, channels *v1beta1.Channel, err error)

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

func (*ChannelsRecorder) ListChannel

func (sr *ChannelsRecorder) ListChannel(channelsList *v1beta1.ChannelList, err error)

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

func (*ChannelsRecorder) Validate

func (sr *ChannelsRecorder) Validate()

Validates validates whether every recorded action has been called

type KnChannelsClient

type KnChannelsClient interface {

	// GetChannel returns a Channel by its name
	GetChannel(name string) (*v1beta1.Channel, error)

	// CreteChannel creates a Channel with given spec
	CreateChannel(channel *v1beta1.Channel) error

	// DeleteChannel deletes a Channel by its name
	DeleteChannel(name string) error

	// ListChannel lists all Channels
	ListChannel() (*v1beta1.ChannelList, error)

	// Namespace returns the namespace for this channel client
	Namespace() string
}

KnChannelsClient for interacting with Channels

type KnMessagingClient

type KnMessagingClient interface {
	// Get the Channels client
	ChannelsClient() KnChannelsClient
}

KnMessagingClient to Eventing Messaging. All methods are relative to the namespace specificied during construction

func NewKnMessagingClient

func NewKnMessagingClient(client clientv1beta1.MessagingV1beta1Interface, namespace string) KnMessagingClient

NewKnMessagingClient for managing all eventing messaging types

type MockKnChannelsClient

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

func NewMockKnChannelsClient

func NewMockKnChannelsClient(t *testing.T, ns ...string) *MockKnChannelsClient

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

func (*MockKnChannelsClient) CreateChannel

func (c *MockKnChannelsClient) CreateChannel(channels *v1beta1.Channel) error

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

func (*MockKnChannelsClient) DeleteChannel

func (c *MockKnChannelsClient) DeleteChannel(name string) error

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

func (*MockKnChannelsClient) GetChannel

func (c *MockKnChannelsClient) GetChannel(name string) (*v1beta1.Channel, error)

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

func (*MockKnChannelsClient) ListChannel

func (c *MockKnChannelsClient) ListChannel() (*v1beta1.ChannelList, error)

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

func (*MockKnChannelsClient) Namespace

func (c *MockKnChannelsClient) Namespace() string

Namespace of this client

func (*MockKnChannelsClient) Recorder

func (c *MockKnChannelsClient) Recorder() *ChannelsRecorder

Recorder returns the recorder for registering API calls