sender

Documentation

Index

• Constants
• func EnableIncrementalId() func(*corev1.Pod)
• func EnableTracing() func(*corev1.Pod)
• func EventSenderPod(imageName string, name string, sink string, event cloudevents.Event, ...) (*corev1.Pod, error)
• func MatchInnerEvent(matchers ...cetest.EventMatcher) cetest.EventMatcher
• func MatchStatusCode(status int) cetest.EventMatcher
• func NewSenderEvent(id string, source string, event *cloudevents.Event, result *cehttp.Result) cloudevents.Event
• func NewSenderEventFromRaw(id string, source string, response *http.Response) cloudevents.Event
• func RequestSenderPod(imageName string, name string, sink string, headers map[string]string, ...) (*corev1.Pod, error)
• func WithAdditionalHeaders(headers map[string]string) func(*corev1.Pod)
• func WithEncoding(encoding cloudevents.Encoding) func(*corev1.Pod)
• func WithMethod(method string) func(*corev1.Pod)
• func WithResponseSink(responseSink string) func(*corev1.Pod)

Constants

const (
	EventType                   = "sender.test.knative.dev"
	ResponseStatusCodeExtension = "responsestatuscode"
)

Functions

func EnableIncrementalId

func EnableIncrementalId() func(*corev1.Pod)

EnableIncrementalId creates a new incremental id for each event sent from the sender pod. Supported only by event-sender Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send events

func EnableTracing

func EnableTracing() func(*corev1.Pod)

EnableTracing enables tracing in sender pod Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send events

func EventSenderPod

func EventSenderPod(imageName string, name string, sink string, event cloudevents.Event, options ...func(*corev1.Pod)) (*corev1.Pod, error)

EventSenderPod creates a Pod that sends events to the given address. Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send events

func MatchInnerEvent

func MatchInnerEvent(matchers ...cetest.EventMatcher) cetest.EventMatcher

MatchInnerEvent matches the response event of the sent event

func MatchStatusCode

func MatchStatusCode(status int) cetest.EventMatcher

MatchStatusCode matches the response status code of the sent event

func NewSenderEvent

func NewSenderEvent(id string, source string, event *cloudevents.Event, result *cehttp.Result) cloudevents.Event

NewSenderEvent creates a new sender event assertable with the matchers provided in this package

func NewSenderEventFromRaw

func NewSenderEventFromRaw(id string, source string, response *http.Response) cloudevents.Event

func RequestSenderPod

func RequestSenderPod(imageName string, name string, sink string, headers map[string]string, body string, options ...func(*corev1.Pod)) (*corev1.Pod, error)

EventSenderPod creates a Pod that sends http requests to the given address. Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send requests

func WithAdditionalHeaders

func WithAdditionalHeaders(headers map[string]string) func(*corev1.Pod)

WithEncoding forces the encoding of the event to send from the sender pod. Supported only by event-sender Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send events

func WithEncoding

func WithEncoding(encoding cloudevents.Encoding) func(*corev1.Pod)

WithEncoding forces the encoding of the event to send from the sender pod. Supported only by event-sender Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send events

func WithMethod

func WithMethod(method string) func(*corev1.Pod)

WithMethod configures the method used to send the http request. Supported only by request-sender Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send requests

func WithResponseSink

func WithResponseSink(responseSink string) func(*corev1.Pod)

WithResponseSink sends the response information as CloudEvent to another sink Deprecated: Now you should use recordevents.DeployEventSenderOrFail to send events and start an EventInfoStore on it to assert the responses