k8s

package
v0.0.27 Latest Latest
Warning

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

Go to latest
Published: Sep 27, 2023 License: Apache-2.0 Imports: 26 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 AsInferenceDeployment

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

func AsResourceList

func AsResourceList(resources v1.ResourceList) types.ResourceList

func GetKubernetesVersion added in v0.0.24

func GetKubernetesVersion(client kubernetes.Interface) (*version.Info, error)

func InstanceFromPod

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

func MakeBuild

func MakeBuild(req types.Build, inference *v2alpha1.Inference, builderImage, buildkitdAddr, buildctlBin, secret string) (*batchv1.Job, error)

func MakeImageCache added in v0.0.24

func MakeImageCache(req types.ImageCache, inference *modelzetes.Inference) *kubefledged.ImageCache

func MakeLabelSelector

func MakeLabelSelector(name string) map[string]string

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