k8s

Documentation

Index

• func AsBuild(job v1.Job) (types.Build, error)
• func AsEnvVar(envs []v1.EnvVar) map[string]string
• func AsInference(item appsv1.Deployment) *types.InferenceDeployment
• func AsInferenceDeployment(inf *v2alpha1.Inference, item *appsv1.Deployment) *types.InferenceDeployment
• func AsResourceList(resources v1.ResourceList) types.ResourceList
• func AsResources(requirements v1.ResourceRequirements) *types.ResourceRequirements
• func InstanceFromPod(pod v1.Pod) *types.InferenceDeploymentInstance
• func MakeBuild(req types.Build, ...) (*batchv1.Job, error)
• func MakeLabelSelector(name string) map[string]string
• func ReadFunctionSecretsSpec(item appsv1.Deployment) []string
• type EndpointResolver
  • func (e EndpointResolver) Close(url.URL)
  • func (e EndpointResolver) Resolve(namespace, name string) (url.URL, error)
• type PortForwardingResolver
  • func (e *PortForwardingResolver) Close(url url.URL)
  • func (e *PortForwardingResolver) Resolve(namespace, name string) (url.URL, error)
• type Resolver
  • func NewEndpointResolver(lister corelister.EndpointsLister) Resolver
  • func NewPortForwardingResolver(cfg *rest.Config, cli kubernetes.Interface) Resolver

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