connection

package
v0.11.118 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
	Databricks  map[string]*databricks.DB
	Mongo       map[string]*mongo.DB
	Mysql       map[string]*mysql.Client
	Notion      map[string]*notion.Client
	HANA        map[string]*hana.Client
	Shopify     map[string]*shopify.Client
	Gorgias     map[string]*gorgias.Client
	Klaviyo     map[string]*klaviyo.Client
	Adjust      map[string]*adjust.Client
	Athena      map[string]*athena.DB
	FacebookAds map[string]*facebookads.Client
	Stripe      map[string]*stripe.Client
	Appsflyer   map[string]*appsflyer.Client
	Kafka       map[string]*kafka.Client
	Airtable    map[string]*airtable.Client

	DuckDB       map[string]*duck.Client
	Hubspot      map[string]*hubspot.Client
	GoogleSheets map[string]*gsheets.Client
	Chess        map[string]*chess.Client
	S3           map[string]*s3.Client
	Slack        map[string]*slack.Client
	Zendesk      map[string]*zendesk.Client
	// contains filtered or unexported fields
}

func NewManagerFromConfig 

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

func (*Manager) AddAdjustConnectionFromConfig added in v0.11.30 

func (m *Manager) AddAdjustConnectionFromConfig(connection *config.AdjustConnection) error

func (*Manager) AddAirtableConnectionFromConfig added in v0.11.49 

func (m *Manager) AddAirtableConnectionFromConfig(connection *config.AirtableConnection) error

func (*Manager) AddAppsflyerConnectionFromConfig added in v0.11.35 

func (m *Manager) AddAppsflyerConnectionFromConfig(connection *config.AppsflyerConnection) error

func (*Manager) AddAthenaConnectionFromConfig added in v0.11.21 

func (m *Manager) AddAthenaConnectionFromConfig(connection *config.AthenaConnection) error

func (*Manager) AddBqConnectionFromConfig 

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

func (*Manager) AddChessConnectionFromConfig added in v0.11.49 

func (m *Manager) AddChessConnectionFromConfig(connection *config.ChessConnection) error

func (*Manager) AddDatabricksConnectionFromConfig added in v0.11.20 

func (m *Manager) AddDatabricksConnectionFromConfig(connection *config.DatabricksConnection) error

func (*Manager) AddDuckDBConnectionFromConfig added in v0.11.41 

func (m *Manager) AddDuckDBConnectionFromConfig(connection *config.DuckDBConnection) error

func (*Manager) AddFacebookAdsConnectionFromConfig added in v0.11.30 

func (m *Manager) AddFacebookAdsConnectionFromConfig(connection *config.FacebookAdsConnection) error

func (*Manager) AddGoogleSheetsConnectionFromConfig added in v0.11.47 

func (m *Manager) AddGoogleSheetsConnectionFromConfig(connection *config.GoogleSheetsConnection) error

func (*Manager) AddGorgiasConnectionFromConfig added in v0.11.5 

func (m *Manager) AddGorgiasConnectionFromConfig(connection *config.GorgiasConnection) error

func (*Manager) AddHANAConnectionFromConfig added in v0.8.2 

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

func (*Manager) AddHubspotConnectionFromConfig added in v0.11.43 

func (m *Manager) AddHubspotConnectionFromConfig(connection *config.HubspotConnection) error

func (*Manager) AddKafkaConnectionFromConfig added in v0.11.40 

func (m *Manager) AddKafkaConnectionFromConfig(connection *config.KafkaConnection) error

func (*Manager) AddKlaviyoConnectionFromConfig added in v0.11.26 

func (m *Manager) AddKlaviyoConnectionFromConfig(connection *config.KlaviyoConnection) error

func (*Manager) AddMongoConnectionFromConfig added in v0.7.2 

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

func (*Manager) AddMsSQLConnectionFromConfig added in v0.5.6 

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

func (*Manager) AddMySQLConnectionFromConfig added in v0.7.8 

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

func (*Manager) AddNotionConnectionFromConfig added in v0.7.9 

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

func (*Manager) AddPgConnectionFromConfig added in v0.5.0 

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

func (*Manager) AddRedshiftConnectionFromConfig added in v0.7.0 

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

func (*Manager) AddS3ConnectionFromConfig added in v0.11.55 

func (m *Manager) AddS3ConnectionFromConfig(connection *config.S3Connection) error

func (*Manager) AddSfConnectionFromConfig added in v0.2.0 

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

func (*Manager) AddShopifyConnectionFromConfig added in v0.11.5 

func (m *Manager) AddShopifyConnectionFromConfig(connection *config.ShopifyConnection) error

func (*Manager) AddSlackConnectionFromConfig added in v0.11.62 

func (m *Manager) AddSlackConnectionFromConfig(connection *config.SlackConnection) error

func (*Manager) AddStripeConnectionFromConfig added in v0.11.32 

func (m *Manager) AddStripeConnectionFromConfig(connection *config.StripeConnection) error

func (*Manager) AddSynapseSQLConnectionFromConfig added in v0.11.55 

func (m *Manager) AddSynapseSQLConnectionFromConfig(connection *config.SynapseConnection) error

func (*Manager) AddZendeskConnectionFromConfig added in v0.11.61 

func (m *Manager) AddZendeskConnectionFromConfig(connection *config.ZendeskConnection) error

func (*Manager) GetAdjustConnection added in v0.11.30 

func (m *Manager) GetAdjustConnection(name string) (*adjust.Client, error)

func (*Manager) GetAdjustConnectionWithoutDefault added in v0.11.30 

func (m *Manager) GetAdjustConnectionWithoutDefault(name string) (*adjust.Client, error)

func (*Manager) GetAirtableConnection added in v0.11.49 

func (m *Manager) GetAirtableConnection(name string) (*airtable.Client, error)

func (*Manager) GetAirtableConnectionWithoutDefault added in v0.11.49 

func (m *Manager) GetAirtableConnectionWithoutDefault(name string) (*airtable.Client, error)

func (*Manager) GetAppsflyerConnection added in v0.11.35 

func (m *Manager) GetAppsflyerConnection(name string) (*appsflyer.Client, error)

func (*Manager) GetAppsflyerConnectionWithoutDefault added in v0.11.35 

func (m *Manager) GetAppsflyerConnectionWithoutDefault(name string) (*appsflyer.Client, error)

func (*Manager) GetAthenaConnection added in v0.11.21 

func (m *Manager) GetAthenaConnection(name string) (athena.Client, error)

func (*Manager) GetAthenaConnectionWithoutDefault added in v0.11.21 

func (m *Manager) GetAthenaConnectionWithoutDefault(name string) (athena.Client, error)

func (*Manager) GetBqConnection 

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

func (*Manager) GetBqConnectionWithoutDefault added in v0.4.3 

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

func (*Manager) GetChessConnection added in v0.11.49 

func (m *Manager) GetChessConnection(name string) (*chess.Client, error)

func (*Manager) GetChessConnectionWithoutDefault added in v0.11.49 

func (m *Manager) GetChessConnectionWithoutDefault(name string) (*chess.Client, error)

func (*Manager) GetConnection 

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

func (*Manager) GetDatabricksConnection added in v0.11.20 

func (m *Manager) GetDatabricksConnection(name string) (databricks.Client, error)

func (*Manager) GetDatabricksConnectionWithoutDefault added in v0.11.20 

func (m *Manager) GetDatabricksConnectionWithoutDefault(name string) (databricks.Client, error)

func (*Manager) GetDuckDBConnection added in v0.11.41 

func (m *Manager) GetDuckDBConnection(name string) (duck.DuckDBClient, error)

func (*Manager) GetDuckDBConnectionWithoutDefault added in v0.11.41 

func (m *Manager) GetDuckDBConnectionWithoutDefault(name string) (duck.DuckDBClient, error)

func (*Manager) GetFacebookAdsConnection added in v0.11.30 

func (m *Manager) GetFacebookAdsConnection(name string) (*facebookads.Client, error)

func (*Manager) GetFacebookAdsConnectionWithoutDefault added in v0.11.30 

func (m *Manager) GetFacebookAdsConnectionWithoutDefault(name string) (*facebookads.Client, error)

func (*Manager) GetGoogleSheetsConnection added in v0.11.47 

func (m *Manager) GetGoogleSheetsConnection(name string) (*gsheets.Client, error)

func (*Manager) GetGoogleSheetsConnectionWithoutDefault added in v0.11.47 

func (m *Manager) GetGoogleSheetsConnectionWithoutDefault(name string) (*gsheets.Client, error)

func (*Manager) GetGorgiasConnection added in v0.11.5 

func (m *Manager) GetGorgiasConnection(name string) (*gorgias.Client, error)

func (*Manager) GetGorgiasConnectionWithoutDefault added in v0.11.5 

func (m *Manager) GetGorgiasConnectionWithoutDefault(name string) (*gorgias.Client, error)

func (*Manager) GetHANAConnection added in v0.8.2 

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

func (*Manager) GetHANAConnectionWithoutDefault added in v0.8.2 

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

func (*Manager) GetHubspotConnection added in v0.11.43 

func (m *Manager) GetHubspotConnection(name string) (*hubspot.Client, error)

func (*Manager) GetHubspotConnectionWithoutDefault added in v0.11.43 

func (m *Manager) GetHubspotConnectionWithoutDefault(name string) (*hubspot.Client, error)

func (*Manager) GetKafkaConnection added in v0.11.40 

func (m *Manager) GetKafkaConnection(name string) (*kafka.Client, error)

func (*Manager) GetKafkaConnectionWithoutDefault added in v0.11.40 

func (m *Manager) GetKafkaConnectionWithoutDefault(name string) (*kafka.Client, error)

func (*Manager) GetKlaviyoConnection added in v0.11.26 

func (m *Manager) GetKlaviyoConnection(name string) (*klaviyo.Client, error)

func (*Manager) GetKlaviyoConnectionWithoutDefault added in v0.11.26 

func (m *Manager) GetKlaviyoConnectionWithoutDefault(name string) (*klaviyo.Client, error)

func (*Manager) GetMongoConnection added in v0.7.2 

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

func (*Manager) GetMongoConnectionWithoutDefault added in v0.7.2 

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

func (*Manager) GetMsConnection added in v0.5.6 

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

func (*Manager) GetMsConnectionWithoutDefault added in v0.5.6 

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

func (*Manager) GetMySQLConnection added in v0.7.8 

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

func (*Manager) GetMySQLConnectionWithoutDefault added in v0.7.8 

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

func (*Manager) GetNotionConnection added in v0.7.9 

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

func (*Manager) GetNotionConnectionWithoutDefault added in v0.7.9 

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

func (*Manager) GetPgConnection added in v0.5.0 

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

func (*Manager) GetPgConnectionWithoutDefault added in v0.5.0 

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

func (*Manager) GetS3Connection added in v0.11.55 

func (m *Manager) GetS3Connection(name string) (*s3.Client, error)

func (*Manager) GetS3ConnectionWithoutDefault added in v0.11.55 

func (m *Manager) GetS3ConnectionWithoutDefault(name string) (*s3.Client, error)

func (*Manager) GetSfConnection added in v0.2.0 

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

func (*Manager) GetSfConnectionWithoutDefault added in v0.4.3 

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

func (*Manager) GetShopifyConnection added in v0.11.5 

func (m *Manager) GetShopifyConnection(name string) (*shopify.Client, error)

func (*Manager) GetShopifyConnectionWithoutDefault added in v0.11.5 

func (m *Manager) GetShopifyConnectionWithoutDefault(name string) (*shopify.Client, error)

func (*Manager) GetSlackConnection added in v0.11.62 

func (m *Manager) GetSlackConnection(name string) (*slack.Client, error)

func (*Manager) GetSlackConnectionWithoutDefault added in v0.11.62 

func (m *Manager) GetSlackConnectionWithoutDefault(name string) (*slack.Client, error)

func (*Manager) GetStripeConnection added in v0.11.32 

func (m *Manager) GetStripeConnection(name string) (*stripe.Client, error)

func (*Manager) GetStripeConnectionWithoutDefault added in v0.11.32 

func (m *Manager) GetStripeConnectionWithoutDefault(name string) (*stripe.Client, error)

func (*Manager) GetZendeskConnection added in v0.11.61 

func (m *Manager) GetZendeskConnection(name string) (*zendesk.Client, error)

func (*Manager) GetZendeskConnectionWithoutDefault added in v0.11.61 

func (m *Manager) GetZendeskConnectionWithoutDefault(name string) (*zendesk.Client, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.