package api

import "github.com/containerd/nri/pkg/api"

Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: pkg/api/api.proto

Index

Constants

const (
	// DefaultSocketPath is the default socket path for external plugins.
	DefaultSocketPath = "/var/run/nri/nri.sock"
	// PluginSocketEnvVar is used to inform plugins about pre-connected sockets.
	PluginSocketEnvVar = "NRI_PLUGIN_SOCKET"
	// PluginNameEnvVar is used to inform NRI-launched plugins about their name.
	PluginNameEnvVar = "NRI_PLUGIN_NAME"
	// PluginIdxEnvVar is used to inform NRI-launched plugins about their ID.
	PluginIdxEnvVar = "NRI_PLUGIN_IDX"
)
const (
	// DefaultPluginRegistrationTimeout is the default timeout for plugin registration.
	DefaultPluginRegistrationTimeout = 5 * time.Second
	// DefaultPluginRequestTimeout is the default timeout for plugins to handle a request.
	DefaultPluginRequestTimeout = 2 * time.Second
)
const PluginPluginAPIVersion = 1
const (
	// SELinuxRelabel is a Mount pseudo-option to request relabeling.
	SELinuxRelabel = "relabel"
)
const (
	// ValidEvents is the event mask of all valid events.
	ValidEvents = EventMask((1 << (Event_LAST - 1)) - 1)
)

Variables

var (
	Event_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "RUN_POD_SANDBOX",
		2:  "STOP_POD_SANDBOX",
		3:  "REMOVE_POD_SANDBOX",
		4:  "CREATE_CONTAINER",
		5:  "POST_CREATE_CONTAINER",
		6:  "START_CONTAINER",
		7:  "POST_START_CONTAINER",
		8:  "UPDATE_CONTAINER",
		9:  "POST_UPDATE_CONTAINER",
		10: "STOP_CONTAINER",
		11: "REMOVE_CONTAINER",
		12: "LAST",
	}
	Event_value = map[string]int32{
		"UNKNOWN":               0,
		"RUN_POD_SANDBOX":       1,
		"STOP_POD_SANDBOX":      2,
		"REMOVE_POD_SANDBOX":    3,
		"CREATE_CONTAINER":      4,
		"POST_CREATE_CONTAINER": 5,
		"START_CONTAINER":       6,
		"POST_START_CONTAINER":  7,
		"UPDATE_CONTAINER":      8,
		"POST_UPDATE_CONTAINER": 9,
		"STOP_CONTAINER":        10,
		"REMOVE_CONTAINER":      11,
		"LAST":                  12,
	}
)

Enum value maps for Event.

var (
	ContainerState_name = map[int32]string{
		0: "CONTAINER_UNKNOWN",
		1: "CONTAINER_CREATED",
		2: "CONTAINER_PAUSED",
		3: "CONTAINER_RUNNING",
		4: "CONTAINER_STOPPED",
	}
	ContainerState_value = map[string]int32{
		"CONTAINER_UNKNOWN": 0,
		"CONTAINER_CREATED": 1,
		"CONTAINER_PAUSED":  2,
		"CONTAINER_RUNNING": 3,
		"CONTAINER_STOPPED": 4,
	}
)

Enum value maps for ContainerState.

var (
	LogRequest_Level_name = map[int32]string{
		0: "LEVEL_UNSPECIFIED",
		1: "LEVEL_DEBUG",
		2: "LEVEL_INFO",
		3: "LEVEL_WARN",
		4: "LEVEL_ERROR",
	}
	LogRequest_Level_value = map[string]int32{
		"LEVEL_UNSPECIFIED": 0,
		"LEVEL_DEBUG":       1,
		"LEVEL_INFO":        2,
		"LEVEL_WARN":        3,
		"LEVEL_ERROR":       4,
	}
)

Enum value maps for LogRequest_Level.

var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
var File_pkg_api_api_proto protoreflect.FileDescriptor

Functions

func CheckPluginIndex

func CheckPluginIndex(idx string) error

CheckPluginIndex checks the validity of a plugin index.

func ClearRemovalMarker

func ClearRemovalMarker(key string) string

ClearRemovalMarker returns a key cleared from any removal marker.

func DupStringMap

func DupStringMap(in map[string]string) map[string]string

DupStringMap creates a copy of a map with string keys and values.

func DupStringSlice

func DupStringSlice(in []string) []string

DupStringSlice creates a copy of a string slice.

func IsMarkedForRemoval

func IsMarkedForRemoval(key string) (string, bool)

IsMarkedForRemoval checks if a key is marked for removal.

The key can be an annotation name, a mount container path, a device path, or an environment variable name. These are all marked for removal in adjustments by preceding their corresponding key with a '-'.

func MarkForRemoval

func MarkForRemoval(key string) string

MarkForRemoval returns a key marked for removal.

func ParsePluginName

func ParsePluginName(name string) (string, string, error)

ParsePluginName parses the (file)name of a plugin into an index and a base.

func RegisterHostFunctionsService

func RegisterHostFunctionsService(srv *ttrpc.Server, svc HostFunctionsService)

func RegisterPluginService

func RegisterPluginService(srv *ttrpc.Server, svc PluginService)

func RegisterRuntimeService

func RegisterRuntimeService(srv *ttrpc.Server, svc RuntimeService)

func WazeroModuleConfig

func WazeroModuleConfig(moduleConfig wazero.ModuleConfig) wazeroConfigOption

func WazeroRuntime

func WazeroRuntime(newRuntime WazeroNewRuntime) wazeroConfigOption

Types

type CDIDevice

type CDIDevice struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

A CDI device reference.

func (*CDIDevice) Descriptor

func (*CDIDevice) Descriptor() ([]byte, []int)

Deprecated: Use CDIDevice.ProtoReflect.Descriptor instead.

func (*CDIDevice) GetName

func (x *CDIDevice) GetName() string

func (*CDIDevice) MarshalToSizedBufferVT

func (m *CDIDevice) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CDIDevice) MarshalToVT

func (m *CDIDevice) MarshalToVT(dAtA []byte) (int, error)

func (*CDIDevice) MarshalVT

func (m *CDIDevice) MarshalVT() (dAtA []byte, err error)

func (*CDIDevice) ProtoMessage

func (*CDIDevice) ProtoMessage()

func (*CDIDevice) ProtoReflect

func (x *CDIDevice) ProtoReflect() protoreflect.Message

func (*CDIDevice) Reset

func (x *CDIDevice) Reset()

func (*CDIDevice) SizeVT

func (m *CDIDevice) SizeVT() (n int)

func (*CDIDevice) String

func (x *CDIDevice) String() string

func (*CDIDevice) UnmarshalVT

func (m *CDIDevice) UnmarshalVT(dAtA []byte) error

type ConfigureRequest

type ConfigureRequest struct {

	// Any plugin-specific data, if present among the NRI configuration.
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// Name of the runtime NRI is running in.
	RuntimeName string `protobuf:"bytes,2,opt,name=runtime_name,json=runtimeName,proto3" json:"runtime_name,omitempty"`
	// Version of the runtime NRI is running in.
	RuntimeVersion string `protobuf:"bytes,3,opt,name=runtime_version,json=runtimeVersion,proto3" json:"runtime_version,omitempty"`
	// Configured registration timeout in milliseconds.
	RegistrationTimeout int64 `protobuf:"varint,4,opt,name=registration_timeout,json=registrationTimeout,proto3" json:"registration_timeout,omitempty"`
	// Configured request processing timeout in milliseconds.
	RequestTimeout int64 `protobuf:"varint,5,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureRequest) Descriptor

func (*ConfigureRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureRequest.ProtoReflect.Descriptor instead.

func (*ConfigureRequest) GetConfig

func (x *ConfigureRequest) GetConfig() string

func (*ConfigureRequest) GetRegistrationTimeout

func (x *ConfigureRequest) GetRegistrationTimeout() int64

func (*ConfigureRequest) GetRequestTimeout

func (x *ConfigureRequest) GetRequestTimeout() int64

func (*ConfigureRequest) GetRuntimeName

func (x *ConfigureRequest) GetRuntimeName() string

func (*ConfigureRequest) GetRuntimeVersion

func (x *ConfigureRequest) GetRuntimeVersion() string

func (*ConfigureRequest) MarshalToSizedBufferVT

func (m *ConfigureRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConfigureRequest) MarshalToVT

func (m *ConfigureRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ConfigureRequest) MarshalVT

func (m *ConfigureRequest) MarshalVT() (dAtA []byte, err error)

func (*ConfigureRequest) ProtoMessage

func (*ConfigureRequest) ProtoMessage()

func (*ConfigureRequest) ProtoReflect

func (x *ConfigureRequest) ProtoReflect() protoreflect.Message

func (*ConfigureRequest) Reset

func (x *ConfigureRequest) Reset()

func (*ConfigureRequest) SizeVT

func (m *ConfigureRequest) SizeVT() (n int)

func (*ConfigureRequest) String

func (x *ConfigureRequest) String() string

func (*ConfigureRequest) UnmarshalVT

func (m *ConfigureRequest) UnmarshalVT(dAtA []byte) error

type ConfigureResponse

type ConfigureResponse struct {

	// Events to subscribe the plugin for. Each bit set corresponds to an
	// enumerated Event.
	Events int32 `protobuf:"varint,2,opt,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureResponse) Descriptor

func (*ConfigureResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.

func (*ConfigureResponse) GetEvents

func (x *ConfigureResponse) GetEvents() int32

func (*ConfigureResponse) MarshalToSizedBufferVT

func (m *ConfigureResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConfigureResponse) MarshalToVT

func (m *ConfigureResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ConfigureResponse) MarshalVT

func (m *ConfigureResponse) MarshalVT() (dAtA []byte, err error)

func (*ConfigureResponse) ProtoMessage

func (*ConfigureResponse) ProtoMessage()

func (*ConfigureResponse) ProtoReflect

func (x *ConfigureResponse) ProtoReflect() protoreflect.Message

func (*ConfigureResponse) Reset

func (x *ConfigureResponse) Reset()

func (*ConfigureResponse) SizeVT

func (m *ConfigureResponse) SizeVT() (n int)

func (*ConfigureResponse) String

func (x *ConfigureResponse) String() string

func (*ConfigureResponse) UnmarshalVT

func (m *ConfigureResponse) UnmarshalVT(dAtA []byte) error

type Container

type Container struct {
	Id           string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PodSandboxId string            `protobuf:"bytes,2,opt,name=pod_sandbox_id,json=podSandboxId,proto3" json:"pod_sandbox_id,omitempty"`
	Name         string            `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	State        ContainerState    `protobuf:"varint,4,opt,name=state,proto3,enum=nri.pkg.api.v1alpha1.ContainerState" json:"state,omitempty"`
	Labels       map[string]string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	Annotations  map[string]string `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	Args         []string          `protobuf:"bytes,7,rep,name=args,proto3" json:"args,omitempty"`
	Env          []string          `protobuf:"bytes,8,rep,name=env,proto3" json:"env,omitempty"`
	Mounts       []*Mount          `protobuf:"bytes,9,rep,name=mounts,proto3" json:"mounts,omitempty"`
	Hooks        *Hooks            `protobuf:"bytes,10,opt,name=hooks,proto3" json:"hooks,omitempty"`
	Linux        *LinuxContainer   `protobuf:"bytes,11,opt,name=linux,proto3" json:"linux,omitempty"`
	Pid          uint32            `protobuf:"varint,12,opt,name=pid,proto3" json:"pid,omitempty"` // for NRI v1 emulation
	Rlimits      []*POSIXRlimit    `protobuf:"bytes,13,rep,name=rlimits,proto3" json:"rlimits,omitempty"`
	// contains filtered or unexported fields
}

Container metadata that is considered relevant for a plugin.

func (*Container) Descriptor

func (*Container) Descriptor() ([]byte, []int)

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetAnnotations

func (x *Container) GetAnnotations() map[string]string

func (*Container) GetArgs

func (x *Container) GetArgs() []string

func (*Container) GetEnv

func (x *Container) GetEnv() []string

func (*Container) GetHooks

func (x *Container) GetHooks() *Hooks

func (*Container) GetId

func (x *Container) GetId() string

func (*Container) GetLabels

func (x *Container) GetLabels() map[string]string

func (*Container) GetLinux

func (x *Container) GetLinux() *LinuxContainer

func (*Container) GetMounts

func (x *Container) GetMounts() []*Mount

func (*Container) GetName

func (x *Container) GetName() string

func (*Container) GetPid

func (x *Container) GetPid() uint32

func (*Container) GetPodSandboxId

func (x *Container) GetPodSandboxId() string

func (*Container) GetRlimits

func (x *Container) GetRlimits() []*POSIXRlimit

func (*Container) GetState

func (x *Container) GetState() ContainerState

func (*Container) MarshalToSizedBufferVT

func (m *Container) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Container) MarshalToVT

func (m *Container) MarshalToVT(dAtA []byte) (int, error)

func (*Container) MarshalVT

func (m *Container) MarshalVT() (dAtA []byte, err error)

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) ProtoReflect

func (x *Container) ProtoReflect() protoreflect.Message

func (*Container) Reset

func (x *Container) Reset()

func (*Container) SizeVT

func (m *Container) SizeVT() (n int)

func (*Container) String

func (x *Container) String() string

func (*Container) UnmarshalVT

func (m *Container) UnmarshalVT(dAtA []byte) error

type ContainerAdjustment

type ContainerAdjustment struct {
	Annotations map[string]string         `protobuf:"bytes,2,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	Mounts      []*Mount                  `protobuf:"bytes,3,rep,name=mounts,proto3" json:"mounts,omitempty"`
	Env         []*KeyValue               `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"`
	Hooks       *Hooks                    `protobuf:"bytes,5,opt,name=hooks,proto3" json:"hooks,omitempty"`
	Linux       *LinuxContainerAdjustment `protobuf:"bytes,6,opt,name=linux,proto3" json:"linux,omitempty"`
	Rlimits     []*POSIXRlimit            `protobuf:"bytes,7,rep,name=rlimits,proto3" json:"rlimits,omitempty"`
	CDIDevices  []*CDIDevice              `protobuf:"bytes,8,rep,name=CDI_devices,json=CDIDevices,proto3" json:"CDI_devices,omitempty"`
	// contains filtered or unexported fields
}

Requested adjustments to a container being created.

func (*ContainerAdjustment) AddAnnotation

func (a *ContainerAdjustment) AddAnnotation(key, value string)

AddAnnotation records the addition of the annotation key=value.

func (*ContainerAdjustment) AddCDIDevice

func (a *ContainerAdjustment) AddCDIDevice(d *CDIDevice)

AddCDIDevice records the addition of the given CDI device to a container.

func (*ContainerAdjustment) AddDevice

func (a *ContainerAdjustment) AddDevice(d *LinuxDevice)

AddDevice records the addition of the given device to a container.

func (*ContainerAdjustment) AddEnv

func (a *ContainerAdjustment) AddEnv(key, value string)

AddEnv records the addition of an environment variable to a container.

func (*ContainerAdjustment) AddHooks

func (a *ContainerAdjustment) AddHooks(h *Hooks)

AddHooks records the addition of the given hooks to a container.

func (*ContainerAdjustment) AddLinuxHugepageLimit

func (a *ContainerAdjustment) AddLinuxHugepageLimit(pageSize string, value uint64)

AddLinuxHugepageLimit records adding a hugepage limit for a container.

func (*ContainerAdjustment) AddLinuxUnified

func (a *ContainerAdjustment) AddLinuxUnified(key, value string)

AddLinuxUnified sets a cgroupv2 unified resource.

func (*ContainerAdjustment) AddMount

func (a *ContainerAdjustment) AddMount(m *Mount)

AddMount records the addition of a mount to a container.

func (*ContainerAdjustment) AddRlimit

func (a *ContainerAdjustment) AddRlimit(typ string, hard, soft uint64)

func (*ContainerAdjustment) Descriptor

func (*ContainerAdjustment) Descriptor() ([]byte, []int)

Deprecated: Use ContainerAdjustment.ProtoReflect.Descriptor instead.

func (*ContainerAdjustment) GetAnnotations

func (x *ContainerAdjustment) GetAnnotations() map[string]string

func (*ContainerAdjustment) GetCDIDevices

func (x *ContainerAdjustment) GetCDIDevices() []*CDIDevice

func (*ContainerAdjustment) GetEnv

func (x *ContainerAdjustment) GetEnv() []*KeyValue

func (*ContainerAdjustment) GetHooks

func (x *ContainerAdjustment) GetHooks() *Hooks

func (*ContainerAdjustment) GetLinux

func (*ContainerAdjustment) GetMounts

func (x *ContainerAdjustment) GetMounts() []*Mount

func (*ContainerAdjustment) GetRlimits

func (x *ContainerAdjustment) GetRlimits() []*POSIXRlimit

func (*ContainerAdjustment) MarshalToSizedBufferVT

func (m *ContainerAdjustment) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ContainerAdjustment) MarshalToVT

func (m *ContainerAdjustment) MarshalToVT(dAtA []byte) (int, error)

func (*ContainerAdjustment) MarshalVT

func (m *ContainerAdjustment) MarshalVT() (dAtA []byte, err error)

func (*ContainerAdjustment) ProtoMessage

func (*ContainerAdjustment) ProtoMessage()

func (*ContainerAdjustment) ProtoReflect

func (x *ContainerAdjustment) ProtoReflect() protoreflect.Message

func (*ContainerAdjustment) RemoveAnnotation

func (a *ContainerAdjustment) RemoveAnnotation(key string)

RemoveAnnotation records the removal of the annotation for the given key. Normally it is an error for a plugin to try and alter an annotation touched by another plugin. However, this is not an error if the plugin removes that annotation prior to touching it.

func (*ContainerAdjustment) RemoveDevice

func (a *ContainerAdjustment) RemoveDevice(path string)

RemoveDevice records the removal of a device from a container. Normally it is an error for a plugin to try and alter an device touched by another container. However, this is not an error if the plugin removes that device prior to touching it.

func (*ContainerAdjustment) RemoveEnv

func (a *ContainerAdjustment) RemoveEnv(key string)

RemoveEnv records the removal of an environment variable from a container. Normally it is an error for a plugin to try and alter an environment variable touched by another container. However, this is not an error if the plugin removes that variable prior to touching it.

func (*ContainerAdjustment) RemoveMount

func (a *ContainerAdjustment) RemoveMount(ContainerPath string)

RemoveMount records the removal of a mount from a container. Normally it is an error for a plugin to try and alter a mount touched by another plugin. However, this is not an error if the plugin removes that mount prior to touching it.

func (*ContainerAdjustment) Reset

func (x *ContainerAdjustment) Reset()

func (*ContainerAdjustment) SetLinuxBlockIOClass

func (a *ContainerAdjustment) SetLinuxBlockIOClass(value string)

SetLinuxBlockIOClass records setting the Block I/O class for a container.

func (*ContainerAdjustment) SetLinuxCPUPeriod

func (a *ContainerAdjustment) SetLinuxCPUPeriod(value int64)

SetLinuxCPUPeriod records setting the scheduler's CPU period for a container.

func (*ContainerAdjustment) SetLinuxCPUQuota

func (a *ContainerAdjustment) SetLinuxCPUQuota(value int64)

SetLinuxCPUQuota records setting the scheduler's CPU quota for a container.

func (*ContainerAdjustment) SetLinuxCPURealtimePeriod

func (a *ContainerAdjustment) SetLinuxCPURealtimePeriod(value uint64)

SetLinuxCPURealtimePeriod records setting the scheduler's realtime period for a container.

func (*ContainerAdjustment) SetLinuxCPURealtimeRuntime

func (a *ContainerAdjustment) SetLinuxCPURealtimeRuntime(value int64)

SetLinuxCPURealtimeRuntime records setting the scheduler's realtime runtime for a container.

func (*ContainerAdjustment) SetLinuxCPUSetCPUs

func (a *ContainerAdjustment) SetLinuxCPUSetCPUs(value string)

SetLinuxCPUSetCPUs records setting the cpuset CPUs for a container.

func (*ContainerAdjustment) SetLinuxCPUSetMems

func (a *ContainerAdjustment) SetLinuxCPUSetMems(value string)

SetLinuxCPUSetMems records setting the cpuset memory for a container.

func (*ContainerAdjustment) SetLinuxCPUShares

func (a *ContainerAdjustment) SetLinuxCPUShares(value uint64)

SetLinuxCPUShares records setting the scheduler's CPU shares for a container.

func (*ContainerAdjustment) SetLinuxCgroupsPath

func (a *ContainerAdjustment) SetLinuxCgroupsPath(value string)

SetLinuxCgroupsPath records setting the cgroups path for a container.

func (*ContainerAdjustment) SetLinuxMemoryDisableOomKiller

func (a *ContainerAdjustment) SetLinuxMemoryDisableOomKiller()

SetLinuxMemoryDisableOomKiller records disabling the OOM killer for a container.

func (*ContainerAdjustment) SetLinuxMemoryKernel

func (a *ContainerAdjustment) SetLinuxMemoryKernel(value int64)

SetLinuxMemoryKernel records setting the memory kernel limit for a container.

func (*ContainerAdjustment) SetLinuxMemoryKernelTCP

func (a *ContainerAdjustment) SetLinuxMemoryKernelTCP(value int64)

SetLinuxMemoryKernelTCP records setting the memory kernel TCP limit for a container.

func (*ContainerAdjustment) SetLinuxMemoryLimit

func (a *ContainerAdjustment) SetLinuxMemoryLimit(value int64)

SetLinuxMemoryLimit records setting the memory limit for a container.

func (*ContainerAdjustment) SetLinuxMemoryReservation

func (a *ContainerAdjustment) SetLinuxMemoryReservation(value int64)

SetLinuxMemoryReservation records setting the memory reservation for a container.

func (*ContainerAdjustment) SetLinuxMemorySwap

func (a *ContainerAdjustment) SetLinuxMemorySwap(value int64)

SetLinuxMemorySwap records records setting the memory swap limit for a container.

func (*ContainerAdjustment) SetLinuxMemorySwappiness

func (a *ContainerAdjustment) SetLinuxMemorySwappiness(value uint64)

SetLinuxMemorySwappiness records setting the memory swappiness for a container.

func (*ContainerAdjustment) SetLinuxMemoryUseHierarchy

func (a *ContainerAdjustment) SetLinuxMemoryUseHierarchy()

SetLinuxMemoryUseHierarchy records enabling hierarchical memory accounting for a container.

func (*ContainerAdjustment) SetLinuxOomScoreAdj

func (a *ContainerAdjustment) SetLinuxOomScoreAdj(value *int)

SetLinuxOomScoreAdj records setting the kernel's Out-Of-Memory (OOM) killer score for a container.

func (*ContainerAdjustment) SetLinuxPidLimits

func (a *ContainerAdjustment) SetLinuxPidLimits(value int64)

SetLinuxPidLimits records setting the pid max number for a container.

func (*ContainerAdjustment) SetLinuxRDTClass

func (a *ContainerAdjustment) SetLinuxRDTClass(value string)

SetLinuxRDTClass records setting the RDT class for a container.

func (*ContainerAdjustment) SizeVT

func (m *ContainerAdjustment) SizeVT() (n int)

func (*ContainerAdjustment) String

func (x *ContainerAdjustment) String() string

func (*ContainerAdjustment) UnmarshalVT

func (m *ContainerAdjustment) UnmarshalVT(dAtA []byte) error

type ContainerEviction

type ContainerEviction struct {

	// Container to evict.
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// Human-readable reason for eviction.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

Request to evict (IOW unsolicitedly stop) a container.

func (*ContainerEviction) Descriptor

func (*ContainerEviction) Descriptor() ([]byte, []int)

Deprecated: Use ContainerEviction.ProtoReflect.Descriptor instead.

func (*ContainerEviction) GetContainerId

func (x *ContainerEviction) GetContainerId() string

func (*ContainerEviction) GetReason

func (x *ContainerEviction) GetReason() string

func (*ContainerEviction) MarshalToSizedBufferVT

func (m *ContainerEviction) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ContainerEviction) MarshalToVT

func (m *ContainerEviction) MarshalToVT(dAtA []byte) (int, error)

func (*ContainerEviction) MarshalVT

func (m *ContainerEviction) MarshalVT() (dAtA []byte, err error)

func (*ContainerEviction) ProtoMessage

func (*ContainerEviction) ProtoMessage()

func (*ContainerEviction) ProtoReflect

func (x *ContainerEviction) ProtoReflect() protoreflect.Message

func (*ContainerEviction) Reset

func (x *ContainerEviction) Reset()

func (*ContainerEviction) SizeVT

func (m *ContainerEviction) SizeVT() (n int)

func (*ContainerEviction) String

func (x *ContainerEviction) String() string

func (*ContainerEviction) UnmarshalVT

func (m *ContainerEviction) UnmarshalVT(dAtA []byte) error

type ContainerState

type ContainerState int32

Possible container states.

const (
	ContainerState_CONTAINER_UNKNOWN ContainerState = 0
	ContainerState_CONTAINER_CREATED ContainerState = 1
	ContainerState_CONTAINER_PAUSED  ContainerState = 2 // is this useful/necessary ?
	ContainerState_CONTAINER_RUNNING ContainerState = 3
	ContainerState_CONTAINER_STOPPED ContainerState = 4
)

func (ContainerState) Descriptor

func (ContainerState) Enum

func (x ContainerState) Enum() *ContainerState

func (ContainerState) EnumDescriptor

func (ContainerState) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContainerState.Descriptor instead.

func (ContainerState) Number

func (ContainerState) String

func (x ContainerState) String() string

func (ContainerState) Type

type ContainerUpdate

type ContainerUpdate struct {
	ContainerId   string                `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Linux         *LinuxContainerUpdate `protobuf:"bytes,2,opt,name=linux,proto3" json:"linux,omitempty"`
	IgnoreFailure bool                  `protobuf:"varint,3,opt,name=ignore_failure,json=ignoreFailure,proto3" json:"ignore_failure,omitempty"`
	// contains filtered or unexported fields
}

Requested update to an already created container.

func (*ContainerUpdate) AddLinuxHugepageLimit

func (u *ContainerUpdate) AddLinuxHugepageLimit(pageSize string, value uint64)

AddLinuxHugepageLimit records adding a hugepage limit for a container.

func (*ContainerUpdate) AddLinuxUnified

func (u *ContainerUpdate) AddLinuxUnified(key, value string)

AddLinuxUnified sets a cgroupv2 unified resource.

func (*ContainerUpdate) Descriptor

func (*ContainerUpdate) Descriptor() ([]byte, []int)

Deprecated: Use ContainerUpdate.ProtoReflect.Descriptor instead.

func (*ContainerUpdate) GetContainerId

func (x *ContainerUpdate) GetContainerId() string

func (*ContainerUpdate) GetIgnoreFailure

func (x *ContainerUpdate) GetIgnoreFailure() bool

func (*ContainerUpdate) GetLinux

func (x *ContainerUpdate) GetLinux() *LinuxContainerUpdate

func (*ContainerUpdate) MarshalToSizedBufferVT

func (m *ContainerUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ContainerUpdate) MarshalToVT

func (m *ContainerUpdate) MarshalToVT(dAtA []byte) (int, error)

func (*ContainerUpdate) MarshalVT

func (m *ContainerUpdate) MarshalVT() (dAtA []byte, err error)

func (*ContainerUpdate) ProtoMessage

func (*ContainerUpdate) ProtoMessage()

func (*ContainerUpdate) ProtoReflect

func (x *ContainerUpdate) ProtoReflect() protoreflect.Message

func (*ContainerUpdate) Reset

func (x *ContainerUpdate) Reset()

func (*ContainerUpdate) SetContainerId

func (u *ContainerUpdate) SetContainerId(id string)

nolint SetContainerId sets the id of the container to update.

func (*ContainerUpdate) SetIgnoreFailure

func (u *ContainerUpdate) SetIgnoreFailure()

SetIgnoreFailure marks an Update as ignored for failures. Such updates will not prevent the related container operation from succeeding if the update fails.

func (*ContainerUpdate) SetLinuxBlockIOClass

func (u *ContainerUpdate) SetLinuxBlockIOClass(value string)

SetLinuxBlockIOClass records setting the Block I/O class for a container.

func (*ContainerUpdate) SetLinuxCPUPeriod

func (u *ContainerUpdate) SetLinuxCPUPeriod(value int64)

SetLinuxCPUPeriod records setting the scheduler's CPU period for a container.

func (*ContainerUpdate) SetLinuxCPUQuota

func (u *ContainerUpdate) SetLinuxCPUQuota(value int64)

SetLinuxCPUQuota records setting the scheduler's CPU quota for a container.

func (*ContainerUpdate) SetLinuxCPURealtimePeriod

func (u *ContainerUpdate) SetLinuxCPURealtimePeriod(value uint64)

SetLinuxCPURealtimePeriod records setting the scheduler's realtime period for a container.

func (*ContainerUpdate) SetLinuxCPURealtimeRuntime

func (u *ContainerUpdate) SetLinuxCPURealtimeRuntime(value int64)

SetLinuxCPURealtimeRuntime records setting the scheduler's realtime runtime for a container.

func (*ContainerUpdate) SetLinuxCPUSetCPUs

func (u *ContainerUpdate) SetLinuxCPUSetCPUs(value string)

SetLinuxCPUSetCPUs records setting the cpuset CPUs for a container.

func (*ContainerUpdate) SetLinuxCPUSetMems

func (u *ContainerUpdate) SetLinuxCPUSetMems(value string)

SetLinuxCPUSetMems records setting the cpuset memory for a container.

func (*ContainerUpdate) SetLinuxCPUShares

func (u *ContainerUpdate) SetLinuxCPUShares(value uint64)

SetLinuxCPUShares records setting the scheduler's CPU shares for a container.

func (*ContainerUpdate) SetLinuxMemoryDisableOomKiller

func (u *ContainerUpdate) SetLinuxMemoryDisableOomKiller()

SetLinuxMemoryDisableOomKiller records disabling the OOM killer for a container.

func (*ContainerUpdate) SetLinuxMemoryKernel

func (u *ContainerUpdate) SetLinuxMemoryKernel(value int64)

SetLinuxMemoryKernel records setting the memory kernel limit for a container.

func (*ContainerUpdate) SetLinuxMemoryKernelTCP

func (u *ContainerUpdate) SetLinuxMemoryKernelTCP(value int64)

SetLinuxMemoryKernelTCP records setting the memory kernel TCP limit for a container.

func (*ContainerUpdate) SetLinuxMemoryLimit

func (u *ContainerUpdate) SetLinuxMemoryLimit(value int64)

SetLinuxMemoryLimit records setting the memory limit for a container.

func (*ContainerUpdate) SetLinuxMemoryReservation

func (u *ContainerUpdate) SetLinuxMemoryReservation(value int64)

SetLinuxMemoryReservation records setting the memory reservation for a container.

func (*ContainerUpdate) SetLinuxMemorySwap

func (u *ContainerUpdate) SetLinuxMemorySwap(value int64)

SetLinuxMemorySwap records records setting the memory swap limit for a container.

func (*ContainerUpdate) SetLinuxMemorySwappiness

func (u *ContainerUpdate) SetLinuxMemorySwappiness(value uint64)

SetLinuxMemorySwappiness records setting the memory swappiness for a container.

func (*ContainerUpdate) SetLinuxMemoryUseHierarchy

func (u *ContainerUpdate) SetLinuxMemoryUseHierarchy()

SetLinuxMemoryUseHierarchy records enabling hierarchical memory accounting for a container.

func (*ContainerUpdate) SetLinuxPidLimits

func (u *ContainerUpdate) SetLinuxPidLimits(value int64)

SetLinuxPidLimits records setting the pid max number for a container.

func (*ContainerUpdate) SetLinuxRDTClass

func (u *ContainerUpdate) SetLinuxRDTClass(value string)

SetLinuxRDTClass records setting the RDT class for a container.

func (*ContainerUpdate) SizeVT

func (m *ContainerUpdate) SizeVT() (n int)

func (*ContainerUpdate) String

func (x *ContainerUpdate) String() string

func (*ContainerUpdate) UnmarshalVT

func (m *ContainerUpdate) UnmarshalVT(dAtA []byte) error

type CreateContainerRequest

type CreateContainerRequest struct {

	// Pod of container being created.
	Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	// Container being created.
	Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateContainerRequest) Descriptor

func (*CreateContainerRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateContainerRequest.ProtoReflect.Descriptor instead.

func (*CreateContainerRequest) GetContainer

func (x *CreateContainerRequest) GetContainer() *Container

func (*CreateContainerRequest) GetPod

func (x *CreateContainerRequest) GetPod() *PodSandbox

func (*CreateContainerRequest) MarshalToSizedBufferVT

func (m *CreateContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateContainerRequest) MarshalToVT

func (m *CreateContainerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateContainerRequest) MarshalVT

func (m *CreateContainerRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateContainerRequest) ProtoMessage

func (*CreateContainerRequest) ProtoMessage()

func (*CreateContainerRequest) ProtoReflect

func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message

func (*CreateContainerRequest) Reset

func (x *CreateContainerRequest) Reset()

func (*CreateContainerRequest) SizeVT

func (m *CreateContainerRequest) SizeVT() (n int)

func (*CreateContainerRequest) String

func (x *CreateContainerRequest) String() string

func (*CreateContainerRequest) UnmarshalVT

func (m *CreateContainerRequest) UnmarshalVT(dAtA []byte) error

type CreateContainerResponse

type CreateContainerResponse struct {

	// Requested adjustments to container being created.
	Adjust *ContainerAdjustment `protobuf:"bytes,1,opt,name=adjust,proto3" json:"adjust,omitempty"`
	// Requested updates to other existing containers.
	Update []*ContainerUpdate `protobuf:"bytes,2,rep,name=update,proto3" json:"update,omitempty"`
	// Requested eviction of existing containers.
	Evict []*ContainerEviction `protobuf:"bytes,3,rep,name=evict,proto3" json:"evict,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateContainerResponse) Descriptor

func (*CreateContainerResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateContainerResponse.ProtoReflect.Descriptor instead.

func (*CreateContainerResponse) GetAdjust

func (*CreateContainerResponse) GetEvict

func (x *CreateContainerResponse) GetEvict() []*ContainerEviction

func (*CreateContainerResponse) GetUpdate

func (x *CreateContainerResponse) GetUpdate() []*ContainerUpdate

func (*CreateContainerResponse) MarshalToSizedBufferVT

func (m *CreateContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateContainerResponse) MarshalToVT

func (m *CreateContainerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateContainerResponse) MarshalVT

func (m *CreateContainerResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateContainerResponse) ProtoMessage

func (*CreateContainerResponse) ProtoMessage()

func (*CreateContainerResponse) ProtoReflect

func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message

func (*CreateContainerResponse) Reset

func (x *CreateContainerResponse) Reset()

func (*CreateContainerResponse) SizeVT

func (m *CreateContainerResponse) SizeVT() (n int)

func (*CreateContainerResponse) String

func (x *CreateContainerResponse) String() string

func (*CreateContainerResponse) UnmarshalVT

func (m *CreateContainerResponse) UnmarshalVT(dAtA []byte) error

type Empty

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

Empty response for those *Requests that are semantically events.

func (*Empty) Descriptor

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) MarshalToSizedBufferVT

func (m *Empty) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Empty) MarshalToVT

func (m *Empty) MarshalToVT(dAtA []byte) (int, error)

func (*Empty) MarshalVT

func (m *Empty) MarshalVT() (dAtA []byte, err error)

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) SizeVT

func (m *Empty) SizeVT() (n int)

func (*Empty) String

func (x *Empty) String() string

func (*Empty) UnmarshalVT

func (m *Empty) UnmarshalVT(dAtA []byte) error

type Event

type Event int32

Events that plugins can subscribe to in ConfigureResponse.

const (
	Event_UNKNOWN               Event = 0
	Event_RUN_POD_SANDBOX       Event = 1
	Event_STOP_POD_SANDBOX      Event = 2
	Event_REMOVE_POD_SANDBOX    Event = 3
	Event_CREATE_CONTAINER      Event = 4
	Event_POST_CREATE_CONTAINER Event = 5
	Event_START_CONTAINER       Event = 6
	Event_POST_START_CONTAINER  Event = 7
	Event_UPDATE_CONTAINER      Event = 8
	Event_POST_UPDATE_CONTAINER Event = 9
	Event_STOP_CONTAINER        Event = 10
	Event_REMOVE_CONTAINER      Event = 11
	Event_LAST                  Event = 12
)

func (Event) Descriptor

func (Event) Descriptor() protoreflect.EnumDescriptor

func (Event) Enum

func (x Event) Enum() *Event

func (Event) EnumDescriptor

func (Event) EnumDescriptor() ([]byte, []int)

Deprecated: Use Event.Descriptor instead.

func (Event) Number

func (x Event) Number() protoreflect.EnumNumber

func (Event) String

func (x Event) String() string

func (Event) Type

func (Event) Type() protoreflect.EnumType

type EventMask

type EventMask int32

EventMask corresponds to a set of enumerated Events.

func MustParseEventMask

func MustParseEventMask(events ...string) EventMask

MustParseEventMask parses the given events, panic()ing on errors.

func ParseEventMask

func ParseEventMask(events ...string) (EventMask, error)

ParseEventMask parses a string representation into an EventMask.

func (*EventMask) Clear

func (m *EventMask) Clear(events ...Event) *EventMask

Clear clears the given Events in the mask.

func (*EventMask) IsSet

func (m *EventMask) IsSet(e Event) bool

IsSet check if the given Event is set in the mask.

func (*EventMask) PrettyString

func (m *EventMask) PrettyString() string

PrettyString returns a human-readable string representation of an EventMask.

func (*EventMask) Set

func (m *EventMask) Set(events ...Event) *EventMask

Set sets the given Events in the mask.

type Hook

type Hook struct {
	Path    string       `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Args    []string     `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Env     []string     `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"`
	Timeout *OptionalInt `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

One OCI hook.

func FromOCIHookSlice

func FromOCIHookSlice(o []rspec.Hook) []*Hook

FromOCIHookSlice returns a hook slice from an OCI runtime Spec.

func (*Hook) Descriptor

func (*Hook) Descriptor() ([]byte, []int)

Deprecated: Use Hook.ProtoReflect.Descriptor instead.

func (*Hook) GetArgs

func (x *Hook) GetArgs() []string

func (*Hook) GetEnv

func (x *Hook) GetEnv() []string

func (*Hook) GetPath

func (x *Hook) GetPath() string

func (*Hook) GetTimeout

func (x *Hook) GetTimeout() *OptionalInt

func (*Hook) MarshalToSizedBufferVT

func (m *Hook) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Hook) MarshalToVT

func (m *Hook) MarshalToVT(dAtA []byte) (int, error)

func (*Hook) MarshalVT

func (m *Hook) MarshalVT() (dAtA []byte, err error)

func (*Hook) ProtoMessage

func (*Hook) ProtoMessage()

func (*Hook) ProtoReflect

func (x *Hook) ProtoReflect() protoreflect.Message

func (*Hook) Reset

func (x *Hook) Reset()

func (*Hook) SizeVT

func (m *Hook) SizeVT() (n int)

func (*Hook) String

func (x *Hook) String() string

func (*Hook) ToOCI

func (h *Hook) ToOCI() rspec.Hook

ToOCI returns the hook for an OCI runtime Spec.

func (*Hook) UnmarshalVT

func (m *Hook) UnmarshalVT(dAtA []byte) error

type Hooks

type Hooks struct {
	Prestart        []*Hook `protobuf:"bytes,1,rep,name=prestart,proto3" json:"prestart,omitempty"`
	CreateRuntime   []*Hook `protobuf:"bytes,2,rep,name=create_runtime,json=createRuntime,proto3" json:"create_runtime,omitempty"`
	CreateContainer []*Hook `protobuf:"bytes,3,rep,name=create_container,json=createContainer,proto3" json:"create_container,omitempty"`
	StartContainer  []*Hook `protobuf:"bytes,4,rep,name=start_container,json=startContainer,proto3" json:"start_container,omitempty"`
	Poststart       []*Hook `protobuf:"bytes,5,rep,name=poststart,proto3" json:"poststart,omitempty"`
	Poststop        []*Hook `protobuf:"bytes,6,rep,name=poststop,proto3" json:"poststop,omitempty"`
	// contains filtered or unexported fields
}

Container OCI hooks.

func FromOCIHooks

func FromOCIHooks(o *rspec.Hooks) *Hooks

FromOCIHooks returns hooks from an OCI runtime Spec.

func (*Hooks) Append

func (hooks *Hooks) Append(h *Hooks) *Hooks

Append appends the given hooks to the existing ones.

func (*Hooks) Descriptor

func (*Hooks) Descriptor() ([]byte, []int)

Deprecated: Use Hooks.ProtoReflect.Descriptor instead.

func (*Hooks) GetCreateContainer

func (x *Hooks) GetCreateContainer() []*Hook

func (*Hooks) GetCreateRuntime

func (x *Hooks) GetCreateRuntime() []*Hook

func (*Hooks) GetPoststart

func (x *Hooks) GetPoststart() []*Hook

func (*Hooks) GetPoststop

func (x *Hooks) GetPoststop() []*Hook

func (*Hooks) GetPrestart

func (x *Hooks) GetPrestart() []*Hook

func (*Hooks) GetStartContainer

func (x *Hooks) GetStartContainer() []*Hook

func (*Hooks) Hooks

func (hooks *Hooks) Hooks() *Hooks

Hooks returns itself it any of its hooks is set. Otherwise it returns nil.

func (*Hooks) MarshalToSizedBufferVT

func (m *Hooks) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Hooks) MarshalToVT

func (m *Hooks) MarshalToVT(dAtA []byte) (int, error)

func (*Hooks) MarshalVT

func (m *Hooks) MarshalVT() (dAtA []byte, err error)

func (*Hooks) ProtoMessage

func (*Hooks) ProtoMessage()

func (*Hooks) ProtoReflect

func (x *Hooks) ProtoReflect() protoreflect.Message

func (*Hooks) Reset

func (x *Hooks) Reset()

func (*Hooks) SizeVT

func (m *Hooks) SizeVT() (n int)

func (*Hooks) String

func (x *Hooks) String() string

func (*Hooks) UnmarshalVT

func (m *Hooks) UnmarshalVT(dAtA []byte) error

type HostFunctions

type HostFunctions interface {
	// Log displays a log message
	Log(context.Context, *LogRequest) (*Empty, error)
}

go:plugin type=host

type HostFunctionsService

type HostFunctionsService interface {
	Log(context.Context, *LogRequest) (*Empty, error)
}

func NewHostFunctionsClient

func NewHostFunctionsClient(client *ttrpc.Client) HostFunctionsService

type HugepageLimit

type HugepageLimit struct {
	PageSize string `protobuf:"bytes,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Limit    uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

Container huge page limit.

func (*HugepageLimit) Descriptor

func (*HugepageLimit) Descriptor() ([]byte, []int)

Deprecated: Use HugepageLimit.ProtoReflect.Descriptor instead.

func (*HugepageLimit) GetLimit

func (x *HugepageLimit) GetLimit() uint64

func (*HugepageLimit) GetPageSize

func (x *HugepageLimit) GetPageSize() string

func (*HugepageLimit) MarshalToSizedBufferVT

func (m *HugepageLimit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HugepageLimit) MarshalToVT

func (m *HugepageLimit) MarshalToVT(dAtA []byte) (int, error)

func (*HugepageLimit) MarshalVT

func (m *HugepageLimit) MarshalVT() (dAtA []byte, err error)

func (*HugepageLimit) ProtoMessage

func (*HugepageLimit) ProtoMessage()

func (*HugepageLimit) ProtoReflect

func (x *HugepageLimit) ProtoReflect() protoreflect.Message

func (*HugepageLimit) Reset

func (x *HugepageLimit) Reset()

func (*HugepageLimit) SizeVT

func (m *HugepageLimit) SizeVT() (n int)

func (*HugepageLimit) String

func (x *HugepageLimit) String() string

func (*HugepageLimit) UnmarshalVT

func (m *HugepageLimit) UnmarshalVT(dAtA []byte) error

type KeyValue

type KeyValue struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

KeyValue represents an environment variable.

func FromOCIEnv

func FromOCIEnv(in []string) []*KeyValue

FromOCIEnv returns KeyValues from an OCI runtime Spec environment.

func (*KeyValue) Descriptor

func (*KeyValue) Descriptor() ([]byte, []int)

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue

func (x *KeyValue) GetValue() string

func (*KeyValue) IsMarkedForRemoval

func (e *KeyValue) IsMarkedForRemoval() (string, bool)

IsMarkedForRemoval checks if an environment variable is marked for removal.

func (*KeyValue) MarshalToSizedBufferVT

func (m *KeyValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyValue) MarshalToVT

func (m *KeyValue) MarshalToVT(dAtA []byte) (int, error)

func (*KeyValue) MarshalVT

func (m *KeyValue) MarshalVT() (dAtA []byte, err error)

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect

func (x *KeyValue) ProtoReflect() protoreflect.Message

func (*KeyValue) Reset

func (x *KeyValue) Reset()

func (*KeyValue) SizeVT

func (m *KeyValue) SizeVT() (n int)

func (*KeyValue) String

func (x *KeyValue) String() string

func (*KeyValue) ToOCI

func (e *KeyValue) ToOCI() string

ToOCI returns an OCI Env entry for the KeyValue.

func (*KeyValue) UnmarshalVT

func (m *KeyValue) UnmarshalVT(dAtA []byte) error

type LinuxCPU

type LinuxCPU struct {
	Shares          *OptionalUInt64 `protobuf:"bytes,1,opt,name=shares,proto3" json:"shares,omitempty"`
	Quota           *OptionalInt64  `protobuf:"bytes,2,opt,name=quota,proto3" json:"quota,omitempty"`
	Period          *OptionalUInt64 `protobuf:"bytes,3,opt,name=period,proto3" json:"period,omitempty"`
	RealtimeRuntime *OptionalInt64  `protobuf:"bytes,4,opt,name=realtime_runtime,json=realtimeRuntime,proto3" json:"realtime_runtime,omitempty"`
	RealtimePeriod  *OptionalUInt64 `protobuf:"bytes,5,opt,name=realtime_period,json=realtimePeriod,proto3" json:"realtime_period,omitempty"`
	Cpus            string          `protobuf:"bytes,6,opt,name=cpus,proto3" json:"cpus,omitempty"`
	Mems            string          `protobuf:"bytes,7,opt,name=mems,proto3" json:"mems,omitempty"`
	// contains filtered or unexported fields
}

CPU-related parts of (linux) resources.

func (*LinuxCPU) Descriptor

func (*LinuxCPU) Descriptor() ([]byte, []int)

Deprecated: Use LinuxCPU.ProtoReflect.Descriptor instead.

func (*LinuxCPU) GetCpus

func (x *LinuxCPU) GetCpus() string

func (*LinuxCPU) GetMems

func (x *LinuxCPU) GetMems() string

func (*LinuxCPU) GetPeriod

func (x *LinuxCPU) GetPeriod() *OptionalUInt64

func (*LinuxCPU) GetQuota

func (x *LinuxCPU) GetQuota() *OptionalInt64

func (*LinuxCPU) GetRealtimePeriod

func (x *LinuxCPU) GetRealtimePeriod() *OptionalUInt64

func (*LinuxCPU) GetRealtimeRuntime

func (x *LinuxCPU) GetRealtimeRuntime() *OptionalInt64

func (*LinuxCPU) GetShares

func (x *LinuxCPU) GetShares() *OptionalUInt64

func (*LinuxCPU) MarshalToSizedBufferVT

func (m *LinuxCPU) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxCPU) MarshalToVT

func (m *LinuxCPU) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxCPU) MarshalVT

func (m *LinuxCPU) MarshalVT() (dAtA []byte, err error)

func (*LinuxCPU) ProtoMessage

func (*LinuxCPU) ProtoMessage()

func (*LinuxCPU) ProtoReflect

func (x *LinuxCPU) ProtoReflect() protoreflect.Message

func (*LinuxCPU) Reset

func (x *LinuxCPU) Reset()

func (*LinuxCPU) SizeVT

func (m *LinuxCPU) SizeVT() (n int)

func (*LinuxCPU) String

func (x *LinuxCPU) String() string

func (*LinuxCPU) UnmarshalVT

func (m *LinuxCPU) UnmarshalVT(dAtA []byte) error

type LinuxContainer

type LinuxContainer struct {
	Namespaces  []*LinuxNamespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Devices     []*LinuxDevice    `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"`
	Resources   *LinuxResources   `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	OomScoreAdj *OptionalInt      `protobuf:"bytes,4,opt,name=oom_score_adj,json=oomScoreAdj,proto3" json:"oom_score_adj,omitempty"`
	CgroupsPath string            `protobuf:"bytes,5,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"`
	// contains filtered or unexported fields
}

Container (linux) metadata.

func (*LinuxContainer) Descriptor

func (*LinuxContainer) Descriptor() ([]byte, []int)

Deprecated: Use LinuxContainer.ProtoReflect.Descriptor instead.

func (*LinuxContainer) GetCgroupsPath

func (x *LinuxContainer) GetCgroupsPath() string

func (*LinuxContainer) GetDevices

func (x *LinuxContainer) GetDevices() []*LinuxDevice

func (*LinuxContainer) GetNamespaces

func (x *LinuxContainer) GetNamespaces() []*LinuxNamespace

func (*LinuxContainer) GetOomScoreAdj

func (x *LinuxContainer) GetOomScoreAdj() *OptionalInt

func (*LinuxContainer) GetResources

func (x *LinuxContainer) GetResources() *LinuxResources

func (*LinuxContainer) MarshalToSizedBufferVT

func (m *LinuxContainer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxContainer) MarshalToVT

func (m *LinuxContainer) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxContainer) MarshalVT

func (m *LinuxContainer) MarshalVT() (dAtA []byte, err error)

func (*LinuxContainer) ProtoMessage

func (*LinuxContainer) ProtoMessage()

func (*LinuxContainer) ProtoReflect

func (x *LinuxContainer) ProtoReflect() protoreflect.Message

func (*LinuxContainer) Reset

func (x *LinuxContainer) Reset()

func (*LinuxContainer) SizeVT

func (m *LinuxContainer) SizeVT() (n int)

func (*LinuxContainer) String

func (x *LinuxContainer) String() string

func (*LinuxContainer) UnmarshalVT

func (m *LinuxContainer) UnmarshalVT(dAtA []byte) error

type LinuxContainerAdjustment

type LinuxContainerAdjustment struct {
	Devices     []*LinuxDevice  `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	Resources   *LinuxResources `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	CgroupsPath string          `protobuf:"bytes,3,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"`
	OomScoreAdj *OptionalInt    `protobuf:"bytes,4,opt,name=oom_score_adj,json=oomScoreAdj,proto3" json:"oom_score_adj,omitempty"`
	// contains filtered or unexported fields
}

Adjustments to (linux) resources.

func (*LinuxContainerAdjustment) Descriptor

func (*LinuxContainerAdjustment) Descriptor() ([]byte, []int)

Deprecated: Use LinuxContainerAdjustment.ProtoReflect.Descriptor instead.

func (*LinuxContainerAdjustment) GetCgroupsPath

func (x *LinuxContainerAdjustment) GetCgroupsPath() string

func (*LinuxContainerAdjustment) GetDevices

func (x *LinuxContainerAdjustment) GetDevices() []*LinuxDevice

func (*LinuxContainerAdjustment) GetOomScoreAdj

func (x *LinuxContainerAdjustment) GetOomScoreAdj() *OptionalInt

func (*LinuxContainerAdjustment) GetResources

func (x *LinuxContainerAdjustment) GetResources() *LinuxResources

func (*LinuxContainerAdjustment) MarshalToSizedBufferVT

func (m *LinuxContainerAdjustment) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxContainerAdjustment) MarshalToVT

func (m *LinuxContainerAdjustment) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxContainerAdjustment) MarshalVT

func (m *LinuxContainerAdjustment) MarshalVT() (dAtA []byte, err error)

func (*LinuxContainerAdjustment) ProtoMessage

func (*LinuxContainerAdjustment) ProtoMessage()

func (*LinuxContainerAdjustment) ProtoReflect

func (x *LinuxContainerAdjustment) ProtoReflect() protoreflect.Message

func (*LinuxContainerAdjustment) Reset

func (x *LinuxContainerAdjustment) Reset()

func (*LinuxContainerAdjustment) SizeVT

func (m *LinuxContainerAdjustment) SizeVT() (n int)

func (*LinuxContainerAdjustment) String

func (x *LinuxContainerAdjustment) String() string

func (*LinuxContainerAdjustment) UnmarshalVT

func (m *LinuxContainerAdjustment) UnmarshalVT(dAtA []byte) error

type LinuxContainerUpdate

type LinuxContainerUpdate struct {
	Resources *LinuxResources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

Updates to (linux) resources.

func (*LinuxContainerUpdate) Descriptor

func (*LinuxContainerUpdate) Descriptor() ([]byte, []int)

Deprecated: Use LinuxContainerUpdate.ProtoReflect.Descriptor instead.

func (*LinuxContainerUpdate) GetResources

func (x *LinuxContainerUpdate) GetResources() *LinuxResources

func (*LinuxContainerUpdate) MarshalToSizedBufferVT

func (m *LinuxContainerUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxContainerUpdate) MarshalToVT

func (m *LinuxContainerUpdate) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxContainerUpdate) MarshalVT

func (m *LinuxContainerUpdate) MarshalVT() (dAtA []byte, err error)

func (*LinuxContainerUpdate) ProtoMessage

func (*LinuxContainerUpdate) ProtoMessage()

func (*LinuxContainerUpdate) ProtoReflect

func (x *LinuxContainerUpdate) ProtoReflect() protoreflect.Message

func (*LinuxContainerUpdate) Reset

func (x *LinuxContainerUpdate) Reset()

func (*LinuxContainerUpdate) SizeVT

func (m *LinuxContainerUpdate) SizeVT() (n int)

func (*LinuxContainerUpdate) String

func (x *LinuxContainerUpdate) String() string

func (*LinuxContainerUpdate) UnmarshalVT

func (m *LinuxContainerUpdate) UnmarshalVT(dAtA []byte) error

type LinuxDevice

type LinuxDevice struct {
	Path     string            `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Type     string            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Major    int64             `protobuf:"varint,3,opt,name=major,proto3" json:"major,omitempty"`
	Minor    int64             `protobuf:"varint,4,opt,name=minor,proto3" json:"minor,omitempty"`
	FileMode *OptionalFileMode `protobuf:"bytes,5,opt,name=file_mode,json=fileMode,proto3" json:"file_mode,omitempty"`
	Uid      *OptionalUInt32   `protobuf:"bytes,6,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid      *OptionalUInt32   `protobuf:"bytes,7,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

A container (linux) device.

func FromOCILinuxDevices

func FromOCILinuxDevices(o []rspec.LinuxDevice) []*LinuxDevice

FromOCILinuxDevices returns a device slice from an OCI runtime Spec.

func (*LinuxDevice) AccessString

func (d *LinuxDevice) AccessString() string

AccessString returns an OCI access string for the device.

func (*LinuxDevice) Cmp

func (d *LinuxDevice) Cmp(v *LinuxDevice) bool

Cmp returns true if the devices are equal.

func (*LinuxDevice) Descriptor

func (*LinuxDevice) Descriptor() ([]byte, []int)

Deprecated: Use LinuxDevice.ProtoReflect.Descriptor instead.

func (*LinuxDevice) GetFileMode

func (x *LinuxDevice) GetFileMode() *OptionalFileMode

func (*LinuxDevice) GetGid

func (x *LinuxDevice) GetGid() *OptionalUInt32

func (*LinuxDevice) GetMajor

func (x *LinuxDevice) GetMajor() int64

func (*LinuxDevice) GetMinor

func (x *LinuxDevice) GetMinor() int64

func (*LinuxDevice) GetPath

func (x *LinuxDevice) GetPath() string

func (*LinuxDevice) GetType

func (x *LinuxDevice) GetType() string

func (*LinuxDevice) GetUid

func (x *LinuxDevice) GetUid() *OptionalUInt32

func (*LinuxDevice) IsMarkedForRemoval

func (d *LinuxDevice) IsMarkedForRemoval() (string, bool)

IsMarkedForRemoval checks if a LinuxDevice is marked for removal.

func (*LinuxDevice) MarshalToSizedBufferVT

func (m *LinuxDevice) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxDevice) MarshalToVT

func (m *LinuxDevice) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxDevice) MarshalVT

func (m *LinuxDevice) MarshalVT() (dAtA []byte, err error)

func (*LinuxDevice) ProtoMessage

func (*LinuxDevice) ProtoMessage()

func (*LinuxDevice) ProtoReflect

func (x *LinuxDevice) ProtoReflect() protoreflect.Message

func (*LinuxDevice) Reset

func (x *LinuxDevice) Reset()

func (*LinuxDevice) SizeVT

func (m *LinuxDevice) SizeVT() (n int)

func (*LinuxDevice) String

func (x *LinuxDevice) String() string

func (*LinuxDevice) ToOCI

func (d *LinuxDevice) ToOCI() rspec.LinuxDevice

ToOCI returns the linux devices for an OCI runtime Spec.

func (*LinuxDevice) UnmarshalVT

func (m *LinuxDevice) UnmarshalVT(dAtA []byte) error

type LinuxDeviceCgroup

type LinuxDeviceCgroup struct {
	Allow  bool           `protobuf:"varint,1,opt,name=allow,proto3" json:"allow,omitempty"`
	Type   string         `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Major  *OptionalInt64 `protobuf:"bytes,3,opt,name=major,proto3" json:"major,omitempty"`
	Minor  *OptionalInt64 `protobuf:"bytes,4,opt,name=minor,proto3" json:"minor,omitempty"`
	Access string         `protobuf:"bytes,5,opt,name=access,proto3" json:"access,omitempty"`
	// contains filtered or unexported fields
}

A linux device cgroup controller rule.

func (*LinuxDeviceCgroup) Descriptor

func (*LinuxDeviceCgroup) Descriptor() ([]byte, []int)

Deprecated: Use LinuxDeviceCgroup.ProtoReflect.Descriptor instead.

func (*LinuxDeviceCgroup) GetAccess

func (x *LinuxDeviceCgroup) GetAccess() string

func (*LinuxDeviceCgroup) GetAllow

func (x *LinuxDeviceCgroup) GetAllow() bool

func (*LinuxDeviceCgroup) GetMajor

func (x *LinuxDeviceCgroup) GetMajor() *OptionalInt64

func (*LinuxDeviceCgroup) GetMinor

func (x *LinuxDeviceCgroup) GetMinor() *OptionalInt64

func (*LinuxDeviceCgroup) GetType

func (x *LinuxDeviceCgroup) GetType() string

func (*LinuxDeviceCgroup) MarshalToSizedBufferVT

func (m *LinuxDeviceCgroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxDeviceCgroup) MarshalToVT

func (m *LinuxDeviceCgroup) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxDeviceCgroup) MarshalVT

func (m *LinuxDeviceCgroup) MarshalVT() (dAtA []byte, err error)

func (*LinuxDeviceCgroup) ProtoMessage

func (*LinuxDeviceCgroup) ProtoMessage()

func (*LinuxDeviceCgroup) ProtoReflect

func (x *LinuxDeviceCgroup) ProtoReflect() protoreflect.Message

func (*LinuxDeviceCgroup) Reset

func (x *LinuxDeviceCgroup) Reset()

func (*LinuxDeviceCgroup) SizeVT

func (m *LinuxDeviceCgroup) SizeVT() (n int)

func (*LinuxDeviceCgroup) String

func (x *LinuxDeviceCgroup) String() string

func (*LinuxDeviceCgroup) UnmarshalVT

func (m *LinuxDeviceCgroup) UnmarshalVT(dAtA []byte) error

type LinuxMemory

type LinuxMemory struct {
	Limit            *OptionalInt64  `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Reservation      *OptionalInt64  `protobuf:"bytes,2,opt,name=reservation,proto3" json:"reservation,omitempty"`
	Swap             *OptionalInt64  `protobuf:"bytes,3,opt,name=swap,proto3" json:"swap,omitempty"`
	Kernel           *OptionalInt64  `protobuf:"bytes,4,opt,name=kernel,proto3" json:"kernel,omitempty"`
	KernelTcp        *OptionalInt64  `protobuf:"bytes,5,opt,name=kernel_tcp,json=kernelTcp,proto3" json:"kernel_tcp,omitempty"`
	Swappiness       *OptionalUInt64 `protobuf:"bytes,6,opt,name=swappiness,proto3" json:"swappiness,omitempty"`
	DisableOomKiller *OptionalBool   `protobuf:"bytes,7,opt,name=disable_oom_killer,json=disableOomKiller,proto3" json:"disable_oom_killer,omitempty"`
	UseHierarchy     *OptionalBool   `protobuf:"bytes,8,opt,name=use_hierarchy,json=useHierarchy,proto3" json:"use_hierarchy,omitempty"`
	// contains filtered or unexported fields
}

Memory-related parts of (linux) resources.

func (*LinuxMemory) Descriptor

func (*LinuxMemory) Descriptor() ([]byte, []int)

Deprecated: Use LinuxMemory.ProtoReflect.Descriptor instead.

func (*LinuxMemory) GetDisableOomKiller

func (x *LinuxMemory) GetDisableOomKiller() *OptionalBool

func (*LinuxMemory) GetKernel

func (x *LinuxMemory) GetKernel() *OptionalInt64

func (*LinuxMemory) GetKernelTcp

func (x *LinuxMemory) GetKernelTcp() *OptionalInt64

func (*LinuxMemory) GetLimit

func (x *LinuxMemory) GetLimit() *OptionalInt64

func (*LinuxMemory) GetReservation

func (x *LinuxMemory) GetReservation() *OptionalInt64

func (*LinuxMemory) GetSwap

func (x *LinuxMemory) GetSwap() *OptionalInt64

func (*LinuxMemory) GetSwappiness

func (x *LinuxMemory) GetSwappiness() *OptionalUInt64

func (*LinuxMemory) GetUseHierarchy

func (x *LinuxMemory) GetUseHierarchy() *OptionalBool

func (*LinuxMemory) MarshalToSizedBufferVT

func (m *LinuxMemory) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxMemory) MarshalToVT

func (m *LinuxMemory) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxMemory) MarshalVT

func (m *LinuxMemory) MarshalVT() (dAtA []byte, err error)

func (*LinuxMemory) ProtoMessage

func (*LinuxMemory) ProtoMessage()

func (*LinuxMemory) ProtoReflect

func (x *LinuxMemory) ProtoReflect() protoreflect.Message

func (*LinuxMemory) Reset

func (x *LinuxMemory) Reset()

func (*LinuxMemory) SizeVT

func (m *LinuxMemory) SizeVT() (n int)

func (*LinuxMemory) String

func (x *LinuxMemory) String() string

func (*LinuxMemory) UnmarshalVT

func (m *LinuxMemory) UnmarshalVT(dAtA []byte) error

type LinuxNamespace

type LinuxNamespace struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

A linux namespace.

func FromOCILinuxNamespaces

func FromOCILinuxNamespaces(o []rspec.LinuxNamespace) []*LinuxNamespace

FromOCILinuxNamespaces returns a namespace slice from an OCI runtime Spec.

func (*LinuxNamespace) Descriptor

func (*LinuxNamespace) Descriptor() ([]byte, []int)

Deprecated: Use LinuxNamespace.ProtoReflect.Descriptor instead.

func (*LinuxNamespace) GetPath

func (x *LinuxNamespace) GetPath() string

func (*LinuxNamespace) GetType

func (x *LinuxNamespace) GetType() string

func (*LinuxNamespace) MarshalToSizedBufferVT

func (m *LinuxNamespace) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxNamespace) MarshalToVT

func (m *LinuxNamespace) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxNamespace) MarshalVT

func (m *LinuxNamespace) MarshalVT() (dAtA []byte, err error)

func (*LinuxNamespace) ProtoMessage

func (*LinuxNamespace) ProtoMessage()

func (*LinuxNamespace) ProtoReflect

func (x *LinuxNamespace) ProtoReflect() protoreflect.Message

func (*LinuxNamespace) Reset

func (x *LinuxNamespace) Reset()

func (*LinuxNamespace) SizeVT

func (m *LinuxNamespace) SizeVT() (n int)

func (*LinuxNamespace) String

func (x *LinuxNamespace) String() string

func (*LinuxNamespace) UnmarshalVT

func (m *LinuxNamespace) UnmarshalVT(dAtA []byte) error

type LinuxPids

type LinuxPids struct {
	Limit int64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

Pids-related parts of (linux) resources.

func (*LinuxPids) Descriptor

func (*LinuxPids) Descriptor() ([]byte, []int)

Deprecated: Use LinuxPids.ProtoReflect.Descriptor instead.

func (*LinuxPids) GetLimit

func (x *LinuxPids) GetLimit() int64

func (*LinuxPids) MarshalToSizedBufferVT

func (m *LinuxPids) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxPids) MarshalToVT

func (m *LinuxPids) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxPids) MarshalVT

func (m *LinuxPids) MarshalVT() (dAtA []byte, err error)

func (*LinuxPids) ProtoMessage

func (*LinuxPids) ProtoMessage()

func (*LinuxPids) ProtoReflect

func (x *LinuxPids) ProtoReflect() protoreflect.Message

func (*LinuxPids) Reset

func (x *LinuxPids) Reset()

func (*LinuxPids) SizeVT

func (m *LinuxPids) SizeVT() (n int)

func (*LinuxPids) String

func (x *LinuxPids) String() string

func (*LinuxPids) UnmarshalVT

func (m *LinuxPids) UnmarshalVT(dAtA []byte) error

type LinuxPodSandbox

type LinuxPodSandbox struct {
	PodOverhead  *LinuxResources   `protobuf:"bytes,1,opt,name=pod_overhead,json=podOverhead,proto3" json:"pod_overhead,omitempty"`
	PodResources *LinuxResources   `protobuf:"bytes,2,opt,name=pod_resources,json=podResources,proto3" json:"pod_resources,omitempty"`
	CgroupParent string            `protobuf:"bytes,3,opt,name=cgroup_parent,json=cgroupParent,proto3" json:"cgroup_parent,omitempty"`
	CgroupsPath  string            `protobuf:"bytes,4,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"` // for NRI v1 emulation
	Namespaces   []*LinuxNamespace `protobuf:"bytes,5,rep,name=namespaces,proto3" json:"namespaces,omitempty"`                      // for NRI v1 emulation
	Resources    *LinuxResources   `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"`                        // for NRI v1 emulation
	// contains filtered or unexported fields
}

PodSandbox linux-specific metadata

func (*LinuxPodSandbox) Descriptor

func (*LinuxPodSandbox) Descriptor() ([]byte, []int)

Deprecated: Use LinuxPodSandbox.ProtoReflect.Descriptor instead.

func (*LinuxPodSandbox) GetCgroupParent

func (x *LinuxPodSandbox) GetCgroupParent() string

func (*LinuxPodSandbox) GetCgroupsPath

func (x *LinuxPodSandbox) GetCgroupsPath() string

func (*LinuxPodSandbox) GetNamespaces

func (x *LinuxPodSandbox) GetNamespaces() []*LinuxNamespace

func (*LinuxPodSandbox) GetPodOverhead

func (x *LinuxPodSandbox) GetPodOverhead() *LinuxResources

func (*LinuxPodSandbox) GetPodResources

func (x *LinuxPodSandbox) GetPodResources() *LinuxResources

func (*LinuxPodSandbox) GetResources

func (x *LinuxPodSandbox) GetResources() *LinuxResources

func (*LinuxPodSandbox) MarshalToSizedBufferVT

func (m *LinuxPodSandbox) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxPodSandbox) MarshalToVT

func (m *LinuxPodSandbox) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxPodSandbox) MarshalVT

func (m *LinuxPodSandbox) MarshalVT() (dAtA []byte, err error)

func (*LinuxPodSandbox) ProtoMessage

func (*LinuxPodSandbox) ProtoMessage()

func (*LinuxPodSandbox) ProtoReflect

func (x *LinuxPodSandbox) ProtoReflect() protoreflect.Message

func (*LinuxPodSandbox) Reset

func (x *LinuxPodSandbox) Reset()

func (*LinuxPodSandbox) SizeVT

func (m *LinuxPodSandbox) SizeVT() (n int)

func (*LinuxPodSandbox) String

func (x *LinuxPodSandbox) String() string

func (*LinuxPodSandbox) UnmarshalVT

func (m *LinuxPodSandbox) UnmarshalVT(dAtA []byte) error

type LinuxResources

type LinuxResources struct {
	Memory         *LinuxMemory         `protobuf:"bytes,1,opt,name=memory,proto3" json:"memory,omitempty"`
	Cpu            *LinuxCPU            `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	HugepageLimits []*HugepageLimit     `protobuf:"bytes,3,rep,name=hugepage_limits,json=hugepageLimits,proto3" json:"hugepage_limits,omitempty"`
	BlockioClass   *OptionalString      `protobuf:"bytes,4,opt,name=blockio_class,json=blockioClass,proto3" json:"blockio_class,omitempty"`
	RdtClass       *OptionalString      `protobuf:"bytes,5,opt,name=rdt_class,json=rdtClass,proto3" json:"rdt_class,omitempty"`
	Unified        map[string]string    `protobuf:"bytes,6,rep,name=unified,proto3" json:"unified,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	Devices        []*LinuxDeviceCgroup `protobuf:"bytes,7,rep,name=devices,proto3" json:"devices,omitempty"` // for NRI v1 emulation
	Pids           *LinuxPids           `protobuf:"bytes,8,opt,name=pids,proto3" json:"pids,omitempty"`
	// contains filtered or unexported fields
}

Container (linux) resources.

func FromCRILinuxResources

func FromCRILinuxResources(c *cri.LinuxContainerResources) *LinuxResources

func FromOCILinuxResources

func FromOCILinuxResources(o *rspec.LinuxResources, _ map[string]string) *LinuxResources

FromOCILinuxResources returns resources from an OCI runtime Spec.

func (*LinuxResources) Copy

func (r *LinuxResources) Copy() *LinuxResources

Copy creates a copy of the resources.

func (*LinuxResources) Descriptor

func (*LinuxResources) Descriptor() ([]byte, []int)

Deprecated: Use LinuxResources.ProtoReflect.Descriptor instead.

func (*LinuxResources) GetBlockioClass

func (x *LinuxResources) GetBlockioClass() *OptionalString

func (*LinuxResources) GetCpu

func (x *LinuxResources) GetCpu() *LinuxCPU

func (*LinuxResources) GetDevices

func (x *LinuxResources) GetDevices() []*LinuxDeviceCgroup

func (*LinuxResources) GetHugepageLimits

func (x *LinuxResources) GetHugepageLimits() []*HugepageLimit

func (*LinuxResources) GetMemory

func (x *LinuxResources) GetMemory() *LinuxMemory

func (*LinuxResources) GetPids

func (x *LinuxResources) GetPids() *LinuxPids

func (*LinuxResources) GetRdtClass

func (x *LinuxResources) GetRdtClass() *OptionalString

func (*LinuxResources) GetUnified

func (x *LinuxResources) GetUnified() map[string]string

func (*LinuxResources) MarshalToSizedBufferVT

func (m *LinuxResources) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LinuxResources) MarshalToVT

func (m *LinuxResources) MarshalToVT(dAtA []byte) (int, error)

func (*LinuxResources) MarshalVT

func (m *LinuxResources) MarshalVT() (dAtA []byte, err error)

func (*LinuxResources) ProtoMessage

func (*LinuxResources) ProtoMessage()

func (*LinuxResources) ProtoReflect

func (x *LinuxResources) ProtoReflect() protoreflect.Message

func (*LinuxResources) Reset

func (x *LinuxResources) Reset()

func (*LinuxResources) SizeVT

func (m *LinuxResources) SizeVT() (n int)

func (*LinuxResources) String

func (x *LinuxResources) String() string

func (*LinuxResources) ToCRI

func (r *LinuxResources) ToCRI(oomScoreAdj int64) *cri.LinuxContainerResources

ToCRI returns resources for CRI.

func (*LinuxResources) ToOCI

func (r *LinuxResources) ToOCI() *rspec.LinuxResources

ToOCI returns resources for an OCI runtime Spec.

func (*LinuxResources) UnmarshalVT

func (m *LinuxResources) UnmarshalVT(dAtA []byte) error

type LogRequest

type LogRequest struct {
	Msg   string           `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Level LogRequest_Level `protobuf:"varint,2,opt,name=level,proto3,enum=nri.pkg.api.v1alpha1.LogRequest_Level" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*LogRequest) Descriptor

func (*LogRequest) Descriptor() ([]byte, []int)

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetLevel

func (x *LogRequest) GetLevel() LogRequest_Level

func (*LogRequest) GetMsg

func (x *LogRequest) GetMsg() string

func (*LogRequest) MarshalToSizedBufferVT

func (m *LogRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogRequest) MarshalToVT

func (m *LogRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LogRequest) MarshalVT

func (m *LogRequest) MarshalVT() (dAtA []byte, err error)

func (*LogRequest) ProtoMessage

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect

func (x *LogRequest) ProtoReflect() protoreflect.Message

func (*LogRequest) Reset

func (x *LogRequest) Reset()

func (*LogRequest) SizeVT

func (m *LogRequest) SizeVT() (n int)

func (*LogRequest) String

func (x *LogRequest) String() string

func (*LogRequest) UnmarshalVT

func (m *LogRequest) UnmarshalVT(dAtA []byte) error

type LogRequest_Level

type LogRequest_Level int32
const (
	LogRequest_LEVEL_UNSPECIFIED LogRequest_Level = 0
	LogRequest_LEVEL_DEBUG       LogRequest_Level = 1
	LogRequest_LEVEL_INFO        LogRequest_Level = 2
	LogRequest_LEVEL_WARN        LogRequest_Level = 3
	LogRequest_LEVEL_ERROR       LogRequest_Level = 4
)

func (LogRequest_Level) Descriptor

func (LogRequest_Level) Enum

func (LogRequest_Level) EnumDescriptor

func (LogRequest_Level) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogRequest_Level.Descriptor instead.

func (LogRequest_Level) Number

func (LogRequest_Level) String

func (x LogRequest_Level) String() string

func (LogRequest_Level) Type

type Mount

type Mount struct {
	Destination string   `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	Type        string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Source      string   `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Options     []string `protobuf:"bytes,4,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

A container mount.

func FromOCIMounts

func FromOCIMounts(o []rspec.Mount) []*Mount

FromOCIMounts returns a Mount slice for an OCI runtime Spec.

func (*Mount) Cmp

func (m *Mount) Cmp(v *Mount) bool

Cmp returns true if the mounts are equal.

func (*Mount) Descriptor

func (*Mount) Descriptor() ([]byte, []int)

Deprecated: Use Mount.ProtoReflect.Descriptor instead.

func (*Mount) GetDestination

func (x *Mount) GetDestination() string

func (*Mount) GetOptions

func (x *Mount) GetOptions() []string

func (*Mount) GetSource

func (x *Mount) GetSource() string

func (*Mount) GetType

func (x *Mount) GetType() string

func (*Mount) IsMarkedForRemoval

func (m *Mount) IsMarkedForRemoval() (string, bool)

IsMarkedForRemoval checks if a Mount is marked for removal.

func (*Mount) MarshalToSizedBufferVT

func (m *Mount) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Mount) MarshalToVT

func (m *Mount) MarshalToVT(dAtA []byte) (int, error)

func (*Mount) MarshalVT

func (m *Mount) MarshalVT() (dAtA []byte, err error)

func (*Mount) ProtoMessage

func (*Mount) ProtoMessage()

func (*Mount) ProtoReflect

func (x *Mount) ProtoReflect() protoreflect.Message

func (*Mount) Reset

func (x *Mount) Reset()

func (*Mount) SizeVT

func (m *Mount) SizeVT() (n int)

func (*Mount) String

func (x *Mount) String() string

func (*Mount) ToOCI

func (m *Mount) ToOCI(propagationQuery *string) rspec.Mount

ToOCI returns a Mount for an OCI runtime Spec.

func (*Mount) UnmarshalVT

func (m *Mount) UnmarshalVT(dAtA []byte) error

type OptionalBool

type OptionalBool struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional boolean value.

func Bool

func Bool(v interface{}) *OptionalBool

Bool creates an Optional wrapper from its argument.

func (*OptionalBool) Descriptor

func (*OptionalBool) Descriptor() ([]byte, []int)

Deprecated: Use OptionalBool.ProtoReflect.Descriptor instead.

func (*OptionalBool) Get

func (o *OptionalBool) Get() *bool

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalBool) GetValue

func (x *OptionalBool) GetValue() bool

func (*OptionalBool) MarshalToSizedBufferVT

func (m *OptionalBool) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalBool) MarshalToVT

func (m *OptionalBool) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalBool) MarshalVT

func (m *OptionalBool) MarshalVT() (dAtA []byte, err error)

func (*OptionalBool) ProtoMessage

func (*OptionalBool) ProtoMessage()

func (*OptionalBool) ProtoReflect

func (x *OptionalBool) ProtoReflect() protoreflect.Message

func (*OptionalBool) Reset

func (x *OptionalBool) Reset()

func (*OptionalBool) SizeVT

func (m *OptionalBool) SizeVT() (n int)

func (*OptionalBool) String

func (x *OptionalBool) String() string

func (*OptionalBool) UnmarshalVT

func (m *OptionalBool) UnmarshalVT(dAtA []byte) error

type OptionalFileMode

type OptionalFileMode struct {
	Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional value of file permissions.

func FileMode

func FileMode(v interface{}) *OptionalFileMode

FileMode creates an Optional wrapper from its argument.

func (*OptionalFileMode) Descriptor

func (*OptionalFileMode) Descriptor() ([]byte, []int)

Deprecated: Use OptionalFileMode.ProtoReflect.Descriptor instead.

func (*OptionalFileMode) Get

func (o *OptionalFileMode) Get() *os.FileMode

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalFileMode) GetValue

func (x *OptionalFileMode) GetValue() uint32

func (*OptionalFileMode) MarshalToSizedBufferVT

func (m *OptionalFileMode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalFileMode) MarshalToVT

func (m *OptionalFileMode) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalFileMode) MarshalVT

func (m *OptionalFileMode) MarshalVT() (dAtA []byte, err error)

func (*OptionalFileMode) ProtoMessage

func (*OptionalFileMode) ProtoMessage()

func (*OptionalFileMode) ProtoReflect

func (x *OptionalFileMode) ProtoReflect() protoreflect.Message

func (*OptionalFileMode) Reset

func (x *OptionalFileMode) Reset()

func (*OptionalFileMode) SizeVT

func (m *OptionalFileMode) SizeVT() (n int)

func (*OptionalFileMode) String

func (x *OptionalFileMode) String() string

func (*OptionalFileMode) UnmarshalVT

func (m *OptionalFileMode) UnmarshalVT(dAtA []byte) error

type OptionalInt

type OptionalInt struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional signed integer value.

func Int

func Int(v interface{}) *OptionalInt

Int creates an Optional wrapper from its argument.

func (*OptionalInt) Descriptor

func (*OptionalInt) Descriptor() ([]byte, []int)

Deprecated: Use OptionalInt.ProtoReflect.Descriptor instead.

func (*OptionalInt) Get

func (o *OptionalInt) Get() *int

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalInt) GetValue

func (x *OptionalInt) GetValue() int64

func (*OptionalInt) MarshalToSizedBufferVT

func (m *OptionalInt) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalInt) MarshalToVT

func (m *OptionalInt) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalInt) MarshalVT

func (m *OptionalInt) MarshalVT() (dAtA []byte, err error)

func (*OptionalInt) ProtoMessage

func (*OptionalInt) ProtoMessage()

func (*OptionalInt) ProtoReflect

func (x *OptionalInt) ProtoReflect() protoreflect.Message

func (*OptionalInt) Reset

func (x *OptionalInt) Reset()

func (*OptionalInt) SizeVT

func (m *OptionalInt) SizeVT() (n int)

func (*OptionalInt) String

func (x *OptionalInt) String() string

func (*OptionalInt) UnmarshalVT

func (m *OptionalInt) UnmarshalVT(dAtA []byte) error

type OptionalInt32

type OptionalInt32 struct {
	Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional 32-bit signed integer value.

func Int32

func Int32(v interface{}) *OptionalInt32

Int32 creates an Optional wrapper from its argument.

func (*OptionalInt32) Descriptor

func (*OptionalInt32) Descriptor() ([]byte, []int)

Deprecated: Use OptionalInt32.ProtoReflect.Descriptor instead.

func (*OptionalInt32) Get

func (o *OptionalInt32) Get() *int32

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalInt32) GetValue

func (x *OptionalInt32) GetValue() int32

func (*OptionalInt32) MarshalToSizedBufferVT

func (m *OptionalInt32) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalInt32) MarshalToVT

func (m *OptionalInt32) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalInt32) MarshalVT

func (m *OptionalInt32) MarshalVT() (dAtA []byte, err error)

func (*OptionalInt32) ProtoMessage

func (*OptionalInt32) ProtoMessage()

func (*OptionalInt32) ProtoReflect

func (x *OptionalInt32) ProtoReflect() protoreflect.Message

func (*OptionalInt32) Reset

func (x *OptionalInt32) Reset()

func (*OptionalInt32) SizeVT

func (m *OptionalInt32) SizeVT() (n int)

func (*OptionalInt32) String

func (x *OptionalInt32) String() string

func (*OptionalInt32) UnmarshalVT

func (m *OptionalInt32) UnmarshalVT(dAtA []byte) error

type OptionalInt64

type OptionalInt64 struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional 64-bit signed integer value.

func Int64

func Int64(v interface{}) *OptionalInt64

Int64 creates an Optional wrapper from its argument.

func (*OptionalInt64) Descriptor

func (*OptionalInt64) Descriptor() ([]byte, []int)

Deprecated: Use OptionalInt64.ProtoReflect.Descriptor instead.

func (*OptionalInt64) Get

func (o *OptionalInt64) Get() *int64

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalInt64) GetValue

func (x *OptionalInt64) GetValue() int64

func (*OptionalInt64) MarshalToSizedBufferVT

func (m *OptionalInt64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalInt64) MarshalToVT

func (m *OptionalInt64) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalInt64) MarshalVT

func (m *OptionalInt64) MarshalVT() (dAtA []byte, err error)

func (*OptionalInt64) ProtoMessage

func (*OptionalInt64) ProtoMessage()

func (*OptionalInt64) ProtoReflect

func (x *OptionalInt64) ProtoReflect() protoreflect.Message

func (*OptionalInt64) Reset

func (x *OptionalInt64) Reset()

func (*OptionalInt64) SizeVT

func (m *OptionalInt64) SizeVT() (n int)

func (*OptionalInt64) String

func (x *OptionalInt64) String() string

func (*OptionalInt64) UnmarshalVT

func (m *OptionalInt64) UnmarshalVT(dAtA []byte) error

type OptionalString

type OptionalString struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional string value.

func String

func String(v interface{}) *OptionalString

String creates an Optional wrapper from its argument.

func (*OptionalString) Descriptor

func (*OptionalString) Descriptor() ([]byte, []int)

Deprecated: Use OptionalString.ProtoReflect.Descriptor instead.

func (*OptionalString) Get

func (o *OptionalString) Get() *string

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalString) GetValue

func (x *OptionalString) GetValue() string

func (*OptionalString) MarshalToSizedBufferVT

func (m *OptionalString) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalString) MarshalToVT

func (m *OptionalString) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalString) MarshalVT

func (m *OptionalString) MarshalVT() (dAtA []byte, err error)

func (*OptionalString) ProtoMessage

func (*OptionalString) ProtoMessage()

func (*OptionalString) ProtoReflect

func (x *OptionalString) ProtoReflect() protoreflect.Message

func (*OptionalString) Reset

func (x *OptionalString) Reset()

func (*OptionalString) SizeVT

func (m *OptionalString) SizeVT() (n int)

func (*OptionalString) String

func (x *OptionalString) String() string

func (*OptionalString) UnmarshalVT

func (m *OptionalString) UnmarshalVT(dAtA []byte) error

type OptionalUInt32

type OptionalUInt32 struct {
	Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional 32-bit unsigned integer value.

func UInt32

func UInt32(v interface{}) *OptionalUInt32

UInt32 creates an Optional wrapper from its argument.

func (*OptionalUInt32) Descriptor

func (*OptionalUInt32) Descriptor() ([]byte, []int)

Deprecated: Use OptionalUInt32.ProtoReflect.Descriptor instead.

func (*OptionalUInt32) Get

func (o *OptionalUInt32) Get() *uint32

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalUInt32) GetValue

func (x *OptionalUInt32) GetValue() uint32

func (*OptionalUInt32) MarshalToSizedBufferVT

func (m *OptionalUInt32) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalUInt32) MarshalToVT

func (m *OptionalUInt32) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalUInt32) MarshalVT

func (m *OptionalUInt32) MarshalVT() (dAtA []byte, err error)

func (*OptionalUInt32) ProtoMessage

func (*OptionalUInt32) ProtoMessage()

func (*OptionalUInt32) ProtoReflect

func (x *OptionalUInt32) ProtoReflect() protoreflect.Message

func (*OptionalUInt32) Reset

func (x *OptionalUInt32) Reset()

func (*OptionalUInt32) SizeVT

func (m *OptionalUInt32) SizeVT() (n int)

func (*OptionalUInt32) String

func (x *OptionalUInt32) String() string

func (*OptionalUInt32) UnmarshalVT

func (m *OptionalUInt32) UnmarshalVT(dAtA []byte) error

type OptionalUInt64

type OptionalUInt64 struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional 64-bit unsigned integer value.

func UInt64

func UInt64(v interface{}) *OptionalUInt64

UInt64 creates an Optional wrapper from its argument.

func (*OptionalUInt64) Descriptor

func (*OptionalUInt64) Descriptor() ([]byte, []int)

Deprecated: Use OptionalUInt64.ProtoReflect.Descriptor instead.

func (*OptionalUInt64) Get

func (o *OptionalUInt64) Get() *uint64

Get returns nil if its value is unset or a pointer to the value itself.

func (*OptionalUInt64) GetValue

func (x *OptionalUInt64) GetValue() uint64

func (*OptionalUInt64) MarshalToSizedBufferVT

func (m *OptionalUInt64) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OptionalUInt64) MarshalToVT

func (m *OptionalUInt64) MarshalToVT(dAtA []byte) (int, error)

func (*OptionalUInt64) MarshalVT

func (m *OptionalUInt64) MarshalVT() (dAtA []byte, err error)

func (*OptionalUInt64) ProtoMessage

func (*OptionalUInt64) ProtoMessage()

func (*OptionalUInt64) ProtoReflect

func (x *OptionalUInt64) ProtoReflect() protoreflect.Message

func (*OptionalUInt64) Reset

func (x *OptionalUInt64) Reset()

func (*OptionalUInt64) SizeVT

func (m *OptionalUInt64) SizeVT() (n int)

func (*OptionalUInt64) String

func (x *OptionalUInt64) String() string

func (*OptionalUInt64) UnmarshalVT

func (m *OptionalUInt64) UnmarshalVT(dAtA []byte) error

type POSIXRlimit

type POSIXRlimit struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Hard uint64 `protobuf:"varint,2,opt,name=hard,proto3" json:"hard,omitempty"`
	Soft uint64 `protobuf:"varint,3,opt,name=soft,proto3" json:"soft,omitempty"`
	// contains filtered or unexported fields
}

Container rlimits

func (*POSIXRlimit) Descriptor

func (*POSIXRlimit) Descriptor() ([]byte, []int)

Deprecated: Use POSIXRlimit.ProtoReflect.Descriptor instead.

func (*POSIXRlimit) GetHard

func (x *POSIXRlimit) GetHard() uint64

func (*POSIXRlimit) GetSoft

func (x *POSIXRlimit) GetSoft() uint64

func (*POSIXRlimit) GetType

func (x *POSIXRlimit) GetType() string

func (*POSIXRlimit) MarshalToSizedBufferVT

func (m *POSIXRlimit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*POSIXRlimit) MarshalToVT

func (m *POSIXRlimit) MarshalToVT(dAtA []byte) (int, error)

func (*POSIXRlimit) MarshalVT

func (m *POSIXRlimit) MarshalVT() (dAtA []byte, err error)

func (*POSIXRlimit) ProtoMessage

func (*POSIXRlimit) ProtoMessage()

func (*POSIXRlimit) ProtoReflect

func (x *POSIXRlimit) ProtoReflect() protoreflect.Message

func (*POSIXRlimit) Reset

func (x *POSIXRlimit) Reset()

func (*POSIXRlimit) SizeVT

func (m *POSIXRlimit) SizeVT() (n int)

func (*POSIXRlimit) String

func (x *POSIXRlimit) String() string

func (*POSIXRlimit) UnmarshalVT

func (m *POSIXRlimit) UnmarshalVT(dAtA []byte) error

type Plugin

type Plugin interface {
	// Configure the plugin and get its event subscription.
	Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
	// Synchronize the plugin with the state of the runtime.
	Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error)
	// Shutdown a plugin (let it know the runtime is going down).
	Shutdown(context.Context, *Empty) (*Empty, error)
	// CreateContainer relays the corresponding request to the plugin. In
	// response, the plugin can adjust the container being created, and
	// update other containers in the runtime. Container adjustment can
	// alter labels, annotations, mounts, devices, environment variables,
	// OCI hooks, and assigned container resources. Updates can alter
	// assigned container resources.
	CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
	// UpdateContainer relays the corresponding request to the plugin.
	// The plugin can alter how the container is updated and request updates
	// to additional containers in the runtime.
	UpdateContainer(context.Context, *UpdateContainerRequest) (*UpdateContainerResponse, error)
	// StopContainer relays the corresponding request to the plugin. The plugin
	// can update any of the remaining containers in the runtime in response.
	StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error)
	// StateChange relays any remaining pod or container lifecycle/state change
	// events the plugin has subscribed for. These can be used to trigger any
	// plugin-specific processing which needs to occur in connection with any of
	// these events.
	StateChange(context.Context, *StateChangeEvent) (*Empty, error)
}

Plugin is the API NRI uses to interact with plugins. It is used to - configure a plugin and subscribe it for lifecycle events - synchronize the state of a plugin with that of the runtime - hook a plugin into the lifecycle events of its interest

During configuration the plugin tells the runtime which lifecycle events it wishes to get hooked into. Once configured, the plugin is synchronized with the runtime by receiving the list of pods and containers known to the runtime. The plugin can request changes to any of the containers in response. After initial synchronization the plugin starts receiving the events it subscribed for as they occur in the runtime. For container creation, update, and stop events, the plugin can request changes, both to the container that triggered the event or any other existing container in the runtime.

For a subset of the container lifecycle events, NRI defines an additional Post-variant of the event. These variants are defined for CreateContainer, StartContainer, and UpdateContainer. For creation and update, these events can be used by plugins to discover the full extent of changes applied to the container, including any changes made by other active plugins.

go:plugin type=plugin version=1

type PluginPlugin

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

func NewPluginPlugin

func NewPluginPlugin(ctx context.Context, opts ...wazeroConfigOption) (*PluginPlugin, error)

func (*PluginPlugin) Load

func (p *PluginPlugin) Load(ctx context.Context, pluginPath string, hostFunctions HostFunctions) (plugin, error)

type PluginService

func NewPluginClient

func NewPluginClient(client *ttrpc.Client) PluginService

type PodSandbox

type PodSandbox struct {
	Id             string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name           string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Uid            string            `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	Namespace      string            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels         map[string]string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	Annotations    map[string]string `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	RuntimeHandler string            `protobuf:"bytes,7,opt,name=runtime_handler,json=runtimeHandler,proto3" json:"runtime_handler,omitempty"`
	Linux          *LinuxPodSandbox  `protobuf:"bytes,8,opt,name=linux,proto3" json:"linux,omitempty"`
	Pid            uint32            `protobuf:"varint,9,opt,name=pid,proto3" json:"pid,omitempty"` // for NRI v1 emulation
	Ips            []string          `protobuf:"bytes,10,rep,name=ips,proto3" json:"ips,omitempty"`
	// contains filtered or unexported fields
}

Pod metadata that is considered relevant for a plugin.

func (*PodSandbox) Descriptor

func (*PodSandbox) Descriptor() ([]byte, []int)

Deprecated: Use PodSandbox.ProtoReflect.Descriptor instead.

func (*PodSandbox) GetAnnotations

func (x *PodSandbox) GetAnnotations() map[string]string

func (*PodSandbox) GetId

func (x *PodSandbox) GetId() string

func (*PodSandbox) GetIps

func (x *PodSandbox) GetIps() []string

func (*PodSandbox) GetLabels

func (x *PodSandbox) GetLabels() map[string]string

func (*PodSandbox) GetLinux

func (x *PodSandbox) GetLinux() *LinuxPodSandbox

func (*PodSandbox) GetName

func (x *PodSandbox) GetName() string

func (*PodSandbox) GetNamespace

func (x *PodSandbox) GetNamespace() string

func (*PodSandbox) GetPid

func (x *PodSandbox) GetPid() uint32

func (*PodSandbox) GetRuntimeHandler

func (x *PodSandbox) GetRuntimeHandler() string

func (*PodSandbox) GetUid

func (x *PodSandbox) GetUid() string

func (*PodSandbox) MarshalToSizedBufferVT

func (m *PodSandbox) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PodSandbox) MarshalToVT

func (m *PodSandbox) MarshalToVT(dAtA []byte) (int, error)

func (*PodSandbox) MarshalVT

func (m *PodSandbox) MarshalVT() (dAtA []byte, err error)

func (*PodSandbox) ProtoMessage

func (*PodSandbox) ProtoMessage()

func (*PodSandbox) ProtoReflect

func (x *PodSandbox) ProtoReflect() protoreflect.Message

func (*PodSandbox) Reset

func (x *PodSandbox) Reset()

func (*PodSandbox) SizeVT

func (m *PodSandbox) SizeVT() (n int)

func (*PodSandbox) String

func (x *PodSandbox) String() string

func (*PodSandbox) UnmarshalVT

func (m *PodSandbox) UnmarshalVT(dAtA []byte) error

type PostCreateContainerRequest

type PostCreateContainerRequest = StateChangeEvent

nolint

type PostCreateContainerResponse

type PostCreateContainerResponse = Empty

nolint

type PostStartContainerRequest

type PostStartContainerRequest = StateChangeEvent

nolint

type PostStartContainerResponse

type PostStartContainerResponse = Empty

nolint

type PostUpdateContainerRequest

type PostUpdateContainerRequest = StateChangeEvent

nolint

type PostUpdateContainerResponse

type PostUpdateContainerResponse = Empty

nolint

type RegisterPluginRequest

type RegisterPluginRequest struct {

	// Name of the plugin to register.
	PluginName string `protobuf:"bytes,1,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"`
	// Plugin invocation index. Plugins are called in ascending index order.
	PluginIdx string `protobuf:"bytes,2,opt,name=plugin_idx,json=pluginIdx,proto3" json:"plugin_idx,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterPluginRequest) Descriptor

func (*RegisterPluginRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterPluginRequest.ProtoReflect.Descriptor instead.

func (*RegisterPluginRequest) GetPluginIdx

func (x *RegisterPluginRequest) GetPluginIdx() string

func (*RegisterPluginRequest) GetPluginName

func (x *RegisterPluginRequest) GetPluginName() string

func (*RegisterPluginRequest) MarshalToSizedBufferVT

func (m *RegisterPluginRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RegisterPluginRequest) MarshalToVT

func (m *RegisterPluginRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RegisterPluginRequest) MarshalVT

func (m *RegisterPluginRequest) MarshalVT() (dAtA []byte, err error)

func (*RegisterPluginRequest) ProtoMessage

func (*RegisterPluginRequest) ProtoMessage()

func (*RegisterPluginRequest) ProtoReflect

func (x *RegisterPluginRequest) ProtoReflect() protoreflect.Message

func (*RegisterPluginRequest) Reset

func (x *RegisterPluginRequest) Reset()

func (*RegisterPluginRequest) SizeVT

func (m *RegisterPluginRequest) SizeVT() (n int)

func (*RegisterPluginRequest) String

func (x *RegisterPluginRequest) String() string

func (*RegisterPluginRequest) UnmarshalVT

func (m *RegisterPluginRequest) UnmarshalVT(dAtA []byte) error

type RemoveContainerRequest

type RemoveContainerRequest = StateChangeEvent

nolint

type RemoveContainerResponse

type RemoveContainerResponse = Empty

nolint

type RemovePodSandboxRequest

type RemovePodSandboxRequest = StateChangeEvent

nolint

type RemovePodSandboxResponse

type RemovePodSandboxResponse = Empty

nolint

type RunPodSandboxRequest

type RunPodSandboxRequest = StateChangeEvent

nolint

type RunPodSandboxResponse

type RunPodSandboxResponse = Empty

nolint

type RuntimeService

type RuntimeService interface {
	RegisterPlugin(context.Context, *RegisterPluginRequest) (*Empty, error)
	UpdateContainers(context.Context, *UpdateContainersRequest) (*UpdateContainersResponse, error)
}

func NewRuntimeClient

func NewRuntimeClient(client *ttrpc.Client) RuntimeService

type ShutdownRequest

type ShutdownRequest = Empty

nolint

type ShutdownResponse

type ShutdownResponse = Empty

nolint

type StartContainerRequest

type StartContainerRequest = StateChangeEvent

nolint

type StartContainerResponse

type StartContainerResponse = Empty

nolint

type StateChangeEvent

type StateChangeEvent struct {

	// Event type of notification.
	Event Event `protobuf:"varint,1,opt,name=event,proto3,enum=nri.pkg.api.v1alpha1.Event" json:"event,omitempty"`
	// Pod this notification is sent for. If this event is related to a container,
	// pod is set to the pod of the container.
	Pod *PodSandbox `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"`
	// Container this notification is sent for. If the event is related to a pod,
	// container is nil.
	Container *Container `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

func (*StateChangeEvent) Descriptor

func (*StateChangeEvent) Descriptor() ([]byte, []int)

Deprecated: Use StateChangeEvent.ProtoReflect.Descriptor instead.

func (*StateChangeEvent) GetContainer

func (x *StateChangeEvent) GetContainer() *Container

func (*StateChangeEvent) GetEvent

func (x *StateChangeEvent) GetEvent() Event

func (*StateChangeEvent) GetPod

func (x *StateChangeEvent) GetPod() *PodSandbox

func (*StateChangeEvent) MarshalToSizedBufferVT

func (m *StateChangeEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StateChangeEvent) MarshalToVT

func (m *StateChangeEvent) MarshalToVT(dAtA []byte) (int, error)

func (*StateChangeEvent) MarshalVT

func (m *StateChangeEvent) MarshalVT() (dAtA []byte, err error)

func (*StateChangeEvent) ProtoMessage

func (*StateChangeEvent) ProtoMessage()

func (*StateChangeEvent) ProtoReflect

func (x *StateChangeEvent) ProtoReflect() protoreflect.Message

func (*StateChangeEvent) Reset

func (x *StateChangeEvent) Reset()

func (*StateChangeEvent) SizeVT

func (m *StateChangeEvent) SizeVT() (n int)

func (*StateChangeEvent) String

func (x *StateChangeEvent) String() string

func (*StateChangeEvent) UnmarshalVT

func (m *StateChangeEvent) UnmarshalVT(dAtA []byte) error

type StateChangeResponse

type StateChangeResponse = Empty

nolint

type StopContainerRequest

type StopContainerRequest struct {

	// Pod of container being stopped.
	Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	// Container being stopped.
	Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

func (*StopContainerRequest) Descriptor

func (*StopContainerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopContainerRequest.ProtoReflect.Descriptor instead.

func (*StopContainerRequest) GetContainer

func (x *StopContainerRequest) GetContainer() *Container

func (*StopContainerRequest) GetPod

func (x *StopContainerRequest) GetPod() *PodSandbox

func (*StopContainerRequest) MarshalToSizedBufferVT

func (m *StopContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopContainerRequest) MarshalToVT

func (m *StopContainerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StopContainerRequest) MarshalVT

func (m *StopContainerRequest) MarshalVT() (dAtA []byte, err error)

func (*StopContainerRequest) ProtoMessage

func (*StopContainerRequest) ProtoMessage()

func (*StopContainerRequest) ProtoReflect

func (x *StopContainerRequest) ProtoReflect() protoreflect.Message

func (*StopContainerRequest) Reset

func (x *StopContainerRequest) Reset()

func (*StopContainerRequest) SizeVT

func (m *StopContainerRequest) SizeVT() (n int)

func (*StopContainerRequest) String

func (x *StopContainerRequest) String() string

func (*StopContainerRequest) UnmarshalVT

func (m *StopContainerRequest) UnmarshalVT(dAtA []byte) error

type StopContainerResponse

type StopContainerResponse struct {

	// Requested updates to containers.
	Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"`
	// contains filtered or unexported fields
}

func (*StopContainerResponse) Descriptor

func (*StopContainerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopContainerResponse.ProtoReflect.Descriptor instead.

func (*StopContainerResponse) GetUpdate

func (x *StopContainerResponse) GetUpdate() []*ContainerUpdate

func (*StopContainerResponse) MarshalToSizedBufferVT

func (m *StopContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopContainerResponse) MarshalToVT

func (m *StopContainerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StopContainerResponse) MarshalVT

func (m *StopContainerResponse) MarshalVT() (dAtA []byte, err error)

func (*StopContainerResponse) ProtoMessage

func (*StopContainerResponse) ProtoMessage()

func (*StopContainerResponse) ProtoReflect

func (x *StopContainerResponse) ProtoReflect() protoreflect.Message

func (*StopContainerResponse) Reset

func (x *StopContainerResponse) Reset()

func (*StopContainerResponse) SizeVT

func (m *StopContainerResponse) SizeVT() (n int)

func (*StopContainerResponse) String

func (x *StopContainerResponse) String() string

func (*StopContainerResponse) UnmarshalVT

func (m *StopContainerResponse) UnmarshalVT(dAtA []byte) error

type StopPodSandboxRequest

type StopPodSandboxRequest = StateChangeEvent

nolint

type StopPodSandboxResponse

type StopPodSandboxResponse = Empty

nolint

type SynchronizeRequest

type SynchronizeRequest struct {

	// Pods known to the runtime.
	Pods []*PodSandbox `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"`
	// Containers known to the runtime.
	Containers []*Container `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"`
	// Whether there are more pods and containers to follow.
	More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeRequest) Descriptor

func (*SynchronizeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.

func (*SynchronizeRequest) GetContainers

func (x *SynchronizeRequest) GetContainers() []*Container

func (*SynchronizeRequest) GetMore

func (x *SynchronizeRequest) GetMore() bool

func (*SynchronizeRequest) GetPods

func (x *SynchronizeRequest) GetPods() []*PodSandbox

func (*SynchronizeRequest) MarshalToSizedBufferVT

func (m *SynchronizeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SynchronizeRequest) MarshalToVT

func (m *SynchronizeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SynchronizeRequest) MarshalVT

func (m *SynchronizeRequest) MarshalVT() (dAtA []byte, err error)

func (*SynchronizeRequest) ProtoMessage

func (*SynchronizeRequest) ProtoMessage()

func (*SynchronizeRequest) ProtoReflect

func (x *SynchronizeRequest) ProtoReflect() protoreflect.Message

func (*SynchronizeRequest) Reset

func (x *SynchronizeRequest) Reset()

func (*SynchronizeRequest) SizeVT

func (m *SynchronizeRequest) SizeVT() (n int)

func (*SynchronizeRequest) String

func (x *SynchronizeRequest) String() string

func (*SynchronizeRequest) UnmarshalVT

func (m *SynchronizeRequest) UnmarshalVT(dAtA []byte) error

type SynchronizeResponse

type SynchronizeResponse struct {

	// Updates to containers requested by the plugin.
	Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"`
	// Whether the client is able to handle more advertised pods and containers.
	More bool `protobuf:"varint,2,opt,name=more,proto3" json:"more,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeResponse) Descriptor

func (*SynchronizeResponse) Descriptor() ([]byte, []int)

Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.

func (*SynchronizeResponse) GetMore

func (x *SynchronizeResponse) GetMore() bool

func (*SynchronizeResponse) GetUpdate

func (x *SynchronizeResponse) GetUpdate() []*ContainerUpdate

func (*SynchronizeResponse) MarshalToSizedBufferVT

func (m *SynchronizeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SynchronizeResponse) MarshalToVT

func (m *SynchronizeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SynchronizeResponse) MarshalVT

func (m *SynchronizeResponse) MarshalVT() (dAtA []byte, err error)

func (*SynchronizeResponse) ProtoMessage

func (*SynchronizeResponse) ProtoMessage()

func (*SynchronizeResponse) ProtoReflect

func (x *SynchronizeResponse) ProtoReflect() protoreflect.Message

func (*SynchronizeResponse) Reset

func (x *SynchronizeResponse) Reset()

func (*SynchronizeResponse) SizeVT

func (m *SynchronizeResponse) SizeVT() (n int)

func (*SynchronizeResponse) String

func (x *SynchronizeResponse) String() string

func (*SynchronizeResponse) UnmarshalVT

func (m *SynchronizeResponse) UnmarshalVT(dAtA []byte) error

type UpdateContainerRequest

type UpdateContainerRequest struct {

	// Pod of container being updated.
	Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	// Container being updated.
	Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// Resources to update.
	LinuxResources *LinuxResources `protobuf:"bytes,3,opt,name=linux_resources,json=linuxResources,proto3" json:"linux_resources,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateContainerRequest) Descriptor

func (*UpdateContainerRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateContainerRequest.ProtoReflect.Descriptor instead.

func (*UpdateContainerRequest) GetContainer

func (x *UpdateContainerRequest) GetContainer() *Container

func (*UpdateContainerRequest) GetLinuxResources

func (x *UpdateContainerRequest) GetLinuxResources() *LinuxResources

func (*UpdateContainerRequest) GetPod

func (x *UpdateContainerRequest) GetPod() *PodSandbox

func (*UpdateContainerRequest) MarshalToSizedBufferVT

func (m *UpdateContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateContainerRequest) MarshalToVT

func (m *UpdateContainerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateContainerRequest) MarshalVT

func (m *UpdateContainerRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateContainerRequest) ProtoMessage

func (*UpdateContainerRequest) ProtoMessage()

func (*UpdateContainerRequest) ProtoReflect

func (x *UpdateContainerRequest) ProtoReflect() protoreflect.Message

func (*UpdateContainerRequest) Reset

func (x *UpdateContainerRequest) Reset()

func (*UpdateContainerRequest) SizeVT

func (m *UpdateContainerRequest) SizeVT() (n int)

func (*UpdateContainerRequest) String

func (x *UpdateContainerRequest) String() string

func (*UpdateContainerRequest) UnmarshalVT

func (m *UpdateContainerRequest) UnmarshalVT(dAtA []byte) error

type UpdateContainerResponse

type UpdateContainerResponse struct {

	// Requested updates to containers.
	Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"`
	// Requested eviction of containers.
	Evict []*ContainerEviction `protobuf:"bytes,2,rep,name=evict,proto3" json:"evict,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateContainerResponse) Descriptor

func (*UpdateContainerResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateContainerResponse.ProtoReflect.Descriptor instead.

func (*UpdateContainerResponse) GetEvict

func (x *UpdateContainerResponse) GetEvict() []*ContainerEviction

func (*UpdateContainerResponse) GetUpdate

func (x *UpdateContainerResponse) GetUpdate() []*ContainerUpdate

func (*UpdateContainerResponse) MarshalToSizedBufferVT

func (m *UpdateContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateContainerResponse) MarshalToVT

func (m *UpdateContainerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateContainerResponse) MarshalVT

func (m *UpdateContainerResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateContainerResponse) ProtoMessage

func (*UpdateContainerResponse) ProtoMessage()

func (*UpdateContainerResponse) ProtoReflect

func (x *UpdateContainerResponse) ProtoReflect() protoreflect.Message

func (*UpdateContainerResponse) Reset

func (x *UpdateContainerResponse) Reset()

func (*UpdateContainerResponse) SizeVT

func (m *UpdateContainerResponse) SizeVT() (n int)

func (*UpdateContainerResponse) String

func (x *UpdateContainerResponse) String() string

func (*UpdateContainerResponse) UnmarshalVT

func (m *UpdateContainerResponse) UnmarshalVT(dAtA []byte) error

type UpdateContainersRequest

type UpdateContainersRequest struct {

	// List of containers to update.
	Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"`
	// List of containers to evict.
	Evict []*ContainerEviction `protobuf:"bytes,2,rep,name=evict,proto3" json:"evict,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateContainersRequest) Descriptor

func (*UpdateContainersRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateContainersRequest.ProtoReflect.Descriptor instead.

func (*UpdateContainersRequest) GetEvict

func (x *UpdateContainersRequest) GetEvict() []*ContainerEviction

func (*UpdateContainersRequest) GetUpdate

func (x *UpdateContainersRequest) GetUpdate() []*ContainerUpdate

func (*UpdateContainersRequest) MarshalToSizedBufferVT

func (m *UpdateContainersRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateContainersRequest) MarshalToVT

func (m *UpdateContainersRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateContainersRequest) MarshalVT

func (m *UpdateContainersRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateContainersRequest) ProtoMessage

func (*UpdateContainersRequest) ProtoMessage()

func (*UpdateContainersRequest) ProtoReflect

func (x *UpdateContainersRequest) ProtoReflect() protoreflect.Message

func (*UpdateContainersRequest) Reset

func (x *UpdateContainersRequest) Reset()

func (*UpdateContainersRequest) SizeVT

func (m *UpdateContainersRequest) SizeVT() (n int)

func (*UpdateContainersRequest) String

func (x *UpdateContainersRequest) String() string

func (*UpdateContainersRequest) UnmarshalVT

func (m *UpdateContainersRequest) UnmarshalVT(dAtA []byte) error

type UpdateContainersResponse

type UpdateContainersResponse struct {

	// Containers that the runtime failed to update.
	Failed []*ContainerUpdate `protobuf:"bytes,1,rep,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateContainersResponse) Descriptor

func (*UpdateContainersResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateContainersResponse.ProtoReflect.Descriptor instead.

func (*UpdateContainersResponse) GetFailed

func (x *UpdateContainersResponse) GetFailed() []*ContainerUpdate

func (*UpdateContainersResponse) MarshalToSizedBufferVT

func (m *UpdateContainersResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateContainersResponse) MarshalToVT

func (m *UpdateContainersResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateContainersResponse) MarshalVT

func (m *UpdateContainersResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateContainersResponse) ProtoMessage

func (*UpdateContainersResponse) ProtoMessage()

func (*UpdateContainersResponse) ProtoReflect

func (x *UpdateContainersResponse) ProtoReflect() protoreflect.Message

func (*UpdateContainersResponse) Reset

func (x *UpdateContainersResponse) Reset()

func (*UpdateContainersResponse) SizeVT

func (m *UpdateContainersResponse) SizeVT() (n int)

func (*UpdateContainersResponse) String

func (x *UpdateContainersResponse) String() string

func (*UpdateContainersResponse) UnmarshalVT

func (m *UpdateContainersResponse) UnmarshalVT(dAtA []byte) error

type WazeroConfig

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

type WazeroNewRuntime

type WazeroNewRuntime func(context.Context) (wazero.Runtime, error)

func DefaultWazeroRuntime

func DefaultWazeroRuntime() WazeroNewRuntime

Source Files

adjustment.go api.pb.go api_host.pb.go api_options.pb.go api_service.pb.go api_ttrpc.pb.go api_vtproto.pb.go device.go doc.go env.go event.go helpers.go hooks.go mount.go namespace.go optional.go plugin.go resources.go timeouts.go update.go

Version
v0.9.0 (latest)
Published
Dec 12, 2024
Platform
linux/amd64
Imports
21 packages
Last checked
2 months ago

Tools for package owners.