api

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 21 Imported by: 41

Documentation

Overview

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

Index

Constants

View Source 
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"
)
View Source 
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
)
View Source 
const PluginPluginAPIVersion = 1
View Source 
const (
	// SELinuxRelabel is a Mount pseudo-option to request relabeling.
	SELinuxRelabel = "relabel"
)
View Source 
const (
	// ValidEvents is the event mask of all valid events.
	ValidEvents = EventMask((1 << (Event_LAST - 1)) - 1)
)

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
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 added in v0.7.0 

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 added in v0.9.0 

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 added in v0.9.0 

func WazeroModuleConfig(moduleConfig wazero.ModuleConfig) wazeroConfigOption

func WazeroRuntime added in v0.9.0 

func WazeroRuntime(newRuntime WazeroNewRuntime) wazeroConfigOption

Types

type CDIDevice added in v0.7.0 

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 deprecated added in v0.7.0 

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

Deprecated: Use CDIDevice.ProtoReflect.Descriptor instead.

func (*CDIDevice) GetName added in v0.7.0 

func (x *CDIDevice) GetName() string

func (*CDIDevice) MarshalToSizedBufferVT added in v0.9.0 

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

func (*CDIDevice) MarshalToVT added in v0.9.0 

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

func (*CDIDevice) MarshalVT added in v0.9.0 

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

func (*CDIDevice) ProtoMessage added in v0.7.0 

func (*CDIDevice) ProtoMessage()

func (*CDIDevice) ProtoReflect added in v0.7.0 

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

func (*CDIDevice) Reset added in v0.7.0 

func (x *CDIDevice) Reset()

func (*CDIDevice) SizeVT added in v0.9.0 

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

func (*CDIDevice) String added in v0.7.0 

func (x *CDIDevice) String() string

func (*CDIDevice) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use ConfigureRequest.ProtoReflect.Descriptor instead.

func (*ConfigureRequest) GetConfig 

func (x *ConfigureRequest) GetConfig() string

func (*ConfigureRequest) GetRegistrationTimeout added in v0.7.0 

func (x *ConfigureRequest) GetRegistrationTimeout() int64

func (*ConfigureRequest) GetRequestTimeout added in v0.7.0 

func (x *ConfigureRequest) GetRequestTimeout() int64

func (*ConfigureRequest) GetRuntimeName 

func (x *ConfigureRequest) GetRuntimeName() string

func (*ConfigureRequest) GetRuntimeVersion 

func (x *ConfigureRequest) GetRuntimeVersion() string

func (*ConfigureRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*ConfigureRequest) MarshalToVT added in v0.9.0 

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

func (*ConfigureRequest) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*ConfigureRequest) String 

func (x *ConfigureRequest) String() string

func (*ConfigureRequest) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.

func (*ConfigureResponse) GetEvents 

func (x *ConfigureResponse) GetEvents() int32

func (*ConfigureResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*ConfigureResponse) MarshalToVT added in v0.9.0 

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

func (*ConfigureResponse) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*ConfigureResponse) String 

func (x *ConfigureResponse) String() string

func (*ConfigureResponse) UnmarshalVT added in v0.9.0 

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 `` /* 153-byte string literal not displayed */
	Annotations  map[string]string `` /* 163-byte string literal not displayed */
	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 deprecated 

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 added in v0.4.0 

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

func (*Container) GetState 

func (x *Container) GetState() ContainerState

func (*Container) MarshalToSizedBufferVT added in v0.9.0 

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

func (*Container) MarshalToVT added in v0.9.0 

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

func (*Container) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*Container) String 

func (x *Container) String() string

func (*Container) UnmarshalVT added in v0.9.0 

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

type ContainerAdjustment 

type ContainerAdjustment struct {
	Annotations map[string]string         `` /* 163-byte string literal not displayed */
	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 added in v0.7.0 

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 added in v0.4.0 

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

func (*ContainerAdjustment) Descriptor deprecated 

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

Deprecated: Use ContainerAdjustment.ProtoReflect.Descriptor instead.

func (*ContainerAdjustment) GetAnnotations 

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

func (*ContainerAdjustment) GetCDIDevices added in v0.7.0 

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 (x *ContainerAdjustment) GetLinux() *LinuxContainerAdjustment

func (*ContainerAdjustment) GetMounts 

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

func (*ContainerAdjustment) GetRlimits added in v0.4.0 

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

func (*ContainerAdjustment) MarshalToSizedBufferVT added in v0.9.0 

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

func (*ContainerAdjustment) MarshalToVT added in v0.9.0 

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

func (*ContainerAdjustment) MarshalVT added in v0.9.0 

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 added in v0.7.0 

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

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

func (*ContainerAdjustment) SetLinuxPidLimits added in v0.7.0 

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 added in v0.9.0 

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

func (*ContainerAdjustment) String 

func (x *ContainerAdjustment) String() string

func (*ContainerAdjustment) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*ContainerEviction) MarshalToVT added in v0.9.0 

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

func (*ContainerEviction) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*ContainerEviction) String 

func (x *ContainerEviction) String() string

func (*ContainerEviction) UnmarshalVT added in v0.9.0 

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) Descriptor() protoreflect.EnumDescriptor

func (ContainerState) Enum 

func (x ContainerState) Enum() *ContainerState

func (ContainerState) EnumDescriptor deprecated 

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

Deprecated: Use ContainerState.Descriptor instead.

func (ContainerState) Number 

func (x ContainerState) Number() protoreflect.EnumNumber

func (ContainerState) String 

func (x ContainerState) String() string

func (ContainerState) Type 

func (ContainerState) Type() protoreflect.EnumType

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 deprecated 

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 added in v0.9.0 

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

func (*ContainerUpdate) MarshalToVT added in v0.9.0 

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

func (*ContainerUpdate) MarshalVT added in v0.9.0 

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 added in v0.7.0 

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 added in v0.9.0 

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

func (*ContainerUpdate) String 

func (x *ContainerUpdate) String() string

func (*ContainerUpdate) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*CreateContainerRequest) MarshalToVT added in v0.9.0 

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

func (*CreateContainerRequest) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*CreateContainerRequest) String 

func (x *CreateContainerRequest) String() string

func (*CreateContainerRequest) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use CreateContainerResponse.ProtoReflect.Descriptor instead.

func (*CreateContainerResponse) GetAdjust 

func (x *CreateContainerResponse) GetAdjust() *ContainerAdjustment

func (*CreateContainerResponse) GetEvict 

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

func (*CreateContainerResponse) GetUpdate 

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

func (*CreateContainerResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*CreateContainerResponse) MarshalToVT added in v0.9.0 

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

func (*CreateContainerResponse) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*CreateContainerResponse) String 

func (x *CreateContainerResponse) String() string

func (*CreateContainerResponse) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) MarshalToSizedBufferVT added in v0.9.0 

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

func (*Empty) MarshalToVT added in v0.9.0 

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

func (*Empty) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*Empty) String 

func (x *Empty) String() string

func (*Empty) UnmarshalVT added in v0.9.0 

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 deprecated 

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 deprecated 

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 added in v0.9.0 

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

func (*Hook) MarshalToVT added in v0.9.0 

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

func (*Hook) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*Hooks) MarshalToVT added in v0.9.0 

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

func (*Hooks) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*Hooks) String 

func (x *Hooks) String() string

func (*Hooks) UnmarshalVT added in v0.9.0 

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

type HostFunctions added in v0.9.0 

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

go:plugin type=host

type HostFunctionsService added in v0.9.0 

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

func NewHostFunctionsClient added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*HugepageLimit) MarshalToVT added in v0.9.0 

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

func (*HugepageLimit) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*HugepageLimit) String 

func (x *HugepageLimit) String() string

func (*HugepageLimit) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*KeyValue) MarshalToVT added in v0.9.0 

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

func (*KeyValue) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*LinuxCPU) MarshalToVT added in v0.9.0 

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

func (*LinuxCPU) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxCPU) String 

func (x *LinuxCPU) String() string

func (*LinuxCPU) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*LinuxContainer) MarshalToVT added in v0.9.0 

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

func (*LinuxContainer) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxContainer) String 

func (x *LinuxContainer) String() string

func (*LinuxContainer) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.7.0 

func (x *LinuxContainerAdjustment) GetOomScoreAdj() *OptionalInt

func (*LinuxContainerAdjustment) GetResources 

func (x *LinuxContainerAdjustment) GetResources() *LinuxResources

func (*LinuxContainerAdjustment) MarshalToSizedBufferVT added in v0.9.0 

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

func (*LinuxContainerAdjustment) MarshalToVT added in v0.9.0 

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

func (*LinuxContainerAdjustment) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxContainerAdjustment) String 

func (x *LinuxContainerAdjustment) String() string

func (*LinuxContainerAdjustment) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use LinuxContainerUpdate.ProtoReflect.Descriptor instead.

func (*LinuxContainerUpdate) GetResources 

func (x *LinuxContainerUpdate) GetResources() *LinuxResources

func (*LinuxContainerUpdate) MarshalToSizedBufferVT added in v0.9.0 

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

func (*LinuxContainerUpdate) MarshalToVT added in v0.9.0 

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

func (*LinuxContainerUpdate) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxContainerUpdate) String 

func (x *LinuxContainerUpdate) String() string

func (*LinuxContainerUpdate) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*LinuxDevice) MarshalToVT added in v0.9.0 

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

func (*LinuxDevice) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*LinuxDeviceCgroup) MarshalToVT added in v0.9.0 

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

func (*LinuxDeviceCgroup) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxDeviceCgroup) String 

func (x *LinuxDeviceCgroup) String() string

func (*LinuxDeviceCgroup) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*LinuxMemory) MarshalToVT added in v0.9.0 

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

func (*LinuxMemory) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxMemory) String 

func (x *LinuxMemory) String() string

func (*LinuxMemory) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*LinuxNamespace) MarshalToVT added in v0.9.0 

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

func (*LinuxNamespace) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxNamespace) String 

func (x *LinuxNamespace) String() string

func (*LinuxNamespace) UnmarshalVT added in v0.9.0 

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

type LinuxPids added in v0.7.0 

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 deprecated added in v0.7.0 

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

Deprecated: Use LinuxPids.ProtoReflect.Descriptor instead.

func (*LinuxPids) GetLimit added in v0.7.0 

func (x *LinuxPids) GetLimit() int64

func (*LinuxPids) MarshalToSizedBufferVT added in v0.9.0 

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

func (*LinuxPids) MarshalToVT added in v0.9.0 

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

func (*LinuxPids) MarshalVT added in v0.9.0 

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

func (*LinuxPids) ProtoMessage added in v0.7.0 

func (*LinuxPids) ProtoMessage()

func (*LinuxPids) ProtoReflect added in v0.7.0 

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

func (*LinuxPids) Reset added in v0.7.0 

func (x *LinuxPids) Reset()

func (*LinuxPids) SizeVT added in v0.9.0 

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

func (*LinuxPids) String added in v0.7.0 

func (x *LinuxPids) String() string

func (*LinuxPids) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*LinuxPodSandbox) MarshalToVT added in v0.9.0 

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

func (*LinuxPodSandbox) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*LinuxPodSandbox) String 

func (x *LinuxPodSandbox) String() string

func (*LinuxPodSandbox) UnmarshalVT added in v0.9.0 

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    ``                                                                    /* 155-byte string literal not displayed */
	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 deprecated 

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 added in v0.7.0 

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 added in v0.9.0 

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

func (*LinuxResources) MarshalToVT added in v0.9.0 

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

func (*LinuxResources) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

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

type LogRequest added in v0.9.0 

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 deprecated added in v0.9.0 

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetLevel added in v0.9.0 

func (x *LogRequest) GetLevel() LogRequest_Level

func (*LogRequest) GetMsg added in v0.9.0 

func (x *LogRequest) GetMsg() string

func (*LogRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*LogRequest) MarshalToVT added in v0.9.0 

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

func (*LogRequest) MarshalVT added in v0.9.0 

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

func (*LogRequest) ProtoMessage added in v0.9.0 

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect added in v0.9.0 

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

func (*LogRequest) Reset added in v0.9.0 

func (x *LogRequest) Reset()

func (*LogRequest) SizeVT added in v0.9.0 

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

func (*LogRequest) String added in v0.9.0 

func (x *LogRequest) String() string

func (*LogRequest) UnmarshalVT added in v0.9.0 

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

type LogRequest_Level added in v0.9.0 

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 added in v0.9.0 

func (LogRequest_Level) Descriptor() protoreflect.EnumDescriptor

func (LogRequest_Level) Enum added in v0.9.0 

func (x LogRequest_Level) Enum() *LogRequest_Level

func (LogRequest_Level) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use LogRequest_Level.Descriptor instead.

func (LogRequest_Level) Number added in v0.9.0 

func (x LogRequest_Level) Number() protoreflect.EnumNumber

func (LogRequest_Level) String added in v0.9.0 

func (x LogRequest_Level) String() string

func (LogRequest_Level) Type added in v0.9.0 

func (LogRequest_Level) Type() protoreflect.EnumType

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 deprecated 

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 added in v0.9.0 

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

func (*Mount) MarshalToVT added in v0.9.0 

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

func (*Mount) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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 added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalBool) MarshalToVT added in v0.9.0 

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

func (*OptionalBool) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalBool) String 

func (x *OptionalBool) String() string

func (*OptionalBool) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalFileMode) MarshalToVT added in v0.9.0 

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

func (*OptionalFileMode) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalFileMode) String 

func (x *OptionalFileMode) String() string

func (*OptionalFileMode) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalInt) MarshalToVT added in v0.9.0 

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

func (*OptionalInt) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalInt) String 

func (x *OptionalInt) String() string

func (*OptionalInt) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalInt32) MarshalToVT added in v0.9.0 

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

func (*OptionalInt32) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalInt32) String 

func (x *OptionalInt32) String() string

func (*OptionalInt32) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalInt64) MarshalToVT added in v0.9.0 

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

func (*OptionalInt64) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalInt64) String 

func (x *OptionalInt64) String() string

func (*OptionalInt64) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalString) MarshalToVT added in v0.9.0 

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

func (*OptionalString) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalString) String 

func (x *OptionalString) String() string

func (*OptionalString) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalUInt32) MarshalToVT added in v0.9.0 

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

func (*OptionalUInt32) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalUInt32) String 

func (x *OptionalUInt32) String() string

func (*OptionalUInt32) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*OptionalUInt64) MarshalToVT added in v0.9.0 

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

func (*OptionalUInt64) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*OptionalUInt64) String 

func (x *OptionalUInt64) String() string

func (*OptionalUInt64) UnmarshalVT added in v0.9.0 

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

type POSIXRlimit added in v0.4.0 

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 deprecated added in v0.4.0 

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

Deprecated: Use POSIXRlimit.ProtoReflect.Descriptor instead.

func (*POSIXRlimit) GetHard added in v0.4.0 

func (x *POSIXRlimit) GetHard() uint64

func (*POSIXRlimit) GetSoft added in v0.4.0 

func (x *POSIXRlimit) GetSoft() uint64

func (*POSIXRlimit) GetType added in v0.4.0 

func (x *POSIXRlimit) GetType() string

func (*POSIXRlimit) MarshalToSizedBufferVT added in v0.9.0 

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

func (*POSIXRlimit) MarshalToVT added in v0.9.0 

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

func (*POSIXRlimit) MarshalVT added in v0.9.0 

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

func (*POSIXRlimit) ProtoMessage added in v0.4.0 

func (*POSIXRlimit) ProtoMessage()

func (*POSIXRlimit) ProtoReflect added in v0.4.0 

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

func (*POSIXRlimit) Reset added in v0.4.0 

func (x *POSIXRlimit) Reset()

func (*POSIXRlimit) SizeVT added in v0.9.0 

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

func (*POSIXRlimit) String added in v0.4.0 

func (x *POSIXRlimit) String() string

func (*POSIXRlimit) UnmarshalVT added in v0.9.0 

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

type Plugin added in v0.9.0 

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 added in v0.9.0 

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

func NewPluginPlugin added in v0.9.0 

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

func (*PluginPlugin) Load added in v0.9.0 

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

type PluginService 

type PluginService interface {
	Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
	Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error)
	Shutdown(context.Context, *Empty) (*Empty, error)
	CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
	UpdateContainer(context.Context, *UpdateContainerRequest) (*UpdateContainerResponse, error)
	StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error)
	StateChange(context.Context, *StateChangeEvent) (*Empty, error)
}

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 `` /* 153-byte string literal not displayed */
	Annotations    map[string]string `` /* 163-byte string literal not displayed */
	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 deprecated 

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 added in v0.8.0 

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 added in v0.9.0 

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

func (*PodSandbox) MarshalToVT added in v0.9.0 

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

func (*PodSandbox) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*PodSandbox) String 

func (x *PodSandbox) String() string

func (*PodSandbox) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*RegisterPluginRequest) MarshalToVT added in v0.9.0 

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

func (*RegisterPluginRequest) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*RegisterPluginRequest) String 

func (x *RegisterPluginRequest) String() string

func (*RegisterPluginRequest) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*StateChangeEvent) MarshalToVT added in v0.9.0 

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

func (*StateChangeEvent) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*StateChangeEvent) String 

func (x *StateChangeEvent) String() string

func (*StateChangeEvent) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*StopContainerRequest) MarshalToVT added in v0.9.0 

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

func (*StopContainerRequest) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*StopContainerRequest) String 

func (x *StopContainerRequest) String() string

func (*StopContainerRequest) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use StopContainerResponse.ProtoReflect.Descriptor instead.

func (*StopContainerResponse) GetUpdate 

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

func (*StopContainerResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StopContainerResponse) MarshalToVT added in v0.9.0 

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

func (*StopContainerResponse) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*StopContainerResponse) String 

func (x *StopContainerResponse) String() string

func (*StopContainerResponse) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.

func (*SynchronizeRequest) GetContainers 

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

func (*SynchronizeRequest) GetMore added in v0.7.0 

func (x *SynchronizeRequest) GetMore() bool

func (*SynchronizeRequest) GetPods 

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

func (*SynchronizeRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SynchronizeRequest) MarshalToVT added in v0.9.0 

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

func (*SynchronizeRequest) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*SynchronizeRequest) String 

func (x *SynchronizeRequest) String() string

func (*SynchronizeRequest) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.

func (*SynchronizeResponse) GetMore added in v0.7.0 

func (x *SynchronizeResponse) GetMore() bool

func (*SynchronizeResponse) GetUpdate 

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

func (*SynchronizeResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SynchronizeResponse) MarshalToVT added in v0.9.0 

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

func (*SynchronizeResponse) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*SynchronizeResponse) String 

func (x *SynchronizeResponse) String() string

func (*SynchronizeResponse) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*UpdateContainerRequest) MarshalToVT added in v0.9.0 

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

func (*UpdateContainerRequest) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*UpdateContainerRequest) String 

func (x *UpdateContainerRequest) String() string

func (*UpdateContainerRequest) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*UpdateContainerResponse) MarshalToVT added in v0.9.0 

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

func (*UpdateContainerResponse) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*UpdateContainerResponse) String 

func (x *UpdateContainerResponse) String() string

func (*UpdateContainerResponse) UnmarshalVT added in v0.9.0 

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 deprecated 

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 added in v0.9.0 

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

func (*UpdateContainersRequest) MarshalToVT added in v0.9.0 

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

func (*UpdateContainersRequest) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*UpdateContainersRequest) String 

func (x *UpdateContainersRequest) String() string

func (*UpdateContainersRequest) UnmarshalVT added in v0.9.0 

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 deprecated 

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

Deprecated: Use UpdateContainersResponse.ProtoReflect.Descriptor instead.

func (*UpdateContainersResponse) GetFailed 

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

func (*UpdateContainersResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*UpdateContainersResponse) MarshalToVT added in v0.9.0 

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

func (*UpdateContainersResponse) MarshalVT added in v0.9.0 

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 added in v0.9.0 

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

func (*UpdateContainersResponse) String 

func (x *UpdateContainersResponse) String() string

func (*UpdateContainersResponse) UnmarshalVT added in v0.9.0 

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

type WazeroConfig added in v0.9.0 

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

type WazeroNewRuntime added in v0.9.0 

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

func DefaultWazeroRuntime added in v0.9.0 

func DefaultWazeroRuntime() WazeroNewRuntime

Source Files

View all Source files

Jump to

Keyboard shortcuts

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