Documentation ¶
Overview ¶
Example (Full) ¶
Output: apiVersion: sinks.knative.dev/v1alpha1 kind: JobSink metadata: name: foo namespace: bar spec: job: metadata: creationTimestamp: null spec: parallelism: 1 template: metadata: creationTimestamp: null spec: containers: - name: job-c resources: {} status: {}
Example (Min) ¶
Output: apiVersion: sinks.knative.dev/v1alpha1 kind: JobSink metadata: name: foo namespace: bar spec:
Index ¶
- func Address(ctx context.Context, name string, timings ...time.Duration) (*duckv1.Addressable, error)
- func AsDestinationRef(name string) *duckv1.Destination
- func AsKReference(name string) *duckv1.KReference
- func GVR() schema.GroupVersionResource
- func GoesReadySimple(name string) *feature.Feature
- func Install(name string, opts ...manifest.CfgFn) feature.StepFn
- func IsAddressable(name string, timings ...time.Duration) feature.StepFn
- func IsNotReady(name string, timing ...time.Duration) feature.StepFn
- func IsReady(name string, timing ...time.Duration) feature.StepFn
- func ValidateAddress(name string, validate addressable.ValidateAddressFn, timings ...time.Duration) feature.StepFn
- func WithAnnotations(annotations map[string]interface{}) manifest.CfgFn
- func WithForwarderJob(sink string, options ...func(*batchv1.Job)) manifest.CfgFn
- func WithJob(job batchv1.Job) manifest.CfgFn
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Address ¶
func Address(ctx context.Context, name string, timings ...time.Duration) (*duckv1.Addressable, error)
Address returns a JobSink's address.
func AsDestinationRef ¶
func AsDestinationRef(name string) *duckv1.Destination
func AsKReference ¶
func AsKReference(name string) *duckv1.KReference
AsKReference returns a KReference for a JobSink without namespace.
func GVR ¶
func GVR() schema.GroupVersionResource
func GoesReadySimple ¶ added in v0.43.0
GoesReadySimple returns a feature that will create a JobSink with a simple sink and confirm it becomes ready with an address.
func IsAddressable ¶
IsAddressable tests to see if a JobSink becomes addressable within the time given.
func IsNotReady ¶
IsNotReady tests to see if a JobSink becomes NotReady within the time given.
func ValidateAddress ¶
func ValidateAddress(name string, validate addressable.ValidateAddressFn, timings ...time.Duration) feature.StepFn
ValidateAddress validates the address retured by Address
func WithAnnotations ¶
WithAnnotations adds annotations to the JobSink.
func WithForwarderJob ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.