Help us shape the future of Go! Take the 2026 Go Developer Survey

connection

package
v0.11.796 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2026 License: Apache-2.0 Imports: 167 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
	ADLS               map[string]*adls.Client
	Fabric             map[string]*fabric.DB
	OneLake            map[string]*onelake.Client
	Mongo              map[string]*mongo.DB
	Cassandra          map[string]*cassandra.Client
	Couchbase          map[string]*couchbase.DB
	CouchDB            map[string]*couchdb.Client
	CrateDB            map[string]*cratedb.Client
	CSV                map[string]*csvsource.Client
	Cursor             map[string]*cursor.Client
	MongoAtlas         map[string]*mongoatlas.DB
	Mysql              map[string]*mysql.Client
	Doris              map[string]*doris.Client
	Vitess             map[string]*mysql.Client
	Planetscale        map[string]*mysql.Client
	Notion             map[string]*notion.Client
	Allium             map[string]*allium.Client
	HANA               map[string]*hana.Client
	Hostaway           map[string]*hostaway.Client
	HTTP               map[string]*httpsource.Client
	Shopify            map[string]*shopify.Client
	Gorgias            map[string]*gorgias.Client
	G2                 map[string]*g2.Client
	Klaviyo            map[string]*klaviyo.Client
	Adjust             map[string]*adjust.Client
	Adapty             map[string]*adapty.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
	Paddle             map[string]*paddle.Client
	Chargebee          map[string]*chargebee.Client
	Recurly            map[string]*recurly.Client
	GitLab             map[string]*gitlab.Client
	SurveyMonkey       map[string]*surveymonkey.Client
	Typeform           map[string]*typeform.Client
	Appsflyer          map[string]*appsflyer.Client
	Kafka              map[string]*kafka.Client
	RabbitMQ           map[string]*rabbitmq.Client
	Airtable           map[string]*airtable.Client
	DuckDB             map[string]*duck.Client
	Hubspot            map[string]*hubspot.Client
	Granola            map[string]*granola.Client
	GoogleSheets       map[string]*gsheets.Client
	Chess              map[string]*chess.Client
	S3                 map[string]*s3.Client
	SharePoint         map[string]*sharepoint.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
	AppleAds           map[string]*appleads.Client
	Kalshi             map[string]*kalshi.Client
	LinkedInAds        map[string]*linkedinads.Client
	RedditAds          map[string]*redditads.Client
	CloudflareRadar    map[string]*cloudflareradar.Client
	Mailchimp          map[string]*mailchimp.Client
	Manifold           map[string]*manifold.Client
	Linear             map[string]*linear.Client
	RevenueCat         map[string]*revenuecat.Client
	ClickHouse         map[string]*clickhouse.Client
	GCS                map[string]*gcs.Client
	Iceberg            map[string]*iceberg.Client
	ApplovinMax        map[string]*applovinmax.Client
	Personio           map[string]*personio.Client
	Kinesis            map[string]*kinesis.Client
	Pipedrive          map[string]*pipedrive.Client
	Polymarket         map[string]*polymarket.Client
	Mixpanel           map[string]*mixpanel.Client
	Amplitude          map[string]*amplitude.Client
	Fastspring         map[string]*fastspring.Client
	TwoCheckout        map[string]*twocheckout.Client
	Payrails           map[string]*payrails.Client
	Clickup            map[string]*clickup.Client
	Jobtread           map[string]*jobtread.Client
	Posthog            map[string]*posthog.Client
	Pinterest          map[string]*pinterest.Client
	Trustpilot         map[string]*trustpilot.Client
	QuickBooks         map[string]*quickbooks.Client
	Wise               map[string]*wise.Client
	Wistia             map[string]*wistia.Client
	Zoom               map[string]*zoom.Client
	Frankfurter        map[string]*frankfurter.Client
	Fluxx              map[string]*fluxx.Client
	Freshdesk          map[string]*freshdesk.Client
	Okta               map[string]*okta.Client
	FundraiseUp        map[string]*fundraiseup.Client
	Fireflies          map[string]*fireflies.Client
	Trello             map[string]*trello.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
	GSC                map[string]*gsc.Client
	AppLovin           map[string]*applovin.Client
	Sklik              map[string]*sklik.Client
	Sumble             map[string]*sumble.Client
	Twenty             map[string]*twenty.Client
	AbraFlexi          map[string]*abraflexi.Client
	ExchangeRatesAPI   map[string]*exchangeratesapi.Client
	Fakturoid          map[string]*fakturoid.Client
	Lumify             map[string]*lumify.Client
	BambooHR           map[string]*bamboohr.Client
	SatisMeter         map[string]*satismeter.Client
	Deel               map[string]*deel.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
	Square             map[string]*square.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
	QuickSight         map[string]*quicksight.Client
	Trino              map[string]*trino.Client
	StarRocks          map[string]*starrocks.Client
	Dremio             map[string]*dremio.Client
	Sail               map[string]*sail.Client
	Spark              map[string]*spark.Client
	Dune               map[string]*dune.Client
	Vertica            map[string]*vertica.DB
	CustomerIo         map[string]*customerio.Client
	CleverTap          map[string]*clevertap.Client
	Sendgrid           map[string]*sendgrid.Client
	Twilio             map[string]*twilio.Client
	Braze              map[string]*braze.Client
	Espn               map[string]*espn.Client
	APIFootball        map[string]*apifootball.Client
	FootballData       map[string]*footballdata.Client
	BallDontLie        map[string]*balldontlie.Client
	Generic            map[string]*config.GenericConnection
	// contains filtered or unexported fields
}

func (*Manager) AddADLSConnectionFromConfig added in v0.11.619 

func (m *Manager) AddADLSConnectionFromConfig(connection *config.ADLSConnection) error

func (*Manager) AddAPIFootballConnectionFromConfig added in v0.11.636 

func (m *Manager) AddAPIFootballConnectionFromConfig(connection *config.APIFootballConnection) error

func (*Manager) AddAPIKeyConnectionFromConfig added in v0.11.777 

func (m *Manager) AddAPIKeyConnectionFromConfig(connection *config.APIKeyConnection) error

func (*Manager) AddAbraFlexiConnectionFromConfig added in v0.11.744 

func (m *Manager) AddAbraFlexiConnectionFromConfig(connection *config.AbraFlexiConnection) error

func (*Manager) AddAdaptyConnectionFromConfig added in v0.11.683 

func (m *Manager) AddAdaptyConnectionFromConfig(connection *config.AdaptyConnection) 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) AddAlliumConnectionFromConfig added in v0.11.324 

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

func (*Manager) AddAmplitudeConnectionFromConfig added in v0.11.676 

func (m *Manager) AddAmplitudeConnectionFromConfig(connection *config.AmplitudeConnection) 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) AddAppleAdsConnectionFromConfig added in v0.11.548 

func (m *Manager) AddAppleAdsConnectionFromConfig(connection *config.AppleAdsConnection) 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) AddBallDontLieConnectionFromConfig added in v0.11.636 

func (m *Manager) AddBallDontLieConnectionFromConfig(connection *config.BallDontLieConnection) error

func (*Manager) AddBambooHRConnectionFromConfig added in v0.11.754 

func (m *Manager) AddBambooHRConnectionFromConfig(connection *config.BambooHRConnection) error

func (*Manager) AddBqConnectionFromConfig 

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

func (*Manager) AddBrazeConnectionFromConfig added in v0.11.640 

func (m *Manager) AddBrazeConnectionFromConfig(connection *config.BrazeConnection) error

func (*Manager) AddBruinCloudConnectionFromConfig added in v0.11.377 

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

func (*Manager) AddCSVConnectionFromConfig added in v0.11.619 

func (m *Manager) AddCSVConnectionFromConfig(connection *config.CSVConnection) error

func (*Manager) AddCassandraConnectionFromConfig added in v0.11.619 

func (m *Manager) AddCassandraConnectionFromConfig(connection *config.CassandraConnection) error

func (*Manager) AddChargebeeConnectionFromConfig added in v0.11.650 

func (m *Manager) AddChargebeeConnectionFromConfig(connection *config.ChargebeeConnection) error

func (*Manager) AddChessConnectionFromConfig added in v0.11.49 

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

func (*Manager) AddCleverTapConnectionFromConfig added in v0.11.716 

func (m *Manager) AddCleverTapConnectionFromConfig(connection *config.CleverTapConnection) 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) AddCloudflareRadarConnectionFromConfig added in v0.11.741 

func (m *Manager) AddCloudflareRadarConnectionFromConfig(connection *config.CloudflareRadarConnection) error

func (*Manager) AddCouchDBConnectionFromConfig added in v0.11.770 

func (m *Manager) AddCouchDBConnectionFromConfig(connection *config.CouchDBConnection) error

func (*Manager) AddCouchbaseConnectionFromConfig added in v0.11.328 

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

func (*Manager) AddCrateDBConnectionFromConfig added in v0.11.619 

func (m *Manager) AddCrateDBConnectionFromConfig(connection *config.CrateDBConnection) 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) AddDeelConnectionFromConfig added in v0.11.744 

func (m *Manager) AddDeelConnectionFromConfig(connection *config.DeelConnection) error

func (*Manager) AddDoceboConnectionFromConfig added in v0.11.296 

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

func (*Manager) AddDorisConnectionFromConfig added in v0.11.672 

func (m *Manager) AddDorisConnectionFromConfig(connection *config.DorisConnection) error

func (*Manager) AddDremioConnectionFromConfig added in v0.11.616 

func (m *Manager) AddDremioConnectionFromConfig(connection *config.DremioConnection) error

func (*Manager) AddDuckDBConnectionFromConfig added in v0.11.41 

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

func (*Manager) AddDuneConnectionFromConfig added in v0.11.494 

func (m *Manager) AddDuneConnectionFromConfig(connection *config.DuneConnection) 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) AddEspnConnectionFromConfig added in v0.11.633 

func (m *Manager) AddEspnConnectionFromConfig(connection *config.EspnConnection) error

func (*Manager) AddExchangeRatesAPIConnectionFromConfig added in v0.11.754 

func (m *Manager) AddExchangeRatesAPIConnectionFromConfig(connection *config.ExchangeRatesAPIConnection) 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) AddFakturoidConnectionFromConfig added in v0.11.754 

func (m *Manager) AddFakturoidConnectionFromConfig(connection *config.FakturoidConnection) error

func (*Manager) AddFastspringConnectionFromConfig added in v0.11.682 

func (m *Manager) AddFastspringConnectionFromConfig(connection *config.FastspringConnection) 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) AddFootballDataConnectionFromConfig added in v0.11.636 

func (m *Manager) AddFootballDataConnectionFromConfig(connection *config.FootballDataConnection) 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) AddG2ConnectionFromConfig added in v0.11.523 

func (m *Manager) AddG2ConnectionFromConfig(connection *config.G2Connection) error

func (*Manager) AddGCSConnectionFromConfig added in v0.11.136 

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

func (*Manager) AddGSCConnectionFromConfig added in v0.11.657 

func (m *Manager) AddGSCConnectionFromConfig(connection *config.GSCConnection) 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) AddGitLabConnectionFromConfig added in v0.11.640 

func (m *Manager) AddGitLabConnectionFromConfig(connection *config.GitLabConnection) 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) AddGranolaConnectionFromConfig added in v0.11.619 

func (m *Manager) AddGranolaConnectionFromConfig(connection *config.GranolaConnection) error

func (*Manager) AddHANAConnectionFromConfig added in v0.8.2 

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

func (*Manager) AddHTTPConnectionFromConfig added in v0.11.619 

func (m *Manager) AddHTTPConnectionFromConfig(connection *config.HTTPConnection) 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) AddIcebergConnectionFromConfig added in v0.11.686 

func (m *Manager) AddIcebergConnectionFromConfig(connection *config.IcebergConnection) 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) AddJobtreadConnectionFromConfig added in v0.11.523 

func (m *Manager) AddJobtreadConnectionFromConfig(connection *config.JobtreadConnection) error

func (*Manager) AddKafkaConnectionFromConfig added in v0.11.40 

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

func (*Manager) AddKalshiConnectionFromConfig added in v0.11.619 

func (m *Manager) AddKalshiConnectionFromConfig(connection *config.KalshiConnection) 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) AddLumifyConnectionFromConfig added in v0.11.754 

func (m *Manager) AddLumifyConnectionFromConfig(connection *config.LumifyConnection) error

func (*Manager) AddMailchimpConnectionFromConfig added in v0.11.319 

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

func (*Manager) AddManifoldConnectionFromConfig added in v0.11.619 

func (m *Manager) AddManifoldConnectionFromConfig(connection *config.ManifoldConnection) 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) AddOktaConnectionFromConfig added in v0.11.719 

func (m *Manager) AddOktaConnectionFromConfig(connection *config.OktaConnection) error

func (*Manager) AddOneLakeConnectionFromConfig added in v0.11.608 

func (m *Manager) AddOneLakeConnectionFromConfig(connection *config.OneLakeConnection) error

func (*Manager) AddOracleConnectionFromConfig added in v0.11.193 

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

func (*Manager) AddPaddleConnectionFromConfig added in v0.11.623 

func (m *Manager) AddPaddleConnectionFromConfig(connection *config.PaddleConnection) error

func (*Manager) AddPayrailsConnectionFromConfig added in v0.11.688 

func (m *Manager) AddPayrailsConnectionFromConfig(connection *config.PayrailsConnection) 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) AddPlanetScaleConnectionFromConfig added in v0.11.661 

func (m *Manager) AddPlanetScaleConnectionFromConfig(connection *config.PlanetScaleConnection) error

AddPlanetScaleConnectionFromConfig registers a PlanetScale connection. It reuses the shared mysql.Client for direct connectivity (TLS is always on) while emitting ingestr's dedicated "ps_mysql" scheme via planetscale.Config.GetIngestrURI.

func (*Manager) AddPlusVibeAIConnectionFromConfig added in v0.11.308 

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

func (*Manager) AddPolymarketConnectionFromConfig added in v0.11.619 

func (m *Manager) AddPolymarketConnectionFromConfig(connection *config.PolymarketConnection) error

func (*Manager) AddPosthogConnectionFromConfig added in v0.11.496 

func (m *Manager) AddPosthogConnectionFromConfig(connection *config.PosthogConnection) 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) AddQuickSightConnectionFromConfig added in v0.11.505 

func (m *Manager) AddQuickSightConnectionFromConfig(connection *config.QuickSightConnection) error

func (*Manager) AddRabbitMQConnectionFromConfig added in v0.11.512 

func (m *Manager) AddRabbitMQConnectionFromConfig(connection *config.RabbitMQConnection) error

func (*Manager) AddRecurlyConnectionFromConfig added in v0.11.654 

func (m *Manager) AddRecurlyConnectionFromConfig(connection *config.RecurlyConnection) error

func (*Manager) AddRedditAdsConnectionFromConfig added in v0.11.619 

func (m *Manager) AddRedditAdsConnectionFromConfig(connection *config.RedditAdsConnection) 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) AddSailConnectionFromConfig added in v0.11.616 

func (m *Manager) AddSailConnectionFromConfig(connection *config.SailConnection) error

func (*Manager) AddSalesforceConnectionFromConfig added in v0.11.188 

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

func (*Manager) AddSatisMeterConnectionFromConfig added in v0.11.744 

func (m *Manager) AddSatisMeterConnectionFromConfig(connection *config.SatisMeterConnection) error

func (*Manager) AddSendgridConnectionFromConfig added in v0.11.633 

func (m *Manager) AddSendgridConnectionFromConfig(connection *config.SendgridConnection) 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) AddSharePointConnectionFromConfig added in v0.11.636 

func (m *Manager) AddSharePointConnectionFromConfig(connection *config.SharePointConnection) error

func (*Manager) AddShopifyConnectionFromConfig added in v0.11.5 

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

func (*Manager) AddSklikConnectionFromConfig added in v0.11.741 

func (m *Manager) AddSklikConnectionFromConfig(connection *config.SklikConnection) 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) AddSparkConnectionFromConfig added in v0.11.697 

func (m *Manager) AddSparkConnectionFromConfig(ctx context.Context, connection *config.SparkConnection) error

func (*Manager) AddSquareConnectionFromConfig added in v0.11.654 

func (m *Manager) AddSquareConnectionFromConfig(connection *config.SquareConnection) error

func (*Manager) AddStarRocksConnectionFromConfig added in v0.11.655 

func (m *Manager) AddStarRocksConnectionFromConfig(connection *config.StarRocksConnection) error

func (*Manager) AddStripeConnectionFromConfig added in v0.11.32 

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

func (*Manager) AddSumbleConnectionFromConfig added in v0.11.744 

func (m *Manager) AddSumbleConnectionFromConfig(connection *config.SumbleConnection) error

func (*Manager) AddSurveyMonkeyConnectionFromConfig added in v0.11.548 

func (m *Manager) AddSurveyMonkeyConnectionFromConfig(connection *config.SurveyMonkeyConnection) 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) AddTrelloConnectionFromConfig added in v0.11.670 

func (m *Manager) AddTrelloConnectionFromConfig(connection *config.TrelloConnection) 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) AddTwentyConnectionFromConfig added in v0.11.744 

func (m *Manager) AddTwentyConnectionFromConfig(connection *config.TwentyConnection) error

func (*Manager) AddTwilioConnectionFromConfig added in v0.11.638 

func (m *Manager) AddTwilioConnectionFromConfig(connection *config.TwilioConnection) error

func (*Manager) AddTwoCheckoutConnectionFromConfig added in v0.11.741 

func (m *Manager) AddTwoCheckoutConnectionFromConfig(connection *config.TwoCheckoutConnection) error

func (*Manager) AddTypeformConnectionFromConfig added in v0.11.696 

func (m *Manager) AddTypeformConnectionFromConfig(connection *config.TypeformConnection) error

func (*Manager) AddVerticaConnectionFromConfig added in v0.11.475 

func (m *Manager) AddVerticaConnectionFromConfig(connection *config.VerticaConnection) error

func (*Manager) AddVitessConnectionFromConfig added in v0.11.661 

func (m *Manager) AddVitessConnectionFromConfig(connection *config.VitessConnection) error

AddVitessConnectionFromConfig registers a Vitess connection. Vitess speaks the MySQL wire protocol, so it reuses the shared mysql.Client for direct connectivity (e.g. `connections test`) while emitting ingestr's dedicated "vitess" scheme via vitess.Config.GetIngestrURI.

func (*Manager) AddWiseConnectionFromConfig added in v0.11.277 

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

func (*Manager) AddWistiaConnectionFromConfig added in v0.11.619 

func (m *Manager) AddWistiaConnectionFromConfig(connection *config.WistiaConnection) 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

func (*Manager) GetSfConnectionWithWarehouse added in v0.11.675 

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

GetSfConnectionWithWarehouse returns a Snowflake client for the named connection whose warehouse is overridden. When warehouse is empty it returns the default connection unchanged; otherwise it builds a client by cloning the connection config with a different warehouse. The returned client is not pinged here; callers that need to fall back on failure should validate it.

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.