Documentation ¶
Overview ¶
Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: pkg/api/api.proto
Index ¶
- Constants
- Variables
- func CheckPluginIndex(idx string) error
- 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 RegisterPluginService(srv *ttrpc.Server, svc PluginService)
- func RegisterRuntimeService(srv *ttrpc.Server, svc RuntimeService)
- type ConfigureRequest
- func (*ConfigureRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigureRequest) GetConfig() string
- func (x *ConfigureRequest) GetRuntimeName() string
- func (x *ConfigureRequest) GetRuntimeVersion() string
- func (*ConfigureRequest) ProtoMessage()
- func (x *ConfigureRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigureRequest) Reset()
- func (x *ConfigureRequest) String() string
- type ConfigureResponse
- type Container
- func (*Container) Descriptor() ([]byte, []int)deprecated
- 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 (*Container) ProtoMessage()
- func (x *Container) ProtoReflect() protoreflect.Message
- func (x *Container) Reset()
- func (x *Container) String() string
- type ContainerAdjustment
- func (a *ContainerAdjustment) AddAnnotation(key, value string)
- 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)deprecated
- func (x *ContainerAdjustment) GetAnnotations() map[string]string
- 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 (*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) SetLinuxRDTClass(value string)
- func (x *ContainerAdjustment) String() string
- type ContainerEviction
- func (*ContainerEviction) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerEviction) GetContainerId() string
- func (x *ContainerEviction) GetReason() string
- func (*ContainerEviction) ProtoMessage()
- func (x *ContainerEviction) ProtoReflect() protoreflect.Message
- func (x *ContainerEviction) Reset()
- func (x *ContainerEviction) String() string
- type ContainerState
- func (ContainerState) Descriptor() protoreflect.EnumDescriptor
- func (x ContainerState) Enum() *ContainerState
- func (ContainerState) EnumDescriptor() ([]byte, []int)deprecated
- 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)deprecated
- func (x *ContainerUpdate) GetContainerId() string
- func (x *ContainerUpdate) GetIgnoreFailure() bool
- func (x *ContainerUpdate) GetLinux() *LinuxContainerUpdate
- 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) SetLinuxRDTClass(value string)
- func (x *ContainerUpdate) String() string
- type CreateContainerRequest
- func (*CreateContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateContainerRequest) GetContainer() *Container
- func (x *CreateContainerRequest) GetPod() *PodSandbox
- func (*CreateContainerRequest) ProtoMessage()
- func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateContainerRequest) Reset()
- func (x *CreateContainerRequest) String() string
- type CreateContainerResponse
- func (*CreateContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateContainerResponse) GetAdjust() *ContainerAdjustment
- func (x *CreateContainerResponse) GetEvict() []*ContainerEviction
- func (x *CreateContainerResponse) GetUpdate() []*ContainerUpdate
- func (*CreateContainerResponse) ProtoMessage()
- func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message
- func (x *CreateContainerResponse) Reset()
- func (x *CreateContainerResponse) String() string
- type Empty
- type Event
- type EventMask
- type Hook
- func (*Hook) Descriptor() ([]byte, []int)deprecated
- func (x *Hook) GetArgs() []string
- func (x *Hook) GetEnv() []string
- func (x *Hook) GetPath() string
- func (x *Hook) GetTimeout() *OptionalInt
- func (*Hook) ProtoMessage()
- func (x *Hook) ProtoReflect() protoreflect.Message
- func (x *Hook) Reset()
- func (x *Hook) String() string
- func (h *Hook) ToOCI() rspec.Hook
- type Hooks
- func (hooks *Hooks) Append(h *Hooks) *Hooks
- func (*Hooks) Descriptor() ([]byte, []int)deprecated
- 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 (*Hooks) ProtoMessage()
- func (x *Hooks) ProtoReflect() protoreflect.Message
- func (x *Hooks) Reset()
- func (x *Hooks) String() string
- type HugepageLimit
- func (*HugepageLimit) Descriptor() ([]byte, []int)deprecated
- func (x *HugepageLimit) GetLimit() uint64
- func (x *HugepageLimit) GetPageSize() string
- func (*HugepageLimit) ProtoMessage()
- func (x *HugepageLimit) ProtoReflect() protoreflect.Message
- func (x *HugepageLimit) Reset()
- func (x *HugepageLimit) String() string
- type KeyValue
- func (*KeyValue) Descriptor() ([]byte, []int)deprecated
- func (x *KeyValue) GetKey() string
- func (x *KeyValue) GetValue() string
- func (e *KeyValue) IsMarkedForRemoval() (string, bool)
- func (*KeyValue) ProtoMessage()
- func (x *KeyValue) ProtoReflect() protoreflect.Message
- func (x *KeyValue) Reset()
- func (x *KeyValue) String() string
- func (e *KeyValue) ToOCI() string
- type LinuxCPU
- func (*LinuxCPU) Descriptor() ([]byte, []int)deprecated
- 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 (*LinuxCPU) ProtoMessage()
- func (x *LinuxCPU) ProtoReflect() protoreflect.Message
- func (x *LinuxCPU) Reset()
- func (x *LinuxCPU) String() string
- type LinuxContainer
- func (*LinuxContainer) Descriptor() ([]byte, []int)deprecated
- 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 (*LinuxContainer) ProtoMessage()
- func (x *LinuxContainer) ProtoReflect() protoreflect.Message
- func (x *LinuxContainer) Reset()
- func (x *LinuxContainer) String() string
- type LinuxContainerAdjustment
- func (*LinuxContainerAdjustment) Descriptor() ([]byte, []int)deprecated
- func (x *LinuxContainerAdjustment) GetCgroupsPath() string
- func (x *LinuxContainerAdjustment) GetDevices() []*LinuxDevice
- func (x *LinuxContainerAdjustment) GetResources() *LinuxResources
- func (*LinuxContainerAdjustment) ProtoMessage()
- func (x *LinuxContainerAdjustment) ProtoReflect() protoreflect.Message
- func (x *LinuxContainerAdjustment) Reset()
- func (x *LinuxContainerAdjustment) String() string
- type LinuxContainerUpdate
- func (*LinuxContainerUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *LinuxContainerUpdate) GetResources() *LinuxResources
- func (*LinuxContainerUpdate) ProtoMessage()
- func (x *LinuxContainerUpdate) ProtoReflect() protoreflect.Message
- func (x *LinuxContainerUpdate) Reset()
- func (x *LinuxContainerUpdate) String() string
- type LinuxDevice
- func (d *LinuxDevice) AccessString() string
- func (d *LinuxDevice) Cmp(v *LinuxDevice) bool
- func (*LinuxDevice) Descriptor() ([]byte, []int)deprecated
- 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 (*LinuxDevice) ProtoMessage()
- func (x *LinuxDevice) ProtoReflect() protoreflect.Message
- func (x *LinuxDevice) Reset()
- func (x *LinuxDevice) String() string
- func (d *LinuxDevice) ToOCI() rspec.LinuxDevice
- type LinuxDeviceCgroup
- func (*LinuxDeviceCgroup) Descriptor() ([]byte, []int)deprecated
- 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 (*LinuxDeviceCgroup) ProtoMessage()
- func (x *LinuxDeviceCgroup) ProtoReflect() protoreflect.Message
- func (x *LinuxDeviceCgroup) Reset()
- func (x *LinuxDeviceCgroup) String() string
- type LinuxMemory
- func (*LinuxMemory) Descriptor() ([]byte, []int)deprecated
- 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 (*LinuxMemory) ProtoMessage()
- func (x *LinuxMemory) ProtoReflect() protoreflect.Message
- func (x *LinuxMemory) Reset()
- func (x *LinuxMemory) String() string
- type LinuxNamespace
- func (*LinuxNamespace) Descriptor() ([]byte, []int)deprecated
- func (x *LinuxNamespace) GetPath() string
- func (x *LinuxNamespace) GetType() string
- func (*LinuxNamespace) ProtoMessage()
- func (x *LinuxNamespace) ProtoReflect() protoreflect.Message
- func (x *LinuxNamespace) Reset()
- func (x *LinuxNamespace) String() string
- type LinuxPodSandbox
- func (*LinuxPodSandbox) Descriptor() ([]byte, []int)deprecated
- 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 (*LinuxPodSandbox) ProtoMessage()
- func (x *LinuxPodSandbox) ProtoReflect() protoreflect.Message
- func (x *LinuxPodSandbox) Reset()
- func (x *LinuxPodSandbox) String() string
- type LinuxResources
- func (r *LinuxResources) Copy() *LinuxResources
- func (*LinuxResources) Descriptor() ([]byte, []int)deprecated
- 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) GetRdtClass() *OptionalString
- func (x *LinuxResources) GetUnified() map[string]string
- func (*LinuxResources) ProtoMessage()
- func (x *LinuxResources) ProtoReflect() protoreflect.Message
- func (x *LinuxResources) Reset()
- func (x *LinuxResources) String() string
- func (r *LinuxResources) ToCRI(oomScoreAdj int64) *cri.LinuxContainerResources
- func (r *LinuxResources) ToOCI() *rspec.LinuxResources
- type Mount
- func (m *Mount) Cmp(v *Mount) bool
- func (*Mount) Descriptor() ([]byte, []int)deprecated
- 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 (*Mount) ProtoMessage()
- func (x *Mount) ProtoReflect() protoreflect.Message
- func (x *Mount) Reset()
- func (x *Mount) String() string
- func (m *Mount) ToOCI(propagationQuery *string) rspec.Mount
- type OptionalBool
- type OptionalFileMode
- func (*OptionalFileMode) Descriptor() ([]byte, []int)deprecated
- func (o *OptionalFileMode) Get() *os.FileMode
- func (x *OptionalFileMode) GetValue() uint32
- func (*OptionalFileMode) ProtoMessage()
- func (x *OptionalFileMode) ProtoReflect() protoreflect.Message
- func (x *OptionalFileMode) Reset()
- func (x *OptionalFileMode) String() string
- type OptionalInt
- type OptionalInt32
- func (*OptionalInt32) Descriptor() ([]byte, []int)deprecated
- func (o *OptionalInt32) Get() *int32
- func (x *OptionalInt32) GetValue() int32
- func (*OptionalInt32) ProtoMessage()
- func (x *OptionalInt32) ProtoReflect() protoreflect.Message
- func (x *OptionalInt32) Reset()
- func (x *OptionalInt32) String() string
- type OptionalInt64
- func (*OptionalInt64) Descriptor() ([]byte, []int)deprecated
- func (o *OptionalInt64) Get() *int64
- func (x *OptionalInt64) GetValue() int64
- func (*OptionalInt64) ProtoMessage()
- func (x *OptionalInt64) ProtoReflect() protoreflect.Message
- func (x *OptionalInt64) Reset()
- func (x *OptionalInt64) String() string
- type OptionalString
- func (*OptionalString) Descriptor() ([]byte, []int)deprecated
- func (o *OptionalString) Get() *string
- func (x *OptionalString) GetValue() string
- func (*OptionalString) ProtoMessage()
- func (x *OptionalString) ProtoReflect() protoreflect.Message
- func (x *OptionalString) Reset()
- func (x *OptionalString) String() string
- type OptionalUInt32
- func (*OptionalUInt32) Descriptor() ([]byte, []int)deprecated
- func (o *OptionalUInt32) Get() *uint32
- func (x *OptionalUInt32) GetValue() uint32
- func (*OptionalUInt32) ProtoMessage()
- func (x *OptionalUInt32) ProtoReflect() protoreflect.Message
- func (x *OptionalUInt32) Reset()
- func (x *OptionalUInt32) String() string
- type OptionalUInt64
- func (*OptionalUInt64) Descriptor() ([]byte, []int)deprecated
- func (o *OptionalUInt64) Get() *uint64
- func (x *OptionalUInt64) GetValue() uint64
- func (*OptionalUInt64) ProtoMessage()
- func (x *OptionalUInt64) ProtoReflect() protoreflect.Message
- func (x *OptionalUInt64) Reset()
- func (x *OptionalUInt64) String() string
- type POSIXRlimit
- func (*POSIXRlimit) Descriptor() ([]byte, []int)deprecated
- func (x *POSIXRlimit) GetHard() uint64
- func (x *POSIXRlimit) GetSoft() uint64
- func (x *POSIXRlimit) GetType() string
- func (*POSIXRlimit) ProtoMessage()
- func (x *POSIXRlimit) ProtoReflect() protoreflect.Message
- func (x *POSIXRlimit) Reset()
- func (x *POSIXRlimit) String() string
- type PluginService
- type PodSandbox
- func (*PodSandbox) Descriptor() ([]byte, []int)deprecated
- func (x *PodSandbox) GetAnnotations() map[string]string
- func (x *PodSandbox) GetId() 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 (*PodSandbox) ProtoMessage()
- func (x *PodSandbox) ProtoReflect() protoreflect.Message
- func (x *PodSandbox) Reset()
- func (x *PodSandbox) String() string
- type PostCreateContainerRequest
- type PostCreateContainerResponse
- type PostStartContainerRequest
- type PostStartContainerResponse
- type PostUpdateContainerRequest
- type PostUpdateContainerResponse
- type RegisterPluginRequest
- func (*RegisterPluginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterPluginRequest) GetPluginIdx() string
- func (x *RegisterPluginRequest) GetPluginName() string
- func (*RegisterPluginRequest) ProtoMessage()
- func (x *RegisterPluginRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterPluginRequest) Reset()
- func (x *RegisterPluginRequest) String() string
- 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)deprecated
- func (x *StateChangeEvent) GetContainer() *Container
- func (x *StateChangeEvent) GetEvent() Event
- func (x *StateChangeEvent) GetPod() *PodSandbox
- func (*StateChangeEvent) ProtoMessage()
- func (x *StateChangeEvent) ProtoReflect() protoreflect.Message
- func (x *StateChangeEvent) Reset()
- func (x *StateChangeEvent) String() string
- type StateChangeResponse
- type StopContainerRequest
- func (*StopContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopContainerRequest) GetContainer() *Container
- func (x *StopContainerRequest) GetPod() *PodSandbox
- func (*StopContainerRequest) ProtoMessage()
- func (x *StopContainerRequest) ProtoReflect() protoreflect.Message
- func (x *StopContainerRequest) Reset()
- func (x *StopContainerRequest) String() string
- type StopContainerResponse
- func (*StopContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StopContainerResponse) GetUpdate() []*ContainerUpdate
- func (*StopContainerResponse) ProtoMessage()
- func (x *StopContainerResponse) ProtoReflect() protoreflect.Message
- func (x *StopContainerResponse) Reset()
- func (x *StopContainerResponse) String() string
- type StopPodSandboxRequest
- type StopPodSandboxResponse
- type SynchronizeRequest
- func (*SynchronizeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SynchronizeRequest) GetContainers() []*Container
- func (x *SynchronizeRequest) GetPods() []*PodSandbox
- func (*SynchronizeRequest) ProtoMessage()
- func (x *SynchronizeRequest) ProtoReflect() protoreflect.Message
- func (x *SynchronizeRequest) Reset()
- func (x *SynchronizeRequest) String() string
- type SynchronizeResponse
- func (*SynchronizeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SynchronizeResponse) GetUpdate() []*ContainerUpdate
- func (*SynchronizeResponse) ProtoMessage()
- func (x *SynchronizeResponse) ProtoReflect() protoreflect.Message
- func (x *SynchronizeResponse) Reset()
- func (x *SynchronizeResponse) String() string
- type UpdateContainerRequest
- func (*UpdateContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateContainerRequest) GetContainer() *Container
- func (x *UpdateContainerRequest) GetLinuxResources() *LinuxResources
- func (x *UpdateContainerRequest) GetPod() *PodSandbox
- func (*UpdateContainerRequest) ProtoMessage()
- func (x *UpdateContainerRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateContainerRequest) Reset()
- func (x *UpdateContainerRequest) String() string
- type UpdateContainerResponse
- func (*UpdateContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateContainerResponse) GetEvict() []*ContainerEviction
- func (x *UpdateContainerResponse) GetUpdate() []*ContainerUpdate
- func (*UpdateContainerResponse) ProtoMessage()
- func (x *UpdateContainerResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateContainerResponse) Reset()
- func (x *UpdateContainerResponse) String() string
- type UpdateContainersRequest
- func (*UpdateContainersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateContainersRequest) GetEvict() []*ContainerEviction
- func (x *UpdateContainersRequest) GetUpdate() []*ContainerUpdate
- func (*UpdateContainersRequest) ProtoMessage()
- func (x *UpdateContainersRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateContainersRequest) Reset()
- func (x *UpdateContainersRequest) String() string
- type UpdateContainersResponse
- func (*UpdateContainersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateContainersResponse) GetFailed() []*ContainerUpdate
- func (*UpdateContainersResponse) ProtoMessage()
- func (x *UpdateContainersResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateContainersResponse) Reset()
- func (x *UpdateContainersResponse) String() string
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 (
// 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 File_pkg_api_api_proto protoreflect.FileDescriptor
Functions ¶
func CheckPluginIndex ¶
CheckPluginIndex checks the validity of a plugin index.
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 RegisterPluginService ¶
func RegisterPluginService(srv *ttrpc.Server, svc PluginService)
func RegisterRuntimeService ¶
func RegisterRuntimeService(srv *ttrpc.Server, svc RuntimeService)
Types ¶
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"` // contains filtered or unexported fields }
func (*ConfigureRequest) Descriptor
deprecated
func (*ConfigureRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureRequest.ProtoReflect.Descriptor instead.
func (*ConfigureRequest) GetConfig ¶
func (x *ConfigureRequest) GetConfig() string
func (*ConfigureRequest) GetRuntimeName ¶
func (x *ConfigureRequest) GetRuntimeName() string
func (*ConfigureRequest) GetRuntimeVersion ¶
func (x *ConfigureRequest) GetRuntimeVersion() string
func (*ConfigureRequest) ProtoMessage ¶
func (*ConfigureRequest) ProtoMessage()
func (*ConfigureRequest) ProtoReflect ¶
func (x *ConfigureRequest) ProtoReflect() protoreflect.Message
func (*ConfigureRequest) Reset ¶
func (x *ConfigureRequest) Reset()
func (*ConfigureRequest) String ¶
func (x *ConfigureRequest) String() string
type ConfigureResponse ¶
type ConfigureResponse struct { // Events to subscribe the plugin for. Each bit set corresponds to an // enumerated Event. Events int32 `protobuf:"varint,2,opt,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*ConfigureResponse) Descriptor
deprecated
func (*ConfigureResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.
func (*ConfigureResponse) GetEvents ¶
func (x *ConfigureResponse) GetEvents() int32
func (*ConfigureResponse) ProtoMessage ¶
func (*ConfigureResponse) ProtoMessage()
func (*ConfigureResponse) ProtoReflect ¶
func (x *ConfigureResponse) ProtoReflect() protoreflect.Message
func (*ConfigureResponse) Reset ¶
func (x *ConfigureResponse) Reset()
func (*ConfigureResponse) String ¶
func (x *ConfigureResponse) String() string
type Container ¶
type Container struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` PodSandboxId string `protobuf:"bytes,2,opt,name=pod_sandbox_id,json=podSandboxId,proto3" json:"pod_sandbox_id,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` State ContainerState `protobuf:"varint,4,opt,name=state,proto3,enum=nri.pkg.api.v1alpha1.ContainerState" json:"state,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Annotations map[string]string `` /* 163-byte string literal not displayed */ Args []string `protobuf:"bytes,7,rep,name=args,proto3" json:"args,omitempty"` Env []string `protobuf:"bytes,8,rep,name=env,proto3" json:"env,omitempty"` Mounts []*Mount `protobuf:"bytes,9,rep,name=mounts,proto3" json:"mounts,omitempty"` Hooks *Hooks `protobuf:"bytes,10,opt,name=hooks,proto3" json:"hooks,omitempty"` Linux *LinuxContainer `protobuf:"bytes,11,opt,name=linux,proto3" json:"linux,omitempty"` Pid uint32 `protobuf:"varint,12,opt,name=pid,proto3" json:"pid,omitempty"` // for NRI v1 emulation Rlimits []*POSIXRlimit `protobuf:"bytes,13,rep,name=rlimits,proto3" json:"rlimits,omitempty"` // contains filtered or unexported fields }
Container metadata that is considered relevant for a plugin.
func (*Container) Descriptor
deprecated
func (*Container) GetAnnotations ¶
func (*Container) GetLinux ¶
func (x *Container) GetLinux() *LinuxContainer
func (*Container) GetPodSandboxId ¶
func (*Container) GetRlimits ¶ added in v0.4.0
func (x *Container) GetRlimits() []*POSIXRlimit
func (*Container) GetState ¶
func (x *Container) GetState() ContainerState
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
func (*Container) ProtoReflect ¶
func (x *Container) ProtoReflect() protoreflect.Message
type ContainerAdjustment ¶
type ContainerAdjustment struct { Annotations map[string]string `` /* 163-byte string literal not displayed */ Mounts []*Mount `protobuf:"bytes,3,rep,name=mounts,proto3" json:"mounts,omitempty"` Env []*KeyValue `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"` Hooks *Hooks `protobuf:"bytes,5,opt,name=hooks,proto3" json:"hooks,omitempty"` Linux *LinuxContainerAdjustment `protobuf:"bytes,6,opt,name=linux,proto3" json:"linux,omitempty"` Rlimits []*POSIXRlimit `protobuf:"bytes,7,rep,name=rlimits,proto3" json:"rlimits,omitempty"` // 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) AddDevice ¶
func (a *ContainerAdjustment) AddDevice(d *LinuxDevice)
AddDevice records the addition of the given device to a container.
func (*ContainerAdjustment) AddEnv ¶
func (a *ContainerAdjustment) AddEnv(key, value string)
AddEnv records the addition of an environment variable to a container.
func (*ContainerAdjustment) AddHooks ¶
func (a *ContainerAdjustment) AddHooks(h *Hooks)
AddHooks records the addition of the given hooks to a container.
func (*ContainerAdjustment) AddLinuxHugepageLimit ¶
func (a *ContainerAdjustment) AddLinuxHugepageLimit(pageSize string, value uint64)
AddLinuxHugepageLimit records adding a hugepage limit for a container.
func (*ContainerAdjustment) AddLinuxUnified ¶
func (a *ContainerAdjustment) AddLinuxUnified(key, value string)
AddLinuxUnified sets a cgroupv2 unified resource.
func (*ContainerAdjustment) AddMount ¶
func (a *ContainerAdjustment) AddMount(m *Mount)
AddMount records the addition of a mount to a container.
func (*ContainerAdjustment) AddRlimit ¶ added in v0.4.0
func (a *ContainerAdjustment) AddRlimit(typ string, hard, soft uint64)
func (*ContainerAdjustment) Descriptor
deprecated
func (*ContainerAdjustment) Descriptor() ([]byte, []int)
Deprecated: Use ContainerAdjustment.ProtoReflect.Descriptor instead.
func (*ContainerAdjustment) GetAnnotations ¶
func (x *ContainerAdjustment) GetAnnotations() map[string]string
func (*ContainerAdjustment) GetEnv ¶
func (x *ContainerAdjustment) GetEnv() []*KeyValue
func (*ContainerAdjustment) GetHooks ¶
func (x *ContainerAdjustment) GetHooks() *Hooks
func (*ContainerAdjustment) GetLinux ¶
func (x *ContainerAdjustment) GetLinux() *LinuxContainerAdjustment
func (*ContainerAdjustment) GetMounts ¶
func (x *ContainerAdjustment) GetMounts() []*Mount
func (*ContainerAdjustment) GetRlimits ¶ added in v0.4.0
func (x *ContainerAdjustment) GetRlimits() []*POSIXRlimit
func (*ContainerAdjustment) 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) SetLinuxRDTClass ¶
func (a *ContainerAdjustment) SetLinuxRDTClass(value string)
SetLinuxRDTClass records setting the RDT class for a container.
func (*ContainerAdjustment) String ¶
func (x *ContainerAdjustment) String() string
type ContainerEviction ¶
type ContainerEviction struct { // Container to evict. ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // Human-readable reason for eviction. Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
Request to evict (IOW unsolicitedly stop) a container.
func (*ContainerEviction) Descriptor
deprecated
func (*ContainerEviction) Descriptor() ([]byte, []int)
Deprecated: Use ContainerEviction.ProtoReflect.Descriptor instead.
func (*ContainerEviction) GetContainerId ¶
func (x *ContainerEviction) GetContainerId() string
func (*ContainerEviction) GetReason ¶
func (x *ContainerEviction) GetReason() string
func (*ContainerEviction) ProtoMessage ¶
func (*ContainerEviction) ProtoMessage()
func (*ContainerEviction) ProtoReflect ¶
func (x *ContainerEviction) ProtoReflect() protoreflect.Message
func (*ContainerEviction) Reset ¶
func (x *ContainerEviction) Reset()
func (*ContainerEviction) String ¶
func (x *ContainerEviction) String() string
type ContainerState ¶
type ContainerState int32
Possible container states.
const ( ContainerState_CONTAINER_UNKNOWN ContainerState = 0 ContainerState_CONTAINER_CREATED ContainerState = 1 ContainerState_CONTAINER_PAUSED ContainerState = 2 // is this useful/necessary ? ContainerState_CONTAINER_RUNNING ContainerState = 3 ContainerState_CONTAINER_STOPPED ContainerState = 4 )
func (ContainerState) Descriptor ¶
func (ContainerState) Descriptor() protoreflect.EnumDescriptor
func (ContainerState) Enum ¶
func (x ContainerState) Enum() *ContainerState
func (ContainerState) EnumDescriptor
deprecated
func (ContainerState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContainerState.Descriptor instead.
func (ContainerState) Number ¶
func (x ContainerState) Number() protoreflect.EnumNumber
func (ContainerState) String ¶
func (x ContainerState) String() string
func (ContainerState) Type ¶
func (ContainerState) Type() protoreflect.EnumType
type ContainerUpdate ¶
type ContainerUpdate struct { ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` Linux *LinuxContainerUpdate `protobuf:"bytes,2,opt,name=linux,proto3" json:"linux,omitempty"` IgnoreFailure bool `protobuf:"varint,3,opt,name=ignore_failure,json=ignoreFailure,proto3" json:"ignore_failure,omitempty"` // contains filtered or unexported fields }
Requested update to an already created container.
func (*ContainerUpdate) AddLinuxHugepageLimit ¶
func (u *ContainerUpdate) AddLinuxHugepageLimit(pageSize string, value uint64)
AddLinuxHugepageLimit records adding a hugepage limit for a container.
func (*ContainerUpdate) AddLinuxUnified ¶
func (u *ContainerUpdate) AddLinuxUnified(key, value string)
AddLinuxUnified sets a cgroupv2 unified resource.
func (*ContainerUpdate) Descriptor
deprecated
func (*ContainerUpdate) Descriptor() ([]byte, []int)
Deprecated: Use ContainerUpdate.ProtoReflect.Descriptor instead.
func (*ContainerUpdate) GetContainerId ¶
func (x *ContainerUpdate) GetContainerId() string
func (*ContainerUpdate) GetIgnoreFailure ¶
func (x *ContainerUpdate) GetIgnoreFailure() bool
func (*ContainerUpdate) GetLinux ¶
func (x *ContainerUpdate) GetLinux() *LinuxContainerUpdate
func (*ContainerUpdate) 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) SetLinuxRDTClass ¶
func (u *ContainerUpdate) SetLinuxRDTClass(value string)
SetLinuxRDTClass records setting the RDT class for a container.
func (*ContainerUpdate) String ¶
func (x *ContainerUpdate) String() string
type CreateContainerRequest ¶
type CreateContainerRequest struct { // Pod of container being created. Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` // Container being created. Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` // contains filtered or unexported fields }
func (*CreateContainerRequest) Descriptor
deprecated
func (*CreateContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateContainerRequest.ProtoReflect.Descriptor instead.
func (*CreateContainerRequest) GetContainer ¶
func (x *CreateContainerRequest) GetContainer() *Container
func (*CreateContainerRequest) GetPod ¶
func (x *CreateContainerRequest) GetPod() *PodSandbox
func (*CreateContainerRequest) ProtoMessage ¶
func (*CreateContainerRequest) ProtoMessage()
func (*CreateContainerRequest) ProtoReflect ¶
func (x *CreateContainerRequest) ProtoReflect() protoreflect.Message
func (*CreateContainerRequest) Reset ¶
func (x *CreateContainerRequest) Reset()
func (*CreateContainerRequest) String ¶
func (x *CreateContainerRequest) String() string
type CreateContainerResponse ¶
type CreateContainerResponse struct { // Requested adjustments to container being created. Adjust *ContainerAdjustment `protobuf:"bytes,1,opt,name=adjust,proto3" json:"adjust,omitempty"` // Requested updates to other existing containers. Update []*ContainerUpdate `protobuf:"bytes,2,rep,name=update,proto3" json:"update,omitempty"` // Requested eviction of existing containers. Evict []*ContainerEviction `protobuf:"bytes,3,rep,name=evict,proto3" json:"evict,omitempty"` // contains filtered or unexported fields }
func (*CreateContainerResponse) Descriptor
deprecated
func (*CreateContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateContainerResponse.ProtoReflect.Descriptor instead.
func (*CreateContainerResponse) GetAdjust ¶
func (x *CreateContainerResponse) GetAdjust() *ContainerAdjustment
func (*CreateContainerResponse) GetEvict ¶
func (x *CreateContainerResponse) GetEvict() []*ContainerEviction
func (*CreateContainerResponse) GetUpdate ¶
func (x *CreateContainerResponse) GetUpdate() []*ContainerUpdate
func (*CreateContainerResponse) ProtoMessage ¶
func (*CreateContainerResponse) ProtoMessage()
func (*CreateContainerResponse) ProtoReflect ¶
func (x *CreateContainerResponse) ProtoReflect() protoreflect.Message
func (*CreateContainerResponse) Reset ¶
func (x *CreateContainerResponse) Reset()
func (*CreateContainerResponse) String ¶
func (x *CreateContainerResponse) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
Empty response for those *Requests that are semantically events.
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
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) EnumDescriptor
deprecated
func (Event) Number ¶
func (x Event) Number() protoreflect.EnumNumber
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) PrettyString ¶
PrettyString returns a human-readable string representation of an EventMask.
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
func (*Hook) GetTimeout ¶
func (x *Hook) GetTimeout() *OptionalInt
func (*Hook) ProtoMessage ¶
func (*Hook) ProtoMessage()
func (*Hook) ProtoReflect ¶
func (x *Hook) ProtoReflect() protoreflect.Message
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) Descriptor
deprecated
func (*Hooks) GetCreateContainer ¶
func (*Hooks) GetCreateRuntime ¶
func (*Hooks) GetPoststart ¶
func (*Hooks) GetPoststop ¶
func (*Hooks) GetPrestart ¶
func (*Hooks) GetStartContainer ¶
func (*Hooks) ProtoMessage ¶
func (*Hooks) ProtoMessage()
func (*Hooks) ProtoReflect ¶
func (x *Hooks) ProtoReflect() protoreflect.Message
type HugepageLimit ¶
type HugepageLimit struct { PageSize string `protobuf:"bytes,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Limit uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
Container huge page limit.
func (*HugepageLimit) Descriptor
deprecated
func (*HugepageLimit) Descriptor() ([]byte, []int)
Deprecated: Use HugepageLimit.ProtoReflect.Descriptor instead.
func (*HugepageLimit) GetLimit ¶
func (x *HugepageLimit) GetLimit() uint64
func (*HugepageLimit) GetPageSize ¶
func (x *HugepageLimit) GetPageSize() string
func (*HugepageLimit) ProtoMessage ¶
func (*HugepageLimit) ProtoMessage()
func (*HugepageLimit) ProtoReflect ¶
func (x *HugepageLimit) ProtoReflect() protoreflect.Message
func (*HugepageLimit) Reset ¶
func (x *HugepageLimit) Reset()
func (*HugepageLimit) String ¶
func (x *HugepageLimit) String() string
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
func (*KeyValue) IsMarkedForRemoval ¶
IsMarkedForRemoval checks if an environment variable is marked for removal.
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
func (*KeyValue) ProtoReflect ¶
func (x *KeyValue) ProtoReflect() protoreflect.Message
type LinuxCPU ¶
type LinuxCPU struct { Quota *OptionalInt64 `protobuf:"bytes,2,opt,name=quota,proto3" json:"quota,omitempty"` Period *OptionalUInt64 `protobuf:"bytes,3,opt,name=period,proto3" json:"period,omitempty"` RealtimeRuntime *OptionalInt64 `protobuf:"bytes,4,opt,name=realtime_runtime,json=realtimeRuntime,proto3" json:"realtime_runtime,omitempty"` RealtimePeriod *OptionalUInt64 `protobuf:"bytes,5,opt,name=realtime_period,json=realtimePeriod,proto3" json:"realtime_period,omitempty"` Cpus string `protobuf:"bytes,6,opt,name=cpus,proto3" json:"cpus,omitempty"` Mems string `protobuf:"bytes,7,opt,name=mems,proto3" json:"mems,omitempty"` // contains filtered or unexported fields }
CPU-related parts of (linux) resources.
func (*LinuxCPU) Descriptor
deprecated
func (*LinuxCPU) 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) ProtoMessage ¶
func (*LinuxCPU) ProtoMessage()
func (*LinuxCPU) ProtoReflect ¶
func (x *LinuxCPU) ProtoReflect() protoreflect.Message
type LinuxContainer ¶
type LinuxContainer struct { Namespaces []*LinuxNamespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"` Devices []*LinuxDevice `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"` Resources *LinuxResources `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"` OomScoreAdj *OptionalInt `protobuf:"bytes,4,opt,name=oom_score_adj,json=oomScoreAdj,proto3" json:"oom_score_adj,omitempty"` CgroupsPath string `protobuf:"bytes,5,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"` // contains filtered or unexported fields }
Container (linux) metadata.
func (*LinuxContainer) Descriptor
deprecated
func (*LinuxContainer) Descriptor() ([]byte, []int)
Deprecated: Use LinuxContainer.ProtoReflect.Descriptor instead.
func (*LinuxContainer) GetCgroupsPath ¶
func (x *LinuxContainer) GetCgroupsPath() string
func (*LinuxContainer) GetDevices ¶
func (x *LinuxContainer) GetDevices() []*LinuxDevice
func (*LinuxContainer) GetNamespaces ¶
func (x *LinuxContainer) GetNamespaces() []*LinuxNamespace
func (*LinuxContainer) GetOomScoreAdj ¶
func (x *LinuxContainer) GetOomScoreAdj() *OptionalInt
func (*LinuxContainer) GetResources ¶
func (x *LinuxContainer) GetResources() *LinuxResources
func (*LinuxContainer) ProtoMessage ¶
func (*LinuxContainer) ProtoMessage()
func (*LinuxContainer) ProtoReflect ¶
func (x *LinuxContainer) ProtoReflect() protoreflect.Message
func (*LinuxContainer) Reset ¶
func (x *LinuxContainer) Reset()
func (*LinuxContainer) String ¶
func (x *LinuxContainer) String() string
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"` // contains filtered or unexported fields }
Adjustments to (linux) resources.
func (*LinuxContainerAdjustment) Descriptor
deprecated
func (*LinuxContainerAdjustment) Descriptor() ([]byte, []int)
Deprecated: Use LinuxContainerAdjustment.ProtoReflect.Descriptor instead.
func (*LinuxContainerAdjustment) GetCgroupsPath ¶
func (x *LinuxContainerAdjustment) GetCgroupsPath() string
func (*LinuxContainerAdjustment) GetDevices ¶
func (x *LinuxContainerAdjustment) GetDevices() []*LinuxDevice
func (*LinuxContainerAdjustment) GetResources ¶
func (x *LinuxContainerAdjustment) GetResources() *LinuxResources
func (*LinuxContainerAdjustment) ProtoMessage ¶
func (*LinuxContainerAdjustment) ProtoMessage()
func (*LinuxContainerAdjustment) ProtoReflect ¶
func (x *LinuxContainerAdjustment) ProtoReflect() protoreflect.Message
func (*LinuxContainerAdjustment) Reset ¶
func (x *LinuxContainerAdjustment) Reset()
func (*LinuxContainerAdjustment) String ¶
func (x *LinuxContainerAdjustment) String() string
type LinuxContainerUpdate ¶
type LinuxContainerUpdate struct { Resources *LinuxResources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"` // contains filtered or unexported fields }
Updates to (linux) resources.
func (*LinuxContainerUpdate) Descriptor
deprecated
func (*LinuxContainerUpdate) Descriptor() ([]byte, []int)
Deprecated: Use LinuxContainerUpdate.ProtoReflect.Descriptor instead.
func (*LinuxContainerUpdate) GetResources ¶
func (x *LinuxContainerUpdate) GetResources() *LinuxResources
func (*LinuxContainerUpdate) ProtoMessage ¶
func (*LinuxContainerUpdate) ProtoMessage()
func (*LinuxContainerUpdate) ProtoReflect ¶
func (x *LinuxContainerUpdate) ProtoReflect() protoreflect.Message
func (*LinuxContainerUpdate) Reset ¶
func (x *LinuxContainerUpdate) Reset()
func (*LinuxContainerUpdate) String ¶
func (x *LinuxContainerUpdate) String() string
type LinuxDevice ¶
type LinuxDevice struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Major int64 `protobuf:"varint,3,opt,name=major,proto3" json:"major,omitempty"` Minor int64 `protobuf:"varint,4,opt,name=minor,proto3" json:"minor,omitempty"` FileMode *OptionalFileMode `protobuf:"bytes,5,opt,name=file_mode,json=fileMode,proto3" json:"file_mode,omitempty"` Uid *OptionalUInt32 `protobuf:"bytes,6,opt,name=uid,proto3" json:"uid,omitempty"` Gid *OptionalUInt32 `protobuf:"bytes,7,opt,name=gid,proto3" json:"gid,omitempty"` // contains filtered or unexported fields }
A container (linux) device.
func FromOCILinuxDevices ¶
func FromOCILinuxDevices(o []rspec.LinuxDevice) []*LinuxDevice
FromOCILinuxDevices returns a device slice from an OCI runtime Spec.
func (*LinuxDevice) AccessString ¶
func (d *LinuxDevice) AccessString() string
AccessString returns an OCI access string for the device.
func (*LinuxDevice) Cmp ¶
func (d *LinuxDevice) Cmp(v *LinuxDevice) bool
Cmp returns true if the devices are equal.
func (*LinuxDevice) Descriptor
deprecated
func (*LinuxDevice) Descriptor() ([]byte, []int)
Deprecated: Use LinuxDevice.ProtoReflect.Descriptor instead.
func (*LinuxDevice) GetFileMode ¶
func (x *LinuxDevice) GetFileMode() *OptionalFileMode
func (*LinuxDevice) GetGid ¶
func (x *LinuxDevice) GetGid() *OptionalUInt32
func (*LinuxDevice) GetMajor ¶
func (x *LinuxDevice) GetMajor() int64
func (*LinuxDevice) GetMinor ¶
func (x *LinuxDevice) GetMinor() int64
func (*LinuxDevice) GetPath ¶
func (x *LinuxDevice) GetPath() string
func (*LinuxDevice) GetType ¶
func (x *LinuxDevice) GetType() string
func (*LinuxDevice) GetUid ¶
func (x *LinuxDevice) GetUid() *OptionalUInt32
func (*LinuxDevice) IsMarkedForRemoval ¶
func (d *LinuxDevice) IsMarkedForRemoval() (string, bool)
IsMarkedForRemoval checks if a LinuxDevice is marked for removal.
func (*LinuxDevice) ProtoMessage ¶
func (*LinuxDevice) ProtoMessage()
func (*LinuxDevice) ProtoReflect ¶
func (x *LinuxDevice) ProtoReflect() protoreflect.Message
func (*LinuxDevice) Reset ¶
func (x *LinuxDevice) Reset()
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.
type LinuxDeviceCgroup ¶
type LinuxDeviceCgroup struct { Allow bool `protobuf:"varint,1,opt,name=allow,proto3" json:"allow,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Major *OptionalInt64 `protobuf:"bytes,3,opt,name=major,proto3" json:"major,omitempty"` Minor *OptionalInt64 `protobuf:"bytes,4,opt,name=minor,proto3" json:"minor,omitempty"` Access string `protobuf:"bytes,5,opt,name=access,proto3" json:"access,omitempty"` // contains filtered or unexported fields }
A linux device cgroup controller rule.
func (*LinuxDeviceCgroup) Descriptor
deprecated
func (*LinuxDeviceCgroup) Descriptor() ([]byte, []int)
Deprecated: Use LinuxDeviceCgroup.ProtoReflect.Descriptor instead.
func (*LinuxDeviceCgroup) GetAccess ¶
func (x *LinuxDeviceCgroup) GetAccess() string
func (*LinuxDeviceCgroup) GetAllow ¶
func (x *LinuxDeviceCgroup) GetAllow() bool
func (*LinuxDeviceCgroup) GetMajor ¶
func (x *LinuxDeviceCgroup) GetMajor() *OptionalInt64
func (*LinuxDeviceCgroup) GetMinor ¶
func (x *LinuxDeviceCgroup) GetMinor() *OptionalInt64
func (*LinuxDeviceCgroup) GetType ¶
func (x *LinuxDeviceCgroup) GetType() string
func (*LinuxDeviceCgroup) ProtoMessage ¶
func (*LinuxDeviceCgroup) ProtoMessage()
func (*LinuxDeviceCgroup) ProtoReflect ¶
func (x *LinuxDeviceCgroup) ProtoReflect() protoreflect.Message
func (*LinuxDeviceCgroup) Reset ¶
func (x *LinuxDeviceCgroup) Reset()
func (*LinuxDeviceCgroup) String ¶
func (x *LinuxDeviceCgroup) String() string
type LinuxMemory ¶
type LinuxMemory struct { Limit *OptionalInt64 `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"` Reservation *OptionalInt64 `protobuf:"bytes,2,opt,name=reservation,proto3" json:"reservation,omitempty"` Swap *OptionalInt64 `protobuf:"bytes,3,opt,name=swap,proto3" json:"swap,omitempty"` Kernel *OptionalInt64 `protobuf:"bytes,4,opt,name=kernel,proto3" json:"kernel,omitempty"` KernelTcp *OptionalInt64 `protobuf:"bytes,5,opt,name=kernel_tcp,json=kernelTcp,proto3" json:"kernel_tcp,omitempty"` Swappiness *OptionalUInt64 `protobuf:"bytes,6,opt,name=swappiness,proto3" json:"swappiness,omitempty"` DisableOomKiller *OptionalBool `protobuf:"bytes,7,opt,name=disable_oom_killer,json=disableOomKiller,proto3" json:"disable_oom_killer,omitempty"` UseHierarchy *OptionalBool `protobuf:"bytes,8,opt,name=use_hierarchy,json=useHierarchy,proto3" json:"use_hierarchy,omitempty"` // contains filtered or unexported fields }
Memory-related parts of (linux) resources.
func (*LinuxMemory) Descriptor
deprecated
func (*LinuxMemory) Descriptor() ([]byte, []int)
Deprecated: Use LinuxMemory.ProtoReflect.Descriptor instead.
func (*LinuxMemory) GetDisableOomKiller ¶
func (x *LinuxMemory) GetDisableOomKiller() *OptionalBool
func (*LinuxMemory) GetKernel ¶
func (x *LinuxMemory) GetKernel() *OptionalInt64
func (*LinuxMemory) GetKernelTcp ¶
func (x *LinuxMemory) GetKernelTcp() *OptionalInt64
func (*LinuxMemory) GetLimit ¶
func (x *LinuxMemory) GetLimit() *OptionalInt64
func (*LinuxMemory) GetReservation ¶
func (x *LinuxMemory) GetReservation() *OptionalInt64
func (*LinuxMemory) GetSwap ¶
func (x *LinuxMemory) GetSwap() *OptionalInt64
func (*LinuxMemory) GetSwappiness ¶
func (x *LinuxMemory) GetSwappiness() *OptionalUInt64
func (*LinuxMemory) GetUseHierarchy ¶
func (x *LinuxMemory) GetUseHierarchy() *OptionalBool
func (*LinuxMemory) ProtoMessage ¶
func (*LinuxMemory) ProtoMessage()
func (*LinuxMemory) ProtoReflect ¶
func (x *LinuxMemory) ProtoReflect() protoreflect.Message
func (*LinuxMemory) Reset ¶
func (x *LinuxMemory) Reset()
func (*LinuxMemory) String ¶
func (x *LinuxMemory) String() string
type LinuxNamespace ¶
type LinuxNamespace struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
A linux namespace.
func FromOCILinuxNamespaces ¶
func FromOCILinuxNamespaces(o []rspec.LinuxNamespace) []*LinuxNamespace
FromOCILinuxNamespaces returns a namespace slice from an OCI runtime Spec.
func (*LinuxNamespace) Descriptor
deprecated
func (*LinuxNamespace) Descriptor() ([]byte, []int)
Deprecated: Use LinuxNamespace.ProtoReflect.Descriptor instead.
func (*LinuxNamespace) GetPath ¶
func (x *LinuxNamespace) GetPath() string
func (*LinuxNamespace) GetType ¶
func (x *LinuxNamespace) GetType() string
func (*LinuxNamespace) ProtoMessage ¶
func (*LinuxNamespace) ProtoMessage()
func (*LinuxNamespace) ProtoReflect ¶
func (x *LinuxNamespace) ProtoReflect() protoreflect.Message
func (*LinuxNamespace) Reset ¶
func (x *LinuxNamespace) Reset()
func (*LinuxNamespace) String ¶
func (x *LinuxNamespace) String() string
type LinuxPodSandbox ¶
type LinuxPodSandbox struct { PodOverhead *LinuxResources `protobuf:"bytes,1,opt,name=pod_overhead,json=podOverhead,proto3" json:"pod_overhead,omitempty"` PodResources *LinuxResources `protobuf:"bytes,2,opt,name=pod_resources,json=podResources,proto3" json:"pod_resources,omitempty"` CgroupParent string `protobuf:"bytes,3,opt,name=cgroup_parent,json=cgroupParent,proto3" json:"cgroup_parent,omitempty"` CgroupsPath string `protobuf:"bytes,4,opt,name=cgroups_path,json=cgroupsPath,proto3" json:"cgroups_path,omitempty"` // for NRI v1 emulation Namespaces []*LinuxNamespace `protobuf:"bytes,5,rep,name=namespaces,proto3" json:"namespaces,omitempty"` // for NRI v1 emulation Resources *LinuxResources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` // for NRI v1 emulation // contains filtered or unexported fields }
PodSandbox linux-specific metadata
func (*LinuxPodSandbox) Descriptor
deprecated
func (*LinuxPodSandbox) Descriptor() ([]byte, []int)
Deprecated: Use LinuxPodSandbox.ProtoReflect.Descriptor instead.
func (*LinuxPodSandbox) GetCgroupParent ¶
func (x *LinuxPodSandbox) GetCgroupParent() string
func (*LinuxPodSandbox) GetCgroupsPath ¶
func (x *LinuxPodSandbox) GetCgroupsPath() string
func (*LinuxPodSandbox) GetNamespaces ¶
func (x *LinuxPodSandbox) GetNamespaces() []*LinuxNamespace
func (*LinuxPodSandbox) GetPodOverhead ¶
func (x *LinuxPodSandbox) GetPodOverhead() *LinuxResources
func (*LinuxPodSandbox) GetPodResources ¶
func (x *LinuxPodSandbox) GetPodResources() *LinuxResources
func (*LinuxPodSandbox) GetResources ¶
func (x *LinuxPodSandbox) GetResources() *LinuxResources
func (*LinuxPodSandbox) ProtoMessage ¶
func (*LinuxPodSandbox) ProtoMessage()
func (*LinuxPodSandbox) ProtoReflect ¶
func (x *LinuxPodSandbox) ProtoReflect() protoreflect.Message
func (*LinuxPodSandbox) Reset ¶
func (x *LinuxPodSandbox) Reset()
func (*LinuxPodSandbox) String ¶
func (x *LinuxPodSandbox) String() string
type LinuxResources ¶
type LinuxResources struct { Memory *LinuxMemory `protobuf:"bytes,1,opt,name=memory,proto3" json:"memory,omitempty"` Cpu *LinuxCPU `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"` HugepageLimits []*HugepageLimit `protobuf:"bytes,3,rep,name=hugepage_limits,json=hugepageLimits,proto3" json:"hugepage_limits,omitempty"` BlockioClass *OptionalString `protobuf:"bytes,4,opt,name=blockio_class,json=blockioClass,proto3" json:"blockio_class,omitempty"` RdtClass *OptionalString `protobuf:"bytes,5,opt,name=rdt_class,json=rdtClass,proto3" json:"rdt_class,omitempty"` Unified map[string]string `` /* 155-byte string literal not displayed */ Devices []*LinuxDeviceCgroup `protobuf:"bytes,7,rep,name=devices,proto3" json:"devices,omitempty"` // for NRI v1 emulation // contains filtered or unexported fields }
Container (linux) resources.
func FromCRILinuxResources ¶
func FromCRILinuxResources(c *cri.LinuxContainerResources) *LinuxResources
func FromOCILinuxResources ¶
func FromOCILinuxResources(o *rspec.LinuxResources, ann map[string]string) *LinuxResources
FromOCILinuxResources returns resources from an OCI runtime Spec.
func (*LinuxResources) Copy ¶
func (r *LinuxResources) Copy() *LinuxResources
Copy creates a copy of the resources.
func (*LinuxResources) Descriptor
deprecated
func (*LinuxResources) Descriptor() ([]byte, []int)
Deprecated: Use LinuxResources.ProtoReflect.Descriptor instead.
func (*LinuxResources) GetBlockioClass ¶
func (x *LinuxResources) GetBlockioClass() *OptionalString
func (*LinuxResources) GetCpu ¶
func (x *LinuxResources) GetCpu() *LinuxCPU
func (*LinuxResources) GetDevices ¶
func (x *LinuxResources) GetDevices() []*LinuxDeviceCgroup
func (*LinuxResources) GetHugepageLimits ¶
func (x *LinuxResources) GetHugepageLimits() []*HugepageLimit
func (*LinuxResources) GetMemory ¶
func (x *LinuxResources) GetMemory() *LinuxMemory
func (*LinuxResources) GetRdtClass ¶
func (x *LinuxResources) GetRdtClass() *OptionalString
func (*LinuxResources) GetUnified ¶
func (x *LinuxResources) GetUnified() map[string]string
func (*LinuxResources) ProtoMessage ¶
func (*LinuxResources) ProtoMessage()
func (*LinuxResources) ProtoReflect ¶
func (x *LinuxResources) ProtoReflect() protoreflect.Message
func (*LinuxResources) Reset ¶
func (x *LinuxResources) Reset()
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.
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) Descriptor
deprecated
func (*Mount) GetDestination ¶
func (*Mount) GetOptions ¶
func (*Mount) IsMarkedForRemoval ¶
IsMarkedForRemoval checks if a Mount is marked for removal.
func (*Mount) ProtoMessage ¶
func (*Mount) ProtoMessage()
func (*Mount) ProtoReflect ¶
func (x *Mount) ProtoReflect() protoreflect.Message
type OptionalBool ¶
type OptionalBool struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional boolean value.
func Bool ¶
func Bool(v interface{}) *OptionalBool
Bool creates an Optional wrapper from its argument.
func (*OptionalBool) Descriptor
deprecated
func (*OptionalBool) Descriptor() ([]byte, []int)
Deprecated: Use OptionalBool.ProtoReflect.Descriptor instead.
func (*OptionalBool) Get ¶
func (o *OptionalBool) Get() *bool
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalBool) GetValue ¶
func (x *OptionalBool) GetValue() bool
func (*OptionalBool) ProtoMessage ¶
func (*OptionalBool) ProtoMessage()
func (*OptionalBool) ProtoReflect ¶
func (x *OptionalBool) ProtoReflect() protoreflect.Message
func (*OptionalBool) Reset ¶
func (x *OptionalBool) Reset()
func (*OptionalBool) String ¶
func (x *OptionalBool) String() string
type OptionalFileMode ¶
type OptionalFileMode struct { Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional value of file permissions.
func FileMode ¶
func FileMode(v interface{}) *OptionalFileMode
FileMode creates an Optional wrapper from its argument.
func (*OptionalFileMode) Descriptor
deprecated
func (*OptionalFileMode) Descriptor() ([]byte, []int)
Deprecated: Use OptionalFileMode.ProtoReflect.Descriptor instead.
func (*OptionalFileMode) Get ¶
func (o *OptionalFileMode) Get() *os.FileMode
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalFileMode) GetValue ¶
func (x *OptionalFileMode) GetValue() uint32
func (*OptionalFileMode) ProtoMessage ¶
func (*OptionalFileMode) ProtoMessage()
func (*OptionalFileMode) ProtoReflect ¶
func (x *OptionalFileMode) ProtoReflect() protoreflect.Message
func (*OptionalFileMode) Reset ¶
func (x *OptionalFileMode) Reset()
func (*OptionalFileMode) String ¶
func (x *OptionalFileMode) String() string
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 (*OptionalInt) Descriptor
deprecated
func (*OptionalInt) Descriptor() ([]byte, []int)
Deprecated: Use OptionalInt.ProtoReflect.Descriptor instead.
func (*OptionalInt) Get ¶
func (o *OptionalInt) Get() *int
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalInt) GetValue ¶
func (x *OptionalInt) GetValue() int64
func (*OptionalInt) ProtoMessage ¶
func (*OptionalInt) ProtoMessage()
func (*OptionalInt) ProtoReflect ¶
func (x *OptionalInt) ProtoReflect() protoreflect.Message
func (*OptionalInt) Reset ¶
func (x *OptionalInt) Reset()
func (*OptionalInt) String ¶
func (x *OptionalInt) String() string
type OptionalInt32 ¶
type OptionalInt32 struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 32-bit signed integer value.
func Int32 ¶
func Int32(v interface{}) *OptionalInt32
Int32 creates an Optional wrapper from its argument.
func (*OptionalInt32) Descriptor
deprecated
func (*OptionalInt32) Descriptor() ([]byte, []int)
Deprecated: Use OptionalInt32.ProtoReflect.Descriptor instead.
func (*OptionalInt32) Get ¶
func (o *OptionalInt32) Get() *int32
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalInt32) GetValue ¶
func (x *OptionalInt32) GetValue() int32
func (*OptionalInt32) ProtoMessage ¶
func (*OptionalInt32) ProtoMessage()
func (*OptionalInt32) ProtoReflect ¶
func (x *OptionalInt32) ProtoReflect() protoreflect.Message
func (*OptionalInt32) Reset ¶
func (x *OptionalInt32) Reset()
func (*OptionalInt32) String ¶
func (x *OptionalInt32) String() string
type OptionalInt64 ¶
type OptionalInt64 struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 64-bit signed integer value.
func Int64 ¶
func Int64(v interface{}) *OptionalInt64
Int64 creates an Optional wrapper from its argument.
func (*OptionalInt64) Descriptor
deprecated
func (*OptionalInt64) Descriptor() ([]byte, []int)
Deprecated: Use OptionalInt64.ProtoReflect.Descriptor instead.
func (*OptionalInt64) Get ¶
func (o *OptionalInt64) Get() *int64
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalInt64) GetValue ¶
func (x *OptionalInt64) GetValue() int64
func (*OptionalInt64) ProtoMessage ¶
func (*OptionalInt64) ProtoMessage()
func (*OptionalInt64) ProtoReflect ¶
func (x *OptionalInt64) ProtoReflect() protoreflect.Message
func (*OptionalInt64) Reset ¶
func (x *OptionalInt64) Reset()
func (*OptionalInt64) String ¶
func (x *OptionalInt64) String() string
type OptionalString ¶
type OptionalString struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional string value.
func String ¶
func String(v interface{}) *OptionalString
String creates an Optional wrapper from its argument.
func (*OptionalString) Descriptor
deprecated
func (*OptionalString) Descriptor() ([]byte, []int)
Deprecated: Use OptionalString.ProtoReflect.Descriptor instead.
func (*OptionalString) Get ¶
func (o *OptionalString) Get() *string
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalString) GetValue ¶
func (x *OptionalString) GetValue() string
func (*OptionalString) ProtoMessage ¶
func (*OptionalString) ProtoMessage()
func (*OptionalString) ProtoReflect ¶
func (x *OptionalString) ProtoReflect() protoreflect.Message
func (*OptionalString) Reset ¶
func (x *OptionalString) Reset()
func (*OptionalString) String ¶
func (x *OptionalString) String() string
type OptionalUInt32 ¶
type OptionalUInt32 struct { Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 32-bit unsigned integer value.
func UInt32 ¶
func UInt32(v interface{}) *OptionalUInt32
UInt32 creates an Optional wrapper from its argument.
func (*OptionalUInt32) Descriptor
deprecated
func (*OptionalUInt32) Descriptor() ([]byte, []int)
Deprecated: Use OptionalUInt32.ProtoReflect.Descriptor instead.
func (*OptionalUInt32) Get ¶
func (o *OptionalUInt32) Get() *uint32
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalUInt32) GetValue ¶
func (x *OptionalUInt32) GetValue() uint32
func (*OptionalUInt32) ProtoMessage ¶
func (*OptionalUInt32) ProtoMessage()
func (*OptionalUInt32) ProtoReflect ¶
func (x *OptionalUInt32) ProtoReflect() protoreflect.Message
func (*OptionalUInt32) Reset ¶
func (x *OptionalUInt32) Reset()
func (*OptionalUInt32) String ¶
func (x *OptionalUInt32) String() string
type OptionalUInt64 ¶
type OptionalUInt64 struct { Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An optional 64-bit unsigned integer value.
func UInt64 ¶
func UInt64(v interface{}) *OptionalUInt64
UInt64 creates an Optional wrapper from its argument.
func (*OptionalUInt64) Descriptor
deprecated
func (*OptionalUInt64) Descriptor() ([]byte, []int)
Deprecated: Use OptionalUInt64.ProtoReflect.Descriptor instead.
func (*OptionalUInt64) Get ¶
func (o *OptionalUInt64) Get() *uint64
Get returns nil if its value is unset or a pointer to the value itself.
func (*OptionalUInt64) GetValue ¶
func (x *OptionalUInt64) GetValue() uint64
func (*OptionalUInt64) ProtoMessage ¶
func (*OptionalUInt64) ProtoMessage()
func (*OptionalUInt64) ProtoReflect ¶
func (x *OptionalUInt64) ProtoReflect() protoreflect.Message
func (*OptionalUInt64) Reset ¶
func (x *OptionalUInt64) Reset()
func (*OptionalUInt64) String ¶
func (x *OptionalUInt64) String() string
type POSIXRlimit ¶ added in v0.4.0
type POSIXRlimit struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Hard uint64 `protobuf:"varint,2,opt,name=hard,proto3" json:"hard,omitempty"` Soft uint64 `protobuf:"varint,3,opt,name=soft,proto3" json:"soft,omitempty"` // contains filtered or unexported fields }
Container rlimits
func (*POSIXRlimit) Descriptor
deprecated
added in
v0.4.0
func (*POSIXRlimit) Descriptor() ([]byte, []int)
Deprecated: Use POSIXRlimit.ProtoReflect.Descriptor instead.
func (*POSIXRlimit) GetHard ¶ added in v0.4.0
func (x *POSIXRlimit) GetHard() uint64
func (*POSIXRlimit) GetSoft ¶ added in v0.4.0
func (x *POSIXRlimit) GetSoft() uint64
func (*POSIXRlimit) GetType ¶ added in v0.4.0
func (x *POSIXRlimit) GetType() string
func (*POSIXRlimit) ProtoMessage ¶ added in v0.4.0
func (*POSIXRlimit) ProtoMessage()
func (*POSIXRlimit) ProtoReflect ¶ added in v0.4.0
func (x *POSIXRlimit) ProtoReflect() protoreflect.Message
func (*POSIXRlimit) Reset ¶ added in v0.4.0
func (x *POSIXRlimit) Reset()
func (*POSIXRlimit) String ¶ added in v0.4.0
func (x *POSIXRlimit) String() string
type PluginService ¶
type PluginService interface { Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error) Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error) Shutdown(context.Context, *Empty) (*Empty, error) CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error) UpdateContainer(context.Context, *UpdateContainerRequest) (*UpdateContainerResponse, error) StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error) StateChange(context.Context, *StateChangeEvent) (*Empty, error) }
func NewPluginClient ¶
func NewPluginClient(client *ttrpc.Client) PluginService
type PodSandbox ¶
type PodSandbox struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Annotations map[string]string `` /* 163-byte string literal not displayed */ RuntimeHandler string `protobuf:"bytes,7,opt,name=runtime_handler,json=runtimeHandler,proto3" json:"runtime_handler,omitempty"` Linux *LinuxPodSandbox `protobuf:"bytes,8,opt,name=linux,proto3" json:"linux,omitempty"` Pid uint32 `protobuf:"varint,9,opt,name=pid,proto3" json:"pid,omitempty"` // for NRI v1 emulation // contains filtered or unexported fields }
Pod metadata that is considered relevant for a plugin.
func (*PodSandbox) Descriptor
deprecated
func (*PodSandbox) Descriptor() ([]byte, []int)
Deprecated: Use PodSandbox.ProtoReflect.Descriptor instead.
func (*PodSandbox) GetAnnotations ¶
func (x *PodSandbox) GetAnnotations() map[string]string
func (*PodSandbox) GetId ¶
func (x *PodSandbox) GetId() string
func (*PodSandbox) 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) ProtoMessage ¶
func (*PodSandbox) ProtoMessage()
func (*PodSandbox) ProtoReflect ¶
func (x *PodSandbox) ProtoReflect() protoreflect.Message
func (*PodSandbox) Reset ¶
func (x *PodSandbox) Reset()
func (*PodSandbox) String ¶
func (x *PodSandbox) String() string
type RegisterPluginRequest ¶
type RegisterPluginRequest struct { // Name of the plugin to register. PluginName string `protobuf:"bytes,1,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"` // Plugin invocation index. Plugins are called in ascending index order. PluginIdx string `protobuf:"bytes,2,opt,name=plugin_idx,json=pluginIdx,proto3" json:"plugin_idx,omitempty"` // contains filtered or unexported fields }
func (*RegisterPluginRequest) Descriptor
deprecated
func (*RegisterPluginRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterPluginRequest.ProtoReflect.Descriptor instead.
func (*RegisterPluginRequest) GetPluginIdx ¶
func (x *RegisterPluginRequest) GetPluginIdx() string
func (*RegisterPluginRequest) GetPluginName ¶
func (x *RegisterPluginRequest) GetPluginName() string
func (*RegisterPluginRequest) ProtoMessage ¶
func (*RegisterPluginRequest) ProtoMessage()
func (*RegisterPluginRequest) ProtoReflect ¶
func (x *RegisterPluginRequest) ProtoReflect() protoreflect.Message
func (*RegisterPluginRequest) Reset ¶
func (x *RegisterPluginRequest) Reset()
func (*RegisterPluginRequest) String ¶
func (x *RegisterPluginRequest) String() string
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 StateChangeEvent ¶
type StateChangeEvent struct { // Event type of notification. Event Event `protobuf:"varint,1,opt,name=event,proto3,enum=nri.pkg.api.v1alpha1.Event" json:"event,omitempty"` // Pod this notification is sent for. If this event is related to a container, // pod is set to the pod of the container. Pod *PodSandbox `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"` // Container this notification is sent for. If the event is related to a pod, // container is nil. Container *Container `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"` // contains filtered or unexported fields }
func (*StateChangeEvent) Descriptor
deprecated
func (*StateChangeEvent) Descriptor() ([]byte, []int)
Deprecated: Use StateChangeEvent.ProtoReflect.Descriptor instead.
func (*StateChangeEvent) GetContainer ¶
func (x *StateChangeEvent) GetContainer() *Container
func (*StateChangeEvent) GetEvent ¶
func (x *StateChangeEvent) GetEvent() Event
func (*StateChangeEvent) GetPod ¶
func (x *StateChangeEvent) GetPod() *PodSandbox
func (*StateChangeEvent) ProtoMessage ¶
func (*StateChangeEvent) ProtoMessage()
func (*StateChangeEvent) ProtoReflect ¶
func (x *StateChangeEvent) ProtoReflect() protoreflect.Message
func (*StateChangeEvent) Reset ¶
func (x *StateChangeEvent) Reset()
func (*StateChangeEvent) String ¶
func (x *StateChangeEvent) String() string
type StopContainerRequest ¶
type StopContainerRequest struct { // Pod of container being stopped. Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` // Container being stopped. Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` // contains filtered or unexported fields }
func (*StopContainerRequest) Descriptor
deprecated
func (*StopContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopContainerRequest.ProtoReflect.Descriptor instead.
func (*StopContainerRequest) GetContainer ¶
func (x *StopContainerRequest) GetContainer() *Container
func (*StopContainerRequest) GetPod ¶
func (x *StopContainerRequest) GetPod() *PodSandbox
func (*StopContainerRequest) ProtoMessage ¶
func (*StopContainerRequest) ProtoMessage()
func (*StopContainerRequest) ProtoReflect ¶
func (x *StopContainerRequest) ProtoReflect() protoreflect.Message
func (*StopContainerRequest) Reset ¶
func (x *StopContainerRequest) Reset()
func (*StopContainerRequest) String ¶
func (x *StopContainerRequest) String() string
type StopContainerResponse ¶
type StopContainerResponse struct { // Requested updates to containers. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // contains filtered or unexported fields }
func (*StopContainerResponse) Descriptor
deprecated
func (*StopContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopContainerResponse.ProtoReflect.Descriptor instead.
func (*StopContainerResponse) GetUpdate ¶
func (x *StopContainerResponse) GetUpdate() []*ContainerUpdate
func (*StopContainerResponse) ProtoMessage ¶
func (*StopContainerResponse) ProtoMessage()
func (*StopContainerResponse) ProtoReflect ¶
func (x *StopContainerResponse) ProtoReflect() protoreflect.Message
func (*StopContainerResponse) Reset ¶
func (x *StopContainerResponse) Reset()
func (*StopContainerResponse) String ¶
func (x *StopContainerResponse) String() string
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"` // contains filtered or unexported fields }
func (*SynchronizeRequest) Descriptor
deprecated
func (*SynchronizeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.
func (*SynchronizeRequest) GetContainers ¶
func (x *SynchronizeRequest) GetContainers() []*Container
func (*SynchronizeRequest) GetPods ¶
func (x *SynchronizeRequest) GetPods() []*PodSandbox
func (*SynchronizeRequest) ProtoMessage ¶
func (*SynchronizeRequest) ProtoMessage()
func (*SynchronizeRequest) ProtoReflect ¶
func (x *SynchronizeRequest) ProtoReflect() protoreflect.Message
func (*SynchronizeRequest) Reset ¶
func (x *SynchronizeRequest) Reset()
func (*SynchronizeRequest) String ¶
func (x *SynchronizeRequest) String() string
type SynchronizeResponse ¶
type SynchronizeResponse struct { // Updates to containers requested by the plugin. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // contains filtered or unexported fields }
func (*SynchronizeResponse) Descriptor
deprecated
func (*SynchronizeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.
func (*SynchronizeResponse) GetUpdate ¶
func (x *SynchronizeResponse) GetUpdate() []*ContainerUpdate
func (*SynchronizeResponse) ProtoMessage ¶
func (*SynchronizeResponse) ProtoMessage()
func (*SynchronizeResponse) ProtoReflect ¶
func (x *SynchronizeResponse) ProtoReflect() protoreflect.Message
func (*SynchronizeResponse) Reset ¶
func (x *SynchronizeResponse) Reset()
func (*SynchronizeResponse) String ¶
func (x *SynchronizeResponse) String() string
type UpdateContainerRequest ¶
type UpdateContainerRequest struct { // Pod of container being updated. Pod *PodSandbox `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` // Container being updated. Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` // Resources to update. LinuxResources *LinuxResources `protobuf:"bytes,3,opt,name=linux_resources,json=linuxResources,proto3" json:"linux_resources,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainerRequest) Descriptor
deprecated
func (*UpdateContainerRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainerRequest.ProtoReflect.Descriptor instead.
func (*UpdateContainerRequest) GetContainer ¶
func (x *UpdateContainerRequest) GetContainer() *Container
func (*UpdateContainerRequest) GetLinuxResources ¶
func (x *UpdateContainerRequest) GetLinuxResources() *LinuxResources
func (*UpdateContainerRequest) GetPod ¶
func (x *UpdateContainerRequest) GetPod() *PodSandbox
func (*UpdateContainerRequest) ProtoMessage ¶
func (*UpdateContainerRequest) ProtoMessage()
func (*UpdateContainerRequest) ProtoReflect ¶
func (x *UpdateContainerRequest) ProtoReflect() protoreflect.Message
func (*UpdateContainerRequest) Reset ¶
func (x *UpdateContainerRequest) Reset()
func (*UpdateContainerRequest) String ¶
func (x *UpdateContainerRequest) String() string
type UpdateContainerResponse ¶
type UpdateContainerResponse struct { // Requested updates to containers. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // Requested eviction of containers. Evict []*ContainerEviction `protobuf:"bytes,2,rep,name=evict,proto3" json:"evict,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainerResponse) Descriptor
deprecated
func (*UpdateContainerResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainerResponse.ProtoReflect.Descriptor instead.
func (*UpdateContainerResponse) GetEvict ¶
func (x *UpdateContainerResponse) GetEvict() []*ContainerEviction
func (*UpdateContainerResponse) GetUpdate ¶
func (x *UpdateContainerResponse) GetUpdate() []*ContainerUpdate
func (*UpdateContainerResponse) ProtoMessage ¶
func (*UpdateContainerResponse) ProtoMessage()
func (*UpdateContainerResponse) ProtoReflect ¶
func (x *UpdateContainerResponse) ProtoReflect() protoreflect.Message
func (*UpdateContainerResponse) Reset ¶
func (x *UpdateContainerResponse) Reset()
func (*UpdateContainerResponse) String ¶
func (x *UpdateContainerResponse) String() string
type UpdateContainersRequest ¶
type UpdateContainersRequest struct { // List of containers to update. Update []*ContainerUpdate `protobuf:"bytes,1,rep,name=update,proto3" json:"update,omitempty"` // List of containers to evict. Evict []*ContainerEviction `protobuf:"bytes,2,rep,name=evict,proto3" json:"evict,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainersRequest) Descriptor
deprecated
func (*UpdateContainersRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainersRequest.ProtoReflect.Descriptor instead.
func (*UpdateContainersRequest) GetEvict ¶
func (x *UpdateContainersRequest) GetEvict() []*ContainerEviction
func (*UpdateContainersRequest) GetUpdate ¶
func (x *UpdateContainersRequest) GetUpdate() []*ContainerUpdate
func (*UpdateContainersRequest) ProtoMessage ¶
func (*UpdateContainersRequest) ProtoMessage()
func (*UpdateContainersRequest) ProtoReflect ¶
func (x *UpdateContainersRequest) ProtoReflect() protoreflect.Message
func (*UpdateContainersRequest) Reset ¶
func (x *UpdateContainersRequest) Reset()
func (*UpdateContainersRequest) String ¶
func (x *UpdateContainersRequest) String() string
type UpdateContainersResponse ¶
type UpdateContainersResponse struct { // Containers that the runtime failed to udpate. Failed []*ContainerUpdate `protobuf:"bytes,1,rep,name=failed,proto3" json:"failed,omitempty"` // contains filtered or unexported fields }
func (*UpdateContainersResponse) Descriptor
deprecated
func (*UpdateContainersResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateContainersResponse.ProtoReflect.Descriptor instead.
func (*UpdateContainersResponse) GetFailed ¶
func (x *UpdateContainersResponse) GetFailed() []*ContainerUpdate
func (*UpdateContainersResponse) ProtoMessage ¶
func (*UpdateContainersResponse) ProtoMessage()
func (*UpdateContainersResponse) ProtoReflect ¶
func (x *UpdateContainersResponse) ProtoReflect() protoreflect.Message
func (*UpdateContainersResponse) Reset ¶
func (x *UpdateContainersResponse) Reset()
func (*UpdateContainersResponse) String ¶
func (x *UpdateContainersResponse) String() string