dbengine

Documentation

Index

• func SetupHTTPClient(cert string) (*http.Client, error)
• type DBEngine
• type DatabaseNames
• type ElasticSearchCredentials
• type ElasticSearchEngine
  • func NewElasticSearchEngine(deployment *composeapi.Deployment) *ElasticSearchEngine
  • func (e *ElasticSearchEngine) GenerateCredentials(instanceID, bindingID string) (interface{}, error)
  • func (e *ElasticSearchEngine) RevokeCredentials(instanceID, bindingID string) error
• type MongoCredentials
• type MongoEngine
  • func NewMongoEngine(deployment *composeapi.Deployment) *MongoEngine
  • func (e *MongoEngine) GenerateCredentials(instanceID, bindingID string) (interface{}, error)
  • func (e *MongoEngine) GetDatabaseName(session MongoSession, defaultName string) (string, error)
  • func (e *MongoEngine) RevokeCredentials(instanceID, bindingID string) error
• type MongoSession
• type Provider
• type ProviderService
  • func NewProviderService() *ProviderService
  • func (p *ProviderService) GetDBEngine(deployment *composeapi.Deployment) (DBEngine, error)

Functions

func SetupHTTPClient

func SetupHTTPClient(cert string) (*http.Client, error)

Types

type DBEngine

type DBEngine interface {
	GenerateCredentials(instanceID, bindingID string) (interface{}, error)
	RevokeCredentials(instanceID, bindingID string) error
}

type DatabaseNames

type DatabaseNames struct {
	Databases []struct {
		Name  string
		Empty bool
	}
}

type ElasticSearchCredentials

type ElasticSearchCredentials struct {
	Hosts               []string `json:"hosts"`
	Name                string   `json:"name"`
	Username            string   `json:"username"`
	Password            string   `json:"password"`
	URI                 string   `json:"uri"`
	URIs                []string `json:"uris"`
	CACertificateBase64 string   `json:"ca_certificate_base64"`
}

type ElasticSearchEngine

type ElasticSearchEngine struct {
	// contains filtered or unexported fields
}

func NewElasticSearchEngine

func NewElasticSearchEngine(deployment *composeapi.Deployment) *ElasticSearchEngine

func (*ElasticSearchEngine) GenerateCredentials

func (e *ElasticSearchEngine) GenerateCredentials(instanceID, bindingID string) (interface{}, error)

func (*ElasticSearchEngine) RevokeCredentials

func (e *ElasticSearchEngine) RevokeCredentials(instanceID, bindingID string) error

type MongoCredentials

type MongoCredentials struct {
	Hosts               []string `json:"hosts"`
	Name                string   `json:"name"`
	Username            string   `json:"username"`
	Password            string   `json:"password"`
	URI                 string   `json:"uri"`
	CACertificateBase64 string   `json:"ca_certificate_base64"`
	AuthSource          string   `json:"auth_source,omitempty"`
}

type MongoEngine

type MongoEngine struct {
	// contains filtered or unexported fields
}

func NewMongoEngine

func NewMongoEngine(deployment *composeapi.Deployment) *MongoEngine

func (*MongoEngine) GenerateCredentials

func (e *MongoEngine) GenerateCredentials(instanceID, bindingID string) (interface{}, error)

func (*MongoEngine) GetDatabaseName

func (e *MongoEngine) GetDatabaseName(session MongoSession, defaultName string) (string, error)

func (*MongoEngine) RevokeCredentials

func (e *MongoEngine) RevokeCredentials(instanceID, bindingID string) error

type MongoSession

type MongoSession interface {
	Run(cmd interface{}, result interface{}) error
}

MongoSession is an incomplete interface for mgo.Session

type Provider

type Provider interface {
	GetDBEngine(*composeapi.Deployment) (DBEngine, error)
}

type ProviderService

type ProviderService struct{}

func NewProviderService

func NewProviderService() *ProviderService

func (*ProviderService) GetDBEngine

func (p *ProviderService) GetDBEngine(deployment *composeapi.Deployment) (DBEngine, error)