cri

Documentation

Index

• type CRIProcessor
  • func DetectCriProcessor(logger logrus.FieldLogger, runtimeType string, ...) (*CRIProcessor, error)
  • func NewProcessor(options *model.ContainerCommandOptions, connection *containerConnection) *CRIProcessor
  • func (p *CRIProcessor) Cancel() error
  • func (p *CRIProcessor) Cleanup() error
  • func (p *CRIProcessor) ExtraLubanParams() string
  • func (p *CRIProcessor) PreCheck() (string, *taskerrors.TaskError)
  • func (p *CRIProcessor) Prepare(commandContent string) *taskerrors.TaskError
  • func (p *CRIProcessor) SideEffect() error
  • func (p *CRIProcessor) SyncRun(stdoutWriter io.Writer, stderrWriter io.Writer, stdinReader io.Reader) (exitCode int, status int, err error)

Types

type CRIProcessor

type CRIProcessor struct {
	SubmissionID string
	// Fundamental properties of command process
	ContainerIdentifier string
	ContainerName       string
	CommandType         string
	CommandContent      string
	Timeout             int
	// contains filtered or unexported fields
}

func DetectCriProcessor

func DetectCriProcessor(logger logrus.FieldLogger, runtimeType string, options *model.ContainerCommandOptions) (*CRIProcessor, error)

func NewProcessor

func NewProcessor(options *model.ContainerCommandOptions, connection *containerConnection) *CRIProcessor

func (*CRIProcessor) Cancel

func (p *CRIProcessor) Cancel() error

func (*CRIProcessor) Cleanup

func (p *CRIProcessor) Cleanup() error

func (*CRIProcessor) ExtraLubanParams

func (p *CRIProcessor) ExtraLubanParams() string

func (*CRIProcessor) PreCheck

func (p *CRIProcessor) PreCheck() (string, *taskerrors.TaskError)

func (*CRIProcessor) Prepare

func (p *CRIProcessor) Prepare(commandContent string) *taskerrors.TaskError

func (*CRIProcessor) SideEffect

func (p *CRIProcessor) SideEffect() error

func (*CRIProcessor) SyncRun

func (p *CRIProcessor) SyncRun(
	stdoutWriter io.Writer,
	stderrWriter io.Writer,
	stdinReader io.Reader) (exitCode int, status int, err error)