AddEventType adds a new type to the subscription.

AddSource adds the source value to the subscription.

EventMeshAuthResponseSuccess writes an oauth2 authentication Response to the writer for the happy-path.

EventMeshCreateSuccess writes a Response to the writer for the happy-path of creating an EventMesh subscription.

EventMeshDeleteResponseSuccess writes a Response to the writer for the happy-path of deleting an EventMesh subscription.

EventMeshGetSuccess writes a Response to the writer for the happy-path of getting an EventMesh subscription.

EventMeshListSuccess writes a Response to the writer for the happy-path of listing a EventMesh subscription.

GetFreePort determines a free port on the host.

GetRestAPIObject gets the name of the involved object in a REST url.

GetSubscriptionResponse checks if a subscription exists in the mock.

IsEventMeshSubscriptionCreate determines if the http request is creating an EventMesh subscription.

IsEventMeshSubscriptionDelete determines if the http request is deleting a EventMesh subscription.

NewAPIRule returns a valid APIRule.

NewFakeSubscriptionClient returns a fake dynamic subscription client.

NewSafeRequests returns a new instance of SafeRequests.

NewSafeSubscriptions returns a new instance of SafeSubscriptions.

NewSubscriber creates a simple test Subscriber with http Endpoints to received, store end answer event data.

RunNatsServerOnPort will run a server with the given server options.

SetSink sets the subscription's sink to a valid sink created from svcNameSpace and svcName.

SetupSchemeOrDie add a scheme to eventing API schemes.

ShutDownNATSServer shuts down test NATS server and waits until shutdown is complete.

StartDefaultJetStreamServer will run a server on the given port.

SubscriptionGroupVersionResource returns the GVR of a subscription.

ToSubscription converts an unstructured subscription into a typed one.

ToUnstructuredAPIRule converts an APIRule object into a unstructured APIRule.

UpdateSubscriptionResponse updates the webhook auth of subscription in the mock.

UpdateSubscriptionStateResponse updates the EventMesh subscription status in the mock.

ValidSinkURL converts a namespace and service name to a valid sink url.

ValidSinkURLWithPath converts a namespace and service name to a valid sink url with path.

WithBackend is a SubscriptionOpt that sets the status with the Backend value.

WithCleanEventSourceAndType is a SubscriptionOpt that initializes subscription with a not clean event source and type.

WithCleanEventTypeOld is a SubscriptionOpt that initializes subscription with a not clean event type from v1alpha2.

WithCloudEventServeMux will make the Subscriber store all CloudEvent-related date ("ce-..." header etc) at its "/store" e Endpoint instead of its default behaviour of only storing the http.Request.Body data.

WithEventSource is a SubscriptionOpt for creating a Subscription with a specific event source,.

WithEventType is a SubscriptionOpt for creating a Subscription with a specific event type, that itself gets created from the passed eventType.

WithExactTypeMatching is a SubscriptionOpt for creating a Subscription with an exact type matching.

WithMaxInFlight is a SubscriptionOpt that sets the status with the maxInFlightMessages int value.

WithMaxInFlightMessages is a SubscriptionOpt that sets the status with the maxInFlightMessages string value.

WithNonZeroDeletionTimestamp sets the deletion timestamp of the subscription to Now().

WithNotCleanEventSourceAndType is a SubscriptionOpt that initializes subscription with a not clean event source and type.

WithNotCleanType initializes subscription with a not clean event-type A not clean event-type means it contains none-alphanumeric characters.

WithSinkURL is a SubscriptionOpt for creating a subscription with a specific sink.

WithSinkURLFromSvc sets a kubernetes service as the sink.

WithSourceAndType is a SubscriptionOpt for creating a Subscription with a specific eventSource and eventType.

WithStandardTypeMatching is a SubscriptionOpt for creating a Subscription with a standard type matching.

WithTypeMatching is a SubscriptionOpt for creating a Subscription with a specific type matching,.

WithTypeMatchingExact is a SubscriptionOpt that initializes the subscription with type matching to exact.

WithTypeMatchingStandard is a SubscriptionOpt that initializes the subscription with type matching to standard.

WithValidSink is a SubscriptionOpt for creating a subscription with a valid sink that itself gets created from the svcNamespace and the svcName.

three segments.

four segments.

EventMeshMock implements a programmable mock for EventMesh.

SafeRequests encapsulates Requests to provide mutual exclusion.

SafeSubscriptions encapsulates Subscriptions to provide mutual exclusion.