common

package

Go to main page

Versions in this module

v0

v0.11.0

Dec 10, 2019

Changes in this version

+ var FlowsParallelTypeMeta = FlowsTypeMeta(resources.FlowsParallelKind)

+ var FlowsSequenceTypeMeta = FlowsTypeMeta(resources.FlowsSequenceKind)

+ func FlowsTypeMeta(kind string) *metav1.TypeMeta

type Client

+ Config *rest.Config

+ 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) CreateServiceOrFail(svc *corev1.Service) *corev1.Service

+ func (client *Client) CreateSinkBindingOrFail(containerSource *sourcesv1alpha1.SinkBinding)

+ func (client *Client) WaitForAllTestResourcesReadyOrFail()

+ func (client *Client) WaitForServiceEndpointsOrFail(svcName string, numberOfExpectedEndpoints int)

v0.10.2

Dec 3, 2019

v0.10.1

Nov 13, 2019

v0.10.0

Oct 29, 2019

Changes in this version

+ const ClusterRoleKind

+ const RoleKind

+ const TestPullSecretName

+ func CopySecret(client *Client, srcNS string, srcSecretName string, tgtNS string, ...) (*corev1.Secret, error)

type Client

+ func (client *Client) CreateRoleOrFail(r *rbacv1.Role)

+ func (client *Client) GetLog(podName string) (string, error)

v0.9.0

Sep 17, 2019

Changes in this version

+ var ChannelFeatureMap = map[string][]Feature

+ var ParallelTypeMeta = MessagingTypeMeta(resources.ParallelKind)

+ type ChannelTestRunner struct

+ ChannelFeatureMap map[string][]Feature

+ ChannelsToTest []string

+ func (tr *ChannelTestRunner) RunTests(t *testing.T, feature Feature, testFunc func(st *testing.T, channel string))

type Client

+ func (client *Client) CheckLogEmpty(podName string, timeout time.Duration) error

+ func (client *Client) CreateChannelWithDefaultOrFail(channel *messagingv1alpha1.Channel)

+ func (client *Client) CreateParallelOrFail(parallel *messagingv1alpha1.Parallel)

+ func (client *Client) SendFakeEventWithTracingToAddressable(senderName, addressableName string, typemeta *metav1.TypeMeta, ...) error

+ type CloudEventsTargeter struct

+ func NewCloudEventsTargeter(sinkUrl string, msgSize int, eventType string, eventSource string) CloudEventsTargeter

+ func (cet CloudEventsTargeter) VegetaTargeter() vegeta.Targeter

v0.8.1

Nov 18, 2019

v0.8.0

Aug 6, 2019

Changes in this version

+ const DefaultChannel

+ var ChoiceTypeMeta = MessagingTypeMeta(resources.ChoiceKind)

+ var SequenceTypeMeta = MessagingTypeMeta(resources.SequenceKind)

+ var ValidChannelsMap = map[string]ChannelConfig

type Client

+ func (client *Client) CreateChoiceOrFail(choice *messagingv1alpha1.Choice)

+ func (client *Client) CreateSequenceOrFail(name string, steps []eventingv1alpha1.SubscriberSpec, ...)

v0.7.1

Jul 2, 2019

v0.7.0

Jun 25, 2019

Changes in this version

+ const DefaultClusterChannelProvisioner

+ var ApiServerSourceTypeMeta = SourcesTypeMeta(resources.ApiServerSourceKind)

+ var BrokerTypeMeta = EventingTypeMeta(resources.BrokerKind)

+ var ChannelTypeMeta = EventingTypeMeta(resources.ChannelKind)

+ var ContainerSourceTypeMeta = SourcesTypeMeta(resources.ContainerSourceKind)

+ var CronJobSourceTypeMeta = SourcesTypeMeta(resources.CronJobSourceKind)

+ var InMemoryChannelTypeMeta = MessagingTypeMeta(resources.InMemoryChannelKind)

+ var KafkaChannelTypeMeta = MessagingTypeMeta(resources.KafkaChannelKind)

+ var NatssChannelTypeMeta = MessagingTypeMeta(resources.NatssChannelKind)

+ var ProvisionerChannelMap = map[string]*metav1.TypeMeta

+ var SubscriptionTypeMeta = EventingTypeMeta(resources.SubscriptionKind)

+ var TriggerTypeMeta = EventingTypeMeta(resources.TriggerKind)

+ var ValidProvisionersMap = map[string]ChannelConfig

+ 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 GetChannelTypeMeta(provisioner string, isCRD bool) *metav1.TypeMeta

+ func LogPodLogsForDebugging(client *Client, podName, containerName string)

+ func MessagingTypeMeta(kind string) *metav1.TypeMeta

+ func RunTests(t *testing.T, provisioners []string, feature Feature, ...)

+ func SourcesTypeMeta(kind string) *metav1.TypeMeta

+ func TearDown(client *Client)

+ func WithService(name string) func(*corev1.Pod, *Client) error

+ type ChannelConfig struct

+ CRDSupported bool

+ Features []Feature

+ type Client struct

+ Dynamic dynamic.Interface

+ Eventing *eventing.Clientset

+ Kafka *kafkachannel.Clientset

+ Kube *test.KubeClient

+ Namespace string

+ Natss *natsschannel.Clientset

+ 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) *Client

+ func (client *Client) CheckLog(podName string, checker func(string) bool) error

+ func (client *Client) CreateApiServerSourceOrFail(name string, apiServerSourceResources []sourcesv1alpha1.ApiServerResource, ...)

+ func (client *Client) CreateBrokerOrFail(name string, channelTypeMeta *metav1.TypeMeta, provisionerName string)

+ func (client *Client) CreateBrokersOrFail(names []string, channelTypeMeta *metav1.TypeMeta, provisionerName string)

+ func (client *Client) CreateChannelOrFail(name string, channelTypeMeta *metav1.TypeMeta, provisionerName string)

+ func (client *Client) CreateChannelsOrFail(names []string, channelTypeMeta *metav1.TypeMeta, provisionerName string)

+ func (client *Client) CreateClusterRoleBindingOrFail(saName, crName, crbName string)

+ func (client *Client) CreateClusterRoleOrFail(cr *rbacv1.ClusterRole)

+ func (client *Client) CreateContainerSourceOrFail(name string, options ...resources.ContainerSourceOption)

+ func (client *Client) CreateCronJobSourceOrFail(name, schedule, data string, options ...resources.CronJobSourceOption)

+ func (client *Client) CreatePodOrFail(pod *corev1.Pod, options ...func(*corev1.Pod, *Client) error)

+ func (client *Client) CreateRBACResourcesForBrokers()

+ func (client *Client) CreateRoleBindingOrFail(saName, crName, rbName, rbNamespace string)

+ func (client *Client) CreateServiceAccountOrFail(saName string)

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

+ func (client *Client) FindAnyLogContents(podName string, contents []string) (bool, error)

+ func (client *Client) GetAddressableURI(addressableName string, typemeta *metav1.TypeMeta) (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) WaitForAllTestResourcesReady() error

+ func (client *Client) WaitForResourceReady(name string, typemeta *metav1.TypeMeta) error

+ func (client *Client) WaitForResourcesReady(typemeta *metav1.TypeMeta) error

+ type Feature string

+ const FeatureBasic

+ const FeaturePersistence

+ const FeatureRedelivery

+ type ResourceDeleter struct

+ Name string

+ Resource dynamic.ResourceInterface

+ type Tracker struct

+ func NewTracker(log logging.FormatLogger, 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL