resource_executor

Documentation

Index

• type NoopResourceExecutor
  • func (n *NoopResourceExecutor) DeleteCheckpointIfNeed(request interface{}) error
  • func (n *NoopResourceExecutor) GenerateHookRequest() interface{}
  • func (n *NoopResourceExecutor) GenerateResourceCheckpoint() interface{}
  • func (n *NoopResourceExecutor) GetMetaInfo() string
  • func (n *NoopResourceExecutor) ParseRequest(request interface{}) error
  • func (n *NoopResourceExecutor) ResourceCheckPoint(response interface{}) error
  • func (n *NoopResourceExecutor) UpdateRequest(response interface{}, request interface{}) error
• type RuntimeResourceExecutor
  • func NewRuntimeResourceExecutor(runtimeResourceType RuntimeResourceType) RuntimeResourceExecutor
• type RuntimeResourceType

Types

type NoopResourceExecutor

type NoopResourceExecutor struct {
}

NoopResourceExecutor means no-operation for cri request, where no hook exists like ListContainerStats/ExecSync etc.

func (*NoopResourceExecutor) DeleteCheckpointIfNeed

func (n *NoopResourceExecutor) DeleteCheckpointIfNeed(request interface{}) error

func (*NoopResourceExecutor) GenerateHookRequest

func (n *NoopResourceExecutor) GenerateHookRequest() interface{}

func (*NoopResourceExecutor) GenerateResourceCheckpoint

func (n *NoopResourceExecutor) GenerateResourceCheckpoint() interface{}

func (*NoopResourceExecutor) GetMetaInfo

func (n *NoopResourceExecutor) GetMetaInfo() string

func (*NoopResourceExecutor) ParseRequest

func (n *NoopResourceExecutor) ParseRequest(request interface{}) error

func (*NoopResourceExecutor) ResourceCheckPoint

func (n *NoopResourceExecutor) ResourceCheckPoint(response interface{}) error

func (*NoopResourceExecutor) UpdateRequest

func (n *NoopResourceExecutor) UpdateRequest(response interface{}, request interface{}) error

type RuntimeResourceExecutor

type RuntimeResourceExecutor interface {
	GetMetaInfo() string
	GenerateHookRequest() interface{}
	ParseRequest(request interface{}) error
	ResourceCheckPoint(response interface{}) error
	DeleteCheckpointIfNeed(request interface{}) error
	UpdateRequest(response interface{}, request interface{}) error
}

func NewRuntimeResourceExecutor

func NewRuntimeResourceExecutor(runtimeResourceType RuntimeResourceType) RuntimeResourceExecutor

type RuntimeResourceType

type RuntimeResourceType string

const (
	RuntimePodResource       RuntimeResourceType = "RuntimePodResource"
	RuntimeContainerResource RuntimeResourceType = "RuntimeContainerResource"
	RuntimeNoopResource      RuntimeResourceType = "RuntimeNoopResource"
)