Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

broker

package

Go to main page

Versions in this module

v1

v1.1.2

Oct 12, 2020

v1.1.1

Jul 31, 2020

v1.1.0

Mar 31, 2020

v1.0.0

Mar 26, 2020

Changes in this version

+ func AddFlags(o *Options)

+ func ApplyParamsToStatement(statement string, args ...string) string

+ func CanBeDeleted(status string) bool

+ func CanBeModified(status string) bool

+ func CanGetBindings(status string) bool

+ func ConflictErrorWithMessage(description string) error

+ func CrudeOSBIHacks(router *mux.Router, b *BusinessLogic)

+ func DeleteMysqlReadOnlyRole(dbInstance *DbInstance, databaseUri string, role string) error

+ func DeletePostgresReadOnlyRole(dbInstance *DbInstance, databaseUri string, role string) error

+ func FinishedTask(storage Storage, taskId string, retries int64, result string, status string)

+ func HttpWrite(w http.ResponseWriter, status int, obj interface{})

+ func InProgress(status string) bool

+ func InternalServerError() error

+ func IsAvailable(status string) bool

+ func IsReady(status string) bool

+ func NotFound() error

+ func RandomString(n int) string

+ func RestoreBackup(storage Storage, dbInstance *DbInstance, namePrefix string, backup string) error

+ func RunBackgroundTasks(ctx context.Context, o Options) error

+ func RunPreprovisionTasks(ctx context.Context, o Options, namePrefix string, storage Storage, wait int64)

+ func RunWorkerTasks(ctx context.Context, o Options, namePrefix string, storage Storage) error

+ func TickTocPreprovisionTasks(ctx context.Context, o Options, namePrefix string, storage Storage)

+ func UnprocessableEntity() error

+ func UnprocessableEntityWithMessage(err string, description string) error

+ func UpdateTaskStatus(storage Storage, taskId string, retries int64, result string, status string)

+ func UpgradeAcrossProviders(storage Storage, fromDb *DbInstance, toPlanId string, namePrefix string) (string, error)

+ func UpgradeWithinProviders(storage Storage, fromDb *DbInstance, toPlanId string, namePrefix string) (string, error)

+ type AWSClusteredProvider struct

+ func NewAWSClusteredProvider(namePrefix string) (*AWSClusteredProvider, error)

+ func (provider AWSClusteredProvider) CreateBackup(dbInstance *DbInstance) (DatabaseBackupSpec, error)

+ func (provider AWSClusteredProvider) CreateReadOnlyUser(dbInstance *DbInstance) (DatabaseUrlSpec, error)

+ func (provider AWSClusteredProvider) CreateReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider AWSClusteredProvider) DeleteReadOnlyUser(dbInstance *DbInstance, role string) error

+ func (provider AWSClusteredProvider) DeleteReadReplica(dbInstance *DbInstance) error

+ func (provider AWSClusteredProvider) Deprovision(dbInstance *DbInstance, takeSnapshot bool) error

+ func (provider AWSClusteredProvider) GetBackup(dbInstance *DbInstance, Id string) (DatabaseBackupSpec, error)

+ func (provider AWSClusteredProvider) GetInstance(name string, plan *ProviderPlan) (*DbInstance, error)

+ func (provider AWSClusteredProvider) GetLogs(dbInstance *DbInstance, path string) (string, error)

+ func (provider AWSClusteredProvider) GetReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider AWSClusteredProvider) ListBackups(dbInstance *DbInstance) ([]DatabaseBackupSpec, error)

+ func (provider AWSClusteredProvider) ListLogs(dbInstance *DbInstance) ([]DatabaseLogs, error)

+ func (provider AWSClusteredProvider) Modify(dbInstance *DbInstance, plan *ProviderPlan) (*DbInstance, error)

+ func (provider AWSClusteredProvider) PerformPostProvision(db *DbInstance) (*DbInstance, error)

+ func (provider AWSClusteredProvider) Provision(Id string, plan *ProviderPlan, Owner string) (*DbInstance, error)

+ func (provider AWSClusteredProvider) Restart(dbInstance *DbInstance) error

+ func (provider AWSClusteredProvider) RestoreBackup(dbInstance *DbInstance, Id string) error

+ func (provider AWSClusteredProvider) RotatePasswordReadOnlyUser(dbInstance *DbInstance, role string) (DatabaseUrlSpec, error)

+ func (provider AWSClusteredProvider) Tag(dbInstance *DbInstance, Name string, Value string) error

+ func (provider AWSClusteredProvider) Untag(dbInstance *DbInstance, Name string) error

+ func (provider AWSClusteredProvider) UpgradeVersion(dbInstance *DbInstance, proposed string) (*DbInstance, error)

+ type AWSClusteredProviderPrivatePlanSettings struct

+ Cluster rds.CreateDBClusterInput

+ Instance rds.CreateDBInstanceInput

+ type AWSInstanceProvider struct

+ func NewAWSInstanceProvider(namePrefix string) (*AWSInstanceProvider, error)

+ func (provider AWSInstanceProvider) CreateBackup(dbInstance *DbInstance) (DatabaseBackupSpec, error)

+ func (provider AWSInstanceProvider) CreateReadOnlyUser(dbInstance *DbInstance) (DatabaseUrlSpec, error)

+ func (provider AWSInstanceProvider) CreateReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider AWSInstanceProvider) DeleteReadOnlyUser(dbInstance *DbInstance, role string) error

+ func (provider AWSInstanceProvider) DeleteReadReplica(dbInstance *DbInstance) error

+ func (provider AWSInstanceProvider) Deprovision(dbInstance *DbInstance, takeSnapshot bool) error

+ func (provider AWSInstanceProvider) GetBackup(dbInstance *DbInstance, Id string) (DatabaseBackupSpec, error)

+ func (provider AWSInstanceProvider) GetInstance(name string, plan *ProviderPlan) (*DbInstance, error)

+ func (provider AWSInstanceProvider) GetLogs(dbInstance *DbInstance, path string) (string, error)

+ func (provider AWSInstanceProvider) GetReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider AWSInstanceProvider) ListBackups(dbInstance *DbInstance) ([]DatabaseBackupSpec, error)

+ func (provider AWSInstanceProvider) ListLogs(dbInstance *DbInstance) ([]DatabaseLogs, error)

+ func (provider AWSInstanceProvider) Modify(dbInstance *DbInstance, plan *ProviderPlan) (*DbInstance, error)

+ func (provider AWSInstanceProvider) ModifyWithSettings(dbInstance *DbInstance, plan *ProviderPlan, ...) (*DbInstance, error)

+ func (provider AWSInstanceProvider) PerformPostProvision(db *DbInstance) (*DbInstance, error)

+ func (provider AWSInstanceProvider) Provision(Id string, plan *ProviderPlan, Owner string) (*DbInstance, error)

+ func (provider AWSInstanceProvider) ProvisionWithSettings(Id string, plan *ProviderPlan, settings *rds.CreateDBInstanceInput) (*DbInstance, error)

+ func (provider AWSInstanceProvider) Restart(dbInstance *DbInstance) error

+ func (provider AWSInstanceProvider) RestoreBackup(dbInstance *DbInstance, Id string) error

+ func (provider AWSInstanceProvider) RotatePasswordReadOnlyUser(dbInstance *DbInstance, role string) (DatabaseUrlSpec, error)

+ func (provider AWSInstanceProvider) Tag(dbInstance *DbInstance, Name string, Value string) error

+ func (provider AWSInstanceProvider) Untag(dbInstance *DbInstance, Name string) error

+ func (provider AWSInstanceProvider) UpgradeVersion(dbInstance *DbInstance, proposed string, settings *rds.CreateDBInstanceInput) (*DbInstance, error)

+ type Action struct

+ type ActionBase struct

+ func (b *ActionBase) ActionSchemaHandler(w http.ResponseWriter, r *http.Request)

+ func (b *ActionBase) AddActions(name string, path string, method string, ...) error

+ func (b *ActionBase) ConvertActionsToExtensions(serviceId string) []osb.ExtensionAPI

+ func (b *ActionBase) RouteActions(router *mux.Router) error

+ type BusinessLogic struct

+ func NewBusinessLogic(ctx context.Context, o Options) (*BusinessLogic, error)

+ func (b *BusinessLogic) ActionCreateBackup(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionCreateReplica(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionCreateRole(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionDeleteReplica(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionDeleteRole(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionGetBackup(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionGetLogs(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionGetReplica(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionGetRole(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionListBackups(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionListLogs(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionListRoles(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionRestart(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionRestoreBackup(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionRotateRole(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) ActionViewLogs(InstanceID string, vars map[string]string, context *broker.RequestContext) (interface{}, error)

+ func (b *BusinessLogic) Bind(request *osb.BindRequest, c *broker.RequestContext) (*broker.BindResponse, error)

+ func (b *BusinessLogic) Deprovision(request *osb.DeprovisionRequest, c *broker.RequestContext) (*broker.DeprovisionResponse, error)

+ func (b *BusinessLogic) GetBinding(request *osb.GetBindingRequest, context *broker.RequestContext) (*osb.GetBindingResponse, error)

+ func (b *BusinessLogic) GetCatalog(c *broker.RequestContext) (*broker.CatalogResponse, error)

+ func (b *BusinessLogic) GetInstanceById(Id string) (*DbInstance, error)

+ func (b *BusinessLogic) GetUnclaimedInstance(PlanId string, InstanceId string) (*DbInstance, error)

+ func (b *BusinessLogic) LastOperation(request *osb.LastOperationRequest, c *broker.RequestContext) (*broker.LastOperationResponse, error)

+ func (b *BusinessLogic) Provision(request *osb.ProvisionRequest, c *broker.RequestContext) (*broker.ProvisionResponse, error)

+ func (b *BusinessLogic) Unbind(request *osb.UnbindRequest, c *broker.RequestContext) (*broker.UnbindResponse, error)

+ func (b *BusinessLogic) Update(request *osb.UpdateInstanceRequest, c *broker.RequestContext) (*broker.UpdateInstanceResponse, error)

+ func (b *BusinessLogic) ValidateBrokerAPIVersion(version string) error

+ type ChangePlansTaskMetadata struct

+ Plan string

+ type ChangeProvidersTaskMetadata struct

+ Plan string

+ type DatabaseBackupSpec struct

+ Created string

+ Database DatabaseSpec

+ Id *string

+ Progress *int64

+ Status *string

+ type DatabaseLogs struct

+ Name *string

+ Size *int64

+ Updated string

+ type DatabaseSpec struct

+ Name string

+ type DatabaseUrlSpec struct

+ Endpoint string

+ Password string

+ Plan string

+ Username string

+ func CreateMysqlReadOnlyRole(dbInstance *DbInstance, databaseUri string) (DatabaseUrlSpec, error)

+ func CreatePostgresReadOnlyRole(dbInstance *DbInstance, databaseUri string) (DatabaseUrlSpec, error)

+ func RotateMysqlReadOnlyRole(dbInstance *DbInstance, databaseUri string, role string) (DatabaseUrlSpec, error)

+ func RotatePostgresReadOnlyRole(dbInstance *DbInstance, databaseUri string, role string) (DatabaseUrlSpec, error)

+ type DbEntry struct

+ Claimed bool

+ Endpoint string

+ Id string

+ Name string

+ Password string

+ PlanId string

+ Status string

+ Tasks int

+ Username string

+ type DbInstance struct

+ Endpoint string

+ Engine string

+ EngineVersion string

+ Id string

+ Name string

+ Password string

+ Plan *ProviderPlan

+ ProviderId string

+ Ready bool

+ Scheme string

+ Status string

+ Username string

+ func GetInstanceById(namePrefix string, storage Storage, Id string) (*DbInstance, error)

+ func GetReplicaById(namePrefix string, storage Storage, Id string) (*DbInstance, error)

+ func (i *DbInstance) Match(other *DbInstance) bool

+ type GCloudInstanceProvider struct

+ func NewGCloudInstanceProvider(namePrefix string) (*GCloudInstanceProvider, error)

+ func (provider GCloudInstanceProvider) CreateBackup(dbInstance *DbInstance) (DatabaseBackupSpec, error)

+ func (provider GCloudInstanceProvider) CreateReadOnlyUser(dbInstance *DbInstance) (DatabaseUrlSpec, error)

+ func (provider GCloudInstanceProvider) CreateReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) DeleteReadOnlyUser(dbInstance *DbInstance, role string) error

+ func (provider GCloudInstanceProvider) DeleteReadReplica(dbInstance *DbInstance) error

+ func (provider GCloudInstanceProvider) Deprovision(dbInstance *DbInstance, takeSnapshot bool) error

+ func (provider GCloudInstanceProvider) GetBackup(dbInstance *DbInstance, Id string) (DatabaseBackupSpec, error)

+ func (provider GCloudInstanceProvider) GetInstance(name string, plan *ProviderPlan) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) GetLogs(dbInstance *DbInstance, path string) (string, error)

+ func (provider GCloudInstanceProvider) GetReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) ListBackups(dbInstance *DbInstance) ([]DatabaseBackupSpec, error)

+ func (provider GCloudInstanceProvider) ListLogs(dbInstance *DbInstance) ([]DatabaseLogs, error)

+ func (provider GCloudInstanceProvider) Modify(dbInstance *DbInstance, plan *ProviderPlan) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) ModifyWithSettings(dbInstance *DbInstance, plan *ProviderPlan, settings *sqladmin.Settings) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) PerformPostProvision(db *DbInstance) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) Provision(Id string, plan *ProviderPlan, Owner string) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) ProvisionWithSettings(Id string, plan *ProviderPlan, settings *sqladmin.DatabaseInstance, ...) (*DbInstance, error)

+ func (provider GCloudInstanceProvider) Restart(dbInstance *DbInstance) error

+ func (provider GCloudInstanceProvider) RestoreBackup(dbInstance *DbInstance, Id string) error

+ func (provider GCloudInstanceProvider) RotatePasswordReadOnlyUser(dbInstance *DbInstance, role string) (DatabaseUrlSpec, error)

+ func (provider GCloudInstanceProvider) Tag(dbInstance *DbInstance, Name string, Value string) error

+ func (provider GCloudInstanceProvider) Untag(dbInstance *DbInstance, Name string) error

+ type MysqlSharedProvider struct

+ func NewMysqlSharedProvider(namePrefix string) (MysqlSharedProvider, error)

+ func (provider MysqlSharedProvider) CreateBackup(dbInstance *DbInstance) (DatabaseBackupSpec, error)

+ func (provider MysqlSharedProvider) CreateReadOnlyUser(dbInstance *DbInstance) (DatabaseUrlSpec, error)

+ func (provider MysqlSharedProvider) CreateReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider MysqlSharedProvider) DeleteReadOnlyUser(dbInstance *DbInstance, role string) error

+ func (provider MysqlSharedProvider) DeleteReadReplica(dbInstance *DbInstance) error

+ func (provider MysqlSharedProvider) Deprovision(dbInstance *DbInstance, takeSnapshot bool) error

+ func (provider MysqlSharedProvider) GetBackup(dbInstance *DbInstance, Id string) (DatabaseBackupSpec, error)

+ func (provider MysqlSharedProvider) GetInstance(name string, plan *ProviderPlan) (*DbInstance, error)

+ func (provider MysqlSharedProvider) GetLogs(dbInstance *DbInstance, path string) (string, error)

+ func (provider MysqlSharedProvider) GetReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider MysqlSharedProvider) ListBackups(dbInstance *DbInstance) ([]DatabaseBackupSpec, error)

+ func (provider MysqlSharedProvider) ListLogs(dbInstance *DbInstance) ([]DatabaseLogs, error)

+ func (provider MysqlSharedProvider) Modify(dbInstance *DbInstance, plan *ProviderPlan) (*DbInstance, error)

+ func (provider MysqlSharedProvider) PerformPostProvision(db *DbInstance) (*DbInstance, error)

+ func (provider MysqlSharedProvider) Provision(Id string, plan *ProviderPlan, Owner string) (*DbInstance, error)

+ func (provider MysqlSharedProvider) Restart(dbInstance *DbInstance) error

+ func (provider MysqlSharedProvider) RestoreBackup(dbInstance *DbInstance, Id string) error

+ func (provider MysqlSharedProvider) RotatePasswordReadOnlyUser(dbInstance *DbInstance, role string) (DatabaseUrlSpec, error)

+ func (provider MysqlSharedProvider) Tag(dbInstance *DbInstance, Name string, Value string) error

+ func (provider MysqlSharedProvider) Untag(dbInstance *DbInstance, Name string) error

+ type MysqlSharedProviderPrivatePlanSettings struct

+ Engine string

+ EngineVersion string

+ MasterUri string

+ SchemeType string

+ func (psppps MysqlSharedProviderPrivatePlanSettings) GetMasterUriAsDsn() string

+ func (psppps MysqlSharedProviderPrivatePlanSettings) GetMasterUriWithDb(dbName string) string

+ func (psppps MysqlSharedProviderPrivatePlanSettings) GetMasterUriWithDbAsDsn(dbName string) string

+ func (psppps MysqlSharedProviderPrivatePlanSettings) MasterHost() string

+ type Options struct

+ DatabaseUrl string

+ NamePrefix string

+ type PostgresSharedProvider struct

+ func NewPostgresSharedProvider(namePrefix string) (PostgresSharedProvider, error)

+ func (provider PostgresSharedProvider) CreateBackup(dbInstance *DbInstance) (DatabaseBackupSpec, error)

+ func (provider PostgresSharedProvider) CreateReadOnlyUser(dbInstance *DbInstance) (DatabaseUrlSpec, error)

+ func (provider PostgresSharedProvider) CreateReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider PostgresSharedProvider) DeleteReadOnlyUser(dbInstance *DbInstance, role string) error

+ func (provider PostgresSharedProvider) DeleteReadReplica(dbInstance *DbInstance) error

+ func (provider PostgresSharedProvider) Deprovision(dbInstance *DbInstance, takeSnapshot bool) error

+ func (provider PostgresSharedProvider) GetBackup(dbInstance *DbInstance, Id string) (DatabaseBackupSpec, error)

+ func (provider PostgresSharedProvider) GetInstance(name string, plan *ProviderPlan) (*DbInstance, error)

+ func (provider PostgresSharedProvider) GetLogs(dbInstance *DbInstance, path string) (string, error)

+ func (provider PostgresSharedProvider) GetReadReplica(dbInstance *DbInstance) (*DbInstance, error)

+ func (provider PostgresSharedProvider) ListBackups(dbInstance *DbInstance) ([]DatabaseBackupSpec, error)

+ func (provider PostgresSharedProvider) ListLogs(dbInstance *DbInstance) ([]DatabaseLogs, error)

+ func (provider PostgresSharedProvider) Modify(dbInstance *DbInstance, plan *ProviderPlan) (*DbInstance, error)

+ func (provider PostgresSharedProvider) PerformPostProvision(db *DbInstance) (*DbInstance, error)

+ func (provider PostgresSharedProvider) Provision(Id string, plan *ProviderPlan, Owner string) (*DbInstance, error)

+ func (provider PostgresSharedProvider) Restart(dbInstance *DbInstance) error

+ func (provider PostgresSharedProvider) RestoreBackup(dbInstance *DbInstance, Id string) error

+ func (provider PostgresSharedProvider) RotatePasswordReadOnlyUser(dbInstance *DbInstance, role string) (DatabaseUrlSpec, error)

+ func (provider PostgresSharedProvider) Tag(dbInstance *DbInstance, Name string, Value string) error

+ func (provider PostgresSharedProvider) Untag(dbInstance *DbInstance, Name string) error

+ type PostgresSharedProviderPrivatePlanSettings struct

+ Engine string

+ EngineVersion string

+ MasterUri string

+ func (psppps PostgresSharedProviderPrivatePlanSettings) GetMasterUriWithDb(dbName string) string

+ func (psppps PostgresSharedProviderPrivatePlanSettings) MasterHost() string

+ type PostgresStorage struct

+ func InitStorage(ctx context.Context, o Options) (*PostgresStorage, error)

+ func (b *PostgresStorage) AddInstance(dbInstance *DbInstance) error

+ func (b *PostgresStorage) AddReplica(dbInstance *DbInstance) error

+ func (b *PostgresStorage) AddRole(dbInstance *DbInstance, username string, password string) (DatabaseUrlSpec, error)

+ func (b *PostgresStorage) AddTask(Id string, action TaskAction, metadata string) (string, error)

+ func (b *PostgresStorage) DeleteInstance(dbInstance *DbInstance) error

+ func (b *PostgresStorage) DeleteReplica(dbInstance *DbInstance) error

+ func (b *PostgresStorage) DeleteRole(dbInstance *DbInstance, username string) error

+ func (b *PostgresStorage) GetInstance(Id string) (*DbEntry, error)

+ func (b *PostgresStorage) GetPlanByID(planId string) (*ProviderPlan, error)

+ func (b *PostgresStorage) GetPlans(serviceId string) ([]ProviderPlan, error)

+ func (b *PostgresStorage) GetReplicas(dbInstance *DbInstance) (DatabaseUrlSpec, error)

+ func (b *PostgresStorage) GetRole(dbInstance *DbInstance, r string) (DatabaseUrlSpec, error)

+ func (b *PostgresStorage) GetServices() ([]osb.Service, error)

+ func (b *PostgresStorage) GetUnclaimedInstance(PlanId string, InstanceId string) (*DbEntry, error)

+ func (b *PostgresStorage) HasReplicas(dbInstance *DbInstance) (int64, error)

+ func (b *PostgresStorage) HasRole(dbInstance *DbInstance, username string) (int64, error)

+ func (b *PostgresStorage) IsRestoring(dbId string) (bool, error)

+ func (b *PostgresStorage) IsUpgrading(dbId string) (bool, error)

+ func (b *PostgresStorage) ListRoles(dbInstance *DbInstance) ([]DatabaseUrlSpec, error)

+ func (b *PostgresStorage) NukeInstance(Id string) error

+ func (b *PostgresStorage) PopPendingTask() (*Task, error)

+ func (b *PostgresStorage) ReturnClaimedInstance(Id string) error

+ func (b *PostgresStorage) StartProvisioningTasks() ([]DbEntry, error)

+ func (b *PostgresStorage) UpdateInstance(dbInstance *DbInstance, PlanId string) error

+ func (b *PostgresStorage) UpdateReplica(dbInstance *DbInstance) error

+ func (b *PostgresStorage) UpdateRole(dbInstance *DbInstance, username string, password string) (DatabaseUrlSpec, error)

+ func (b *PostgresStorage) UpdateTask(Id string, status *string, retries *int64, metadata *string, result *string, ...) error

+ func (b *PostgresStorage) ValidateInstanceID(id string) error

+ func (b *PostgresStorage) WarnOnUnfinishedTasks()

+ type Provider interface

+ CreateBackup func(*DbInstance) (DatabaseBackupSpec, error)

+ CreateReadOnlyUser func(*DbInstance) (DatabaseUrlSpec, error)

+ CreateReadReplica func(*DbInstance) (*DbInstance, error)

+ DeleteReadOnlyUser func(*DbInstance, string) error

+ DeleteReadReplica func(*DbInstance) error

+ Deprovision func(*DbInstance, bool) error

+ GetBackup func(*DbInstance, string) (DatabaseBackupSpec, error)

+ GetInstance func(string, *ProviderPlan) (*DbInstance, error)

+ GetLogs func(*DbInstance, string) (string, error)

+ GetReadReplica func(*DbInstance) (*DbInstance, error)

+ ListBackups func(*DbInstance) ([]DatabaseBackupSpec, error)

+ ListLogs func(*DbInstance) ([]DatabaseLogs, error)

+ Modify func(*DbInstance, *ProviderPlan) (*DbInstance, error)

+ PerformPostProvision func(*DbInstance) (*DbInstance, error)

+ Provision func(string, *ProviderPlan, string) (*DbInstance, error)

+ Restart func(*DbInstance) error

+ RestoreBackup func(*DbInstance, string) error

+ RotatePasswordReadOnlyUser func(*DbInstance, string) (DatabaseUrlSpec, error)

+ Tag func(*DbInstance, string, string) error

+ Untag func(*DbInstance, string) error

+ func GetProviderByPlan(namePrefix string, plan *ProviderPlan) (Provider, error)

+ type ProviderPlan struct

+ ID string

+ Provider Providers

+ Scheme string

+ type Providers string

+ const AWSCluster

+ const AWSInstance

+ const GCloudInstance

+ const MysqlShared

+ const PostgresShared

+ const Unknown

+ func GetProvidersFromString(str string) Providers

+ type RestoreDbTaskMetadata struct

+ Backup string

+ type Storage interface

+ AddInstance func(*DbInstance) error

+ AddReplica func(*DbInstance) error

+ AddRole func(*DbInstance, string, string) (DatabaseUrlSpec, error)

+ AddTask func(string, TaskAction, string) (string, error)

+ DeleteInstance func(*DbInstance) error

+ DeleteReplica func(*DbInstance) error

+ DeleteRole func(*DbInstance, string) error

+ GetInstance func(string) (*DbEntry, error)

+ GetPlanByID func(string) (*ProviderPlan, error)

+ GetPlans func(string) ([]ProviderPlan, error)

+ GetReplicas func(*DbInstance) (DatabaseUrlSpec, error)

+ GetRole func(*DbInstance, string) (DatabaseUrlSpec, error)

+ GetServices func() ([]osb.Service, error)

+ GetUnclaimedInstance func(string, string) (*DbEntry, error)

+ HasReplicas func(*DbInstance) (int64, error)

+ HasRole func(*DbInstance, string) (int64, error)

+ IsRestoring func(string) (bool, error)

+ IsUpgrading func(string) (bool, error)

+ ListRoles func(*DbInstance) ([]DatabaseUrlSpec, error)

+ NukeInstance func(string) error

+ PopPendingTask func() (*Task, error)

+ ReturnClaimedInstance func(string) error

+ StartProvisioningTasks func() ([]DbEntry, error)

+ UpdateInstance func(*DbInstance, string) error

+ UpdateReplica func(*DbInstance) error

+ UpdateRole func(*DbInstance, string, string) (DatabaseUrlSpec, error)

+ UpdateTask func(string, *string, *int64, *string, *string, *time.Time, *time.Time) error

+ ValidateInstanceID func(id string) error

+ WarnOnUnfinishedTasks func()

+ func InitFromOptions(ctx context.Context, o Options) (Storage, string, error)

+ type Task struct

+ Action TaskAction

+ DatabaseId string

+ Finished *time.Time

+ Id string

+ Metadata string

+ Result string

+ Retries int64

+ Started *time.Time

+ Status string

+ type TaskAction string

+ const ChangePlansTask

+ const ChangeProvidersTask

+ const DeleteTask

+ const NotifyCreateBindingWebhookTask

+ const NotifyCreateServiceWebhookTask

+ const PerformPostProvisionTask

+ const RestoreDbTask

+ const ResyncFromProviderTask

+ const ResyncFromProviderUntilAvailableTask

+ const ResyncReplicasFromProviderTask

+ type WebhookTaskMetadata struct

+ Secret string

+ Url string