Documentation
¶
Index ¶
- type Action
- type AddPersistentDiskAction
- func (a AddPersistentDiskAction) Cancel() error
- func (a AddPersistentDiskAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a AddPersistentDiskAction) IsLoggable() bool
- func (a AddPersistentDiskAction) IsPersistent() bool
- func (a AddPersistentDiskAction) Resume() (interface{}, error)
- func (a AddPersistentDiskAction) Run(diskCID string, diskHint interface{}) (interface{}, error)
- type ApplyAction
- type CancelTaskAction
- func (a CancelTaskAction) Cancel() error
- func (a CancelTaskAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a CancelTaskAction) IsLoggable() bool
- func (a CancelTaskAction) IsPersistent() bool
- func (a CancelTaskAction) Resume() (interface{}, error)
- func (a CancelTaskAction) Run(taskID string) (string, error)
- type CompilePackageAction
- func (a CompilePackageAction) Cancel() error
- func (a CompilePackageAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a CompilePackageAction) IsLoggable() bool
- func (a CompilePackageAction) IsPersistent() bool
- func (a CompilePackageAction) Resume() (interface{}, error)
- func (a CompilePackageAction) Run(blobID string, multiDigest boshcrypto.MultipleDigest, name, version string, ...) (val map[string]interface{}, err error)
- type CompilePackageWithSignedURL
- type CompilePackageWithSignedURLRequest
- type CompilePackageWithSignedURLResponse
- type DeleteARPEntriesAction
- func (a DeleteARPEntriesAction) Cancel() error
- func (a DeleteARPEntriesAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a DeleteARPEntriesAction) IsLoggable() bool
- func (a DeleteARPEntriesAction) IsPersistent() bool
- func (a DeleteARPEntriesAction) Resume() (interface{}, error)
- func (a DeleteARPEntriesAction) Run(args DeleteARPEntriesActionArgs) (interface{}, error)
- type DeleteARPEntriesActionArgs
- type DrainAction
- func (a DrainAction) Cancel() error
- func (a DrainAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a DrainAction) IsLoggable() bool
- func (a DrainAction) IsPersistent() bool
- func (a DrainAction) Resume() (interface{}, error)
- func (a DrainAction) Run(drainType DrainType, newSpecs ...boshas.V1ApplySpec) (int, error)
- type DrainType
- type ErrandResult
- type Factory
- type FetchLogsAction
- func (a FetchLogsAction) Cancel() error
- func (a FetchLogsAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a FetchLogsAction) IsLoggable() bool
- func (a FetchLogsAction) IsPersistent() bool
- func (a FetchLogsAction) Resume() (interface{}, error)
- func (a FetchLogsAction) Run(logType string, filters []string) (value map[string]string, err error)
- type FetchLogsWithSignedURLAction
- func (a FetchLogsWithSignedURLAction) Cancel() error
- func (a FetchLogsWithSignedURLAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a FetchLogsWithSignedURLAction) IsLoggable() bool
- func (a FetchLogsWithSignedURLAction) IsPersistent() bool
- func (a FetchLogsWithSignedURLAction) Resume() (interface{}, error)
- func (a FetchLogsWithSignedURLAction) Run(request FetchLogsWithSignedURLRequest) (FetchLogsWithSignedURLResponse, error)
- type FetchLogsWithSignedURLRequest
- type FetchLogsWithSignedURLResponse
- type GetStateAction
- func (a GetStateAction) Cancel() error
- func (a GetStateAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a GetStateAction) IsLoggable() bool
- func (a GetStateAction) IsPersistent() bool
- func (a GetStateAction) Resume() (interface{}, error)
- func (a GetStateAction) Run(filters ...string) (GetStateV1ApplySpec, error)
- type GetStateV1ApplySpec
- type GetTaskAction
- type InfoAction
- type InfoResponse
- type ListDiskAction
- type MigrateDiskAction
- func (a MigrateDiskAction) Cancel() error
- func (a MigrateDiskAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a MigrateDiskAction) IsLoggable() bool
- func (a MigrateDiskAction) IsPersistent() bool
- func (a MigrateDiskAction) Resume() (interface{}, error)
- func (a MigrateDiskAction) Run() (value interface{}, err error)
- type MountDiskAction
- func (a MountDiskAction) Cancel() error
- func (a MountDiskAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a MountDiskAction) IsLoggable() bool
- func (a MountDiskAction) IsPersistent() bool
- func (a MountDiskAction) Resume() (interface{}, error)
- func (a MountDiskAction) Run(diskCid string) (interface{}, error)
- type PingAction
- type PrepareAction
- func (a PrepareAction) Cancel() error
- func (a PrepareAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a PrepareAction) IsLoggable() bool
- func (a PrepareAction) IsPersistent() bool
- func (a PrepareAction) Resume() (interface{}, error)
- func (a PrepareAction) Run(desiredSpec boshas.V1ApplySpec) (string, error)
- type PrepareConfigureNetworksAction
- func (a PrepareConfigureNetworksAction) Cancel() error
- func (a PrepareConfigureNetworksAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a PrepareConfigureNetworksAction) IsLoggable() bool
- func (a PrepareConfigureNetworksAction) IsPersistent() bool
- func (a PrepareConfigureNetworksAction) Resume() (interface{}, error)
- func (a PrepareConfigureNetworksAction) Run() (string, error)
- type ProtocolVersion
- type ReleaseApplySpecAction
- func (a ReleaseApplySpecAction) Cancel() error
- func (a ReleaseApplySpecAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a ReleaseApplySpecAction) IsLoggable() bool
- func (a ReleaseApplySpecAction) IsPersistent() bool
- func (a ReleaseApplySpecAction) Resume() (interface{}, error)
- func (a ReleaseApplySpecAction) Run() (value interface{}, err error)
- type RemovePersistentDiskAction
- func (a RemovePersistentDiskAction) Cancel() error
- func (a RemovePersistentDiskAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a RemovePersistentDiskAction) IsLoggable() bool
- func (a RemovePersistentDiskAction) IsPersistent() bool
- func (a RemovePersistentDiskAction) Resume() (interface{}, error)
- func (a RemovePersistentDiskAction) Run(diskCID string) (interface{}, error)
- type RunErrandAction
- func (a RunErrandAction) Cancel() error
- func (a RunErrandAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a RunErrandAction) IsLoggable() bool
- func (a RunErrandAction) IsPersistent() bool
- func (a RunErrandAction) Resume() (interface{}, error)
- func (a RunErrandAction) Run(errandName ...string) (ErrandResult, error)
- type RunScriptAction
- func (a RunScriptAction) Cancel() error
- func (a RunScriptAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a RunScriptAction) IsLoggable() bool
- func (a RunScriptAction) IsPersistent() bool
- func (a RunScriptAction) Resume() (interface{}, error)
- func (a RunScriptAction) Run(scriptName string, options RunScriptOptions) (map[string]string, error)
- type RunScriptOptions
- type Runner
- type SSHAction
- type SSHParams
- type SSHResult
- type ShutdownAction
- type StartAction
- type StopAction
- func (a StopAction) Cancel() error
- func (a StopAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a StopAction) IsLoggable() bool
- func (a StopAction) IsPersistent() bool
- func (a StopAction) Resume() (interface{}, error)
- func (a StopAction) Run(protocolVersion ProtocolVersion) (value string, err error)
- type SyncDNS
- func (a SyncDNS) Cancel() error
- func (a SyncDNS) IsAsynchronous(_ ProtocolVersion) bool
- func (a SyncDNS) IsLoggable() bool
- func (a SyncDNS) IsPersistent() bool
- func (a SyncDNS) Resume() (interface{}, error)
- func (a SyncDNS) Run(blobID string, multiDigest boshcrypto.MultipleDigest, version uint64) (string, error)
- type SyncDNSWithSignedURL
- type SyncDNSWithSignedURLRequest
- type UnmountDiskAction
- func (a UnmountDiskAction) Cancel() error
- func (a UnmountDiskAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a UnmountDiskAction) IsLoggable() bool
- func (a UnmountDiskAction) IsPersistent() bool
- func (a UnmountDiskAction) Resume() (interface{}, error)
- func (a UnmountDiskAction) Run(diskID string) (value interface{}, err error)
- type UpdateSettingsAction
- func (a UpdateSettingsAction) Cancel() error
- func (a UpdateSettingsAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a UpdateSettingsAction) IsLoggable() bool
- func (a UpdateSettingsAction) IsPersistent() bool
- func (a UpdateSettingsAction) Resume() (interface{}, error)
- func (a UpdateSettingsAction) Run(newUpdateSettings boshsettings.UpdateSettings) (string, error)
- type UploadBlobAction
- func (a UploadBlobAction) Cancel() error
- func (a UploadBlobAction) IsAsynchronous(_ ProtocolVersion) bool
- func (a UploadBlobAction) IsLoggable() bool
- func (a UploadBlobAction) IsPersistent() bool
- func (a UploadBlobAction) Resume() (interface{}, error)
- func (a UploadBlobAction) Run(content UploadBlobSpec) (string, error)
- type UploadBlobSpec
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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)
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{}
func (CompilePackageWithSignedURL) Run ¶
func (a CompilePackageWithSignedURL) Run(request CompilePackageWithSignedURLRequest) (CompilePackageWithSignedURLResponse, error)
type CompilePackageWithSignedURLRequest ¶
type CompilePackageWithSignedURLRequest struct { PackageGetSignedURL string `json:"package_get_signed_url"` UploadSignedURL string `json:"upload_signed_url"` MultiDigest boshcrypto.MultipleDigest `json:"multi_digest"` Name string `json:"name"` Version string `json:"version"` Deps boshcomp.Dependencies `json:"deps"` }
type CompilePackageWithSignedURLResponse ¶
type CompilePackageWithSignedURLResponse struct {
SHA1Digest string `json:"sha1_digest"`
}
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 ErrandResult ¶
type Factory ¶
func NewFactory ¶
func NewFactory( settingsService boshsettings.Service, platform boshplatform.Platform, blobstore boshblob.DigestBlobstore, 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, ) (factory Factory)
type FetchLogsAction ¶
type FetchLogsAction struct {
// contains filtered or unexported fields
}
func NewFetchLogs ¶
func NewFetchLogs( compressor boshcmd.Compressor, copier boshcmd.Copier, blobstore boshblob.DigestBlobstore, 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)
type FetchLogsWithSignedURLAction ¶
type FetchLogsWithSignedURLAction struct {
// contains filtered or unexported fields
}
func NewFetchLogsWithSignedURLAction ¶
func NewFetchLogsWithSignedURLAction( compressor boshcmd.Compressor, copier boshcmd.Copier, settingsDir boshdirs.Provider, httpBlobProvider httpblobprovider.HTTPBlobProvider, ) (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 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 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 (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 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) IsAsynchronous ¶
func (a SSHAction) IsAsynchronous(_ ProtocolVersion) bool
func (SSHAction) IsLoggable ¶
func (SSHAction) IsPersistent ¶
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 boshblob.DigestBlobstore, settingsService boshsettings.Service, platform boshplat.Platform, logger boshlog.Logger) SyncDNS
func (SyncDNS) IsAsynchronous ¶
func (a SyncDNS) IsAsynchronous(_ ProtocolVersion) bool
func (SyncDNS) IsLoggable ¶
func (SyncDNS) IsPersistent ¶
func (SyncDNS) Run ¶
func (a SyncDNS) Run(blobID string, multiDigest boshcrypto.MultipleDigest, version uint64) (string, error)
type SyncDNSWithSignedURL ¶
type SyncDNSWithSignedURL struct{}
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"` }
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 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
¶
- action_interface.go
- add_persistent_disk.go
- apply.go
- cancel_task.go
- compile_package.go
- compile_package_with_signed_url.go
- concrete_factory.go
- delete_arp_entries.go
- drain.go
- factory_interface.go
- fetch_logs.go
- fetch_logs_with_signed_url.go
- get_state.go
- get_task.go
- info.go
- list_disk.go
- migrate_disk.go
- mount_disk.go
- ping.go
- prepare.go
- prepare_configure_networks.go
- release_apply_spec.go
- remove_persistent_disk.go
- run_errand.go
- run_script.go
- runner.go
- shutdown.go
- ssh.go
- start.go
- stop.go
- sync_dns.go
- sync_dns_with_signed_url.go
- unmount_disk.go
- update_settings.go
- upload_blob.go
Click to show internal directories.
Click to hide internal directories.