runner

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2026 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckTools

func CheckTools(names ...string) error

func IsCanceled

func IsCanceled(err error) bool

Types

type AWSCredentialProvider

type AWSCredentialProvider interface {
	Environment(context.Context, string) ([]string, error)
}

type Command

type Command struct {
	Name string
	Args []string
	Dir  string
	Env  []string
	// Stdin carries sensitive manifests without putting their contents in the
	// process argument list or deployment log.
	Stdin io.Reader
}

type DataServiceCredentialProvider

type DataServiceCredentialProvider interface {
	Materials(context.Context, string, string) (map[string]dataservicecredentials.Material, error)
}

type Deployment

type Deployment struct {
	// contains filtered or unexported fields
}

func NewDeployment

func NewDeployment(config *appconfig.Config, environments *environment.Repository) *Deployment

func (*Deployment) Run

func (d *Deployment) Run(ctx context.Context, environmentName string, action jobs.Action, jobID string, output io.Writer) error

func (*Deployment) RunJob

func (d *Deployment) RunJob(ctx context.Context, job jobs.Job, output io.Writer) error

RunJob receives operation parameters from the task manager. Ordinary deployment jobs continue through Run unchanged; scoped storage jobs read only the allowlisted parameters placed in this private context value.

func (*Deployment) SetAWSCredentialProvider

func (d *Deployment) SetAWSCredentialProvider(provider AWSCredentialProvider)

func (*Deployment) SetDataServiceCredentialProvider

func (d *Deployment) SetDataServiceCredentialProvider(provider DataServiceCredentialProvider)

func (*Deployment) SetStateBackendProvider

func (d *Deployment) SetStateBackendProvider(provider StateBackendProvider)

func (*Deployment) SetTLSCertificateProvider

func (d *Deployment) SetTLSCertificateProvider(provider TLSCertificateProvider)

type Executor

type Executor struct{}

func (Executor) Run

func (Executor) Run(ctx context.Context, command Command, output io.Writer) error

type RedactingWriter

type RedactingWriter struct {
	// contains filtered or unexported fields
}

func NewRedactingWriter

func NewRedactingWriter(w io.Writer) *RedactingWriter

func (*RedactingWriter) Flush

func (w *RedactingWriter) Flush() error

func (*RedactingWriter) Write

func (w *RedactingWriter) Write(p []byte) (int, error)

type StateBackendProvider

type StateBackendProvider interface {
	Runtime(context.Context) (statebackend.Runtime, error)
}

type TLSCertificateProvider

type TLSCertificateProvider interface {
	Material(context.Context, string, string, string) (tlscertificates.Material, error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL