resources

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 6, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CloudEventEncodingBinary     = "binary"
	CloudEventEncodingStructured = "structured"
	CloudEventDefaultEncoding    = CloudEventEncodingBinary
	CloudEventDefaultType        = "dev.knative.test.event"
)

CloudEvent related constants.

View Source 
const (
	CoreAPIVersion      = "v1"
	EventingAPIVersion  = "eventing.knative.dev/v1alpha1"
	SourcesAPIVersion   = "sources.eventing.knative.dev/v1alpha1"
	MessagingAPIVersion = "messaging.knative.dev/v1alpha1"
)

API versions for the resources.

View Source 
const (
	SubscriptionKind string = "Subscription"

	BrokerKind  string = "Broker"
	TriggerKind string = "Trigger"
)

Kind for eventing resources.

View Source 
const (
	InMemoryChannelKind string = "InMemoryChannel"
	NatssChannelKind    string = "NatssChannel"

	SequenceKind string = "Sequence"
	ChoiceKind   string = "Choice"
)

Kind for messaging resources.

View Source 
const (
	CronJobSourceKind   string = "CronJobSource"
	ContainerSourceKind string = "ContainerSource"
	ApiServerSourceKind string = "ApiServerSource"
)

Kind for sources resources.

View Source 
const (
	ServiceKind string = "Service"
)

Kind for core Kubernetes resources.

View Source 
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 ApiServerSource 

func ApiServerSource(
	name string,
	resources []sourcesv1alpha1.ApiServerResource,
	mode string,
	options ...ApiServerSourceOption,
) *sourcesv1alpha1.ApiServerSource

ApiServerSource returns an ApiServer EventSource.

func Broker 

func Broker(name string, options ...BrokerOption) *eventingv1alpha1.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 ContainerSource 

func ContainerSource(
	name string,
	options ...ContainerSourceOption,
) *sourcesv1alpha1.ContainerSource

ContainerSource returns a Container EventSource.

func ContainerSourceBasicTemplate 

func ContainerSourceBasicTemplate(
	name,
	namespace,
	imageName string,
	args []string,
) *corev1.PodTemplateSpec

ContainerSourceBasicTemplate returns a basic template that can be used in ContainerSource.

func CronJobSource 

func CronJobSource(
	name,
	schedule,
	data string,
	options ...CronJobSourceOption,
) *sourcesv1alpha1.CronJobSource

CronJobSource returns a CronJob EventSource.

func EventFilteringPod added in v0.8.0 

func EventFilteringPod(name string, filter bool) *corev1.Pod

EventFilteringPod creates a Pod that either filter or send the received CloudEvent

func EventLatencyPod 

func EventLatencyPod(name, sink string, eventCount int) *corev1.Pod

EventLatencyPod creates a Pod that measures events transfer latency.

func EventLoggerPod 

func EventLoggerPod(name string) *corev1.Pod

EventLoggerPod creates a Pod that logs events received.

func EventSenderPod 

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

EventSenderPod creates a Pod that sends a single event to the given address.

func EventTransformationPod 

func EventTransformationPod(name string, event *CloudEvent) *corev1.Pod

EventTransformationPod creates a Pod that transforms events received.

func EventWatcherClusterRole 

func EventWatcherClusterRole(crName string) *rbacv1.ClusterRole

EventWatcherClusterRole creates a Kubernetes ClusterRole that can be used to watch Events.

func HelloWorldPod 

func HelloWorldPod(name string) *corev1.Pod

HelloWorldPod creates a Pod that logs "Hello, World!".

func InMemoryChannel 

func InMemoryChannel(name string) *messagingv1alpha1.InMemoryChannel

InMemoryChannel returns an InMemoryChannel resource.

func NatssChannel 

func NatssChannel(name string) *natssmessagingv1alpha1.NatssChannel

NatssChannel returns a NatssChannel resource.

func RoleBinding 

func RoleBinding(saName, saNamespace, crName, rbName, rbNamespace string) *rbacv1.RoleBinding

RoleBinding creates a Kubernetes RoleBinding with the given ServiceAccount name and namespace, ClusterRole name, RoleBinding name and namespace.

func Sequence added in v0.8.0 

func Sequence(
	name string,
	steps []eventingv1alpha1.SubscriberSpec,
	channelTemplate *eventingduckv1alpha1.ChannelTemplateSpec,
	options ...SequenceOption,
) *messagingv1alpha1.Sequence

Sequence returns a Sequence resource.

func SequenceStepperPod added in v0.8.0 

func SequenceStepperPod(name, eventMsgAppender string) *corev1.Pod

SequenceStepperPod creates a Pod that can be used as a step in testing Sequence. Note event data used in the test must be CloudEventBaseData, and this Pod as a Subscriber will receive the event, and return a new event with eventMsgAppender added to data.Message.

func Service 

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

Service creates a Kubernetes Service with the given name, namespace, and selector. Port 8080 is set as the target port.

func ServiceAccount 

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

ServiceAccount creates a Kubernetes ServiceAccount with the given name and namespace.

func ServiceRef added in v0.8.0 

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,
) *eventingv1alpha1.Subscription

Subscription returns a Subscription.

func Trigger 

func Trigger(name string, options ...TriggerOption) *eventingv1alpha1.Trigger

Trigger returns a Trigger.

Types

type ApiServerSourceOption 

type ApiServerSourceOption func(*sourcesv1alpha1.ApiServerSource)

ApiServerSourceOption enables further configuration of an ApiServerSource.

func WithServiceAccountForApiServerSource 

func WithServiceAccountForApiServerSource(saName string) ApiServerSourceOption

WithServiceAccountForApiServerSource returns an option that adds a ServiceAccount for the given ApiServerSource.

func WithSinkServiceForApiServerSource 

func WithSinkServiceForApiServerSource(name string) ApiServerSourceOption

WithSinkServiceForApiServerSource returns an option that adds a Kubernetes Service sink for the given ApiServerSource.

type BrokerOption 

type BrokerOption func(*eventingv1alpha1.Broker)

BrokerOption enables further configuration of a Broker.

func WithChannelTemplateForBroker 

func WithChannelTemplateForBroker(channelTypeMeta metav1.TypeMeta) BrokerOption

WithChannelTemplateForBroker returns a function that adds a ChannelTemplate for the given Broker.

type CloudEvent 

type CloudEvent struct {
	ID       string
	Type     string
	Source   string
	Data     string // must be in json format
	Encoding string // binary or structured
}

CloudEvent specifies the arguments for a CloudEvent used by the sendevents or transformevents image.

type CloudEventBaseData added in v0.8.0 

type CloudEventBaseData struct {
	Sequence int    `json:"id"`
	Message  string `json:"message"`
}

CloudEventBaseData defines a simple struct that can be used as data of a CloudEvent.

type ContainerSourceOption 

type ContainerSourceOption func(*sourcesv1alpha1.ContainerSource)

ContainerSourceOption enables further configuration of a ContainerSource.

func WithSinkServiceForContainerSource 

func WithSinkServiceForContainerSource(name string) ContainerSourceOption

WithSinkServiceForContainerSource returns an option that adds a Kubernetes Service sink for the given ContainerSource.

func WithTemplateForContainerSource 

func WithTemplateForContainerSource(template *corev1.PodTemplateSpec) ContainerSourceOption

WithTemplateForContainerSource returns an option that adds a template for the given ContainerSource.

type CronJobSourceOption 

type CronJobSourceOption func(*sourcesv1alpha1.CronJobSource)

CronJobSourceOption enables further configuration of a CronJobSource.

func WithServiceAccountForCronJobSource 

func WithServiceAccountForCronJobSource(saName string) CronJobSourceOption

WithServiceAccountForCronJobSource returns an option that adds a ServiceAccount for the given CronJobSource.

func WithSinkServiceForCronJobSource 

func WithSinkServiceForCronJobSource(name string) CronJobSourceOption

WithSinkServiceForCronJobSource returns an option that adds a Kubernetes Service sink for the given CronJobSource.

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 

type MetaResourceList struct {
	metav1.TypeMeta `json:",inline"`
	Namespace       string
}

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 SequenceOption added in v0.8.0 

type SequenceOption func(*messagingv1alpha1.Sequence)

SequenceOption enables further configuration of a Sequence.

func WithReplyForSequence added in v0.8.0 

func WithReplyForSequence(name string, typemeta *metav1.TypeMeta) SequenceOption

WithReplyForSequence returns an option that adds a Reply for the given Sequence.

type SubscriptionOption 

type SubscriptionOption func(*eventingv1alpha1.Subscription)

SubscriptionOption enables further configuration of a Subscription.

func WithReplyForSubscription added in v0.8.0 

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 TriggerOption 

type TriggerOption func(*eventingv1alpha1.Trigger)

TriggerOption enables further configuration of a Trigger.

func WithBroker 

func WithBroker(brokerName string) TriggerOption

WithBroker returns an option that adds a Broker for the given Trigger.

func WithSubscriberRefForTrigger 

func WithSubscriberRefForTrigger(name string) TriggerOption

WithSubscriberRefForTrigger returns an option that adds a Subscriber 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.

func WithTriggerFilter 

func WithTriggerFilter(eventSource, eventType string) TriggerOption

WithTriggerFilter returns an option that adds a TriggerFilter for the given Trigger.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.