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

database

package

Go to main page

Versions in this module

v1

v1.0.0

Aug 24, 2021

Changes in this version

type Endpoint

+ SecretKeyRef SecretKeyRef

+ type SecretKeyRef struct

+ Key string

+ Name string

v0

v0.2.0

Jun 17, 2021

Changes in this version

+ const DbmsConfigKey

+ const Mariadb

+ const Mysql

+ const OperationsConfigKey

+ const Postgres

+ const RotateMapKey

+ func GetMysqlOpQuery(operation Operation) (string, error)

+ func RenderGoTemplate(text string, values interface{}, options ...string) (string, error)

type Dbms

+ DatabaseClassName string

+ func (in *Dbms) DeepCopy() *Dbms

+ func (in *Dbms) DeepCopyInto(out *Dbms)

+ type DbmsList []Dbms

+ func (c DbmsList) GetDatabaseClassNameByEndpointName(endpointName string) string

+ func (in DbmsList) DeepCopy() DbmsList

+ func (in DbmsList) DeepCopyInto(out *DbmsList)

type Driver

+ Rotate func(operation Operation) OpOutput

type Dsn

+ func (dsn Dsn) GenMysql() (string, error)

+ func (dsn Dsn) GenPostgres() (string, error)

+ func (dsn Dsn) GenSqlserver() (string, error)

type Endpoint

+ func (in *Endpoint) DeepCopy() *Endpoint

+ func (in *Endpoint) DeepCopyInto(out *Endpoint)

+ type MysqlConn struct

+ func NewMysqlConn(dsn string) (*MysqlConn, error)

+ func (c *MysqlConn) CreateDb(operation Operation) OpOutput

+ func (c *MysqlConn) DeleteDb(operation Operation) OpOutput

+ func (c *MysqlConn) Ping() error

+ func (c *MysqlConn) Rotate(operation Operation) OpOutput

type OpOutput

+ Result map[string]string

type Operation

+ func (in *Operation) DeepCopy() *Operation

+ func (in *Operation) DeepCopyInto(out *Operation)

+ func (op Operation) RenderOperation(values OpValues) (Operation, error)

type PsqlConn

+ func (c *PsqlConn) Rotate(operation Operation) OpOutput

+ type RateLimitedDbmsConn struct

+ func NewRateLimitedDbmsConn(dbmsConn Driver, rps int) (*RateLimitedDbmsConn, error)

+ func (conn *RateLimitedDbmsConn) CreateDb(operation Operation) OpOutput

+ func (conn *RateLimitedDbmsConn) DeleteDb(operation Operation) OpOutput

+ func (conn *RateLimitedDbmsConn) Ping() error

+ type SecretFormat map[string]string

+ func (in SecretFormat) DeepCopy() SecretFormat

+ func (in SecretFormat) DeepCopyInto(out *SecretFormat)

+ func (s SecretFormat) From(toMerge map[string]string) SecretFormat

+ func (s SecretFormat) RenderSecretFormat(createOpOutput OpOutput) (SecretFormat, error)

+ type SqlserverConn struct

+ func NewSqlserverConn(dsn string) (*SqlserverConn, error)

+ func (c *SqlserverConn) CreateDb(operation Operation) OpOutput

+ func (c *SqlserverConn) DeleteDb(operation Operation) OpOutput

+ func (c *SqlserverConn) Ping() error

+ func (c *SqlserverConn) Rotate(operation Operation) OpOutput

v0.1.0

Jan 20, 2021

Changes in this version

+ const CreateMapKey

+ const DbNameMapKey

+ const DeleteMapKey

+ const ErrorOnMissingKeyOption

+ const FqdnMapKey

+ const K8sMapKey

+ const PassMapKey

+ const PortMapKey

+ const Psql

+ const Sqlserver

+ const UserMapKey

+ type Dbms struct

+ Driver string

+ Endpoints []Endpoint

+ Operations map[string]Operation

+ func (d Dbms) RenderOperation(opKey string, values OpValues) (Operation, error)

+ type DbmsConfig []Dbms

+ func (c DbmsConfig) GetByDriverAndEndpoint(driver, endpoint string) (Dbms, error)

+ type DbmsConn struct

+ func New(dsn Dsn, ops map[string]Operation) (*DbmsConn, error)

+ type Driver interface

+ CreateDb func(operation Operation) OpOutput

+ DeleteDb func(operation Operation) OpOutput

+ Ping func() error

+ type Dsn string

+ func NewDsn(driver, username, password, host, port, dbName string) Dsn

+ func (s Dsn) GetDriver() string

+ func (s Dsn) String() string

+ func (s Dsn) WithTable(table string) Dsn

+ type Endpoint struct

+ Dsn Dsn

+ Name string

+ func (e Endpoint) IsDsnPresent() bool

+ func (e Endpoint) IsNamePresent() bool

+ type MssqlConn struct

+ func NewMssqlConn(dsn Dsn) (*MssqlConn, error)

+ func (c *MssqlConn) CreateDb(operation Operation) OpOutput

+ func (c *MssqlConn) DeleteDb(operation Operation) OpOutput

+ func (c *MssqlConn) Ping() error

+ type OpOutput struct

+ Err error

+ Out []string

+ type OpValues struct

+ Metadata map[string]interface{}

+ Parameters map[string]string

+ type Operation struct

+ Inputs map[string]string

+ Name string

+ Outputs map[string]string

+ type PsqlConn struct

+ func NewPsqlConn(dsn string) (*PsqlConn, error)

+ func (c *PsqlConn) CreateDb(operation Operation) OpOutput

+ func (c *PsqlConn) DeleteDb(operation Operation) OpOutput

+ func (c *PsqlConn) Ping() error