dbengine

Documentation

Index

• func SetupHTTPClient(cert string) (*http.Client, error)
• type Credentials
• type DBEngine
• type ElasticSearchEngine
  • func NewElasticSearchEngine() *ElasticSearchEngine
  • func (e *ElasticSearchEngine) Close()
  • func (e *ElasticSearchEngine) CreateUser(instanceID, bindingID string, deployment *composeapi.Deployment) (*Credentials, error)
  • func (e *ElasticSearchEngine) DropUser(instanceID, bindingID string, deployment *composeapi.Deployment) error
  • func (e *ElasticSearchEngine) Open(creds *Credentials) error
  • func (e *ElasticSearchEngine) ParseConnectionString(deployment *composeapi.Deployment) (*Credentials, error)
• type MongoEngine
  • func NewMongoEngine() *MongoEngine
  • func (m *MongoEngine) Close()
  • func (m *MongoEngine) CreateUser(instanceID, bindingID string, deployment *composeapi.Deployment) (*Credentials, error)
  • func (m *MongoEngine) DropUser(instanceID, bindingID string, deployment *composeapi.Deployment) error
  • func (m *MongoEngine) Open(credentials *Credentials) error
  • func (m *MongoEngine) ParseConnectionString(deployment *composeapi.Deployment) (*Credentials, error)
• type Provider
• type ProviderService
  • func NewProviderService() *ProviderService
  • func (p *ProviderService) GetDBEngine(engine string) (DBEngine, error)

Functions

func SetupHTTPClient

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

Types

type Credentials

type Credentials struct {
	Host                string `json:"host"`
	Port                string `json:"port"`
	Name                string `json:"name"`
	Username            string `json:"username"`
	Password            string `json:"password"`
	URI                 string `json:"uri"`
	CACertificateBase64 string `json:"ca_certificate_base64"`
}

type DBEngine

type DBEngine interface {
	ParseConnectionString(deployment *composeapi.Deployment) (*Credentials, error)
	CreateUser(instanceID, bindingID string, deployment *composeapi.Deployment) (*Credentials, error)
	DropUser(instanceID, bindingID string, deployment *composeapi.Deployment) error
	Open(*Credentials) error
	Close()
}

type ElasticSearchEngine

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

func NewElasticSearchEngine

func NewElasticSearchEngine() *ElasticSearchEngine

func (*ElasticSearchEngine) Close

func (e *ElasticSearchEngine) Close()

func (*ElasticSearchEngine) CreateUser

func (e *ElasticSearchEngine) CreateUser(instanceID, bindingID string, deployment *composeapi.Deployment) (*Credentials, error)

func (*ElasticSearchEngine) DropUser

func (e *ElasticSearchEngine) DropUser(instanceID, bindingID string, deployment *composeapi.Deployment) error

func (*ElasticSearchEngine) Open

func (e *ElasticSearchEngine) Open(creds *Credentials) error

func (*ElasticSearchEngine) ParseConnectionString

func (e *ElasticSearchEngine) ParseConnectionString(deployment *composeapi.Deployment) (*Credentials, error)

type MongoEngine

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

func NewMongoEngine

func NewMongoEngine() *MongoEngine

func (*MongoEngine) Close

func (m *MongoEngine) Close()

func (*MongoEngine) CreateUser

func (m *MongoEngine) CreateUser(instanceID, bindingID string, deployment *composeapi.Deployment) (*Credentials, error)

func (*MongoEngine) DropUser

func (m *MongoEngine) DropUser(instanceID, bindingID string, deployment *composeapi.Deployment) error

func (*MongoEngine) Open

func (m *MongoEngine) Open(credentials *Credentials) error

func (*MongoEngine) ParseConnectionString

func (m *MongoEngine) ParseConnectionString(deployment *composeapi.Deployment) (*Credentials, error)

type Provider

type Provider interface {
	GetDBEngine(engine string) (DBEngine, error)
}

type ProviderService

type ProviderService struct{}

func NewProviderService

func NewProviderService() *ProviderService

func (*ProviderService) GetDBEngine

func (p *ProviderService) GetDBEngine(engine string) (DBEngine, error)