Documentation ¶
Index ¶
- func OpenDatabase(c DatabaseConnConfig) (*sqlx.DB, error)
- type Column
- type DataSource
- type DatabaseConfig
- type DatabaseConnConfig
- type DatabaseConnPoolConfig
- type DatabaseGroup
- type DatabaseInstance
- type DatabaseItem
- type DatabaseStore
- func (s *DatabaseStore) AddDatabase(config DatabaseConfig) error
- func (s *DatabaseStore) AddDatabases(databases []DatabaseConfig)
- func (s *DatabaseStore) GetDatabaseItems() []DatabaseItem
- func (s *DatabaseStore) GetTablesMetadata(groupName string, groupType string) (map[string][]string, error)
- func (s *DatabaseStore) QueryDatabase(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult
- func (s *DatabaseStore) QueryMultipleDatabases(ctx context.Context, groupType string, query string) []GroupQueryResult
- type DatabaseStoreI
- type DatabaseStoreMock
- func (d DatabaseStoreMock) AddDatabase(config DatabaseConfig) error
- func (d DatabaseStoreMock) AddDatabases(databases []DatabaseConfig)
- func (d DatabaseStoreMock) GetDatabaseItems() []DatabaseItem
- func (d DatabaseStoreMock) GetTablesMetadata(groupName string, groupType string) (map[string][]string, error)
- func (d DatabaseStoreMock) QueryDatabase(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult
- func (d DatabaseStoreMock) QueryMultipleDatabases(ctx context.Context, groupType string, query string) []GroupQueryResult
- type GroupQueryResult
- type QueryData
- type QueryError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OpenDatabase ¶
func OpenDatabase(c DatabaseConnConfig) (*sqlx.DB, error)
Types ¶
type Column ¶
Column is used to store original column name(Name) and custom name(FieldName) for json response. This is required, because sql row can contain multiple columns with same name
type DataSource ¶
type DataSource struct { DatabaseConnConfig Query string }
type DatabaseConfig ¶
type DatabaseConfig struct { DatabaseGroup DatabaseConnConfig DatabaseConnPoolConfig }
func GetDatabaseConfigsFromDataSource ¶
func GetDatabaseConfigsFromDataSource(dataSource DataSource) ([]DatabaseConfig, error)
func GetDatabaseConfigsFromDataSources ¶
func GetDatabaseConfigsFromDataSources(dataSources []DataSource) ([]DatabaseConfig, []error)
type DatabaseConnConfig ¶
type DatabaseConnPoolConfig ¶
type DatabaseGroup ¶
type DatabaseInstance ¶
type DatabaseInstance struct { Config DatabaseConfig DB *sqlx.DB }
type DatabaseItem ¶
type DatabaseItem struct { DatabaseGroup Type string `json:"type"` }
type DatabaseStore ¶
type DatabaseStore struct {
// contains filtered or unexported fields
}
func NewDatabaseStore ¶
func NewDatabaseStore() *DatabaseStore
func (*DatabaseStore) AddDatabase ¶
func (s *DatabaseStore) AddDatabase(config DatabaseConfig) error
func (*DatabaseStore) AddDatabases ¶
func (s *DatabaseStore) AddDatabases(databases []DatabaseConfig)
func (*DatabaseStore) GetDatabaseItems ¶
func (s *DatabaseStore) GetDatabaseItems() []DatabaseItem
func (*DatabaseStore) GetTablesMetadata ¶
func (*DatabaseStore) QueryDatabase ¶
func (s *DatabaseStore) QueryDatabase(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult
func (*DatabaseStore) QueryMultipleDatabases ¶
func (s *DatabaseStore) QueryMultipleDatabases(ctx context.Context, groupType string, query string) []GroupQueryResult
type DatabaseStoreI ¶
type DatabaseStoreI interface { AddDatabases(databases []DatabaseConfig) AddDatabase(config DatabaseConfig) error GetTablesMetadata(groupName string, groupType string) (map[string][]string, error) QueryDatabase(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult QueryMultipleDatabases(ctx context.Context, groupType string, query string) []GroupQueryResult GetDatabaseItems() []DatabaseItem }
type DatabaseStoreMock ¶
type DatabaseStoreMock struct { AddDatabasesFunc func(databases []DatabaseConfig) AddDatabaseFunc func(config DatabaseConfig) error GetTablesMetadataFunc func(groupName string, groupType string) (map[string][]string, error) QueryDatabaseFunc func(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult QueryMultipleDatabasesFunc func(ctx context.Context, groupType string, query string) []GroupQueryResult GetDatabaseItemsFunc func() []DatabaseItem }
func (DatabaseStoreMock) AddDatabase ¶
func (d DatabaseStoreMock) AddDatabase(config DatabaseConfig) error
func (DatabaseStoreMock) AddDatabases ¶
func (d DatabaseStoreMock) AddDatabases(databases []DatabaseConfig)
func (DatabaseStoreMock) GetDatabaseItems ¶
func (d DatabaseStoreMock) GetDatabaseItems() []DatabaseItem
func (DatabaseStoreMock) GetTablesMetadata ¶
func (DatabaseStoreMock) QueryDatabase ¶
func (d DatabaseStoreMock) QueryDatabase(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult
func (DatabaseStoreMock) QueryMultipleDatabases ¶
func (d DatabaseStoreMock) QueryMultipleDatabases(ctx context.Context, groupType string, query string) []GroupQueryResult
type GroupQueryResult ¶
type GroupQueryResult struct { GroupName string `json:"groupName"` Data *QueryData `json:"data"` Error *QueryError `json:"error"` }
type QueryError ¶
func NewQueryError ¶
func NewQueryError(err error) *QueryError
Click to show internal directories.
Click to hide internal directories.