connection

package
v0.11.469 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2026 License: Apache-2.0 Imports: 103 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewManagerFromConfig 

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

NewManagerFromConfig creates a connection Manager using a background context. Prefer NewManagerFromConfigWithContext to propagate cancellation and deadlines.

func NewManagerFromConfigWithContext added in v0.11.327 

func NewManagerFromConfigWithContext(ctx context.Context, cm *config.Config) (config.ConnectionAndDetailsGetter, []error)

NewManagerFromConfigWithContext creates a connection Manager using the provided context for any connection initializations that support context (e.g., Postgres/Redshift).

Types

type Manager 

type Manager struct {
	AllConnectionDetails map[string]any

	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
	Fabric             map[string]*fabric.DB
	Mongo              map[string]*mongo.DB
	Couchbase          map[string]*couchbase.DB
	Cursor             map[string]*cursor.Client
	MongoAtlas         map[string]*mongoatlas.DB
	Mysql              map[string]*mysql.Client
	Notion             map[string]*notion.Client
	Allium             map[string]*allium.Client
	HANA               map[string]*hana.Client
	Hostaway           map[string]*hostaway.Client
	Shopify            map[string]*shopify.Client
	Gorgias            map[string]*gorgias.Client
	Klaviyo            map[string]*klaviyo.Client
	Adjust             map[string]*adjust.Client
	Anthropic          map[string]*anthropic.Client
	Intercom           map[string]*intercom.Client
	Athena             map[string]*athena.DB
	Aws                map[string]*config.AwsConnection
	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
	Socrata            map[string]*socrata.Client
	Asana              map[string]*asana.Client
	DynamoDB           map[string]*dynamodb.Client
	Docebo             map[string]*docebo.Client
	Zendesk            map[string]*zendesk.Client
	GoogleAds          map[string]*googleads.Client
	TikTokAds          map[string]*tiktokads.Client
	SnapchatAds        map[string]*snapchatads.Client
	GitHub             map[string]*github.Client
	AppStore           map[string]*appstore.Client
	LinkedInAds        map[string]*linkedinads.Client
	Mailchimp          map[string]*mailchimp.Client
	Linear             map[string]*linear.Client
	RevenueCat         map[string]*revenuecat.Client
	ClickHouse         map[string]*clickhouse.Client
	GCS                map[string]*gcs.Client
	ApplovinMax        map[string]*applovinmax.Client
	Personio           map[string]*personio.Client
	Kinesis            map[string]*kinesis.Client
	Pipedrive          map[string]*pipedrive.Client
	Mixpanel           map[string]*mixpanel.Client
	Clickup            map[string]*clickup.Client
	Pinterest          map[string]*pinterest.Client
	Trustpilot         map[string]*trustpilot.Client
	QuickBooks         map[string]*quickbooks.Client
	Wise               map[string]*wise.Client
	Zoom               map[string]*zoom.Client
	Frankfurter        map[string]*frankfurter.Client
	Fluxx              map[string]*fluxx.Client
	Freshdesk          map[string]*freshdesk.Client
	FundraiseUp        map[string]*fundraiseup.Client
	Fireflies          map[string]*fireflies.Client
	Jira               map[string]*jira.Client
	Monday             map[string]*monday.Client
	PlusVibeAI         map[string]*plusvibeai.Client
	BruinCloud         map[string]*bruincloud.Client
	Primer             map[string]*primer.Client
	Indeed             map[string]*indeed.Client
	EMRSeverless       map[string]*emr_serverless.Client
	DataprocServerless map[string]*dataprocserverless.Client
	GoogleAnalytics    map[string]*googleanalytics.Client
	AppLovin           map[string]*applovin.Client
	Salesforce         map[string]*salesforce.Client
	SQLite             map[string]*sqlite.Client
	DB2                map[string]*db2.Client
	Oracle             map[string]*oracle.Client
	Phantombuster      map[string]*phantombuster.Client
	Elasticsearch      map[string]*elasticsearch.Client
	Spanner            map[string]*spanner.Client
	Solidgate          map[string]*solidgate.Client
	Smartsheet         map[string]*smartsheet.Client
	Attio              map[string]*attio.Client
	Sftp               map[string]*sftp.Client
	ISOCPulse          map[string]*isocpulse.Client
	InfluxDB           map[string]*influxdb.Client
	Tableau            map[string]*tableau.Client
	Trino              map[string]*trino.Client
	CustomerIo         map[string]*customerio.Client
	Generic            map[string]*config.GenericConnection
	// contains filtered or unexported fields
}

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) AddAlliumConnectionFromConfig added in v0.11.324 

func (m *Manager) AddAlliumConnectionFromConfig(connection *config.AlliumConnection) error

func (*Manager) AddAnthropicConnectionFromConfig added in v0.11.296 

func (m *Manager) AddAnthropicConnectionFromConfig(connection *config.AnthropicConnection) error

func (*Manager) AddAppLovinConnectionFromConfig added in v0.11.186 

func (m *Manager) AddAppLovinConnectionFromConfig(connection *config.AppLovinConnection) error

func (*Manager) AddAppStoreConnectionFromConfig added in v0.11.132 

func (m *Manager) AddAppStoreConnectionFromConfig(connection *config.AppStoreConnection) error

func (*Manager) AddApplovinMaxConnectionFromConfig added in v0.11.138 

func (m *Manager) AddApplovinMaxConnectionFromConfig(connection *config.ApplovinMaxConnection) error

func (*Manager) AddAppsflyerConnectionFromConfig added in v0.11.35 

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

func (*Manager) AddAsanaConnectionFromConfig added in v0.11.123 

func (m *Manager) AddAsanaConnectionFromConfig(connection *config.AsanaConnection) error

func (*Manager) AddAthenaConnectionFromConfig added in v0.11.21 

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

func (*Manager) AddAttioConnectionFromConfig added in v0.11.220 

func (m *Manager) AddAttioConnectionFromConfig(connection *config.AttioConnection) error

func (*Manager) AddAwsConnectionFromConfig added in v0.11.20 

func (m *Manager) AddAwsConnectionFromConfig(connection *config.AwsConnection) error

func (*Manager) AddBqConnectionFromConfig 

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

func (*Manager) AddBruinCloudConnectionFromConfig added in v0.11.377 

func (m *Manager) AddBruinCloudConnectionFromConfig(connection *config.BruinCloudConnection) error

func (*Manager) AddChessConnectionFromConfig added in v0.11.49 

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

func (*Manager) AddClickHouseConnectionFromConfig added in v0.11.133 

func (m *Manager) AddClickHouseConnectionFromConfig(connection *config.ClickHouseConnection) error

func (*Manager) AddClickupConnectionFromConfig added in v0.11.264 

func (m *Manager) AddClickupConnectionFromConfig(connection *config.ClickupConnection) error

func (*Manager) AddCouchbaseConnectionFromConfig added in v0.11.328 

func (m *Manager) AddCouchbaseConnectionFromConfig(connection *config.CouchbaseConnection) error

func (*Manager) AddCursorConnectionFromConfig added in v0.11.337 

func (m *Manager) AddCursorConnectionFromConfig(connection *config.CursorConnection) error

func (*Manager) AddCustomerIoConnectionFromConfig added in v0.11.436 

func (m *Manager) AddCustomerIoConnectionFromConfig(connection *config.CustomerIoConnection) error

func (*Manager) AddDB2ConnectionFromConfig added in v0.11.191 

func (m *Manager) AddDB2ConnectionFromConfig(connection *config.DB2Connection) error

func (*Manager) AddDatabricksConnectionFromConfig added in v0.11.20 

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

func (*Manager) AddDataprocServerlessConnectionFromConfig added in v0.11.391 

func (m *Manager) AddDataprocServerlessConnectionFromConfig(connection *config.DataprocServerlessConnection) error

func (*Manager) AddDoceboConnectionFromConfig added in v0.11.296 

func (m *Manager) AddDoceboConnectionFromConfig(connection *config.DoceboConnection) error

func (*Manager) AddDuckDBConnectionFromConfig added in v0.11.41 

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

func (*Manager) AddDynamoDBConnectionFromConfig added in v0.11.123 

func (m *Manager) AddDynamoDBConnectionFromConfig(connection *config.DynamoDBConnection) error

func (*Manager) AddEMRServerlessConnectionFromConfig added in v0.11.187 

func (m *Manager) AddEMRServerlessConnectionFromConfig(connection *config.EMRServerlessConnection) error

func (*Manager) AddElasticsearchConnectionFromConfig added in v0.11.209 

func (m *Manager) AddElasticsearchConnectionFromConfig(connection *config.ElasticsearchConnection) error

func (*Manager) AddFabricConnectionFromConfig added in v0.11.450 

func (m *Manager) AddFabricConnectionFromConfig(connection *config.FabricConnection) error

func (*Manager) AddFacebookAdsConnectionFromConfig added in v0.11.30 

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

func (*Manager) AddFirefliesConnectionFromConfig added in v0.11.409 

func (m *Manager) AddFirefliesConnectionFromConfig(connection *config.FirefliesConnection) error

func (*Manager) AddFluxxConnectionFromConfig added in v0.11.287 

func (m *Manager) AddFluxxConnectionFromConfig(connection *config.FluxxConnection) error

func (*Manager) AddFrankfurterConnectionFromConfig added in v0.11.189 

func (m *Manager) AddFrankfurterConnectionFromConfig(connection *config.FrankfurterConnection) error

func (*Manager) AddFreshdeskConnectionFromConfig added in v0.11.311 

func (m *Manager) AddFreshdeskConnectionFromConfig(connection *config.FreshdeskConnection) error

func (*Manager) AddFundraiseUpConnectionFromConfig added in v0.11.296 

func (m *Manager) AddFundraiseUpConnectionFromConfig(connection *config.FundraiseUpConnection) error

func (*Manager) AddGCSConnectionFromConfig added in v0.11.136 

func (m *Manager) AddGCSConnectionFromConfig(connection *config.GCSConnection) error

func (*Manager) AddGenericConnectionFromConfig added in v0.11.261 

func (m *Manager) AddGenericConnectionFromConfig(connection *config.GenericConnection) error

func (*Manager) AddGitHubConnectionFromConfig added in v0.11.130 

func (m *Manager) AddGitHubConnectionFromConfig(connection *config.GitHubConnection) error

func (*Manager) AddGoogleAdsConnectionFromConfig added in v0.11.136 

func (m *Manager) AddGoogleAdsConnectionFromConfig(connection *config.GoogleAdsConnection) error

func (*Manager) AddGoogleAnalyticsConnectionFromConfig added in v0.11.184 

func (m *Manager) AddGoogleAnalyticsConnectionFromConfig(connection *config.GoogleAnalyticsConnection) 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) AddHostawayConnectionFromConfig added in v0.11.331 

func (m *Manager) AddHostawayConnectionFromConfig(connection *config.HostawayConnection) error

func (*Manager) AddHubspotConnectionFromConfig added in v0.11.43 

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

func (*Manager) AddISOCPulseConnectionFromConfig added in v0.11.244 

func (m *Manager) AddISOCPulseConnectionFromConfig(connection *config.ISOCPulseConnection) error

func (*Manager) AddIndeedConnectionFromConfig added in v0.11.401 

func (m *Manager) AddIndeedConnectionFromConfig(connection *config.IndeedConnection) error

func (*Manager) AddInfluxDBConnectionFromConfig added in v0.11.270 

func (m *Manager) AddInfluxDBConnectionFromConfig(connection *config.InfluxDBConnection) error

func (*Manager) AddIntercomConnectionFromConfig added in v0.11.298 

func (m *Manager) AddIntercomConnectionFromConfig(connection *config.IntercomConnection) error

func (*Manager) AddJiraConnectionFromConfig added in v0.11.300 

func (m *Manager) AddJiraConnectionFromConfig(connection *config.JiraConnection) error

func (*Manager) AddKafkaConnectionFromConfig added in v0.11.40 

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

func (*Manager) AddKinesisConnectionFromConfig added in v0.11.161 

func (m *Manager) AddKinesisConnectionFromConfig(connection *config.KinesisConnection) error

func (*Manager) AddKlaviyoConnectionFromConfig added in v0.11.26 

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

func (*Manager) AddLinearConnectionFromConfig added in v0.11.249 

func (m *Manager) AddLinearConnectionFromConfig(connection *config.LinearConnection) error

func (*Manager) AddLinkedInAdsConnectionFromConfig added in v0.11.133 

func (m *Manager) AddLinkedInAdsConnectionFromConfig(connection *config.LinkedInAdsConnection) error

func (*Manager) AddMailchimpConnectionFromConfig added in v0.11.319 

func (m *Manager) AddMailchimpConnectionFromConfig(connection *config.MailchimpConnection) error

func (*Manager) AddMixpanelConnectionFromConfig added in v0.11.238 

func (m *Manager) AddMixpanelConnectionFromConfig(connection *config.MixpanelConnection) error

func (*Manager) AddMondayConnectionFromConfig added in v0.11.311 

func (m *Manager) AddMondayConnectionFromConfig(connection *config.MondayConnection) error

func (*Manager) AddMongoAtlasConnectionFromConfig added in v0.11.309 

func (m *Manager) AddMongoAtlasConnectionFromConfig(connection *config.MongoAtlasConnection) error

func (*Manager) AddMongoConnectionFromConfig added in v0.7.2 

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

func (*Manager) AddMotherduckConnectionFromConfig added in v0.11.273 

func (m *Manager) AddMotherduckConnectionFromConfig(connection *config.MotherduckConnection) 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) AddOracleConnectionFromConfig added in v0.11.193 

func (m *Manager) AddOracleConnectionFromConfig(connection *config.OracleConnection) error

func (*Manager) AddPersonioConnectionFromConfig added in v0.11.139 

func (m *Manager) AddPersonioConnectionFromConfig(connection *config.PersonioConnection) error

func (*Manager) AddPgConnectionFromConfig added in v0.5.0 

func (m *Manager) AddPgConnectionFromConfig(ctx context.Context, connection *config.PostgresConnection) error

func (*Manager) AddPhantombusterConnectionFromConfig added in v0.11.203 

func (m *Manager) AddPhantombusterConnectionFromConfig(connection *config.PhantombusterConnection) error

func (*Manager) AddPinterestConnectionFromConfig added in v0.11.248 

func (m *Manager) AddPinterestConnectionFromConfig(connection *config.PinterestConnection) error

func (*Manager) AddPipedriveConnectionFromConfig added in v0.11.179 

func (m *Manager) AddPipedriveConnectionFromConfig(connection *config.PipedriveConnection) error

func (*Manager) AddPlusVibeAIConnectionFromConfig added in v0.11.308 

func (m *Manager) AddPlusVibeAIConnectionFromConfig(connection *config.PlusVibeAIConnection) error

func (*Manager) AddPrimerConnectionFromConfig added in v0.11.377 

func (m *Manager) AddPrimerConnectionFromConfig(connection *config.PrimerConnection) error

func (*Manager) AddQuickBooksConnectionFromConfig added in v0.11.239 

func (m *Manager) AddQuickBooksConnectionFromConfig(connection *config.QuickBooksConnection) error

func (*Manager) AddRedshiftConnectionFromConfig added in v0.7.0 

func (m *Manager) AddRedshiftConnectionFromConfig(ctx context.Context, connection *config.RedshiftConnection) error

func (*Manager) AddRevenueCatConnectionFromConfig added in v0.11.286 

func (m *Manager) AddRevenueCatConnectionFromConfig(connection *config.RevenueCatConnection) error

func (*Manager) AddS3ConnectionFromConfig added in v0.11.55 

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

func (*Manager) AddSQLiteConnectionFromConfig added in v0.11.190 

func (m *Manager) AddSQLiteConnectionFromConfig(connection *config.SQLiteConnection) error

func (*Manager) AddSalesforceConnectionFromConfig added in v0.11.188 

func (m *Manager) AddSalesforceConnectionFromConfig(connection *config.SalesforceConnection) error

func (*Manager) AddSfConnectionFromConfig added in v0.2.0 

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

func (*Manager) AddSftpConnectionFromConfig added in v0.11.226 

func (m *Manager) AddSftpConnectionFromConfig(connection *config.SFTPConnection) 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) AddSmartsheetConnectionFromConfig added in v0.11.217 

func (m *Manager) AddSmartsheetConnectionFromConfig(connection *config.SmartsheetConnection) error

func (*Manager) AddSnapchatAdsConnectionFromConfig added in v0.11.353 

func (m *Manager) AddSnapchatAdsConnectionFromConfig(connection *config.SnapchatAdsConnection) error

func (*Manager) AddSocrataConnectionFromConfig added in v0.11.330 

func (m *Manager) AddSocrataConnectionFromConfig(connection *config.SocrataConnection) error

func (*Manager) AddSolidgateConnectionFromConfig added in v0.11.215 

func (m *Manager) AddSolidgateConnectionFromConfig(connection *config.SolidgateConnection) error

func (*Manager) AddSpannerConnectionFromConfig added in v0.11.209 

func (m *Manager) AddSpannerConnectionFromConfig(connection *config.SpannerConnection) 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) AddTableauConnectionFromConfig added in v0.11.250 

func (m *Manager) AddTableauConnectionFromConfig(connection *config.TableauConnection) error

func (*Manager) AddTikTokAdsConnectionFromConfig added in v0.11.129 

func (m *Manager) AddTikTokAdsConnectionFromConfig(connection *config.TikTokAdsConnection) error

func (*Manager) AddTrinoConnectionFromConfig added in v0.11.274 

func (m *Manager) AddTrinoConnectionFromConfig(connection *config.TrinoConnection) error

func (*Manager) AddTrustpilotConnectionFromConfig added in v0.11.249 

func (m *Manager) AddTrustpilotConnectionFromConfig(connection *config.TrustpilotConnection) error

func (*Manager) AddWiseConnectionFromConfig added in v0.11.277 

func (m *Manager) AddWiseConnectionFromConfig(connection *config.WiseConnection) error

func (*Manager) AddZendeskConnectionFromConfig added in v0.11.61 

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

func (*Manager) AddZoomConnectionFromConfig added in v0.11.244 

func (m *Manager) AddZoomConnectionFromConfig(connection *config.ZoomConnection) error

func (*Manager) GetConnection 

func (m *Manager) GetConnection(name string) any

func (*Manager) GetConnectionDetails added in v0.11.266 

func (m *Manager) GetConnectionDetails(name string) any

func (*Manager) GetConnectionType added in v0.11.465 

func (m *Manager) GetConnectionType(name string) string

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.