director

package

Go to main page

Versions in this module

v6

v6.4.1

Oct 17, 2020

v6.4.0

Aug 29, 2020

v6.3.1

Jul 9, 2020

v6.3.0

Jun 17, 2020

Changes in this version

type AllOrInstanceGroupOrInstanceSlug

+ func (s AllOrInstanceGroupOrInstanceSlug) IP() string

v6.2.1

Feb 8, 2020

v6.2.0

Jan 15, 2020

Changes in this version

+ type CleanUp struct

+ CompiledPackages []CleanableCompiledPackage

+ DNSBlobs []string

+ ExportedReleases []string

+ OrphanedDisks []OrphanDiskResp

+ OrphanedVMs []OrphanedVM

+ Releases []CleanableRelease

+ Stemcells []Stemcell

+ type CleanUpResponse struct

+ CompiledPackages []CleanableCompiledPackage

+ DNSBlobs []string

+ ExportedReleases []string

+ OrphanedDisks []OrphanDiskResp

+ OrphanedVMs []OrphanedVMResponse

+ Releases []CleanableRelease

+ Stemcells []StemcellResp

+ type CleanableCompiledPackage struct

+ Name string

+ StemcellOs string

+ StemcellVersion string

+ type CleanableRelease struct

+ Name string

+ Versions []string

type VMInfo

+ Stemcell VmInfoStemcell

+ type VmInfoStemcell struct

+ ApiVersion int

+ Name string

+ Version string

v6.1.1

Oct 19, 2019

v6.1.0

Sep 14, 2019

v6.0.0

Aug 3, 2019

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

+ func NewAllOrInstanceGroupOrInstanceSlug(name, indexOrID string) AllOrInstanceGroupOrInstanceSlug

+ func NewAllOrInstanceGroupOrInstanceSlugFromString(str string) (AllOrInstanceGroupOrInstanceSlug, error)

+ func (s *AllOrInstanceGroupOrInstanceSlug) UnmarshalFlag(data string) error

+ func (s AllOrInstanceGroupOrInstanceSlug) IndexOrID() string

+ func (s AllOrInstanceGroupOrInstanceSlug) InstanceSlug() (InstanceSlug, bool)

+ func (s AllOrInstanceGroupOrInstanceSlug) Name() string

+ func (s AllOrInstanceGroupOrInstanceSlug) String() string

+ type AuthRequestAdjustment struct

+ func NewAuthRequestAdjustment(authFunc func(bool) (string, error), client, clientSecret string) AuthRequestAdjustment

+ func (a AuthRequestAdjustment) Adjust(req *http.Request, retried bool) error

+ func (a AuthRequestAdjustment) NeedsReadjustment(resp *http.Response) bool

+ type CPIConfig struct

+ Properties string

+ type CertificateExpiryInfo struct

+ DaysLeft int

+ Expiry string

+ Path string

+ type Client struct

+ func NewClient(endpoint string, httpClient *httpclient.HTTPClient, taskReporter TaskReporter, ...) Client

+ func (c Client) CPIConfigs() ([]CPIConfig, error)

+ func (c Client) CancelTask(id int) error

+ func (c Client) ChangeJobState(state, deploymentName, job, indexOrID string, skipDrain bool, 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(filter TasksFilter) ([]TaskResp, error)

+ func (c Client) DeleteDeployment(deploymentName string, force bool) error

+ func (c Client) DeleteOrphanDisk(cid string) error

+ func (c Client) DeleteOrphanNetwork(name 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) DeleteVM(cid string) error

+ func (c Client) Deployment(name string) (DeploymentResp, error)

+ func (c Client) DeploymentInstanceInfos(deploymentName string) ([]VMInfo, error)

+ func (c Client) DeploymentInstances(deploymentName string) ([]Instance, error)

+ func (c Client) DeploymentVMInfos(deploymentName string) ([]VMInfo, error)

+ func (c Client) DeploymentVMs(deploymentName string) ([]DeploymentVMResp, error)

+ func (c Client) Deployments() ([]DeploymentResp, error)

+ func (c Client) DeploymentsWithoutConfigs() ([]DeploymentResp, error)

+ func (c Client) Diff(manifest []byte, deploymentName string, doNotRedact bool) (DeploymentDiffResponse, error)

+ func (c Client) DiffCPIConfig(manifest []byte, noRedact bool) (ConfigDiffResponse, error)

+ func (c Client) DiffCloudConfig(manifest []byte) (ConfigDiffResponse, error)

+ func (c Client) DiffConfig(manifest []byte) (ConfigDiffResponse, error)

+ func (c Client) DiffConfigs(from DiffInput, to DiffInput) (ConfigDiffResponse, error)

+ func (c Client) DiffRuntimeConfig(name string, manifest []byte, noRedact bool) (ConfigDiffResponse, 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) Event(id string) (EventResp, error)

+ func (c Client) Events(opts EventsFilter) ([]EventResp, error)

+ func (c Client) ExportRelease(deploymentName string, release ReleaseSlug, os OSVersionSlug, jobs []string) (ExportReleaseResp, error)

+ func (c Client) FetchLogs(deploymentName, job, indexOrID string, filters []string, agent bool) (string, string, error)

+ func (c Client) FindTasksByContextId(contextId string) ([]TaskResp, error)

+ func (c Client) HasRelease(name, version string) (bool, error)

+ func (c Client) HasStemcell(name, version string) (bool, error)

+ func (c Client) Ignore(deploymentName, instanceGroup, indexOrID string, enabled 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) NonConvergingJobAction(action string, deployment string, instanceGroup string, id string, ...) error

+ func (c Client) OrphanDisk(cid string) error

+ func (c Client) OrphanDisks() ([]OrphanDiskResp, error)

+ func (c Client) OrphanNetworks() ([]OrphanNetworkResp, error)

+ func (c Client) OrphanedVMs() ([]OrphanedVM, error)

+ func (c Client) RecentTasks(limit int, filter TasksFilter) ([]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, whenChanged bool, ...) ([]ErrandRunResp, error)

+ func (c Client) RuntimeConfigs(name string) ([]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) StemcellNeedsUpload(stemcells StemcellInfo) (bool, bool, 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) UpdateCPIConfig(manifest []byte) error

+ func (c Client) UpdateCloudConfig(manifest []byte) error

+ func (c Client) UpdateDeployment(manifest []byte, opts UpdateOpts) error

+ func (c Client) UpdateRuntimeConfig(name string, 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

+ func (c Client) VMs() ([]VMResp, error)

+ func (c Client) WithContext(contextId string) Client

+ type ClientRequest struct

+ func NewClientRequest(endpoint string, httpClient *httpclient.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)

+ func (r ClientRequest) WithContext(contextId string) ClientRequest

+ type CloudConfig struct

+ Properties string

+ type CompiledPackage struct

+ BlobstoreID string

+ SHA1 string

+ Stemcell OSVersionSlug

+ type Config struct

+ Content string

+ CreatedAt string

+ Current bool

+ ID string

+ Name string

+ Team string

+ Type string

+ type ConfigDiff struct

+ Diff [][]interface{}

+ FromId string

+ func NewConfigDiff(diff [][]interface{}) ConfigDiff

+ func NewConfigDiffWithFromId(diff [][]interface{}, fromId string) ConfigDiff

+ type ConfigDiffResponse struct

+ Diff [][]interface{}

+ From map[string]string

+ type ConfigResponse struct

+ ExpectedLatestId string

+ LatestId string

+ type ConfigsFilter struct

+ Name string

+ Type string

+ type Deployment interface

+ AttachDisk func(slug InstanceSlug, diskCID string, diskProperties string) error

+ CleanUpSSH func(AllOrInstanceGroupOrInstanceSlug, SSHOpts) error

+ CloudConfig func() (string, error)

+ Delete func(force bool) error

+ DeleteSnapshot func(string) error

+ DeleteSnapshots func() error

+ DeleteVM func(string) error

+ Diff func([]byte, bool) (DeploymentDiff, error)

+ EnableResurrection func(InstanceSlug, bool) error

+ Errands func() ([]Errand, error)

+ ExportRelease func(ReleaseSlug, OSVersionSlug, []string) (ExportReleaseResult, error)

+ FetchLogs func(AllOrInstanceGroupOrInstanceSlug, []string, bool) (LogsResult, error)

+ Ignore func(InstanceSlug, bool) error

+ InstanceInfos func() ([]VMInfo, error)

+ Instances func() ([]Instance, error)

+ Manifest func() (string, error)

+ Name func() string

+ Recreate func(slug AllOrInstanceGroupOrInstanceSlug, opts RecreateOpts) error

+ Releases func() ([]Release, error)

+ ResolveProblems func([]ProblemAnswer) error

+ Restart func(slug AllOrInstanceGroupOrInstanceSlug, opts RestartOpts) error

+ RunErrand func(string, bool, bool, []InstanceGroupOrInstanceSlug) ([]ErrandResult, error)

+ ScanForProblems func() ([]Problem, error)

+ SetUpSSH func(AllOrInstanceGroupOrInstanceSlug, SSHOpts) (SSHResult, error)

+ Snapshots func() ([]Snapshot, error)

+ Start func(slug AllOrInstanceGroupOrInstanceSlug, opts StartOpts) error

+ Stemcells func() ([]Stemcell, error)

+ Stop func(slug AllOrInstanceGroupOrInstanceSlug, opts StopOpts) error

+ TakeSnapshot func(InstanceSlug) error

+ TakeSnapshots func() error

+ Teams func() ([]string, error)

+ Update func(manifest []byte, opts UpdateOpts) error

+ VMInfos func() ([]VMInfo, error)

+ Variables func() ([]VariableResult, error)

+ type DeploymentConfig struct

+ Config DeploymentConfigProperties

+ type DeploymentConfigProperties struct

+ Id int

+ Name string

+ Type string

+ type DeploymentConfigs struct

+ Configs []DeploymentConfig

+ func (d DeploymentConfigs) GetConfig(idx int) DeploymentConfigProperties

+ func (d DeploymentConfigs) GetConfigs() []DeploymentConfigProperties

+ type DeploymentDiff struct

+ Diff [][]interface{}

+ func NewDeploymentDiff(diff [][]interface{}, context map[string]interface{}) DeploymentDiff

+ 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) Teams() ([]string, error)

+ func (d DeploymentImpl) AttachDisk(slug InstanceSlug, diskCID string, diskProperties string) error

+ func (d DeploymentImpl) CleanUpSSH(slug AllOrInstanceGroupOrInstanceSlug, 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) DeleteVM(cid string) error

+ func (d DeploymentImpl) Diff(manifest []byte, doNotRedact bool) (DeploymentDiff, error)

+ func (d DeploymentImpl) EnableResurrection(slug InstanceSlug, enabled bool) error

+ func (d DeploymentImpl) Errands() ([]Errand, error)

+ func (d DeploymentImpl) ExportRelease(release ReleaseSlug, os OSVersionSlug, jobs []string) (ExportReleaseResult, error)

+ func (d DeploymentImpl) FetchLogs(slug AllOrInstanceGroupOrInstanceSlug, filters []string, agent bool) (LogsResult, error)

+ func (d DeploymentImpl) Ignore(slug InstanceSlug, enabled bool) error

+ func (d DeploymentImpl) InstanceInfos() ([]VMInfo, error)

+ func (d DeploymentImpl) Instances() ([]Instance, error)

+ func (d DeploymentImpl) IsInProgress() (bool, error)

+ func (d DeploymentImpl) Manifest() (string, error)

+ func (d DeploymentImpl) Name() string

+ func (d DeploymentImpl) Recreate(slug AllOrInstanceGroupOrInstanceSlug, opts RecreateOpts) error

+ func (d DeploymentImpl) ResolveProblems(answers []ProblemAnswer) error

+ func (d DeploymentImpl) Restart(slug AllOrInstanceGroupOrInstanceSlug, opts RestartOpts) error

+ func (d DeploymentImpl) RunErrand(name string, keepAlive bool, whenChanged bool, ...) ([]ErrandResult, error)

+ func (d DeploymentImpl) ScanForProblems() ([]Problem, error)

+ func (d DeploymentImpl) SetUpSSH(slug AllOrInstanceGroupOrInstanceSlug, opts SSHOpts) (SSHResult, error)

+ func (d DeploymentImpl) Snapshots() ([]Snapshot, error)

+ func (d DeploymentImpl) Start(slug AllOrInstanceGroupOrInstanceSlug, opts StartOpts) error

+ func (d DeploymentImpl) Stop(slug AllOrInstanceGroupOrInstanceSlug, opts StopOpts) error

+ func (d DeploymentImpl) TakeSnapshot(slug InstanceSlug) error

+ func (d DeploymentImpl) TakeSnapshots() error

+ func (d DeploymentImpl) Update(manifest []byte, opts UpdateOpts) error

+ func (d DeploymentImpl) VMInfos() ([]VMInfo, error)

+ func (d DeploymentImpl) Variables() ([]VariableResult, error)

+ type DeploymentReleaseResp struct

+ Name string

+ Version string

+ type DeploymentResp struct

+ CloudConfig string

+ Manifest string

+ Name string

+ Releases []DeploymentReleaseResp

+ Stemcells []DeploymentStemcellResp

+ Teams []string

+ type DeploymentStemcellResp struct

+ Name string

+ Version string

+ type DeploymentVMResp struct

+ AgentID string

+ CID string

+ JobIndex int

+ JobName string

+ type DiffConfigBody struct

+ From DiffInput

+ To DiffInput

+ type DiffConfigError struct

+ Code int

+ Description string

+ type DiffInput struct

+ Content string

+ ID string

+ type DiffLines [][]interface

+ type Director interface

+ CancelTasks func(TasksFilter) error

+ CertificateExpiry func() ([]CertificateExpiryInfo, error)

+ CleanUp func(bool) error

+ CurrentTasks func(TasksFilter) ([]Task, error)

+ DeleteConfig func(configType string, name string) (bool, error)

+ DeleteConfigByID func(configID string) (bool, error)

+ Deployments func() ([]Deployment, error)

+ DiffCPIConfig func(manifest []byte, noRedact bool) (ConfigDiff, error)

+ DiffCloudConfig func(manifest []byte) (ConfigDiff, error)

+ DiffConfig func(configType string, name string, manifest []byte) (ConfigDiff, error)

+ DiffConfigByIDOrContent func(fromID string, fromContent []byte, toID string, toContent []byte) (ConfigDiff, error)

+ DiffRuntimeConfig func(name string, manifest []byte, noRedact bool) (ConfigDiff, error)

+ DownloadResourceUnchecked func(blobstoreID string, out io.Writer) error

+ EnableResurrection func(bool) error

+ Event func(string) (Event, error)

+ Events func(EventsFilter) ([]Event, error)

+ FindDeployment func(string) (Deployment, error)

+ FindOrphanDisk func(string) (OrphanDisk, error)

+ FindOrphanNetwork func(string) (OrphanNetwork, error)

+ FindRelease func(ReleaseSlug) (Release, error)

+ FindReleaseSeries func(ReleaseSeriesSlug) (ReleaseSeries, error)

+ FindStemcell func(StemcellSlug) (Stemcell, error)

+ FindTask func(int) (Task, error)

+ FindTasksByContextId func(string) ([]Task, error)

+ HasRelease func(name, version string, stemcell OSVersionSlug) (bool, error)

+ HasStemcell func(name, version string) (bool, error)

+ Info func() (Info, error)

+ IsAuthenticated func() (bool, error)

+ LatestCPIConfig func() (CPIConfig, error)

+ LatestCloudConfig func() (CloudConfig, error)

+ LatestConfig func(configType string, name string) (Config, error)

+ LatestConfigByID func(configID string) (Config, error)

+ LatestRuntimeConfig func(name string) (RuntimeConfig, error)

+ ListConfigs func(limit int, filter ConfigsFilter) ([]Config, error)

+ ListDeploymentConfigs func(name string) (DeploymentConfigs, error)

+ ListDeployments func() ([]DeploymentResp, error)

+ Locks func() ([]Lock, error)

+ MatchPackages func(manifest interface{}, compiled bool) ([]string, error)

+ OrphanDisk func(string) error

+ OrphanDisks func() ([]OrphanDisk, error)

+ OrphanNetworks func() ([]OrphanNetwork, error)

+ OrphanedVMs func() ([]OrphanedVM, error)

+ RecentTasks func(int, TasksFilter) ([]Task, error)

+ Releases func() ([]Release, error)

+ StemcellNeedsUpload func(StemcellInfo) (bool, bool, error)

+ Stemcells func() ([]Stemcell, error)

+ UpdateCPIConfig func([]byte) error

+ UpdateCloudConfig func([]byte) error

+ UpdateConfig func(configType string, name string, expectedLatestId string, content []byte) (Config, error)

+ UpdateRuntimeConfig func(name string, manifest []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

+ WithContext func(id string) Director

+ type DirectorImpl struct

+ func (d DirectorImpl) CancelTasks(filter TasksFilter) error

+ func (d DirectorImpl) CertificateExpiry() ([]CertificateExpiryInfo, error)

+ func (d DirectorImpl) CleanUp(all bool) error

+ func (d DirectorImpl) CurrentTasks(filter TasksFilter) ([]Task, error)

+ func (d DirectorImpl) DeleteConfig(configType string, name string) (bool, error)

+ func (d DirectorImpl) DeleteConfigByID(configID string) (bool, error)

+ func (d DirectorImpl) Deployments() ([]Deployment, error)

+ func (d DirectorImpl) DiffCPIConfig(manifest []byte, noRedact bool) (ConfigDiff, error)

+ func (d DirectorImpl) DiffCloudConfig(manifest []byte) (ConfigDiff, error)

+ func (d DirectorImpl) DiffConfig(configType string, name string, manifest []byte) (ConfigDiff, error)

+ func (d DirectorImpl) DiffConfigByIDOrContent(fromID string, fromContent []byte, toID string, toContent []byte) (ConfigDiff, error)

+ func (d DirectorImpl) DiffRuntimeConfig(name string, manifest []byte, noRedact bool) (ConfigDiff, error)

+ func (d DirectorImpl) DownloadResourceUnchecked(blobstoreID string, out io.Writer) error

+ func (d DirectorImpl) EnableResurrection(enabled bool) error

+ func (d DirectorImpl) Event(id string) (Event, error)

+ func (d DirectorImpl) Events(opts EventsFilter) ([]Event, error)

+ func (d DirectorImpl) FindDeployment(name string) (Deployment, error)

+ func (d DirectorImpl) FindOrphanDisk(cid string) (OrphanDisk, error)

+ func (d DirectorImpl) FindOrphanNetwork(name string) (OrphanNetwork, 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) FindTasksByContextId(contextId string) ([]Task, error)

+ func (d DirectorImpl) HasRelease(name, version string, stemcell OSVersionSlug) (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) LatestCPIConfig() (CPIConfig, error)

+ func (d DirectorImpl) LatestCloudConfig() (CloudConfig, error)

+ func (d DirectorImpl) LatestConfig(configType string, name string) (Config, error)

+ func (d DirectorImpl) LatestConfigByID(configID string) (Config, error)

+ func (d DirectorImpl) LatestRuntimeConfig(name string) (RuntimeConfig, error)

+ func (d DirectorImpl) ListConfigs(limit int, filter ConfigsFilter) ([]Config, error)

+ func (d DirectorImpl) ListDeploymentConfigs(name string) (DeploymentConfigs, error)

+ func (d DirectorImpl) ListDeployments() ([]DeploymentResp, error)

+ func (d DirectorImpl) Locks() ([]Lock, error)

+ func (d DirectorImpl) MatchPackages(manifest interface{}, compiled bool) ([]string, error)

+ func (d DirectorImpl) NewHTTPClientRequest() ClientRequest

+ func (d DirectorImpl) OrphanDisk(cid string) error

+ func (d DirectorImpl) OrphanDisks() ([]OrphanDisk, error)

+ func (d DirectorImpl) OrphanNetworks() ([]OrphanNetwork, error)

+ func (d DirectorImpl) OrphanedVMs() ([]OrphanedVM, error)

+ func (d DirectorImpl) RecentTasks(limit int, filter TasksFilter) ([]Task, error)

+ func (d DirectorImpl) Releases() ([]Release, error)

+ func (d DirectorImpl) StemcellNeedsUpload(stemcells StemcellInfo) (bool, bool, error)

+ func (d DirectorImpl) Stemcells() ([]Stemcell, error)

+ func (d DirectorImpl) UpdateCPIConfig(manifest []byte) error

+ func (d DirectorImpl) UpdateCloudConfig(manifest []byte) error

+ func (d DirectorImpl) UpdateConfig(configType string, name string, expectedLatestId string, content []byte) (Config, error)

+ func (d DirectorImpl) UpdateRuntimeConfig(name string, 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

+ func (d DirectorImpl) WithContext(id string) Director

+ type Errand struct

+ Name string

+ type ErrandResult struct

+ ExitCode int

+ InstanceGroup string

+ InstanceID string

+ LogsBlobstoreID string

+ LogsSHA1 string

+ Stderr string

+ Stdout string

+ type ErrandRunResp struct

+ ExitCode int

+ Instance struct{ ... }

+ Logs struct{ ... }

+ Stderr string

+ Stdout string

+ type Event interface

+ Action func() string

+ Context func() map[string]interface{}

+ DeploymentName func() string

+ Error 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) Error() 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

+ Error string

+ ID string

+ Instance string

+ ObjectName string

+ ObjectType string

+ ParentID string

+ TaskID string

+ Timestamp int64

+ User string

+ type EventsFilter struct

+ Action string

+ After string

+ Before string

+ BeforeID string

+ Deployment string

+ Instance string

+ ObjectName string

+ ObjectType string

+ Task string

+ User string

+ type ExportReleaseResp struct

+ BlobstoreID string

+ SHA1 string

+ type ExportReleaseResult struct

+ BlobstoreID string

+ SHA1 string

+ type Factory struct

+ func NewFactory(logger boshlog.Logger) Factory

+ func (f Factory) New(factoryConfig FactoryConfig, taskReporter TaskReporter, ...) (Director, error)

+ type FactoryConfig struct

+ CACert string

+ Client string

+ ClientSecret string

+ Host string

+ Port int

+ TokenFunc func(bool) (string, error)

+ func NewConfigFromURL(url string) (FactoryConfig, error)

+ func (c FactoryConfig) CACertPool() (*x509.CertPool, error)

+ func (c FactoryConfig) Validate() error

+ type FileReporter interface

+ TrackDownload func(int64, io.Writer) io.Writer

+ TrackUpload func(int64, io.ReadCloser) bio.ReadSeekCloser

+ 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

+ StemcellOS string

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

+ StemcellOS string

+ StemcellVersion string

+ UUID string

+ User string

+ Version string

+ type Instance struct

+ AZ string

+ AgentID string

+ ExpectsVM bool

+ Group string

+ ID string

+ IPs []string

+ VMID string

+ type InstanceFilter struct

+ Group string

+ ID string

+ type InstanceGroupOrInstanceSlug struct

+ func NewInstanceGroupOrInstanceSlug(name, indexOrID string) InstanceGroupOrInstanceSlug

+ func NewInstanceGroupOrInstanceSlugFromString(str string) (InstanceGroupOrInstanceSlug, error)

+ func (s *InstanceGroupOrInstanceSlug) UnmarshalFlag(data string) error

+ func (s InstanceGroupOrInstanceSlug) DirectorHash() InstanceFilter

+ func (s InstanceGroupOrInstanceSlug) IndexOrID() string

+ func (s InstanceGroupOrInstanceSlug) Name() string

+ func (s InstanceGroupOrInstanceSlug) String() string

+ type InstanceGroupSlug struct

+ func NewInstanceGroupSlug(name string) InstanceGroupSlug

+ func (s *InstanceGroupSlug) UnmarshalFlag(data string) error

+ func (s InstanceGroupSlug) Name() string

+ func (s InstanceGroupSlug) String() 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

+ LinksConsumed []Link

+ LinksProvided []Link

+ Name string

+ SHA1 string

+ type Link struct

+ Name string

+ Optional bool

+ Type string

+ type Lock struct

+ ExpiresAt time.Time

+ Resource []string

+ TaskID string

+ Type string

+ type LockResp struct

+ Resource []string

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

+ Stemcell ManifestReleaseStemcell

+ URL string

+ Version string

+ type ManifestReleaseStemcell struct

+ OS 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) bio.ReadSeekCloser

+ type NoopReadSeekCloser struct

+ Reader io.ReadCloser

+ func (nrsc NoopReadSeekCloser) Close() error

+ func (nrsc NoopReadSeekCloser) Read(p []byte) (n int, err error)

+ func (nrsc NoopReadSeekCloser) Seek(offset int64, whence int) (int64, error)

+ 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) UnmarshalJSON(data []byte) error

+ func (s OSVersionSlug) IsProvided() bool

+ func (s OSVersionSlug) OS() string

+ func (s OSVersionSlug) String() string

+ func (s OSVersionSlug) Version() string

+ type OrphanDisk interface

+ AZName func() string

+ CID func() string

+ Delete func() error

+ Deployment func() Deployment

+ InstanceName func() string

+ OrphanedAt func() time.Time

+ Size func() uint64

+ type OrphanDiskImpl struct

+ func (d OrphanDiskImpl) AZName() string

+ func (d OrphanDiskImpl) CID() string

+ func (d OrphanDiskImpl) Delete() error

+ func (d OrphanDiskImpl) Deployment() Deployment

+ func (d OrphanDiskImpl) InstanceName() string

+ func (d OrphanDiskImpl) OrphanedAt() time.Time

+ func (d OrphanDiskImpl) Size() uint64

+ type OrphanDiskResp struct

+ AZ string

+ CID string

+ DeploymentName string

+ InstanceName string

+ OrphanedAt string

+ Size uint64

+ type OrphanNetwork interface

+ CreatedAt func() time.Time

+ Delete func() error

+ Name func() string

+ OrphanedAt func() time.Time

+ Type func() string

+ type OrphanNetworkImpl struct

+ func (n OrphanNetworkImpl) CreatedAt() time.Time

+ func (n OrphanNetworkImpl) Delete() error

+ func (n OrphanNetworkImpl) Name() string

+ func (n OrphanNetworkImpl) OrphanedAt() time.Time

+ func (n OrphanNetworkImpl) Type() string

+ type OrphanNetworkResp struct

+ CreatedAt string

+ Name string

+ OrphanedAt string

+ Type string

+ type OrphanedVM struct

+ AZName string

+ CID string

+ DeploymentName string

+ IPAddresses []string

+ InstanceName string

+ OrphanedAt time.Time

+ type OrphanedVMResponse struct

+ AZName string

+ CID string

+ DeploymentName string

+ IPAddresses []string

+ InstanceName string

+ OrphanedAt string

+ type Package struct

+ BlobstoreID string

+ CompiledPackages []CompiledPackage

+ Fingerprint string

+ Name string

+ SHA1 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{}

+ var ProblemResolutionSkip ProblemResolution = ProblemResolution{ ... }

+ type RecreateOpts struct

+ Canaries string

+ Converge bool

+ DryRun bool

+ Fix bool

+ Force bool

+ MaxInFlight string

+ SkipDrain bool

+ type RedirectFunc func(*http.Request, []*http.Request) error

+ type Release interface

+ CommitHashWithMark func(mark string) string

+ Delete func(force bool) error

+ Exists func() (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() (ReleaseMetadata, error)

+ func NewFSReleaseArchive(path string, fs boshsys.FileSystem) ReleaseArchive

+ type ReleaseArchiveWithMetadata struct

+ func (a ReleaseArchiveWithMetadata) File() (UploadFile, error)

+ func (a ReleaseArchiveWithMetadata) Info() (ReleaseMetadata, error)

+ 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) Exists() (bool, error)

+ func (r ReleaseImpl) Name() string

+ func (r ReleaseImpl) Version() semver.Version

+ func (r ReleaseImpl) VersionMark(suffix string) string

+ type ReleaseMetadata struct

+ Name string

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

+ Exists func() (bool, error)

+ Name func() string

+ type ReleaseSeriesImpl struct

+ func (rs ReleaseSeriesImpl) Delete(force bool) error

+ func (rs ReleaseSeriesImpl) Exists() (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 RestartOpts struct

+ Canaries string

+ Converge bool

+ Force bool

+ MaxInFlight string

+ SkipDrain bool

+ type RuntimeConfig struct

+ Properties string

+ type SSHOpts struct

+ 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 ShouldTrackDownload interface

+ ShouldTrackDownload func() bool

+ type SkipDrain struct

+ All bool

+ Slug InstanceGroupOrInstanceSlug

+ func (s *SkipDrain) UnmarshalFlag(data string) error

+ type SkipDrains []SkipDrain

+ func (s SkipDrains) 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 StartOpts struct

+ Canaries string

+ Converge bool

+ MaxInFlight string

+ type Stemcell interface

+ CID func() string

+ CPI 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() (StemcellMetadata, error)

+ func NewFSStemcellArchive(path string, fs boshsys.FileSystem) (stemcellArchive StemcellArchive)

+ type StemcellArchiveWithMetadata struct

+ func (a StemcellArchiveWithMetadata) File() (UploadFile, error)

+ func (a StemcellArchiveWithMetadata) Info() (StemcellMetadata, error)

+ type StemcellImpl struct

+ func (s StemcellImpl) CID() string

+ func (s StemcellImpl) CPI() 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 StemcellInfo struct

+ Name string

+ Version string

+ type StemcellMetadata struct

+ CloudProperties biproperty.Map

+ Name string

+ OS string

+ Version string

+ type StemcellResp struct

+ CID string

+ CPI 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 StopOpts struct

+ Canaries string

+ Converge bool

+ Force bool

+ Hard bool

+ MaxInFlight string

+ SkipDrain bool

+ type Task interface

+ CPIOutput func(TaskReporter) error

+ Cancel func() error

+ ContextID func() string

+ DebugOutput func(TaskReporter) error

+ DeploymentName func() string

+ Description func() string

+ EventOutput func(TaskReporter) error

+ FinishedAt func() time.Time

+ ID func() int

+ IsError func() bool

+ Result func() string

+ ResultOutput func(TaskReporter) error

+ StartedAt func() time.Time

+ 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) ContextID() string

+ 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) FinishedAt() time.Time

+ func (t TaskImpl) ID() int

+ func (t TaskImpl) IsError() bool

+ func (t TaskImpl) Result() string

+ func (t TaskImpl) ResultOutput(taskReporter TaskReporter) error

+ func (t TaskImpl) StartedAt() time.Time

+ 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

+ ContextId string

+ Deployment string

+ Description string

+ FinishedAt int64

+ ID int

+ Result string

+ StartedAt int64

+ State string

+ User string

+ type TasksFilter struct

+ All bool

+ Deployment string

+ States []string

+ Types []string

+ type TimeParser struct

+ func (p TimeParser) Parse(s string) (time.Time, error)

+ type TimeoutTime time.Time

+ type UpdateConfigBody struct

+ Content string

+ ExpectedLatestId string

+ Name string

+ Type string

+ type UpdateOpts struct

+ Canaries string

+ Diff DeploymentDiff

+ DryRun bool

+ Fix bool

+ MaxInFlight string

+ Recreate bool

+ RecreatePersistentDisks bool

+ SkipDrain SkipDrains

+ 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

+ Active *bool

+ AgentID string

+ Bootstrap bool

+ CloudProperties interface{}

+ DNS []string

+ Deployment string

+ DiskID string

+ DiskIDs []string

+ ID string

+ IPs []string

+ Ignore bool

+ Index *int

+ JobName string

+ ProcessState string

+ Processes []VMInfoProcess

+ ResourcePool string

+ ResurrectionPaused bool

+ State string

+ VMCreatedAt time.Time

+ VMCreatedAtRaw string

+ VMID string

+ VMType string

+ Vitals VMInfoVitals

+ func (i VMInfo) InstanceState() string

+ 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

+ VMCID string

+ type VariableResult struct

+ ID string

+ Name string

Other modules containing this package

gopkg.in/cloudfoundry/bosh-cli.v0

gopkg.in/cloudfoundry/bosh-cli.v2

gopkg.in/cloudfoundry/bosh-cli.v3

gopkg.in/cloudfoundry/bosh-cli.v4

gopkg.in/cloudfoundry/bosh-cli.v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL