k8s

package
v0.41.0 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrInvalidReference if given reference is invalid.
	ErrInvalidReference = errors.New("reference is invalid")

	// ErrNotFound if given reference do not point to any resource.
	ErrNotFound = errors.New("resource not found")

	// ErrNotAddressable if found resource isn't addressable.
	ErrNotAddressable = errors.New("resource isn't addressable")

	// ErrMoreThenOneFound if more then one resource has been found.
	ErrMoreThenOneFound = errors.New("more then one resource has been found")

	// ErrUnexcpected if something unexpected actually has happened.
	ErrUnexcpected = errors.New("something unexpected actually has happened")

	// ErrICSenderJobFailed if the ICS job runner has failed.
	ErrICSenderJobFailed = errors.New("the ICS job runner has failed")
)
View Source
var ErrNoKubernetesConnection = errors.New("no Kubernetes connection")

ErrNoKubernetesConnection if can't connect to Kube API server.

Functions

This section is empty.

Types

type Clients

type Clients interface {
	Namespace() string
	Typed() kubernetes.Interface
	Dynamic() dynamic.Interface
	Context() context.Context
	Serving() servingv1.ServingV1Interface
	Eventing() eventingv1.EventingV1Interface
	Messaging() messagingv1.MessagingV1Interface
}

Clients holds available Kubernetes clients.

func CreateKubeClient

func CreateKubeClient(props *event.Properties) (Clients, error)

CreateKubeClient creates kubernetes.Interface.

type JobRunner

type JobRunner interface {
	Run(job *batchv1.Job) error
}

JobRunner will launch a Job and monitor it for completion.

func CreateJobRunner

func CreateJobRunner(kube Clients) JobRunner

CreateJobRunner will create a JobRunner, or return an error.

type ReferenceAddressResolver

type ReferenceAddressResolver interface {
	ResolveAddress(ref *tracker.Reference, uri *apis.URL) (*url.URL, error)
}

ReferenceAddressResolver will resolve the tracker.Reference to an url.URL, or return an error.

func CreateAddressResolver

func CreateAddressResolver(kube Clients) ReferenceAddressResolver

CreateAddressResolver will create ReferenceAddressResolver, or return an error.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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