test

Sep 17, 2019

Changes in this version

+ func InitializeEventingFlags()

Aug 6, 2019

Changes in this version

+ type Channels []string

+ func (channels *Channels) Set(value string) error

+ func (channels *Channels) String() string

May 14, 2019

Changes in this version

+ const CloudEventDefaultEncoding

+ const CloudEventDefaultType

+ const DefaultBrokerName

+ const DefaultClusterChannelProvisioner

+ const GCPPubSubProvisioner

+ const InMemoryChannelProvisioner

+ const InMemoryProvisioner

+ const KafkaProvisioner

+ const NatssProvisioner

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

+ func ReplyStrategyForChannel(name string) *v1alpha1.ReplyStrategy

type EventingEnvironmentFlags

+ RunFromMain bool

+ type Provisioners []string

+ func (ps *Provisioners) Set(value string) error

+ func (ps *Provisioners) String() string

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

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

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