action

package
Version: v2.367.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 9, 2021 License: Apache-2.0 Imports: 36 Imported by: 8

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 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) (val map[string]interface{}, err error)

type CompilePackageWithSignedURL

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

func NewCompilePackageWithSignedURL

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

func (CompilePackageWithSignedURL) Cancel

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

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(
	compressor boshcmd.Compressor,
	copier boshcmd.Copier,
	blobstore blobstore_delegator.BlobstoreDelegator,
	settingsDir boshdirs.Provider,
) (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(logType string, filters []string) (value map[string]string, err error)

type FetchLogsWithSignedURLAction

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

func NewFetchLogsWithSignedURLAction

func NewFetchLogsWithSignedURLAction(
	compressor boshcmd.Compressor,
	copier boshcmd.Copier,
	settingsDir boshdirs.Provider,
	blobDelegator blobdelegator.BlobstoreDelegator) (action FetchLogsWithSignedURLAction)

func (FetchLogsWithSignedURLAction) Cancel

func (FetchLogsWithSignedURLAction) IsAsynchronous

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

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 (PrepareConfigureNetworksAction) IsAsynchronous

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

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 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

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) 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 (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"`
}

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