runner

package
v0.25.0 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2025 License: GPL-3.0 Imports: 16 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LibBash string
View Source 
var OPSH string
View Source 
var RunScript string

Functions

This section is empty.

Types

type Command 

type Command interface {
	Check() error
	Env() *EnvBuilder
	AddToPayload(*Payload) error
}

type Config added in v0.22.5 

type Config struct {
	PackageConfig  *deb.PackageConfig `pulumi:"packageConfig,optional"`
	AptLockTimeout *int               `pulumi:"aptLockTimeout,optional"`
}

func (*Config) SetDefaults added in v0.25.0 

func (c *Config) SetDefaults()

func (*Config) UpdatePackageGroup added in v0.22.5 

func (c *Config) UpdatePackageGroup(grp *deb.PackageGroup) error

type Deployer added in v0.11.0 

type Deployer struct {
	Payload *Payload
	Client  *ssh.Client
}

func (*Deployer) Deploy added in v0.11.0 

func (p *Deployer) Deploy() error

func (*Deployer) Run added in v0.11.0 

func (p *Deployer) Run(cmdSegs []string, dontCleanup bool, handler DeployerHandler) error

type DeployerHandler added in v0.11.0 

type DeployerHandler interface {
	// IngestReaders is responsible for keeping the readers drained.
	// After the readers have been closed, it MUST signal completion by
	// closing the provided done channel.
	IngestReaders(done chan<- struct{}, stdout io.Reader, stderr io.Reader) error
	AugmentError(error) error
}

type EnvBuilder added in v0.13.0 

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

func NewEnvBuilder added in v0.13.0 

func NewEnvBuilder() *EnvBuilder

func (*EnvBuilder) Args added in v0.13.0 

func (e *EnvBuilder) Args() []string

func (*EnvBuilder) Buffer added in v0.13.0 

func (e *EnvBuilder) Buffer() *bytes.Buffer

func (*EnvBuilder) Map added in v0.13.0 

func (e *EnvBuilder) Map() map[string]string

func (*EnvBuilder) Merge added in v0.13.0 

func (e *EnvBuilder) Merge(other *EnvBuilder)

func (*EnvBuilder) Set added in v0.13.0 

func (e *EnvBuilder) Set(k, v string)

func (*EnvBuilder) SetArray added in v0.13.0 

func (e *EnvBuilder) SetArray(k string, s []string)

func (*EnvBuilder) SetArrayP added in v0.13.0 

func (e *EnvBuilder) SetArrayP(k string, s *[]string)

func (*EnvBuilder) SetBool added in v0.13.0 

func (e *EnvBuilder) SetBool(k string, v bool)

func (*EnvBuilder) SetBoolP added in v0.13.0 

func (e *EnvBuilder) SetBoolP(k string, v *bool)

func (*EnvBuilder) SetFloat64 added in v0.13.0 

func (e *EnvBuilder) SetFloat64(k string, v float64)

func (*EnvBuilder) SetFloat64P added in v0.13.0 

func (e *EnvBuilder) SetFloat64P(k string, v *float64)

func (*EnvBuilder) SetInt added in v0.13.0 

func (e *EnvBuilder) SetInt(k string, v int)

func (*EnvBuilder) SetInt64P added in v0.13.0 

func (e *EnvBuilder) SetInt64P(k string, v *int64)

func (*EnvBuilder) SetIntP added in v0.13.0 

func (e *EnvBuilder) SetIntP(k string, v *int)

func (*EnvBuilder) SetMap added in v0.13.0 

func (e *EnvBuilder) SetMap(m map[string]string)

func (*EnvBuilder) SetP added in v0.13.0 

func (e *EnvBuilder) SetP(k string, v *string)

func (*EnvBuilder) SetRaw added in v0.13.0 

func (e *EnvBuilder) SetRaw(k, v string)

func (*EnvBuilder) String added in v0.13.0 

func (e *EnvBuilder) String() string

type FlagBuilder added in v0.13.0 

type FlagBuilder []string

func (*FlagBuilder) Append added in v0.13.0 

func (f *FlagBuilder) Append(k string, v string)

func (*FlagBuilder) AppendArray added in v0.19.0 

func (f *FlagBuilder) AppendArray(k string, array []string)

func (*FlagBuilder) AppendArrayP added in v0.19.0 

func (f *FlagBuilder) AppendArrayP(k string, array *[]string)

func (*FlagBuilder) AppendBoolP added in v0.13.0 

func (f *FlagBuilder) AppendBoolP(k string, v *bool)

func (*FlagBuilder) AppendFloat64 added in v0.13.0 

func (f *FlagBuilder) AppendFloat64(k string, v float64)

func (*FlagBuilder) AppendFloat64P added in v0.13.0 

func (f *FlagBuilder) AppendFloat64P(k string, v *float64)

func (*FlagBuilder) AppendInt64P added in v0.13.0 

func (f *FlagBuilder) AppendInt64P(k string, v *int64)

func (*FlagBuilder) AppendIntP added in v0.13.0 

func (f *FlagBuilder) AppendIntP(k string, v *int)

func (*FlagBuilder) AppendP added in v0.13.0 

func (f *FlagBuilder) AppendP(k string, v *string)

func (*FlagBuilder) AppendRaw added in v0.19.0 

func (f *FlagBuilder) AppendRaw(s ...string)

func (*FlagBuilder) Args added in v0.20.0 

func (f *FlagBuilder) Args() []string

func (*FlagBuilder) String added in v0.13.0 

func (f *FlagBuilder) String() string

XXX - We need to work backwards from this, and make sure we're quoting spaces.

type Payload added in v0.11.0 

type Payload = payload.Payload

type PayloadFile added in v0.11.0 

type PayloadFile = payload.PayloadFile

type Runner 

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

func NewRunner added in v0.8.0 

func NewRunner(client *ssh.Client, cmd Command) *Runner

func (*Runner) Run 

func (r *Runner) Run(ctx context.Context, handler DeployerHandler) error

type RunnerCommand added in v0.24.0 

type RunnerCommand struct {
	RunnerConfig *Config `pulumi:"runnerConfig,optional"`
	// contains filtered or unexported fields
}

func (*RunnerCommand) AddToPayload added in v0.24.0 

func (r *RunnerCommand) AddToPayload(p *Payload) error

func (*RunnerCommand) Env added in v0.24.0 

func (r *RunnerCommand) Env() *EnvBuilder

func (*RunnerCommand) SetConfigDefaults added in v0.25.0 

func (r *RunnerCommand) SetConfigDefaults()

func (*RunnerCommand) UpdatePackageGroup added in v0.24.0 

func (r *RunnerCommand) UpdatePackageGroup(grp *deb.PackageGroup) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.