manager

package
v1.12.0 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2018 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package manager implements kubelet runtime API

Index

Constants

View Source 
const (

	// OSContainerAnnotationKey specifying this pod will run by OS container runtime.
	OSContainerAnnotationKey = "runtime.frakti.alpha.kubernetes.io/OSContainer"
	// OSContainerAnnotationTrue specifying this pod will run by OS container runtime.
	OSContainerAnnotationTrue = "true"
	// UnikernelAnnotationKey specifying this pod will run by unikernel runtime.
	UnikernelAnnotationKey = "runtime.frakti.alpha.kubernetes.io/Unikernel"
	// UnikernelAnnotationTrue specifying this pod will run by unikernel runtime.
	UnikernelAnnotationTrue = "true"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type FraktiManager 

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

FraktiManager serves the kubelet runtime gRPC api which will be consumed by kubelet

func NewFraktiManager 

func NewFraktiManager(
	hyperRuntimeService runtime.RuntimeService,
	hyperImageService runtime.ImageManagerService,
	streamingServer streaming.Server,
	privilegedRuntimeService runtime.RuntimeService,
	privilegedImageService runtime.ImageManagerService,
	unikernelRuntimeService runtime.RuntimeService,
	unikernelImageService runtime.ImageManagerService,
) (*FraktiManager, error)

NewFraktiManager creates a new FraktiManager

func (*FraktiManager) Attach 

func (s *FraktiManager) Attach(ctx context.Context, req *kubeapi.AttachRequest) (*kubeapi.AttachResponse, error)

Attach prepares a streaming endpoint to attach to a running container.

func (*FraktiManager) ContainerStats 

func (s *FraktiManager) ContainerStats(ctx context.Context, req *kubeapi.ContainerStatsRequest) (*kubeapi.ContainerStatsResponse, error)

ContainerStats returns information of the container filesystem.

func (*FraktiManager) ContainerStatus 

func (s *FraktiManager) ContainerStatus(ctx context.Context, req *kubeapi.ContainerStatusRequest) (*kubeapi.ContainerStatusResponse, error)

ContainerStatus returns the container status.

func (*FraktiManager) CreateContainer 

func (s *FraktiManager) CreateContainer(ctx context.Context, req *kubeapi.CreateContainerRequest) (*kubeapi.CreateContainerResponse, error)

CreateContainer creates a new container in specified PodSandbox

func (*FraktiManager) Exec 

func (s *FraktiManager) Exec(ctx context.Context, req *kubeapi.ExecRequest) (*kubeapi.ExecResponse, error)

Exec prepares a streaming endpoint to execute a command in the container.

func (*FraktiManager) ExecSync 

func (s *FraktiManager) ExecSync(ctx context.Context, req *kubeapi.ExecSyncRequest) (*kubeapi.ExecSyncResponse, error)

ExecSync runs a command in a container synchronously.

func (*FraktiManager) ImageFsInfo 

func (s *FraktiManager) ImageFsInfo(ctx context.Context, req *kubeapi.ImageFsInfoRequest) (*kubeapi.ImageFsInfoResponse, error)

ImageFsInfo returns information of the filesystem that is used to store images.

func (*FraktiManager) ImageStatus 

func (s *FraktiManager) ImageStatus(ctx context.Context, req *kubeapi.ImageStatusRequest) (*kubeapi.ImageStatusResponse, error)

ImageStatus returns the status of the image.

func (*FraktiManager) ListContainerStats 

func (s *FraktiManager) ListContainerStats(ctx context.Context, req *kubeapi.ListContainerStatsRequest) (*kubeapi.ListContainerStatsResponse, error)

ListContainerStats returns stats of all running containers

func (*FraktiManager) ListContainers 

func (s *FraktiManager) ListContainers(ctx context.Context, req *kubeapi.ListContainersRequest) (*kubeapi.ListContainersResponse, error)

ListContainers lists all containers by filters.

func (*FraktiManager) ListImages 

func (s *FraktiManager) ListImages(ctx context.Context, req *kubeapi.ListImagesRequest) (*kubeapi.ListImagesResponse, error)

ListImages lists existing images.

func (*FraktiManager) ListPodSandbox 

func (s *FraktiManager) ListPodSandbox(ctx context.Context, req *kubeapi.ListPodSandboxRequest) (*kubeapi.ListPodSandboxResponse, error)

ListPodSandbox returns a list of SandBox.

func (*FraktiManager) PodSandboxStatus 

func (s *FraktiManager) PodSandboxStatus(ctx context.Context, req *kubeapi.PodSandboxStatusRequest) (*kubeapi.PodSandboxStatusResponse, error)

PodSandboxStatus returns the Status of the PodSandbox.

func (*FraktiManager) PortForward 

func (s *FraktiManager) PortForward(ctx context.Context, req *kubeapi.PortForwardRequest) (*kubeapi.PortForwardResponse, error)

PortForward prepares a streaming endpoint to forward ports from a PodSandbox.

func (*FraktiManager) PullImage 

func (s *FraktiManager) PullImage(ctx context.Context, req *kubeapi.PullImageRequest) (*kubeapi.PullImageResponse, error)

PullImage pulls a image with authentication config.

func (*FraktiManager) RemoveContainer 

func (s *FraktiManager) RemoveContainer(ctx context.Context, req *kubeapi.RemoveContainerRequest) (*kubeapi.RemoveContainerResponse, error)

RemoveContainer removes the container.

func (*FraktiManager) RemoveImage 

func (s *FraktiManager) RemoveImage(ctx context.Context, req *kubeapi.RemoveImageRequest) (*kubeapi.RemoveImageResponse, error)

RemoveImage removes the image.

func (*FraktiManager) RemovePodSandbox 

func (s *FraktiManager) RemovePodSandbox(ctx context.Context, req *kubeapi.RemovePodSandboxRequest) (*kubeapi.RemovePodSandboxResponse, error)

RemovePodSandbox deletes the sandbox.

func (*FraktiManager) ReopenContainerLog added in v1.10.0 

func (s *FraktiManager) ReopenContainerLog(ctx context.Context, req *kubeapi.ReopenContainerLogRequest) (*kubeapi.ReopenContainerLogResponse, error)

func (*FraktiManager) RunPodSandbox 

func (s *FraktiManager) RunPodSandbox(ctx context.Context, req *kubeapi.RunPodSandboxRequest) (*kubeapi.RunPodSandboxResponse, error)

RunPodSandbox creates and start a hyper Pod.

func (*FraktiManager) Serve 

func (s *FraktiManager) Serve(addr string) error

Serve starts gRPC server at unix://addr

func (*FraktiManager) StartContainer 

func (s *FraktiManager) StartContainer(ctx context.Context, req *kubeapi.StartContainerRequest) (*kubeapi.StartContainerResponse, error)

StartContainer starts the container.

func (*FraktiManager) Status 

func (s *FraktiManager) Status(ctx context.Context, req *kubeapi.StatusRequest) (*kubeapi.StatusResponse, error)

Status returns the status of the runtime.

func (*FraktiManager) StopContainer 

func (s *FraktiManager) StopContainer(ctx context.Context, req *kubeapi.StopContainerRequest) (*kubeapi.StopContainerResponse, error)

StopContainer stops a running container with a grace period (i.e. timeout).

func (*FraktiManager) StopPodSandbox 

func (s *FraktiManager) StopPodSandbox(ctx context.Context, req *kubeapi.StopPodSandboxRequest) (*kubeapi.StopPodSandboxResponse, error)

StopPodSandbox stops the sandbox.

func (*FraktiManager) UpdateContainerResources 

func (s *FraktiManager) UpdateContainerResources(
	ctx context.Context,
	req *kubeapi.UpdateContainerResourcesRequest,
) (*kubeapi.UpdateContainerResourcesResponse, error)

UpdateContainerResources updates ContainerConfig of the container

func (*FraktiManager) UpdateRuntimeConfig 

func (s *FraktiManager) UpdateRuntimeConfig(ctx context.Context, req *kubeapi.UpdateRuntimeConfigRequest) (*kubeapi.UpdateRuntimeConfigResponse, error)

UpdateRuntimeConfig updates runtime configuration if specified

func (*FraktiManager) Version 

func (s *FraktiManager) Version(ctx context.Context, req *kubeapi.VersionRequest) (*kubeapi.VersionResponse, error)

Version returns the runtime name, runtime version and runtime API version.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.