k8s

package
v0.0.0-...-37f5ccb Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AsBuild

func AsBuild(job v1.Job) (types.Build, error)

func AsEnvVar

func AsEnvVar(envs []v1.EnvVar) map[string]string

func AsInference

func AsInference(item appsv1.Deployment) *types.InferenceDeployment

AsInference reads a Deployment object into an InferenceDeployment, parsing the Deployment and Container spec into a simplified summary of the Inference.

func AsInferenceDeployment

func AsInferenceDeployment(inf *v2alpha1.Inference, item *appsv1.Deployment) *types.InferenceDeployment

func AsResourceList

func AsResourceList(resources v1.ResourceList) types.ResourceList

func AsResources

func AsResources(
	requirements v1.ResourceRequirements) *types.ResourceRequirements

func InstanceFromPod

func InstanceFromPod(pod v1.Pod) *types.InferenceDeploymentInstance

func MakeBuild

func MakeBuild(req types.Build, builderImage, buildkitdAddr, buildctlBin, register, registerToken string) (*batchv1.Job, error)

func MakeLabelSelector

func MakeLabelSelector(name string) map[string]string

func ReadFunctionSecretsSpec

func ReadFunctionSecretsSpec(item appsv1.Deployment) []string

ReadFunctionSecretsSpec parses the name of the required function secrets. This is the inverse of ConfigureSecrets.

Types

type EndpointResolver

type EndpointResolver struct {
	EndpointLister corelister.EndpointsLister
}

func (EndpointResolver) Close

func (e EndpointResolver) Close(url.URL)

func (EndpointResolver) Resolve

func (e EndpointResolver) Resolve(namespace, name string) (url.URL, error)

type PortForwardingResolver

type PortForwardingResolver struct {
	// contains filtered or unexported fields
}

func (*PortForwardingResolver) Close

func (e *PortForwardingResolver) Close(url url.URL)

func (*PortForwardingResolver) Resolve

func (e *PortForwardingResolver) Resolve(namespace, name string) (url.URL, error)

type Resolver

type Resolver interface {
	Resolve(namespace, name string) (url.URL, error)
	Close(url url.URL)
}

func NewEndpointResolver

func NewEndpointResolver(lister corelister.EndpointsLister) Resolver

func NewPortForwardingResolver

func NewPortForwardingResolver(cfg *rest.Config, cli kubernetes.Interface) Resolver

Jump to

Keyboard shortcuts

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