runtime

Documentation

Index

• Constants
• type Artifact
• type CacheArtifact
  • func (art CacheArtifact) ID() string
• type ErrResourceScriptFailed
  • func (err ErrResourceScriptFailed) Error() string
• type FileNotFoundError
  • func (err FileNotFoundError) Error() string
• type GetArtifact
  • func (art GetArtifact) ID() string
• type GetRequest
• type ProcessSpec
• type PutRequest
• type Runner
• type StartingEventDelegate
• type TaskArtifact
  • func (art TaskArtifact) ID() string
• type VersionResult

Constants

const (
	ResourceResultPropertyName = "concourse:resource-result"
	ResourceProcessID          = "resource"
)

Types

type Artifact

type Artifact interface {
	ID() string
}

type CacheArtifact

type CacheArtifact struct {
	TeamID   int
	JobID    int
	StepName string
	Path     string
}

func (CacheArtifact) ID

func (art CacheArtifact) ID() string

type ErrResourceScriptFailed

type ErrResourceScriptFailed struct {
	Path       string
	Args       []string
	ExitStatus int

	Stderr string
}

func (ErrResourceScriptFailed) Error

func (err ErrResourceScriptFailed) Error() string

type FileNotFoundError

type FileNotFoundError struct {
	Path string
}

FileNotFoundError is the error to return from StreamFile when the given path does not exist.

func (FileNotFoundError) Error

func (err FileNotFoundError) Error() string

Error prints a helpful message including the file path. The user will see this message if e.g. their task config path does not exist.

type GetArtifact

type GetArtifact struct {
	VolumeHandle string
}

TODO (Krishna/Sameer): get rid of these - can GetArtifact and TaskArtifact be merged ?

func (GetArtifact) ID

func (art GetArtifact) ID() string

type GetRequest

type GetRequest struct {
	Source atc.Source `json:"source"`
	Params atc.Params `json:"params,omitempty"`
}

type ProcessSpec

type ProcessSpec struct {
	Path         string
	Args         []string
	Dir          string
	User         string
	StdoutWriter io.Writer
	StderrWriter io.Writer
}

type PutRequest

type PutRequest struct {
	Source atc.Source `json:"source"`
	Params atc.Params `json:"params,omitempty"`
}

type Runner

type Runner interface {
	RunScript(
		ctx context.Context,
		path string,
		args []string,
		input []byte,
		output interface{},
		logDest io.Writer,
		recoverable bool,
	) error
}

TODO (runtime/#4910): consider a different name as this is close to "Runnable" in atc/engine/engine

type StartingEventDelegate

type StartingEventDelegate interface {
	Starting(lager.Logger)
	SelectedWorker(lager.Logger, string)
}

type TaskArtifact

type TaskArtifact struct {
	VolumeHandle string
}

func (TaskArtifact) ID

func (art TaskArtifact) ID() string

type VersionResult

type VersionResult struct {
	Version  atc.Version         `json:"version"`
	Metadata []atc.MetadataField `json:"metadata,omitempty"`
}