broker

Nov 18, 2024

Changes in this version

+ type ManifestCleaner interface

+ Cleanup func(deploymentName string)

Jun 25, 2020

Changes in this version

type Broker

+ func (b *Broker) GetServiceInstanceClient(instanceID string, contextMap map[string]interface{}) (map[string]string, error)

+ func (b *Broker) SetUAAClient(uaaClient UAAClient)

+ func (b *Broker) UpdateServiceInstanceClient(instanceID, dashboardURL string, siClient map[string]string, ...) error

+ type UAAClient interface

+ CreateClient func(id, name, spaceGUID string) (map[string]string, error)

+ DeleteClient func(id string) error

+ GetClient func(id string) (map[string]string, error)

+ HasClientDefinition func() bool

+ UpdateClient func(id, redirectURI, spaceGUID string) (map[string]string, error)

Mar 24, 2020

Changes in this version

type Broker

+ SupportBackupAgentBinding bool

Jan 30, 2020

Changes in this version

type BoshClient

+ GetTasksInProgress func(deploymentName string, logger *log.Logger) (boshdirector.BoshTasks, error)

Dec 5, 2019

Changes in this version

+ type Decider interface

+ CanProvision func(catalog []domain.Service, planID string, ...) error

+ DecideOperation func(catalog []domain.Service, details domain.UpdateDetails, logger *log.Logger) (decider.Operation, error)

Oct 4, 2019

Changes in this version

type CloudFoundryClient

+ GetServiceInstances func(filter cf.GetInstancesFilter, logger *log.Logger) ([]cf.Instance, error)

Aug 20, 2019

Changes in this version

+ func NewOperationAlreadyCompletedError(e error) error

+ type OperationAlreadyCompletedError struct

+ type TelemetryLogger interface

+ LogInstances func(instanceLister service.InstanceLister, item string, operation string)

Jun 4, 2019

Changes in this version

type CloudFoundryClient

+ GetInstances func(filter cf.GetInstancesFilter, logger *log.Logger) ([]cf.Instance, error)

May 14, 2019

Changes in this version

+ const OperationTypeForceDelete

+ type MaintenanceInfoChecker interface

+ Check func(planID string, maintenanceInfo domain.MaintenanceInfo, ...) error

Feb 12, 2019

Changes in this version

type BoshClient

+ DeleteConfig func(configType, configName string, logger *log.Logger) (bool, error)

+ DeleteConfigs func(configName string, logger *log.Logger) error

+ GetConfigs func(configName string, logger *log.Logger) ([]boshdirector.BoshConfig, error)

type Broker

+ DisableBoshConfigs bool

Dec 4, 2018

Changes in this version

+ const OperationTypeRecreate

type BoshClient

+ Recreate func(deploymentName, contextID string, logger *log.Logger, ...) (int, error)

type Broker

+ func (b *Broker) Recreate(ctx context.Context, instanceID string, details brokerapi.UpdateDetails, ...) (OperationData, error)

type Deployer

+ Recreate func(deploymentName, planID, boshContextID string, logger *log.Logger) (int, error)

+ type Hasher interface

+ Hash func(m map[string]string) string

Nov 6, 2018

Changes in this version

type Broker

+ func (b *Broker) GetBinding(ctx context.Context, instanceID, bindingID string) (brokerapi.GetBindingSpec, error)

+ func (b *Broker) GetInstance(ctx context.Context, instanceID string) (brokerapi.GetInstanceDetailsSpec, error)

+ func (b *Broker) LastBindingOperation(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.LastOperation, error)

Sep 14, 2018

Changes in this version

+ const ComponentName

+ func NewDeploymentNotFoundError(e error) error

+ func NewPendingChangesNotAppliedError(e error) error

+ func NewServiceError(e error) error

type BoshClient

+ Deploy func(manifest []byte, contextID string, logger *log.Logger, ...) (int, error)

type Broker

+ EnableSecureManifests bool

+ type DeploymentNotFoundError struct

+ type ManifestSecret struct

+ Name string

+ Path string

+ Value interface{}

+ type ManifestSecretManager interface

+ DeleteSecretsForInstance func(instanceID string, logger *log.Logger) error

+ ResolveManifestSecrets func(manifest []byte, deploymentVariables []boshdirector.Variable, ...) (map[string]string, error)

+ type PendingChangesNotAppliedError struct

+ type PlanNotFoundError struct

+ PlanGUID string

+ func (e PlanNotFoundError) Error() string

+ type ServiceError struct

+ type TaskInProgressError struct

+ Message string

+ func (e TaskInProgressError) Error() string

Jul 26, 2018

Changes in this version

+ const MinimumSemverVersionForBindingWithDNS

type BoshClient

+ GetDNSAddresses func(deploymentName string, requestedDNS []config.BindingDNS) (map[string]string, error)

+ Variables func(deploymentName string, logger *log.Logger) ([]boshdirector.Variable, error)

type Broker

+ EnableResolveSecretsAtBind bool

+ type ManifestSecretResolver interface

+ ResolveManifestSecrets func(manifest []byte, deploymentVariables []boshdirector.Variable, ...) (map[string]string, error)

Apr 13, 2018

Changes in this version

type Broker

+ EnablePlanSchemas bool

+ func (b *Broker) FilteredInstances(orgName, spaceName string, logger *log.Logger) ([]service.Instance, error)

type CloudFoundryClient

+ GetInstancesOfServiceOfferingByOrgSpace func(serviceOfferingID, orgName, spaceName string, logger *log.Logger) ([]service.Instance, error)

+ type Errand struct

+ Instances []string

+ Name string

type OperationData

+ Errands []config.Errand

type ServiceAdapterClient

+ GeneratePlanSchema func(plan serviceadapter.Plan, logger *log.Logger) (brokerapi.ServiceSchemas, error)

+ type Validator struct

+ func NewValidator(rawSchema map[string]interface{}) *Validator

+ func (v *Validator) ValidateParams(params map[string]interface{}) error

+ func (v *Validator) ValidateSchema() error

Feb 16, 2018

Changes in this version

type Broker

+ ExposeOperationalErrors bool

+ type BrokerError interface

+ Error func() string

+ ErrorForCFUser func() error

type DisplayableError

+ func (e DisplayableError) ExtendedCFError() error

Nov 30, 2017

Changes in this version

type OperationData

+ PreDeleteErrand PreDeleteErrand

+ type PreDeleteErrand struct

+ Instances []string

+ Name string

Nov 16, 2017

Changes in this version

+ const MinimumMajorSemverDirectorVersionForLifecycleErrands

+ const MinimumMajorStemcellDirectorVersionForODB

type OperationData

+ PostDeployErrand PostDeployErrand

+ type PostDeployErrand struct

+ Instances []string

+ Name string

+ type StartupChecker interface

+ Check func() error

Oct 13, 2017

Changes in this version

+ const MinimumCFVersion

type BoshClient

+ GetInfo func(logger *log.Logger) (*boshdirector.Info, error)

+ VerifyAuth func(logger *log.Logger) error

Jun 14, 2017

Changes in this version

+ const UpdateLoggerAction

May 9, 2017

Changes in this version

+ const ApplyChangesDisabledMessage

+ const ApplyChangesNotPermittedMessage

+ const GenericErrorPrefix

+ const InstancePrefix

+ const OperationInProgressMessage

+ const OperationTypeBind

+ const OperationTypeCreate

+ const OperationTypeDelete

+ const OperationTypeUnbind

+ const OperationTypeUpdate

+ const OperationTypeUpgrade

+ const PendingChangesErrorMessage

+ var NilError = DisplayableError

+ func NewOperationInProgressError(e error) error

+ type BoshClient interface

+ DeleteDeployment func(name, contextID string, logger *log.Logger) (int, error)

+ GetDeployment func(name string, logger *log.Logger) ([]byte, bool, error)

+ GetDeployments func(logger *log.Logger) ([]boshclient.BoshDeployment, error)

+ GetDirectorVersion func(logger *log.Logger) (boshclient.BoshDirectorVersion, error)

+ GetNormalisedTasksByContext func(deploymentName, contextID string, logger *log.Logger) (boshclient.BoshTasks, error)

+ GetTask func(taskID int, logger *log.Logger) (boshclient.BoshTask, error)

+ GetTasks func(deploymentName string, logger *log.Logger) (boshclient.BoshTasks, error)

+ RunErrand func(deploymentName, errandName, contextID string, logger *log.Logger) (int, error)

+ VMs func(deploymentName string, logger *log.Logger) (bosh.BoshVMs, error)

+ type Broker struct

+ func New(boshClient BoshClient, cfClient CloudFoundryClient, ...) (*Broker, error)

+ func (b *Broker) Bind(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.Binding, error)

+ func (b *Broker) CountInstancesOfPlans(logger *log.Logger) (map[string]int, error)

+ func (b *Broker) Deprovision(ctx context.Context, instanceID string, _ brokerapi.DeprovisionDetails, ...) (brokerapi.DeprovisionServiceSpec, error)

+ func (b *Broker) Instances(logger *log.Logger) ([]string, error)

+ func (b *Broker) LastOperation(ctx context.Context, instanceID, operationDataRaw string) (brokerapi.LastOperation, error)

+ func (b *Broker) OrphanDeployments(logger *log.Logger) ([]string, error)

+ func (b *Broker) Provision(ctx context.Context, instanceID string, details brokerapi.ProvisionDetails, ...) (brokerapi.ProvisionedServiceSpec, error)

+ func (b *Broker) Services(_ context.Context) []brokerapi.Service

+ func (b *Broker) Unbind(ctx context.Context, instanceID, bindingID string, ...) error

+ func (b *Broker) Update(ctx context.Context, instanceID string, details brokerapi.UpdateDetails, ...) (brokerapi.UpdateServiceSpec, error)

+ func (b *Broker) Upgrade(ctx context.Context, instanceID string, logger *log.Logger) (OperationData, error)

+ type CloudFoundryClient interface

+ CountInstancesOfPlan func(serviceOfferingID, planID string, logger *log.Logger) (int, error)

+ CountInstancesOfServiceOffering func(serviceOfferingID string, logger *log.Logger) (instanceCountByPlanID map[string]int, err error)

+ GetAPIVersion func(logger *log.Logger) (string, error)

+ GetInstanceState func(serviceInstanceGUID string, logger *log.Logger) (cloud_foundry_client.InstanceState, error)

+ GetInstancesOfServiceOffering func(serviceOfferingID string, logger *log.Logger) ([]string, error)

+ type CredhubClient interface

+ PutCredentials func(identifier string, credentialsMap map[string]interface{}) error

+ type Deployer interface

+ Create func(deploymentName, planID string, requestParams map[string]interface{}, ...) (int, []byte, error)

+ Update func(deploymentName, planID string, applyPendingChanges bool, ...) (int, []byte, error)

+ Upgrade func(deploymentName, planID string, previousPlanID *string, boshContextID string, ...) (int, []byte, error)

+ type DisplayableError struct

+ func NewApplyChangesDisabledError(errForOperator error) DisplayableError

+ func NewApplyChangesNotPermittedError(errForOperator error) DisplayableError

+ func NewBoshRequestError(action string, requestError error) DisplayableError

+ func NewDisplayableError(errorForCFUser, errForOperator error) DisplayableError

+ func NewGenericError(ctx context.Context, err error) DisplayableError

+ func NewPendingChangesError(errForOperator error) DisplayableError

+ func (e DisplayableError) Error() string

+ func (e DisplayableError) ErrorForCFUser() error

+ func (e DisplayableError) Occurred() bool

+ type FeatureFlags interface

+ CFUserTriggeredUpgrades func() bool

+ type LifeCycleRunner struct

+ func NewLifeCycleRunner(boshClient BoshClient, plans config.Plans) LifeCycleRunner

+ func (l LifeCycleRunner) GetTask(deploymentName string, operationData OperationData, logger *log.Logger) (boshclient.BoshTask, error)

+ type OperationData struct

+ BoshContextID string

+ BoshTaskID int

+ OperationType OperationType

+ PlanID string

+ PostDeployErrandName string

+ type OperationInProgressError struct

+ type OperationType string

+ type ServiceAdapterClient interface

+ CreateBinding func(bindingID string, deploymentTopology bosh.BoshVMs, manifest []byte, ...) (serviceadapter.Binding, error)

+ DeleteBinding func(bindingID string, deploymentTopology bosh.BoshVMs, manifest []byte, ...) error

+ GenerateDashboardUrl func(instanceID string, plan serviceadapter.Plan, manifest []byte, ...) (string, error)