Versions in this module Expand all Collapse all v0 v0.0.52 Sep 1, 2016 Changes in this version type Task + LastActivityAt func() time.Time + StartedAt func() time.Time type TaskImpl + func (t TaskImpl) LastActivityAt() time.Time + func (t TaskImpl) StartedAt() time.Time type TaskResp + LastActivityAt int64 + StartedAt int64 + type TasksFilter struct + All bool + Deployment string v0.0.51 Aug 31, 2016 v0.0.50 Aug 31, 2016 Changes in this version + type AdjustableClient struct + func NewAdjustableClient(client AdjustedClient, adjustment Adjustment) AdjustableClient + func (c AdjustableClient) Do(req *http.Request) (*http.Response, error) + type AdjustedClient interface + Do func(*http.Request) (*http.Response, error) + type Adjustment interface + Adjust func(req *http.Request, retried bool) error + NeedsReadjustment func(*http.Response) bool + type AllOrPoolOrInstanceSlug struct + func NewAllOrPoolOrInstanceSlug(name, indexOrID string) AllOrPoolOrInstanceSlug + func NewAllOrPoolOrInstanceSlugFromString(str string) (AllOrPoolOrInstanceSlug, error) + func (s *AllOrPoolOrInstanceSlug) UnmarshalFlag(data string) error + func (s AllOrPoolOrInstanceSlug) IndexOrID() string + func (s AllOrPoolOrInstanceSlug) InstanceSlug() (InstanceSlug, bool) + func (s AllOrPoolOrInstanceSlug) Name() string + func (s AllOrPoolOrInstanceSlug) String() string + type AuthRequestAdjustment struct + func NewAuthRequestAdjustment(authFunc func(bool) (string, error), username string, password string) AuthRequestAdjustment + func (a AuthRequestAdjustment) Adjust(req *http.Request, retried bool) error + func (a AuthRequestAdjustment) NeedsReadjustment(resp *http.Response) bool + type Client struct + func NewClient(endpoint string, httpClient boshhttp.HTTPClient, taskReporter TaskReporter, ...) Client + func (c Client) CancelTask(id int) error + func (c Client) ChangeJobState(state, deploymentName, job, indexOrID string, sd SkipDrain, force bool, ...) error + func (c Client) CleanUp(all bool) error + func (c Client) CleanUpSSH(deploymentName, jobName, indexOrID string, opts SSHOpts) error + func (c Client) CloudConfigs() ([]CloudConfig, error) + func (c Client) CurrentTasks(includeAll bool) ([]TaskResp, error) + func (c Client) DeleteDeployment(deploymentName string, force bool) error + func (c Client) DeleteOrphanedDisk(cid string) error + func (c Client) DeleteReleaseOrSeries(name, version string, force bool) error + func (c Client) DeleteSnapshot(deploymentName, cid string) error + func (c Client) DeleteSnapshots(deploymentName string) error + func (c Client) DeleteStemcell(name, version string, force bool) error + func (c Client) Deployment(name string) (DeploymentResp, error) + func (c Client) DeploymentInstanceInfos(deploymentName string) ([]VMInfo, error) + func (c Client) DeploymentVMInfos(deploymentName string) ([]VMInfo, error) + func (c Client) DeploymentVMs(deploymentName string) ([]VMResp, error) + func (c Client) Deployments() ([]DeploymentResp, error) + func (c Client) Diff(manifest []byte, deploymentName string, doNotRedact bool) (DeploymentDiffResponse, error) + func (c Client) DownloadResourceUnchecked(blobstoreID string, out io.Writer) error + func (c Client) EnableResurrection(deploymentName, job, indexOrID string, enabled bool) error + func (c Client) EnableResurrectionAll(enabled bool) error + func (c Client) Errands(deploymentName string) ([]Errand, error) + func (c Client) Events(opts EventsFilter) ([]EventResp, error) + func (c Client) ExportRelease(deploymentName string, release ReleaseSlug, os OSVersionSlug) (ExportReleaseResp, error) + func (c Client) FetchLogs(deploymentName, job, indexOrID string, filters []string, agent bool) (string, string, error) + func (c Client) HasRelease(name, version string) (bool, error) + func (c Client) HasStemcell(name, version string) (bool, error) + func (c Client) Info() (InfoResp, error) + func (c Client) ListProblems(deploymentName string) ([]Problem, error) + func (c Client) Locks() ([]LockResp, error) + func (c Client) MatchCompiledPackages(manifest interface{}) ([]string, error) + func (c Client) MatchPackages(manifest interface{}) ([]string, error) + func (c Client) OrphanedDisks() ([]OrphanedDiskResp, error) + func (c Client) RecentTasks(limit int, includeAll bool) ([]TaskResp, error) + func (c Client) Release(name, version string) (ReleaseResp, error) + func (c Client) ReleaseSeries() ([]ReleaseSeriesResp, error) + func (c Client) ResolveProblems(deploymentName string, answers []ProblemAnswer) error + func (c Client) RunErrand(deploymentName, name string, keepAlive bool) (ErrandRunResp, error) + func (c Client) RuntimeConfigs() ([]RuntimeConfig, error) + func (c Client) ScanForProblems(deploymentName string) error + func (c Client) SetUpSSH(deploymentName, jobName, indexOrID string, opts SSHOpts) ([]SSHResp, error) + func (c Client) Snapshots(deploymentName string) ([]SnapshotResp, error) + func (c Client) Stemcells() ([]StemcellResp, error) + func (c Client) TakeSnapshot(deploymentName, job, indexOrID string) error + func (c Client) TakeSnapshots(deploymentName string) error + func (c Client) Task(id int) (TaskResp, error) + func (c Client) TaskOutput(id int, type_ string, taskReporter TaskReporter) error + func (c Client) UpdateCloudConfig(manifest []byte) error + func (c Client) UpdateDeployment(manifest []byte, recreate bool, sd SkipDrain) error + func (c Client) UpdateRuntimeConfig(manifest []byte) error + func (c Client) UploadReleaseFile(file UploadFile, rebase, fix bool) error + func (c Client) UploadReleaseURL(url, sha1 string, rebase, fix bool) error + func (c Client) UploadStemcellFile(file UploadFile, fix bool) error + func (c Client) UploadStemcellURL(url, sha1 string, fix bool) error + type ClientRequest struct + func NewClientRequest(endpoint string, httpClient boshhttp.HTTPClient, fileReporter FileReporter, ...) ClientRequest + func (r ClientRequest) Delete(path string, response interface{}) error + func (r ClientRequest) Get(path string, response interface{}) error + func (r ClientRequest) Post(path string, payload []byte, f func(*http.Request), response interface{}) error + func (r ClientRequest) Put(path string, payload []byte, f func(*http.Request), response interface{}) error + func (r ClientRequest) RawDelete(path string) ([]byte, *http.Response, error) + func (r ClientRequest) RawGet(path string, out io.Writer, f func(*http.Request)) ([]byte, *http.Response, error) + func (r ClientRequest) RawPost(path string, payload []byte, f func(*http.Request)) ([]byte, *http.Response, error) + func (r ClientRequest) RawPut(path string, payload []byte, f func(*http.Request)) ([]byte, *http.Response, error) + type CloudConfig struct + Properties string + type CompiledPackage struct + BlobstoreID string + SHA1 string + StemcellSlug StemcellSlug + type Config struct + CACert string + Host string + Password string + Port int + TokenFunc func(bool) (string, error) + Username string + func NewConfigFromURL(url string) (Config, error) + func (c Config) CACertPool() (*x509.CertPool, error) + func (c Config) Validate() error + type Deployment interface + CleanUpSSH func(AllOrPoolOrInstanceSlug, SSHOpts) error + CloudConfig func() (string, error) + Delete func(force bool) error + DeleteSnapshot func(string) error + DeleteSnapshots func() error + Diff func([]byte, bool) (DiffLines, error) + EnableResurrection func(InstanceSlug, bool) error + Errands func() ([]Errand, error) + ExportRelease func(ReleaseSlug, OSVersionSlug) (ExportReleaseResult, error) + FetchLogs func(InstanceSlug, []string, bool) (LogsResult, error) + InstanceInfos func() ([]VMInfo, error) + Manifest func() (string, error) + Name func() string + Recreate func(slug AllOrPoolOrInstanceSlug, sd SkipDrain, force bool) error + Releases func() ([]Release, error) + ResolveProblems func([]ProblemAnswer) error + Restart func(slug AllOrPoolOrInstanceSlug, sd SkipDrain, force bool) error + RunErrand func(string, bool) (ErrandResult, error) + ScanForProblems func() ([]Problem, error) + SetUpSSH func(AllOrPoolOrInstanceSlug, SSHOpts) (SSHResult, error) + Snapshots func() ([]Snapshot, error) + Start func(slug AllOrPoolOrInstanceSlug) error + Stemcells func() ([]Stemcell, error) + Stop func(slug AllOrPoolOrInstanceSlug, hard bool, sd SkipDrain, force bool) error + TakeSnapshot func(InstanceSlug) error + TakeSnapshots func() error + Update func(manifest []byte, recreate bool, sd SkipDrain) error + VMInfos func() ([]VMInfo, error) + type DeploymentDiffResponse struct + Context map[string]interface{} + Diff [][]interface{} + type DeploymentImpl struct + func (d *DeploymentImpl) CloudConfig() (string, error) + func (d *DeploymentImpl) Releases() ([]Release, error) + func (d *DeploymentImpl) Stemcells() ([]Stemcell, error) + func (d DeploymentImpl) CleanUpSSH(slug AllOrPoolOrInstanceSlug, opts SSHOpts) error + func (d DeploymentImpl) Delete(force bool) error + func (d DeploymentImpl) DeleteSnapshot(cid string) error + func (d DeploymentImpl) DeleteSnapshots() error + func (d DeploymentImpl) Diff(manifest []byte, doNotRedact bool) (DiffLines, error) + func (d DeploymentImpl) EnableResurrection(slug InstanceSlug, enabled bool) error + func (d DeploymentImpl) Errands() ([]Errand, error) + func (d DeploymentImpl) ExportRelease(release ReleaseSlug, os OSVersionSlug) (ExportReleaseResult, error) + func (d DeploymentImpl) FetchLogs(slug InstanceSlug, filters []string, agent bool) (LogsResult, error) + func (d DeploymentImpl) InstanceInfos() ([]VMInfo, error) + func (d DeploymentImpl) IsInProgress() (bool, error) + func (d DeploymentImpl) Manifest() (string, error) + func (d DeploymentImpl) Name() string + func (d DeploymentImpl) Recreate(slug AllOrPoolOrInstanceSlug, sd SkipDrain, force bool) error + func (d DeploymentImpl) ResolveProblems(answers []ProblemAnswer) error + func (d DeploymentImpl) Restart(slug AllOrPoolOrInstanceSlug, sd SkipDrain, force bool) error + func (d DeploymentImpl) RunErrand(name string, keepAlive bool) (ErrandResult, error) + func (d DeploymentImpl) ScanForProblems() ([]Problem, error) + func (d DeploymentImpl) SetUpSSH(slug AllOrPoolOrInstanceSlug, opts SSHOpts) (SSHResult, error) + func (d DeploymentImpl) Snapshots() ([]Snapshot, error) + func (d DeploymentImpl) Start(slug AllOrPoolOrInstanceSlug) error + func (d DeploymentImpl) Stop(slug AllOrPoolOrInstanceSlug, hard bool, sd SkipDrain, force bool) error + func (d DeploymentImpl) TakeSnapshot(slug InstanceSlug) error + func (d DeploymentImpl) TakeSnapshots() error + func (d DeploymentImpl) Update(manifest []byte, recreate bool, sd SkipDrain) error + func (d DeploymentImpl) VMInfos() ([]VMInfo, error) + type DeploymentReleaseResp struct + Name string + Version string + type DeploymentResp struct + CloudConfig string + Manifest string + Name string + Releases []DeploymentReleaseResp + Stemcells []DeploymentStemcellResp + type DeploymentStemcellResp struct + Name string + Version string + type DiffLines [][]interface + type Director interface + CleanUp func(bool) error + CurrentTasks func(includeAll bool) ([]Task, error) + Deployments func() ([]Deployment, error) + DownloadResourceUnchecked func(blobstoreID string, out io.Writer) error + EnableResurrection func(bool) error + Events func(EventsFilter) ([]Event, error) + FindDeployment func(string) (Deployment, error) + FindOrphanedDisk func(string) (OrphanedDisk, error) + FindRelease func(ReleaseSlug) (Release, error) + FindReleaseSeries func(ReleaseSeriesSlug) (ReleaseSeries, error) + FindStemcell func(StemcellSlug) (Stemcell, error) + FindTask func(int) (Task, error) + HasRelease func(name, version string) (bool, error) + HasStemcell func(name, version string) (bool, error) + Info func() (Info, error) + IsAuthenticated func() (bool, error) + LatestCloudConfig func() (CloudConfig, error) + LatestRuntimeConfig func() (RuntimeConfig, error) + Locks func() ([]Lock, error) + MatchPackages func(manifest interface{}, compiled bool) ([]string, error) + OrphanedDisks func() ([]OrphanedDisk, error) + RecentTasks func(limit int, includeAll bool) ([]Task, error) + Releases func() ([]Release, error) + Stemcells func() ([]Stemcell, error) + UpdateCloudConfig func([]byte) error + UpdateRuntimeConfig func([]byte) error + UploadReleaseFile func(file UploadFile, rebase, fix bool) error + UploadReleaseURL func(url, sha1 string, rebase, fix bool) error + UploadStemcellFile func(file UploadFile, fix bool) error + UploadStemcellURL func(url, sha1 string, fix bool) error + type DirectorImpl struct + func (d DirectorImpl) CleanUp(all bool) error + func (d DirectorImpl) CurrentTasks(includeAll bool) ([]Task, error) + func (d DirectorImpl) Deployments() ([]Deployment, error) + func (d DirectorImpl) DownloadResourceUnchecked(blobstoreID string, out io.Writer) error + func (d DirectorImpl) EnableResurrection(enabled bool) error + func (d DirectorImpl) Events(opts EventsFilter) ([]Event, error) + func (d DirectorImpl) FindDeployment(name string) (Deployment, error) + func (d DirectorImpl) FindOrphanedDisk(cid string) (OrphanedDisk, error) + func (d DirectorImpl) FindRelease(slug ReleaseSlug) (Release, error) + func (d DirectorImpl) FindReleaseSeries(slug ReleaseSeriesSlug) (ReleaseSeries, error) + func (d DirectorImpl) FindStemcell(slug StemcellSlug) (Stemcell, error) + func (d DirectorImpl) FindTask(id int) (Task, error) + func (d DirectorImpl) HasRelease(name, version string) (bool, error) + func (d DirectorImpl) HasStemcell(name, version string) (bool, error) + func (d DirectorImpl) Info() (Info, error) + func (d DirectorImpl) IsAuthenticated() (bool, error) + func (d DirectorImpl) LatestCloudConfig() (CloudConfig, error) + func (d DirectorImpl) LatestRuntimeConfig() (RuntimeConfig, error) + func (d DirectorImpl) Locks() ([]Lock, error) + func (d DirectorImpl) MatchPackages(manifest interface{}, compiled bool) ([]string, error) + func (d DirectorImpl) OrphanedDisks() ([]OrphanedDisk, error) + func (d DirectorImpl) RecentTasks(limit int, includeAll bool) ([]Task, error) + func (d DirectorImpl) Releases() ([]Release, error) + func (d DirectorImpl) Stemcells() ([]Stemcell, error) + func (d DirectorImpl) UpdateCloudConfig(manifest []byte) error + func (d DirectorImpl) UpdateRuntimeConfig(manifest []byte) error + func (d DirectorImpl) UploadReleaseFile(file UploadFile, rebase, fix bool) error + func (d DirectorImpl) UploadReleaseURL(url, sha1 string, rebase, fix bool) error + func (d DirectorImpl) UploadStemcellFile(file UploadFile, fix bool) error + func (d DirectorImpl) UploadStemcellURL(url, sha1 string, fix bool) error + type Errand struct + Name string + type ErrandResult struct + ExitCode int + LogsBlobstoreID string + LogsSHA1 string + Stderr string + Stdout string + type ErrandRunResp struct + ExitCode int + Logs struct{ ... } + Stderr string + Stdout string + type Event interface + Action func() string + Context func() map[string]interface{} + DeploymentName func() string + ID func() string + Instance func() string + ObjectName func() string + ObjectType func() string + ParentID func() string + TaskID func() string + Timestamp func() time.Time + User func() string + type EventImpl struct + func NewEventFromResp(client Client, r EventResp) EventImpl + func (e EventImpl) Action() string + func (e EventImpl) Context() map[string]interface{} + func (e EventImpl) DeploymentName() string + func (e EventImpl) ID() string + func (e EventImpl) Instance() string + func (e EventImpl) ObjectName() string + func (e EventImpl) ObjectType() string + func (e EventImpl) ParentID() string + func (e EventImpl) TaskID() string + func (e EventImpl) Timestamp() time.Time + func (e EventImpl) User() string + type EventResp struct + Action string + Context map[string]interface{} + DeploymentName string + ID string + Instance string + ObjectName string + ObjectType string + ParentID string + TaskID string + Timestamp int64 + User string + type EventsFilter struct + After string + Before string + BeforeID string + Deployment string + Instance string + Task string + type ExportReleaseResp struct + BlobstoreID string + SHA1 string + type ExportReleaseResult struct + BlobstoreID string + SHA1 string + type FSArchiveWithMetadata struct + func (a FSArchiveWithMetadata) File() (UploadFile, error) + func (a FSArchiveWithMetadata) Info() (string, string, error) + type Factory struct + func NewFactory(logger boshlog.Logger) Factory + func (f Factory) New(config Config, taskReporter TaskReporter, fileReporter FileReporter) (Director, error) + type FileReporter interface + TrackDownload func(int64, io.Writer) io.Writer + TrackUpload func(int64, io.ReadCloser) io.ReadCloser + type Host struct + Host string + HostPublicKey string + IndexOrID string + Job string + Username string + type Info struct + Auth UserAuthentication + CPI string + Features map[string]bool + Name string + UUID string + User string + Version string + type InfoFeatureResp struct + Status bool + type InfoResp struct + Auth UserAuthenticationResp + CPI string + Features map[string]InfoFeatureResp + Name string + UUID string + User string + Version string + type InstanceSlug struct + func NewInstanceSlug(name, indexOrID string) InstanceSlug + func (s *InstanceSlug) UnmarshalFlag(data string) error + func (s InstanceSlug) IndexOrID() string + func (s InstanceSlug) IsProvided() bool + func (s InstanceSlug) Name() string + func (s InstanceSlug) String() string + type Job struct + BlobstoreID string + Fingerprint string + Name string + SHA1 string + type Lock struct + ExpiresAt time.Time + Resource []string + Type string + type LockResp struct + Resource []string + Timeout string + Type string + func (l LockResp) IsForDeployment(name string) bool + type LogsResult struct + BlobstoreID string + SHA1 string + type Manifest struct + Name string + Releases []ManifestRelease + func NewManifestFromBytes(bytes []byte) (Manifest, error) + func NewManifestFromPath(path string, fs boshsys.FileSystem) (Manifest, error) + type ManifestRelease struct + Name string + SHA1 string + URL string + Version string + type NoopFileReporter struct + func NewNoopFileReporter() NoopFileReporter + func (r NoopFileReporter) TrackDownload(size int64, writer io.Writer) io.Writer + func (r NoopFileReporter) TrackUpload(size int64, reader io.ReadCloser) io.ReadCloser + type NoopTaskReporter struct + func NewNoopTaskReporter() NoopTaskReporter + func (r NoopTaskReporter) TaskFinished(id int, state string) + func (r NoopTaskReporter) TaskOutputChunk(id int, chunk []byte) + func (r NoopTaskReporter) TaskStarted(id int) + type OSVersionSlug struct + func NewOSVersionSlug(os, version string) OSVersionSlug + func (s *OSVersionSlug) UnmarshalFlag(data string) error + func (s OSVersionSlug) OS() string + func (s OSVersionSlug) String() string + func (s OSVersionSlug) Version() string + type OrphanedDisk interface + AZName func() string + CID func() string + Delete func() error + Deployment func() Deployment + InstanceName func() string + OrphanedAt func() time.Time + Size func() uint64 + type OrphanedDiskImpl struct + func (d OrphanedDiskImpl) AZName() string + func (d OrphanedDiskImpl) CID() string + func (d OrphanedDiskImpl) Delete() error + func (d OrphanedDiskImpl) Deployment() Deployment + func (d OrphanedDiskImpl) InstanceName() string + func (d OrphanedDiskImpl) OrphanedAt() time.Time + func (d OrphanedDiskImpl) Size() uint64 + type OrphanedDiskResp struct + AZ string + CID string + DeploymentName string + InstanceName string + OrphanedAt string + Size uint64 + type Package struct + BlobstoreID string + CompiledPackages []CompiledPackage + Fingerprint string + Name string + SHA1 string + type PoolOrInstanceSlug struct + func NewPoolOrInstanceSlug(name, indexOrID string) PoolOrInstanceSlug + func NewPoolOrInstanceSlugFromString(str string) (PoolOrInstanceSlug, error) + func (s PoolOrInstanceSlug) IndexOrID() string + func (s PoolOrInstanceSlug) Name() string + func (s PoolOrInstanceSlug) String() string + type PoolSlug struct + func NewPoolSlug(name string) PoolSlug + func (s *PoolSlug) UnmarshalFlag(data string) error + func (s PoolSlug) Name() string + func (s PoolSlug) String() string + type Problem struct + Data interface{} + Description string + ID int + Resolutions []ProblemResolution + Type string + type ProblemAnswer struct + ProblemID int + Resolution ProblemResolution + type ProblemResolution struct + Name string + Plan string + var ProblemResolutionDefault ProblemResolution = ProblemResolution{ ... } + type RedirectFunc func(*http.Request, []*http.Request) error + type Release interface + CommitHashWithMark func(mark string) string + Delete func(force bool) error + Jobs func() ([]Job, error) + Name func() string + Packages func() ([]Package, error) + Version func() semver.Version + VersionMark func(mark string) string + type ReleaseArchive interface + File func() (UploadFile, error) + Info func() (string, string, error) + func NewFSReleaseArchive(path string, fs boshsys.FileSystem) ReleaseArchive + func NewFSStemcellArchive(path string, fs boshsys.FileSystem) ReleaseArchive + type ReleaseImpl struct + func (r *ReleaseImpl) Jobs() ([]Job, error) + func (r *ReleaseImpl) Packages() ([]Package, error) + func (r ReleaseImpl) CommitHashWithMark(suffix string) string + func (r ReleaseImpl) Delete(force bool) error + func (r ReleaseImpl) Name() string + func (r ReleaseImpl) Version() semver.Version + func (r ReleaseImpl) VersionMark(suffix string) string + type ReleaseOrSeriesSlug struct + func NewReleaseOrSeriesSlug(name, version string) ReleaseOrSeriesSlug + func (s *ReleaseOrSeriesSlug) UnmarshalFlag(data string) error + func (s ReleaseOrSeriesSlug) Name() string + func (s ReleaseOrSeriesSlug) ReleaseSlug() (ReleaseSlug, bool) + func (s ReleaseOrSeriesSlug) SeriesSlug() ReleaseSeriesSlug + func (s ReleaseOrSeriesSlug) Version() string + type ReleaseResp struct + Jobs []Job + Packages []Package + type ReleaseSeries interface + Delete func(force bool) error + Name func() string + type ReleaseSeriesImpl struct + func (rs ReleaseSeriesImpl) Delete(force bool) error + func (rs ReleaseSeriesImpl) Name() string + type ReleaseSeriesResp struct + Name string + Versions []ReleaseVersionResp + type ReleaseSeriesSlug struct + func NewReleaseSeriesSlug(name string) ReleaseSeriesSlug + func (s *ReleaseSeriesSlug) UnmarshalFlag(data string) error + func (s ReleaseSeriesSlug) Name() string + func (s ReleaseSeriesSlug) String() string + type ReleaseSlug struct + func NewReleaseSlug(name, version string) ReleaseSlug + func (s *ReleaseSlug) UnmarshalFlag(data string) error + func (s ReleaseSlug) Name() string + func (s ReleaseSlug) String() string + func (s ReleaseSlug) Version() string + type ReleaseVersionResp struct + CommitHash string + CurrentlyDeployed bool + UncommittedChanges bool + Version string + type RequestSanitizer struct + Request http.Request + func (rs RequestSanitizer) SanitizeRequest() (http.Request, error) + type RuntimeConfig struct + Properties string + type RuntimeConfigManifest struct + Releases []RuntimeConfigManifestRelease + func NewRuntimeConfigManifestFromBytes(bytes []byte) (RuntimeConfigManifest, error) + type RuntimeConfigManifestRelease struct + Name string + SHA1 string + URL string + Version string + type SSHOpts struct + Password string + PublicKey string + Username string + func NewSSHOpts(uuidGen boshuuid.Generator) (SSHOpts, string, error) + type SSHResp struct + GatewayHost string + GatewayUser string + HostPublicKey string + ID string + IP string + Index *int + Job string + Status string + func (r SSHResp) IndexOrID() string + type SSHResult struct + GatewayHost string + GatewayUsername string + Hosts []Host + type SkipDrain struct + All bool + Slugs []PoolOrInstanceSlug + func (s *SkipDrain) UnmarshalFlag(data string) error + func (s SkipDrain) AsQueryValue() string + type Snapshot struct + CID string + Clean bool + CreatedAt time.Time + Index *int + Job string + func (s Snapshot) InstanceDesc() string + type SnapshotResp struct + Clean bool + CreatedAt string + Index *int + Job string + SnapshotCID string + type Stemcell interface + CID func() string + Delete func(force bool) error + Name func() string + OSName func() string + Version func() semver.Version + VersionMark func(mark string) string + type StemcellArchive interface + File func() (UploadFile, error) + Info func() (string, string, error) + func NewFSArchiveWithMetadata(path, fileName string, fs boshsys.FileSystem) StemcellArchive + type StemcellImpl struct + func (s StemcellImpl) CID() string + func (s StemcellImpl) Delete(force bool) error + func (s StemcellImpl) Name() string + func (s StemcellImpl) OSName() string + func (s StemcellImpl) Version() semver.Version + func (s StemcellImpl) VersionMark(suffix string) string + type StemcellResp struct + CID string + Deployments []interface{} + Name string + OperatingSystem string + Version string + type StemcellSlug struct + func NewStemcellSlug(name, version string) StemcellSlug + func (s *StemcellSlug) UnmarshalFlag(data string) error + func (s *StemcellSlug) UnmarshalJSON(data []byte) error + func (s StemcellSlug) Name() string + func (s StemcellSlug) String() string + func (s StemcellSlug) Version() string + type Task interface + CPIOutput func(TaskReporter) error + Cancel func() error + CreatedAt func() time.Time + DebugOutput func(TaskReporter) error + DeploymentName func() string + Description func() string + EventOutput func(TaskReporter) error + ID func() int + IsError func() bool + RawOutput func(TaskReporter) error + Result func() string + ResultOutput func(TaskReporter) error + State func() string + User func() string + type TaskClientRequest struct + func NewTaskClientRequest(clientRequest ClientRequest, taskReporter TaskReporter, ...) TaskClientRequest + func (r TaskClientRequest) DeleteResult(path string) ([]byte, error) + func (r TaskClientRequest) GetResult(path string) (int, []byte, error) + func (r TaskClientRequest) PostResult(path string, payload []byte, f func(*http.Request)) ([]byte, error) + func (r TaskClientRequest) PutResult(path string, payload []byte, f func(*http.Request)) ([]byte, error) + func (r TaskClientRequest) WaitForCompletion(id int, type_ string, taskReporter TaskReporter) error + type TaskImpl struct + func NewTaskFromResp(client Client, r TaskResp) TaskImpl + func (t TaskImpl) CPIOutput(taskReporter TaskReporter) error + func (t TaskImpl) Cancel() error + func (t TaskImpl) CreatedAt() time.Time + func (t TaskImpl) DebugOutput(taskReporter TaskReporter) error + func (t TaskImpl) DeploymentName() string + func (t TaskImpl) Description() string + func (t TaskImpl) EventOutput(taskReporter TaskReporter) error + func (t TaskImpl) ID() int + func (t TaskImpl) IsError() bool + func (t TaskImpl) RawOutput(taskReporter TaskReporter) error + func (t TaskImpl) Result() string + func (t TaskImpl) ResultOutput(taskReporter TaskReporter) error + func (t TaskImpl) State() string + func (t TaskImpl) User() string + type TaskReporter interface + TaskFinished func(int, string) + TaskOutputChunk func(int, []byte) + TaskStarted func(int) + type TaskResp struct + Deployment string + Description string + ID int + Result string + State string + Timestamp int64 + User string + type TimeParser struct + func (p TimeParser) Parse(s string) (time.Time, error) + type TimeoutTime time.Time + type UploadFile interface + Stat func() (os.FileInfo, error) + type UserAuthentication struct + Options map[string]interface{} + Type string + type UserAuthenticationResp struct + Options map[string]interface{} + Type string + type VMInfo struct + AZ string + AgentID string + Bootstrap bool + DNS []string + DiskID string + ID string + IPs []string + Index *int + JobName string + ProcessState string + Processes []VMInfoProcess + ResourcePool string + ResurrectionPaused bool + State string + VMID string + VMType string + Vitals VMInfoVitals + func (i VMInfo) IsRunning() bool + type VMInfoProcess struct + CPU VMInfoVitalsCPU + Mem VMInfoVitalsMemIntSize + Name string + State string + Uptime VMInfoVitalsUptime + func (p VMInfoProcess) IsRunning() bool + type VMInfoVitals struct + CPU VMInfoVitalsCPU + Disk map[string]VMInfoVitalsDiskSize + Load []string + Mem VMInfoVitalsMemSize + Swap VMInfoVitalsMemSize + Uptime VMInfoVitalsUptime + func (v VMInfoVitals) EphemeralDisk() VMInfoVitalsDiskSize + func (v VMInfoVitals) PersistentDisk() VMInfoVitalsDiskSize + func (v VMInfoVitals) SystemDisk() VMInfoVitalsDiskSize + type VMInfoVitalsCPU struct + Sys string + Total *float64 + User string + Wait string + type VMInfoVitalsDiskSize struct + InodePercent string + Percent string + type VMInfoVitalsMemIntSize struct + KB *uint64 + Percent *float64 + type VMInfoVitalsMemSize struct + KB string + Percent string + type VMInfoVitalsUptime struct + Seconds *uint64 + type VMResp struct + AgentID string + CID string + JobIndex int + JobName string