sender

package
v0.43.3 Latest Latest
Warning

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

Go to latest
Published: Nov 21, 2024 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Index

Constants

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

Variables

This section is empty.

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

Types

This section is empty.

Jump to

Keyboard shortcuts

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