Documentation ¶
Index ¶
- Constants
- func Broker(name string, options ...BrokerOption) *eventingv1alpha1.Broker
- func BrokerV1Beta1(name string, options ...BrokerV1Beta1Option) *eventingv1beta1.Broker
- func ClusterRoleBinding(saName, saNamespace, crName, crbName string) *rbacv1.ClusterRoleBinding
- func ConfigMap(name string, data map[string]string) *corev1.ConfigMap
- func ConfigMapPropagation(name, namespace string) *configsv1alpha1.ConfigMapPropagation
- func Delivery(options ...DeliveryOption) *eventingduckv1beta1.DeliverySpec
- func EventDetailsPod(name string) *corev1.Pod
- func EventFilteringPod(name string, filter bool) *corev1.Pod
- func EventLoggerPod(name string) *corev1.Pod
- func EventRecordPod(name string) *corev1.Pod
- func EventSenderPod(name string, sink string, event *cloudevents.CloudEvent) (*corev1.Pod, error)
- func EventSenderTracingPod(name string, sink string, event *cloudevents.CloudEvent) (*corev1.Pod, error)
- func EventTransformationPod(name string, event *cloudevents.CloudEvent) *corev1.Pod
- func HelloWorldPod(name string, options ...PodOption) *corev1.Pod
- func KServiceRef(name string) *corev1.ObjectReference
- func KnativeRefForBroker(name, namespace string) *duckv1.KReference
- func KnativeRefForService(name, namespace string) *duckv1.KReference
- func PerformanceAggregatorService() *corev1.Service
- func PerformanceConsumerService() *corev1.Service
- func PerformanceImageAggregatorPod(expectedRecords int, publish bool, additionalArgs ...string) *corev1.Pod
- func PerformanceImageReceiverPod(imageName string, pace string, warmup string, aggregatorHostname string, ...) *corev1.Pod
- func Role(rName string, options ...RoleOption) *rbacv1.Role
- func RoleBinding(saName, saNamespace, rKind, rName, rbName, rbNamespace string) *rbacv1.RoleBinding
- func SequenceStepperPod(name, eventMsgAppender string) *corev1.Pod
- func Service(name string, selector map[string]string, ports []corev1.ServicePort) *corev1.Service
- func ServiceAccount(name, namespace string) *corev1.ServiceAccount
- func ServiceDefaultHTTP(name string, selector map[string]string) *corev1.Service
- func ServiceKRef(name string) *v1.KReference
- func ServiceRef(name string) *corev1.ObjectReference
- func Subscription(name, channelName string, channelTypeMeta *metav1.TypeMeta, ...) *messagingv1alpha1.Subscription
- func SubscriptionV1Beta1(name, channelName string, channelTypeMeta *metav1.TypeMeta, ...) *messagingv1beta1.Subscription
- func Trigger(name string, options ...TriggerOption) *eventingv1alpha1.Trigger
- func TriggerV1Beta1(name string, options ...TriggerOptionV1Beta1) *eventingv1beta1.Trigger
- type BrokerOption
- type BrokerV1Beta1Option
- type DeliveryOption
- type MetaResource
- type MetaResourceList
- type PodOption
- type RoleOption
- type SubscriptionOption
- type SubscriptionOptionV1Beta1
- type TriggerOption
- func WithAttributesTriggerFilter(eventSource, eventType string, extensions map[string]interface{}) TriggerOption
- func WithBroker(brokerName string) TriggerOption
- func WithDeprecatedSourceAndTypeTriggerFilter(eventSource, eventType string) TriggerOption
- func WithSubscriberServiceRefForTrigger(name string) TriggerOption
- func WithSubscriberURIForTrigger(uri string) TriggerOption
- type TriggerOptionV1Beta1
- func WithAttributesTriggerFilterV1Beta1(eventSource, eventType string, extensions map[string]interface{}) TriggerOptionV1Beta1
- func WithDependencyAnnotationTriggerV1Beta1(dependencyAnnotation string) TriggerOptionV1Beta1
- func WithSubscriberServiceRefForTriggerV1Beta1(name string) TriggerOptionV1Beta1
Constants ¶
const ( CoreAPIVersion = "v1" EventingAPIVersion = "eventing.knative.dev/v1alpha1" MessagingAPIVersion = "messaging.knative.dev/v1alpha1" FlowsAPIVersion = "flows.knative.dev/v1alpha1" ServingAPIVersion = "serving.knative.dev/v1" )
API versions for the resources.
const ( SubscriptionKind string = "Subscription" BrokerKind string = "Broker" TriggerKind string = "Trigger" )
Kind for eventing resources.
const ( InMemoryChannelKind string = "InMemoryChannel" ChannelKind string = "Channel" SequenceKind string = "Sequence" ParallelKind string = "Parallel" )
Kind for messaging resources.
const ( FlowsSequenceKind string = "Sequence" FlowsParallelKind string = "Parallel" )
Kind for flows resources.
const ( PerfConsumerService = "perf-consumer" PerfAggregatorService = "perf-aggregator" PerfServiceAccount = "perf-eventing" )
const (
KServiceKind string = "Service"
)
Kind for Knative resources.
const (
ServiceKind string = "Service"
)
Kind for core Kubernetes resources.
const SystemNamespace = "knative-eventing"
SystemNamespace is the namespace where Eventing is installed, it's default to be knative-eventing.
Variables ¶
This section is empty.
Functions ¶
func Broker ¶
func Broker(name string, options ...BrokerOption) *eventingv1alpha1.Broker
Broker returns a Broker.
func BrokerV1Beta1 ¶ added in v0.13.0
func BrokerV1Beta1(name string, options ...BrokerV1Beta1Option) *eventingv1beta1.Broker
Broker returns a Broker.
func ClusterRoleBinding ¶
func ClusterRoleBinding(saName, saNamespace, crName, crbName string) *rbacv1.ClusterRoleBinding
ClusterRoleBinding creates a Kubernetes ClusterRoleBinding with the given ServiceAccount name and namespace, ClusterRole name, ClusterRoleBinding name.
func ConfigMapPropagation ¶ added in v0.13.0
func ConfigMapPropagation(name, namespace string) *configsv1alpha1.ConfigMapPropagation
ConfigMapPropagation returns a ConfigMapPropagation.
func Delivery ¶
func Delivery(options ...DeliveryOption) *eventingduckv1beta1.DeliverySpec
Delivery returns a DeliverySpec.
func EventDetailsPod ¶
EventDetailsPod creates a Pod that validates events received and log details about events.
func EventFilteringPod ¶
EventFilteringPod creates a Pod that either filter or send the received CloudEvent
func EventLoggerPod ¶
EventLoggerPod creates a Pod that logs events received.
func EventRecordPod ¶ added in v0.14.0
EventRecordPod creates a Pod that stores received events for test retrieval.
func EventSenderPod ¶
func EventSenderPod(name string, sink string, event *cloudevents.CloudEvent) (*corev1.Pod, error)
EventSenderPod creates a Pod that sends a single event to the given address.
func EventSenderTracingPod ¶
func EventSenderTracingPod(name string, sink string, event *cloudevents.CloudEvent) (*corev1.Pod, error)
EventSenderTracingPod creates a Pod that sends a single event to the given address.
func EventTransformationPod ¶
func EventTransformationPod(name string, event *cloudevents.CloudEvent) *corev1.Pod
EventTransformationPod creates a Pod that transforms events received.
func HelloWorldPod ¶
HelloWorldPod creates a Pod that logs "Hello, World!".
func KServiceRef ¶
func KServiceRef(name string) *corev1.ObjectReference
KServiceRef returns a Knative Service ObjectReference for a given Service name.
func KnativeRefForBroker ¶ added in v0.14.0
func KnativeRefForBroker(name, namespace string) *duckv1.KReference
func KnativeRefForService ¶ added in v0.13.0
func KnativeRefForService(name, namespace string) *duckv1.KReference
func Role ¶
func Role(rName string, options ...RoleOption) *rbacv1.Role
EventWatcherRole creates a Kubernetes Role
func RoleBinding ¶
func RoleBinding(saName, saNamespace, rKind, rName, rbName, rbNamespace string) *rbacv1.RoleBinding
RoleBinding creates a Kubernetes RoleBinding with the given ServiceAccount name and namespace, Role or ClusterRole Kind, name, RoleBinding name and namespace.
func SequenceStepperPod ¶
SequenceStepperPod creates a Pod that can be used as a step in testing Sequence. Note event data used in the test must be BaseData, and this Pod as a Subscriber will receive the event, and return a new event with eventMsgAppender added to data.Message.
func ServiceAccount ¶
func ServiceAccount(name, namespace string) *corev1.ServiceAccount
ServiceAccount creates a Kubernetes ServiceAccount with the given name and namespace.
func ServiceDefaultHTTP ¶
Service creates a Kubernetes Service with the given name, namespace, and selector. Port 8080 is set as the target port.
func ServiceKRef ¶ added in v0.14.0
func ServiceKRef(name string) *v1.KReference
ServiceKRef returns a Service ObjectReference for a given Service name.
func ServiceRef ¶
func ServiceRef(name string) *corev1.ObjectReference
ServiceRef returns a Service ObjectReference for a given Service name.
func Subscription ¶
func Subscription( name, channelName string, channelTypeMeta *metav1.TypeMeta, options ...SubscriptionOption, ) *messagingv1alpha1.Subscription
Subscription returns a Subscription.
func SubscriptionV1Beta1 ¶ added in v0.13.0
func SubscriptionV1Beta1( name, channelName string, channelTypeMeta *metav1.TypeMeta, options ...SubscriptionOptionV1Beta1, ) *messagingv1beta1.Subscription
SubscriptionV1Beta1 returns a v1beta1 Subscription.
func Trigger ¶
func Trigger(name string, options ...TriggerOption) *eventingv1alpha1.Trigger
Trigger returns a Trigger.
func TriggerV1Beta1 ¶ added in v0.13.0
func TriggerV1Beta1(name string, options ...TriggerOptionV1Beta1) *eventingv1beta1.Trigger
TriggerV1Beta1 returns a v1beta1 Trigger.
Types ¶
type BrokerOption ¶
type BrokerOption func(*eventingv1alpha1.Broker)
BrokerOption enables further configuration of a Broker.
func WithBrokerClassForBroker ¶ added in v0.14.0
func WithBrokerClassForBroker(brokerClass string) BrokerOption
WithBrokerClassForBroker returns a function that adds a brokerClass annotation to the given Broker.
func WithChannelTemplateForBroker ¶
func WithChannelTemplateForBroker(channelTypeMeta *metav1.TypeMeta) BrokerOption
WithChannelTemplateForBroker returns a function that adds a ChannelTemplate for the given Broker.
func WithDeliveryForBroker ¶
func WithDeliveryForBroker(delivery *eventingduckv1beta1.DeliverySpec) BrokerOption
WithDeliveryForBroker returns a function that adds a Delivery for the given Broker.
type BrokerV1Beta1Option ¶ added in v0.13.0
type BrokerV1Beta1Option func(*eventingv1beta1.Broker)
BrokerV1Beta1Option enables further configuration of a Broker.
func WithBrokerClassForBrokerV1Beta1 ¶ added in v0.14.0
func WithBrokerClassForBrokerV1Beta1(brokerClass string) BrokerV1Beta1Option
WithBrokerClassForBrokerV1Beta1 returns a function that adds a brokerClass annotation to the given Broker.
func WithChannelTemplateForBrokerV1Beta1 ¶ added in v0.13.0
func WithChannelTemplateForBrokerV1Beta1(config *duckv1.KReference) BrokerV1Beta1Option
WithChannelTemplateForBrokerV1Beta1 returns a function that adds a Config to the given Broker.
type DeliveryOption ¶
type DeliveryOption func(*eventingduckv1beta1.DeliverySpec)
DeliveryOption enables further configuration of DeliverySpec.
func WithDeadLetterSinkForDelivery ¶
func WithDeadLetterSinkForDelivery(name string) DeliveryOption
WithDeadLetterSinkForDelivery returns an options that adds a DeadLetterSink for the given DeliverySpec.
type MetaResource ¶
type MetaResource struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` }
MetaResource includes necessary meta data to retrieve the generic Kubernetes resource.
func NewMetaResource ¶
func NewMetaResource(name, namespace string, typemeta *metav1.TypeMeta) *MetaResource
NewMetaResource returns a MetaResource built from the given name, namespace and typemeta.
type MetaResourceList ¶
MetaResourceList includes necessary meta data to retrieve the generic Kubernetes resource list.
func NewMetaResourceList ¶
func NewMetaResourceList(namespace string, typemeta *metav1.TypeMeta) *MetaResourceList
NewMetaResourceList returns a MetaResourceList built from the given namespace and typemeta.
type PodOption ¶
PodOption enables further configuration of a Pod.
func WithLabelsForPod ¶
WithLabelsForPod returns an option setting the pod labels
type RoleOption ¶
Option enables further configuration of a Role.
func WithRuleForRole ¶
func WithRuleForRole(rule *rbacv1.PolicyRule) RoleOption
WithRuleForRole is a Role Option for adding a rule
type SubscriptionOption ¶
type SubscriptionOption func(*messagingv1alpha1.Subscription)
SubscriptionOption enables further configuration of a Subscription.
func WithDeadLetterSinkForSubscription ¶
func WithDeadLetterSinkForSubscription(name string) SubscriptionOption
WithDeadLetterSinkForSubscription returns an options that adds a DeadLetterSink for the given Subscription.
func WithReplyForSubscription ¶
func WithReplyForSubscription(name string, typemeta *metav1.TypeMeta) SubscriptionOption
WithReplyForSubscription returns an options that adds a ReplyStrategy for the given Subscription.
func WithSubscriberForSubscription ¶
func WithSubscriberForSubscription(name string) SubscriptionOption
WithSubscriberForSubscription returns an option that adds a Subscriber for the given Subscription.
type SubscriptionOptionV1Beta1 ¶ added in v0.13.0
type SubscriptionOptionV1Beta1 func(*messagingv1beta1.Subscription)
SubscriptionOptionV1Beta1 enables further configuration of a Subscription.
func WithSubscriberForSubscriptionV1Beta1 ¶ added in v0.13.0
func WithSubscriberForSubscriptionV1Beta1(name string) SubscriptionOptionV1Beta1
WithSubscriberForSubscriptionV1Beta1 returns an option that adds a Subscriber for the given v1beta1 Subscription.
type TriggerOption ¶
type TriggerOption func(*eventingv1alpha1.Trigger)
TriggerOption enables further configuration of a Trigger.
func WithAttributesTriggerFilter ¶
func WithAttributesTriggerFilter(eventSource, eventType string, extensions map[string]interface{}) TriggerOption
WithAttributesTriggerFilter returns an option that adds a TriggerFilter with Attributes for the given Trigger.
func WithBroker ¶
func WithBroker(brokerName string) TriggerOption
WithBroker returns an option that adds a Broker for the given Trigger.
func WithDeprecatedSourceAndTypeTriggerFilter ¶
func WithDeprecatedSourceAndTypeTriggerFilter(eventSource, eventType string) TriggerOption
WithDeprecatedSourceAndTypeTriggerFilter returns an option that adds a TriggerFilter with DeprecatedSourceAndType for the given Trigger.
func WithSubscriberServiceRefForTrigger ¶
func WithSubscriberServiceRefForTrigger(name string) TriggerOption
WithSubscriberServiceRefForTrigger returns an option that adds a Subscriber Kubernetes Service Ref for the given Trigger.
func WithSubscriberURIForTrigger ¶
func WithSubscriberURIForTrigger(uri string) TriggerOption
WithSubscriberURIForTrigger returns an option that adds a Subscriber URI for the given Trigger.
type TriggerOptionV1Beta1 ¶ added in v0.13.0
type TriggerOptionV1Beta1 func(*eventingv1beta1.Trigger)
TriggerOptionV1Beta1 enables further configuration of a v1beta1 Trigger.
func WithAttributesTriggerFilterV1Beta1 ¶ added in v0.13.0
func WithAttributesTriggerFilterV1Beta1(eventSource, eventType string, extensions map[string]interface{}) TriggerOptionV1Beta1
WithAttributesTriggerFilter returns an option that adds a TriggerFilter with Attributes for the given Trigger.
func WithDependencyAnnotationTriggerV1Beta1 ¶ added in v0.13.1
func WithDependencyAnnotationTriggerV1Beta1(dependencyAnnotation string) TriggerOptionV1Beta1
WithDependencyAnnotationTrigger returns an option that adds a dependency annotation to the given Trigger.
func WithSubscriberServiceRefForTriggerV1Beta1 ¶ added in v0.13.0
func WithSubscriberServiceRefForTriggerV1Beta1(name string) TriggerOptionV1Beta1
WithSubscriberServiceRefForTriggerV1Beta1 returns an option that adds a Subscriber Knative Service Ref for the given Trigger.