agent

Mar 30, 2023

Changes in this version

+ type Downloader interface

Jan 27, 2023

Changes in this version

type Environment

+ func (e *Environment) WorkingDir() string

Jan 19, 2023

Changes in this version

+ var DefaultEnvs = []string

type Config

+ PluginCache bool

Jan 13, 2023

Changes in this version

type Config

+ Debug bool

Oct 30, 2022

Changes in this version

+ const HashicorpReleasesHost

+ type Cancelation struct

+ Forceful bool

+ Run *otf.Run

+ type Config struct

+ Concurrency int

+ External bool

+ Organization *string

+ Sandbox bool

+ func NewConfigFromFlags(flags *pflag.FlagSet) *Config

+ type Doer interface

+ Do func(otf.Environment) error

+ type Download struct

+ func (d *Download) Download() error

type Environment

+ func (e *Environment) Close() error

+ func (e *Environment) Path() string

+ func (e *Environment) RunTerraform(cmd string, args ...string) error

+ func (e *Environment) TerraformPath() string

+ func (e *Environment) Write(p []byte) (int, error)

+ type Terraform interface

+ TerraformPath func(version string) string

+ type TerraformDownloader struct

+ func NewTerraformDownloader() *TerraformDownloader

+ func (d *TerraformDownloader) Download(ctx context.Context, version string, w io.Writer) (string, error)

+ type TerraformPathFinder struct

+ func (*TerraformPathFinder) TerraformPath(version string) string

Nov 7, 2021

Changes in this version

+ var PluginCacheDir = filepath.Join(os.TempDir(), "plugin-cache")

Oct 31, 2021

Changes in this version

+ type Environment struct

+ ConfigurationVersionService otf.ConfigurationVersionService

+ RunService otf.RunService

+ StateVersionService otf.StateVersionService

+ func NewEnvironment(logger logr.Logger, rs otf.RunService, cvs otf.ConfigurationVersionService, ...) (*Environment, error)

+ func (e *Environment) Cancel(force bool)

+ func (e *Environment) Execute(run *otf.Run, job otf.Job) (err error)

+ func (e *Environment) GetConfigurationVersionService() otf.ConfigurationVersionService

+ func (e *Environment) GetPath() string

+ func (e *Environment) GetRunService() otf.RunService

+ func (e *Environment) GetStateVersionService() otf.StateVersionService

+ func (e *Environment) RunCLI(name string, args ...string) error

+ func (e *Environment) RunFunc(fn otf.EnvironmentFunc) error

type Spooler

+ GetRun func() <-chan *otf.Run

type SpoolerDaemon

+ func (s *SpoolerDaemon) GetRun() <-chan *otf.Run

+ type Subscriber interface

+ Subscribe func(id string) (otf.Subscription, error)

type Supervisor

+ AgentID string

Sep 19, 2021

Changes in this version

+ const DefaultConcurrency

+ const DefaultDataDir

+ const DefaultID

+ const SpoolerCapacity

+ var QueuedStatuses = []tfe.RunStatus

+ type Agent struct

+ ConfigurationVersionService otf.ConfigurationVersionService

+ DataDir string

+ ID string

+ ServerAddr string

+ StateVersionService otf.StateVersionService

+ func NewAgent(logger logr.Logger, cvs otf.ConfigurationVersionService, ...) (*Agent, error)

+ func (a *Agent) Start(ctx context.Context)

+ type Cancelable interface

+ Cancel func(force bool)

+ type Executor struct

+ ConfigurationVersionService otf.ConfigurationVersionService

+ RunService otf.RunService

+ StateVersionService otf.StateVersionService

+ func (e *Executor) Do(run *otf.Run) error

+ type ExecutorEnvironment struct

+ type MockJobGetter struct

+ func NewMockJobGetter(job ...otf.Job) *MockJobGetter

+ func (s *MockJobGetter) GetJob() <-chan otf.Job

+ type MockSpooler struct

+ func NewMockSpooler(opt ...MockSpoolerOption) *MockSpooler

+ func (s *MockSpooler) GetCancelation() <-chan otf.Job

+ func (s *MockSpooler) GetJob() <-chan otf.Job

+ type MockSpoolerOption func(*MockSpooler)

+ func WithCanceledJobs(job ...otf.Job) MockSpoolerOption

+ func WithMockJobs(job ...otf.Job) MockSpoolerOption

+ type RunLister interface

+ List func(otf.RunListOptions) (*otf.RunList, error)

+ type Spooler interface

+ GetCancelation func() <-chan otf.Job

+ GetJob func() <-chan otf.Job

+ Start func(context.Context)

+ type SpoolerDaemon struct

+ func NewSpooler(rl RunLister, es otf.EventService, logger logr.Logger) (*SpoolerDaemon, error)

+ func (s *SpoolerDaemon) GetCancelation() <-chan otf.Job

+ func (s *SpoolerDaemon) GetJob() <-chan otf.Job

+ func (s *SpoolerDaemon) Start(ctx context.Context)

+ type Supervisor struct

+ ConfigurationVersionService otf.ConfigurationVersionService

+ RunService otf.RunService

+ StateVersionService otf.StateVersionService

+ func NewSupervisor(spooler Spooler, cvs otf.ConfigurationVersionService, ...) *Supervisor

+ func (s *Supervisor) Start(ctx context.Context)

+ type Terminator struct

+ func NewTerminator() *Terminator

+ func (t *Terminator) Cancel(id string, force bool)

+ func (t *Terminator) CheckIn(id string, job Cancelable)

+ func (t *Terminator) CheckOut(id string)

+ type Worker struct

+ func (w *Worker) Start(ctx context.Context)