connection

Documentation

Index

• type Manager
  • func NewManagerFromConfig(cm *config.Config) (*Manager, error)
  • func (m *Manager) AddBqConnectionFromConfig(connection *config.GoogleCloudPlatformConnection) error
  • func (m *Manager) AddHANAConnectionFromConfig(connection *config.HANAConnection) error
  • func (m *Manager) AddMongoConnectionFromConfig(connection *config.MongoConnection) error
  • func (m *Manager) AddMsSQLConnectionFromConfig(connection *config.MsSQLConnection) error
  • func (m *Manager) AddMySQLConnectionFromConfig(connection *config.MySQLConnection) error
  • func (m *Manager) AddNotionConnectionFromConfig(connection *config.NotionConnection) error
  • func (m *Manager) AddPgConnectionFromConfig(connection *config.PostgresConnection) error
  • func (m *Manager) AddRedshiftConnectionFromConfig(connection *config.PostgresConnection) error
  • func (m *Manager) AddSfConnectionFromConfig(connection *config.SnowflakeConnection) error
  • func (m *Manager) GetBqConnection(name string) (bigquery.DB, error)
  • func (m *Manager) GetBqConnectionWithoutDefault(name string) (bigquery.DB, error)
  • func (m *Manager) GetConnection(name string) (interface{}, error)
  • func (m *Manager) GetHANAConnection(name string) (*hana.Client, error)
  • func (m *Manager) GetHANAConnectionWithoutDefault(name string) (*hana.Client, error)
  • func (m *Manager) GetMongoConnection(name string) (*mongo.DB, error)
  • func (m *Manager) GetMongoConnectionWithoutDefault(name string) (*mongo.DB, error)
  • func (m *Manager) GetMsConnection(name string) (mssql.MsClient, error)
  • func (m *Manager) GetMsConnectionWithoutDefault(name string) (mssql.MsClient, error)
  • func (m *Manager) GetMySQLConnection(name string) (*mysql.Client, error)
  • func (m *Manager) GetMySQLConnectionWithoutDefault(name string) (*mysql.Client, error)
  • func (m *Manager) GetNotionConnection(name string) (*notion.Client, error)
  • func (m *Manager) GetNotionConnectionWithoutDefault(name string) (*notion.Client, error)
  • func (m *Manager) GetPgConnection(name string) (postgres.PgClient, error)
  • func (m *Manager) GetPgConnectionWithoutDefault(name string) (postgres.PgClient, error)
  • func (m *Manager) GetSfConnection(name string) (snowflake.SfClient, error)
  • func (m *Manager) GetSfConnectionWithoutDefault(name string) (snowflake.SfClient, error)

Types

type Manager

type Manager struct {
	BigQuery  map[string]*bigquery.Client
	Snowflake map[string]*snowflake.DB
	Postgres  map[string]*postgres.Client
	MsSQL     map[string]*mssql.DB
	Mongo     map[string]*mongo.DB
	Mysql     map[string]*mysql.Client
	Notion    map[string]*notion.Client
	HANA      map[string]*hana.Client
	// contains filtered or unexported fields
}

func NewManagerFromConfig

func NewManagerFromConfig(cm *config.Config) (*Manager, error)

func (*Manager) AddBqConnectionFromConfig

func (m *Manager) AddBqConnectionFromConfig(connection *config.GoogleCloudPlatformConnection) error

func (*Manager) AddHANAConnectionFromConfig

func (m *Manager) AddHANAConnectionFromConfig(connection *config.HANAConnection) error

func (*Manager) AddMongoConnectionFromConfig

func (m *Manager) AddMongoConnectionFromConfig(connection *config.MongoConnection) error

func (*Manager) AddMsSQLConnectionFromConfig

func (m *Manager) AddMsSQLConnectionFromConfig(connection *config.MsSQLConnection) error

func (*Manager) AddMySQLConnectionFromConfig

func (m *Manager) AddMySQLConnectionFromConfig(connection *config.MySQLConnection) error

func (*Manager) AddNotionConnectionFromConfig

func (m *Manager) AddNotionConnectionFromConfig(connection *config.NotionConnection) error

func (*Manager) AddPgConnectionFromConfig

func (m *Manager) AddPgConnectionFromConfig(connection *config.PostgresConnection) error

func (*Manager) AddRedshiftConnectionFromConfig

func (m *Manager) AddRedshiftConnectionFromConfig(connection *config.PostgresConnection) error

func (*Manager) AddSfConnectionFromConfig

func (m *Manager) AddSfConnectionFromConfig(connection *config.SnowflakeConnection) error

func (*Manager) GetBqConnection

func (m *Manager) GetBqConnection(name string) (bigquery.DB, error)

func (*Manager) GetBqConnectionWithoutDefault

func (m *Manager) GetBqConnectionWithoutDefault(name string) (bigquery.DB, error)

func (*Manager) GetConnection

func (m *Manager) GetConnection(name string) (interface{}, error)

func (*Manager) GetHANAConnection

func (m *Manager) GetHANAConnection(name string) (*hana.Client, error)

func (*Manager) GetHANAConnectionWithoutDefault

func (m *Manager) GetHANAConnectionWithoutDefault(name string) (*hana.Client, error)

func (*Manager) GetMongoConnection

func (m *Manager) GetMongoConnection(name string) (*mongo.DB, error)

func (*Manager) GetMongoConnectionWithoutDefault

func (m *Manager) GetMongoConnectionWithoutDefault(name string) (*mongo.DB, error)

func (*Manager) GetMsConnection

func (m *Manager) GetMsConnection(name string) (mssql.MsClient, error)

func (*Manager) GetMsConnectionWithoutDefault

func (m *Manager) GetMsConnectionWithoutDefault(name string) (mssql.MsClient, error)

func (*Manager) GetMySQLConnection

func (m *Manager) GetMySQLConnection(name string) (*mysql.Client, error)

func (*Manager) GetMySQLConnectionWithoutDefault

func (m *Manager) GetMySQLConnectionWithoutDefault(name string) (*mysql.Client, error)

func (*Manager) GetNotionConnection

func (m *Manager) GetNotionConnection(name string) (*notion.Client, error)

func (*Manager) GetNotionConnectionWithoutDefault

func (m *Manager) GetNotionConnectionWithoutDefault(name string) (*notion.Client, error)

func (*Manager) GetPgConnection

func (m *Manager) GetPgConnection(name string) (postgres.PgClient, error)

func (*Manager) GetPgConnectionWithoutDefault

func (m *Manager) GetPgConnectionWithoutDefault(name string) (postgres.PgClient, error)

func (*Manager) GetSfConnection

func (m *Manager) GetSfConnection(name string) (snowflake.SfClient, error)

func (*Manager) GetSfConnectionWithoutDefault

func (m *Manager) GetSfConnectionWithoutDefault(name string) (snowflake.SfClient, error)