Versions in this module Expand all Collapse all v0 v0.0.61 Sep 10, 2016 v0.0.60 Sep 9, 2016 v0.0.59 Sep 8, 2016 v0.0.58 Sep 8, 2016 Changes in this version type VMInfo + DiskIDs []string v0.0.57 Sep 8, 2016 v0.0.56 Sep 7, 2016 v0.0.55 Sep 6, 2016 v0.0.54 Sep 6, 2016 v0.0.53 Sep 2, 2016 Changes in this version + type UpdateOpts struct + Fix bool + Recreate bool + SkipDrain SkipDrain 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
Go to main page