test

package

Go to main page

Versions in this module

v0

v0.5.0

Apr 2, 2019

Changes in this version

+ func Broker(name string, namespace string) *v1alpha1.Broker

+ func IsBrokerReady(b *eventingv1alpha1.Broker) (bool, error)

+ func IsTriggerReady(t *eventingv1alpha1.Trigger) (bool, error)

+ func TriggersReady(triggerList *eventingv1alpha1.TriggerList) (bool, error)

+ func WaitForBrokerState(client eventingclient.BrokerInterface, name string, ...) error

+ func WaitForTriggerState(client eventingclient.TriggerInterface, name string, ...) error

+ func WaitForTriggersListState(clients eventingclient.TriggerInterface, ...) error

+ type TriggerBuilder struct

+ func NewTriggerBuilder(name, namespace string) *TriggerBuilder

+ func (b *TriggerBuilder) Broker(brokerName string) *TriggerBuilder

+ func (b *TriggerBuilder) Build() *eventingv1alpha1.Trigger

+ func (b *TriggerBuilder) EventSource(eventSource string) *TriggerBuilder

+ func (b *TriggerBuilder) EventType(eventType string) *TriggerBuilder

+ func (b *TriggerBuilder) SubscriberSvc(svcName string) *TriggerBuilder

+ type TypeAndSource struct

+ Source string

+ Type string

v0.4.1

Feb 20, 2019

v0.4.0

Feb 15, 2019

Changes in this version

+ const CloudEventEncodingBinary

+ const CloudEventEncodingStructured

+ func EventLoggerPod(name string, namespace string, selector map[string]string) *corev1.Pod

+ func EventSenderPod(name string, namespace string, sink string, event CloudEvent) *corev1.Pod

+ func ImagePath(name string) string

+ func IsChannelReady(c *eventingv1alpha1.Channel) (bool, error)

+ func IsSubscriptionReady(s *eventingv1alpha1.Subscription) (bool, error)

+ func Service(name string, namespace string, selector map[string]string) *corev1.Service

+ func SubscriberSpecForService(name string) *v1alpha1.SubscriberSpec

+ func WaitForChannelState(client eventingclient.ChannelInterface, name string, ...) error

+ func WaitForSubscriptionState(client eventingclient.SubscriptionInterface, name string, ...) error

+ type CloudEvent struct

+ Data string

+ Encoding string

+ ID string

+ Source string

+ Type string

type EventingEnvironmentFlags

+ Provisioner string

v0.3.0

Jan 9, 2019

v0.2.1

Nov 28, 2018

v0.2.0

Nov 10, 2018

Changes in this version

+ var EventingFlags = initializeEventingFlags()

+ func Channel(name string, namespace string, provisioner *corev1.ObjectReference) *v1alpha1.Channel

+ func ChannelRef(name string) *corev1.ObjectReference

+ func CleanupOnInterrupt(cleanup func(), logger *logging.BaseLogger)

+ func ClusterChannelProvisioner(name string) *corev1.ObjectReference

+ func ClusterRoleBinding(name string, namespace string, serviceAccount string, role string) *rbacv1beta1.ClusterRoleBinding

+ func Configuration(name string, namespace string, imagePath string) *servingv1alpha1.Configuration

+ func IsRevisionReady(r *v1alpha1.Revision) (bool, error)

+ func IsRouteReady(r *v1alpha1.Route) (bool, error)

+ func IsServiceReady(s *v1alpha1.Service) (bool, error)

+ func KubernetesEventSource(name string, namespace string, targetNamespace string, serviceAccount string, ...) *sourcesv1alpha1.KubernetesEventSource

+ func NGinxPod(namespace string) *corev1.Pod

+ func PodsRunning(podList *corev1.PodList) (bool, error)

+ func Route(name string, namespace string, configName string) *servingv1alpha1.Route

+ func ServiceAccount(name string, namespace string) *corev1.ServiceAccount

+ func SubscriberSpecForRoute(name string) *v1alpha1.SubscriberSpec

+ func Subscription(name string, namespace string, channel *corev1.ObjectReference, ...) *v1alpha1.Subscription

+ func WaitForRouteState(client servingtyped.RouteInterface, name string, ...) error

+ type Cleaner struct

+ func NewCleaner(log *logging.BaseLogger, client dynamic.Interface) *Cleaner

+ func (c *Cleaner) Add(group string, version string, resource string, namespace string, name string) error

+ func (c *Cleaner) Clean(awaitDeletion bool) error

+ type Clients struct

+ Dynamic dynamic.Interface

+ Eventing *eventing.Clientset

+ Kube *test.KubeClient

+ Serving *serving.Clientset

+ Sources *sources.Clientset

+ func NewClients(configPath string, clusterName string, namespace string) (*Clients, error)

+ type EventingEnvironmentFlags struct

+ DockerRepo string

+ Tag string

+ type ResourceDeleter struct

+ Name string

+ Resource dynamic.ResourceInterface

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