wasmercri

package module
v0.0.0-...-1e97fd4 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2021 License: MIT Imports: 19 Imported by: 0

README

wasmer-cri

Implementation of WebAssembly Runtime(wasmer-go) CRI for kubelet.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Network string // unix
	Address string // /tmp/wasmshim.sock
}

Config of service

type ContainerStore 

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

ContainerStore store for pod sandbox

func NewContainerStore 

func NewContainerStore() *ContainerStore

NewContainerStore create pod-sandbox store

func (*ContainerStore) Add 

func (s *ContainerStore) Add(sb *pb.Container) error

Add a sandbox into the store.

func (*ContainerStore) Delete 

func (s *ContainerStore) Delete(id string)

Delete deletes the sandbox with specified id.

func (*ContainerStore) Get 

func (s *ContainerStore) Get(id string) (pb.Container, error)

Get returns the sandbox with specified id.

func (*ContainerStore) List 

func (s *ContainerStore) List() []pb.Container

List lists all sandboxes.

type ImageServer 

type ImageServer struct {
	pb.UnimplementedImageServiceServer
}

ImageServer is used to implement images

func NewImageServer 

func NewImageServer() (*ImageServer, error)

NewImageServer create image server

func (*ImageServer) ImageFsInfo 

func (s *ImageServer) ImageFsInfo(ctx context.Context, in *pb.ImageFsInfoRequest) (*pb.ImageFsInfoResponse, error)

ImageFsInfo get image file-system info

func (*ImageServer) ImageStatus 

func (s *ImageServer) ImageStatus(ctx context.Context, in *pb.ImageStatusRequest) (*pb.ImageStatusResponse, error)

ImageStatus show status of image

func (*ImageServer) ListImages 

func (s *ImageServer) ListImages(ctx context.Context, in *pb.ListImagesRequest) (*pb.ListImagesResponse, error)

ListImages list images

func (*ImageServer) PullImage 

func (s *ImageServer) PullImage(ctx context.Context, in *pb.PullImageRequest) (*pb.PullImageResponse, error)

PullImage pull image

func (*ImageServer) RemoveImage 

func (s *ImageServer) RemoveImage(ctx context.Context, in *pb.RemoveImageRequest) (*pb.RemoveImageResponse, error)

RemoveImage remove image

type ImageStore 

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

ImageStore store for images

func NewImageStore 

func NewImageStore() *ImageStore

NewImageStore creates an image store.

func (*ImageStore) Get 

func (s *ImageStore) Get(id string) (*pb.Image, error)

Get get image by id

type PodSandboxStore 

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

PodSandboxStore store for pod sandbox

func NewPodSandboxStore 

func NewPodSandboxStore() *PodSandboxStore

NewPodSandboxStore create pod-sandbox store

func (*PodSandboxStore) Add 

func (s *PodSandboxStore) Add(sb *pb.PodSandbox) error

Add a sandbox into the store.

func (*PodSandboxStore) Delete 

func (s *PodSandboxStore) Delete(id string)

Delete deletes the sandbox with specified id.

func (*PodSandboxStore) Get 

func (s *PodSandboxStore) Get(id string) (pb.PodSandbox, error)

Get returns the sandbox with specified id.

func (*PodSandboxStore) List 

func (s *PodSandboxStore) List() []pb.PodSandbox

List lists all sandboxes.

type RuntimeServer 

type RuntimeServer struct {
	pb.UnimplementedRuntimeServiceServer
	// contains filtered or unexported fields
}

RuntimeServer is used to implement images

func NewRuntimeServer 

func NewRuntimeServer() (*RuntimeServer, error)

NewRuntimeServer register image server

func (*RuntimeServer) Attach 

func (s *RuntimeServer) Attach(ctx context.Context, req *pb.AttachRequest) (*pb.AttachResponse, error)

Attach container

func (*RuntimeServer) ContainerStats 

func (s *RuntimeServer) ContainerStats(ctx context.Context, req *pb.ContainerStatsRequest) (*pb.ContainerStatsResponse, error)

ContainerStats container

func (*RuntimeServer) ContainerStatus 

func (s *RuntimeServer) ContainerStatus(ctx context.Context, in *pb.ContainerStatusRequest) (*pb.ContainerStatusResponse, error)

ContainerStatus show container status

func (*RuntimeServer) CreateContainer 

func (s *RuntimeServer) CreateContainer(ctx context.Context, in *pb.CreateContainerRequest) (*pb.CreateContainerResponse, error)

CreateContainer create container

func (*RuntimeServer) Exec 

func (s *RuntimeServer) Exec(ctx context.Context, req *pb.ExecRequest) (*pb.ExecResponse, error)

Exec container

func (*RuntimeServer) ExecSync 

func (s *RuntimeServer) ExecSync(ctx context.Context, req *pb.ExecSyncRequest) (*pb.ExecSyncResponse, error)

ExecSync container

func (*RuntimeServer) ListContainerStats 

func (s *RuntimeServer) ListContainerStats(ctx context.Context, req *pb.ListContainerStatsRequest) (*pb.ListContainerStatsResponse, error)

ListContainerStats container

func (*RuntimeServer) ListContainers 

func (s *RuntimeServer) ListContainers(ctx context.Context, in *pb.ListContainersRequest) (*pb.ListContainersResponse, error)

ListContainers list containers

func (*RuntimeServer) ListPodSandbox 

func (s *RuntimeServer) ListPodSandbox(ctx context.Context, in *pb.ListPodSandboxRequest) (_ *pb.ListPodSandboxResponse, _ error)

ListPodSandbox pod

func (*RuntimeServer) PodSandboxStatus 

func (s *RuntimeServer) PodSandboxStatus(ctx context.Context, in *pb.PodSandboxStatusRequest) (*pb.PodSandboxStatusResponse, error)

PodSandboxStatus pod

func (*RuntimeServer) PortForward 

func (s *RuntimeServer) PortForward(ctx context.Context, req *pb.PortForwardRequest) (*pb.PortForwardResponse, error)

PortForward container

func (*RuntimeServer) RemoveContainer 

func (s *RuntimeServer) RemoveContainer(ctx context.Context, in *pb.RemoveContainerRequest) (*pb.RemoveContainerResponse, error)

RemoveContainer remove container

func (*RuntimeServer) RemovePodSandbox 

func (s *RuntimeServer) RemovePodSandbox(ctx context.Context, in *pb.RemovePodSandboxRequest) (*pb.RemovePodSandboxResponse, error)

RemovePodSandbox pod

func (*RuntimeServer) ReopenContainerLog 

func (s *RuntimeServer) ReopenContainerLog(ctx context.Context, req *pb.ReopenContainerLogRequest) (*pb.ReopenContainerLogResponse, error)

ReopenContainerLog container

func (*RuntimeServer) RunPodSandbox 

func (s *RuntimeServer) RunPodSandbox(ctx context.Context, in *pb.RunPodSandboxRequest) (_ *pb.RunPodSandboxResponse, retErr error)

RunPodSandbox run pod sandbox

func (*RuntimeServer) StartContainer 

func (s *RuntimeServer) StartContainer(ctx context.Context, in *pb.StartContainerRequest) (*pb.StartContainerResponse, error)

StartContainer start container

func (*RuntimeServer) Status 

func (s *RuntimeServer) Status(ctx context.Context, req *pb.StatusRequest) (*pb.StatusResponse, error)

Status container

func (*RuntimeServer) StopContainer 

func (s *RuntimeServer) StopContainer(ctx context.Context, in *pb.StopContainerRequest) (*pb.StopContainerResponse, error)

StopContainer stop container

func (*RuntimeServer) StopPodSandbox 

func (s *RuntimeServer) StopPodSandbox(ctx context.Context, in *pb.StopPodSandboxRequest) (*pb.StopPodSandboxResponse, error)

StopPodSandbox pod

func (*RuntimeServer) UpdateContainerResources 

func (s *RuntimeServer) UpdateContainerResources(ctx context.Context, in *pb.UpdateContainerResourcesRequest) (*pb.UpdateContainerResourcesResponse, error)

UpdateContainerResources update container resources

func (*RuntimeServer) UpdateRuntimeConfig 

func (s *RuntimeServer) UpdateRuntimeConfig(ctx context.Context, req *pb.UpdateRuntimeConfigRequest) (*pb.UpdateRuntimeConfigResponse, error)

UpdateRuntimeConfig container

func (*RuntimeServer) Version 

func (s *RuntimeServer) Version(ctx context.Context, in *pb.VersionRequest) (*pb.VersionResponse, error)

Version runtime version

type Service 

type Service struct {
	Config     *Config
	GRPCServer *grpc.Server
}

Service to provide grpc server

func NewService 

func NewService(config *Config) (*Service, error)

NewService create service

func (*Service) Listen 

func (s *Service) Listen() error

Listen start unix socket

Source Files

View all Source files

Directories

Path Synopsis
cri
config
runtime/v1alpha2
utils
Package docker provides a general type to represent any way of referencing images within the registry.
 Package docker provides a general type to represent any way of referencing images within the registry.
pkg
cli
oci
Package truncindex provides a general 'index tree', used by Docker in order to be able to reference containers by only a few unambiguous characters of their id.
 Package truncindex provides a general 'index tree', used by Docker in order to be able to reference containers by only a few unambiguous characters of their id.
wasmer
example

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.