v1beta1

Oct 7, 2020

Changes in this version

+ func BuiltInChannelGVKs() []schema.GroupVersionKind

Oct 7, 2020

Changes in this version

type KnMessagingClient

+ SubscriptionsClient func() KnSubscriptionsClient

+ type KnSubscriptionsClient interface

+ CreateSubscription func(subscription *v1beta1.Subscription) error

+ DeleteSubscription func(name string) error

+ GetSubscription func(name string) (*v1beta1.Subscription, error)

+ ListSubscription func() (*v1beta1.SubscriptionList, error)

+ Namespace func() string

+ UpdateSubscription func(subscription *v1beta1.Subscription) error

+ type MockKnSubscriptionsClient struct

+ func NewMockKnSubscriptionsClient(t *testing.T, ns ...string) *MockKnSubscriptionsClient

+ func (c *MockKnSubscriptionsClient) CreateSubscription(subscription *v1beta1.Subscription) error

+ func (c *MockKnSubscriptionsClient) DeleteSubscription(name string) error

+ func (c *MockKnSubscriptionsClient) GetSubscription(name string) (*v1beta1.Subscription, error)

+ func (c *MockKnSubscriptionsClient) ListSubscription() (*v1beta1.SubscriptionList, error)

+ func (c *MockKnSubscriptionsClient) Namespace() string

+ func (c *MockKnSubscriptionsClient) Recorder() *SubscriptionsRecorder

+ func (c *MockKnSubscriptionsClient) UpdateSubscription(subscription *v1beta1.Subscription) error

+ type SubscriptionBuilder struct

+ func NewSubscriptionBuilder(name string) *SubscriptionBuilder

+ func NewSubscriptionBuilderFromExisting(subs *v1beta1.Subscription) *SubscriptionBuilder

+ func (s *SubscriptionBuilder) Build() *v1beta1.Subscription

+ func (s *SubscriptionBuilder) Channel(channel *corev1.ObjectReference) *SubscriptionBuilder

+ func (s *SubscriptionBuilder) DeadLetterSink(dls *duckv1.Destination) *SubscriptionBuilder

+ func (s *SubscriptionBuilder) Reply(reply *duckv1.Destination) *SubscriptionBuilder

+ func (s *SubscriptionBuilder) Subscriber(subs *duckv1.Destination) *SubscriptionBuilder

+ type SubscriptionsRecorder struct

+ func (sr *SubscriptionsRecorder) CreateSubscription(subscription interface{}, err error)

+ func (sr *SubscriptionsRecorder) DeleteSubscription(name interface{}, err error)

+ func (sr *SubscriptionsRecorder) GetSubscription(name interface{}, subscription *v1beta1.Subscription, err error)

+ func (sr *SubscriptionsRecorder) ListSubscription(subscriptionsList *v1beta1.SubscriptionList, err error)

+ func (sr *SubscriptionsRecorder) UpdateSubscription(subscription interface{}, err error)

+ func (sr *SubscriptionsRecorder) Validate()

Aug 26, 2020

Changes in this version

+ type ChannelBuilder struct

+ func NewChannelBuilder(name string) *ChannelBuilder

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

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

+ type ChannelsRecorder struct

+ 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 interface

+ CreateChannel func(channel *v1beta1.Channel) error

+ DeleteChannel func(name string) error

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

+ ListChannel func() (*v1beta1.ChannelList, error)

+ Namespace func() string

+ type KnMessagingClient interface

+ ChannelsClient func() KnChannelsClient

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

+ type MockKnChannelsClient struct

+ 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