cri

Documentation

Index

• func IsKeyValExistInLabels(labels map[string]string, key, val string) bool
• type ContainerResourceExecutor
  • func NewContainerResourceExecutor() *ContainerResourceExecutor
  • func (c *ContainerResourceExecutor) DeleteCheckpointIfNeed(req interface{}) error
  • func (c *ContainerResourceExecutor) GenerateHookRequest() interface{}
  • func (c *ContainerResourceExecutor) GetMetaInfo() string
  • func (c *ContainerResourceExecutor) ParseContainer(container *runtimeapi.Container) error
  • func (c *ContainerResourceExecutor) ParseRequest(req interface{}) (utils.CallHookPluginOperation, error)
  • func (c *ContainerResourceExecutor) ResourceCheckPoint(rsp interface{}) error
  • func (c *ContainerResourceExecutor) String() string
  • func (c *ContainerResourceExecutor) UpdateRequest(rsp interface{}, req interface{}) error
• type PodResourceExecutor
  • func NewPodResourceExecutor() *PodResourceExecutor
  • func (p *PodResourceExecutor) DeleteCheckpointIfNeed(req interface{}) error
  • func (p *PodResourceExecutor) GenerateHookRequest() interface{}
  • func (p *PodResourceExecutor) GetMetaInfo() string
  • func (p *PodResourceExecutor) ParsePod(podsandbox *runtimeapi.PodSandbox) error
  • func (p *PodResourceExecutor) ParseRequest(req interface{}) (utils.CallHookPluginOperation, error)
  • func (p *PodResourceExecutor) ResourceCheckPoint(response interface{}) error
  • func (p *PodResourceExecutor) String() string
  • func (p *PodResourceExecutor) UpdateRequest(rsp interface{}, req interface{}) error

Functions

func IsKeyValExistInLabels

func IsKeyValExistInLabels(labels map[string]string, key, val string) bool

Types

type ContainerResourceExecutor

type ContainerResourceExecutor struct {
	store.ContainerInfo
}

func NewContainerResourceExecutor

func NewContainerResourceExecutor() *ContainerResourceExecutor

func (*ContainerResourceExecutor) DeleteCheckpointIfNeed

func (c *ContainerResourceExecutor) DeleteCheckpointIfNeed(req interface{}) error

func (*ContainerResourceExecutor) GenerateHookRequest

func (c *ContainerResourceExecutor) GenerateHookRequest() interface{}

func (*ContainerResourceExecutor) GetMetaInfo

func (c *ContainerResourceExecutor) GetMetaInfo() string

func (*ContainerResourceExecutor) ParseContainer

func (c *ContainerResourceExecutor) ParseContainer(container *runtimeapi.Container) error

func (*ContainerResourceExecutor) ParseRequest

func (c *ContainerResourceExecutor) ParseRequest(req interface{}) (utils.CallHookPluginOperation, error)

func (*ContainerResourceExecutor) ResourceCheckPoint

func (c *ContainerResourceExecutor) ResourceCheckPoint(rsp interface{}) error

func (*ContainerResourceExecutor) String

func (c *ContainerResourceExecutor) String() string

func (*ContainerResourceExecutor) UpdateRequest

func (c *ContainerResourceExecutor) UpdateRequest(rsp interface{}, req interface{}) error

UpdateRequest will update ContainerResourceExecutor from hook response and then update CRI request.

type PodResourceExecutor

type PodResourceExecutor struct {
	store.PodSandboxInfo
}

func NewPodResourceExecutor

func NewPodResourceExecutor() *PodResourceExecutor

func (*PodResourceExecutor) DeleteCheckpointIfNeed

func (p *PodResourceExecutor) DeleteCheckpointIfNeed(req interface{}) error

func (*PodResourceExecutor) GenerateHookRequest

func (p *PodResourceExecutor) GenerateHookRequest() interface{}

func (*PodResourceExecutor) GetMetaInfo

func (p *PodResourceExecutor) GetMetaInfo() string

func (*PodResourceExecutor) ParsePod

func (p *PodResourceExecutor) ParsePod(podsandbox *runtimeapi.PodSandbox) error

func (*PodResourceExecutor) ParseRequest

func (p *PodResourceExecutor) ParseRequest(req interface{}) (utils.CallHookPluginOperation, error)

ParseRequest would

func (*PodResourceExecutor) ResourceCheckPoint

func (p *PodResourceExecutor) ResourceCheckPoint(response interface{}) error

func (*PodResourceExecutor) String

func (p *PodResourceExecutor) String() string

func (*PodResourceExecutor) UpdateRequest

func (p *PodResourceExecutor) UpdateRequest(rsp interface{}, req interface{}) error

UpdateRequest will update PodResourceExecutor from hook response and then update CRI request.