broker

Dec 15, 2023

Changes in this version

+ const DefaultHost

type Config

+ Host string

+ TLS *TLSConfig

+ func (c Config) TLSEnabled() bool

+ type TLSConfig struct

+ Certificate string

+ PrivateKey string

+ func (t *TLSConfig) GenerateTLSConfig() (*tls.Config, error)

+ func (t *TLSConfig) Validate() error

Dec 13, 2022

Changes in this version

+ const ActionFailover

+ const FailoverTimeout

+ const TestFailover

type Operation

+ PrimaryNode string

+ TimeOut string

type UpdateParameters

+ TestFailover *bool

Nov 2, 2022

Changes in this version

+ const ParamPreferredMaintenanceWindow

type UpdateParameters

+ PreferredMaintenanceWindow string

Aug 17, 2022

Changes in this version

type PlanConfig

+ MultiAZEnabled bool

Mar 19, 2020

Changes in this version

type Broker

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

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

+ func (b *Broker) LastBindingOperation(ctx context.Context, first, second string, pollDetails brokerapi.PollDetails) (brokerapi.LastOperation, error)

Mar 3, 2020

Changes in this version

type PlanConfig

+ CacheParameterGroupFamily string

+ Engine string

+ EngineVersion string

Apr 16, 2018

Changes in this version

type Config

+ KmsKeyID string

+ SecretsManagerPath string

Feb 15, 2018

Changes in this version

+ const ParamMaxMemoryPolicy

+ const ParamRestoreLatestSnapshotOf

type ProvisionParameters

+ MaxMemoryPolicy *string

type UpdateParameters

+ MaxMemoryPolicy *string

Feb 14, 2018

Changes in this version

+ type ByCreateTime []providers.SnapshotInfo

+ func (ct ByCreateTime) Len() int

+ func (ct ByCreateTime) Less(i, j int) bool

+ func (ct ByCreateTime) Swap(i, j int)

type ProvisionParameters

+ RestoreFromLatestSnapshotOf *string

+ func ParseProvisionParameters(data []byte) (*ProvisionParameters, error)

Dec 7, 2017

Changes in this version

+ const ActionDeprovisioning

+ const ActionProvisioning

+ const ActionUpdating

+ type Operation struct

+ Action string

+ func (o Operation) String() string

type Provider

+ DeleteCacheParameterGroup func(ctx context.Context, instanceID string) error

Nov 27, 2017

Changes in this version

+ type Credentials struct

+ Host string

+ Name string

+ Password string

+ Port int64

+ TLSEnabled bool

+ URI string

type Provider

+ GenerateCredentials func(ctx context.Context, instanceID, bindingID string) (*Credentials, error)

+ RevokeCredentials func(ctx context.Context, instanceID, bindingID string) error

Nov 23, 2017

Changes in this version

+ var ErrNoSuchPlan = errors.New("no plan found")

+ func ProviderStatesMapping(state ServiceState) (brokerapi.LastOperationState, error)

+ type BindParameters struct

+ type Broker struct

+ func New(config Config, provider Provider, logger lager.Logger) *Broker

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

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

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

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

+ func (b *Broker) Services(ctx 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)

+ type Config struct

+ AllowUserBindParameters bool

+ AllowUserProvisionParameters bool

+ AllowUserUpdateParameters bool

+ AuthTokenSeed string

+ BrokerName string

+ CacheSubnetGroupName string

+ Catalog brokerapi.CatalogResponse

+ ClusterNamePrefix string

+ LogLevel string

+ Password string

+ PlanConfigs map[string]PlanConfig

+ Region string

+ Username string

+ VpcSecurityGroupIds []string

+ func LoadConfig(configFile string) (config Config, err error)

+ func (c Config) GetPlanConfig(planID string) (PlanConfig, error)

+ func (c Config) Validate() error

+ type DeprovisionParameters struct

+ FinalSnapshotIdentifier string

+ type PlanConfig struct

+ AutomaticFailoverEnabled bool

+ InstanceType string

+ Parameters map[string]string

+ ReplicasPerNodeGroup int64

+ ShardCount int64

+ SnapshotRetentionLimit int64

+ type Provider interface

+ Deprovision func(ctx context.Context, instanceID string, params DeprovisionParameters) error

+ GetState func(ctx context.Context, instanceID string) (ServiceState, string, error)

+ Provision func(ctx context.Context, instanceID string, params ProvisionParameters) error

+ type ProvisionParameters struct

+ AuthToken string

+ AutomaticFailoverEnabled bool

+ CacheParameterGroupName string

+ CacheSubnetGroupName string

+ Description string

+ InstanceType string

+ Parameters map[string]string

+ PreferredMaintenanceWindow string

+ ReplicasPerNodeGroup int64

+ SecurityGroupIds []string

+ ShardCount int64

+ SnapshotRetentionLimit int64

+ Tags map[string]string

+ type ServiceState string

+ const Available

+ const CreateFailed

+ const Creating

+ const Deleting

+ const Modifying

+ const NonExisting

+ const Snapshotting

+ type UpdateParameters struct