Versions in this module Expand all Collapse all v0 v0.12.0 Jan 21, 2020 Changes in this version + const ClusterRoleKind + const RoleKind + const TestPullSecretName + var BrokerTypeMeta = EventingTypeMeta(resources.BrokerKind) + var ChannelFeatureMap = map[metav1.TypeMeta][]Feature + var ChannelTypeMeta = MessagingTypeMeta(resources.ChannelKind) + var ContainerSourceTypeMeta = LegacySourcesTypeMeta(resources.ContainerSourceKind) + var CronJobSourceTypeMeta = LegacySourcesTypeMeta(resources.CronJobSourceKind) + var DefaultChannel = InMemoryChannelTypeMeta + var FlowsParallelTypeMeta = FlowsTypeMeta(resources.FlowsParallelKind) + var FlowsSequenceTypeMeta = FlowsTypeMeta(resources.FlowsSequenceKind) + var InMemoryChannelTypeMeta = metav1.TypeMeta + var LegacyApiServerSourceTypeMeta = LegacySourcesTypeMeta(resources.ApiServerSourceKind) + var ParallelTypeMeta = MessagingTypeMeta(resources.ParallelKind) + var SequenceTypeMeta = MessagingTypeMeta(resources.SequenceKind) + var SubscriptionTypeMeta = MessagingTypeMeta(resources.SubscriptionKind) + var TriggerTypeMeta = EventingTypeMeta(resources.TriggerKind) + func CheckerContains(content string) func(string) bool + func CheckerContainsAll(contents []string) func(string) bool + func CheckerContainsAtLeast(content string, count int) func(string) bool + func CheckerContainsCount(content string, count int) func(string) bool + func CreateNamespaceIfNeeded(t *testing.T, client *Client, namespace string) + func DeleteNameSpace(client *Client) error + func EventingTypeMeta(kind string) *metav1.TypeMeta + func FlowsTypeMeta(kind string) *metav1.TypeMeta + func LegacySourcesTypeMeta(kind string) *metav1.TypeMeta + func MessagingTypeMeta(kind string) *metav1.TypeMeta + func TearDown(client *Client) + func WithService(name string) func(*corev1.Pod, *Client) error + type ChannelTestRunner struct + ChannelFeatureMap map[metav1.TypeMeta][]Feature + ChannelsToTest []metav1.TypeMeta + func (tr *ChannelTestRunner) RunTests(t *testing.T, feature Feature, ...) + type Client struct + Config *rest.Config + Dynamic dynamic.Interface + Eventing *eventing.Clientset + Kube *test.KubeClient + Legacy *legacy.Clientset + Namespace string + T *testing.T + Tracker *Tracker + func NewClient(configPath string, clusterName string, namespace string, t *testing.T) (*Client, error) + func Setup(t *testing.T, runInParallel bool, options ...SetupClientOption) *Client + func (client *Client) CheckLog(podName string, checker func(string) bool) error + func (client *Client) CheckLogEmpty(podName string, timeout time.Duration) error + func (client *Client) CreateApiServerSourceOrFail(apiServerSource *sourcesv1alpha1.ApiServerSource) + func (client *Client) CreateBrokerOrFail(name string, options ...resources.BrokerOption) *v1alpha1.Broker + func (client *Client) CreateBrokersOrFail(names []string, channelTypeMeta *metav1.TypeMeta) + func (client *Client) CreateChannelOrFail(name string, channelTypeMeta *metav1.TypeMeta) + func (client *Client) CreateChannelWithDefaultOrFail(channel *messagingv1alpha1.Channel) + func (client *Client) CreateChannelsOrFail(names []string, channelTypeMeta *metav1.TypeMeta) + func (client *Client) CreateClusterRoleBindingOrFail(saName, crName, crbName string) + func (client *Client) CreateClusterRoleOrFail(cr *rbacv1.ClusterRole) + func (client *Client) CreateCronJobOrFail(cronjob *batchv1beta1.CronJob, ...) + func (client *Client) CreateDeploymentOrFail(deploy *appsv1.Deployment, options ...func(*appsv1.Deployment, *Client) error) + func (client *Client) CreateFlowsParallelOrFail(parallel *flowsv1alpha1.Parallel) + func (client *Client) CreateFlowsSequenceOrFail(sequence *flowsv1alpha1.Sequence) + func (client *Client) CreateLegacyApiServerSourceOrFail(apiServerSource *legacysourcesv1alpha1.ApiServerSource) + func (client *Client) CreateLegacyContainerSourceOrFail(containerSource *legacysourcesv1alpha1.ContainerSource) + func (client *Client) CreateLegacyCronJobSourceOrFail(cronJobSource *legacysourcesv1alpha1.CronJobSource) + func (client *Client) CreateLegacySinkBindingOrFail(containerSource *legacysourcesv1alpha1.SinkBinding) + func (client *Client) CreateParallelOrFail(parallel *messagingv1alpha1.Parallel) + func (client *Client) CreatePodOrFail(pod *corev1.Pod, options ...func(*corev1.Pod, *Client) error) + func (client *Client) CreateRBACResourcesForBrokers() + func (client *Client) CreateRoleBindingOrFail(saName, rKind, rName, rbName, rbNamespace string) + func (client *Client) CreateRoleOrFail(r *rbacv1.Role) + func (client *Client) CreateSequenceOrFail(sequence *messagingv1alpha1.Sequence) + func (client *Client) CreateServiceAccountOrFail(saName string) + func (client *Client) CreateServiceOrFail(svc *corev1.Service) *corev1.Service + func (client *Client) CreateSinkBindingOrFail(sb *sourcesv1alpha1.SinkBinding) + func (client *Client) CreateSubscriptionOrFail(name, channelName string, channelTypeMeta *metav1.TypeMeta, ...) + func (client *Client) CreateSubscriptionsOrFail(names []string, channelName string, channelTypeMeta *metav1.TypeMeta, ...) + func (client *Client) CreateTriggerOrFail(name string, options ...resources.TriggerOption) *v1alpha1.Trigger + func (client *Client) FindAnyLogContents(podName string, contents []string) (bool, error) + func (client *Client) GetAddressableURI(addressableName string, typeMeta *metav1.TypeMeta) (string, error) + func (client *Client) GetLog(podName string) (string, error) + func (client *Client) LabelNamespace(labels map[string]string) error + func (client *Client) SendFakeEventToAddressable(senderName, addressableName string, typemeta *metav1.TypeMeta, ...) error + func (client *Client) SendFakeEventWithTracingToAddressable(senderName, addressableName string, typemeta *metav1.TypeMeta, ...) error + func (client *Client) WaitForAllTestResourcesReady() error + func (client *Client) WaitForAllTestResourcesReadyOrFail() + func (client *Client) WaitForResourceReady(name string, typemeta *metav1.TypeMeta) error + func (client *Client) WaitForResourceReadyOrFail(name string, typemeta *metav1.TypeMeta) + func (client *Client) WaitForResourcesReady(typemeta *metav1.TypeMeta) error + func (client *Client) WaitForResourcesReadyOrFail(typemeta *metav1.TypeMeta) + func (client *Client) WaitForServiceEndpointsOrFail(svcName string, numberOfExpectedEndpoints int) + type Feature string + const FeatureBasic + const FeaturePersistence + const FeatureRedelivery + type ResourceDeleter struct + Name string + Resource dynamic.ResourceInterface + type SetupClientOption func(*Client) + var SetupClientOptionNoop SetupClientOption = func(*Client) { ... } + type Tracker struct + func NewTracker(t *testing.T, client dynamic.Interface) *Tracker + func (t *Tracker) Add(group string, version string, resource string, namespace string, name string) + func (t *Tracker) AddObj(obj kmeta.OwnerRefable) + func (t *Tracker) Clean(awaitDeletion bool) error + func (t *Tracker) WaitForKResourcesReady() error
Go to main page