provisiontest

package
v0.0.0-...-47649f3 Latest Latest
Warning

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

 Go to latest Published: May 2, 2024 License: BSD-3-Clause Imports: 27 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFakeJob 

func NewFakeJob(name, pool, teamOwner string) *jobTypes.Job

Types

type AutoScaleProvisioner 

type AutoScaleProvisioner struct {
	*FakeProvisioner
	// contains filtered or unexported fields
}

func (*AutoScaleProvisioner) GetAutoScale 

func (p *AutoScaleProvisioner) GetAutoScale(ctx context.Context, app provision.App) ([]provision.AutoScaleSpec, error)

func (*AutoScaleProvisioner) GetVerticalAutoScaleRecommendations 

func (p *AutoScaleProvisioner) GetVerticalAutoScaleRecommendations(ctx context.Context, app provision.App) ([]provision.RecommendedResources, error)

func (*AutoScaleProvisioner) RemoveAutoScale 

func (p *AutoScaleProvisioner) RemoveAutoScale(ctx context.Context, app provision.App, process string) error

func (*AutoScaleProvisioner) SetAutoScale 

func (p *AutoScaleProvisioner) SetAutoScale(ctx context.Context, app provision.App, spec provision.AutoScaleSpec) error

type Cmd 

type Cmd struct {
	Cmd  string
	Args []string
	App  provision.App
}

type FakeApp 

type FakeApp struct {
	IP string

	Commands []string
	Memory   int64
	MilliCPU int

	Deploys uint

	Pool              string
	UpdatePlatform    bool
	TeamOwner         string
	Teams             []string
	Tags              []string
	Metadata          appTypes.Metadata
	InternalAddresses []provision.AppInternalAddress
	// contains filtered or unexported fields
}

Fake implementation for provision.App.

func NewFakeApp 

func NewFakeApp(name, platform string, units int) *FakeApp

func NewFakeAppWithPool 

func NewFakeAppWithPool(name, platform, pool string, units int) *FakeApp

func (*FakeApp) AddInstance 

func (a *FakeApp) AddInstance(instanceArgs bind.AddInstanceArgs) error

func (*FakeApp) AddUnit 

func (a *FakeApp) AddUnit(u provision.Unit)

func (*FakeApp) Envs 

func (a *FakeApp) Envs() map[string]bindTypes.EnvVar

func (*FakeApp) GetAddresses 

func (app *FakeApp) GetAddresses() ([]string, error)

func (*FakeApp) GetCPUBurst 

func (a *FakeApp) GetCPUBurst() float64

func (*FakeApp) GetCname 

func (a *FakeApp) GetCname() []string

func (*FakeApp) GetCommands 

func (a *FakeApp) GetCommands() []string

func (*FakeApp) GetDeploys 

func (a *FakeApp) GetDeploys() uint

func (*FakeApp) GetInternalBindableAddresses 

func (app *FakeApp) GetInternalBindableAddresses() ([]string, error)

func (*FakeApp) GetMemory 

func (a *FakeApp) GetMemory() int64

func (*FakeApp) GetMetadata 

func (app *FakeApp) GetMetadata(process string) appTypes.Metadata

func (*FakeApp) GetMilliCPU 

func (a *FakeApp) GetMilliCPU() int

func (*FakeApp) GetName 

func (a *FakeApp) GetName() string

func (*FakeApp) GetPlan 

func (a *FakeApp) GetPlan() appTypes.Plan

func (*FakeApp) GetPlatform 

func (a *FakeApp) GetPlatform() string

func (*FakeApp) GetPlatformVersion 

func (a *FakeApp) GetPlatformVersion() string

func (*FakeApp) GetPool 

func (a *FakeApp) GetPool() string

func (*FakeApp) GetProcess 

func (app *FakeApp) GetProcess(process string) *appTypes.Process

func (*FakeApp) GetRegistry 

func (app *FakeApp) GetRegistry() (imgTypes.ImageRegistry, error)

func (*FakeApp) GetRouters 

func (app *FakeApp) GetRouters() []appTypes.AppRouter

func (*FakeApp) GetServiceEnvs 

func (a *FakeApp) GetServiceEnvs() []bindTypes.ServiceEnvVar

func (*FakeApp) GetTeamOwner 

func (a *FakeApp) GetTeamOwner() string

func (*FakeApp) GetTeamsName 

func (a *FakeApp) GetTeamsName() []string

func (*FakeApp) GetUUID 

func (a *FakeApp) GetUUID() (string, error)

func (*FakeApp) GetUpdatePlatform 

func (a *FakeApp) GetUpdatePlatform() bool

func (*FakeApp) HasLog 

func (a *FakeApp) HasLog(source, unit, message string) bool

func (*FakeApp) ListTags 

func (app *FakeApp) ListTags() []string

func (*FakeApp) Log 

func (a *FakeApp) Log(message, source, unit string) error

func (*FakeApp) Logs 

func (a *FakeApp) Logs() []string

func (*FakeApp) RemoveInstance 

func (a *FakeApp) RemoveInstance(instanceArgs bind.RemoveInstanceArgs) error

func (*FakeApp) Run 

func (a *FakeApp) Run(cmd string, w io.Writer, args provision.RunArgs) error

func (*FakeApp) SetEnv 

func (a *FakeApp) SetEnv(env bindTypes.EnvVar)

func (*FakeApp) SetEnvs 

func (a *FakeApp) SetEnvs(setEnvs bind.SetEnvArgs) error

func (*FakeApp) Units 

func (a *FakeApp) Units() ([]provision.Unit, error)

func (*FakeApp) UnsetEnvs 

func (a *FakeApp) UnsetEnvs(unsetEnvs bind.UnsetEnvArgs) error

type FakeConn 

type FakeConn struct {
	Buf *safe.Buffer
}

func (*FakeConn) Close 

func (c *FakeConn) Close() error

func (*FakeConn) LocalAddr 

func (c *FakeConn) LocalAddr() net.Addr

func (*FakeConn) Read 

func (c *FakeConn) Read(b []byte) (int, error)

func (*FakeConn) RemoteAddr 

func (c *FakeConn) RemoteAddr() net.Addr

func (*FakeConn) SetDeadline 

func (c *FakeConn) SetDeadline(t time.Time) error

func (*FakeConn) SetReadDeadline 

func (c *FakeConn) SetReadDeadline(t time.Time) error

func (*FakeConn) SetWriteDeadline 

func (c *FakeConn) SetWriteDeadline(t time.Time) error

func (*FakeConn) Write 

func (c *FakeConn) Write(b []byte) (int, error)

type FakeProvisioner 

type FakeProvisioner struct {
	Name        string
	LogsEnabled bool
	// contains filtered or unexported fields
}

Fake implementation for provision.Provisioner. 

var (
	ProvisionerInstance *FakeProvisioner
)

func NewFakeProvisioner 

func NewFakeProvisioner() *FakeProvisioner

func (*FakeProvisioner) AddUnit 

func (p *FakeProvisioner) AddUnit(app provision.App, unit provision.Unit)

func (*FakeProvisioner) AddUnits 

func (p *FakeProvisioner) AddUnits(ctx context.Context, app provision.App, n uint, process string, version appTypes.AppVersion, w io.Writer) error

func (*FakeProvisioner) AddUnitsToNode 

func (p *FakeProvisioner) AddUnitsToNode(app provision.App, n uint, process string, w io.Writer, nodeAddr string, version appTypes.AppVersion) ([]provision.Unit, error)

func (*FakeProvisioner) Addr 

func (p *FakeProvisioner) Addr(app provision.App) (string, error)

func (*FakeProvisioner) AllExecs 

func (p *FakeProvisioner) AllExecs() map[string][]provision.ExecOptions

AllExecs return all exec calls to all units.

func (*FakeProvisioner) CustomData 

func (p *FakeProvisioner) CustomData(app provision.App) map[string]interface{}

func (*FakeProvisioner) DeleteVolume 

func (p *FakeProvisioner) DeleteVolume(ctx context.Context, volName, pool string) error

func (*FakeProvisioner) Deploy 

func (p *FakeProvisioner) Deploy(ctx context.Context, args provision.DeployArgs) (string, error)

func (*FakeProvisioner) Destroy 

func (p *FakeProvisioner) Destroy(ctx context.Context, app provision.App) error

func (*FakeProvisioner) DestroyVersion 

func (p *FakeProvisioner) DestroyVersion(ctx context.Context, app provision.App, version appTypes.AppVersion) error

func (*FakeProvisioner) Execs 

func (p *FakeProvisioner) Execs(unit string) []provision.ExecOptions

Execs return all exec calls to the given unit.

func (*FakeProvisioner) ExecuteCommand 

func (p *FakeProvisioner) ExecuteCommand(ctx context.Context, opts provision.ExecOptions) error

func (*FakeProvisioner) FilterAppsByUnitStatus 

func (p *FakeProvisioner) FilterAppsByUnitStatus(ctx context.Context, apps []provision.App, status []string) ([]provision.App, error)

func (*FakeProvisioner) GetAppFromUnitID 

func (p *FakeProvisioner) GetAppFromUnitID(unitID string) (provision.App, error)

GetAppFromUnitID returns an app from unitID

func (*FakeProvisioner) GetName 

func (p *FakeProvisioner) GetName() string

func (*FakeProvisioner) GetUnits 

func (p *FakeProvisioner) GetUnits(app provision.App) []provision.Unit

func (*FakeProvisioner) InternalAddresses 

func (p *FakeProvisioner) InternalAddresses(ctx context.Context, a provision.App) ([]provision.AppInternalAddress, error)

func (*FakeProvisioner) IsVolumeProvisioned 

func (p *FakeProvisioner) IsVolumeProvisioned(ctx context.Context, name, pool string) (bool, error)

func (*FakeProvisioner) JobExecutions 

func (p *FakeProvisioner) JobExecutions(jobName string) int

JobExecutions returns the number of times a job has run

func (*FakeProvisioner) ListLogs 

func (p *FakeProvisioner) ListLogs(ctx context.Context, obj logTypes.LogabbleObject, args appTypes.ListLogArgs) ([]appTypes.Applog, error)

func (*FakeProvisioner) MockRoutableAddresses 

func (p *FakeProvisioner) MockRoutableAddresses(app provision.App, addrs []appTypes.RoutableAddresses)

func (*FakeProvisioner) PrepareFailure 

func (p *FakeProvisioner) PrepareFailure(method string, err error)

PrepareFailure prepares a failure for the given method name.

For instance, PrepareFailure("GitDeploy", errors.New("GitDeploy failed")) will cause next Deploy call to return the given error. Multiple calls to this method will enqueue failures, i.e. three calls to PrepareFailure("GitDeploy"...) means that the three next GitDeploy call will fail.

func (*FakeProvisioner) PrepareOutput 

func (p *FakeProvisioner) PrepareOutput(b []byte)

PrepareOutput sends the given slice of bytes to a queue of outputs.

Each prepared output will be used in the ExecuteCommand. It might be sent to the standard output or standard error. See ExecuteCommand docs for more details.

func (*FakeProvisioner) Provision 

func (p *FakeProvisioner) Provision(ctx context.Context, app provision.App) error

func (*FakeProvisioner) Provisioned 

func (p *FakeProvisioner) Provisioned(app provision.App) bool

Provisioned checks whether the given app has been provisioned.

func (*FakeProvisioner) ProvisionedJob 

func (p *FakeProvisioner) ProvisionedJob(jobName string) bool

ProvisionedJob checks whether the given job has been provisioned.

func (*FakeProvisioner) RemoveUnits 

func (p *FakeProvisioner) RemoveUnits(ctx context.Context, app provision.App, n uint, process string, version appTypes.AppVersion, w io.Writer) error

func (*FakeProvisioner) Reset 

func (p *FakeProvisioner) Reset()

Reset cleans up the FakeProvisioner, deleting all apps and their data. It also deletes prepared failures and output. It's like calling NewFakeProvisioner again, without all the allocations.

func (*FakeProvisioner) Restart 

func (p *FakeProvisioner) Restart(ctx context.Context, app provision.App, process string, version appTypes.AppVersion, w io.Writer) error

func (*FakeProvisioner) Restarts 

func (p *FakeProvisioner) Restarts(a provision.App, process string) int

Restarts returns the number of restarts for a given app.

func (*FakeProvisioner) RoutableAddresses 

func (p *FakeProvisioner) RoutableAddresses(ctx context.Context, app provision.App) ([]appTypes.RoutableAddresses, error)

func (*FakeProvisioner) Start 

func (p *FakeProvisioner) Start(ctx context.Context, app provision.App, process string, version appTypes.AppVersion, w io.Writer) error

func (*FakeProvisioner) Starts 

func (p *FakeProvisioner) Starts(app provision.App, process string) int

Starts returns the number of starts for a given app.

func (*FakeProvisioner) Stop 

func (p *FakeProvisioner) Stop(ctx context.Context, app provision.App, process string, version appTypes.AppVersion, w io.Writer) error

func (*FakeProvisioner) Stops 

func (p *FakeProvisioner) Stops(app provision.App, process string) int

Stops returns the number of stops for a given app.

func (*FakeProvisioner) Units 

func (p *FakeProvisioner) Units(ctx context.Context, apps ...provision.App) ([]provision.Unit, error)

func (*FakeProvisioner) UnitsMetrics 

func (p *FakeProvisioner) UnitsMetrics(ctx context.Context, a provision.App) ([]provision.UnitMetric, error)

func (*FakeProvisioner) UpdateApp 

func (p *FakeProvisioner) UpdateApp(ctx context.Context, old, new provision.App, w io.Writer) error

func (*FakeProvisioner) ValidateVolume 

func (p *FakeProvisioner) ValidateVolume(ctx context.Context, vol *volumeTypes.Volume) error

func (*FakeProvisioner) WatchLogs 

func (p *FakeProvisioner) WatchLogs(ctx context.Context, obj logTypes.LogabbleObject, args appTypes.ListLogArgs) (appTypes.LogWatcher, error)

type Hijacker 

type Hijacker struct {
	http.ResponseWriter
	Conn net.Conn
	Err  error
}

func (*Hijacker) Hijack 

func (h *Hijacker) Hijack() (net.Conn, *bufio.ReadWriter, error)

type JobProvisioner 

type JobProvisioner struct {
	*FakeProvisioner
}

func (*JobProvisioner) DestroyJob 

func (p *JobProvisioner) DestroyJob(ctx context.Context, job *jobTypes.Job) error

func (*JobProvisioner) EnsureJob 

func (p *JobProvisioner) EnsureJob(ctx context.Context, job *jobTypes.Job) error

JobSchedule creates a cronjob object in the cluster

func (*JobProvisioner) JobUnits 

func (p *JobProvisioner) JobUnits(ctx context.Context, job *jobTypes.Job) ([]provision.Unit, error)

JobUnits returns information about units related to a specific Job or CronJob

func (*JobProvisioner) KillJobUnit 

func (*JobProvisioner) KillJobUnit(ctx context.Context, job *jobTypes.Job, unit string, force bool) error

func (*JobProvisioner) NewJobWithUnits 

func (p *JobProvisioner) NewJobWithUnits(ctx context.Context, job *jobTypes.Job) (string, error)

func (*JobProvisioner) TriggerCron 

func (p *JobProvisioner) TriggerCron(ctx context.Context, name, pool string) error

type PipelineErrorFakeProvisioner 

type PipelineErrorFakeProvisioner struct {
	*FakeProvisioner
}

func (*PipelineErrorFakeProvisioner) DeployPipeline 

func (p *PipelineErrorFakeProvisioner) DeployPipeline() *action.Pipeline

type PipelineFakeProvisioner 

type PipelineFakeProvisioner struct {
	*FakeProvisioner
	// contains filtered or unexported fields
}

func (*PipelineFakeProvisioner) DeployPipeline 

func (p *PipelineFakeProvisioner) DeployPipeline() *action.Pipeline

func (*PipelineFakeProvisioner) ExecutedPipeline 

func (p *PipelineFakeProvisioner) ExecutedPipeline() bool

Source Files

View all Source files

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.