jobsink

package
v0.44.0 Latest Latest
Warning

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

Go to latest
Published: Jan 20, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

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

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 GoesReadySimple added in v0.43.0

func GoesReadySimple(name string) *feature.Feature

GoesReadySimple returns a feature that will create a JobSink with a simple sink and confirm it becomes ready with an address.

func Install

func Install(name string, opts ...manifest.CfgFn) feature.StepFn

Install will create a resource, augmented with the config fn options.

func IsAddressable

func IsAddressable(name string, timings ...time.Duration) feature.StepFn

IsAddressable tests to see if a JobSink becomes addressable within the time given.

func IsNotReady

func IsNotReady(name string, timing ...time.Duration) feature.StepFn

IsNotReady tests to see if a JobSink becomes NotReady within the time given.

func IsReady

func IsReady(name string, timing ...time.Duration) feature.StepFn

IsReady tests to see if a JobSink becomes ready 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

func WithAnnotations(annotations map[string]interface{}) manifest.CfgFn

WithAnnotations adds annotations to the JobSink.

func WithForwarderJob

func WithForwarderJob(sink string, options ...func(*batchv1.Job)) manifest.CfgFn

func WithJob

func WithJob(job batchv1.Job) manifest.CfgFn

Types

This section is empty.

Jump to

Keyboard shortcuts

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