package api
import "github.com/containerd/nri/pkg/api"
Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: pkg/api/api.proto
Index ¶
- Constants
- Variables
- func CheckPluginIndex(idx string) error
- func ClearRemovalMarker(key string) string
- func DupStringMap(in map[string]string) map[string]string
- func DupStringSlice(in []string) []string
- func IsMarkedForRemoval(key string) (string, bool)
- func MarkForRemoval(key string) string
- func ParsePluginName(name string) (string, string, error)
- func RegisterHostFunctionsService(srv *ttrpc.Server, svc HostFunctionsService)
- func RegisterPluginService(srv *ttrpc.Server, svc PluginService)
- func RegisterRuntimeService(srv *ttrpc.Server, svc RuntimeService)
- func WazeroModuleConfig(moduleConfig wazero.ModuleConfig) wazeroConfigOption
- func WazeroRuntime(newRuntime WazeroNewRuntime) wazeroConfigOption
- type CDIDevice
- func (*CDIDevice) Descriptor() ([]byte, []int)
- func (x *CDIDevice) GetName() string
- func (m *CDIDevice) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CDIDevice) MarshalToVT(dAtA []byte) (int, error)
- func (m *CDIDevice) MarshalVT() (dAtA []byte, err error)
- func (*CDIDevice) ProtoMessage()
- func (x *CDIDevice) ProtoReflect() protoreflect.Message
- func (x *CDIDevice) Reset()
- func (m *CDIDevice) SizeVT() (n int)
- func (x *CDIDevice) String() string
- func (m *CDIDevice) UnmarshalVT(dAtA []byte) error
- type ConfigureRequest
- func (*ConfigureRequest) Descriptor() ([]byte, []int)
- func (x *ConfigureRequest) GetConfig() string
- func (x *ConfigureRequest) GetRegistrationTimeout() int64
- func (x *ConfigureRequest) GetRequestTimeout() int64
- func (x *ConfigureRequest) GetRuntimeName() string
- func (x *ConfigureRequest) GetRuntimeVersion() string
- func (m *ConfigureRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ConfigureRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ConfigureRequest) MarshalVT() (dAtA []byte, err error)
- func (*ConfigureRequest) ProtoMessage()
- func (x *ConfigureRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigureRequest) Reset()
- func (m *ConfigureRequest) SizeVT() (n int)
- func (x *ConfigureRequest) String() string
- func (m *ConfigureRequest) UnmarshalVT(dAtA []byte) error
- type ConfigureResponse
- func (*ConfigureResponse) Descriptor() ([]byte, []int)
- func (x *ConfigureResponse) GetEvents() int32
- func (m *ConfigureResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ConfigureResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ConfigureResponse) MarshalVT() (dAtA []byte, err error)
- func (*ConfigureResponse) ProtoMessage()
- func (x *ConfigureResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigureResponse) Reset()
- func (m *ConfigureResponse) SizeVT() (n int)
- func (x *ConfigureResponse) String() string
- func (m *ConfigureResponse) UnmarshalVT(dAtA []byte) error
- type Container
- func (*Container) Descriptor() ([]byte, []int)
- func (x *Container) GetAnnotations() map[string]string
- func (x *Container) GetArgs() []string
- func (x *Container) GetEnv() []string
- func (x *Container) GetHooks() *Hooks
- func (x *Container) GetId() string
- func (x *Container) GetLabels() map[string]string
- func (x *Container) GetLinux() *LinuxContainer
- func (x *Container) GetMounts() []*Mount
- func (x *Container) GetName() string
- func (x *Container) GetPid() uint32
- func (x *Container) GetPodSandboxId() string
- func (x *Container) GetRlimits() []*POSIXRlimit
- func (x *Container) GetState() ContainerState
- func (m *Container) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Container) MarshalToVT(dAtA []byte) (int, error)
- func (m *Container) MarshalVT() (dAtA []byte, err error)
- func (*Container) ProtoMessage()
- func (x *Container) ProtoReflect() protoreflect.Message
- func (x *Container) Reset()
- func (m *Container) SizeVT() (n int)
- func (x *Container) String() string
- func (m *Container) UnmarshalVT(dAtA []byte) error
- type ContainerAdjustment
- func (a *ContainerAdjustment) AddAnnotation(key, value string)
- func (a *ContainerAdjustment) AddCDIDevice(d *CDIDevice)
- func (a *ContainerAdjustment) AddDevice(d *LinuxDevice)
- func (a *ContainerAdjustment) AddEnv(key, value string)
- func (a *ContainerAdjustment) AddHooks(h *Hooks)
- func (a *ContainerAdjustment) AddLinuxHugepageLimit(pageSize string, value uint64)
- func (a *ContainerAdjustment) AddLinuxUnified(key, value string)
- func (a *ContainerAdjustment) AddMount(m *Mount)
- func (a *ContainerAdjustment) AddRlimit(typ string, hard, soft uint64)
- func (*ContainerAdjustment) Descriptor() ([]byte, []int)
- func (x *ContainerAdjustment) GetAnnotations() map[string]string
- func (x *ContainerAdjustment) GetCDIDevices() []*CDIDevice
- func (x *ContainerAdjustment) GetEnv() []*KeyValue
- func (x *ContainerAdjustment) GetHooks() *Hooks
- func (x *ContainerAdjustment) GetLinux() *LinuxContainerAdjustment
- func (x *ContainerAdjustment) GetMounts() []*Mount
- func (x *ContainerAdjustment) GetRlimits() []*POSIXRlimit
- func (m *ContainerAdjustment) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ContainerAdjustment) MarshalToVT(dAtA []byte) (int, error)
- func (m *ContainerAdjustment) MarshalVT() (dAtA []byte, err error)
- func (*ContainerAdjustment) ProtoMessage()
- func (x *ContainerAdjustment) ProtoReflect() protoreflect.Message
- func (a *ContainerAdjustment) RemoveAnnotation(key string)
- func (a *ContainerAdjustment) RemoveDevice(path string)
- func (a *ContainerAdjustment) RemoveEnv(key string)
- func (a *ContainerAdjustment) RemoveMount(ContainerPath string)
- func (x *ContainerAdjustment) Reset()
- func (a *ContainerAdjustment) SetLinuxBlockIOClass(value string)
- func (a *ContainerAdjustment) SetLinuxCPUPeriod(value int64)
- func (a *ContainerAdjustment) SetLinuxCPUQuota(value int64)
- func (a *ContainerAdjustment) SetLinuxCPURealtimePeriod(value uint64)
- func (a *ContainerAdjustment) SetLinuxCPURealtimeRuntime(value int64)
- func (a *ContainerAdjustment) SetLinuxCPUSetCPUs(value string)
- func (a *ContainerAdjustment) SetLinuxCPUSetMems(value string)
- func (a *ContainerAdjustment) SetLinuxCPUShares(value uint64)
- func (a *ContainerAdjustment) SetLinuxCgroupsPath(value string)
- func (a *ContainerAdjustment) SetLinuxMemoryDisableOomKiller()
- func (a *ContainerAdjustment) SetLinuxMemoryKernel(value int64)
- func (a *ContainerAdjustment) SetLinuxMemoryKernelTCP(value int64)
- func (a *ContainerAdjustment) SetLinuxMemoryLimit(value int64)
- func (a *ContainerAdjustment) SetLinuxMemoryReservation(value int64)
- func (a *ContainerAdjustment) SetLinuxMemorySwap(value int64)
- func (a *ContainerAdjustment) SetLinuxMemorySwappiness(value uint64)
- func (a *ContainerAdjustment) SetLinuxMemoryUseHierarchy()
- func (a *ContainerAdjustment) SetLinuxOomScoreAdj(value *int)
- func (a *ContainerAdjustment) SetLinuxPidLimits(value int64)
- func (a *ContainerAdjustment) SetLinuxRDTClass(value string)
- func (m *ContainerAdjustment) SizeVT() (n int)
- func (x *ContainerAdjustment) String() string
- func (m *ContainerAdjustment) UnmarshalVT(dAtA []byte) error
- type ContainerEviction
- func (*ContainerEviction) Descriptor() ([]byte, []int)
- func (x *ContainerEviction) GetContainerId() string
- func (x *ContainerEviction) GetReason() string
- func (m *ContainerEviction) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ContainerEviction) MarshalToVT(dAtA []byte) (int, error)
- func (m *ContainerEviction) MarshalVT() (dAtA []byte, err error)
- func (*ContainerEviction) ProtoMessage()
- func (x *ContainerEviction) ProtoReflect() protoreflect.Message
- func (x *ContainerEviction) Reset()
- func (m *ContainerEviction) SizeVT() (n int)
- func (x *ContainerEviction) String() string
- func (m *ContainerEviction) UnmarshalVT(dAtA []byte) error
- type ContainerState
- func (ContainerState) Descriptor() protoreflect.EnumDescriptor
- func (x ContainerState) Enum() *ContainerState
- func (ContainerState) EnumDescriptor() ([]byte, []int)
- func (x ContainerState) Number() protoreflect.EnumNumber
- func (x ContainerState) String() string
- func (ContainerState) Type() protoreflect.EnumType
- type ContainerUpdate
- func (u *ContainerUpdate) AddLinuxHugepageLimit(pageSize string, value uint64)
- func (u *ContainerUpdate) AddLinuxUnified(key, value string)
- func (*ContainerUpdate) Descriptor() ([]byte, []int)
- func (x *ContainerUpdate) GetContainerId() string
- func (x *ContainerUpdate) GetIgnoreFailure() bool
- func (x *ContainerUpdate) GetLinux() *LinuxContainerUpdate
- func (m *ContainerUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ContainerUpdate) MarshalToVT(dAtA []byte) (int, error)
- func (m *ContainerUpdate) MarshalVT() (dAtA []byte, err error)
- func (*ContainerUpdate) ProtoMessage()
- func (x *ContainerUpdate) ProtoReflect() protoreflect.Message
- func (x *ContainerUpdate) Reset()
- func (u *ContainerUpdate) SetContainerId(id string)
- func (u *ContainerUpdate) SetIgnoreFailure()
- func (u *ContainerUpdate) SetLinuxBlockIOClass(value string)
- func (u *ContainerUpdate) SetLinuxCPUPeriod(value int64)
- func (u *ContainerUpdate) SetLinuxCPUQuota(value int64)
- func (u *ContainerUpdate) SetLinuxCPURealtimePeriod(value uint64)
- func (u *ContainerUpdate) SetLinuxCPURealtimeRuntime(value int64)
- func (u *ContainerUpdate) SetLinuxCPUSetCPUs(value string)
- func (u *ContainerUpdate) SetLinuxCPUSetMems(value string)
- func (u *ContainerUpdate) SetLinuxCPUShares(value uint64)
- func (u *ContainerUpdate) SetLinuxMemoryDisableOomKiller()
- func (u *ContainerUpdate) SetLinuxMemoryKernel(value int64)
- func (u *ContainerUpdate) SetLinuxMemoryKernelTCP(value int64)
- func (u *ContainerUpdate) SetLinuxMemoryLimit(value int64)
- func (u *ContainerUpdate) SetLinuxMemoryReservation(value int64)
- func (u *ContainerUpdate) SetLinuxMemorySwap(value int64)
- func (u *ContainerUpdate) SetLinuxMemorySwappiness(value uint64)
- func (u *ContainerUpdate) SetLinuxMemoryUseHierarchy()
- func (u *ContainerUpdate) SetLinuxPidLimits(value int64)
- func (u *ContainerUpdate) SetLinuxRDTClass(value string)
- func (m *ContainerUpdate) SizeVT() (n int)
- func (x *ContainerUpdate) String() string
- func (m *ContainerUpdate) UnmarshalVT(dAtA []byte) error
- type CreateContainerRequest
- func (*CreateContainerRequest) Descriptor() ([]byte, []int)
- func (x *CreateContainerRequest) GetContainer() *Container
- func (x *CreateContainerRequest) GetPod() *PodSandbox
- func (m *CreateContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateContainerRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateContainerRequest) MarshalVT() (dAtA []byte, err error)
- func (*CreateContainerRequest) ProtoMessage()
- func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateContainerRequest) Reset()
- func (m *CreateContainerRequest) SizeVT() (n int)
- func (x *CreateContainerRequest) String() string
- func (m *CreateContainerRequest) UnmarshalVT(dAtA []byte) error
- type CreateContainerResponse
- func (*CreateContainerResponse) Descriptor() ([]byte, []int)
- func (x *CreateContainerResponse) GetAdjust() *ContainerAdjustment
- func (x *CreateContainerResponse) GetEvict() []*ContainerEviction
- func (x *CreateContainerResponse) GetUpdate() []*ContainerUpdate
- func (m *CreateContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateContainerResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateContainerResponse) MarshalVT() (dAtA []byte, err error)
- func (*CreateContainerResponse) ProtoMessage()
- func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message
- func (x *CreateContainerResponse) Reset()
- func (m *CreateContainerResponse) SizeVT() (n int)
- func (x *CreateContainerResponse) String() string
- func (m *CreateContainerResponse) UnmarshalVT(dAtA []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (m *Empty) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Empty) MarshalToVT(dAtA []byte) (int, error)
- func (m *Empty) MarshalVT() (dAtA []byte, err error)
- func (*Empty) ProtoMessage()
- func (x *Empty) ProtoReflect() protoreflect.Message
- func (x *Empty) Reset()
- func (m *Empty) SizeVT() (n int)
- func (x *Empty) String() string
- func (m *Empty) UnmarshalVT(dAtA []byte) error
- type Event
- func (Event) Descriptor() protoreflect.EnumDescriptor
- func (x Event) Enum() *Event
- func (Event) EnumDescriptor() ([]byte, []int)
- func (x Event) Number() protoreflect.EnumNumber
- func (x Event) String() string
- func (Event) Type() protoreflect.EnumType
- type EventMask
- func MustParseEventMask(events ...string) EventMask
- func ParseEventMask(events ...string) (EventMask, error)
- func (m *EventMask) Clear(events ...Event) *EventMask
- func (m *EventMask) IsSet(e Event) bool
- func (m *EventMask) PrettyString() string
- func (m *EventMask) Set(events ...Event) *EventMask
- type Hook
- func FromOCIHookSlice(o []rspec.Hook) []*Hook
- func (*Hook) Descriptor() ([]byte, []int)
- func (x *Hook) GetArgs() []string
- func (x *Hook) GetEnv() []string
- func (x *Hook) GetPath() string
- func (x *Hook) GetTimeout() *OptionalInt
- func (m *Hook) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Hook) MarshalToVT(dAtA []byte) (int, error)
- func (m *Hook) MarshalVT() (dAtA []byte, err error)
- func (*Hook) ProtoMessage()
- func (x *Hook) ProtoReflect() protoreflect.Message
- func (x *Hook) Reset()
- func (m *Hook) SizeVT() (n int)
- func (x *Hook) String() string
- func (h *Hook) ToOCI() rspec.Hook
- func (m *Hook) UnmarshalVT(dAtA []byte) error
- type Hooks
- func FromOCIHooks(o *rspec.Hooks) *Hooks
- func (hooks *Hooks) Append(h *Hooks) *Hooks
- func (*Hooks) Descriptor() ([]byte, []int)
- func (x *Hooks) GetCreateContainer() []*Hook
- func (x *Hooks) GetCreateRuntime() []*Hook
- func (x *Hooks) GetPoststart() []*Hook
- func (x *Hooks) GetPoststop() []*Hook
- func (x *Hooks) GetPrestart() []*Hook
- func (x *Hooks) GetStartContainer() []*Hook
- func (hooks *Hooks) Hooks() *Hooks
- func (m *Hooks) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Hooks) MarshalToVT(dAtA []byte) (int, error)
- func (m *Hooks) MarshalVT() (dAtA []byte, err error)
- func (*Hooks) ProtoMessage()
- func (x *Hooks) ProtoReflect() protoreflect.Message
- func (x *Hooks) Reset()
- func (m *Hooks) SizeVT() (n int)
- func (x *Hooks) String() string
- func (m *Hooks) UnmarshalVT(dAtA []byte) error
- type HostFunctions
- type HostFunctionsService
- type HugepageLimit
- func (*HugepageLimit) Descriptor() ([]byte, []int)
- func (x *HugepageLimit) GetLimit() uint64
- func (x *HugepageLimit) GetPageSize() string
- func (m *HugepageLimit) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *HugepageLimit) MarshalToVT(dAtA []byte) (int, error)
- func (m *HugepageLimit) MarshalVT() (dAtA []byte, err error)
- func (*HugepageLimit) ProtoMessage()
- func (x *HugepageLimit) ProtoReflect() protoreflect.Message
- func (x *HugepageLimit) Reset()
- func (m *HugepageLimit) SizeVT() (n int)
- func (x *HugepageLimit) String() string
- func (m *HugepageLimit) UnmarshalVT(dAtA []byte) error
- type KeyValue
- func FromOCIEnv(in []string) []*KeyValue
- func (*KeyValue) Descriptor() ([]byte, []int)
- func (x *KeyValue) GetKey() string
- func (x *KeyValue) GetValue() string
- func (e *KeyValue) IsMarkedForRemoval() (string, bool)
- func (m *KeyValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *KeyValue) MarshalToVT(dAtA []byte) (int, error)
- func (m *KeyValue) MarshalVT() (dAtA []byte, err error)
- func (*KeyValue) ProtoMessage()
- func (x *KeyValue) ProtoReflect() protoreflect.Message
- func (x *KeyValue) Reset()
- func (m *KeyValue) SizeVT() (n int)
- func (x *KeyValue) String() string
- func (e *KeyValue) ToOCI() string
- func (m *KeyValue) UnmarshalVT(dAtA []byte) error
- type LinuxCPU
- func (*LinuxCPU) Descriptor() ([]byte, []int)
- func (x *LinuxCPU) GetCpus() string
- func (x *LinuxCPU) GetMems() string
- func (x *LinuxCPU) GetPeriod() *OptionalUInt64
- func (x *LinuxCPU) GetQuota() *OptionalInt64
- func (x *LinuxCPU) GetRealtimePeriod() *OptionalUInt64
- func (x *LinuxCPU) GetRealtimeRuntime() *OptionalInt64
- func (x *LinuxCPU) GetShares() *OptionalUInt64
- func (m *LinuxCPU) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxCPU) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxCPU) MarshalVT() (dAtA []byte, err error)
- func (*LinuxCPU) ProtoMessage()
- func (x *LinuxCPU) ProtoReflect() protoreflect.Message
- func (x *LinuxCPU) Reset()
- func (m *LinuxCPU) SizeVT() (n int)
- func (x *LinuxCPU) String() string
- func (m *LinuxCPU) UnmarshalVT(dAtA []byte) error
- type LinuxContainer
- func (*LinuxContainer) Descriptor() ([]byte, []int)
- func (x *LinuxContainer) GetCgroupsPath() string
- func (x *LinuxContainer) GetDevices() []*LinuxDevice
- func (x *LinuxContainer) GetNamespaces() []*LinuxNamespace
- func (x *LinuxContainer) GetOomScoreAdj() *OptionalInt
- func (x *LinuxContainer) GetResources() *LinuxResources
- func (m *LinuxContainer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxContainer) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxContainer) MarshalVT() (dAtA []byte, err error)
- func (*LinuxContainer) ProtoMessage()
- func (x *LinuxContainer) ProtoReflect() protoreflect.Message
- func (x *LinuxContainer) Reset()
- func (m *LinuxContainer) SizeVT() (n int)
- func (x *LinuxContainer) String() string
- func (m *LinuxContainer) UnmarshalVT(dAtA []byte) error
- type LinuxContainerAdjustment
- func (*LinuxContainerAdjustment) Descriptor() ([]byte, []int)
- func (x *LinuxContainerAdjustment) GetCgroupsPath() string
- func (x *LinuxContainerAdjustment) GetDevices() []*LinuxDevice
- func (x *LinuxContainerAdjustment) GetOomScoreAdj() *OptionalInt
- func (x *LinuxContainerAdjustment) GetResources() *LinuxResources
- func (m *LinuxContainerAdjustment) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxContainerAdjustment) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxContainerAdjustment) MarshalVT() (dAtA []byte, err error)
- func (*LinuxContainerAdjustment) ProtoMessage()
- func (x *LinuxContainerAdjustment) ProtoReflect() protoreflect.Message
- func (x *LinuxContainerAdjustment) Reset()
- func (m *LinuxContainerAdjustment) SizeVT() (n int)
- func (x *LinuxContainerAdjustment) String() string
- func (m *LinuxContainerAdjustment) UnmarshalVT(dAtA []byte) error
- type LinuxContainerUpdate
- func (*LinuxContainerUpdate) Descriptor() ([]byte, []int)
- func (x *LinuxContainerUpdate) GetResources() *LinuxResources
- func (m *LinuxContainerUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxContainerUpdate) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxContainerUpdate) MarshalVT() (dAtA []byte, err error)
- func (*LinuxContainerUpdate) ProtoMessage()
- func (x *LinuxContainerUpdate) ProtoReflect() protoreflect.Message
- func (x *LinuxContainerUpdate) Reset()
- func (m *LinuxContainerUpdate) SizeVT() (n int)
- func (x *LinuxContainerUpdate) String() string
- func (m *LinuxContainerUpdate) UnmarshalVT(dAtA []byte) error
- type LinuxDevice
- func FromOCILinuxDevices(o []rspec.LinuxDevice) []*LinuxDevice
- func (d *LinuxDevice) AccessString() string
- func (d *LinuxDevice) Cmp(v *LinuxDevice) bool
- func (*LinuxDevice) Descriptor() ([]byte, []int)
- func (x *LinuxDevice) GetFileMode() *OptionalFileMode
- func (x *LinuxDevice) GetGid() *OptionalUInt32
- func (x *LinuxDevice) GetMajor() int64
- func (x *LinuxDevice) GetMinor() int64
- func (x *LinuxDevice) GetPath() string
- func (x *LinuxDevice) GetType() string
- func (x *LinuxDevice) GetUid() *OptionalUInt32
- func (d *LinuxDevice) IsMarkedForRemoval() (string, bool)
- func (m *LinuxDevice) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxDevice) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxDevice) MarshalVT() (dAtA []byte, err error)
- func (*LinuxDevice) ProtoMessage()
- func (x *LinuxDevice) ProtoReflect() protoreflect.Message
- func (x *LinuxDevice) Reset()
- func (m *LinuxDevice) SizeVT() (n int)
- func (x *LinuxDevice) String() string
- func (d *LinuxDevice) ToOCI() rspec.LinuxDevice
- func (m *LinuxDevice) UnmarshalVT(dAtA []byte) error
- type LinuxDeviceCgroup
- func (*LinuxDeviceCgroup) Descriptor() ([]byte, []int)
- func (x *LinuxDeviceCgroup) GetAccess() string
- func (x *LinuxDeviceCgroup) GetAllow() bool
- func (x *LinuxDeviceCgroup) GetMajor() *OptionalInt64
- func (x *LinuxDeviceCgroup) GetMinor() *OptionalInt64
- func (x *LinuxDeviceCgroup) GetType() string
- func (m *LinuxDeviceCgroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxDeviceCgroup) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxDeviceCgroup) MarshalVT() (dAtA []byte, err error)
- func (*LinuxDeviceCgroup) ProtoMessage()
- func (x *LinuxDeviceCgroup) ProtoReflect() protoreflect.Message
- func (x *LinuxDeviceCgroup) Reset()
- func (m *LinuxDeviceCgroup) SizeVT() (n int)
- func (x *LinuxDeviceCgroup) String() string
- func (m *LinuxDeviceCgroup) UnmarshalVT(dAtA []byte) error
- type LinuxMemory
- func (*LinuxMemory) Descriptor() ([]byte, []int)
- func (x *LinuxMemory) GetDisableOomKiller() *OptionalBool
- func (x *LinuxMemory) GetKernel() *OptionalInt64
- func (x *LinuxMemory) GetKernelTcp() *OptionalInt64
- func (x *LinuxMemory) GetLimit() *OptionalInt64
- func (x *LinuxMemory) GetReservation() *OptionalInt64
- func (x *LinuxMemory) GetSwap() *OptionalInt64
- func (x *LinuxMemory) GetSwappiness() *OptionalUInt64
- func (x *LinuxMemory) GetUseHierarchy() *OptionalBool
- func (m *LinuxMemory) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxMemory) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxMemory) MarshalVT() (dAtA []byte, err error)
- func (*LinuxMemory) ProtoMessage()
- func (x *LinuxMemory) ProtoReflect() protoreflect.Message
- func (x *LinuxMemory) Reset()
- func (m *LinuxMemory) SizeVT() (n int)
- func (x *LinuxMemory) String() string
- func (m *LinuxMemory) UnmarshalVT(dAtA []byte) error
- type LinuxNamespace
- func FromOCILinuxNamespaces(o []rspec.LinuxNamespace) []*LinuxNamespace
- func (*LinuxNamespace) Descriptor() ([]byte, []int)
- func (x *LinuxNamespace) GetPath() string
- func (x *LinuxNamespace) GetType() string
- func (m *LinuxNamespace) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxNamespace) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxNamespace) MarshalVT() (dAtA []byte, err error)
- func (*LinuxNamespace) ProtoMessage()
- func (x *LinuxNamespace) ProtoReflect() protoreflect.Message
- func (x *LinuxNamespace) Reset()
- func (m *LinuxNamespace) SizeVT() (n int)
- func (x *LinuxNamespace) String() string
- func (m *LinuxNamespace) UnmarshalVT(dAtA []byte) error
- type LinuxPids
- func (*LinuxPids) Descriptor() ([]byte, []int)
- func (x *LinuxPids) GetLimit() int64
- func (m *LinuxPids) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxPids) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxPids) MarshalVT() (dAtA []byte, err error)
- func (*LinuxPids) ProtoMessage()
- func (x *LinuxPids) ProtoReflect() protoreflect.Message
- func (x *LinuxPids) Reset()
- func (m *LinuxPids) SizeVT() (n int)
- func (x *LinuxPids) String() string
- func (m *LinuxPids) UnmarshalVT(dAtA []byte) error
- type LinuxPodSandbox
- func (*LinuxPodSandbox) Descriptor() ([]byte, []int)
- func (x *LinuxPodSandbox) GetCgroupParent() string
- func (x *LinuxPodSandbox) GetCgroupsPath() string
- func (x *LinuxPodSandbox) GetNamespaces() []*LinuxNamespace
- func (x *LinuxPodSandbox) GetPodOverhead() *LinuxResources
- func (x *LinuxPodSandbox) GetPodResources() *LinuxResources
- func (x *LinuxPodSandbox) GetResources() *LinuxResources
- func (m *LinuxPodSandbox) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxPodSandbox) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxPodSandbox) MarshalVT() (dAtA []byte, err error)
- func (*LinuxPodSandbox) ProtoMessage()
- func (x *LinuxPodSandbox) ProtoReflect() protoreflect.Message
- func (x *LinuxPodSandbox) Reset()
- func (m *LinuxPodSandbox) SizeVT() (n int)
- func (x *LinuxPodSandbox) String() string
- func (m *LinuxPodSandbox) UnmarshalVT(dAtA []byte) error
- type LinuxResources
- func FromCRILinuxResources(c *cri.LinuxContainerResources) *LinuxResources
- func FromOCILinuxResources(o *rspec.LinuxResources, _ map[string]string) *LinuxResources
- func (r *LinuxResources) Copy() *LinuxResources
- func (*LinuxResources) Descriptor() ([]byte, []int)
- func (x *LinuxResources) GetBlockioClass() *OptionalString
- func (x *LinuxResources) GetCpu() *LinuxCPU
- func (x *LinuxResources) GetDevices() []*LinuxDeviceCgroup
- func (x *LinuxResources) GetHugepageLimits() []*HugepageLimit
- func (x *LinuxResources) GetMemory() *LinuxMemory
- func (x *LinuxResources) GetPids() *LinuxPids
- func (x *LinuxResources) GetRdtClass() *OptionalString
- func (x *LinuxResources) GetUnified() map[string]string
- func (m *LinuxResources) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LinuxResources) MarshalToVT(dAtA []byte) (int, error)
- func (m *LinuxResources) MarshalVT() (dAtA []byte, err error)
- func (*LinuxResources) ProtoMessage()
- func (x *LinuxResources) ProtoReflect() protoreflect.Message
- func (x *LinuxResources) Reset()
- func (m *LinuxResources) SizeVT() (n int)
- func (x *LinuxResources) String() string
- func (r *LinuxResources) ToCRI(oomScoreAdj int64) *cri.LinuxContainerResources
- func (r *LinuxResources) ToOCI() *rspec.LinuxResources
- func (m *LinuxResources) UnmarshalVT(dAtA []byte) error
- type LogRequest
- func (*LogRequest) Descriptor() ([]byte, []int)
- func (x *LogRequest) GetLevel() LogRequest_Level
- func (x *LogRequest) GetMsg() string
- func (m *LogRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *LogRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *LogRequest) MarshalVT() (dAtA []byte, err error)
- func (*LogRequest) ProtoMessage()
- func (x *LogRequest) ProtoReflect() protoreflect.Message
- func (x *LogRequest) Reset()
- func (m *LogRequest) SizeVT() (n int)
- func (x *LogRequest) String() string
- func (m *LogRequest) UnmarshalVT(dAtA []byte) error
- type LogRequest_Level
- func (LogRequest_Level) Descriptor() protoreflect.EnumDescriptor
- func (x LogRequest_Level) Enum() *LogRequest_Level
- func (LogRequest_Level) EnumDescriptor() ([]byte, []int)
- func (x LogRequest_Level) Number() protoreflect.EnumNumber
- func (x LogRequest_Level) String() string
- func (LogRequest_Level) Type() protoreflect.EnumType
- type Mount
- func FromOCIMounts(o []rspec.Mount) []*Mount
- func (m *Mount) Cmp(v *Mount) bool
- func (*Mount) Descriptor() ([]byte, []int)
- func (x *Mount) GetDestination() string
- func (x *Mount) GetOptions() []string
- func (x *Mount) GetSource() string
- func (x *Mount) GetType() string
- func (m *Mount) IsMarkedForRemoval() (string, bool)
- func (m *Mount) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Mount) MarshalToVT(dAtA []byte) (int, error)
- func (m *Mount) MarshalVT() (dAtA []byte, err error)
- func (*Mount) ProtoMessage()
- func (x *Mount) ProtoReflect() protoreflect.Message
- func (x *Mount) Reset()
- func (m *Mount) SizeVT() (n int)
- func (x *Mount) String() string
- func (m *Mount) ToOCI(propagationQuery *string) rspec.Mount
- func (m *Mount) UnmarshalVT(dAtA []byte) error
- type OptionalBool
- func Bool(v interface{}) *OptionalBool
- func (*OptionalBool) Descriptor() ([]byte, []int)
- func (o *OptionalBool) Get() *bool
- func (x *OptionalBool) GetValue() bool
- func (m *OptionalBool) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalBool) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalBool) MarshalVT() (dAtA []byte, err error)
- func (*OptionalBool) ProtoMessage()
- func (x *OptionalBool) ProtoReflect() protoreflect.Message
- func (x *OptionalBool) Reset()
- func (m *OptionalBool) SizeVT() (n int)
- func (x *OptionalBool) String() string
- func (m *OptionalBool) UnmarshalVT(dAtA []byte) error
- type OptionalFileMode
- func FileMode(v interface{}) *OptionalFileMode
- func (*OptionalFileMode) Descriptor() ([]byte, []int)
- func (o *OptionalFileMode) Get() *os.FileMode
- func (x *OptionalFileMode) GetValue() uint32
- func (m *OptionalFileMode) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalFileMode) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalFileMode) MarshalVT() (dAtA []byte, err error)
- func (*OptionalFileMode) ProtoMessage()
- func (x *OptionalFileMode) ProtoReflect() protoreflect.Message
- func (x *OptionalFileMode) Reset()
- func (m *OptionalFileMode) SizeVT() (n int)
- func (x *OptionalFileMode) String() string
- func (m *OptionalFileMode) UnmarshalVT(dAtA []byte) error
- type OptionalInt
- func Int(v interface{}) *OptionalInt
- func (*OptionalInt) Descriptor() ([]byte, []int)
- func (o *OptionalInt) Get() *int
- func (x *OptionalInt) GetValue() int64
- func (m *OptionalInt) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalInt) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalInt) MarshalVT() (dAtA []byte, err error)
- func (*OptionalInt) ProtoMessage()
- func (x *OptionalInt) ProtoReflect() protoreflect.Message
- func (x *OptionalInt) Reset()
- func (m *OptionalInt) SizeVT() (n int)
- func (x *OptionalInt) String() string
- func (m *OptionalInt) UnmarshalVT(dAtA []byte) error
- type OptionalInt32
- func Int32(v interface{}) *OptionalInt32
- func (*OptionalInt32) Descriptor() ([]byte, []int)
- func (o *OptionalInt32) Get() *int32
- func (x *OptionalInt32) GetValue() int32
- func (m *OptionalInt32) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalInt32) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalInt32) MarshalVT() (dAtA []byte, err error)
- func (*OptionalInt32) ProtoMessage()
- func (x *OptionalInt32) ProtoReflect() protoreflect.Message
- func (x *OptionalInt32) Reset()
- func (m *OptionalInt32) SizeVT() (n int)
- func (x *OptionalInt32) String() string
- func (m *OptionalInt32) UnmarshalVT(dAtA []byte) error
- type OptionalInt64
- func Int64(v interface{}) *OptionalInt64
- func (*OptionalInt64) Descriptor() ([]byte, []int)
- func (o *OptionalInt64) Get() *int64
- func (x *OptionalInt64) GetValue() int64
- func (m *OptionalInt64) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalInt64) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalInt64) MarshalVT() (dAtA []byte, err error)
- func (*OptionalInt64) ProtoMessage()
- func (x *OptionalInt64) ProtoReflect() protoreflect.Message
- func (x *OptionalInt64) Reset()
- func (m *OptionalInt64) SizeVT() (n int)
- func (x *OptionalInt64) String() string
- func (m *OptionalInt64) UnmarshalVT(dAtA []byte) error
- type OptionalString
- func String(v interface{}) *OptionalString
- func (*OptionalString) Descriptor() ([]byte, []int)
- func (o *OptionalString) Get() *string
- func (x *OptionalString) GetValue() string
- func (m *OptionalString) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalString) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalString) MarshalVT() (dAtA []byte, err error)
- func (*OptionalString) ProtoMessage()
- func (x *OptionalString) ProtoReflect() protoreflect.Message
- func (x *OptionalString) Reset()
- func (m *OptionalString) SizeVT() (n int)
- func (x *OptionalString) String() string
- func (m *OptionalString) UnmarshalVT(dAtA []byte) error
- type OptionalUInt32
- func UInt32(v interface{}) *OptionalUInt32
- func (*OptionalUInt32) Descriptor() ([]byte, []int)
- func (o *OptionalUInt32) Get() *uint32
- func (x *OptionalUInt32) GetValue() uint32
- func (m *OptionalUInt32) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalUInt32) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalUInt32) MarshalVT() (dAtA []byte, err error)
- func (*OptionalUInt32) ProtoMessage()
- func (x *OptionalUInt32) ProtoReflect() protoreflect.Message
- func (x *OptionalUInt32) Reset()
- func (m *OptionalUInt32) SizeVT() (n int)
- func (x *OptionalUInt32) String() string
- func (m *OptionalUInt32) UnmarshalVT(dAtA []byte) error
- type OptionalUInt64
- func UInt64(v interface{}) *OptionalUInt64
- func (*OptionalUInt64) Descriptor() ([]byte, []int)
- func (o *OptionalUInt64) Get() *uint64
- func (x *OptionalUInt64) GetValue() uint64
- func (m *OptionalUInt64) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OptionalUInt64) MarshalToVT(dAtA []byte) (int, error)
- func (m *OptionalUInt64) MarshalVT() (dAtA []byte, err error)
- func (*OptionalUInt64) ProtoMessage()
- func (x *OptionalUInt64) ProtoReflect() protoreflect.Message
- func (x *OptionalUInt64) Reset()
- func (m *OptionalUInt64) SizeVT() (n int)
- func (x *OptionalUInt64) String() string
- func (m *OptionalUInt64) UnmarshalVT(dAtA []byte) error
- type POSIXRlimit
- func (*POSIXRlimit) Descriptor() ([]byte, []int)
- func (x *POSIXRlimit) GetHard() uint64
- func (x *POSIXRlimit) GetSoft() uint64
- func (x *POSIXRlimit) GetType() string
- func (m *POSIXRlimit) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *POSIXRlimit) MarshalToVT(dAtA []byte) (int, error)
- func (m *POSIXRlimit) MarshalVT() (dAtA []byte, err error)
- func (*POSIXRlimit) ProtoMessage()
- func (x *POSIXRlimit) ProtoReflect() protoreflect.Message
- func (x *POSIXRlimit) Reset()
- func (m *POSIXRlimit) SizeVT() (n int)
- func (x *POSIXRlimit) String() string
- func (m *POSIXRlimit) UnmarshalVT(dAtA []byte) error
- type Plugin
- type PluginPlugin
- func NewPluginPlugin(ctx context.Context, opts ...wazeroConfigOption) (*PluginPlugin, error)
- func (p *PluginPlugin) Load(ctx context.Context, pluginPath string, hostFunctions HostFunctions) (plugin, error)
- type PluginService
- type PodSandbox
- func (*PodSandbox) Descriptor() ([]byte, []int)
- func (x *PodSandbox) GetAnnotations() map[string]string
- func (x *PodSandbox) GetId() string
- func (x *PodSandbox) GetIps() []string
- func (x *PodSandbox) GetLabels() map[string]string
- func (x *PodSandbox) GetLinux() *LinuxPodSandbox
- func (x *PodSandbox) GetName() string
- func (x *PodSandbox) GetNamespace() string
- func (x *PodSandbox) GetPid() uint32
- func (x *PodSandbox) GetRuntimeHandler() string
- func (x *PodSandbox) GetUid() string
- func (m *PodSandbox) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PodSandbox) MarshalToVT(dAtA []byte) (int, error)
- func (m *PodSandbox) MarshalVT() (dAtA []byte, err error)
- func (*PodSandbox) ProtoMessage()
- func (x *PodSandbox) ProtoReflect() protoreflect.Message
- func (x *PodSandbox) Reset()
- func (m *PodSandbox) SizeVT() (n int)
- func (x *PodSandbox) String() string
- func (m *PodSandbox) UnmarshalVT(dAtA []byte) error
- type PostCreateContainerRequest
- type PostCreateContainerResponse
- type PostStartContainerRequest
- type PostStartContainerResponse
- type PostUpdateContainerRequest
- type PostUpdateContainerResponse
- type RegisterPluginRequest
- func (*RegisterPluginRequest) Descriptor() ([]byte, []int)
- func (x *RegisterPluginRequest) GetPluginIdx() string
- func (x *RegisterPluginRequest) GetPluginName() string
- func (m *RegisterPluginRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RegisterPluginRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *RegisterPluginRequest) MarshalVT() (dAtA []byte, err error)
- func (*RegisterPluginRequest) ProtoMessage()
- func (x *RegisterPluginRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterPluginRequest) Reset()
- func (m *RegisterPluginRequest) SizeVT() (n int)
- func (x *RegisterPluginRequest) String() string
- func (m *RegisterPluginRequest) UnmarshalVT(dAtA []byte) error
- type RemoveContainerRequest
- type RemoveContainerResponse
- type RemovePodSandboxRequest
- type RemovePodSandboxResponse
- type RunPodSandboxRequest
- type RunPodSandboxResponse
- type RuntimeService
- type ShutdownRequest
- type ShutdownResponse
- type StartContainerRequest
- type StartContainerResponse
- type StateChangeEvent
- func (*StateChangeEvent) Descriptor() ([]byte, []int)
- func (x *StateChangeEvent) GetContainer() *Container
- func (x *StateChangeEvent) GetEvent() Event
- func (x *StateChangeEvent) GetPod() *PodSandbox
- func (m *StateChangeEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StateChangeEvent) MarshalToVT(dAtA []byte) (int, error)
- func (m *StateChangeEvent) MarshalVT() (dAtA []byte, err error)
- func (*StateChangeEvent) ProtoMessage()
- func (x *StateChangeEvent) ProtoReflect() protoreflect.Message
- func (x *StateChangeEvent) Reset()
- func (m *StateChangeEvent) SizeVT() (n int)
- func (x *StateChangeEvent) String() string
- func (m *StateChangeEvent) UnmarshalVT(dAtA []byte) error
- type StateChangeResponse
- type StopContainerRequest
- func (*StopContainerRequest) Descriptor() ([]byte, []int)
- func (x *StopContainerRequest) GetContainer() *Container
- func (x *StopContainerRequest) GetPod() *PodSandbox
- func (m *StopContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StopContainerRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *StopContainerRequest) MarshalVT() (dAtA []byte, err error)
- func (*StopContainerRequest) ProtoMessage()
- func (x *StopContainerRequest) ProtoReflect() protoreflect.Message
- func (x *StopContainerRequest) Reset()
- func (m *StopContainerRequest) SizeVT() (n int)
- func (x *StopContainerRequest) String() string
- func (m *StopContainerRequest) UnmarshalVT(dAtA []byte) error
- type StopContainerResponse
- func (*StopContainerResponse) Descriptor() ([]byte, []int)
- func (x *StopContainerResponse) GetUpdate() []*ContainerUpdate
- func (m *StopContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StopContainerResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *StopContainerResponse) MarshalVT() (dAtA []byte, err error)
- func (*StopContainerResponse) ProtoMessage()
- func (x *StopContainerResponse) ProtoReflect() protoreflect.Message
- func (x *StopContainerResponse) Reset()
- func (m *StopContainerResponse) SizeVT() (n int)
- func (x *StopContainerResponse) String() string
- func (m *StopContainerResponse) UnmarshalVT(dAtA []byte) error
- type StopPodSandboxRequest
- type StopPodSandboxResponse
- type SynchronizeRequest
- func (*SynchronizeRequest) Descriptor() ([]byte, []int)
- func (x *SynchronizeRequest) GetContainers() []*Container
- func (x *SynchronizeRequest) GetMore() bool
- func (x *SynchronizeRequest) GetPods() []*PodSandbox
- func (m *SynchronizeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SynchronizeRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *SynchronizeRequest) MarshalVT() (dAtA []byte, err error)
- func (*SynchronizeRequest) ProtoMessage()
- func (x *SynchronizeRequest) ProtoReflect() protoreflect.Message
- func (x *SynchronizeRequest) Reset()
- func (m *SynchronizeRequest) SizeVT() (n int)
- func (x *SynchronizeRequest) String() string
- func (m *SynchronizeRequest) UnmarshalVT(dAtA []byte) error
- type SynchronizeResponse
- func (*SynchronizeResponse) Descriptor() ([]byte, []int)
- func (x *SynchronizeResponse) GetMore() bool
- func (x *SynchronizeResponse) GetUpdate() []*ContainerUpdate
- func (m *SynchronizeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SynchronizeResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *SynchronizeResponse) MarshalVT() (dAtA []byte, err error)
- func (*SynchronizeResponse) ProtoMessage()
- func (x *SynchronizeResponse) ProtoReflect() protoreflect.Message
- func (x *SynchronizeResponse) Reset()
- func (m *SynchronizeResponse) SizeVT() (n int)
- func (x *SynchronizeResponse) String() string
- func (m *SynchronizeResponse) UnmarshalVT(dAtA []byte) error
- type UpdateContainerRequest
- func (*UpdateContainerRequest) Descriptor() ([]byte, []int)
- func (x *UpdateContainerRequest) GetContainer() *Container
- func (x *UpdateContainerRequest) GetLinuxResources() *LinuxResources
- func (x *UpdateContainerRequest) GetPod() *PodSandbox
- func (m *UpdateContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *UpdateContainerRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *UpdateContainerRequest) MarshalVT() (dAtA []byte, err error)
- func (*UpdateContainerRequest) ProtoMessage()
- func (x *UpdateContainerRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateContainerRequest) Reset()
- func (m *UpdateContainerRequest) SizeVT() (n int)
- func (x *UpdateContainerRequest) String() string
- func (m *UpdateContainerRequest) UnmarshalVT(dAtA []byte) error
- type UpdateContainerResponse
- func (*UpdateContainerResponse) Descriptor() ([]byte, []int)
- func (x *UpdateContainerResponse) GetEvict() []*ContainerEviction
- func (x *UpdateContainerResponse) GetUpdate() []*ContainerUpdate
- func (m *UpdateContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *UpdateContainerResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *UpdateContainerResponse) MarshalVT() (dAtA []byte, err error)
- func (*UpdateContainerResponse) ProtoMessage()
- func (x *UpdateContainerResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateContainerResponse) Reset()
- func (m *UpdateContainerResponse) SizeVT() (n int)
- func (x *UpdateContainerResponse) String() string
- func (m *UpdateContainerResponse) UnmarshalVT(dAtA []byte) error
- type UpdateContainersRequest
- func (*UpdateContainersRequest) Descriptor() ([]byte, []int)
- func (x *UpdateContainersRequest) GetEvict() []*ContainerEviction
- func (x *UpdateContainersRequest) GetUpdate() []*ContainerUpdate
- func (m *UpdateContainersRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *UpdateContainersRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *UpdateContainersRequest) MarshalVT() (dAtA []byte, err error)
- func (*UpdateContainersRequest) ProtoMessage()
- func (x *UpdateContainersRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateContainersRequest) Reset()
- func (m *UpdateContainersRequest) SizeVT() (n int)
- func (x *UpdateContainersRequest) String() string
- func (m *UpdateContainersRequest) UnmarshalVT(dAtA []byte) error
- type UpdateContainersResponse
- func (*UpdateContainersResponse) Descriptor() ([]byte, []int)
- func (x *UpdateContainersResponse) GetFailed() []*ContainerUpdate
- func (m *UpdateContainersResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *UpdateContainersResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *UpdateContainersResponse) MarshalVT() (dAtA []byte, err error)
- func (*UpdateContainersResponse) ProtoMessage()
- func (x *UpdateContainersResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateContainersResponse) Reset()
- func (m *UpdateContainersResponse) SizeVT() (n int)
- func (x *UpdateContainersResponse) String() string
- func (m *UpdateContainersResponse) UnmarshalVT(dAtA []byte) error
- type WazeroConfig
- type WazeroNewRuntime
Constants ¶
const ( // DefaultSocketPath is the default socket path for external plugins. DefaultSocketPath = "/var/run/nri/nri.sock" // PluginSocketEnvVar is used to inform plugins about pre-connected sockets. PluginSocketEnvVar = "NRI_PLUGIN_SOCKET" // PluginNameEnvVar is used to inform NRI-launched plugins about their name. PluginNameEnvVar = "NRI_PLUGIN_NAME" // PluginIdxEnvVar is used to inform NRI-launched plugins about their ID. PluginIdxEnvVar = "NRI_PLUGIN_IDX" )
const ( // DefaultPluginRegistrationTimeout is the default timeout for plugin registration. DefaultPluginRegistrationTimeout = 5 * time.Second // DefaultPluginRequestTimeout is the default timeout for plugins to handle a request. DefaultPluginRequestTimeout = 2 * time.Second )
const PluginPluginAPIVersion = 1
const ( // SELinuxRelabel is a Mount pseudo-option to request relabeling. SELinuxRelabel = "relabel" )
const ( // ValidEvents is the event mask of all valid events. ValidEvents = EventMask((1 << (Event_LAST - 1)) - 1) )
Variables ¶
var ( Event_name = map[int32]string{ 0: "UNKNOWN", 1: "RUN_POD_SANDBOX", 2: "STOP_POD_SANDBOX", 3: "REMOVE_POD_SANDBOX", 4: "CREATE_CONTAINER", 5: "POST_CREATE_CONTAINER", 6: "START_CONTAINER", 7: "POST_START_CONTAINER", 8: "UPDATE_CONTAINER", 9: "POST_UPDATE_CONTAINER", 10: "STOP_CONTAINER", 11: "REMOVE_CONTAINER", 12: "LAST", } Event_value = map[string]int32{ "UNKNOWN": 0, "RUN_POD_SANDBOX": 1, "STOP_POD_SANDBOX": 2, "REMOVE_POD_SANDBOX": 3, "CREATE_CONTAINER": 4, "POST_CREATE_CONTAINER": 5, "START_CONTAINER": 6, "POST_START_CONTAINER": 7, "UPDATE_CONTAINER": 8, "POST_UPDATE_CONTAINER": 9, "STOP_CONTAINER": 10, "REMOVE_CONTAINER": 11, "LAST": 12, } )
Enum value maps for Event.
var ( ContainerState_name = map[int32]string{ 0: "CONTAINER_UNKNOWN", 1: "CONTAINER_CREATED", 2: "CONTAINER_PAUSED", 3: "CONTAINER_RUNNING", 4: "CONTAINER_STOPPED", } ContainerState_value = map[string]int32{ "CONTAINER_UNKNOWN": 0, "CONTAINER_CREATED": 1, "CONTAINER_PAUSED": 2, "CONTAINER_RUNNING": 3, "CONTAINER_STOPPED": 4, } )
Enum value maps for ContainerState.
var ( LogRequest_Level_name = map[int32]string{ 0: "LEVEL_UNSPECIFIED", 1: "LEVEL_DEBUG", 2: "LEVEL_INFO", 3: "LEVEL_WARN", 4: "LEVEL_ERROR", } LogRequest_Level_value = map[string]int32{ "LEVEL_UNSPECIFIED": 0, "LEVEL_DEBUG": 1, "LEVEL_INFO": 2, "LEVEL_WARN": 3, "LEVEL_ERROR": 4, } )
Enum value maps for LogRequest_Level.
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var File_pkg_api_api_proto protoreflect.FileDescriptor
Functions ¶
func CheckPluginIndex ¶
CheckPluginIndex checks the validity of a plugin index.
func ClearRemovalMarker ¶
ClearRemovalMarker returns a key cleared from any removal marker.
func DupStringMap ¶
DupStringMap creates a copy of a map with string keys and values.
func DupStringSlice ¶
DupStringSlice creates a copy of a string slice.
func IsMarkedForRemoval ¶
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 ¶
MarkForRemoval returns a key marked for removal.
func ParsePluginName ¶
ParsePluginName parses the (file)name of a plugin into an index and a base.
func RegisterHostFunctionsService ¶
func RegisterHostFunctionsService(srv *ttrpc.Server, svc HostFunctionsService)
func RegisterPluginService ¶
func RegisterPluginService(srv *ttrpc.Server, svc PluginService)
func RegisterRuntimeService ¶
func RegisterRuntimeService(srv *ttrpc.Server, svc RuntimeService)
func WazeroModuleConfig ¶
func WazeroModuleConfig(moduleConfig wazero.ModuleConfig) wazeroConfigOption
func WazeroRuntime ¶
func WazeroRuntime(newRuntime WazeroNewRuntime) wazeroConfigOption
Types ¶
type CDIDevice ¶
type CDIDevice struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
A CDI device reference.
func (*CDIDevice) Descriptor ¶
Deprecated: Use CDIDevice.ProtoReflect.Descriptor instead.
func (*CDIDevice) GetName ¶
func (*CDIDevice) MarshalToSizedBufferVT ¶
func (*CDIDevice) MarshalToVT ¶
func (*CDIDevice) MarshalVT ¶
func (*CDIDevice) ProtoMessage ¶
func (*CDIDevice) ProtoMessage()
func (*CDIDevice) ProtoReflect ¶
func (x *CDIDevice) ProtoReflect() protoreflect.Message
func (*CDIDevice) Reset ¶
func (x *CDIDevice) Reset()
func (*CDIDevice) SizeVT ¶
func (*CDIDevice) String ¶
func (*CDIDevice) UnmarshalVT ¶
type ConfigureRequest ¶
type ConfigureRequest struct { // Any plugin-specific data, if present among the NRI configuration. Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // Name of the runtime NRI is running in. RuntimeName string `protobuf:"bytes,2,opt,name=runtime_name,json=runtimeName,proto3" json:"runtime_name,omitempty"` // Version of the runtime NRI is running in. RuntimeVersion string `protobuf:"bytes,3,opt,name=runtime_version,json=runtimeVersion,proto3" json:"runtime_version,omitempty"` // Configured registration timeout in milliseconds. RegistrationTimeout int64 `protobuf:"varint,4,opt,name=registration_timeout,json=registrationTimeout,proto3" json:"registration_timeout,omitempty"` // Configured request processing timeout in milliseconds. RequestTimeout int64 `protobuf:"varint,5,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"` // contains filtered or unexported fields }
func (*ConfigureRequest) Descriptor ¶
func (*ConfigureRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureRequest.ProtoReflect.Descriptor instead.
func (*ConfigureRequest) GetConfig ¶
func (x *ConfigureRequest) GetConfig() string
func (*ConfigureRequest) GetRegistrationTimeout ¶
func (x *ConfigureRequest) GetRegistrationTimeout() int64
func (*ConfigureRequest) GetRequestTimeout ¶
func (x *ConfigureRequest) GetRequestTimeout() int64
func (*ConfigureRequest) GetRuntimeName ¶
func (x *ConfigureRequest) GetRuntimeName() string
func (*ConfigureRequest) GetRuntimeVersion ¶
func (x *ConfigureRequest) GetRuntimeVersion() string
func (*ConfigureRequest) MarshalToSizedBufferVT ¶
func (m *ConfigureRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ConfigureRequest) MarshalToVT ¶
func (m *ConfigureRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ConfigureRequest) MarshalVT ¶
func (m *ConfigureRequest) MarshalVT() (dAtA []byte, err error)
func (*ConfigureRequest) ProtoMessage ¶
func (*ConfigureRequest) ProtoMessage()
func (*ConfigureRequest) ProtoReflect ¶
func (x *ConfigureRequest) ProtoReflect() protoreflect.Message
func (*ConfigureRequest) Reset ¶
func (x *ConfigureRequest) Reset()
func (*ConfigureRequest) SizeVT ¶
func (m *ConfigureRequest) SizeVT() (n int)
func (*ConfigureRequest) String ¶
func (x *ConfigureRequest) String() string
func (*ConfigureRequest) UnmarshalVT ¶
func (m *ConfigureRequest) UnmarshalVT(dAtA []byte) error
type ConfigureResponse ¶
type ConfigureResponse struct { // Events to subscribe the plugin for. Each bit set corresponds to an // enumerated Event. Events int32 `protobuf:"varint,2,opt,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*ConfigureResponse) Descriptor ¶
func (*ConfigureResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.
func (*ConfigureResponse) GetEvents ¶
func (x *ConfigureResponse) GetEvents() int32
func (*ConfigureResponse) MarshalToSizedBufferVT ¶
func (m *ConfigureResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ConfigureResponse) MarshalToVT ¶
func (m *ConfigureResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ConfigureResponse) MarshalVT ¶
func (m *ConfigureResponse) MarshalVT() (dAtA []byte, err error)
func (*ConfigureResponse) ProtoMessage ¶
func (*ConfigureResponse) ProtoMessage()
func (*ConfigureResponse) ProtoReflect ¶
func (x *ConfigureResponse) ProtoReflect() protoreflect.Message
func (*ConfigureResponse) Reset ¶
func (x *ConfigureResponse) Reset()
func (*ConfigureResponse) SizeVT ¶
func (m *ConfigureResponse) SizeVT() (n int)
func (*ConfigureResponse) String ¶
func (x *ConfigureResponse) String() string
func (*ConfigureResponse) UnmarshalVT ¶
func (m *ConfigureResponse) UnmarshalVT(dAtA []byte) error
type Container ¶
type Container struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` PodSandboxId string `protobuf:"bytes,2,opt,name=pod_sandbox_id,json=podSandboxId,proto3" json:"pod_sandbox_id,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` State ContainerState `protobuf:"varint,4,opt,name=state,proto3,enum=nri.pkg.api.v1alpha1.ContainerState" json:"state,omitempty"` Labels map[string]string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` Annotations map[string]string `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` Args []string `protobuf:"bytes,7,rep,name=args,proto3" json:"args,omitempty"` Env []string `protobuf:"bytes,8,rep,name=env,proto3" json:"env,omitempty"` Mounts []*Mount `protobuf:"bytes,9,rep,name=mounts,proto3" json:"mounts,omitempty"` Hooks *Hooks `protobuf:"bytes,10,opt,name=hooks,proto3" json:"hooks,omitempty"` Linux *LinuxContainer `protobuf:"bytes,11,opt,name=linux,proto3" json:"linux,omitempty"` Pid uint32 `protobuf:"varint,12,opt,name=pid,proto3" json:"pid,omitempty"` // for NRI v1 emulation Rlimits []*POSIXRlimit `protobuf:"bytes,13,rep,name=rlimits,proto3" json:"rlimits,omitempty"` // contains filtered or unexported fields }
Container metadata that is considered relevant for a plugin.
func (*Container) Descriptor ¶
Deprecated: Use Container.ProtoReflect.Descriptor instead.
func (*Container) GetAnnotations ¶
func (*Container) GetArgs ¶
func (*Container) GetEnv ¶
func (*Container) GetHooks ¶
func (*Container) GetId ¶
func (*Container) GetLabels ¶
func (*Container) GetLinux ¶
func (x *Container) GetLinux() *LinuxContainer
func (*Container) GetMounts ¶
func (*Container) GetName ¶
func (*Container) GetPid ¶
func (*Container) GetPodSandboxId ¶
func (*Container) GetRlimits ¶
func (x *Container) GetRlimits() []*POSIXRlimit
func (*Container) GetState ¶
func (x *Container) GetState() ContainerState
func (*Container) MarshalToSizedBufferVT ¶
func (*Container) MarshalToVT ¶
func (*Container) MarshalVT ¶
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
func (*Container) ProtoReflect ¶
func (x *Container) ProtoReflect() protoreflect.Message
func (*Container) Reset ¶
func (x *Container) Reset()
func (*Container) SizeVT ¶
func (*Container) String ¶
func (*Container) UnmarshalVT ¶
type ContainerAdjustment ¶
type ContainerAdjustment struct { Annotations map[string]string `protobuf:"bytes,2,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` Mounts []*Mount `protobuf:"bytes,3,rep,name=mounts,proto3" json:"mounts,omitempty"` Env []*KeyValue `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"` Hooks *Hooks `protobuf:"bytes,5,opt,name=hooks,proto3" json:"hooks,omitempty"` Linux *LinuxContainerAdjustment `protobuf:"bytes,6,opt,name=linux,proto3" json:"linux,omitempty"` Rlimits []*POSIXRlimit `protobuf:"bytes,7,rep,name=rlimits,proto3" json:"rlimits,omitempty"` CDIDevices []*CDIDevice `protobuf:"bytes,8,rep,name=CDI_devices,json=CDIDevices,proto3" json:"CDI_devices,omitempty"` // contains filtered or unexported fields }
Requested adjustments to a container being created.
func (*ContainerAdjustment) AddAnnotation ¶
func (a *ContainerAdjustment) AddAnnotation(key, value string)
AddAnnotation records the addition of the annotation key=value.
func (*ContainerAdjustment) AddCDIDevice ¶
func (a *ContainerAdjustment) AddCDIDevice(d *CDIDevice)
AddCDIDevice records the addition of the given CDI device to a container.
func (*ContainerAdjustment) AddDevice ¶
func (a *ContainerAdjustment) AddDevice(d *LinuxDevice)
AddDevice records the addition of the given device to a container.
func (*ContainerAdjustment) AddEnv ¶
func (a *ContainerAdjustment) AddEnv(key, value string)
AddEnv records the addition of an environment variable to a container.
func (*ContainerAdjustment) AddHooks ¶
func (a *ContainerAdjustment) AddHooks(h *Hooks)
AddHooks records the addition of the given hooks to a container.
func (*ContainerAdjustment) AddLinuxHugepageLimit ¶
func (a *ContainerAdjustment) AddLinuxHugepageLimit(pageSize string, value uint64)
AddLinuxHugepageLimit records adding a hugepage limit for a container.
func (*ContainerAdjustment) AddLinuxUnified ¶
func (a *ContainerAdjustment) AddLinuxUnified(key, value string)
AddLinuxUnified sets a cgroupv2 unified resource.
func (*ContainerAdjustment) AddMount ¶
func (a *ContainerAdjustment) AddMount(m *Mount)
AddMount records the addition of a mount to a container.
func (*ContainerAdjustment) AddRlimit ¶
func (a *ContainerAdjustment) AddRlimit(typ string, hard, soft uint64)
func (*ContainerAdjustment) Descriptor ¶
func (*ContainerAdjustment) Descriptor() ([]byte, []int)
Deprecated: Use ContainerAdjustment.ProtoReflect.Descriptor instead.
func (*ContainerAdjustment) GetAnnotations ¶
func (x *ContainerAdjustment) GetAnnotations() map[string]string
func (*ContainerAdjustment) GetCDIDevices ¶
func (x *ContainerAdjustment) GetCDIDevices() []*CDIDevice
func (*ContainerAdjustment) GetEnv ¶
func (x *ContainerAdjustment) GetEnv() []*KeyValue
func (*ContainerAdjustment) GetHooks ¶
func (x *ContainerAdjustment) GetHooks() *Hooks
func (*ContainerAdjustment) GetLinux ¶
func (x *ContainerAdjustment) GetLinux() *LinuxContainerAdjustment
func (*ContainerAdjustment) GetMounts ¶
func (x *ContainerAdjustment) GetMounts() []*Mount
func (*ContainerAdjustment) GetRlimits ¶
func (x *ContainerAdjustment) GetRlimits() []*POSIXRlimit
func (*ContainerAdjustment) MarshalToSizedBufferVT ¶
func (m *ContainerAdjustment) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ContainerAdjustment) MarshalToVT ¶
func (m *ContainerAdjustment) MarshalToVT(dAtA []byte) (int, error)
func (*ContainerAdjustment) MarshalVT ¶
func (m *ContainerAdjustment) MarshalVT() (dAtA []byte, err error)
func (*ContainerAdjustment) ProtoMessage ¶
func (*ContainerAdjustment) ProtoMessage()
func (*ContainerAdjustment) ProtoReflect ¶
func (x *ContainerAdjustment) ProtoReflect() protoreflect.Message
func (*ContainerAdjustment) RemoveAnnotation ¶
func (a *ContainerAdjustment) RemoveAnnotation(key string)
RemoveAnnotation records the removal of the annotation for the given key. Normally it is an error for a plugin to try and alter an annotation touched by another plugin. However, this is not an error if the plugin removes that annotation prior to touching it.
func (*ContainerAdjustment) RemoveDevice ¶
func (a *ContainerAdjustment) RemoveDevice(path string)
RemoveDevice records the removal of a device from a container. Normally it is an error for a plugin to try and alter an device touched by another container. However, this is not an error if the plugin removes that device prior to touching it.
func (*ContainerAdjustment) RemoveEnv ¶
func (a *ContainerAdjustment) RemoveEnv(key string)
RemoveEnv records the removal of an environment variable from a container. Normally it is an error for a plugin to try and alter an environment variable touched by another container. However, this is not an error if the plugin removes that variable prior to touching it.
func (*ContainerAdjustment) RemoveMount ¶
func (a *ContainerAdjustment) RemoveMount(ContainerPath string)
RemoveMount records the removal of a mount from a container. Normally it is an error for a plugin to try and alter a mount touched by another plugin. However, this is not an error if the plugin removes that mount prior to touching it.
func (*ContainerAdjustment) Reset ¶
func (x *ContainerAdjustment) Reset()
func (*ContainerAdjustment) SetLinuxBlockIOClass ¶
func (a *ContainerAdjustment) SetLinuxBlockIOClass(value string)
SetLinuxBlockIOClass records setting the Block I/O class for a container.
func (*ContainerAdjustment) SetLinuxCPUPeriod ¶
func (a *ContainerAdjustment) SetLinuxCPUPeriod(value int64)
SetLinuxCPUPeriod records setting the scheduler's CPU period for a container.
func (*ContainerAdjustment) SetLinuxCPUQuota ¶
func (a *ContainerAdjustment) SetLinuxCPUQuota(value int64)
SetLinuxCPUQuota records setting the scheduler's CPU quota for a container.
func (*ContainerAdjustment) SetLinuxCPURealtimePeriod ¶
func (a *ContainerAdjustment) SetLinuxCPURealtimePeriod(value uint64)
SetLinuxCPURealtimePeriod records setting the scheduler's realtime period for a container.
func (*ContainerAdjustment) SetLinuxCPURealtimeRuntime ¶
func (a *ContainerAdjustment) SetLinuxCPURealtimeRuntime(value int64)
SetLinuxCPURealtimeRuntime records setting the scheduler's realtime runtime for a container.
func (*ContainerAdjustment) SetLinuxCPUSetCPUs ¶
func (a *ContainerAdjustment) SetLinuxCPUSetCPUs(value string)
SetLinuxCPUSetCPUs records setting the cpuset CPUs for a container.
func (*ContainerAdjustment) SetLinuxCPUSetMems ¶
func (a *ContainerAdjustment) SetLinuxCPUSetMems(value string)
SetLinuxCPUSetMems records setting the cpuset memory for a container.
func (*ContainerAdjustment) SetLinuxCPUShares ¶
func (a *ContainerAdjustment) SetLinuxCPUShares(value uint64)
SetLinuxCPUShares records setting the scheduler's CPU shares for a container.
func (*ContainerAdjustment) SetLinuxCgroupsPath ¶
func (a *ContainerAdjustment) SetLinuxCgroupsPath(value string)
SetLinuxCgroupsPath records setting the cgroups path for a container.
func (*ContainerAdjustment) SetLinuxMemoryDisableOomKiller ¶
func (a *ContainerAdjustment) SetLinuxMemoryDisableOomKiller()
SetLinuxMemoryDisableOomKiller records disabling the OOM killer for a container.
func (*ContainerAdjustment) SetLinuxMemoryKernel ¶
func (a *ContainerAdjustment) SetLinuxMemoryKernel(value int64)
SetLinuxMemoryKernel records setting the memory kernel limit for a container.
func (*ContainerAdjustment) SetLinuxMemoryKernelTCP ¶
func (a *ContainerAdjustment) SetLinuxMemoryKernelTCP(value int64)
SetLinuxMemoryKernelTCP records setting the memory kernel TCP limit for a container.
func (*ContainerAdjustment) SetLinuxMemoryLimit ¶
func (a *ContainerAdjustment) SetLinuxMemoryLimit(value int64)
SetLinuxMemoryLimit records setting the memory limit for a container.
func (*ContainerAdjustment) SetLinuxMemoryReservation ¶
func (a *ContainerAdjustment) SetLinuxMemoryReservation(value int64)
SetLinuxMemoryReservation records setting the memory reservation for a container.
func (*ContainerAdjustment) SetLinuxMemorySwap ¶
func (a *ContainerAdjustment) SetLinuxMemorySwap(value int64)
SetLinuxMemorySwap records records setting the memory swap limit for a container.
func (*ContainerAdjustment) SetLinuxMemorySwappiness ¶
func (a *ContainerAdjustment) SetLinuxMemorySwappiness(value uint64)
SetLinuxMemorySwappiness records setting the memory swappiness for a container.
func (*ContainerAdjustment) SetLinuxMemoryUseHierarchy ¶
func (a *ContainerAdjustment) SetLinuxMemoryUseHierarchy()
SetLinuxMemoryUseHierarchy records enabling hierarchical memory accounting for a container.
func (*ContainerAdjustment) SetLinuxOomScoreAdj ¶
func (a *ContainerAdjustment) SetLinuxOomScoreAdj(value *int)
SetLinuxOomScoreAdj records setting the kernel's Out-Of-Memory (OOM) killer score for a container.
func (*ContainerAdjustment) SetLinuxPidLimits ¶
func (a *ContainerAdjustment) SetLinuxPidLimits(value int64)
SetLinuxPidLimits records setting the pid max number for a container.
func (*ContainerAdjustment) SetLinuxRDTClass ¶
func (a *ContainerAdjustment) SetLinuxRDTClass(value string)
SetLinuxRDTClass records setting the RDT class for a container.
func (*ContainerAdjustment) SizeVT ¶
func (m *ContainerAdjustment) SizeVT() (n int)
func (*ContainerAdjustment) String ¶
func (x *ContainerAdjustment) String() string
func (*ContainerAdjustment) UnmarshalVT ¶
func (m *ContainerAdjustment) UnmarshalVT(dAtA []byte) error
type ContainerEviction ¶
type ContainerEviction struct { // Container to evict. ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // Human-readable reason for eviction. Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
Request to evict (IOW unsolicitedly stop) a container.
func (*ContainerEviction) Descriptor ¶
func (*ContainerEviction) Descriptor() ([]byte, []int)
Deprecated: Use ContainerEviction.ProtoReflect.Descriptor instead.
func (*ContainerEviction) GetContainerId ¶
func (x *ContainerEviction) GetContainerId() string
func (*ContainerEviction) GetReason ¶
func (x *ContainerEviction) GetReason() string
func (*ContainerEviction) MarshalToSizedBufferVT ¶
func (m *ContainerEviction) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ContainerEviction) MarshalToVT ¶
func (m *ContainerEviction) MarshalToVT(dAtA []byte) (int, error)
func (*ContainerEviction) MarshalVT ¶
func (m *ContainerEviction) MarshalVT() (dAtA []byte, err error)
func (*ContainerEviction) ProtoMessage ¶
func (*ContainerEviction) ProtoMessage()
func (*ContainerEviction) ProtoReflect ¶
func (x *ContainerEviction) ProtoReflect() protoreflect.Message
func (*ContainerEviction) Reset ¶
func (x *ContainerEviction) Reset()
func (*ContainerEviction) SizeVT ¶
func (m *ContainerEviction) SizeVT() (n int)
func (*ContainerEviction) String ¶
func (x *ContainerEviction) String() string
func (*ContainerEviction) UnmarshalVT ¶
func (m *ContainerEviction) UnmarshalVT(dAtA []byte) error
type ContainerState ¶
type ContainerState int32
Possible container states.
const ( ContainerState_CONTAINER_UNKNOWN ContainerState = 0 ContainerState_CONTAINER_CREATED ContainerState = 1 ContainerState_CONTAINER_PAUSED ContainerState = 2 // is this useful/necessary ? ContainerState_CONTAINER_RUNNING ContainerState = 3 ContainerState_CONTAINER_STOPPED ContainerState = 4 )
func (ContainerState) Descriptor ¶
func (ContainerState) Descriptor() protoreflect.EnumDescriptor
func (ContainerState) Enum ¶
func (x ContainerState) Enum() *ContainerState
func (ContainerState) EnumDescriptor ¶
func (ContainerState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContainerState.Descriptor instead.
func (ContainerState) Number ¶
func (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 ¶
func (*ContainerUpdate) Descriptor() ([]byte, []int)
Deprecated: Use ContainerUpdate.ProtoReflect.Descriptor instead.
func (*ContainerUpdate) GetContainerId ¶
func (x *ContainerUpdate) GetContainerId() string
func (*ContainerUpdate) GetIgnoreFailure ¶
func (x *ContainerUpdate) GetIgnoreFailure() bool
func (*ContainerUpdate) GetLinux ¶
func (x *ContainerUpdate) GetLinux() *LinuxContainerUpdate
func (*ContainerUpdate) MarshalToSizedBufferVT ¶
func (m *ContainerUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ContainerUpdate) MarshalToVT ¶
func (m *ContainerUpdate) MarshalToVT(dAtA []byte) (int, error)
func (*ContainerUpdate) MarshalVT ¶
func (m *ContainerUpdate) MarshalVT() (dAtA []byte, err error)
func (*ContainerUpdate) ProtoMessage ¶
func (*ContainerUpdate) ProtoMessage()
func (*ContainerUpdate) ProtoReflect ¶
func (x *ContainerUpdate) ProtoReflect() protoreflect.Message
func (*ContainerUpdate) Reset ¶
func (x *ContainerUpdate) Reset()
func (*ContainerUpdate) SetContainerId ¶
func (u *ContainerUpdate) SetContainerId(id string)
nolint SetContainerId sets the id of the container to update.
func (*ContainerUpdate) SetIgnoreFailure ¶
func (u *ContainerUpdate) SetIgnoreFailure()
SetIgnoreFailure marks an Update as ignored for failures. Such updates will not prevent the related container operation from succeeding if the update fails.
func (*ContainerUpdate) SetLinuxBlockIOClass ¶
func (u *ContainerUpdate) SetLinuxBlockIOClass(value string)
SetLinuxBlockIOClass records setting the Block I/O class for a container.
func (*ContainerUpdate) SetLinuxCPUPeriod ¶
func (u *ContainerUpdate) SetLinuxCPUPeriod(value int64)
SetLinuxCPUPeriod records setting the scheduler's CPU period for a container.
func (*ContainerUpdate) SetLinuxCPUQuota ¶
func (u *ContainerUpdate) SetLinuxCPUQuota(value int64)
SetLinuxCPUQuota records setting the scheduler's CPU quota for a container.
func (*ContainerUpdate) SetLinuxCPURealtimePeriod ¶
func (u *ContainerUpdate) SetLinuxCPURealtimePeriod(value uint64)
SetLinuxCPURealtimePeriod records setting the scheduler's realtime period for a container.
func (*ContainerUpdate) SetLinuxCPURealtimeRuntime ¶
func (u *ContainerUpdate) SetLinuxCPURealtimeRuntime(value int64)
SetLinuxCPURealtimeRuntime records setting the scheduler's realtime runtime for a container.
func (*ContainerUpdate) SetLinuxCPUSetCPUs ¶
func (u *ContainerUpdate) SetLinuxCPUSetCPUs(value string)
SetLinuxCPUSetCPUs records setting the cpuset CPUs for a container.
func (*ContainerUpdate) SetLinuxCPUSetMems ¶
func (u *ContainerUpdate) SetLinuxCPUSetMems(value string)
SetLinuxCPUSetMems records setting the cpuset memory for a container.
func (*ContainerUpdate) SetLinuxCPUShares ¶
func (u *ContainerUpdate) SetLinuxCPUShares(value uint64)
SetLinuxCPUShares records setting the scheduler's CPU shares for a container.
func (*ContainerUpdate) SetLinuxMemoryDisableOomKiller ¶
func (u *ContainerUpdate) SetLinuxMemoryDisableOomKiller()
SetLinuxMemoryDisableOomKiller records disabling the OOM killer for a container.
func (*ContainerUpdate) SetLinuxMemoryKernel ¶
func (u *ContainerUpdate) SetLinuxMemoryKernel(value int64)
SetLinuxMemoryKernel records setting the memory kernel limit for a container.
func (*ContainerUpdate) SetLinuxMemoryKernelTCP ¶
func (u *ContainerUpdate) SetLinuxMemoryKernelTCP(value int64)
SetLinuxMemoryKernelTCP records setting the memory kernel TCP limit for a container.
func (*ContainerUpdate) SetLinuxMemoryLimit ¶
func (u *ContainerUpdate) SetLinuxMemoryLimit(value int64)
SetLinuxMemoryLimit records setting the memory limit for a container.
func (*ContainerUpdate) SetLinuxMemoryReservation ¶
func (u *ContainerUpdate) SetLinuxMemoryReservation(value int64)
SetLinuxMemoryReservation records setting the memory reservation for a container.
func (*ContainerUpdate) SetLinuxMemorySwap ¶
func (u *ContainerUpdate) SetLinuxMemorySwap(value int64)
SetLinuxMemorySwap records records setting the memory swap limit for a container.
func (*ContainerUpdate) SetLinuxMemorySwappiness ¶
func (u *ContainerUpdate) SetLinuxMemorySwappiness(value uint64)
SetLinuxMemorySwappiness records setting the memory swappiness for a container.
func (*ContainerUpdate) SetLinuxMemoryUseHierarchy ¶
func (u *ContainerUpdate) SetLinuxMemoryUseHierarchy()
SetLinuxMemoryUseHierarchy records enabling hierarchical memory accounting for a container.
func (*ContainerUpdate) SetLinuxPidLimits ¶
func (u *ContainerUpdate) SetLinuxPidLimits(value int64)
SetLinuxPidLimits records setting the pid max number for a container.
func (*ContainerUpdate) SetLinuxRDTClass ¶
func (u *ContainerUpdate) SetLinuxRDTClass(value string)
SetLinuxRDTClass records setting the RDT class for a container.
func (*ContainerUpdate) SizeVT ¶
func (m *ContainerUpdate) SizeVT() (n int)
func (*ContainerUpdate) String ¶
func (x *ContainerUpdate) String() string
func (*ContainerUpdate) UnmarshalVT ¶
func (m *ContainerUpdate) UnmarshalVT(dAtA []byte) error
type CreateContainerRequest ¶
type CreateContainerRequest struct { // Pod of container being created. Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` // Container being created. Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` // contains filtered or unexported fields }
func (*CreateContainerRequest) Descriptor ¶
func (*CreateContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateContainerRequest.ProtoReflect.Descriptor instead.
func (*CreateContainerRequest) GetContainer ¶
func (x *CreateContainerRequest) GetContainer() *Container
func (*CreateContainerRequest) GetPod ¶
func (x *CreateContainerRequest) GetPod() *PodSandbox
func (*CreateContainerRequest) MarshalToSizedBufferVT ¶
func (m *CreateContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateContainerRequest) MarshalToVT ¶
func (m *CreateContainerRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateContainerRequest) MarshalVT ¶
func (m *CreateContainerRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateContainerRequest) ProtoMessage ¶
func (*CreateContainerRequest) ProtoMessage()
func (*CreateContainerRequest) ProtoReflect ¶
func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message
func (*CreateContainerRequest) Reset ¶
func (x *CreateContainerRequest) Reset()
func (*CreateContainerRequest) SizeVT ¶
func (m *CreateContainerRequest) SizeVT() (n int)
func (*CreateContainerRequest) String ¶
func (x *CreateContainerRequest) String() string
func (*CreateContainerRequest) UnmarshalVT ¶
func (m *CreateContainerRequest) UnmarshalVT(dAtA []byte) error
type CreateContainerResponse ¶
type CreateContainerResponse struct { // Requested adjustments to container being created. Adjust *ContainerAdjustment `protobuf:"bytes,1,opt,name=adjust,proto3" json:"adjust,omitempty"` // Requested updates to other existing containers. Update []*ContainerUpdate `protobuf:"bytes,2,rep,name=update,proto3" json:"update,omitempty"` // Requested eviction of existing containers. Evict []*ContainerEviction `protobuf:"bytes,3,rep,name=evict,proto3" json:"evict,omitempty"` // contains filtered or unexported fields }
func (*CreateContainerResponse) Descriptor ¶
func (*CreateContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateContainerResponse.ProtoReflect.Descriptor instead.
func (*CreateContainerResponse) GetAdjust ¶
func (x *CreateContainerResponse) GetAdjust() *ContainerAdjustment
func (*CreateContainerResponse) GetEvict ¶
func (x *CreateContainerResponse) GetEvict() []*ContainerEviction
func (*CreateContainerResponse) GetUpdate ¶
func (x *CreateContainerResponse) GetUpdate() []*ContainerUpdate
func (*CreateContainerResponse) MarshalToSizedBufferVT ¶
func (m *CreateContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateContainerResponse) MarshalToVT ¶
func (m *CreateContainerResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateContainerResponse) MarshalVT ¶
func (m *CreateContainerResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateContainerResponse) ProtoMessage ¶
func (*CreateContainerResponse) ProtoMessage()
func (*CreateContainerResponse) ProtoReflect ¶
func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message
func (*CreateContainerResponse) Reset ¶
func (x *CreateContainerResponse) Reset()
func (*CreateContainerResponse) SizeVT ¶
func (m *CreateContainerResponse) SizeVT() (n int)
func (*CreateContainerResponse) String ¶
func (x *CreateContainerResponse) String() string
func (*CreateContainerResponse) UnmarshalVT ¶
func (m *CreateContainerResponse) UnmarshalVT(dAtA []byte) error
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
Empty response for those *Requests that are semantically events.
func (*Empty) Descriptor ¶
Deprecated: Use Empty.ProtoReflect.Descriptor instead.
func (*Empty) MarshalToSizedBufferVT ¶
func (*Empty) MarshalToVT ¶
func (*Empty) MarshalVT ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
func (*Empty) Reset ¶
func (x *Empty) Reset()
func (*Empty) SizeVT ¶
func (*Empty) String ¶
func (*Empty) UnmarshalVT ¶
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 (Event) EnumDescriptor ¶
Deprecated: Use Event.Descriptor instead.
func (Event) Number ¶
func (x Event) Number() protoreflect.EnumNumber
func (Event) String ¶
func (Event) Type ¶
func (Event) Type() protoreflect.EnumType
type EventMask ¶
type EventMask int32
EventMask corresponds to a set of enumerated Events.
func MustParseEventMask ¶
MustParseEventMask parses the given events, panic()ing on errors.
func ParseEventMask ¶
ParseEventMask parses a string representation into an EventMask.
func (*EventMask) Clear ¶
Clear clears the given Events in the mask.
func (*EventMask) IsSet ¶
IsSet check if the given Event is set in the mask.
func (*EventMask) PrettyString ¶
PrettyString returns a human-readable string representation of an EventMask.
func (*EventMask) Set ¶
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 ¶
FromOCIHookSlice returns a hook slice from an OCI runtime Spec.
func (*Hook) Descriptor ¶
Deprecated: Use Hook.ProtoReflect.Descriptor instead.
func (*Hook) GetArgs ¶
func (*Hook) GetEnv ¶
func (*Hook) GetPath ¶
func (*Hook) GetTimeout ¶
func (x *Hook) GetTimeout() *OptionalInt
func (*Hook) MarshalToSizedBufferVT ¶
func (*Hook) MarshalToVT ¶
func (*Hook) MarshalVT ¶
func (*Hook) ProtoMessage ¶
func (*Hook) ProtoMessage()
func (*Hook) ProtoReflect ¶
func (x *Hook) ProtoReflect() protoreflect.Message
func (*Hook) Reset ¶
func (x *Hook) Reset()
func (*Hook) SizeVT ¶
func (*Hook) String ¶
func (*Hook) ToOCI ¶
ToOCI returns the hook for an OCI runtime Spec.
func (*Hook) UnmarshalVT ¶
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 ¶
FromOCIHooks returns hooks from an OCI runtime Spec.
func (*Hooks) Append ¶
Append appends the given hooks to the existing ones.
func (*Hooks) Descriptor ¶
Deprecated: Use Hooks.ProtoReflect.Descriptor instead.
func (*Hooks) GetCreateContainer ¶
func (*Hooks) GetCreateRuntime ¶
func (*Hooks) GetPoststart ¶
func (*Hooks) GetPoststop ¶
func (*Hooks) GetPrestart ¶
func (*Hooks) GetStartContainer ¶
func (*Hooks) Hooks ¶
Hooks returns itself it any of its hooks is set. Otherwise it returns nil.
func (*Hooks) MarshalToSizedBufferVT ¶
func (*Hooks) MarshalToVT ¶
func (*Hooks) MarshalVT ¶
func (*Hooks) ProtoMessage ¶
func (*Hooks) ProtoMessage()
func (*Hooks) ProtoReflect ¶
func (x *Hooks) ProtoReflect() protoreflect.Message
func (*Hooks) Reset ¶
func (x *Hooks) Reset()
func (*Hooks) SizeVT ¶
func (*Hooks) String ¶
func (*Hooks) UnmarshalVT ¶
type HostFunctions ¶
type HostFunctions interface { // Log displays a log message Log(context.Context, *LogRequest) (*Empty, error) }
go:plugin type=host
type HostFunctionsService ¶
type HostFunctionsService interface { Log(context.Context, *LogRequest) (*Empty, error) }
func NewHostFunctionsClient ¶
func NewHostFunctionsClient(client *ttrpc.Client) HostFunctionsService
type HugepageLimit ¶
type HugepageLimit struct { PageSize string `protobuf:"bytes,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Limit uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
Container huge page limit.
func (*HugepageLimit) Descriptor ¶
func (*HugepageLimit) Descriptor() ([]byte, []int)
Deprecated: Use HugepageLimit.ProtoReflect.Descriptor instead.
func (*HugepageLimit) GetLimit ¶
func (x *HugepageLimit) GetLimit() uint64
func (*HugepageLimit) GetPageSize ¶
func (x *HugepageLimit) GetPageSize() string
func (*HugepageLimit) MarshalToSizedBufferVT ¶
func (m *HugepageLimit) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*HugepageLimit) MarshalToVT ¶
func (m *HugepageLimit) MarshalToVT(dAtA []byte) (int, error)
func (*HugepageLimit) MarshalVT ¶
func (m *HugepageLimit) MarshalVT() (dAtA []byte, err error)
func (*HugepageLimit) ProtoMessage ¶
func (*HugepageLimit) ProtoMessage()
func (*HugepageLimit) ProtoReflect ¶
func (x *HugepageLimit) ProtoReflect() protoreflect.Message
func (*HugepageLimit) Reset ¶
func (x *HugepageLimit) Reset()
func (*HugepageLimit) SizeVT ¶
func (m *HugepageLimit) SizeVT() (n int)
func (*HugepageLimit) String ¶
func (x *HugepageLimit) String() string
func (*HugepageLimit) UnmarshalVT ¶
func (m *HugepageLimit) UnmarshalVT(dAtA []byte) error
type KeyValue ¶
type KeyValue struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
KeyValue represents an environment variable.
func FromOCIEnv ¶
FromOCIEnv returns KeyValues from an OCI runtime Spec environment.
func (*KeyValue) Descriptor ¶
Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.
func (*KeyValue) GetKey ¶
func (*KeyValue) GetValue ¶
func (*KeyValue) IsMarkedForRemoval ¶
IsMarkedForRemoval checks if an environment variable is marked for removal.
func (*KeyValue) MarshalToSizedBufferVT ¶
func (*KeyValue) MarshalToVT ¶
func (*KeyValue) MarshalVT ¶
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
func (*KeyValue) ProtoReflect ¶
func (x *KeyValue) ProtoReflect() protoreflect.Message
func (*KeyValue) Reset ¶
func (x *KeyValue) Reset()
func (*KeyValue) SizeVT ¶
func (*KeyValue) String ¶
func (*KeyValue) ToOCI ¶
ToOCI returns an OCI Env entry for the KeyValue.
func (*KeyValue) UnmarshalVT ¶
type LinuxCPU ¶
type LinuxCPU struct { 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: Use LinuxCPU.ProtoReflect.Descriptor instead.
func (*LinuxCPU) GetCpus ¶
func (*LinuxCPU) GetMems ¶
func (*LinuxCPU) GetPeriod ¶
func (x *LinuxCPU) GetPeriod() *OptionalUInt64
func (*LinuxCPU) GetQuota ¶
func (x *LinuxCPU) GetQuota() *OptionalInt64
func (*LinuxCPU) GetRealtimePeriod ¶
func (x *LinuxCPU) GetRealtimePeriod() *OptionalUInt64
func (*LinuxCPU) GetRealtimeRuntime ¶
func (x *LinuxCPU) GetRealtimeRuntime() *OptionalInt64
func (*LinuxCPU) GetShares ¶
func (x *LinuxCPU) GetShares() *OptionalUInt64
func (*LinuxCPU) MarshalToSizedBufferVT ¶
func (*LinuxCPU) MarshalToVT ¶
func (*LinuxCPU) MarshalVT ¶
func (*LinuxCPU) ProtoMessage ¶
func (*LinuxCPU) ProtoMessage()
func (*LinuxCPU) ProtoReflect ¶
func (x *LinuxCPU) ProtoReflect() protoreflect.Message
func (*LinuxCPU) Reset ¶
func (x *LinuxCPU) Reset()
func (*LinuxCPU) SizeVT ¶
func (*LinuxCPU) String ¶
func (*LinuxCPU) UnmarshalVT ¶
type LinuxContainer ¶
type LinuxContainer struct { Namespaces []*LinuxNamespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"` Devices []*LinuxDevice `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"` Resources *LinuxResources `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"` OomScoreAdj *OptionalInt `protobuf:"bytes,4,opt,name=oom_score_adj,json=oomScoreAdj,proto3" json:"oom_score_adj,omitempty"` CgroupsPath string `protobuf:"bytes,5,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"` // contains filtered or unexported fields }
Container (linux) metadata.
func (*LinuxContainer) Descriptor ¶
func (*LinuxContainer) Descriptor() ([]byte, []int)
Deprecated: Use LinuxContainer.ProtoReflect.Descriptor instead.
func (*LinuxContainer) GetCgroupsPath ¶
func (x *LinuxContainer) GetCgroupsPath() string
func (*LinuxContainer) GetDevices ¶
func (x *LinuxContainer) GetDevices() []*LinuxDevice
func (*LinuxContainer) GetNamespaces ¶
func (x *LinuxContainer) GetNamespaces() []*LinuxNamespace
func (*LinuxContainer) GetOomScoreAdj ¶
func (x *LinuxContainer) GetOomScoreAdj() *OptionalInt
func (*LinuxContainer) GetResources ¶
func (x *LinuxContainer) GetResources() *LinuxResources
func (*LinuxContainer) MarshalToSizedBufferVT ¶
func (m *LinuxContainer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxContainer) MarshalToVT ¶
func (m *LinuxContainer) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxContainer) MarshalVT ¶
func (m *LinuxContainer) MarshalVT() (dAtA []byte, err error)
func (*LinuxContainer) ProtoMessage ¶
func (*LinuxContainer) ProtoMessage()
func (*LinuxContainer) ProtoReflect ¶
func (x *LinuxContainer) ProtoReflect() protoreflect.Message
func (*LinuxContainer) Reset ¶
func (x *LinuxContainer) Reset()
func (*LinuxContainer) SizeVT ¶
func (m *LinuxContainer) SizeVT() (n int)
func (*LinuxContainer) String ¶
func (x *LinuxContainer) String() string
func (*LinuxContainer) UnmarshalVT ¶
func (m *LinuxContainer) UnmarshalVT(dAtA []byte) error
type LinuxContainerAdjustment ¶
type LinuxContainerAdjustment struct { Devices []*LinuxDevice `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"` Resources *LinuxResources `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"` CgroupsPath string `protobuf:"bytes,3,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"` OomScoreAdj *OptionalInt `protobuf:"bytes,4,opt,name=oom_score_adj,json=oomScoreAdj,proto3" json:"oom_score_adj,omitempty"` // contains filtered or unexported fields }
Adjustments to (linux) resources.
func (*LinuxContainerAdjustment) Descriptor ¶
func (*LinuxContainerAdjustment) Descriptor() ([]byte, []int)
Deprecated: Use LinuxContainerAdjustment.ProtoReflect.Descriptor instead.
func (*LinuxContainerAdjustment) GetCgroupsPath ¶
func (x *LinuxContainerAdjustment) GetCgroupsPath() string
func (*LinuxContainerAdjustment) GetDevices ¶
func (x *LinuxContainerAdjustment) GetDevices() []*LinuxDevice
func (*LinuxContainerAdjustment) GetOomScoreAdj ¶
func (x *LinuxContainerAdjustment) GetOomScoreAdj() *OptionalInt
func (*LinuxContainerAdjustment) GetResources ¶
func (x *LinuxContainerAdjustment) GetResources() *LinuxResources
func (*LinuxContainerAdjustment) MarshalToSizedBufferVT ¶
func (m *LinuxContainerAdjustment) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxContainerAdjustment) MarshalToVT ¶
func (m *LinuxContainerAdjustment) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxContainerAdjustment) MarshalVT ¶
func (m *LinuxContainerAdjustment) MarshalVT() (dAtA []byte, err error)
func (*LinuxContainerAdjustment) ProtoMessage ¶
func (*LinuxContainerAdjustment) ProtoMessage()
func (*LinuxContainerAdjustment) ProtoReflect ¶
func (x *LinuxContainerAdjustment) ProtoReflect() protoreflect.Message
func (*LinuxContainerAdjustment) Reset ¶
func (x *LinuxContainerAdjustment) Reset()
func (*LinuxContainerAdjustment) SizeVT ¶
func (m *LinuxContainerAdjustment) SizeVT() (n int)
func (*LinuxContainerAdjustment) String ¶
func (x *LinuxContainerAdjustment) String() string
func (*LinuxContainerAdjustment) UnmarshalVT ¶
func (m *LinuxContainerAdjustment) UnmarshalVT(dAtA []byte) error
type LinuxContainerUpdate ¶
type LinuxContainerUpdate struct { Resources *LinuxResources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"` // contains filtered or unexported fields }
Updates to (linux) resources.
func (*LinuxContainerUpdate) Descriptor ¶
func (*LinuxContainerUpdate) Descriptor() ([]byte, []int)
Deprecated: Use LinuxContainerUpdate.ProtoReflect.Descriptor instead.
func (*LinuxContainerUpdate) GetResources ¶
func (x *LinuxContainerUpdate) GetResources() *LinuxResources
func (*LinuxContainerUpdate) MarshalToSizedBufferVT ¶
func (m *LinuxContainerUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxContainerUpdate) MarshalToVT ¶
func (m *LinuxContainerUpdate) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxContainerUpdate) MarshalVT ¶
func (m *LinuxContainerUpdate) MarshalVT() (dAtA []byte, err error)
func (*LinuxContainerUpdate) ProtoMessage ¶
func (*LinuxContainerUpdate) ProtoMessage()
func (*LinuxContainerUpdate) ProtoReflect ¶
func (x *LinuxContainerUpdate) ProtoReflect() protoreflect.Message
func (*LinuxContainerUpdate) Reset ¶
func (x *LinuxContainerUpdate) Reset()
func (*LinuxContainerUpdate) SizeVT ¶
func (m *LinuxContainerUpdate) SizeVT() (n int)
func (*LinuxContainerUpdate) String ¶
func (x *LinuxContainerUpdate) String() string
func (*LinuxContainerUpdate) UnmarshalVT ¶
func (m *LinuxContainerUpdate) UnmarshalVT(dAtA []byte) error
type LinuxDevice ¶
type LinuxDevice struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Major int64 `protobuf:"varint,3,opt,name=major,proto3" json:"major,omitempty"` Minor int64 `protobuf:"varint,4,opt,name=minor,proto3" json:"minor,omitempty"` FileMode *OptionalFileMode `protobuf:"bytes,5,opt,name=file_mode,json=fileMode,proto3" json:"file_mode,omitempty"` Uid *OptionalUInt32 `protobuf:"bytes,6,opt,name=uid,proto3" json:"uid,omitempty"` Gid *OptionalUInt32 `protobuf:"bytes,7,opt,name=gid,proto3" json:"gid,omitempty"` // contains filtered or unexported fields }
A container (linux) device.
func FromOCILinuxDevices ¶
func FromOCILinuxDevices(o []rspec.LinuxDevice) []*LinuxDevice
FromOCILinuxDevices returns a device slice from an OCI runtime Spec.
func (*LinuxDevice) AccessString ¶
func (d *LinuxDevice) AccessString() string
AccessString returns an OCI access string for the device.
func (*LinuxDevice) Cmp ¶
func (d *LinuxDevice) Cmp(v *LinuxDevice) bool
Cmp returns true if the devices are equal.
func (*LinuxDevice) Descriptor ¶
func (*LinuxDevice) Descriptor() ([]byte, []int)
Deprecated: Use LinuxDevice.ProtoReflect.Descriptor instead.
func (*LinuxDevice) GetFileMode ¶
func (x *LinuxDevice) GetFileMode() *OptionalFileMode
func (*LinuxDevice) GetGid ¶
func (x *LinuxDevice) GetGid() *OptionalUInt32
func (*LinuxDevice) GetMajor ¶
func (x *LinuxDevice) GetMajor() int64
func (*LinuxDevice) GetMinor ¶
func (x *LinuxDevice) GetMinor() int64
func (*LinuxDevice) GetPath ¶
func (x *LinuxDevice) GetPath() string
func (*LinuxDevice) GetType ¶
func (x *LinuxDevice) GetType() string
func (*LinuxDevice) GetUid ¶
func (x *LinuxDevice) GetUid() *OptionalUInt32
func (*LinuxDevice) IsMarkedForRemoval ¶
func (d *LinuxDevice) IsMarkedForRemoval() (string, bool)
IsMarkedForRemoval checks if a LinuxDevice is marked for removal.
func (*LinuxDevice) MarshalToSizedBufferVT ¶
func (m *LinuxDevice) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxDevice) MarshalToVT ¶
func (m *LinuxDevice) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxDevice) MarshalVT ¶
func (m *LinuxDevice) MarshalVT() (dAtA []byte, err error)
func (*LinuxDevice) ProtoMessage ¶
func (*LinuxDevice) ProtoMessage()
func (*LinuxDevice) ProtoReflect ¶
func (x *LinuxDevice) ProtoReflect() protoreflect.Message
func (*LinuxDevice) Reset ¶
func (x *LinuxDevice) Reset()
func (*LinuxDevice) SizeVT ¶
func (m *LinuxDevice) SizeVT() (n int)
func (*LinuxDevice) String ¶
func (x *LinuxDevice) String() string
func (*LinuxDevice) ToOCI ¶
func (d *LinuxDevice) ToOCI() rspec.LinuxDevice
ToOCI returns the linux devices for an OCI runtime Spec.
func (*LinuxDevice) UnmarshalVT ¶
func (m *LinuxDevice) UnmarshalVT(dAtA []byte) error
type LinuxDeviceCgroup ¶
type LinuxDeviceCgroup struct { Allow bool `protobuf:"varint,1,opt,name=allow,proto3" json:"allow,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Major *OptionalInt64 `protobuf:"bytes,3,opt,name=major,proto3" json:"major,omitempty"` Minor *OptionalInt64 `protobuf:"bytes,4,opt,name=minor,proto3" json:"minor,omitempty"` Access string `protobuf:"bytes,5,opt,name=access,proto3" json:"access,omitempty"` // contains filtered or unexported fields }
A linux device cgroup controller rule.
func (*LinuxDeviceCgroup) Descriptor ¶
func (*LinuxDeviceCgroup) Descriptor() ([]byte, []int)
Deprecated: Use LinuxDeviceCgroup.ProtoReflect.Descriptor instead.
func (*LinuxDeviceCgroup) GetAccess ¶
func (x *LinuxDeviceCgroup) GetAccess() string
func (*LinuxDeviceCgroup) GetAllow ¶
func (x *LinuxDeviceCgroup) GetAllow() bool
func (*LinuxDeviceCgroup) GetMajor ¶
func (x *LinuxDeviceCgroup) GetMajor() *OptionalInt64
func (*LinuxDeviceCgroup) GetMinor ¶
func (x *LinuxDeviceCgroup) GetMinor() *OptionalInt64
func (*LinuxDeviceCgroup) GetType ¶
func (x *LinuxDeviceCgroup) GetType() string
func (*LinuxDeviceCgroup) MarshalToSizedBufferVT ¶
func (m *LinuxDeviceCgroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxDeviceCgroup) MarshalToVT ¶
func (m *LinuxDeviceCgroup) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxDeviceCgroup) MarshalVT ¶
func (m *LinuxDeviceCgroup) MarshalVT() (dAtA []byte, err error)
func (*LinuxDeviceCgroup) ProtoMessage ¶
func (*LinuxDeviceCgroup) ProtoMessage()
func (*LinuxDeviceCgroup) ProtoReflect ¶
func (x *LinuxDeviceCgroup) ProtoReflect() protoreflect.Message
func (*LinuxDeviceCgroup) Reset ¶
func (x *LinuxDeviceCgroup) Reset()
func (*LinuxDeviceCgroup) SizeVT ¶
func (m *LinuxDeviceCgroup) SizeVT() (n int)
func (*LinuxDeviceCgroup) String ¶
func (x *LinuxDeviceCgroup) String() string
func (*LinuxDeviceCgroup) UnmarshalVT ¶
func (m *LinuxDeviceCgroup) UnmarshalVT(dAtA []byte) error
type LinuxMemory ¶
type LinuxMemory struct { Limit *OptionalInt64 `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"` Reservation *OptionalInt64 `protobuf:"bytes,2,opt,name=reservation,proto3" json:"reservation,omitempty"` Swap *OptionalInt64 `protobuf:"bytes,3,opt,name=swap,proto3" json:"swap,omitempty"` Kernel *OptionalInt64 `protobuf:"bytes,4,opt,name=kernel,proto3" json:"kernel,omitempty"` KernelTcp *OptionalInt64 `protobuf:"bytes,5,opt,name=kernel_tcp,json=kernelTcp,proto3" json:"kernel_tcp,omitempty"` Swappiness *OptionalUInt64 `protobuf:"bytes,6,opt,name=swappiness,proto3" json:"swappiness,omitempty"` DisableOomKiller *OptionalBool `protobuf:"bytes,7,opt,name=disable_oom_killer,json=disableOomKiller,proto3" json:"disable_oom_killer,omitempty"` UseHierarchy *OptionalBool `protobuf:"bytes,8,opt,name=use_hierarchy,json=useHierarchy,proto3" json:"use_hierarchy,omitempty"` // contains filtered or unexported fields }
Memory-related parts of (linux) resources.
func (*LinuxMemory) Descriptor ¶
func (*LinuxMemory) Descriptor() ([]byte, []int)
Deprecated: Use LinuxMemory.ProtoReflect.Descriptor instead.
func (*LinuxMemory) GetDisableOomKiller ¶
func (x *LinuxMemory) GetDisableOomKiller() *OptionalBool
func (*LinuxMemory) GetKernel ¶
func (x *LinuxMemory) GetKernel() *OptionalInt64
func (*LinuxMemory) GetKernelTcp ¶
func (x *LinuxMemory) GetKernelTcp() *OptionalInt64
func (*LinuxMemory) GetLimit ¶
func (x *LinuxMemory) GetLimit() *OptionalInt64
func (*LinuxMemory) GetReservation ¶
func (x *LinuxMemory) GetReservation() *OptionalInt64
func (*LinuxMemory) GetSwap ¶
func (x *LinuxMemory) GetSwap() *OptionalInt64
func (*LinuxMemory) GetSwappiness ¶
func (x *LinuxMemory) GetSwappiness() *OptionalUInt64
func (*LinuxMemory) GetUseHierarchy ¶
func (x *LinuxMemory) GetUseHierarchy() *OptionalBool
func (*LinuxMemory) MarshalToSizedBufferVT ¶
func (m *LinuxMemory) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxMemory) MarshalToVT ¶
func (m *LinuxMemory) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxMemory) MarshalVT ¶
func (m *LinuxMemory) MarshalVT() (dAtA []byte, err error)
func (*LinuxMemory) ProtoMessage ¶
func (*LinuxMemory) ProtoMessage()
func (*LinuxMemory) ProtoReflect ¶
func (x *LinuxMemory) ProtoReflect() protoreflect.Message
func (*LinuxMemory) Reset ¶
func (x *LinuxMemory) Reset()
func (*LinuxMemory) SizeVT ¶
func (m *LinuxMemory) SizeVT() (n int)
func (*LinuxMemory) String ¶
func (x *LinuxMemory) String() string
func (*LinuxMemory) UnmarshalVT ¶
func (m *LinuxMemory) UnmarshalVT(dAtA []byte) error
type LinuxNamespace ¶
type LinuxNamespace struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
A linux namespace.
func FromOCILinuxNamespaces ¶
func FromOCILinuxNamespaces(o []rspec.LinuxNamespace) []*LinuxNamespace
FromOCILinuxNamespaces returns a namespace slice from an OCI runtime Spec.
func (*LinuxNamespace) Descriptor ¶
func (*LinuxNamespace) Descriptor() ([]byte, []int)
Deprecated: Use LinuxNamespace.ProtoReflect.Descriptor instead.
func (*LinuxNamespace) GetPath ¶
func (x *LinuxNamespace) GetPath() string
func (*LinuxNamespace) GetType ¶
func (x *LinuxNamespace) GetType() string
func (*LinuxNamespace) MarshalToSizedBufferVT ¶
func (m *LinuxNamespace) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxNamespace) MarshalToVT ¶
func (m *LinuxNamespace) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxNamespace) MarshalVT ¶
func (m *LinuxNamespace) MarshalVT() (dAtA []byte, err error)
func (*LinuxNamespace) ProtoMessage ¶
func (*LinuxNamespace) ProtoMessage()
func (*LinuxNamespace) ProtoReflect ¶
func (x *LinuxNamespace) ProtoReflect() protoreflect.Message
func (*LinuxNamespace) Reset ¶
func (x *LinuxNamespace) Reset()
func (*LinuxNamespace) SizeVT ¶
func (m *LinuxNamespace) SizeVT() (n int)
func (*LinuxNamespace) String ¶
func (x *LinuxNamespace) String() string
func (*LinuxNamespace) UnmarshalVT ¶
func (m *LinuxNamespace) UnmarshalVT(dAtA []byte) error
type LinuxPids ¶
type LinuxPids struct { Limit int64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
Pids-related parts of (linux) resources.
func (*LinuxPids) Descriptor ¶
Deprecated: Use LinuxPids.ProtoReflect.Descriptor instead.
func (*LinuxPids) GetLimit ¶
func (*LinuxPids) MarshalToSizedBufferVT ¶
func (*LinuxPids) MarshalToVT ¶
func (*LinuxPids) MarshalVT ¶
func (*LinuxPids) ProtoMessage ¶
func (*LinuxPids) ProtoMessage()
func (*LinuxPids) ProtoReflect ¶
func (x *LinuxPids) ProtoReflect() protoreflect.Message
func (*LinuxPids) Reset ¶
func (x *LinuxPids) Reset()
func (*LinuxPids) SizeVT ¶
func (*LinuxPids) String ¶
func (*LinuxPids) UnmarshalVT ¶
type LinuxPodSandbox ¶
type LinuxPodSandbox struct { PodOverhead *LinuxResources `protobuf:"bytes,1,opt,name=pod_overhead,json=podOverhead,proto3" json:"pod_overhead,omitempty"` PodResources *LinuxResources `protobuf:"bytes,2,opt,name=pod_resources,json=podResources,proto3" json:"pod_resources,omitempty"` CgroupParent string `protobuf:"bytes,3,opt,name=cgroup_parent,json=cgroupParent,proto3" json:"cgroup_parent,omitempty"` CgroupsPath string `protobuf:"bytes,4,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"` // for NRI v1 emulation Namespaces []*LinuxNamespace `protobuf:"bytes,5,rep,name=namespaces,proto3" json:"namespaces,omitempty"` // for NRI v1 emulation Resources *LinuxResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` // for NRI v1 emulation // contains filtered or unexported fields }
PodSandbox linux-specific metadata
func (*LinuxPodSandbox) Descriptor ¶
func (*LinuxPodSandbox) Descriptor() ([]byte, []int)
Deprecated: Use LinuxPodSandbox.ProtoReflect.Descriptor instead.
func (*LinuxPodSandbox) GetCgroupParent ¶
func (x *LinuxPodSandbox) GetCgroupParent() string
func (*LinuxPodSandbox) GetCgroupsPath ¶
func (x *LinuxPodSandbox) GetCgroupsPath() string
func (*LinuxPodSandbox) GetNamespaces ¶
func (x *LinuxPodSandbox) GetNamespaces() []*LinuxNamespace
func (*LinuxPodSandbox) GetPodOverhead ¶
func (x *LinuxPodSandbox) GetPodOverhead() *LinuxResources
func (*LinuxPodSandbox) GetPodResources ¶
func (x *LinuxPodSandbox) GetPodResources() *LinuxResources
func (*LinuxPodSandbox) GetResources ¶
func (x *LinuxPodSandbox) GetResources() *LinuxResources
func (*LinuxPodSandbox) MarshalToSizedBufferVT ¶
func (m *LinuxPodSandbox) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxPodSandbox) MarshalToVT ¶
func (m *LinuxPodSandbox) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxPodSandbox) MarshalVT ¶
func (m *LinuxPodSandbox) MarshalVT() (dAtA []byte, err error)
func (*LinuxPodSandbox) ProtoMessage ¶
func (*LinuxPodSandbox) ProtoMessage()
func (*LinuxPodSandbox) ProtoReflect ¶
func (x *LinuxPodSandbox) ProtoReflect() protoreflect.Message
func (*LinuxPodSandbox) Reset ¶
func (x *LinuxPodSandbox) Reset()
func (*LinuxPodSandbox) SizeVT ¶
func (m *LinuxPodSandbox) SizeVT() (n int)
func (*LinuxPodSandbox) String ¶
func (x *LinuxPodSandbox) String() string
func (*LinuxPodSandbox) UnmarshalVT ¶
func (m *LinuxPodSandbox) UnmarshalVT(dAtA []byte) error
type LinuxResources ¶
type LinuxResources struct { Memory *LinuxMemory `protobuf:"bytes,1,opt,name=memory,proto3" json:"memory,omitempty"` Cpu *LinuxCPU `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"` HugepageLimits []*HugepageLimit `protobuf:"bytes,3,rep,name=hugepage_limits,json=hugepageLimits,proto3" json:"hugepage_limits,omitempty"` BlockioClass *OptionalString `protobuf:"bytes,4,opt,name=blockio_class,json=blockioClass,proto3" json:"blockio_class,omitempty"` RdtClass *OptionalString `protobuf:"bytes,5,opt,name=rdt_class,json=rdtClass,proto3" json:"rdt_class,omitempty"` Unified map[string]string `protobuf:"bytes,6,rep,name=unified,proto3" json:"unified,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` Devices []*LinuxDeviceCgroup `protobuf:"bytes,7,rep,name=devices,proto3" json:"devices,omitempty"` // for NRI v1 emulation Pids *LinuxPids `protobuf:"bytes,8,opt,name=pids,proto3" json:"pids,omitempty"` // contains filtered or unexported fields }
Container (linux) resources.
func FromCRILinuxResources ¶
func FromCRILinuxResources(c *cri.LinuxContainerResources) *LinuxResources
func FromOCILinuxResources ¶
func FromOCILinuxResources(o *rspec.LinuxResources, _ map[string]string) *LinuxResources
FromOCILinuxResources returns resources from an OCI runtime Spec.
func (*LinuxResources) Copy ¶
func (r *LinuxResources) Copy() *LinuxResources
Copy creates a copy of the resources.
func (*LinuxResources) Descriptor ¶
func (*LinuxResources) Descriptor() ([]byte, []int)
Deprecated: Use LinuxResources.ProtoReflect.Descriptor instead.
func (*LinuxResources) GetBlockioClass ¶
func (x *LinuxResources) GetBlockioClass() *OptionalString
func (*LinuxResources) GetCpu ¶
func (x *LinuxResources) GetCpu() *LinuxCPU
func (*LinuxResources) GetDevices ¶
func (x *LinuxResources) GetDevices() []*LinuxDeviceCgroup
func (*LinuxResources) GetHugepageLimits ¶
func (x *LinuxResources) GetHugepageLimits() []*HugepageLimit
func (*LinuxResources) GetMemory ¶
func (x *LinuxResources) GetMemory() *LinuxMemory
func (*LinuxResources) GetPids ¶
func (x *LinuxResources) GetPids() *LinuxPids
func (*LinuxResources) GetRdtClass ¶
func (x *LinuxResources) GetRdtClass() *OptionalString
func (*LinuxResources) GetUnified ¶
func (x *LinuxResources) GetUnified() map[string]string
func (*LinuxResources) MarshalToSizedBufferVT ¶
func (m *LinuxResources) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LinuxResources) MarshalToVT ¶
func (m *LinuxResources) MarshalToVT(dAtA []byte) (int, error)
func (*LinuxResources) MarshalVT ¶
func (m *LinuxResources) MarshalVT() (dAtA []byte, err error)
func (*LinuxResources) ProtoMessage ¶
func (*LinuxResources) ProtoMessage()
func (*LinuxResources) ProtoReflect ¶
func (x *LinuxResources) ProtoReflect() protoreflect.Message
func (*LinuxResources) Reset ¶
func (x *LinuxResources) Reset()
func (*LinuxResources) SizeVT ¶
func (m *LinuxResources) SizeVT() (n int)
func (*LinuxResources) String ¶
func (x *LinuxResources) String() string
func (*LinuxResources) ToCRI ¶
func (r *LinuxResources) ToCRI(oomScoreAdj int64) *cri.LinuxContainerResources
ToCRI returns resources for CRI.
func (*LinuxResources) ToOCI ¶
func (r *LinuxResources) ToOCI() *rspec.LinuxResources
ToOCI returns resources for an OCI runtime Spec.
func (*LinuxResources) UnmarshalVT ¶
func (m *LinuxResources) UnmarshalVT(dAtA []byte) error
type LogRequest ¶
type LogRequest struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Level LogRequest_Level `protobuf:"varint,2,opt,name=level,proto3,enum=nri.pkg.api.v1alpha1.LogRequest_Level" json:"level,omitempty"` // contains filtered or unexported fields }
func (*LogRequest) Descriptor ¶
func (*LogRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.
func (*LogRequest) GetLevel ¶
func (x *LogRequest) GetLevel() LogRequest_Level
func (*LogRequest) GetMsg ¶
func (x *LogRequest) GetMsg() string
func (*LogRequest) MarshalToSizedBufferVT ¶
func (m *LogRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*LogRequest) MarshalToVT ¶
func (m *LogRequest) MarshalToVT(dAtA []byte) (int, error)
func (*LogRequest) MarshalVT ¶
func (m *LogRequest) MarshalVT() (dAtA []byte, err error)
func (*LogRequest) ProtoMessage ¶
func (*LogRequest) ProtoMessage()
func (*LogRequest) ProtoReflect ¶
func (x *LogRequest) ProtoReflect() protoreflect.Message
func (*LogRequest) Reset ¶
func (x *LogRequest) Reset()
func (*LogRequest) SizeVT ¶
func (m *LogRequest) SizeVT() (n int)
func (*LogRequest) String ¶
func (x *LogRequest) String() string
func (*LogRequest) UnmarshalVT ¶
func (m *LogRequest) UnmarshalVT(dAtA []byte) error
type LogRequest_Level ¶
type LogRequest_Level int32
const ( LogRequest_LEVEL_UNSPECIFIED LogRequest_Level = 0 LogRequest_LEVEL_DEBUG LogRequest_Level = 1 LogRequest_LEVEL_INFO LogRequest_Level = 2 LogRequest_LEVEL_WARN LogRequest_Level = 3 LogRequest_LEVEL_ERROR LogRequest_Level = 4 )
func (LogRequest_Level) Descriptor ¶
func (LogRequest_Level) Descriptor() protoreflect.EnumDescriptor
func (LogRequest_Level) Enum ¶
func (x LogRequest_Level) Enum() *LogRequest_Level
func (LogRequest_Level) EnumDescriptor ¶
func (LogRequest_Level) EnumDescriptor() ([]byte, []int)
Deprecated: Use LogRequest_Level.Descriptor instead.
func (LogRequest_Level) Number ¶
func (x LogRequest_Level) Number() protoreflect.EnumNumber
func (LogRequest_Level) String ¶
func (x LogRequest_Level) String() string
func (LogRequest_Level) Type ¶
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 ¶
FromOCIMounts returns a Mount slice for an OCI runtime Spec.
func (*Mount) Cmp ¶
Cmp returns true if the mounts are equal.
func (*Mount) Descriptor ¶
Deprecated: Use Mount.ProtoReflect.Descriptor instead.
func (*Mount) GetDestination ¶
func (*Mount) GetOptions ¶
func (*Mount) GetSource ¶
func (*Mount) GetType ¶
func (*Mount) IsMarkedForRemoval ¶
IsMarkedForRemoval checks if a Mount is marked for removal.
func (*Mount) MarshalToSizedBufferVT ¶
func (*Mount) MarshalToVT ¶
func (*Mount) MarshalVT ¶
func (*Mount) ProtoMessage ¶
func (*Mount) ProtoMessage()
func (*Mount) ProtoReflect ¶
func (x *Mount) ProtoReflect() protoreflect.Message
func (*Mount) Reset ¶
func (x *Mount) Reset()
func (*Mount) SizeVT ¶
func (*Mount) String ¶
func (*Mount) ToOCI ¶
ToOCI returns a Mount for an OCI runtime Spec.
func (*Mount) UnmarshalVT ¶
type OptionalBool ¶
type OptionalBool struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional boolean value.
func Bool ¶
func Bool(v interface{}) *OptionalBool
Bool creates an Optional wrapper from its argument.
func (*OptionalBool) Descriptor ¶
func (*OptionalBool) Descriptor() ([]byte, []int)
Deprecated: Use OptionalBool.ProtoReflect.Descriptor instead.
func (*OptionalBool) Get ¶
func (o *OptionalBool) Get() *bool
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalBool) GetValue ¶
func (x *OptionalBool) GetValue() bool
func (*OptionalBool) MarshalToSizedBufferVT ¶
func (m *OptionalBool) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalBool) MarshalToVT ¶
func (m *OptionalBool) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalBool) MarshalVT ¶
func (m *OptionalBool) MarshalVT() (dAtA []byte, err error)
func (*OptionalBool) ProtoMessage ¶
func (*OptionalBool) ProtoMessage()
func (*OptionalBool) ProtoReflect ¶
func (x *OptionalBool) ProtoReflect() protoreflect.Message
func (*OptionalBool) Reset ¶
func (x *OptionalBool) Reset()
func (*OptionalBool) SizeVT ¶
func (m *OptionalBool) SizeVT() (n int)
func (*OptionalBool) String ¶
func (x *OptionalBool) String() string
func (*OptionalBool) UnmarshalVT ¶
func (m *OptionalBool) UnmarshalVT(dAtA []byte) error
type OptionalFileMode ¶
type OptionalFileMode struct { Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional value of file permissions.
func FileMode ¶
func FileMode(v interface{}) *OptionalFileMode
FileMode creates an Optional wrapper from its argument.
func (*OptionalFileMode) Descriptor ¶
func (*OptionalFileMode) Descriptor() ([]byte, []int)
Deprecated: Use OptionalFileMode.ProtoReflect.Descriptor instead.
func (*OptionalFileMode) Get ¶
func (o *OptionalFileMode) Get() *os.FileMode
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalFileMode) GetValue ¶
func (x *OptionalFileMode) GetValue() uint32
func (*OptionalFileMode) MarshalToSizedBufferVT ¶
func (m *OptionalFileMode) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalFileMode) MarshalToVT ¶
func (m *OptionalFileMode) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalFileMode) MarshalVT ¶
func (m *OptionalFileMode) MarshalVT() (dAtA []byte, err error)
func (*OptionalFileMode) ProtoMessage ¶
func (*OptionalFileMode) ProtoMessage()
func (*OptionalFileMode) ProtoReflect ¶
func (x *OptionalFileMode) ProtoReflect() protoreflect.Message
func (*OptionalFileMode) Reset ¶
func (x *OptionalFileMode) Reset()
func (*OptionalFileMode) SizeVT ¶
func (m *OptionalFileMode) SizeVT() (n int)
func (*OptionalFileMode) String ¶
func (x *OptionalFileMode) String() string
func (*OptionalFileMode) UnmarshalVT ¶
func (m *OptionalFileMode) UnmarshalVT(dAtA []byte) error
type OptionalInt ¶
type OptionalInt struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional signed integer value.
func Int ¶
func Int(v interface{}) *OptionalInt
Int creates an Optional wrapper from its argument.
func (*OptionalInt) Descriptor ¶
func (*OptionalInt) Descriptor() ([]byte, []int)
Deprecated: Use OptionalInt.ProtoReflect.Descriptor instead.
func (*OptionalInt) Get ¶
func (o *OptionalInt) Get() *int
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalInt) GetValue ¶
func (x *OptionalInt) GetValue() int64
func (*OptionalInt) MarshalToSizedBufferVT ¶
func (m *OptionalInt) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalInt) MarshalToVT ¶
func (m *OptionalInt) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalInt) MarshalVT ¶
func (m *OptionalInt) MarshalVT() (dAtA []byte, err error)
func (*OptionalInt) ProtoMessage ¶
func (*OptionalInt) ProtoMessage()
func (*OptionalInt) ProtoReflect ¶
func (x *OptionalInt) ProtoReflect() protoreflect.Message
func (*OptionalInt) Reset ¶
func (x *OptionalInt) Reset()
func (*OptionalInt) SizeVT ¶
func (m *OptionalInt) SizeVT() (n int)
func (*OptionalInt) String ¶
func (x *OptionalInt) String() string
func (*OptionalInt) UnmarshalVT ¶
func (m *OptionalInt) UnmarshalVT(dAtA []byte) error
type OptionalInt32 ¶
type OptionalInt32 struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 32-bit signed integer value.
func Int32 ¶
func Int32(v interface{}) *OptionalInt32
Int32 creates an Optional wrapper from its argument.
func (*OptionalInt32) Descriptor ¶
func (*OptionalInt32) Descriptor() ([]byte, []int)
Deprecated: Use OptionalInt32.ProtoReflect.Descriptor instead.
func (*OptionalInt32) Get ¶
func (o *OptionalInt32) Get() *int32
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalInt32) GetValue ¶
func (x *OptionalInt32) GetValue() int32
func (*OptionalInt32) MarshalToSizedBufferVT ¶
func (m *OptionalInt32) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalInt32) MarshalToVT ¶
func (m *OptionalInt32) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalInt32) MarshalVT ¶
func (m *OptionalInt32) MarshalVT() (dAtA []byte, err error)
func (*OptionalInt32) ProtoMessage ¶
func (*OptionalInt32) ProtoMessage()
func (*OptionalInt32) ProtoReflect ¶
func (x *OptionalInt32) ProtoReflect() protoreflect.Message
func (*OptionalInt32) Reset ¶
func (x *OptionalInt32) Reset()
func (*OptionalInt32) SizeVT ¶
func (m *OptionalInt32) SizeVT() (n int)
func (*OptionalInt32) String ¶
func (x *OptionalInt32) String() string
func (*OptionalInt32) UnmarshalVT ¶
func (m *OptionalInt32) UnmarshalVT(dAtA []byte) error
type OptionalInt64 ¶
type OptionalInt64 struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 64-bit signed integer value.
func Int64 ¶
func Int64(v interface{}) *OptionalInt64
Int64 creates an Optional wrapper from its argument.
func (*OptionalInt64) Descriptor ¶
func (*OptionalInt64) Descriptor() ([]byte, []int)
Deprecated: Use OptionalInt64.ProtoReflect.Descriptor instead.
func (*OptionalInt64) Get ¶
func (o *OptionalInt64) Get() *int64
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalInt64) GetValue ¶
func (x *OptionalInt64) GetValue() int64
func (*OptionalInt64) MarshalToSizedBufferVT ¶
func (m *OptionalInt64) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalInt64) MarshalToVT ¶
func (m *OptionalInt64) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalInt64) MarshalVT ¶
func (m *OptionalInt64) MarshalVT() (dAtA []byte, err error)
func (*OptionalInt64) ProtoMessage ¶
func (*OptionalInt64) ProtoMessage()
func (*OptionalInt64) ProtoReflect ¶
func (x *OptionalInt64) ProtoReflect() protoreflect.Message
func (*OptionalInt64) Reset ¶
func (x *OptionalInt64) Reset()
func (*OptionalInt64) SizeVT ¶
func (m *OptionalInt64) SizeVT() (n int)
func (*OptionalInt64) String ¶
func (x *OptionalInt64) String() string
func (*OptionalInt64) UnmarshalVT ¶
func (m *OptionalInt64) UnmarshalVT(dAtA []byte) error
type OptionalString ¶
type OptionalString struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional string value.
func String ¶
func String(v interface{}) *OptionalString
String creates an Optional wrapper from its argument.
func (*OptionalString) Descriptor ¶
func (*OptionalString) Descriptor() ([]byte, []int)
Deprecated: Use OptionalString.ProtoReflect.Descriptor instead.
func (*OptionalString) Get ¶
func (o *OptionalString) Get() *string
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalString) GetValue ¶
func (x *OptionalString) GetValue() string
func (*OptionalString) MarshalToSizedBufferVT ¶
func (m *OptionalString) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalString) MarshalToVT ¶
func (m *OptionalString) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalString) MarshalVT ¶
func (m *OptionalString) MarshalVT() (dAtA []byte, err error)
func (*OptionalString) ProtoMessage ¶
func (*OptionalString) ProtoMessage()
func (*OptionalString) ProtoReflect ¶
func (x *OptionalString) ProtoReflect() protoreflect.Message
func (*OptionalString) Reset ¶
func (x *OptionalString) Reset()
func (*OptionalString) SizeVT ¶
func (m *OptionalString) SizeVT() (n int)
func (*OptionalString) String ¶
func (x *OptionalString) String() string
func (*OptionalString) UnmarshalVT ¶
func (m *OptionalString) UnmarshalVT(dAtA []byte) error
type OptionalUInt32 ¶
type OptionalUInt32 struct { Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 32-bit unsigned integer value.
func UInt32 ¶
func UInt32(v interface{}) *OptionalUInt32
UInt32 creates an Optional wrapper from its argument.
func (*OptionalUInt32) Descriptor ¶
func (*OptionalUInt32) Descriptor() ([]byte, []int)
Deprecated: Use OptionalUInt32.ProtoReflect.Descriptor instead.
func (*OptionalUInt32) Get ¶
func (o *OptionalUInt32) Get() *uint32
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalUInt32) GetValue ¶
func (x *OptionalUInt32) GetValue() uint32
func (*OptionalUInt32) MarshalToSizedBufferVT ¶
func (m *OptionalUInt32) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalUInt32) MarshalToVT ¶
func (m *OptionalUInt32) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalUInt32) MarshalVT ¶
func (m *OptionalUInt32) MarshalVT() (dAtA []byte, err error)
func (*OptionalUInt32) ProtoMessage ¶
func (*OptionalUInt32) ProtoMessage()
func (*OptionalUInt32) ProtoReflect ¶
func (x *OptionalUInt32) ProtoReflect() protoreflect.Message
func (*OptionalUInt32) Reset ¶
func (x *OptionalUInt32) Reset()
func (*OptionalUInt32) SizeVT ¶
func (m *OptionalUInt32) SizeVT() (n int)
func (*OptionalUInt32) String ¶
func (x *OptionalUInt32) String() string
func (*OptionalUInt32) UnmarshalVT ¶
func (m *OptionalUInt32) UnmarshalVT(dAtA []byte) error
type OptionalUInt64 ¶
type OptionalUInt64 struct { Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 64-bit unsigned integer value.
func UInt64 ¶
func UInt64(v interface{}) *OptionalUInt64
UInt64 creates an Optional wrapper from its argument.
func (*OptionalUInt64) Descriptor ¶
func (*OptionalUInt64) Descriptor() ([]byte, []int)
Deprecated: Use OptionalUInt64.ProtoReflect.Descriptor instead.
func (*OptionalUInt64) Get ¶
func (o *OptionalUInt64) Get() *uint64
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalUInt64) GetValue ¶
func (x *OptionalUInt64) GetValue() uint64
func (*OptionalUInt64) MarshalToSizedBufferVT ¶
func (m *OptionalUInt64) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OptionalUInt64) MarshalToVT ¶
func (m *OptionalUInt64) MarshalToVT(dAtA []byte) (int, error)
func (*OptionalUInt64) MarshalVT ¶
func (m *OptionalUInt64) MarshalVT() (dAtA []byte, err error)
func (*OptionalUInt64) ProtoMessage ¶
func (*OptionalUInt64) ProtoMessage()
func (*OptionalUInt64) ProtoReflect ¶
func (x *OptionalUInt64) ProtoReflect() protoreflect.Message
func (*OptionalUInt64) Reset ¶
func (x *OptionalUInt64) Reset()
func (*OptionalUInt64) SizeVT ¶
func (m *OptionalUInt64) SizeVT() (n int)
func (*OptionalUInt64) String ¶
func (x *OptionalUInt64) String() string
func (*OptionalUInt64) UnmarshalVT ¶
func (m *OptionalUInt64) UnmarshalVT(dAtA []byte) error
type POSIXRlimit ¶
type POSIXRlimit struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Hard uint64 `protobuf:"varint,2,opt,name=hard,proto3" json:"hard,omitempty"` Soft uint64 `protobuf:"varint,3,opt,name=soft,proto3" json:"soft,omitempty"` // contains filtered or unexported fields }
Container rlimits
func (*POSIXRlimit) Descriptor ¶
func (*POSIXRlimit) Descriptor() ([]byte, []int)
Deprecated: Use POSIXRlimit.ProtoReflect.Descriptor instead.
func (*POSIXRlimit) GetHard ¶
func (x *POSIXRlimit) GetHard() uint64
func (*POSIXRlimit) GetSoft ¶
func (x *POSIXRlimit) GetSoft() uint64
func (*POSIXRlimit) GetType ¶
func (x *POSIXRlimit) GetType() string
func (*POSIXRlimit) MarshalToSizedBufferVT ¶
func (m *POSIXRlimit) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*POSIXRlimit) MarshalToVT ¶
func (m *POSIXRlimit) MarshalToVT(dAtA []byte) (int, error)
func (*POSIXRlimit) MarshalVT ¶
func (m *POSIXRlimit) MarshalVT() (dAtA []byte, err error)
func (*POSIXRlimit) ProtoMessage ¶
func (*POSIXRlimit) ProtoMessage()
func (*POSIXRlimit) ProtoReflect ¶
func (x *POSIXRlimit) ProtoReflect() protoreflect.Message
func (*POSIXRlimit) Reset ¶
func (x *POSIXRlimit) Reset()
func (*POSIXRlimit) SizeVT ¶
func (m *POSIXRlimit) SizeVT() (n int)
func (*POSIXRlimit) String ¶
func (x *POSIXRlimit) String() string
func (*POSIXRlimit) UnmarshalVT ¶
func (m *POSIXRlimit) UnmarshalVT(dAtA []byte) error
type Plugin ¶
type Plugin interface { // Configure the plugin and get its event subscription. Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error) // Synchronize the plugin with the state of the runtime. Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error) // Shutdown a plugin (let it know the runtime is going down). Shutdown(context.Context, *Empty) (*Empty, error) // CreateContainer relays the corresponding request to the plugin. In // response, the plugin can adjust the container being created, and // update other containers in the runtime. Container adjustment can // alter labels, annotations, mounts, devices, environment variables, // OCI hooks, and assigned container resources. Updates can alter // assigned container resources. CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error) // UpdateContainer relays the corresponding request to the plugin. // The plugin can alter how the container is updated and request updates // to additional containers in the runtime. UpdateContainer(context.Context, *UpdateContainerRequest) (*UpdateContainerResponse, error) // StopContainer relays the corresponding request to the plugin. The plugin // can update any of the remaining containers in the runtime in response. StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error) // StateChange relays any remaining pod or container lifecycle/state change // events the plugin has subscribed for. These can be used to trigger any // plugin-specific processing which needs to occur in connection with any of // these events. StateChange(context.Context, *StateChangeEvent) (*Empty, error) }
Plugin is the API NRI uses to interact with plugins. It is used to - configure a plugin and subscribe it for lifecycle events - synchronize the state of a plugin with that of the runtime - hook a plugin into the lifecycle events of its interest
During configuration the plugin tells the runtime which lifecycle events it wishes to get hooked into. Once configured, the plugin is synchronized with the runtime by receiving the list of pods and containers known to the runtime. The plugin can request changes to any of the containers in response. After initial synchronization the plugin starts receiving the events it subscribed for as they occur in the runtime. For container creation, update, and stop events, the plugin can request changes, both to the container that triggered the event or any other existing container in the runtime.
For a subset of the container lifecycle events, NRI defines an additional Post-variant of the event. These variants are defined for CreateContainer, StartContainer, and UpdateContainer. For creation and update, these events can be used by plugins to discover the full extent of changes applied to the container, including any changes made by other active plugins.
go:plugin type=plugin version=1
type PluginPlugin ¶
type PluginPlugin struct {
// contains filtered or unexported fields
}
func NewPluginPlugin ¶
func NewPluginPlugin(ctx context.Context, opts ...wazeroConfigOption) (*PluginPlugin, error)
func (*PluginPlugin) Load ¶
func (p *PluginPlugin) Load(ctx context.Context, pluginPath string, hostFunctions HostFunctions) (plugin, error)
type PluginService ¶
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 `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` Annotations map[string]string `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` RuntimeHandler string `protobuf:"bytes,7,opt,name=runtime_handler,json=runtimeHandler,proto3" json:"runtime_handler,omitempty"` Linux *LinuxPodSandbox `protobuf:"bytes,8,opt,name=linux,proto3" json:"linux,omitempty"` Pid uint32 `protobuf:"varint,9,opt,name=pid,proto3" json:"pid,omitempty"` // for NRI v1 emulation Ips []string `protobuf:"bytes,10,rep,name=ips,proto3" json:"ips,omitempty"` // contains filtered or unexported fields }
Pod metadata that is considered relevant for a plugin.
func (*PodSandbox) Descriptor ¶
func (*PodSandbox) Descriptor() ([]byte, []int)
Deprecated: Use PodSandbox.ProtoReflect.Descriptor instead.
func (*PodSandbox) GetAnnotations ¶
func (x *PodSandbox) GetAnnotations() map[string]string
func (*PodSandbox) GetId ¶
func (x *PodSandbox) GetId() string
func (*PodSandbox) GetIps ¶
func (x *PodSandbox) GetIps() []string
func (*PodSandbox) GetLabels ¶
func (x *PodSandbox) GetLabels() map[string]string
func (*PodSandbox) GetLinux ¶
func (x *PodSandbox) GetLinux() *LinuxPodSandbox
func (*PodSandbox) GetName ¶
func (x *PodSandbox) GetName() string
func (*PodSandbox) GetNamespace ¶
func (x *PodSandbox) GetNamespace() string
func (*PodSandbox) GetPid ¶
func (x *PodSandbox) GetPid() uint32
func (*PodSandbox) GetRuntimeHandler ¶
func (x *PodSandbox) GetRuntimeHandler() string
func (*PodSandbox) GetUid ¶
func (x *PodSandbox) GetUid() string
func (*PodSandbox) MarshalToSizedBufferVT ¶
func (m *PodSandbox) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PodSandbox) MarshalToVT ¶
func (m *PodSandbox) MarshalToVT(dAtA []byte) (int, error)
func (*PodSandbox) MarshalVT ¶
func (m *PodSandbox) MarshalVT() (dAtA []byte, err error)
func (*PodSandbox) ProtoMessage ¶
func (*PodSandbox) ProtoMessage()
func (*PodSandbox) ProtoReflect ¶
func (x *PodSandbox) ProtoReflect() protoreflect.Message
func (*PodSandbox) Reset ¶
func (x *PodSandbox) Reset()
func (*PodSandbox) SizeVT ¶
func (m *PodSandbox) SizeVT() (n int)
func (*PodSandbox) String ¶
func (x *PodSandbox) String() string
func (*PodSandbox) UnmarshalVT ¶
func (m *PodSandbox) UnmarshalVT(dAtA []byte) error
type PostCreateContainerRequest ¶
type PostCreateContainerRequest = StateChangeEvent
nolint
type PostCreateContainerResponse ¶
type PostCreateContainerResponse = Empty
nolint
type PostStartContainerRequest ¶
type PostStartContainerRequest = StateChangeEvent
nolint
type PostStartContainerResponse ¶
type PostStartContainerResponse = Empty
nolint
type PostUpdateContainerRequest ¶
type PostUpdateContainerRequest = StateChangeEvent
nolint
type PostUpdateContainerResponse ¶
type PostUpdateContainerResponse = Empty
nolint
type RegisterPluginRequest ¶
type RegisterPluginRequest struct { // Name of the plugin to register. PluginName string `protobuf:"bytes,1,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"` // Plugin invocation index. Plugins are called in ascending index order. PluginIdx string `protobuf:"bytes,2,opt,name=plugin_idx,json=pluginIdx,proto3" json:"plugin_idx,omitempty"` // contains filtered or unexported fields }
func (*RegisterPluginRequest) Descriptor ¶
func (*RegisterPluginRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterPluginRequest.ProtoReflect.Descriptor instead.
func (*RegisterPluginRequest) GetPluginIdx ¶
func (x *RegisterPluginRequest) GetPluginIdx() string
func (*RegisterPluginRequest) GetPluginName ¶
func (x *RegisterPluginRequest) GetPluginName() string
func (*RegisterPluginRequest) MarshalToSizedBufferVT ¶
func (m *RegisterPluginRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RegisterPluginRequest) MarshalToVT ¶
func (m *RegisterPluginRequest) MarshalToVT(dAtA []byte) (int, error)
func (*RegisterPluginRequest) MarshalVT ¶
func (m *RegisterPluginRequest) MarshalVT() (dAtA []byte, err error)
func (*RegisterPluginRequest) ProtoMessage ¶
func (*RegisterPluginRequest) ProtoMessage()
func (*RegisterPluginRequest) ProtoReflect ¶
func (x *RegisterPluginRequest) ProtoReflect() protoreflect.Message
func (*RegisterPluginRequest) Reset ¶
func (x *RegisterPluginRequest) Reset()
func (*RegisterPluginRequest) SizeVT ¶
func (m *RegisterPluginRequest) SizeVT() (n int)
func (*RegisterPluginRequest) String ¶
func (x *RegisterPluginRequest) String() string
func (*RegisterPluginRequest) UnmarshalVT ¶
func (m *RegisterPluginRequest) UnmarshalVT(dAtA []byte) error
type RemoveContainerRequest ¶
type RemoveContainerRequest = StateChangeEvent
nolint
type RemoveContainerResponse ¶
type RemoveContainerResponse = Empty
nolint
type RemovePodSandboxRequest ¶
type RemovePodSandboxRequest = StateChangeEvent
nolint
type RemovePodSandboxResponse ¶
type RemovePodSandboxResponse = Empty
nolint
type RunPodSandboxRequest ¶
type RunPodSandboxRequest = StateChangeEvent
nolint
type RunPodSandboxResponse ¶
type RunPodSandboxResponse = Empty
nolint
type RuntimeService ¶
type RuntimeService interface { RegisterPlugin(context.Context, *RegisterPluginRequest) (*Empty, error) UpdateContainers(context.Context, *UpdateContainersRequest) (*UpdateContainersResponse, error) }
func NewRuntimeClient ¶
func NewRuntimeClient(client *ttrpc.Client) RuntimeService
type ShutdownRequest ¶
type ShutdownRequest = Empty
nolint
type ShutdownResponse ¶
type ShutdownResponse = Empty
nolint
type StartContainerRequest ¶
type StartContainerRequest = StateChangeEvent
nolint
type StartContainerResponse ¶
type StartContainerResponse = Empty
nolint
type StateChangeEvent ¶
type StateChangeEvent struct { // Event type of notification. Event Event `protobuf:"varint,1,opt,name=event,proto3,enum=nri.pkg.api.v1alpha1.Event" json:"event,omitempty"` // Pod this notification is sent for. If this event is related to a container, // pod is set to the pod of the container. Pod *PodSandbox `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"` // Container this notification is sent for. If the event is related to a pod, // container is nil. Container *Container `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"` // contains filtered or unexported fields }
func (*StateChangeEvent) Descriptor ¶
func (*StateChangeEvent) Descriptor() ([]byte, []int)
Deprecated: Use StateChangeEvent.ProtoReflect.Descriptor instead.
func (*StateChangeEvent) GetContainer ¶
func (x *StateChangeEvent) GetContainer() *Container
func (*StateChangeEvent) GetEvent ¶
func (x *StateChangeEvent) GetEvent() Event
func (*StateChangeEvent) GetPod ¶
func (x *StateChangeEvent) GetPod() *PodSandbox
func (*StateChangeEvent) MarshalToSizedBufferVT ¶
func (m *StateChangeEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StateChangeEvent) MarshalToVT ¶
func (m *StateChangeEvent) MarshalToVT(dAtA []byte) (int, error)
func (*StateChangeEvent) MarshalVT ¶
func (m *StateChangeEvent) MarshalVT() (dAtA []byte, err error)
func (*StateChangeEvent) ProtoMessage ¶
func (*StateChangeEvent) ProtoMessage()
func (*StateChangeEvent) ProtoReflect ¶
func (x *StateChangeEvent) ProtoReflect() protoreflect.Message
func (*StateChangeEvent) Reset ¶
func (x *StateChangeEvent) Reset()
func (*StateChangeEvent) SizeVT ¶
func (m *StateChangeEvent) SizeVT() (n int)
func (*StateChangeEvent) String ¶
func (x *StateChangeEvent) String() string
func (*StateChangeEvent) UnmarshalVT ¶
func (m *StateChangeEvent) UnmarshalVT(dAtA []byte) error
type StateChangeResponse ¶
type StateChangeResponse = Empty
nolint
type StopContainerRequest ¶
type StopContainerRequest struct { // Pod of container being stopped. Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` // Container being stopped. Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` // contains filtered or unexported fields }
func (*StopContainerRequest) Descriptor ¶
func (*StopContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopContainerRequest.ProtoReflect.Descriptor instead.
func (*StopContainerRequest) GetContainer ¶
func (x *StopContainerRequest) GetContainer() *Container
func (*StopContainerRequest) GetPod ¶
func (x *StopContainerRequest) GetPod() *PodSandbox
func (*StopContainerRequest) MarshalToSizedBufferVT ¶
func (m *StopContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StopContainerRequest) MarshalToVT ¶
func (m *StopContainerRequest) MarshalToVT(dAtA []byte) (int, error)
func (*StopContainerRequest) MarshalVT ¶
func (m *StopContainerRequest) MarshalVT() (dAtA []byte, err error)
func (*StopContainerRequest) ProtoMessage ¶
func (*StopContainerRequest) ProtoMessage()
func (*StopContainerRequest) ProtoReflect ¶
func (x *StopContainerRequest) ProtoReflect() protoreflect.Message
func (*StopContainerRequest) Reset ¶
func (x *StopContainerRequest) Reset()
func (*StopContainerRequest) SizeVT ¶
func (m *StopContainerRequest) SizeVT() (n int)
func (*StopContainerRequest) String ¶
func (x *StopContainerRequest) String() string
func (*StopContainerRequest) UnmarshalVT ¶
func (m *StopContainerRequest) UnmarshalVT(dAtA []byte) error
type StopContainerResponse ¶
type StopContainerResponse struct { // Requested updates to containers. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // contains filtered or unexported fields }
func (*StopContainerResponse) Descriptor ¶
func (*StopContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopContainerResponse.ProtoReflect.Descriptor instead.
func (*StopContainerResponse) GetUpdate ¶
func (x *StopContainerResponse) GetUpdate() []*ContainerUpdate
func (*StopContainerResponse) MarshalToSizedBufferVT ¶
func (m *StopContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StopContainerResponse) MarshalToVT ¶
func (m *StopContainerResponse) MarshalToVT(dAtA []byte) (int, error)
func (*StopContainerResponse) MarshalVT ¶
func (m *StopContainerResponse) MarshalVT() (dAtA []byte, err error)
func (*StopContainerResponse) ProtoMessage ¶
func (*StopContainerResponse) ProtoMessage()
func (*StopContainerResponse) ProtoReflect ¶
func (x *StopContainerResponse) ProtoReflect() protoreflect.Message
func (*StopContainerResponse) Reset ¶
func (x *StopContainerResponse) Reset()
func (*StopContainerResponse) SizeVT ¶
func (m *StopContainerResponse) SizeVT() (n int)
func (*StopContainerResponse) String ¶
func (x *StopContainerResponse) String() string
func (*StopContainerResponse) UnmarshalVT ¶
func (m *StopContainerResponse) UnmarshalVT(dAtA []byte) error
type StopPodSandboxRequest ¶
type StopPodSandboxRequest = StateChangeEvent
nolint
type StopPodSandboxResponse ¶
type StopPodSandboxResponse = Empty
nolint
type SynchronizeRequest ¶
type SynchronizeRequest struct { // Pods known to the runtime. Pods []*PodSandbox `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"` // Containers known to the runtime. Containers []*Container `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"` // Whether there are more pods and containers to follow. More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"` // contains filtered or unexported fields }
func (*SynchronizeRequest) Descriptor ¶
func (*SynchronizeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.
func (*SynchronizeRequest) GetContainers ¶
func (x *SynchronizeRequest) GetContainers() []*Container
func (*SynchronizeRequest) GetMore ¶
func (x *SynchronizeRequest) GetMore() bool
func (*SynchronizeRequest) GetPods ¶
func (x *SynchronizeRequest) GetPods() []*PodSandbox
func (*SynchronizeRequest) MarshalToSizedBufferVT ¶
func (m *SynchronizeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SynchronizeRequest) MarshalToVT ¶
func (m *SynchronizeRequest) MarshalToVT(dAtA []byte) (int, error)
func (*SynchronizeRequest) MarshalVT ¶
func (m *SynchronizeRequest) MarshalVT() (dAtA []byte, err error)
func (*SynchronizeRequest) ProtoMessage ¶
func (*SynchronizeRequest) ProtoMessage()
func (*SynchronizeRequest) ProtoReflect ¶
func (x *SynchronizeRequest) ProtoReflect() protoreflect.Message
func (*SynchronizeRequest) Reset ¶
func (x *SynchronizeRequest) Reset()
func (*SynchronizeRequest) SizeVT ¶
func (m *SynchronizeRequest) SizeVT() (n int)
func (*SynchronizeRequest) String ¶
func (x *SynchronizeRequest) String() string
func (*SynchronizeRequest) UnmarshalVT ¶
func (m *SynchronizeRequest) UnmarshalVT(dAtA []byte) error
type SynchronizeResponse ¶
type SynchronizeResponse struct { // Updates to containers requested by the plugin. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // Whether the client is able to handle more advertised pods and containers. More bool `protobuf:"varint,2,opt,name=more,proto3" json:"more,omitempty"` // contains filtered or unexported fields }
func (*SynchronizeResponse) Descriptor ¶
func (*SynchronizeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.
func (*SynchronizeResponse) GetMore ¶
func (x *SynchronizeResponse) GetMore() bool
func (*SynchronizeResponse) GetUpdate ¶
func (x *SynchronizeResponse) GetUpdate() []*ContainerUpdate
func (*SynchronizeResponse) MarshalToSizedBufferVT ¶
func (m *SynchronizeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SynchronizeResponse) MarshalToVT ¶
func (m *SynchronizeResponse) MarshalToVT(dAtA []byte) (int, error)
func (*SynchronizeResponse) MarshalVT ¶
func (m *SynchronizeResponse) MarshalVT() (dAtA []byte, err error)
func (*SynchronizeResponse) ProtoMessage ¶
func (*SynchronizeResponse) ProtoMessage()
func (*SynchronizeResponse) ProtoReflect ¶
func (x *SynchronizeResponse) ProtoReflect() protoreflect.Message
func (*SynchronizeResponse) Reset ¶
func (x *SynchronizeResponse) Reset()
func (*SynchronizeResponse) SizeVT ¶
func (m *SynchronizeResponse) SizeVT() (n int)
func (*SynchronizeResponse) String ¶
func (x *SynchronizeResponse) String() string
func (*SynchronizeResponse) UnmarshalVT ¶
func (m *SynchronizeResponse) UnmarshalVT(dAtA []byte) error
type UpdateContainerRequest ¶
type UpdateContainerRequest struct { // Pod of container being updated. Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` // Container being updated. Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` // Resources to update. LinuxResources *LinuxResources `protobuf:"bytes,3,opt,name=linux_resources,json=linuxResources,proto3" json:"linux_resources,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainerRequest) Descriptor ¶
func (*UpdateContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainerRequest.ProtoReflect.Descriptor instead.
func (*UpdateContainerRequest) GetContainer ¶
func (x *UpdateContainerRequest) GetContainer() *Container
func (*UpdateContainerRequest) GetLinuxResources ¶
func (x *UpdateContainerRequest) GetLinuxResources() *LinuxResources
func (*UpdateContainerRequest) GetPod ¶
func (x *UpdateContainerRequest) GetPod() *PodSandbox
func (*UpdateContainerRequest) MarshalToSizedBufferVT ¶
func (m *UpdateContainerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*UpdateContainerRequest) MarshalToVT ¶
func (m *UpdateContainerRequest) MarshalToVT(dAtA []byte) (int, error)
func (*UpdateContainerRequest) MarshalVT ¶
func (m *UpdateContainerRequest) MarshalVT() (dAtA []byte, err error)
func (*UpdateContainerRequest) ProtoMessage ¶
func (*UpdateContainerRequest) ProtoMessage()
func (*UpdateContainerRequest) ProtoReflect ¶
func (x *UpdateContainerRequest) ProtoReflect() protoreflect.Message
func (*UpdateContainerRequest) Reset ¶
func (x *UpdateContainerRequest) Reset()
func (*UpdateContainerRequest) SizeVT ¶
func (m *UpdateContainerRequest) SizeVT() (n int)
func (*UpdateContainerRequest) String ¶
func (x *UpdateContainerRequest) String() string
func (*UpdateContainerRequest) UnmarshalVT ¶
func (m *UpdateContainerRequest) UnmarshalVT(dAtA []byte) error
type UpdateContainerResponse ¶
type UpdateContainerResponse struct { // Requested updates to containers. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // Requested eviction of containers. Evict []*ContainerEviction `protobuf:"bytes,2,rep,name=evict,proto3" json:"evict,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainerResponse) Descriptor ¶
func (*UpdateContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainerResponse.ProtoReflect.Descriptor instead.
func (*UpdateContainerResponse) GetEvict ¶
func (x *UpdateContainerResponse) GetEvict() []*ContainerEviction
func (*UpdateContainerResponse) GetUpdate ¶
func (x *UpdateContainerResponse) GetUpdate() []*ContainerUpdate
func (*UpdateContainerResponse) MarshalToSizedBufferVT ¶
func (m *UpdateContainerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*UpdateContainerResponse) MarshalToVT ¶
func (m *UpdateContainerResponse) MarshalToVT(dAtA []byte) (int, error)
func (*UpdateContainerResponse) MarshalVT ¶
func (m *UpdateContainerResponse) MarshalVT() (dAtA []byte, err error)
func (*UpdateContainerResponse) ProtoMessage ¶
func (*UpdateContainerResponse) ProtoMessage()
func (*UpdateContainerResponse) ProtoReflect ¶
func (x *UpdateContainerResponse) ProtoReflect() protoreflect.Message
func (*UpdateContainerResponse) Reset ¶
func (x *UpdateContainerResponse) Reset()
func (*UpdateContainerResponse) SizeVT ¶
func (m *UpdateContainerResponse) SizeVT() (n int)
func (*UpdateContainerResponse) String ¶
func (x *UpdateContainerResponse) String() string
func (*UpdateContainerResponse) UnmarshalVT ¶
func (m *UpdateContainerResponse) UnmarshalVT(dAtA []byte) error
type UpdateContainersRequest ¶
type UpdateContainersRequest struct { // List of containers to update. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // List of containers to evict. Evict []*ContainerEviction `protobuf:"bytes,2,rep,name=evict,proto3" json:"evict,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainersRequest) Descriptor ¶
func (*UpdateContainersRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainersRequest.ProtoReflect.Descriptor instead.
func (*UpdateContainersRequest) GetEvict ¶
func (x *UpdateContainersRequest) GetEvict() []*ContainerEviction
func (*UpdateContainersRequest) GetUpdate ¶
func (x *UpdateContainersRequest) GetUpdate() []*ContainerUpdate
func (*UpdateContainersRequest) MarshalToSizedBufferVT ¶
func (m *UpdateContainersRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*UpdateContainersRequest) MarshalToVT ¶
func (m *UpdateContainersRequest) MarshalToVT(dAtA []byte) (int, error)
func (*UpdateContainersRequest) MarshalVT ¶
func (m *UpdateContainersRequest) MarshalVT() (dAtA []byte, err error)
func (*UpdateContainersRequest) ProtoMessage ¶
func (*UpdateContainersRequest) ProtoMessage()
func (*UpdateContainersRequest) ProtoReflect ¶
func (x *UpdateContainersRequest) ProtoReflect() protoreflect.Message
func (*UpdateContainersRequest) Reset ¶
func (x *UpdateContainersRequest) Reset()
func (*UpdateContainersRequest) SizeVT ¶
func (m *UpdateContainersRequest) SizeVT() (n int)
func (*UpdateContainersRequest) String ¶
func (x *UpdateContainersRequest) String() string
func (*UpdateContainersRequest) UnmarshalVT ¶
func (m *UpdateContainersRequest) UnmarshalVT(dAtA []byte) error
type UpdateContainersResponse ¶
type UpdateContainersResponse struct { // Containers that the runtime failed to update. Failed []*ContainerUpdate `protobuf:"bytes,1,rep,name=failed,proto3" json:"failed,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainersResponse) Descriptor ¶
func (*UpdateContainersResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainersResponse.ProtoReflect.Descriptor instead.
func (*UpdateContainersResponse) GetFailed ¶
func (x *UpdateContainersResponse) GetFailed() []*ContainerUpdate
func (*UpdateContainersResponse) MarshalToSizedBufferVT ¶
func (m *UpdateContainersResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*UpdateContainersResponse) MarshalToVT ¶
func (m *UpdateContainersResponse) MarshalToVT(dAtA []byte) (int, error)
func (*UpdateContainersResponse) MarshalVT ¶
func (m *UpdateContainersResponse) MarshalVT() (dAtA []byte, err error)
func (*UpdateContainersResponse) ProtoMessage ¶
func (*UpdateContainersResponse) ProtoMessage()
func (*UpdateContainersResponse) ProtoReflect ¶
func (x *UpdateContainersResponse) ProtoReflect() protoreflect.Message
func (*UpdateContainersResponse) Reset ¶
func (x *UpdateContainersResponse) Reset()
func (*UpdateContainersResponse) SizeVT ¶
func (m *UpdateContainersResponse) SizeVT() (n int)
func (*UpdateContainersResponse) String ¶
func (x *UpdateContainersResponse) String() string
func (*UpdateContainersResponse) UnmarshalVT ¶
func (m *UpdateContainersResponse) UnmarshalVT(dAtA []byte) error
type WazeroConfig ¶
type WazeroConfig struct {
// contains filtered or unexported fields
}
type WazeroNewRuntime ¶
func DefaultWazeroRuntime ¶
func DefaultWazeroRuntime() WazeroNewRuntime
Source Files ¶
adjustment.go api.pb.go api_host.pb.go api_options.pb.go api_service.pb.go api_ttrpc.pb.go api_vtproto.pb.go device.go doc.go env.go event.go helpers.go hooks.go mount.go namespace.go optional.go plugin.go resources.go timeouts.go update.go
- Version
- v0.9.0 (latest)
- Published
- Dec 12, 2024
- Platform
- linux/amd64
- Imports
- 21 packages
- Last checked
- 2 months ago –
Tools for package owners.