action

package
v2.709.0 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 36 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Action 

type Action interface {
	IsAsynchronous(ProtocolVersion) bool
	IsPersistent() bool
	IsLoggable() bool

	Resume() (interface{}, error)
	Cancel() error
}

type AddPersistentDiskAction 

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

func NewAddPersistentDiskAction 

func NewAddPersistentDiskAction(settingsService boshsettings.Service) AddPersistentDiskAction

func (AddPersistentDiskAction) Cancel 

func (a AddPersistentDiskAction) Cancel() error

func (AddPersistentDiskAction) IsAsynchronous 

func (a AddPersistentDiskAction) IsAsynchronous(_ ProtocolVersion) bool

func (AddPersistentDiskAction) IsLoggable 

func (a AddPersistentDiskAction) IsLoggable() bool

func (AddPersistentDiskAction) IsPersistent 

func (a AddPersistentDiskAction) IsPersistent() bool

func (AddPersistentDiskAction) Resume 

func (a AddPersistentDiskAction) Resume() (interface{}, error)

func (AddPersistentDiskAction) Run 

func (a AddPersistentDiskAction) Run(diskCID string, diskHint interface{}) (interface{}, error)

type ApplyAction 

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

func NewApply 

func NewApply(
	applier boshappl.Applier,
	specService boshas.V1Service,
	settingsService boshsettings.Service,
	dirProvider directories.Provider,
	fs boshsys.FileSystem,
) (action ApplyAction)

func (ApplyAction) Cancel 

func (a ApplyAction) Cancel() error

func (ApplyAction) IsAsynchronous 

func (a ApplyAction) IsAsynchronous(_ ProtocolVersion) bool

func (ApplyAction) IsLoggable 

func (a ApplyAction) IsLoggable() bool

func (ApplyAction) IsPersistent 

func (a ApplyAction) IsPersistent() bool

func (ApplyAction) Resume 

func (a ApplyAction) Resume() (interface{}, error)

func (ApplyAction) Run 

func (a ApplyAction) Run(desiredSpec boshas.V1ApplySpec) (string, error)

type BundleLogsAction 

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

func NewBundleLogs 

func NewBundleLogs(
	logsTarProvider logstarprovider.LogsTarProvider,
	fs boshsys.FileSystem,

) (action BundleLogsAction)

func (BundleLogsAction) Cancel 

func (a BundleLogsAction) Cancel() error

func (BundleLogsAction) IsAsynchronous 

func (a BundleLogsAction) IsAsynchronous(_ ProtocolVersion) bool

func (BundleLogsAction) IsLoggable 

func (a BundleLogsAction) IsLoggable() bool

func (BundleLogsAction) IsPersistent 

func (a BundleLogsAction) IsPersistent() bool

func (BundleLogsAction) Resume 

func (a BundleLogsAction) Resume() (interface{}, error)

func (BundleLogsAction) Run 

func (a BundleLogsAction) Run(request BundleLogsRequest) (BundleLogsResponse, error)

type BundleLogsRequest 

type BundleLogsRequest struct {
	OwningUser string `json:"owning_user"`

	LogType string   `json:"log_type"`
	Filters []string `json:"filters"`
}

type BundleLogsResponse 

type BundleLogsResponse struct {
	LogsTarPath  string `json:"logs_tar_path"`
	SHA512Digest string `json:"sha512"`
}

type CancelTaskAction 

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

func NewCancelTask 

func NewCancelTask(taskService boshtask.Service) (getTask CancelTaskAction)

func (CancelTaskAction) Cancel 

func (a CancelTaskAction) Cancel() error

func (CancelTaskAction) IsAsynchronous 

func (a CancelTaskAction) IsAsynchronous(_ ProtocolVersion) bool

func (CancelTaskAction) IsLoggable 

func (a CancelTaskAction) IsLoggable() bool

func (CancelTaskAction) IsPersistent 

func (a CancelTaskAction) IsPersistent() bool

func (CancelTaskAction) Resume 

func (a CancelTaskAction) Resume() (interface{}, error)

func (CancelTaskAction) Run 

func (a CancelTaskAction) Run(taskID string) (string, error)

type CompilePackageAction 

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

func NewCompilePackage 

func NewCompilePackage(compiler boshcomp.Compiler) (compilePackage CompilePackageAction)

func (CompilePackageAction) Cancel 

func (a CompilePackageAction) Cancel() error

func (CompilePackageAction) IsAsynchronous 

func (a CompilePackageAction) IsAsynchronous(_ ProtocolVersion) bool

func (CompilePackageAction) IsLoggable 

func (a CompilePackageAction) IsLoggable() bool

func (CompilePackageAction) IsPersistent 

func (a CompilePackageAction) IsPersistent() bool

func (CompilePackageAction) Resume 

func (a CompilePackageAction) Resume() (interface{}, error)

func (CompilePackageAction) Run 

func (a CompilePackageAction) Run(blobID string, multiDigest boshcrypto.MultipleDigest, name, version string, deps boshcomp.Dependencies) (map[string]interface{}, error)

type CompilePackageWithSignedURL 

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

func NewCompilePackageWithSignedURL 

func NewCompilePackageWithSignedURL(compiler boshcomp.Compiler) (compilePackage CompilePackageWithSignedURL)

func (CompilePackageWithSignedURL) Cancel 

func (a CompilePackageWithSignedURL) Cancel() error

func (CompilePackageWithSignedURL) IsAsynchronous 

func (a CompilePackageWithSignedURL) IsAsynchronous(_ ProtocolVersion) bool

func (CompilePackageWithSignedURL) IsLoggable 

func (a CompilePackageWithSignedURL) IsLoggable() bool

func (CompilePackageWithSignedURL) IsPersistent 

func (a CompilePackageWithSignedURL) IsPersistent() bool

func (CompilePackageWithSignedURL) Resume 

func (a CompilePackageWithSignedURL) Resume() (interface{}, error)

func (CompilePackageWithSignedURL) Run 

func (a CompilePackageWithSignedURL) Run(request CompilePackageWithSignedURLRequest) (map[string]interface{}, error)

type CompilePackageWithSignedURLRequest 

type CompilePackageWithSignedURLRequest struct {
	PackageGetSignedURL string            `json:"package_get_signed_url"`
	UploadSignedURL     string            `json:"upload_signed_url"`
	BlobstoreHeaders    map[string]string `json:"blobstore_headers"`

	Digest  boshcrypto.MultipleDigest `json:"digest"`
	Name    string                    `json:"name"`
	Version string                    `json:"version"`
	Deps    boshcomp.Dependencies     `json:"deps"`
}

type DeleteARPEntriesAction 

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

func NewDeleteARPEntries 

func NewDeleteARPEntries(platform boshplatform.Platform) DeleteARPEntriesAction

func (DeleteARPEntriesAction) Cancel 

func (a DeleteARPEntriesAction) Cancel() error

func (DeleteARPEntriesAction) IsAsynchronous 

func (a DeleteARPEntriesAction) IsAsynchronous(_ ProtocolVersion) bool

func (DeleteARPEntriesAction) IsLoggable 

func (a DeleteARPEntriesAction) IsLoggable() bool

func (DeleteARPEntriesAction) IsPersistent 

func (a DeleteARPEntriesAction) IsPersistent() bool

func (DeleteARPEntriesAction) Resume 

func (a DeleteARPEntriesAction) Resume() (interface{}, error)

func (DeleteARPEntriesAction) Run 

func (a DeleteARPEntriesAction) Run(args DeleteARPEntriesActionArgs) (interface{}, error)

type DeleteARPEntriesActionArgs 

type DeleteARPEntriesActionArgs struct {
	Ips []string `json:"ips"`
}

type DrainAction 

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

func NewDrain 

func NewDrain(
	notifier boshnotif.Notifier,
	specService boshas.V1Service,
	jobScriptProvider boshscript.JobScriptProvider,
	jobSupervisor boshjobsuper.JobSupervisor,
	logger boshlog.Logger,
) DrainAction

func (DrainAction) Cancel 

func (a DrainAction) Cancel() error

func (DrainAction) IsAsynchronous 

func (a DrainAction) IsAsynchronous(_ ProtocolVersion) bool

func (DrainAction) IsLoggable 

func (a DrainAction) IsLoggable() bool

func (DrainAction) IsPersistent 

func (a DrainAction) IsPersistent() bool

func (DrainAction) Resume 

func (a DrainAction) Resume() (interface{}, error)

func (DrainAction) Run 

func (a DrainAction) Run(drainType DrainType, newSpecs ...boshas.V1ApplySpec) (int, error)

type DrainType 

type DrainType string
const (
	DrainTypeUpdate   DrainType = "update"
	DrainTypeStatus   DrainType = "status"
	DrainTypeShutdown DrainType = "shutdown"
)

type ErrandResult 

type ErrandResult struct {
	Stdout     string `json:"stdout"`
	Stderr     string `json:"stderr"`
	ExitStatus int    `json:"exit_code"`
}

type Factory 

type Factory interface {
	Create(method string) (action Action, err error)
}

func NewFactory 

func NewFactory(
	settingsService boshsettings.Service,
	platform boshplatform.Platform,

	sensitiveBlobManager boshagentblob.BlobManagerInterface,
	taskService boshtask.Service,
	notifier boshnotif.Notifier,
	applier boshappl.Applier,
	compiler boshcomp.Compiler,
	jobSupervisor boshjobsuper.JobSupervisor,
	specService boshas.V1Service,
	jobScriptProvider boshscript.JobScriptProvider,
	logger boshlog.Logger,
	blobstoreDelegator blobdelegator.BlobstoreDelegator) (factory Factory)

type FetchLogsAction 

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

func NewFetchLogs 

func NewFetchLogs(
	logsTarProvider logstarprovider.LogsTarProvider,
	blobstore blobdelegator.BlobstoreDelegator,
) (action FetchLogsAction)

func (FetchLogsAction) Cancel 

func (a FetchLogsAction) Cancel() error

func (FetchLogsAction) IsAsynchronous 

func (a FetchLogsAction) IsAsynchronous(_ ProtocolVersion) bool

func (FetchLogsAction) IsLoggable 

func (a FetchLogsAction) IsLoggable() bool

func (FetchLogsAction) IsPersistent 

func (a FetchLogsAction) IsPersistent() bool

func (FetchLogsAction) Resume 

func (a FetchLogsAction) Resume() (interface{}, error)

func (FetchLogsAction) Run 

func (a FetchLogsAction) Run(logTypes string, filters []string) (value map[string]string, err error)

type FetchLogsWithSignedURLAction 

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

func NewFetchLogsWithSignedURLAction 

func NewFetchLogsWithSignedURLAction(
	logsTarProvider logstarprovider.LogsTarProvider,
	blobDelegator blobdelegator.BlobstoreDelegator) (action FetchLogsWithSignedURLAction)

func (FetchLogsWithSignedURLAction) Cancel 

func (a FetchLogsWithSignedURLAction) Cancel() error

func (FetchLogsWithSignedURLAction) IsAsynchronous 

func (a FetchLogsWithSignedURLAction) IsAsynchronous(_ ProtocolVersion) bool

func (FetchLogsWithSignedURLAction) IsLoggable 

func (a FetchLogsWithSignedURLAction) IsLoggable() bool

func (FetchLogsWithSignedURLAction) IsPersistent 

func (a FetchLogsWithSignedURLAction) IsPersistent() bool

func (FetchLogsWithSignedURLAction) Resume 

func (a FetchLogsWithSignedURLAction) Resume() (interface{}, error)

func (FetchLogsWithSignedURLAction) Run 

func (a FetchLogsWithSignedURLAction) Run(request FetchLogsWithSignedURLRequest) (FetchLogsWithSignedURLResponse, error)

type FetchLogsWithSignedURLRequest 

type FetchLogsWithSignedURLRequest struct {
	SignedURL        string            `json:"signed_url"`
	LogType          string            `json:"log_type"`
	Filters          []string          `json:"filters"`
	BlobstoreHeaders map[string]string `json:"blobstore_headers"`
}

type FetchLogsWithSignedURLResponse 

type FetchLogsWithSignedURLResponse struct {
	SHA1Digest string `json:"sha1"`
}

type GetStateAction 

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

func NewGetState 

func NewGetState(
	settingsService boshsettings.Service,
	specService boshas.V1Service,
	jobSupervisor boshjobsuper.JobSupervisor,
	vitalsService boshvitals.Service,
) (action GetStateAction)

func (GetStateAction) Cancel 

func (a GetStateAction) Cancel() error

func (GetStateAction) IsAsynchronous 

func (a GetStateAction) IsAsynchronous(_ ProtocolVersion) bool

func (GetStateAction) IsLoggable 

func (a GetStateAction) IsLoggable() bool

func (GetStateAction) IsPersistent 

func (a GetStateAction) IsPersistent() bool

func (GetStateAction) Resume 

func (a GetStateAction) Resume() (interface{}, error)

func (GetStateAction) Run 

func (a GetStateAction) Run(filters ...string) (GetStateV1ApplySpec, error)

type GetStateV1ApplySpec 

type GetStateV1ApplySpec struct {
	boshas.V1ApplySpec

	AgentID   string                 `json:"agent_id"`
	JobState  string                 `json:"job_state"`
	Vitals    *boshvitals.Vitals     `json:"vitals,omitempty"`
	Processes []boshjobsuper.Process `json:"processes,omitempty"`
	VM        boshsettings.VM        `json:"vm"`
}

type GetTaskAction 

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

func NewGetTask 

func NewGetTask(taskService boshtask.Service) (getTask GetTaskAction)

func (GetTaskAction) Cancel 

func (a GetTaskAction) Cancel() error

func (GetTaskAction) IsAsynchronous 

func (a GetTaskAction) IsAsynchronous(_ ProtocolVersion) bool

func (GetTaskAction) IsLoggable 

func (a GetTaskAction) IsLoggable() bool

func (GetTaskAction) IsPersistent 

func (a GetTaskAction) IsPersistent() bool

func (GetTaskAction) Resume 

func (a GetTaskAction) Resume() (interface{}, error)

func (GetTaskAction) Run 

func (a GetTaskAction) Run(taskID string) (interface{}, error)

type InfoAction 

type InfoAction struct{}

func NewInfo 

func NewInfo() InfoAction

func (InfoAction) Cancel 

func (a InfoAction) Cancel() error

func (InfoAction) IsAsynchronous 

func (a InfoAction) IsAsynchronous(_ ProtocolVersion) bool

func (InfoAction) IsLoggable 

func (a InfoAction) IsLoggable() bool

func (InfoAction) IsPersistent 

func (a InfoAction) IsPersistent() bool

func (InfoAction) Resume 

func (a InfoAction) Resume() (interface{}, error)

func (InfoAction) Run 

func (a InfoAction) Run() (InfoResponse, error)

type InfoResponse 

type InfoResponse struct {
	APIVersion int `json:"api_version"`
}

type ListDiskAction 

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

func NewListDisk 

func NewListDisk(
	settingsService boshsettings.Service,
	platform boshplatform.Platform,
	logger boshlog.Logger,
) (action ListDiskAction)

func (ListDiskAction) Cancel 

func (a ListDiskAction) Cancel() error

func (ListDiskAction) IsAsynchronous 

func (a ListDiskAction) IsAsynchronous(version ProtocolVersion) bool

func (ListDiskAction) IsLoggable 

func (a ListDiskAction) IsLoggable() bool

func (ListDiskAction) IsPersistent 

func (a ListDiskAction) IsPersistent() bool

func (ListDiskAction) Resume 

func (a ListDiskAction) Resume() (interface{}, error)

func (ListDiskAction) Run 

func (a ListDiskAction) Run() (interface{}, error)

type MigrateDiskAction 

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

func NewMigrateDisk 

func NewMigrateDisk(
	platform boshplatform.Platform,
	dirProvider boshdirs.Provider,
) (action MigrateDiskAction)

func (MigrateDiskAction) Cancel 

func (a MigrateDiskAction) Cancel() error

func (MigrateDiskAction) IsAsynchronous 

func (a MigrateDiskAction) IsAsynchronous(_ ProtocolVersion) bool

func (MigrateDiskAction) IsLoggable 

func (a MigrateDiskAction) IsLoggable() bool

func (MigrateDiskAction) IsPersistent 

func (a MigrateDiskAction) IsPersistent() bool

func (MigrateDiskAction) Resume 

func (a MigrateDiskAction) Resume() (interface{}, error)

func (MigrateDiskAction) Run 

func (a MigrateDiskAction) Run() (value interface{}, err error)

type MountDiskAction 

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

func NewMountDisk 

func NewMountDisk(
	settingsService boshsettings.Service,
	diskMounter diskMounter,
	dirProvider boshdirs.Provider,
	logger boshlog.Logger,
) (mountDisk MountDiskAction)

func (MountDiskAction) Cancel 

func (a MountDiskAction) Cancel() error

func (MountDiskAction) IsAsynchronous 

func (a MountDiskAction) IsAsynchronous(_ ProtocolVersion) bool

func (MountDiskAction) IsLoggable 

func (a MountDiskAction) IsLoggable() bool

func (MountDiskAction) IsPersistent 

func (a MountDiskAction) IsPersistent() bool

func (MountDiskAction) Resume 

func (a MountDiskAction) Resume() (interface{}, error)

func (MountDiskAction) Run 

func (a MountDiskAction) Run(diskCid string) (interface{}, error)

type PingAction 

type PingAction struct{}

func NewPing 

func NewPing() PingAction

func (PingAction) Cancel 

func (a PingAction) Cancel() error

func (PingAction) IsAsynchronous 

func (a PingAction) IsAsynchronous(_ ProtocolVersion) bool

func (PingAction) IsLoggable 

func (a PingAction) IsLoggable() bool

func (PingAction) IsPersistent 

func (a PingAction) IsPersistent() bool

func (PingAction) Resume 

func (a PingAction) Resume() (interface{}, error)

func (PingAction) Run 

func (a PingAction) Run() (string, error)

type PrepareAction 

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

func NewPrepare 

func NewPrepare(applier boshappl.Applier) (action PrepareAction)

func (PrepareAction) Cancel 

func (a PrepareAction) Cancel() error

func (PrepareAction) IsAsynchronous 

func (a PrepareAction) IsAsynchronous(_ ProtocolVersion) bool

func (PrepareAction) IsLoggable 

func (a PrepareAction) IsLoggable() bool

func (PrepareAction) IsPersistent 

func (a PrepareAction) IsPersistent() bool

func (PrepareAction) Resume 

func (a PrepareAction) Resume() (interface{}, error)

func (PrepareAction) Run 

func (a PrepareAction) Run(desiredSpec boshas.V1ApplySpec) (string, error)

type PrepareConfigureNetworksAction 

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

func NewPrepareConfigureNetworks 

func NewPrepareConfigureNetworks(
	platform boshplatform.Platform,
	settingsService boshsettings.Service,
) PrepareConfigureNetworksAction

func (PrepareConfigureNetworksAction) Cancel 

func (a PrepareConfigureNetworksAction) Cancel() error

func (PrepareConfigureNetworksAction) IsAsynchronous 

func (a PrepareConfigureNetworksAction) IsAsynchronous(_ ProtocolVersion) bool

func (PrepareConfigureNetworksAction) IsLoggable 

func (a PrepareConfigureNetworksAction) IsLoggable() bool

func (PrepareConfigureNetworksAction) IsPersistent 

func (a PrepareConfigureNetworksAction) IsPersistent() bool

func (PrepareConfigureNetworksAction) Resume 

func (a PrepareConfigureNetworksAction) Resume() (interface{}, error)

func (PrepareConfigureNetworksAction) Run 

func (a PrepareConfigureNetworksAction) Run() (string, error)

type ProtocolVersion 

type ProtocolVersion int

type ReleaseApplySpecAction 

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

func NewReleaseApplySpec 

func NewReleaseApplySpec(platform boshplatform.Platform) (action ReleaseApplySpecAction)

func (ReleaseApplySpecAction) Cancel 

func (a ReleaseApplySpecAction) Cancel() error

func (ReleaseApplySpecAction) IsAsynchronous 

func (a ReleaseApplySpecAction) IsAsynchronous(_ ProtocolVersion) bool

func (ReleaseApplySpecAction) IsLoggable 

func (a ReleaseApplySpecAction) IsLoggable() bool

func (ReleaseApplySpecAction) IsPersistent 

func (a ReleaseApplySpecAction) IsPersistent() bool

func (ReleaseApplySpecAction) Resume 

func (a ReleaseApplySpecAction) Resume() (interface{}, error)

func (ReleaseApplySpecAction) Run 

func (a ReleaseApplySpecAction) Run() (value interface{}, err error)

type RemoveFileAction 

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

func NewRemoveFile 

func NewRemoveFile(
	fs boshsys.FileSystem) RemoveFileAction

func (RemoveFileAction) Cancel 

func (r RemoveFileAction) Cancel() error

func (RemoveFileAction) IsAsynchronous 

func (r RemoveFileAction) IsAsynchronous(_ ProtocolVersion) bool

func (RemoveFileAction) IsLoggable 

func (r RemoveFileAction) IsLoggable() bool

func (RemoveFileAction) IsPersistent 

func (r RemoveFileAction) IsPersistent() bool

func (RemoveFileAction) Resume 

func (r RemoveFileAction) Resume() (interface{}, error)

func (RemoveFileAction) Run 

func (r RemoveFileAction) Run(path string) (string, error)

type RemovePersistentDiskAction 

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

func NewRemovePersistentDiskAction 

func NewRemovePersistentDiskAction(settingsService boshsettings.Service) RemovePersistentDiskAction

func (RemovePersistentDiskAction) Cancel 

func (a RemovePersistentDiskAction) Cancel() error

func (RemovePersistentDiskAction) IsAsynchronous 

func (a RemovePersistentDiskAction) IsAsynchronous(_ ProtocolVersion) bool

func (RemovePersistentDiskAction) IsLoggable 

func (a RemovePersistentDiskAction) IsLoggable() bool

func (RemovePersistentDiskAction) IsPersistent 

func (a RemovePersistentDiskAction) IsPersistent() bool

func (RemovePersistentDiskAction) Resume 

func (a RemovePersistentDiskAction) Resume() (interface{}, error)

func (RemovePersistentDiskAction) Run 

func (a RemovePersistentDiskAction) Run(diskCID string) (interface{}, error)

type RunErrandAction 

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

func NewRunErrand 

func NewRunErrand(
	specService boshas.V1Service,
	jobsDir string,
	cmdRunner boshsys.CmdRunner,
	logger boshlog.Logger,
) RunErrandAction

func (RunErrandAction) Cancel 

func (a RunErrandAction) Cancel() error

Cancel satisfies above rules though it never returns any error

func (RunErrandAction) IsAsynchronous 

func (a RunErrandAction) IsAsynchronous(_ ProtocolVersion) bool

func (RunErrandAction) IsLoggable 

func (a RunErrandAction) IsLoggable() bool

func (RunErrandAction) IsPersistent 

func (a RunErrandAction) IsPersistent() bool

func (RunErrandAction) Resume 

func (a RunErrandAction) Resume() (interface{}, error)

func (RunErrandAction) Run 

func (a RunErrandAction) Run(errandName ...string) (ErrandResult, error)

type RunScriptAction 

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

func NewRunScript 

func NewRunScript(
	scriptProvider boshscript.JobScriptProvider,
	specService boshas.V1Service,
	logger boshlog.Logger,
) RunScriptAction

func (RunScriptAction) Cancel 

func (a RunScriptAction) Cancel() error

func (RunScriptAction) IsAsynchronous 

func (a RunScriptAction) IsAsynchronous(_ ProtocolVersion) bool

func (RunScriptAction) IsLoggable 

func (a RunScriptAction) IsLoggable() bool

func (RunScriptAction) IsPersistent 

func (a RunScriptAction) IsPersistent() bool

func (RunScriptAction) Resume 

func (a RunScriptAction) Resume() (interface{}, error)

func (RunScriptAction) Run 

func (a RunScriptAction) Run(scriptName string, options RunScriptOptions) (map[string]string, error)

type RunScriptOptions 

type RunScriptOptions struct {
	Env map[string]string `json:"env"`
}

type Runner 

type Runner interface {
	Run(action Action, payload []byte, protocolVersion ProtocolVersion) (value interface{}, err error)
	Resume(action Action, payload []byte) (value interface{}, err error)
}

func NewRunner 

func NewRunner() Runner

type SSHAction 

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

func NewSSH 

func NewSSH(
	settingsService boshsettings.Service,
	platform boshplatform.Platform,
	dirProvider boshdirs.Provider,
	logger boshlog.Logger,
) (action SSHAction)

func (SSHAction) Cancel 

func (a SSHAction) Cancel() error

func (SSHAction) IsAsynchronous 

func (a SSHAction) IsAsynchronous(_ ProtocolVersion) bool

func (SSHAction) IsLoggable 

func (a SSHAction) IsLoggable() bool

func (SSHAction) IsPersistent 

func (a SSHAction) IsPersistent() bool

func (SSHAction) Resume 

func (a SSHAction) Resume() (interface{}, error)

func (SSHAction) Run 

func (a SSHAction) Run(cmd string, params SSHParams) (SSHResult, error)

type SSHParams 

type SSHParams struct {
	UserRegex string `json:"user_regex"`
	User      string
	PublicKey string `json:"public_key"`
}

type SSHResult 

type SSHResult struct {
	Command       string `json:"command"`
	Status        string `json:"status"`
	IP            string `json:"ip,omitempty"`
	HostPublicKey string `json:"host_public_key,omitempty"`
}

type ShutdownAction 

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

func NewShutdown 

func NewShutdown(platform platform.Platform) ShutdownAction

func (ShutdownAction) Cancel 

func (a ShutdownAction) Cancel() error

func (ShutdownAction) IsAsynchronous 

func (a ShutdownAction) IsAsynchronous(_ ProtocolVersion) bool

func (ShutdownAction) IsLoggable 

func (a ShutdownAction) IsLoggable() bool

func (ShutdownAction) IsPersistent 

func (a ShutdownAction) IsPersistent() bool

func (ShutdownAction) Resume 

func (a ShutdownAction) Resume() (interface{}, error)

func (ShutdownAction) Run 

func (a ShutdownAction) Run() (string, error)

type StartAction 

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

func NewStart 

func NewStart(jobSupervisor boshjobsuper.JobSupervisor, applier boshappl.Applier, specService boshas.V1Service) (start StartAction)

func (StartAction) Cancel 

func (a StartAction) Cancel() error

func (StartAction) IsAsynchronous 

func (a StartAction) IsAsynchronous(_ ProtocolVersion) bool

func (StartAction) IsLoggable 

func (a StartAction) IsLoggable() bool

func (StartAction) IsPersistent 

func (a StartAction) IsPersistent() bool

func (StartAction) Resume 

func (a StartAction) Resume() (interface{}, error)

func (StartAction) Run 

func (a StartAction) Run() (value string, err error)

type StopAction 

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

func NewStop 

func NewStop(jobSupervisor boshjobsuper.JobSupervisor) (stop StopAction)

func (StopAction) Cancel 

func (a StopAction) Cancel() error

func (StopAction) IsAsynchronous 

func (a StopAction) IsAsynchronous(_ ProtocolVersion) bool

func (StopAction) IsLoggable 

func (a StopAction) IsLoggable() bool

func (StopAction) IsPersistent 

func (a StopAction) IsPersistent() bool

func (StopAction) Resume 

func (a StopAction) Resume() (interface{}, error)

func (StopAction) Run 

func (a StopAction) Run(protocolVersion ProtocolVersion) (value string, err error)

type SyncDNS 

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

func NewSyncDNS 

func NewSyncDNS(blobstore blobstore_delegator.BlobstoreDelegator, settingsService boshsettings.Service, platform boshplat.Platform, logger boshlog.Logger) SyncDNS

func (SyncDNS) Cancel 

func (a SyncDNS) Cancel() error

func (SyncDNS) IsAsynchronous 

func (a SyncDNS) IsAsynchronous(_ ProtocolVersion) bool

func (SyncDNS) IsLoggable 

func (a SyncDNS) IsLoggable() bool

func (SyncDNS) IsPersistent 

func (a SyncDNS) IsPersistent() bool

func (SyncDNS) Resume 

func (a SyncDNS) Resume() (interface{}, error)

func (SyncDNS) Run 

func (a SyncDNS) Run(blobID string, multiDigest boshcrypto.MultipleDigest, version uint64) (string, error)

type SyncDNSWithSignedURL 

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

func NewSyncDNSWithSignedURL 

func NewSyncDNSWithSignedURL(
	settingsService boshsettings.Service,
	platform boshplat.Platform,
	logger boshlog.Logger,
	bd blobdelegator.BlobstoreDelegator) (action SyncDNSWithSignedURL)

func (SyncDNSWithSignedURL) Cancel 

func (a SyncDNSWithSignedURL) Cancel() error

func (SyncDNSWithSignedURL) IsAsynchronous 

func (a SyncDNSWithSignedURL) IsAsynchronous(_ ProtocolVersion) bool

func (SyncDNSWithSignedURL) IsLoggable 

func (a SyncDNSWithSignedURL) IsLoggable() bool

func (SyncDNSWithSignedURL) IsPersistent 

func (a SyncDNSWithSignedURL) IsPersistent() bool

func (SyncDNSWithSignedURL) Resume 

func (a SyncDNSWithSignedURL) Resume() (interface{}, error)

func (SyncDNSWithSignedURL) Run 

func (a SyncDNSWithSignedURL) Run(request SyncDNSWithSignedURLRequest) (string, error)

type SyncDNSWithSignedURLRequest 

type SyncDNSWithSignedURLRequest struct {
	SignedURL        string                    `json:"signed_url"`
	MultiDigest      boshcrypto.MultipleDigest `json:"multi_digest"`
	Version          uint64                    `json:"version"`
	BlobstoreHeaders map[string]string         `json:"blobstore_headers"`
}

type UnmountDiskAction 

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

func NewUnmountDisk 

func NewUnmountDisk(
	settingsService boshsettings.Service,
	platform boshplatform.Platform,
) (unmountDisk UnmountDiskAction)

func (UnmountDiskAction) Cancel 

func (a UnmountDiskAction) Cancel() error

func (UnmountDiskAction) IsAsynchronous 

func (a UnmountDiskAction) IsAsynchronous(_ ProtocolVersion) bool

func (UnmountDiskAction) IsLoggable 

func (a UnmountDiskAction) IsLoggable() bool

func (UnmountDiskAction) IsPersistent 

func (a UnmountDiskAction) IsPersistent() bool

func (UnmountDiskAction) Resume 

func (a UnmountDiskAction) Resume() (interface{}, error)

func (UnmountDiskAction) Run 

func (a UnmountDiskAction) Run(diskID string) (value interface{}, err error)

type UpdateSettingsAction 

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

func NewUpdateSettings 

func NewUpdateSettings(service boshsettings.Service, platform platform.Platform, trustedCertManager cert.Manager, logger logger.Logger, agentKiller utils.Killer) UpdateSettingsAction

func (UpdateSettingsAction) Cancel 

func (a UpdateSettingsAction) Cancel() error

func (UpdateSettingsAction) IsAsynchronous 

func (a UpdateSettingsAction) IsAsynchronous(_ ProtocolVersion) bool

func (UpdateSettingsAction) IsLoggable 

func (a UpdateSettingsAction) IsLoggable() bool

func (UpdateSettingsAction) IsPersistent 

func (a UpdateSettingsAction) IsPersistent() bool

func (UpdateSettingsAction) Resume 

func (a UpdateSettingsAction) Resume() (interface{}, error)

func (UpdateSettingsAction) Run 

func (a UpdateSettingsAction) Run(newUpdateSettings boshsettings.UpdateSettings) (string, error)

type UploadBlobAction 

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

func NewUploadBlobAction 

func NewUploadBlobAction(blobManager boshagentblobstore.BlobManagerInterface) UploadBlobAction

func (UploadBlobAction) Cancel 

func (a UploadBlobAction) Cancel() error

func (UploadBlobAction) IsAsynchronous 

func (a UploadBlobAction) IsAsynchronous(_ ProtocolVersion) bool

func (UploadBlobAction) IsLoggable 

func (a UploadBlobAction) IsLoggable() bool

func (UploadBlobAction) IsPersistent 

func (a UploadBlobAction) IsPersistent() bool

func (UploadBlobAction) Resume 

func (a UploadBlobAction) Resume() (interface{}, error)

func (UploadBlobAction) Run 

func (a UploadBlobAction) Run(content UploadBlobSpec) (string, error)

type UploadBlobSpec 

type UploadBlobSpec struct {
	BlobID   string                    `json:"blob_id"`
	Checksum boshcrypto.MultipleDigest `json:"checksum"`
	Payload  string                    `json:"payload"`
}

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

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.