k8s

Documentation

Index

• Variables
• type Clients
  • func CreateKubeClient(props *event.Properties) (Clients, error)
• type JobRunner
  • func CreateJobRunner(kube Clients) JobRunner
• type ReferenceAddressResolver
  • func CreateAddressResolver(kube Clients) ReferenceAddressResolver

Variables

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")
)

var ErrNoKubernetesConnection = errors.New("no Kubernetes connection")

ErrNoKubernetesConnection if can't connect to Kube API server.

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(*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.