Documentation
¶
Index ¶
- func GetConnectionTypeNames() []string
- func GetConnectionsSchema() (string, error)
- type ADLSConnection
- type APIFootballConnection
- type AdaptyConnection
- type AdjustConnection
- type AirtableConnection
- type AlliumConnection
- type AmplitudeConnection
- type AnthropicConnection
- type AppLovinConnection
- type AppStoreConnection
- type AppleAdsConnection
- type ApplovinMaxConnection
- type AppsflyerConnection
- type AsanaConnection
- type AthenaConnection
- type AttioConnection
- type AwsConnection
- type BallDontLieConnection
- type BrazeConnection
- type BruinCloudConnection
- type CSVConnection
- type CassandraConnection
- type CatalogAuth
- type CatalogConfig
- type CatalogType
- type ChargebeeConnection
- type ChessConnection
- type ClickHouseConnection
- type ClickupConnection
- type ConcurrencyLimitedConnection
- type Config
- func (c *Config) AddConnection(environmentName, name, connType string, creds map[string]interface{}) error
- func (c *Config) AddEnvironment(name, schemaPrefix string) error
- func (c *Config) CanRunTaskInstances(p *pipeline.Pipeline, tasks []scheduler.TaskInstance) error
- func (c *Config) CloneEnvironment(sourceName, targetName, schemaPrefix string) error
- func (c *Config) DeleteConnection(environmentName, connectionName string) error
- func (c *Config) DeleteEnvironment(name string) error
- func (c *Config) EnvironmentExists(name string) bool
- func (c *Config) GetEnvironmentNames() []string
- func (c *Config) Path() string
- func (c *Config) Persist() error
- func (c *Config) PersistToFs(fs afero.Fs) error
- func (c *Config) SelectEnvironment(name string) error
- func (c *Config) UpdateEnvironment(oldName, newName, schemaPrefix string) error
- type ConnectionAndDetailsGetter
- type ConnectionDetailsGetter
- type ConnectionFieldDef
- type ConnectionGetter
- type ConnectionMetadata
- type ConnectionResolver
- type ConnectionTypeDef
- type Connections
- type CouchbaseConnection
- type CrateDBConnection
- type CursorConnection
- type CustomerIoConnection
- type DB2Connection
- type DatabricksConnection
- type DataprocServerlessConnection
- type DoceboConnection
- type DorisConnection
- type DremioConnection
- type DuckDBConnection
- type DuneConnection
- type DynamoDBConnection
- type EMRServerlessConnection
- type ElasticsearchConnection
- type EnvContextKey
- type Environment
- type EnvironmentConfig
- type EspnConnection
- type FabricConnection
- type FacebookAdsConnection
- type FastspringConnection
- type FirefliesConnection
- type FluxxConnection
- type FootballDataConnection
- type FrankfurterConnection
- type FreshdeskConnection
- type FundraiseUpConnection
- type G2Connection
- type GCSConnection
- type GSCConnection
- type GenericConnection
- type GitHubConnection
- type GitLabConnection
- type GoogleAdsConnection
- type GoogleAnalyticsConnection
- type GoogleCloudPlatformConnection
- func (c *GoogleCloudPlatformConnection) GetCredentials() *google.Credentials
- func (c GoogleCloudPlatformConnection) GetName() string
- func (c GoogleCloudPlatformConnection) MarshalJSON() ([]byte, error)
- func (c GoogleCloudPlatformConnection) MarshalYAML() (interface{}, error)
- func (c *GoogleCloudPlatformConnection) SetCredentials(cred *google.Credentials)
- type GoogleSheetsConnection
- type GorgiasConnection
- type GranolaConnection
- type HANAConnection
- type HTTPConnection
- type HostawayConnection
- type HubspotConnection
- type ISOCPulseConnection
- type IcebergAuth
- type IcebergCatalog
- type IcebergCatalogType
- type IcebergConnection
- type IcebergStorage
- type IcebergStorageType
- type IndeedConnection
- type InfluxDBConnection
- type IntercomConnection
- type JiraConnection
- type JobtreadConnection
- type KafkaConnection
- type KalshiConnection
- type KinesisConnection
- type KlaviyoConnection
- type LakehouseConfig
- type LakehouseFormat
- type LinearConnection
- type LinkedInAdsConnection
- type MailchimpConnection
- type ManifoldConnection
- type MissingConnectionError
- type MixpanelConnection
- type MondayConnection
- type MongoAtlasConnection
- type MongoConnection
- type MotherduckConnection
- type MsSQLConnection
- type MySQLConnection
- type Named
- type NotionConnection
- type OneLakeConnection
- type OracleConnection
- type PaddleConnection
- type PayrailsConnection
- type PersonioConnection
- type PhantombusterConnection
- type PinterestConnection
- type PipedriveConnection
- type PlanetScaleConnection
- type PlusVibeAIConnection
- type PolymarketConnection
- type PostgresConnection
- type PosthogConnection
- type PrimerConnection
- type QuickBooksConnection
- type QuickSightConnection
- type RabbitMQConnection
- type RecurlyConnection
- type RedditAdsConnection
- type RedshiftConnection
- type RevenueCatConnection
- type S3Connection
- type SFTPConnection
- type SQLiteConnection
- type SailConnection
- type SalesforceConnection
- type SendgridConnection
- type SharePointConnection
- type ShopifyConnection
- type SlackConnection
- type SmartsheetConnection
- type SnapchatAdsConnection
- type SnowflakeConnection
- type SocrataConnection
- type SolidgateConnection
- type SpannerConnection
- type SquareConnection
- type StarRocksConnection
- type StorageAuth
- type StorageConfig
- type StorageType
- type StripeConnection
- type SurveyMonkeyConnection
- type SynapseConnection
- type TableauConnection
- type TikTokAdsConnection
- type TrelloConnection
- type TrinoConnection
- type TrustpilotConnection
- type TwilioConnection
- type VerticaConnection
- type VitessConnection
- type WiseConnection
- type WistiaConnection
- type ZendeskConnection
- type ZoomConnection
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetConnectionTypeNames ¶ added in v0.11.475
func GetConnectionTypeNames() []string
GetConnectionTypeNames returns a sorted list of all connection type names.
func GetConnectionsSchema ¶ added in v0.11.55
Types ¶
type ADLSConnection ¶ added in v0.11.619
type ADLSConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccountName string `yaml:"account_name,omitempty" json:"account_name" mapstructure:"account_name"`
TenantID string `yaml:"tenant_id,omitempty" json:"tenant_id,omitempty" mapstructure:"tenant_id"`
ClientID string `yaml:"client_id,omitempty" json:"client_id,omitempty" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret,omitempty" mapstructure:"client_secret" sensitive:"true"`
AccountKey string `yaml:"account_key,omitempty" json:"account_key,omitempty" mapstructure:"account_key" sensitive:"true"`
SASToken string `yaml:"sas_token,omitempty" json:"sas_token,omitempty" mapstructure:"sas_token" sensitive:"true"`
Layout string `yaml:"layout,omitempty" json:"layout,omitempty" mapstructure:"layout"`
}
func (ADLSConnection) GetName ¶ added in v0.11.619
func (c ADLSConnection) GetName() string
type APIFootballConnection ¶ added in v0.11.636
type APIFootballConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
League string `yaml:"league,omitempty" json:"league,omitempty" mapstructure:"league"`
Season string `yaml:"season,omitempty" json:"season,omitempty" mapstructure:"season"`
Timezone string `yaml:"timezone,omitempty" json:"timezone,omitempty" mapstructure:"timezone"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
}
func (APIFootballConnection) GetName ¶ added in v0.11.636
func (c APIFootballConnection) GetName() string
type AdaptyConnection ¶ added in v0.11.683
type AdaptyConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key" json:"api_key" mapstructure:"api_key" sensitive:"true"`
LookbackDays *int `yaml:"lookback_days,omitempty" json:"lookback_days,omitempty" mapstructure:"lookback_days"`
Timezone string `yaml:"timezone,omitempty" json:"timezone,omitempty" mapstructure:"timezone"`
}
func (AdaptyConnection) GetName ¶ added in v0.11.683
func (c AdaptyConnection) GetName() string
type AdjustConnection ¶ added in v0.11.30
type AdjustConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (AdjustConnection) GetName ¶ added in v0.11.30
func (c AdjustConnection) GetName() string
type AirtableConnection ¶ added in v0.11.49
type AirtableConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
BaseID string `yaml:"base_id,omitempty" json:"base_id" mapstructure:"base_id"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
}
func (AirtableConnection) GetName ¶ added in v0.11.49
func (c AirtableConnection) GetName() string
type AlliumConnection ¶ added in v0.11.324
type AlliumConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (AlliumConnection) GetName ¶ added in v0.11.324
func (c AlliumConnection) GetName() string
type AmplitudeConnection ¶ added in v0.11.676
type AmplitudeConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key,omitempty" mapstructure:"api_key" sensitive:"true"`
SecretKey string `yaml:"secret_key,omitempty" json:"secret_key,omitempty" mapstructure:"secret_key" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
}
func (AmplitudeConnection) GetName ¶ added in v0.11.676
func (c AmplitudeConnection) GetName() string
type AnthropicConnection ¶ added in v0.11.296
type AnthropicConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (AnthropicConnection) GetName ¶ added in v0.11.296
func (c AnthropicConnection) GetName() string
type AppLovinConnection ¶ added in v0.11.186
type AppLovinConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (AppLovinConnection) GetName ¶ added in v0.11.186
func (c AppLovinConnection) GetName() string
type AppStoreConnection ¶ added in v0.11.132
type AppStoreConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
KeyID string `yaml:"key_id,omitempty" json:"key_id" mapstructure:"key_id"`
IssuerID string `yaml:"issuer_id,omitempty" json:"issuer_id" mapstructure:"issuer_id"`
KeyPath string `yaml:"key_path,omitempty" json:"key_path" mapstructure:"key_path"`
Key string `yaml:"key,omitempty" json:"key" mapstructure:"key" sensitive:"true"`
}
func (AppStoreConnection) GetName ¶ added in v0.11.132
func (c AppStoreConnection) GetName() string
type AppleAdsConnection ¶ added in v0.11.548
type AppleAdsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
TeamID string `yaml:"team_id,omitempty" json:"team_id" mapstructure:"team_id"`
KeyID string `yaml:"key_id,omitempty" json:"key_id" mapstructure:"key_id"`
OrgID string `yaml:"org_id,omitempty" json:"org_id" mapstructure:"org_id"`
KeyPath string `yaml:"key_path,omitempty" json:"key_path" mapstructure:"key_path"`
KeyBase64 string `yaml:"key_base64,omitempty" json:"key_base64" mapstructure:"key_base64" sensitive:"true"`
}
func (AppleAdsConnection) GetName ¶ added in v0.11.548
func (c AppleAdsConnection) GetName() string
type ApplovinMaxConnection ¶ added in v0.11.138
type ApplovinMaxConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (ApplovinMaxConnection) GetName ¶ added in v0.11.138
func (c ApplovinMaxConnection) GetName() string
type AppsflyerConnection ¶ added in v0.11.35
type AppsflyerConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (AppsflyerConnection) GetName ¶ added in v0.11.35
func (c AppsflyerConnection) GetName() string
type AsanaConnection ¶ added in v0.11.123
type AsanaConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
WorkspaceID string `yaml:"workspace,omitempty" json:"workspace" mapstructure:"workspace"`
}
func (AsanaConnection) GetName ¶ added in v0.11.123
func (c AsanaConnection) GetName() string
type AthenaConnection ¶ added in v0.11.21
type AthenaConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessKey string `yaml:"access_key_id,omitempty" json:"access_key_id,omitempty" mapstructure:"access_key_id" sensitive:"true"`
SecretKey string `yaml:"secret_access_key,omitempty" json:"secret_access_key,omitempty" mapstructure:"secret_access_key" sensitive:"true"`
SessionToken string `yaml:"session_token,omitempty" json:"session_token,omitempty" mapstructure:"session_token" sensitive:"true"`
QueryResultsPath string `yaml:"query_results_path,omitempty" json:"query_results_path" mapstructure:"query_results_path"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
Profile string `yaml:"profile,omitempty" json:"profile,omitempty" mapstructure:"profile"`
// contains filtered or unexported fields
}
func (AthenaConnection) GetName ¶ added in v0.11.22
func (c AthenaConnection) GetName() string
func (AthenaConnection) JSONSchemaExtend ¶ added in v0.11.664
func (AthenaConnection) JSONSchemaExtend(s *jsonschema.Schema)
JSONSchemaExtend requires either static access keys or a named profile, so an Athena connection can never be defined without any AWS credentials while still allowing profile-based auth (which supplies no access keys).
func (*AthenaConnection) LoadCredentialsFromProfile ¶ added in v0.11.190
func (c *AthenaConnection) LoadCredentialsFromProfile(ctx context.Context) error
func (AthenaConnection) MarshalYAML ¶ added in v0.11.190
func (c AthenaConnection) MarshalYAML() (interface{}, error)
type AttioConnection ¶ added in v0.11.220
type AttioConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (AttioConnection) GetName ¶ added in v0.11.220
func (c AttioConnection) GetName() string
type AwsConnection ¶ added in v0.11.20
type AwsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessKey string `yaml:"access_key,omitempty" json:"access_key" mapstructure:"access_key" sensitive:"true"`
SecretKey string `yaml:"secret_key,omitempty" json:"secret_key" mapstructure:"secret_key" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region" mapstructure:"region"`
}
func (AwsConnection) GetName ¶ added in v0.11.22
func (c AwsConnection) GetName() string
type BallDontLieConnection ¶ added in v0.11.636
type BallDontLieConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Season string `yaml:"season,omitempty" json:"season,omitempty" mapstructure:"season"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
}
func (BallDontLieConnection) GetName ¶ added in v0.11.636
func (c BallDontLieConnection) GetName() string
type BrazeConnection ¶ added in v0.11.640
type BrazeConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Endpoint string `yaml:"endpoint,omitempty" json:"endpoint" mapstructure:"endpoint"`
}
func (BrazeConnection) GetName ¶ added in v0.11.640
func (c BrazeConnection) GetName() string
type BruinCloudConnection ¶ added in v0.11.377
type BruinCloudConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token" sensitive:"true"`
}
func (BruinCloudConnection) GetName ¶ added in v0.11.377
func (c BruinCloudConnection) GetName() string
type CSVConnection ¶ added in v0.11.619
type CSVConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Path string `yaml:"path,omitempty" json:"path" mapstructure:"path"`
Encoding string `yaml:"encoding,omitempty" json:"encoding,omitempty" mapstructure:"encoding"`
Layout string `yaml:"layout,omitempty" json:"layout,omitempty" mapstructure:"layout"`
}
func (CSVConnection) GetName ¶ added in v0.11.619
func (c CSVConnection) GetName() string
type CassandraConnection ¶ added in v0.11.619
type CassandraConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Hosts []string `yaml:"hosts,omitempty" json:"hosts,omitempty" mapstructure:"hosts"`
Port int `yaml:"port,omitempty" json:"port,omitempty" mapstructure:"port" jsonschema:"default=9042"`
Keyspace string `yaml:"keyspace,omitempty" json:"keyspace,omitempty" mapstructure:"keyspace"`
Consistency string `yaml:"consistency,omitempty" json:"consistency,omitempty" mapstructure:"consistency"`
PageSize int `yaml:"page_size,omitempty" json:"page_size,omitempty" mapstructure:"page_size"`
Timeout string `yaml:"timeout,omitempty" json:"timeout,omitempty" mapstructure:"timeout"`
ConnectTimeout string `yaml:"connect_timeout,omitempty" json:"connect_timeout,omitempty" mapstructure:"connect_timeout"`
SSL bool `yaml:"ssl,omitempty" json:"ssl,omitempty" mapstructure:"ssl"`
DisableInitialHostLookup bool `` /* 132-byte string literal not displayed */
}
func (CassandraConnection) GetName ¶ added in v0.11.619
func (c CassandraConnection) GetName() string
type CatalogAuth ¶ added in v0.11.442
type CatalogAuth struct {
// AWS credentials (for Glue)
AccessKey string `yaml:"access_key,omitempty" json:"access_key,omitempty" mapstructure:"access_key" sensitive:"true"`
SecretKey string `yaml:"secret_key,omitempty" json:"secret_key,omitempty" mapstructure:"secret_key" sensitive:"true"`
SessionToken string `yaml:"session_token,omitempty" json:"session_token,omitempty" mapstructure:"session_token" sensitive:"true"`
// Postgres credentials (for DuckLake)
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
}
func (CatalogAuth) IsAWS ¶ added in v0.11.442
func (auth CatalogAuth) IsAWS() bool
func (CatalogAuth) IsPostgres ¶ added in v0.11.442
func (auth CatalogAuth) IsPostgres() bool
func (CatalogAuth) IsZero ¶ added in v0.11.455
func (auth CatalogAuth) IsZero() bool
type CatalogConfig ¶ added in v0.11.442
type CatalogConfig struct {
Type CatalogType `yaml:"type" json:"type" mapstructure:"type"`
// Glue-specific
CatalogID string `yaml:"catalog_id,omitempty" json:"catalog_id,omitempty" mapstructure:"catalog_id"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
// DuckDB and SQLite-specific
Path string `yaml:"path,omitempty" json:"path,omitempty" mapstructure:"path"`
// Postgres-specific
Host string `yaml:"host,omitempty" json:"host,omitempty" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port,omitempty" mapstructure:"port"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
// Authentication
Auth CatalogAuth `yaml:"auth,omitempty" json:"auth,omitempty" mapstructure:"auth"`
}
func (CatalogConfig) IsZero ¶ added in v0.11.455
func (c CatalogConfig) IsZero() bool
type CatalogType ¶ added in v0.11.442
type CatalogType string
const ( CatalogTypeGlue CatalogType = "glue" // DuckLake Specific. CatalogTypePostgres CatalogType = "postgres" CatalogTypeDuckDB CatalogType = "duckdb" CatalogTypeSQLite CatalogType = "sqlite" )
type ChargebeeConnection ¶ added in v0.11.650
type ChargebeeConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Site string `yaml:"site,omitempty" json:"site" mapstructure:"site"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (ChargebeeConnection) GetName ¶ added in v0.11.650
func (c ChargebeeConnection) GetName() string
type ChessConnection ¶ added in v0.11.49
type ChessConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Players []string `` /* 279-byte string literal not displayed */
}
func (ChessConnection) GetName ¶ added in v0.11.49
func (c ChessConnection) GetName() string
type ClickHouseConnection ¶ added in v0.11.133
type ClickHouseConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username" json:"username" mapstructure:"username"`
Password string `yaml:"password" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host" json:"host" mapstructure:"host"`
Port int `yaml:"port" json:"port" mapstructure:"port"`
Database string `yaml:"database" json:"database" mapstructure:"database"`
HTTPPort int `yaml:"http_port,omitempty" json:"http_port,omitempty" mapstructure:"http_port"`
Secure *int `yaml:"secure,omitempty" json:"secure,omitempty" mapstructure:"secure"`
}
func (ClickHouseConnection) GetName ¶ added in v0.11.133
func (c ClickHouseConnection) GetName() string
type ClickupConnection ¶ added in v0.11.264
type ClickupConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token" sensitive:"true"`
}
func (ClickupConnection) GetName ¶ added in v0.11.264
func (c ClickupConnection) GetName() string
type ConcurrencyLimitedConnection ¶ added in v0.11.661
type Config ¶
type Config struct {
DefaultEnvironmentName string `yaml:"default_environment" json:"default_environment_name" mapstructure:"default_environment_name"`
SelectedEnvironmentName string `yaml:"-" json:"selected_environment_name" mapstructure:"selected_environment_name"`
SelectedEnvironment *Environment `yaml:"-" json:"selected_environment" mapstructure:"selected_environment"`
Environments map[string]Environment `yaml:"environments" json:"environments" mapstructure:"environments"`
// contains filtered or unexported fields
}
func LoadFromFileOrEnv ¶ added in v0.11.237
func LoadOrCreateWithoutPathAbsolutization ¶ added in v0.11.138
func (*Config) AddConnection ¶ added in v0.11.22
func (*Config) AddEnvironment ¶ added in v0.11.252
AddEnvironment adds a new environment to the configuration. If an environment with the given name already exists an error is returned. The schemaPrefix argument is optional and can be left empty.
func (*Config) CanRunTaskInstances ¶ added in v0.11.102
func (*Config) CloneEnvironment ¶ added in v0.11.280
CloneEnvironment creates a copy of an existing environment with a new name. If the source environment does not exist or the target name already exists, an error is returned. The schemaPrefix argument is optional and will override the source environment's schema prefix if provided.
func (*Config) DeleteConnection ¶ added in v0.11.22
func (*Config) DeleteEnvironment ¶ added in v0.11.254
DeleteEnvironment removes an environment from the configuration. If the environment does not exist, an error is returned.
func (*Config) EnvironmentExists ¶ added in v0.11.254
EnvironmentExists checks if an environment exists in the configuration.
func (*Config) GetEnvironmentNames ¶ added in v0.11.4
func (*Config) SelectEnvironment ¶
func (*Config) UpdateEnvironment ¶ added in v0.11.254
UpdateEnvironment updates an existing environment in the configuration. If the environment does not exist, an error is returned.
type ConnectionAndDetailsGetter ¶ added in v0.11.267
type ConnectionAndDetailsGetter interface {
ConnectionGetter
ConnectionDetailsGetter
}
type ConnectionDetailsGetter ¶ added in v0.11.266
type ConnectionFieldDef ¶ added in v0.11.475
type ConnectionFieldDef struct {
Name string // mapstructure tag value (e.g. "username")
Type string // "string", "int", or "bool"
DefaultValue string // from jsonschema "default=..." tag, empty if none
IsRequired bool // true when the yaml tag does NOT contain "omitempty"
}
ConnectionFieldDef describes a single field on a connection struct.
func GetConnectionFieldsForType ¶ added in v0.11.475
func GetConnectionFieldsForType(typeName string) []ConnectionFieldDef
GetConnectionFieldsForType returns the credential fields for a specific connection type, or nil if the type is not found.
type ConnectionGetter ¶ added in v0.11.255
type ConnectionMetadata ¶ added in v0.11.661
type ConnectionMetadata struct {
Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
MaxConcurrentAssets *int `yaml:"max_concurrent_assets,omitempty" json:"max_concurrent_assets,omitempty" mapstructure:"max_concurrent_assets"`
}
func (ConnectionMetadata) GetMaxConcurrentAssets ¶ added in v0.11.661
func (c ConnectionMetadata) GetMaxConcurrentAssets() *int
func (ConnectionMetadata) GetName ¶ added in v0.11.661
func (c ConnectionMetadata) GetName() string
type ConnectionResolver ¶ added in v0.11.674
ConnectionResolver is an optional counterpart to ConnectionGetter for implementations that can explain why a lookup failed. GetConnection returns a bare nil, which cannot distinguish "no such connection" from "the secrets backend rejected our credentials".
A nil connection with a nil error means the connection does not exist.
type ConnectionTypeDef ¶ added in v0.11.475
type ConnectionTypeDef struct {
TypeName string // yaml tag on the Connections struct (e.g. "snowflake")
Fields []ConnectionFieldDef // sorted alphabetically by Name
}
ConnectionTypeDef groups a connection type name with its credential fields.
func GetConnectionTypeDefs ¶ added in v0.11.475
func GetConnectionTypeDefs() []ConnectionTypeDef
GetConnectionTypeDefs reflects over the Connections struct and returns a sorted list of all connection types with their fields.
type Connections ¶
type Connections struct {
AwsConnection []AwsConnection `yaml:"aws,omitempty" json:"aws,omitempty" mapstructure:"aws"`
AthenaConnection []AthenaConnection `yaml:"athena,omitempty" json:"athena,omitempty" mapstructure:"athena"`
GoogleCloudPlatform []GoogleCloudPlatformConnection `yaml:"google_cloud_platform,omitempty" json:"google_cloud_platform,omitempty" mapstructure:"google_cloud_platform"`
Snowflake []SnowflakeConnection `yaml:"snowflake,omitempty" json:"snowflake,omitempty" mapstructure:"snowflake"`
Postgres []PostgresConnection `yaml:"postgres,omitempty" json:"postgres,omitempty" mapstructure:"postgres"`
RedShift []RedshiftConnection `yaml:"redshift,omitempty" json:"redshift,omitempty" mapstructure:"redshift"`
MsSQL []MsSQLConnection `yaml:"mssql,omitempty" json:"mssql,omitempty" mapstructure:"mssql"`
Databricks []DatabricksConnection `yaml:"databricks,omitempty" json:"databricks,omitempty" mapstructure:"databricks"`
ADLS []ADLSConnection `yaml:"adls,omitempty" json:"adls,omitempty" mapstructure:"adls"`
Synapse []SynapseConnection `yaml:"synapse,omitempty" json:"synapse,omitempty" mapstructure:"synapse"`
Fabric []FabricConnection `yaml:"fabric,omitempty" json:"fabric,omitempty" mapstructure:"fabric"`
OneLake []OneLakeConnection `yaml:"onelake,omitempty" json:"onelake,omitempty" mapstructure:"onelake"`
Mongo []MongoConnection `yaml:"mongo,omitempty" json:"mongo,omitempty" mapstructure:"mongo"`
Cassandra []CassandraConnection `yaml:"cassandra,omitempty" json:"cassandra,omitempty" mapstructure:"cassandra"`
Couchbase []CouchbaseConnection `yaml:"couchbase,omitempty" json:"couchbase,omitempty" mapstructure:"couchbase"`
CrateDB []CrateDBConnection `yaml:"cratedb,omitempty" json:"cratedb,omitempty" mapstructure:"cratedb"`
CSV []CSVConnection `yaml:"csv,omitempty" json:"csv,omitempty" mapstructure:"csv"`
Cursor []CursorConnection `yaml:"cursor,omitempty" json:"cursor,omitempty" mapstructure:"cursor"`
MongoAtlas []MongoAtlasConnection `yaml:"mongo_atlas,omitempty" json:"mongo_atlas,omitempty" mapstructure:"mongo_atlas"`
MySQL []MySQLConnection `yaml:"mysql,omitempty" json:"mysql,omitempty" mapstructure:"mysql"`
Doris []DorisConnection `yaml:"doris,omitempty" json:"doris,omitempty" mapstructure:"doris"`
Vitess []VitessConnection `yaml:"vitess,omitempty" json:"vitess,omitempty" mapstructure:"vitess"`
Planetscale []PlanetScaleConnection `yaml:"planetscale_mysql,omitempty" json:"planetscale_mysql,omitempty" mapstructure:"planetscale_mysql"`
Notion []NotionConnection `yaml:"notion,omitempty" json:"notion,omitempty" mapstructure:"notion"`
Allium []AlliumConnection `yaml:"allium,omitempty" json:"allium,omitempty" mapstructure:"allium"`
HANA []HANAConnection `yaml:"hana,omitempty" json:"hana,omitempty" mapstructure:"hana"`
Hostaway []HostawayConnection `yaml:"hostaway,omitempty" json:"hostaway,omitempty" mapstructure:"hostaway"`
HTTP []HTTPConnection `yaml:"http,omitempty" json:"http,omitempty" mapstructure:"http"`
Shopify []ShopifyConnection `yaml:"shopify,omitempty" json:"shopify,omitempty" mapstructure:"shopify"`
Gorgias []GorgiasConnection `yaml:"gorgias,omitempty" json:"gorgias,omitempty" mapstructure:"gorgias"`
G2 []G2Connection `yaml:"g2,omitempty" json:"g2,omitempty" mapstructure:"g2"`
Klaviyo []KlaviyoConnection `yaml:"klaviyo,omitempty" json:"klaviyo,omitempty" mapstructure:"klaviyo"`
Adjust []AdjustConnection `yaml:"adjust,omitempty" json:"adjust,omitempty" mapstructure:"adjust"`
Adapty []AdaptyConnection `yaml:"adapty,omitempty" json:"adapty,omitempty" mapstructure:"adapty"`
Anthropic []AnthropicConnection `yaml:"anthropic,omitempty" json:"anthropic,omitempty" mapstructure:"anthropic"`
Generic []GenericConnection `yaml:"generic,omitempty" json:"generic,omitempty" mapstructure:"generic"`
FacebookAds []FacebookAdsConnection `yaml:"facebookads,omitempty" json:"facebookads,omitempty" mapstructure:"facebookads"`
Stripe []StripeConnection `yaml:"stripe,omitempty" json:"stripe,omitempty" mapstructure:"stripe"`
Paddle []PaddleConnection `yaml:"paddle,omitempty" json:"paddle,omitempty" mapstructure:"paddle"`
Chargebee []ChargebeeConnection `yaml:"chargebee,omitempty" json:"chargebee,omitempty" mapstructure:"chargebee"`
Recurly []RecurlyConnection `yaml:"recurly,omitempty" json:"recurly,omitempty" mapstructure:"recurly"`
GitLab []GitLabConnection `yaml:"gitlab,omitempty" json:"gitlab,omitempty" mapstructure:"gitlab"`
Appsflyer []AppsflyerConnection `yaml:"appsflyer,omitempty" json:"appsflyer,omitempty" mapstructure:"appsflyer"`
Kafka []KafkaConnection `yaml:"kafka,omitempty" json:"kafka,omitempty" mapstructure:"kafka"`
RabbitMQ []RabbitMQConnection `yaml:"rabbitmq,omitempty" json:"rabbitmq,omitempty" mapstructure:"rabbitmq"`
DuckDB []DuckDBConnection `yaml:"duckdb,omitempty" json:"duckdb,omitempty" mapstructure:"duckdb"`
MotherDuck []MotherduckConnection `yaml:"motherduck,omitempty" json:"motherduck,omitempty" mapstructure:"motherduck"`
ClickHouse []ClickHouseConnection `yaml:"clickhouse,omitempty" json:"clickhouse,omitempty" mapstructure:"clickhouse"`
Hubspot []HubspotConnection `yaml:"hubspot,omitempty" json:"hubspot,omitempty" mapstructure:"hubspot"`
Intercom []IntercomConnection `yaml:"intercom,omitempty" json:"intercom,omitempty" mapstructure:"intercom"`
GitHub []GitHubConnection `yaml:"github,omitempty" json:"github,omitempty" mapstructure:"github"`
GoogleSheets []GoogleSheetsConnection `yaml:"google_sheets,omitempty" json:"google_sheets,omitempty" mapstructure:"google_sheets"`
Chess []ChessConnection `yaml:"chess,omitempty" json:"chess,omitempty" mapstructure:"chess"`
Airtable []AirtableConnection `yaml:"airtable,omitempty" json:"airtable,omitempty" mapstructure:"airtable"`
Granola []GranolaConnection `yaml:"granola,omitempty" json:"granola,omitempty" mapstructure:"granola"`
Zendesk []ZendeskConnection `yaml:"zendesk,omitempty" json:"zendesk,omitempty" mapstructure:"zendesk"`
Kalshi []KalshiConnection `yaml:"kalshi,omitempty" json:"kalshi,omitempty" mapstructure:"kalshi"`
TikTokAds []TikTokAdsConnection `yaml:"tiktokads,omitempty" json:"tiktokads,omitempty" mapstructure:"tiktokads"`
SnapchatAds []SnapchatAdsConnection `yaml:"snapchatads,omitempty" json:"snapchatads,omitempty" mapstructure:"snapchatads"`
S3 []S3Connection `yaml:"s3,omitempty" json:"s3,omitempty" mapstructure:"s3"`
Slack []SlackConnection `yaml:"slack,omitempty" json:"slack,omitempty" mapstructure:"slack"`
Socrata []SocrataConnection `yaml:"socrata,omitempty" json:"socrata,omitempty" mapstructure:"socrata"`
Asana []AsanaConnection `yaml:"asana,omitempty" json:"asana,omitempty" mapstructure:"asana"`
DynamoDB []DynamoDBConnection `yaml:"dynamodb,omitempty" json:"dynamodb,omitempty" mapstructure:"dynamodb"`
Docebo []DoceboConnection `yaml:"docebo,omitempty" json:"docebo,omitempty" mapstructure:"docebo"`
GoogleAds []GoogleAdsConnection `yaml:"googleads,omitempty" json:"googleads,omitempty" mapstructure:"googleads"`
AppStore []AppStoreConnection `yaml:"appstore,omitempty" json:"appstore,omitempty" mapstructure:"appstore"`
AppleAds []AppleAdsConnection `yaml:"appleads,omitempty" json:"appleads,omitempty" mapstructure:"appleads"`
LinkedInAds []LinkedInAdsConnection `yaml:"linkedinads,omitempty" json:"linkedinads,omitempty" mapstructure:"linkedinads"`
RedditAds []RedditAdsConnection `yaml:"reddit_ads,omitempty" json:"reddit_ads,omitempty" mapstructure:"reddit_ads"`
Mailchimp []MailchimpConnection `yaml:"mailchimp,omitempty" json:"mailchimp,omitempty" mapstructure:"mailchimp"`
Manifold []ManifoldConnection `yaml:"manifold,omitempty" json:"manifold,omitempty" mapstructure:"manifold"`
RevenueCat []RevenueCatConnection `yaml:"revenuecat,omitempty" json:"revenuecat,omitempty" mapstructure:"revenuecat"`
Linear []LinearConnection `yaml:"linear,omitempty" json:"linear,omitempty" mapstructure:"linear"`
GCS []GCSConnection `yaml:"gcs,omitempty" json:"gcs,omitempty" mapstructure:"gcs"`
Iceberg []IcebergConnection `yaml:"iceberg,omitempty" json:"iceberg,omitempty" mapstructure:"iceberg"`
ApplovinMax []ApplovinMaxConnection `yaml:"applovinmax,omitempty" json:"applovinmax,omitempty" mapstructure:"applovinmax"`
Personio []PersonioConnection `yaml:"personio,omitempty" json:"personio,omitempty" mapstructure:"personio"`
Kinesis []KinesisConnection `yaml:"kinesis,omitempty" json:"kinesis,omitempty" mapstructure:"kinesis"`
Pipedrive []PipedriveConnection `yaml:"pipedrive,omitempty" json:"pipedrive,omitempty" mapstructure:"pipedrive"`
Polymarket []PolymarketConnection `yaml:"polymarket,omitempty" json:"polymarket,omitempty" mapstructure:"polymarket"`
Mixpanel []MixpanelConnection `yaml:"mixpanel,omitempty" json:"mixpanel,omitempty" mapstructure:"mixpanel"`
Amplitude []AmplitudeConnection `yaml:"amplitude,omitempty" json:"amplitude,omitempty" mapstructure:"amplitude"`
Fastspring []FastspringConnection `yaml:"fastspring,omitempty" json:"fastspring,omitempty" mapstructure:"fastspring"`
Payrails []PayrailsConnection `yaml:"payrails,omitempty" json:"payrails,omitempty" mapstructure:"payrails"`
Clickup []ClickupConnection `yaml:"clickup,omitempty" json:"clickup,omitempty" mapstructure:"clickup"`
Jobtread []JobtreadConnection `yaml:"jobtread,omitempty" json:"jobtread,omitempty" mapstructure:"jobtread"`
Posthog []PosthogConnection `yaml:"posthog,omitempty" json:"posthog,omitempty" mapstructure:"posthog"`
Pinterest []PinterestConnection `yaml:"pinterest,omitempty" json:"pinterest,omitempty" mapstructure:"pinterest"`
Trustpilot []TrustpilotConnection `yaml:"trustpilot,omitempty" json:"trustpilot,omitempty" mapstructure:"trustpilot"`
QuickBooks []QuickBooksConnection `yaml:"quickbooks,omitempty" json:"quickbooks,omitempty" mapstructure:"quickbooks"`
Wise []WiseConnection `yaml:"wise,omitempty" json:"wise,omitempty" mapstructure:"wise"`
Wistia []WistiaConnection `yaml:"wistia,omitempty" json:"wistia,omitempty" mapstructure:"wistia"`
Zoom []ZoomConnection `yaml:"zoom,omitempty" json:"zoom,omitempty" mapstructure:"zoom"`
EMRServerless []EMRServerlessConnection `yaml:"emr_serverless,omitempty" json:"emr_serverless,omitempty" mapstructure:"emr_serverless"`
DataprocServerless []DataprocServerlessConnection `yaml:"dataproc_serverless,omitempty" json:"dataproc_serverless,omitempty" mapstructure:"dataproc_serverless"`
GoogleAnalytics []GoogleAnalyticsConnection `yaml:"googleanalytics,omitempty" json:"googleanalytics,omitempty" mapstructure:"googleanalytics"`
GSC []GSCConnection `yaml:"gsc,omitempty" json:"gsc,omitempty" mapstructure:"gsc"`
AppLovin []AppLovinConnection `yaml:"applovin,omitempty" json:"applovin,omitempty" mapstructure:"applovin"`
Frankfurter []FrankfurterConnection `yaml:"frankfurter,omitempty" json:"frankfurter,omitempty" mapstructure:"frankfurter"`
Salesforce []SalesforceConnection `yaml:"salesforce,omitempty" json:"salesforce,omitempty" mapstructure:"salesforce"`
SQLite []SQLiteConnection `yaml:"sqlite,omitempty" json:"sqlite,omitempty" mapstructure:"sqlite"`
DB2 []DB2Connection `yaml:"db2,omitempty" json:"db2,omitempty" mapstructure:"db2"`
Oracle []OracleConnection `yaml:"oracle,omitempty" json:"oracle,omitempty" mapstructure:"oracle"`
Phantombuster []PhantombusterConnection `yaml:"phantombuster,omitempty" json:"phantombuster,omitempty" mapstructure:"phantombuster"`
Elasticsearch []ElasticsearchConnection `yaml:"elasticsearch,omitempty" json:"elasticsearch,omitempty" mapstructure:"elasticsearch"`
Solidgate []SolidgateConnection `yaml:"solidgate,omitempty" json:"solidgate,omitempty" mapstructure:"solidgate"`
Square []SquareConnection `yaml:"square,omitempty" json:"square,omitempty" mapstructure:"square"`
Spanner []SpannerConnection `yaml:"spanner,omitempty" json:"spanner,omitempty" mapstructure:"spanner"`
Smartsheet []SmartsheetConnection `yaml:"smartsheet,omitempty" json:"smartsheet,omitempty" mapstructure:"smartsheet"`
Attio []AttioConnection `yaml:"attio,omitempty" json:"attio,omitempty" mapstructure:"attio"`
Sftp []SFTPConnection `yaml:"sftp,omitempty" json:"sftp,omitempty" mapstructure:"sftp"`
ISOCPulse []ISOCPulseConnection `yaml:"isoc_pulse,omitempty" json:"isoc_pulse,omitempty" mapstructure:"isoc_pulse"`
InfluxDB []InfluxDBConnection `yaml:"influxdb,omitempty" json:"influxdb,omitempty" mapstructure:"influxdb"`
Tableau []TableauConnection `yaml:"tableau,omitempty" json:"tableau,omitempty" mapstructure:"tableau"`
QuickSight []QuickSightConnection `yaml:"quicksight,omitempty" json:"quicksight,omitempty" mapstructure:"quicksight"`
Trino []TrinoConnection `yaml:"trino,omitempty" json:"trino,omitempty" mapstructure:"trino"`
StarRocks []StarRocksConnection `yaml:"starrocks,omitempty" json:"starrocks,omitempty" mapstructure:"starrocks"`
Dremio []DremioConnection `yaml:"dremio,omitempty" json:"dremio,omitempty" mapstructure:"dremio"`
Sail []SailConnection `yaml:"sail,omitempty" json:"sail,omitempty" mapstructure:"sail"`
Fluxx []FluxxConnection `yaml:"fluxx,omitempty" json:"fluxx,omitempty" mapstructure:"fluxx"`
Freshdesk []FreshdeskConnection `yaml:"freshdesk,omitempty" json:"freshdesk,omitempty" mapstructure:"freshdesk"`
FundraiseUp []FundraiseUpConnection `yaml:"fundraiseup,omitempty" json:"fundraiseup,omitempty" mapstructure:"fundraiseup"`
Fireflies []FirefliesConnection `yaml:"fireflies,omitempty" json:"fireflies,omitempty" mapstructure:"fireflies"`
Trello []TrelloConnection `yaml:"trello,omitempty" json:"trello,omitempty" mapstructure:"trello"`
Jira []JiraConnection `yaml:"jira,omitempty" json:"jira,omitempty" mapstructure:"jira"`
Monday []MondayConnection `yaml:"monday,omitempty" json:"monday,omitempty" mapstructure:"monday"`
PlusVibeAI []PlusVibeAIConnection `yaml:"plusvibeai,omitempty" json:"plusvibeai,omitempty" mapstructure:"plusvibeai"`
BruinCloud []BruinCloudConnection `yaml:"bruin,omitempty" json:"bruin,omitempty" mapstructure:"bruin"`
Primer []PrimerConnection `yaml:"primer,omitempty" json:"primer,omitempty" mapstructure:"primer"`
Indeed []IndeedConnection `yaml:"indeed,omitempty" json:"indeed,omitempty" mapstructure:"indeed"`
CustomerIo []CustomerIoConnection `yaml:"customerio,omitempty" json:"customerio,omitempty" mapstructure:"customerio"`
Sendgrid []SendgridConnection `yaml:"sendgrid,omitempty" json:"sendgrid,omitempty" mapstructure:"sendgrid"`
Twilio []TwilioConnection `yaml:"twilio,omitempty" json:"twilio,omitempty" mapstructure:"twilio"`
Braze []BrazeConnection `yaml:"braze,omitempty" json:"braze,omitempty" mapstructure:"braze"`
Espn []EspnConnection `yaml:"espn,omitempty" json:"espn,omitempty" mapstructure:"espn"`
APIFootball []APIFootballConnection `yaml:"apifootball,omitempty" json:"apifootball,omitempty" mapstructure:"apifootball"`
FootballData []FootballDataConnection `yaml:"footballdata,omitempty" json:"footballdata,omitempty" mapstructure:"footballdata"`
BallDontLie []BallDontLieConnection `yaml:"balldontlie,omitempty" json:"balldontlie,omitempty" mapstructure:"balldontlie"`
Vertica []VerticaConnection `yaml:"vertica,omitempty" json:"vertica,omitempty" mapstructure:"vertica"`
SurveyMonkey []SurveyMonkeyConnection `yaml:"surveymonkey,omitempty" json:"surveymonkey,omitempty" mapstructure:"surveymonkey"`
Dune []DuneConnection `yaml:"dune,omitempty" json:"dune,omitempty" mapstructure:"dune"`
// contains filtered or unexported fields
}
func (*Connections) ConnectionConcurrencyLimits ¶ added in v0.11.661
func (c *Connections) ConnectionConcurrencyLimits() (map[string]int, error)
func (*Connections) ConnectionsSummaryList ¶ added in v0.11.22
func (c *Connections) ConnectionsSummaryList() map[string]string
func (*Connections) Exists ¶ added in v0.11.22
func (c *Connections) Exists(name string) bool
func (*Connections) GetConnection ¶ added in v0.11.635
func (c *Connections) GetConnection(name string) any
GetConnection returns the connection object registered under the given name, or nil if it does not exist. The returned value is a pointer to the typed connection struct (e.g. *PostgresConnection).
func (*Connections) MergeFrom ¶ added in v0.11.138
func (c *Connections) MergeFrom(source *Connections) error
MergeFrom implements ConnectionMerger interface.
type CouchbaseConnection ¶ added in v0.11.328
type CouchbaseConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Bucket string `yaml:"bucket,omitempty" json:"bucket,omitempty" mapstructure:"bucket"`
SSL bool `yaml:"ssl,omitempty" json:"ssl,omitempty" mapstructure:"ssl"`
}
func (CouchbaseConnection) GetName ¶ added in v0.11.328
func (c CouchbaseConnection) GetName() string
type CrateDBConnection ¶ added in v0.11.619
type CrateDBConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port,omitempty" mapstructure:"port" jsonschema:"default=5432"`
SslMode string `yaml:"ssl_mode,omitempty" json:"ssl_mode,omitempty" mapstructure:"ssl_mode"`
}
func (CrateDBConnection) GetName ¶ added in v0.11.619
func (c CrateDBConnection) GetName() string
type CursorConnection ¶ added in v0.11.337
type CursorConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (CursorConnection) GetName ¶ added in v0.11.337
func (c CursorConnection) GetName() string
type CustomerIoConnection ¶ added in v0.11.436
type CustomerIoConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
}
func (CustomerIoConnection) GetName ¶ added in v0.11.436
func (c CustomerIoConnection) GetName() string
type DB2Connection ¶ added in v0.11.191
type DB2Connection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port string `yaml:"port,omitempty" json:"port" mapstructure:"port"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
}
func (DB2Connection) GetName ¶ added in v0.11.191
func (c DB2Connection) GetName() string
type DatabricksConnection ¶ added in v0.11.20
type DatabricksConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Token string `yaml:"token,omitempty" json:"token,omitempty" mapstructure:"token" jsonschema:"oneof_required=token" sensitive:"true"`
Path string `yaml:"path,omitempty" json:"path" mapstructure:"path"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=443"`
Catalog string `yaml:"catalog,omitempty" json:"catalog" mapstructure:"catalog"`
Schema string `yaml:"schema,omitempty" json:"schema" mapstructure:"schema"`
ClientID string `yaml:"client_id,omitempty" json:"client_id,omitempty" mapstructure:"client_id" jsonschema:"oneof_required=oauth"`
ClientSecret string `` /* 141-byte string literal not displayed */
}
func (DatabricksConnection) GetName ¶ added in v0.11.22
func (c DatabricksConnection) GetName() string
type DataprocServerlessConnection ¶ added in v0.11.391
type DataprocServerlessConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ServiceAccountJSON string `` /* 128-byte string literal not displayed */
ServiceAccountFile string `yaml:"service_account_file,omitempty" json:"service_account_file,omitempty" mapstructure:"service_account_file"`
UseApplicationDefaultCredentials bool `` /* 156-byte string literal not displayed */
ProjectID string `yaml:"project_id,omitempty" json:"project_id" mapstructure:"project_id"`
Region string `yaml:"region" json:"region" mapstructure:"region"`
Workspace string `yaml:"workspace" json:"workspace" mapstructure:"workspace"`
ExecutionRole string `yaml:"execution_role" json:"execution_role" mapstructure:"execution_role"`
SubnetworkURI string `yaml:"subnetwork_uri,omitempty" json:"subnetwork_uri,omitempty" mapstructure:"subnetwork_uri"`
NetworkTags []string `yaml:"network_tags,omitempty" json:"network_tags,omitempty" mapstructure:"network_tags"`
KmsKey string `yaml:"kms_key,omitempty" json:"kms_key,omitempty" mapstructure:"kms_key"`
StagingBucket string `yaml:"staging_bucket,omitempty" json:"staging_bucket,omitempty" mapstructure:"staging_bucket"`
MetastoreService string `yaml:"metastore_service,omitempty" json:"metastore_service,omitempty" mapstructure:"metastore_service"`
}
func (DataprocServerlessConnection) GetName ¶ added in v0.11.391
func (c DataprocServerlessConnection) GetName() string
type DoceboConnection ¶ added in v0.11.296
type DoceboConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url" mapstructure:"base_url"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
}
func (DoceboConnection) GetName ¶ added in v0.11.296
func (c DoceboConnection) GetName() string
type DorisConnection ¶ added in v0.11.672
type DorisConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=9030"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Driver string `yaml:"driver,omitempty" json:"driver,omitempty" mapstructure:"driver"`
SslCaPath string `yaml:"ssl_ca_path,omitempty" json:"ssl_ca_path,omitempty" mapstructure:"ssl_ca_path"`
SslCertPath string `yaml:"ssl_cert_path,omitempty" json:"ssl_cert_path,omitempty" mapstructure:"ssl_cert_path"`
SslKeyPath string `yaml:"ssl_key_path,omitempty" json:"ssl_key_path,omitempty" mapstructure:"ssl_key_path"`
}
func (DorisConnection) GetName ¶ added in v0.11.672
func (c DorisConnection) GetName() string
type DremioConnection ¶ added in v0.11.616
type DremioConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host" json:"host" mapstructure:"host"`
Port int `yaml:"port" json:"port" mapstructure:"port"`
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
Token string `yaml:"token,omitempty" json:"token,omitempty" mapstructure:"token" sensitive:"true"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
TLS bool `yaml:"tls,omitempty" json:"tls,omitempty" mapstructure:"tls"`
TLSSkipVerify bool `yaml:"tls_skip_verify,omitempty" json:"tls_skip_verify,omitempty" mapstructure:"tls_skip_verify"`
}
DremioConnection holds the settings for a Dremio platform. Dremio is reached over the Arrow Flight SQL wire protocol. Authentication is either username/password (Dremio Software) or a bearer Token / PAT (Dremio Cloud).
func (DremioConnection) GetName ¶ added in v0.11.616
func (c DremioConnection) GetName() string
type DuckDBConnection ¶ added in v0.11.41
type DuckDBConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Path string `yaml:"path,omitempty" json:"path" mapstructure:"path"`
ReadOnly bool `yaml:"read_only,omitempty" json:"read_only,omitempty" mapstructure:"read_only"`
Lakehouse *LakehouseConfig `yaml:"lakehouse,omitempty" json:"lakehouse,omitempty" mapstructure:"lakehouse"`
}
func (DuckDBConnection) GetName ¶ added in v0.11.41
func (d DuckDBConnection) GetName() string
type DuneConnection ¶ added in v0.11.494
type DuneConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (DuneConnection) GetName ¶ added in v0.11.494
func (c DuneConnection) GetName() string
type DynamoDBConnection ¶ added in v0.11.123
type DynamoDBConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessKeyID string `yaml:"access_key_id,omitempty" json:"access_key_id" mapstructure:"access_key_id" sensitive:"true"`
SecretAccessKey string `yaml:"secret_access_key,omitempty" json:"secret_access_key" mapstructure:"secret_access_key" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region" mapstructure:"region"`
}
func (DynamoDBConnection) GetName ¶ added in v0.11.123
func (c DynamoDBConnection) GetName() string
type EMRServerlessConnection ¶ added in v0.11.187
type EMRServerlessConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessKey string `yaml:"access_key" json:"access_key" mapstructure:"access_key" sensitive:"true"`
SecretKey string `yaml:"secret_key" json:"secret_key" mapstructure:"secret_key" sensitive:"true"`
ApplicationID string `yaml:"application_id" json:"application_id" mapstructure:"application_id"`
ExecutionRole string `yaml:"execution_role" json:"execution_role" mapstructure:"execution_role"`
Region string `yaml:"region" json:"region" mapstructure:"region"`
Workspace string `yaml:"workspace" json:"workspace,omitempty" mapstructure:"workspace"`
}
func (EMRServerlessConnection) GetName ¶ added in v0.11.187
func (c EMRServerlessConnection) GetName() string
type ElasticsearchConnection ¶ added in v0.11.209
type ElasticsearchConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port"`
Secure string `yaml:"secure,omitempty" json:"secure" mapstructure:"secure" default:"true"`
VerifyCerts string `yaml:"verify_certs,omitempty" json:"verify_certs" mapstructure:"verify_certs" default:"true"`
}
func (ElasticsearchConnection) GetName ¶ added in v0.11.209
func (c ElasticsearchConnection) GetName() string
type EnvContextKey ¶ added in v0.11.170
type EnvContextKey string
const ( EnvironmentContextKey EnvContextKey = "environment" SecretsBackendContextKey EnvContextKey = "secrets_backend" EnvironmentNameContextKey EnvContextKey = "environment_name" ConfigFilePathContextKey EnvContextKey = "config_file_path" )
type Environment ¶
type Environment struct {
Connections *Connections `yaml:"connections" json:"connections" mapstructure:"connections"`
SchemaPrefix string `yaml:"schema_prefix,omitempty" json:"schema_prefix" mapstructure:"schema_prefix"`
Config *EnvironmentConfig `yaml:"config,omitempty" json:"config,omitempty" mapstructure:"config"`
}
type EnvironmentConfig ¶ added in v0.11.579
type EnvironmentConfig struct {
RefreshRestricted bool `yaml:"full_refresh_restricted,omitempty" json:"full_refresh_restricted,omitempty" mapstructure:"full_refresh_restricted"`
}
type EspnConnection ¶ added in v0.11.633
type EspnConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Sport string `yaml:"sport,omitempty" json:"sport,omitempty" mapstructure:"sport"`
League string `yaml:"league,omitempty" json:"league,omitempty" mapstructure:"league"`
Season string `yaml:"season,omitempty" json:"season,omitempty" mapstructure:"season"`
Limit int `yaml:"limit,omitempty" json:"limit,omitempty" mapstructure:"limit"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
}
func (EspnConnection) GetName ¶ added in v0.11.633
func (c EspnConnection) GetName() string
type FabricConnection ¶ added in v0.11.450
type FabricConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=1433"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
Options string `yaml:"options,omitempty" json:"options,omitempty" mapstructure:"options"`
UseAzureDefaultCredential bool `` /* 135-byte string literal not displayed */
ClientID string `yaml:"client_id,omitempty" json:"client_id,omitempty" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret,omitempty" mapstructure:"client_secret" sensitive:"true"`
TenantID string `yaml:"tenant_id,omitempty" json:"tenant_id,omitempty" mapstructure:"tenant_id"`
}
func (FabricConnection) GetName ¶ added in v0.11.450
func (c FabricConnection) GetName() string
type FacebookAdsConnection ¶ added in v0.11.30
type FacebookAdsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
AccountID string `yaml:"account_id,omitempty" json:"account_id" mapstructure:"account_id"`
}
func (FacebookAdsConnection) GetName ¶ added in v0.11.30
func (c FacebookAdsConnection) GetName() string
type FastspringConnection ¶ added in v0.11.682
type FastspringConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
}
func (FastspringConnection) GetName ¶ added in v0.11.682
func (c FastspringConnection) GetName() string
type FirefliesConnection ¶ added in v0.11.409
type FirefliesConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (FirefliesConnection) GetName ¶ added in v0.11.409
func (c FirefliesConnection) GetName() string
type FluxxConnection ¶ added in v0.11.287
type FluxxConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Instance string `yaml:"instance,omitempty" json:"instance" mapstructure:"instance"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
}
func (FluxxConnection) GetName ¶ added in v0.11.287
func (c FluxxConnection) GetName() string
type FootballDataConnection ¶ added in v0.11.636
type FootballDataConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Competition string `yaml:"competition,omitempty" json:"competition,omitempty" mapstructure:"competition"`
Season string `yaml:"season,omitempty" json:"season,omitempty" mapstructure:"season"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
Matchday string `yaml:"matchday,omitempty" json:"matchday,omitempty" mapstructure:"matchday"`
Status string `yaml:"status,omitempty" json:"status,omitempty" mapstructure:"status"`
Stage string `yaml:"stage,omitempty" json:"stage,omitempty" mapstructure:"stage"`
Group string `yaml:"group,omitempty" json:"group,omitempty" mapstructure:"group"`
UnfoldGoals bool `yaml:"unfold_goals,omitempty" json:"unfold_goals,omitempty" mapstructure:"unfold_goals"`
UnfoldBookings bool `yaml:"unfold_bookings,omitempty" json:"unfold_bookings,omitempty" mapstructure:"unfold_bookings"`
UnfoldSubs bool `yaml:"unfold_subs,omitempty" json:"unfold_subs,omitempty" mapstructure:"unfold_subs"`
UnfoldLineups bool `yaml:"unfold_lineups,omitempty" json:"unfold_lineups,omitempty" mapstructure:"unfold_lineups"`
}
func (FootballDataConnection) GetName ¶ added in v0.11.636
func (c FootballDataConnection) GetName() string
type FrankfurterConnection ¶ added in v0.11.189
type FrankfurterConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
}
func (FrankfurterConnection) GetName ¶ added in v0.11.189
func (c FrankfurterConnection) GetName() string
type FreshdeskConnection ¶ added in v0.11.311
type FreshdeskConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Domain string `yaml:"domain,omitempty" json:"domain" mapstructure:"domain"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (FreshdeskConnection) GetName ¶ added in v0.11.311
func (c FreshdeskConnection) GetName() string
type FundraiseUpConnection ¶ added in v0.11.296
type FundraiseUpConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (FundraiseUpConnection) GetName ¶ added in v0.11.296
func (c FundraiseUpConnection) GetName() string
type G2Connection ¶ added in v0.11.523
type G2Connection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token" sensitive:"true"`
}
func (G2Connection) GetName ¶ added in v0.11.523
func (c G2Connection) GetName() string
type GCSConnection ¶ added in v0.11.136
type GCSConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ServiceAccountFile string `` /* 160-byte string literal not displayed */
ServiceAccountJSON string `` /* 177-byte string literal not displayed */
BucketName string `yaml:"bucket_name,omitempty" json:"bucket_name,omitempty" mapstructure:"bucket_name"`
PathToFile string `yaml:"path_to_file,omitempty" json:"path_to_file,omitempty" mapstructure:"path_to_file"`
Layout string `yaml:"layout,omitempty" json:"layout,omitempty" mapstructure:"layout"`
}
func (GCSConnection) GetName ¶ added in v0.11.136
func (c GCSConnection) GetName() string
type GSCConnection ¶ added in v0.11.657
type GSCConnection struct {
Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
ServiceAccountFile string `yaml:"service_account_file,omitempty" json:"service_account_file,omitempty" mapstructure:"service_account_file"`
ServiceAccountJSON string `` /* 128-byte string literal not displayed */
SiteURL string `yaml:"site_url,omitempty" json:"site_url" mapstructure:"site_url"`
}
func (GSCConnection) GetName ¶ added in v0.11.657
func (c GSCConnection) GetName() string
type GenericConnection ¶
type GenericConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Value string `yaml:"value,omitempty" json:"value" mapstructure:"value" sensitive:"true"`
}
func (GenericConnection) GetName ¶ added in v0.11.22
func (c GenericConnection) GetName() string
func (GenericConnection) MarshalJSON ¶
func (c GenericConnection) MarshalJSON() ([]byte, error)
type GitHubConnection ¶ added in v0.11.130
type GitHubConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token,omitempty" mapstructure:"access_token" sensitive:"true"`
Owner string `yaml:"owner,omitempty" json:"owner" mapstructure:"owner"`
Repo string `yaml:"repo,omitempty" json:"repo" mapstructure:"repo"`
}
github://?access_token=<access_token>&owner=<owner>&repo=<repo>
func (GitHubConnection) GetName ¶ added in v0.11.130
func (c GitHubConnection) GetName() string
type GitLabConnection ¶ added in v0.11.640
type GitLabConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
}
func (GitLabConnection) GetName ¶ added in v0.11.640
func (c GitLabConnection) GetName() string
type GoogleAdsConnection ¶ added in v0.11.136
type GoogleAdsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
CustomerID string `yaml:"customer_id,omitempty" json:"customer_id" mapstructure:"customer_id"`
ServiceAccountJSON string `` /* 128-byte string literal not displayed */
ServiceAccountFile string `yaml:"service_account_file,omitempty" json:"service_account_file,omitempty" mapstructure:"service_account_file"`
DeveloperToken string `yaml:"dev_token,omitempty" json:"dev_token" mapstructure:"dev_token" sensitive:"true"`
LoginCustomerID string `yaml:"login_customer_id,omitempty" json:"login_customer_id,omitempty" mapstructure:"login_customer_id"`
}
func (GoogleAdsConnection) GetName ¶ added in v0.11.136
func (c GoogleAdsConnection) GetName() string
type GoogleAnalyticsConnection ¶ added in v0.11.184
type GoogleAnalyticsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ServiceAccountFile string `` /* 160-byte string literal not displayed */
ServiceAccountJSON string `` /* 177-byte string literal not displayed */
PropertyID string `yaml:"property_id,omitempty" json:"property_id" mapstructure:"property_id"`
}
func (GoogleAnalyticsConnection) GetName ¶ added in v0.11.184
func (c GoogleAnalyticsConnection) GetName() string
type GoogleCloudPlatformConnection ¶
type GoogleCloudPlatformConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ServiceAccountJSON string `` /* 128-byte string literal not displayed */
ServiceAccountFile string `` /* 133-byte string literal not displayed */
ProjectID string `yaml:"project_id,omitempty" json:"project_id" mapstructure:"project_id"`
Location string `yaml:"location,omitempty" json:"location,omitempty" mapstructure:"location"`
UseApplicationDefaultCredentials bool `` /* 156-byte string literal not displayed */
MaxBillableBytes *int64 `yaml:"max_billable_bytes,omitempty" json:"max_billable_bytes,omitempty" mapstructure:"max_billable_bytes"`
MaxQueryCost *float64 `yaml:"max_query_cost,omitempty" json:"max_query_cost,omitempty" mapstructure:"max_query_cost"`
MaxBillableBytesSoft *int64 `yaml:"max_billable_bytes_soft,omitempty" json:"max_billable_bytes_soft,omitempty" mapstructure:"max_billable_bytes_soft"`
MaxQueryCostSoft *float64 `yaml:"max_query_cost_soft,omitempty" json:"max_query_cost_soft,omitempty" mapstructure:"max_query_cost_soft"`
// contains filtered or unexported fields
}
func (*GoogleCloudPlatformConnection) GetCredentials ¶
func (c *GoogleCloudPlatformConnection) GetCredentials() *google.Credentials
func (GoogleCloudPlatformConnection) GetName ¶ added in v0.11.22
func (c GoogleCloudPlatformConnection) GetName() string
func (GoogleCloudPlatformConnection) MarshalJSON ¶
func (c GoogleCloudPlatformConnection) MarshalJSON() ([]byte, error)
func (GoogleCloudPlatformConnection) MarshalYAML ¶ added in v0.11.22
func (c GoogleCloudPlatformConnection) MarshalYAML() (interface{}, error)
func (*GoogleCloudPlatformConnection) SetCredentials ¶
func (c *GoogleCloudPlatformConnection) SetCredentials(cred *google.Credentials)
type GoogleSheetsConnection ¶ added in v0.11.47
type GoogleSheetsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ServiceAccountJSON string `` /* 128-byte string literal not displayed */
ServiceAccountFile string `` /* 133-byte string literal not displayed */
}
func (GoogleSheetsConnection) GetName ¶ added in v0.11.47
func (c GoogleSheetsConnection) GetName() string
type GorgiasConnection ¶ added in v0.11.5
type GorgiasConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Domain string `yaml:"domain,omitempty" json:"domain" mapstructure:"domain"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Email string `yaml:"email,omitempty" json:"email" mapstructure:"email"`
}
func (GorgiasConnection) GetName ¶ added in v0.11.22
func (c GorgiasConnection) GetName() string
type GranolaConnection ¶ added in v0.11.619
type GranolaConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (GranolaConnection) GetName ¶ added in v0.11.619
func (c GranolaConnection) GetName() string
type HANAConnection ¶ added in v0.8.2
type HANAConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
}
func (HANAConnection) GetName ¶ added in v0.11.22
func (c HANAConnection) GetName() string
type HTTPConnection ¶ added in v0.11.619
type HTTPConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
URL string `yaml:"url,omitempty" json:"url" mapstructure:"url"`
}
func (HTTPConnection) GetName ¶ added in v0.11.619
func (c HTTPConnection) GetName() string
type HostawayConnection ¶ added in v0.11.331
type HostawayConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (HostawayConnection) GetName ¶ added in v0.11.331
func (c HostawayConnection) GetName() string
type HubspotConnection ¶ added in v0.11.43
type HubspotConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (HubspotConnection) GetName ¶ added in v0.11.43
func (c HubspotConnection) GetName() string
type ISOCPulseConnection ¶ added in v0.11.244
type ISOCPulseConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Token string `yaml:"token,omitempty" json:"token" mapstructure:"token" sensitive:"true"`
}
func (ISOCPulseConnection) GetName ¶ added in v0.11.244
func (c ISOCPulseConnection) GetName() string
type IcebergAuth ¶ added in v0.11.686
type IcebergAuth struct {
// S3 / Glue credentials.
AccessKey string `yaml:"access_key,omitempty" json:"access_key,omitempty" mapstructure:"access_key" sensitive:"true"`
SecretKey string `yaml:"secret_key,omitempty" json:"secret_key,omitempty" mapstructure:"secret_key" sensitive:"true"`
SessionToken string `yaml:"session_token,omitempty" json:"session_token,omitempty" mapstructure:"session_token" sensitive:"true"`
// Postgres-catalog credentials.
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
}
IcebergAuth holds credentials for the catalog and/or storage backend.
type IcebergCatalog ¶ added in v0.11.686
type IcebergCatalog struct {
Type IcebergCatalogType `yaml:"type" json:"type" mapstructure:"type"`
CatalogID string `yaml:"catalog_id,omitempty" json:"catalog_id,omitempty" mapstructure:"catalog_id"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
Path string `yaml:"path,omitempty" json:"path,omitempty" mapstructure:"path"`
Host string `yaml:"host,omitempty" json:"host,omitempty" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port,omitempty" mapstructure:"port"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
Auth IcebergAuth `yaml:"auth,omitempty" json:"auth,omitempty" mapstructure:"auth"`
// Catalog credentials. These are dedicated fields (rather than free-form
// Properties entries) so the credential masker redacts them from run logs.
// Credential/Token are REST-catalog auth; URI is the SQL-catalog connection
// string (may embed a password).
Credential string `yaml:"credential,omitempty" json:"credential,omitempty" mapstructure:"credential" sensitive:"true"`
Token string `yaml:"token,omitempty" json:"token,omitempty" mapstructure:"token" sensitive:"true"`
URI string `yaml:"uri,omitempty" json:"uri,omitempty" mapstructure:"uri" sensitive:"true"`
}
IcebergCatalog describes the Iceberg catalog backend. Which fields apply depends on Type (glue: catalog_id/region; sqlite/hadoop: path; postgres/rest/hive: host).
type IcebergCatalogType ¶ added in v0.11.686
type IcebergCatalogType string
const ( IcebergCatalogGlue IcebergCatalogType = "glue" IcebergCatalogSQLite IcebergCatalogType = "sqlite" IcebergCatalogPostgres IcebergCatalogType = "postgres" IcebergCatalogREST IcebergCatalogType = "rest" IcebergCatalogHive IcebergCatalogType = "hive" IcebergCatalogHadoop IcebergCatalogType = "hadoop" IcebergCatalogSQL IcebergCatalogType = "sql" )
type IcebergConnection ¶ added in v0.11.686
type IcebergConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
// CatalogName is the logical catalog identifier (defaults to "ingestr").
CatalogName string `yaml:"catalog_name,omitempty" json:"catalog_name,omitempty" mapstructure:"catalog_name"`
Catalog IcebergCatalog `yaml:"catalog" json:"catalog" mapstructure:"catalog"`
Storage IcebergStorage `yaml:"storage" json:"storage" mapstructure:"storage"`
// Table/namespace behaviour (ingestr destination write options).
CreateNamespace *bool `yaml:"create_namespace,omitempty" json:"create_namespace,omitempty" mapstructure:"create_namespace"`
TableLocation string `yaml:"table_location,omitempty" json:"table_location,omitempty" mapstructure:"table_location"`
TablePath string `yaml:"table_path,omitempty" json:"table_path,omitempty" mapstructure:"table_path"`
// TableProperties are Iceberg table properties, emitted as table.<key>=<value>
// (e.g. {"write.format.default": "parquet"}).
TableProperties map[string]string `yaml:"table_properties,omitempty" json:"table_properties,omitempty" mapstructure:"table_properties"`
// Properties is a passthrough for non-secret ingestr Iceberg URI parameters
// (e.g. oauth2-server-uri, s3.* / glue.* non-credential overrides). Its values
// are NOT redacted from logs, so credentials must go in the dedicated fields
// (catalog.auth, catalog.credential, catalog.token, catalog.uri, storage.auth),
// never here.
Properties map[string]string `yaml:"properties,omitempty" json:"properties,omitempty" mapstructure:"properties"`
}
IcebergConnection is a first-class ingestr destination for Apache Iceberg, described by a catalog and a storage block (plus optional table settings).
func (IcebergConnection) GetName ¶ added in v0.11.686
func (c IcebergConnection) GetName() string
type IcebergStorage ¶ added in v0.11.686
type IcebergStorage struct {
Type IcebergStorageType `yaml:"type" json:"type" mapstructure:"type"`
// Path is the full s3://<bucket>/<prefix> warehouse location.
Path string `yaml:"path,omitempty" json:"path,omitempty" mapstructure:"path"`
// Bucket/Prefix are an alternative to Path: the bucket name and an optional
// key prefix, from which the s3://<bucket>/<prefix> warehouse is built.
Bucket string `yaml:"bucket,omitempty" json:"bucket,omitempty" mapstructure:"bucket"`
Prefix string `yaml:"prefix,omitempty" json:"prefix,omitempty" mapstructure:"prefix"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
Endpoint string `yaml:"endpoint,omitempty" json:"endpoint,omitempty" mapstructure:"endpoint"`
UseSSL *bool `yaml:"use_ssl,omitempty" json:"use_ssl,omitempty" mapstructure:"use_ssl"`
Auth IcebergAuth `yaml:"auth,omitempty" json:"auth,omitempty" mapstructure:"auth"`
}
IcebergStorage describes the S3-compatible object store holding the data files.
The warehouse location can be given two ways (mutually exclusive): either as a full s3:// URI in Path, or as a separate Bucket (+ optional Prefix). Leave all three empty to let the catalog supply its own warehouse location.
type IcebergStorageType ¶ added in v0.11.686
type IcebergStorageType string
const (
IcebergStorageS3 IcebergStorageType = "s3"
)
type IndeedConnection ¶ added in v0.11.401
type IndeedConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
EmployerID string `yaml:"employer_id,omitempty" json:"employer_id" mapstructure:"employer_id"`
}
func (IndeedConnection) GetName ¶ added in v0.11.401
func (c IndeedConnection) GetName() string
type InfluxDBConnection ¶ added in v0.11.270
type InfluxDBConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port,omitempty" mapstructure:"port"`
Token string `yaml:"token,omitempty" json:"token" mapstructure:"token" sensitive:"true"`
Org string `yaml:"org,omitempty" json:"org" mapstructure:"org"`
Bucket string `yaml:"bucket,omitempty" json:"bucket" mapstructure:"bucket"`
Secure string `yaml:"secure,omitempty" json:"secure,omitempty" mapstructure:"secure" default:"true"`
}
func (InfluxDBConnection) GetName ¶ added in v0.11.270
func (c InfluxDBConnection) GetName() string
type IntercomConnection ¶ added in v0.11.298
type IntercomConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region" mapstructure:"region"`
}
func (IntercomConnection) GetName ¶ added in v0.11.298
func (c IntercomConnection) GetName() string
type JiraConnection ¶ added in v0.11.300
type JiraConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Domain string `yaml:"domain,omitempty" json:"domain" mapstructure:"domain"`
Email string `yaml:"email,omitempty" json:"email" mapstructure:"email"`
APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token" sensitive:"true"`
}
func (JiraConnection) GetName ¶ added in v0.11.300
func (c JiraConnection) GetName() string
type JobtreadConnection ¶ added in v0.11.523
type JobtreadConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
GrantKey string `yaml:"grant_key,omitempty" json:"grant_key" mapstructure:"grant_key" sensitive:"true"`
OrganizationID string `yaml:"organization_id,omitempty" json:"organization_id" mapstructure:"organization_id"`
}
func (JobtreadConnection) GetName ¶ added in v0.11.523
func (c JobtreadConnection) GetName() string
type KafkaConnection ¶ added in v0.11.40
type KafkaConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
BootstrapServers string `yaml:"bootstrap_servers,omitempty" json:"bootstrap_servers" mapstructure:"bootstrap_servers"`
GroupID string `yaml:"group_id,omitempty" json:"group_id" mapstructure:"group_id"`
SecurityProtocol string `yaml:"security_protocol,omitempty" json:"security_protocol,omitempty" mapstructure:"security_protocol"`
SaslMechanisms string `yaml:"sasl_mechanisms,omitempty" json:"sasl_mechanisms,omitempty" mapstructure:"sasl_mechanisms"`
SaslUsername string `yaml:"sasl_username,omitempty" json:"sasl_username,omitempty" mapstructure:"sasl_username"`
SaslPassword string `yaml:"sasl_password,omitempty" json:"sasl_password,omitempty" mapstructure:"sasl_password" sensitive:"true"`
BatchSize string `yaml:"batch_size,omitempty" json:"batch_size,omitempty" mapstructure:"batch_size"`
BatchTimeout string `yaml:"batch_timeout,omitempty" json:"batch_timeout,omitempty" mapstructure:"batch_timeout"`
}
func (KafkaConnection) GetName ¶ added in v0.11.40
func (c KafkaConnection) GetName() string
type KalshiConnection ¶ added in v0.11.619
type KalshiConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
QueryParams map[string]string `yaml:"query_params,omitempty" json:"query_params,omitempty" mapstructure:"query_params"`
}
func (KalshiConnection) GetName ¶ added in v0.11.619
func (c KalshiConnection) GetName() string
type KinesisConnection ¶ added in v0.11.161
type KinesisConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessKeyID string `yaml:"access_key_id,omitempty" json:"access_key_id" mapstructure:"access_key_id" sensitive:"true"`
SecretAccessKey string `yaml:"secret_access_key,omitempty" json:"secret_access_key" mapstructure:"secret_access_key" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region" mapstructure:"region"`
}
func (KinesisConnection) GetName ¶ added in v0.11.161
func (c KinesisConnection) GetName() string
type KlaviyoConnection ¶ added in v0.11.26
type KlaviyoConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (KlaviyoConnection) GetName ¶ added in v0.11.26
func (c KlaviyoConnection) GetName() string
type LakehouseConfig ¶ added in v0.11.442
type LakehouseConfig struct {
Format LakehouseFormat `yaml:"format" json:"format" mapstructure:"format"`
Catalog CatalogConfig `yaml:"catalog,omitempty" json:"catalog,omitempty" mapstructure:"catalog"`
Storage StorageConfig `yaml:"storage,omitempty" json:"storage,omitempty" mapstructure:"storage"`
}
func (*LakehouseConfig) IsZero ¶ added in v0.11.455
func (lh *LakehouseConfig) IsZero() bool
func (*LakehouseConfig) Validate ¶ added in v0.11.442
func (lh *LakehouseConfig) Validate() error
Validate performs basic structural validation of the LakehouseConfig (engine-agnostic).
type LakehouseFormat ¶ added in v0.11.442
type LakehouseFormat string
const ( LakehouseFormatIceberg LakehouseFormat = "iceberg" LakehouseFormatDuckLake LakehouseFormat = "ducklake" )
type LinearConnection ¶ added in v0.11.249
type LinearConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (LinearConnection) GetName ¶ added in v0.11.249
func (c LinearConnection) GetName() string
type LinkedInAdsConnection ¶ added in v0.11.133
type LinkedInAdsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
AccountIds string `yaml:"account_ids,omitempty" json:"account_ids" mapstructure:"account_ids"`
}
func (LinkedInAdsConnection) GetName ¶ added in v0.11.133
func (c LinkedInAdsConnection) GetName() string
type MailchimpConnection ¶ added in v0.11.319
type MailchimpConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Server string `yaml:"server,omitempty" json:"server" mapstructure:"server"`
}
func (MailchimpConnection) GetName ¶ added in v0.11.319
func (c MailchimpConnection) GetName() string
type ManifoldConnection ¶ added in v0.11.619
type ManifoldConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
QueryParams map[string]string `yaml:"query_params,omitempty" json:"query_params,omitempty" mapstructure:"query_params"`
QueryParamLists map[string][]string `yaml:"query_param_lists,omitempty" json:"query_param_lists,omitempty" mapstructure:"query_param_lists"`
}
func (ManifoldConnection) GetName ¶ added in v0.11.619
func (c ManifoldConnection) GetName() string
type MissingConnectionError ¶ added in v0.11.472
type MissingConnectionError struct {
Role string
Name string
SecretsBackend string
ConfigFilePath string
EnvironmentName string
}
MissingConnectionError is returned when a requested connection cannot be found.
func NewConnectionNotFoundError ¶ added in v0.11.472
func NewConnectionNotFoundError(ctx context.Context, role, name string) *MissingConnectionError
func (*MissingConnectionError) Error ¶ added in v0.11.472
func (e *MissingConnectionError) Error() string
type MixpanelConnection ¶ added in v0.11.238
type MixpanelConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
APISecret string `yaml:"api_secret,omitempty" json:"api_secret,omitempty" mapstructure:"api_secret" sensitive:"true"`
ProjectID string `yaml:"project_id,omitempty" json:"project_id,omitempty" mapstructure:"project_id"`
Server string `yaml:"server,omitempty" json:"server,omitempty" mapstructure:"server"`
}
func (MixpanelConnection) GetName ¶ added in v0.11.238
func (c MixpanelConnection) GetName() string
type MondayConnection ¶ added in v0.11.311
type MondayConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token" sensitive:"true"`
}
func (MondayConnection) GetName ¶ added in v0.11.311
func (c MondayConnection) GetName() string
type MongoAtlasConnection ¶ added in v0.11.309
type MongoAtlasConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
}
func (MongoAtlasConnection) GetName ¶ added in v0.11.309
func (c MongoAtlasConnection) GetName() string
type MongoConnection ¶ added in v0.7.2
type MongoConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=27017"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
}
func (MongoConnection) GetName ¶ added in v0.11.22
func (c MongoConnection) GetName() string
type MotherduckConnection ¶ added in v0.11.273
type MotherduckConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Token string `yaml:"token,omitempty" json:"token" mapstructure:"token" sensitive:"true"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
}
func (MotherduckConnection) GetName ¶ added in v0.11.273
func (m MotherduckConnection) GetName() string
type MsSQLConnection ¶ added in v0.5.6
type MsSQLConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=1433"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Options string `yaml:"options,omitempty" json:"options,omitempty" mapstructure:"options"`
}
func (MsSQLConnection) GetName ¶ added in v0.11.22
func (c MsSQLConnection) GetName() string
type MySQLConnection ¶ added in v0.7.8
type MySQLConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=3306"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Driver string `yaml:"driver,omitempty" json:"driver,omitempty" mapstructure:"driver"`
SslCaPath string `yaml:"ssl_ca_path,omitempty" json:"ssl_ca_path,omitempty" mapstructure:"ssl_ca_path"`
SslCertPath string `yaml:"ssl_cert_path,omitempty" json:"ssl_cert_path,omitempty" mapstructure:"ssl_cert_path"`
SslKeyPath string `yaml:"ssl_key_path,omitempty" json:"ssl_key_path,omitempty" mapstructure:"ssl_key_path"`
}
func (MySQLConnection) GetName ¶ added in v0.11.22
func (c MySQLConnection) GetName() string
type NotionConnection ¶ added in v0.7.9
type NotionConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (NotionConnection) GetName ¶ added in v0.11.22
func (c NotionConnection) GetName() string
type OneLakeConnection ¶ added in v0.11.608
type OneLakeConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
WorkspaceName string `yaml:"workspace_name,omitempty" json:"workspace_name" mapstructure:"workspace_name"`
LakehouseName string `yaml:"lakehouse_name,omitempty" json:"lakehouse_name" mapstructure:"lakehouse_name"`
TenantID string `yaml:"tenant_id,omitempty" json:"tenant_id,omitempty" mapstructure:"tenant_id"`
ClientID string `yaml:"client_id,omitempty" json:"client_id,omitempty" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret,omitempty" mapstructure:"client_secret" sensitive:"true"`
SASToken string `yaml:"sas_token,omitempty" json:"sas_token,omitempty" mapstructure:"sas_token" sensitive:"true"`
UseAzureDefaultCredential bool `` /* 135-byte string literal not displayed */
}
func (OneLakeConnection) GetName ¶ added in v0.11.608
func (c OneLakeConnection) GetName() string
type OracleConnection ¶ added in v0.11.193
type OracleConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port string `yaml:"port,omitempty" json:"port" mapstructure:"port"`
ServiceName string `yaml:"service_name,omitempty" json:"service_name" mapstructure:"service_name"`
SID string `yaml:"sid,omitempty" json:"sid" mapstructure:"sid"`
Role string `yaml:"role,omitempty" json:"role" mapstructure:"role"`
SSL bool `yaml:"ssl,omitempty" json:"ssl" mapstructure:"ssl"`
SSLVerify bool `yaml:"ssl_verify,omitempty" json:"ssl_verify" mapstructure:"ssl_verify"`
PrefetchRows int `yaml:"prefetch_rows,omitempty" json:"prefetch_rows" mapstructure:"prefetch_rows"`
TraceFile string `yaml:"trace_file,omitempty" json:"trace_file" mapstructure:"trace_file"`
Wallet string `yaml:"wallet,omitempty" json:"wallet" mapstructure:"wallet"`
}
func (OracleConnection) GetName ¶ added in v0.11.193
func (c OracleConnection) GetName() string
type PaddleConnection ¶ added in v0.11.623
type PaddleConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (PaddleConnection) GetName ¶ added in v0.11.623
func (c PaddleConnection) GetName() string
type PayrailsConnection ¶ added in v0.11.688
type PayrailsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
CertPath string `yaml:"cert_path,omitempty" json:"cert_path,omitempty" mapstructure:"cert_path"`
KeyPath string `yaml:"key_path,omitempty" json:"key_path,omitempty" mapstructure:"key_path"`
Cert string `yaml:"cert,omitempty" json:"cert,omitempty" mapstructure:"cert" sensitive:"true"`
Key string `yaml:"key,omitempty" json:"key,omitempty" mapstructure:"key" sensitive:"true"`
Environment string `yaml:"environment,omitempty" json:"environment,omitempty" mapstructure:"environment"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
}
func (PayrailsConnection) GetName ¶ added in v0.11.688
func (c PayrailsConnection) GetName() string
type PersonioConnection ¶ added in v0.11.139
type PersonioConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ClientID string `yaml:"client_id" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
}
func (PersonioConnection) GetName ¶ added in v0.11.139
func (c PersonioConnection) GetName() string
type PhantombusterConnection ¶ added in v0.11.203
type PhantombusterConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (PhantombusterConnection) GetName ¶ added in v0.11.203
func (c PhantombusterConnection) GetName() string
type PinterestConnection ¶ added in v0.11.248
type PinterestConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
}
func (PinterestConnection) GetName ¶ added in v0.11.248
func (c PinterestConnection) GetName() string
type PipedriveConnection ¶ added in v0.11.179
type PipedriveConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token" sensitive:"true"`
}
func (PipedriveConnection) GetName ¶ added in v0.11.179
func (c PipedriveConnection) GetName() string
type PlanetScaleConnection ¶ added in v0.11.661
type PlanetScaleConnection struct {
Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=3306"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
}
PlanetScaleConnection describes a connection to PlanetScale, the managed Vitess platform. It is configured under the "planetscale_mysql" connection type (the "_mysql" suffix distinguishes it from PlanetScale's Postgres offering). ingestr routes it through its "ps_mysql" scheme (hosted psdbconnect API) and enables TLS automatically, so no SSL configuration is required.
func (PlanetScaleConnection) GetName ¶ added in v0.11.661
func (c PlanetScaleConnection) GetName() string
type PlusVibeAIConnection ¶ added in v0.11.308
type PlusVibeAIConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
WorkspaceID string `yaml:"workspace_id,omitempty" json:"workspace_id" mapstructure:"workspace_id"`
}
func (PlusVibeAIConnection) GetName ¶ added in v0.11.308
func (c PlusVibeAIConnection) GetName() string
type PolymarketConnection ¶ added in v0.11.619
type PolymarketConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Order string `yaml:"order,omitempty" json:"order,omitempty" mapstructure:"order"`
Ascending string `yaml:"ascending,omitempty" json:"ascending,omitempty" mapstructure:"ascending"`
Slug string `yaml:"slug,omitempty" json:"slug,omitempty" mapstructure:"slug"`
Closed string `yaml:"closed,omitempty" json:"closed,omitempty" mapstructure:"closed"`
Live string `yaml:"live,omitempty" json:"live,omitempty" mapstructure:"live"`
Active string `yaml:"active,omitempty" json:"active,omitempty" mapstructure:"active"`
Archived string `yaml:"archived,omitempty" json:"archived,omitempty" mapstructure:"archived"`
Featured string `yaml:"featured,omitempty" json:"featured,omitempty" mapstructure:"featured"`
TagID string `yaml:"tag_id,omitempty" json:"tag_id,omitempty" mapstructure:"tag_id"`
TagSlug string `yaml:"tag_slug,omitempty" json:"tag_slug,omitempty" mapstructure:"tag_slug"`
SeriesID string `yaml:"series_id,omitempty" json:"series_id,omitempty" mapstructure:"series_id"`
IncludeChat string `yaml:"include_chat,omitempty" json:"include_chat,omitempty" mapstructure:"include_chat"`
IncludeTemplate string `yaml:"include_template,omitempty" json:"include_template,omitempty" mapstructure:"include_template"`
IncludeMarkets string `yaml:"include_markets,omitempty" json:"include_markets,omitempty" mapstructure:"include_markets"`
ClobTokenIDs string `yaml:"clob_token_ids,omitempty" json:"clob_token_ids,omitempty" mapstructure:"clob_token_ids"`
ConditionIDs string `yaml:"condition_ids,omitempty" json:"condition_ids,omitempty" mapstructure:"condition_ids"`
QuestionIDs string `yaml:"question_ids,omitempty" json:"question_ids,omitempty" mapstructure:"question_ids"`
RelatedTags string `yaml:"related_tags,omitempty" json:"related_tags,omitempty" mapstructure:"related_tags"`
IncludeTag string `yaml:"include_tag,omitempty" json:"include_tag,omitempty" mapstructure:"include_tag"`
RFQEnabled string `yaml:"rfq_enabled,omitempty" json:"rfq_enabled,omitempty" mapstructure:"rfq_enabled"`
Limit string `yaml:"limit,omitempty" json:"limit,omitempty" mapstructure:"limit"`
Offset string `yaml:"offset,omitempty" json:"offset,omitempty" mapstructure:"offset"`
ParentEntityID string `yaml:"parent_entity_id,omitempty" json:"parent_entity_id,omitempty" mapstructure:"parent_entity_id"`
ParentEntityType string `yaml:"parent_entity_type,omitempty" json:"parent_entity_type,omitempty" mapstructure:"parent_entity_type"`
Market string `yaml:"market,omitempty" json:"market,omitempty" mapstructure:"market"`
User string `yaml:"user,omitempty" json:"user,omitempty" mapstructure:"user"`
Q string `yaml:"q,omitempty" json:"q,omitempty" mapstructure:"q"`
EventsStatus string `yaml:"events_status,omitempty" json:"events_status,omitempty" mapstructure:"events_status"`
MarketsStatus string `yaml:"markets_status,omitempty" json:"markets_status,omitempty" mapstructure:"markets_status"`
TokenID string `yaml:"token_id,omitempty" json:"token_id,omitempty" mapstructure:"token_id"`
Side string `yaml:"side,omitempty" json:"side,omitempty" mapstructure:"side"`
Interval string `yaml:"interval,omitempty" json:"interval,omitempty" mapstructure:"interval"`
Fidelity string `yaml:"fidelity,omitempty" json:"fidelity,omitempty" mapstructure:"fidelity"`
TakerOnly string `yaml:"taker_only,omitempty" json:"taker_only,omitempty" mapstructure:"taker_only"`
FilterType string `yaml:"filter_type,omitempty" json:"filter_type,omitempty" mapstructure:"filter_type"`
FilterAmount string `yaml:"filter_amount,omitempty" json:"filter_amount,omitempty" mapstructure:"filter_amount"`
EventID string `yaml:"event_id,omitempty" json:"event_id,omitempty" mapstructure:"event_id"`
Type string `yaml:"type,omitempty" json:"type,omitempty" mapstructure:"type"`
}
func (PolymarketConnection) GetName ¶ added in v0.11.619
func (c PolymarketConnection) GetName() string
type PostgresConnection ¶ added in v0.5.0
type PostgresConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=5432"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Schema string `yaml:"schema,omitempty" json:"schema,omitempty" mapstructure:"schema"`
PoolMaxConns int `yaml:"pool_max_conns,omitempty" json:"pool_max_conns,omitempty" mapstructure:"pool_max_conns" default:"10"`
SslMode string `yaml:"ssl_mode,omitempty" json:"ssl_mode,omitempty" mapstructure:"ssl_mode" default:"allow"`
}
func (PostgresConnection) GetName ¶ added in v0.11.22
func (c PostgresConnection) GetName() string
type PosthogConnection ¶ added in v0.11.496
type PosthogConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
PersonalAPIKey string `yaml:"personal_api_key,omitempty" json:"personal_api_key" mapstructure:"personal_api_key" sensitive:"true"`
ProjectID string `yaml:"project_id,omitempty" json:"project_id" mapstructure:"project_id"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
}
func (PosthogConnection) GetName ¶ added in v0.11.496
func (c PosthogConnection) GetName() string
type PrimerConnection ¶ added in v0.11.377
type PrimerConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (PrimerConnection) GetName ¶ added in v0.11.377
func (c PrimerConnection) GetName() string
type QuickBooksConnection ¶ added in v0.11.239
type QuickBooksConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
CompanyID string `yaml:"company_id,omitempty" json:"company_id" mapstructure:"company_id"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
RefreshToken string `yaml:"refresh_token,omitempty" json:"refresh_token" mapstructure:"refresh_token" sensitive:"true"`
Environment string `yaml:"environment,omitempty" json:"environment,omitempty" mapstructure:"environment"`
MinorVersion string `yaml:"minor_version,omitempty" json:"minor_version,omitempty" mapstructure:"minor_version"`
}
func (QuickBooksConnection) GetName ¶ added in v0.11.239
func (c QuickBooksConnection) GetName() string
type QuickSightConnection ¶ added in v0.11.505
type QuickSightConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AwsAccessKeyID string `yaml:"aws_access_key_id,omitempty" json:"aws_access_key_id" mapstructure:"aws_access_key_id" sensitive:"true"`
AwsSecretAccessKey string `yaml:"aws_secret_access_key,omitempty" json:"aws_secret_access_key" mapstructure:"aws_secret_access_key" sensitive:"true"`
AwsSessionToken string `yaml:"aws_session_token,omitempty" json:"aws_session_token" mapstructure:"aws_session_token" sensitive:"true"`
AwsRegion string `yaml:"aws_region,omitempty" json:"aws_region" mapstructure:"aws_region"`
AwsAccountID string `yaml:"aws_account_id,omitempty" json:"aws_account_id" mapstructure:"aws_account_id"`
}
func (QuickSightConnection) GetName ¶ added in v0.11.505
func (c QuickSightConnection) GetName() string
type RabbitMQConnection ¶ added in v0.11.512
type RabbitMQConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port,omitempty" mapstructure:"port"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Vhost string `yaml:"vhost,omitempty" json:"vhost,omitempty" mapstructure:"vhost"`
TLS bool `yaml:"tls,omitempty" json:"tls,omitempty" mapstructure:"tls"`
}
func (RabbitMQConnection) GetName ¶ added in v0.11.512
func (c RabbitMQConnection) GetName() string
type RecurlyConnection ¶ added in v0.11.654
type RecurlyConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
}
func (RecurlyConnection) GetName ¶ added in v0.11.654
func (c RecurlyConnection) GetName() string
type RedditAdsConnection ¶ added in v0.11.619
type RedditAdsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token,omitempty" mapstructure:"access_token" sensitive:"true"`
ClientID string `yaml:"client_id,omitempty" json:"client_id,omitempty" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret,omitempty" mapstructure:"client_secret" sensitive:"true"`
RefreshToken string `yaml:"refresh_token,omitempty" json:"refresh_token,omitempty" mapstructure:"refresh_token" sensitive:"true"`
}
func (RedditAdsConnection) GetName ¶ added in v0.11.619
func (c RedditAdsConnection) GetName() string
type RedshiftConnection ¶ added in v0.11.55
type RedshiftConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=5439"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Schema string `yaml:"schema,omitempty" json:"schema" mapstructure:"schema"`
SslMode string `yaml:"ssl_mode,omitempty" json:"ssl_mode,omitempty" mapstructure:"ssl_mode" default:"allow"`
}
func (RedshiftConnection) GetName ¶ added in v0.11.55
func (c RedshiftConnection) GetName() string
type RevenueCatConnection ¶ added in v0.11.286
type RevenueCatConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
ProjectID string `yaml:"project_id,omitempty" json:"project_id" mapstructure:"project_id"`
}
func (RevenueCatConnection) GetName ¶ added in v0.11.286
func (c RevenueCatConnection) GetName() string
type S3Connection ¶ added in v0.11.55
type S3Connection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
BucketName string `yaml:"bucket_name,omitempty" json:"bucket_name" mapstructure:"bucket_name"`
PathToFile string `yaml:"path_to_file,omitempty" json:"path_to_file" mapstructure:"path_to_file"`
AccessKeyID string `yaml:"access_key_id,omitempty" json:"access_key_id" mapstructure:"access_key_id" sensitive:"true"`
SecretAccessKey string `yaml:"secret_access_key,omitempty" json:"secret_access_key" mapstructure:"secret_access_key" sensitive:"true"`
EndpointURL string `yaml:"endpoint_url,omitempty" json:"endpoint_url" mapstructure:"endpoint_url"`
Layout string `yaml:"layout,omitempty" json:"layout" mapstructure:"layout"`
}
func (S3Connection) GetName ¶ added in v0.11.55
func (c S3Connection) GetName() string
type SFTPConnection ¶ added in v0.11.226
type SFTPConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
}
func (SFTPConnection) GetName ¶ added in v0.11.226
func (c SFTPConnection) GetName() string
type SQLiteConnection ¶ added in v0.11.190
type SQLiteConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Path string `yaml:"path,omitempty" json:"path" mapstructure:"path"`
}
func (SQLiteConnection) GetName ¶ added in v0.11.190
func (c SQLiteConnection) GetName() string
type SailConnection ¶ added in v0.11.616
type SailConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host" json:"host" mapstructure:"host"`
Port int `yaml:"port" json:"port" mapstructure:"port"`
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
Token string `yaml:"token,omitempty" json:"token,omitempty" mapstructure:"token" sensitive:"true"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
TLS bool `yaml:"tls,omitempty" json:"tls,omitempty" mapstructure:"tls"`
TLSSkipVerify bool `yaml:"tls_skip_verify,omitempty" json:"tls_skip_verify,omitempty" mapstructure:"tls_skip_verify"`
}
SailConnection holds the settings for a Sail (LakeSail / PySail) platform. Sail exposes an Arrow Flight SQL server and speaks Spark SQL. It does not require authentication by default.
func (SailConnection) GetName ¶ added in v0.11.616
func (c SailConnection) GetName() string
type SalesforceConnection ¶ added in v0.11.188
type SalesforceConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
Token string `yaml:"token,omitempty" json:"token,omitempty" mapstructure:"token" sensitive:"true"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token,omitempty" mapstructure:"access_token" sensitive:"true"`
Domain string `yaml:"domain" json:"domain" mapstructure:"domain"`
}
func (SalesforceConnection) GetName ¶ added in v0.11.188
func (c SalesforceConnection) GetName() string
type SendgridConnection ¶ added in v0.11.633
type SendgridConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
OnBehalfOf string `yaml:"on_behalf_of,omitempty" json:"on_behalf_of,omitempty" mapstructure:"on_behalf_of"`
}
func (SendgridConnection) GetName ¶ added in v0.11.633
func (c SendgridConnection) GetName() string
type SharePointConnection ¶ added in v0.11.636
type SharePointConnection struct {
}
func (SharePointConnection) GetName ¶ added in v0.11.636
func (c SharePointConnection) GetName() string
type ShopifyConnection ¶ added in v0.11.5
type ShopifyConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
URL string `yaml:"url,omitempty" json:"url" mapstructure:"url"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
ClientID string `yaml:"client_id,omitempty" json:"client_id,omitempty" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret,omitempty" mapstructure:"client_secret" sensitive:"true"`
}
func (ShopifyConnection) GetName ¶ added in v0.11.22
func (c ShopifyConnection) GetName() string
type SlackConnection ¶ added in v0.11.62
type SlackConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (SlackConnection) GetName ¶ added in v0.11.62
func (c SlackConnection) GetName() string
type SmartsheetConnection ¶ added in v0.11.217
type SmartsheetConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
SmartsheetID string `yaml:"smartsheet_id,omitempty" json:"smartsheet_id,omitempty" mapstructure:"smartsheet_id"`
}
func (SmartsheetConnection) GetName ¶ added in v0.11.217
func (c SmartsheetConnection) GetName() string
type SnapchatAdsConnection ¶ added in v0.11.353
type SnapchatAdsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
RefreshToken string `yaml:"refresh_token,omitempty" json:"refresh_token" mapstructure:"refresh_token" sensitive:"true"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
OrganizationID string `yaml:"organization_id,omitempty" json:"organization_id,omitempty" mapstructure:"organization_id"`
}
func (SnapchatAdsConnection) GetName ¶ added in v0.11.353
func (c SnapchatAdsConnection) GetName() string
type SnowflakeConnection ¶
type SnowflakeConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Account string `yaml:"account,omitempty" json:"account" mapstructure:"account"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `` /* 129-byte string literal not displayed */
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
Role string `yaml:"role,omitempty" json:"role,omitempty" mapstructure:"role"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
Schema string `yaml:"schema,omitempty" json:"schema,omitempty" mapstructure:"schema"`
Warehouse string `yaml:"warehouse,omitempty" json:"warehouse,omitempty" mapstructure:"warehouse"`
PrivateKeyPath string `` /* 166-byte string literal not displayed */
PrivateKey string `` /* 141-byte string literal not displayed */
}
func (SnowflakeConnection) GetName ¶ added in v0.11.22
func (c SnowflakeConnection) GetName() string
func (SnowflakeConnection) MarshalJSON ¶
func (c SnowflakeConnection) MarshalJSON() ([]byte, error)
func (SnowflakeConnection) MarshalYAML ¶ added in v0.11.522
func (c SnowflakeConnection) MarshalYAML() (interface{}, error)
MarshalYAML implements custom YAML marshaling for SnowflakeConnection. This ensures that the private_key field is written using YAML literal block scalar style (|) to preserve newlines in the PEM-formatted private key.
type SocrataConnection ¶ added in v0.11.330
type SocrataConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Domain string `yaml:"domain,omitempty" json:"domain" mapstructure:"domain"`
AppToken string `yaml:"app_token,omitempty" json:"app_token" mapstructure:"app_token" sensitive:"true"`
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
}
func (SocrataConnection) GetName ¶ added in v0.11.330
func (c SocrataConnection) GetName() string
type SolidgateConnection ¶ added in v0.11.215
type SolidgateConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
PublicKey string `yaml:"public_key,omitempty" json:"public_key" mapstructure:"public_key"`
SecretKey string `yaml:"secret_key,omitempty" json:"secret_key" mapstructure:"secret_key" sensitive:"true"`
}
func (SolidgateConnection) GetName ¶ added in v0.11.215
func (c SolidgateConnection) GetName() string
type SpannerConnection ¶ added in v0.11.209
type SpannerConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ProjectID string `yaml:"project_id,omitempty" json:"project_id" mapstructure:"project_id"`
InstanceID string `yaml:"instance_id,omitempty" json:"instance_id" mapstructure:"instance_id"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
ServiceAccountJSON string `` /* 128-byte string literal not displayed */
ServiceAccountFile string `yaml:"service_account_file,omitempty" json:"service_account_file,omitempty" mapstructure:"service_account_file"`
}
func (SpannerConnection) GetName ¶ added in v0.11.209
func (c SpannerConnection) GetName() string
type SquareConnection ¶ added in v0.11.654
type SquareConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
Environment string `yaml:"environment,omitempty" json:"environment,omitempty" mapstructure:"environment"`
}
func (SquareConnection) GetName ¶ added in v0.11.654
func (c SquareConnection) GetName() string
type StarRocksConnection ¶ added in v0.11.655
type StarRocksConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host" json:"host" mapstructure:"host"`
Username string `yaml:"username" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
Port int `yaml:"port,omitempty" json:"port,omitempty" mapstructure:"port"`
Database string `yaml:"database,omitempty" json:"database,omitempty" mapstructure:"database"`
Catalog string `yaml:"catalog,omitempty" json:"catalog,omitempty" mapstructure:"catalog"`
SSL string `yaml:"ssl,omitempty" json:"ssl,omitempty" mapstructure:"ssl"`
HTTPPort int `yaml:"http_port,omitempty" json:"http_port,omitempty" mapstructure:"http_port"`
ReplicationNum int `yaml:"replication_num,omitempty" json:"replication_num,omitempty" mapstructure:"replication_num"`
}
func (StarRocksConnection) GetName ¶ added in v0.11.655
func (c StarRocksConnection) GetName() string
type StorageAuth ¶ added in v0.11.442
type StorageAuth struct {
// S3/GCS HMAC-style credentials
AccessKey string `yaml:"access_key,omitempty" json:"access_key,omitempty" mapstructure:"access_key" sensitive:"true"`
SecretKey string `yaml:"secret_key,omitempty" json:"secret_key,omitempty" mapstructure:"secret_key" sensitive:"true"`
SessionToken string `yaml:"session_token,omitempty" json:"session_token,omitempty" mapstructure:"session_token" sensitive:"true"`
}
func (StorageAuth) IsGCS ¶ added in v0.11.514
func (a StorageAuth) IsGCS() bool
func (StorageAuth) IsS3 ¶ added in v0.11.442
func (a StorageAuth) IsS3() bool
func (StorageAuth) IsZero ¶ added in v0.11.455
func (a StorageAuth) IsZero() bool
type StorageConfig ¶ added in v0.11.442
type StorageConfig struct {
Type StorageType `yaml:"type" json:"type" mapstructure:"type"`
Path string `yaml:"path,omitempty" json:"path,omitempty" mapstructure:"path"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
// S3-compatible storage (MinIO, R2, B2, Tigris, on-prem, etc.).
// All three are optional pass-throughs to DuckDB's CREATE SECRET; when
// unset, behaviour is unchanged (AWS S3 / GCS defaults).
Endpoint string `yaml:"endpoint,omitempty" json:"endpoint,omitempty" mapstructure:"endpoint"`
URLStyle string `yaml:"url_style,omitempty" json:"url_style,omitempty" mapstructure:"url_style"`
UseSSL *bool `yaml:"use_ssl,omitempty" json:"use_ssl,omitempty" mapstructure:"use_ssl"`
Auth StorageAuth `yaml:"auth,omitempty" json:"auth,omitempty" mapstructure:"auth"`
}
func (StorageConfig) IsZero ¶ added in v0.11.455
func (s StorageConfig) IsZero() bool
type StorageType ¶ added in v0.11.442
type StorageType string
const ( StorageTypeS3 StorageType = "s3" StorageTypeGCS StorageType = "gcs" )
type StripeConnection ¶ added in v0.11.32
type StripeConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (StripeConnection) GetName ¶ added in v0.11.32
func (c StripeConnection) GetName() string
type SurveyMonkeyConnection ¶ added in v0.11.548
type SurveyMonkeyConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
Region string `yaml:"region,omitempty" json:"region,omitempty" mapstructure:"region"`
}
func (SurveyMonkeyConnection) GetName ¶ added in v0.11.548
func (c SurveyMonkeyConnection) GetName() string
type SynapseConnection ¶ added in v0.11.55
type SynapseConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=1433"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Options string `yaml:"options,omitempty" json:"options,omitempty" mapstructure:"options"`
}
func (SynapseConnection) GetName ¶ added in v0.11.55
func (c SynapseConnection) GetName() string
type TableauConnection ¶ added in v0.11.250
type TableauConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Username string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username" jsonschema:"oneof_required=username_password"`
Password string `` /* 138-byte string literal not displayed */
PersonalAccessTokenName string `` /* 179-byte string literal not displayed */
PersonalAccessTokenSecret string `` /* 202-byte string literal not displayed */
SiteID string `yaml:"site_id,omitempty" json:"site_id" mapstructure:"site_id"`
APIVersion string `yaml:"api_version,omitempty" json:"api_version,omitempty" mapstructure:"api_version"`
}
func (TableauConnection) GetName ¶ added in v0.11.250
func (c TableauConnection) GetName() string
type TikTokAdsConnection ¶ added in v0.11.129
type TikTokAdsConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
AdvertiserIDs string `yaml:"advertiser_ids,omitempty" json:"advertiser_ids" mapstructure:"advertiser_ids"`
Timezone string `yaml:"timezone,omitempty" json:"timezone,omitempty" mapstructure:"timezone"`
}
func (TikTokAdsConnection) GetName ¶ added in v0.11.129
func (c TikTokAdsConnection) GetName() string
type TrelloConnection ¶ added in v0.11.670
type TrelloConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
Token string `yaml:"token,omitempty" json:"token" mapstructure:"token" sensitive:"true"`
}
func (TrelloConnection) GetName ¶ added in v0.11.670
func (c TrelloConnection) GetName() string
type TrinoConnection ¶ added in v0.11.274
type TrinoConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Host string `yaml:"host" json:"host" mapstructure:"host"`
Port int `yaml:"port" json:"port" mapstructure:"port"`
Username string `yaml:"username" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password" sensitive:"true"`
Catalog string `yaml:"catalog" json:"catalog" mapstructure:"catalog"`
Schema string `yaml:"schema" json:"schema" mapstructure:"schema"`
}
func (TrinoConnection) GetName ¶ added in v0.11.274
func (c TrinoConnection) GetName() string
type TrustpilotConnection ¶ added in v0.11.249
type TrustpilotConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
BusinessUnitID string `yaml:"business_unit_id,omitempty" json:"business_unit_id" mapstructure:"business_unit_id"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (TrustpilotConnection) GetName ¶ added in v0.11.249
func (c TrustpilotConnection) GetName() string
type TwilioConnection ¶ added in v0.11.638
type TwilioConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccountSID string `yaml:"account_sid,omitempty" json:"account_sid" mapstructure:"account_sid"`
AuthToken string `yaml:"auth_token,omitempty" json:"auth_token,omitempty" mapstructure:"auth_token" sensitive:"true"`
APIKey string `yaml:"api_key,omitempty" json:"api_key,omitempty" mapstructure:"api_key" sensitive:"true"`
APISecret string `yaml:"api_secret,omitempty" json:"api_secret,omitempty" mapstructure:"api_secret" sensitive:"true"`
}
func (TwilioConnection) GetName ¶ added in v0.11.638
func (c TwilioConnection) GetName() string
type VerticaConnection ¶ added in v0.11.475
type VerticaConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=5433"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
Schema string `yaml:"schema,omitempty" json:"schema,omitempty" mapstructure:"schema"`
}
func (VerticaConnection) GetName ¶ added in v0.11.475
func (c VerticaConnection) GetName() string
type VitessConnection ¶ added in v0.11.661
type VitessConnection struct {
Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
Username string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
Password string `yaml:"password,omitempty" json:"password" mapstructure:"password" sensitive:"true"`
Host string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
Port int `yaml:"port,omitempty" json:"port" mapstructure:"port" jsonschema:"default=15306"`
Database string `yaml:"database,omitempty" json:"database" mapstructure:"database"`
GrpcPort int `yaml:"grpc_port,omitempty" json:"grpc_port,omitempty" mapstructure:"grpc_port"`
GrpcHost string `yaml:"grpc_host,omitempty" json:"grpc_host,omitempty" mapstructure:"grpc_host"`
GrpcTLS bool `yaml:"grpc_tls,omitempty" json:"grpc_tls,omitempty" mapstructure:"grpc_tls"`
SslCaPath string `yaml:"ssl_ca_path,omitempty" json:"ssl_ca_path,omitempty" mapstructure:"ssl_ca_path"`
SslCertPath string `yaml:"ssl_cert_path,omitempty" json:"ssl_cert_path,omitempty" mapstructure:"ssl_cert_path"`
SslKeyPath string `yaml:"ssl_key_path,omitempty" json:"ssl_key_path,omitempty" mapstructure:"ssl_key_path"`
}
VitessConnection describes a connection to a Vitess cluster via vtgate. Vitess speaks the MySQL wire protocol, but ingestr now routes it through its own "vitess" scheme, so it is a dedicated connection type rather than a MySQL connection. The grpc_* fields point at vtgate's VStream gRPC endpoint and are only needed for change data capture.
func (VitessConnection) GetName ¶ added in v0.11.661
func (c VitessConnection) GetName() string
type WiseConnection ¶ added in v0.11.277
type WiseConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key" sensitive:"true"`
}
func (WiseConnection) GetName ¶ added in v0.11.277
func (c WiseConnection) GetName() string
type WistiaConnection ¶ added in v0.11.619
type WistiaConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token" sensitive:"true"`
APIKey string `yaml:"api_key,omitempty" json:"api_key,omitempty" mapstructure:"api_key" sensitive:"true"`
Token string `yaml:"token,omitempty" json:"token,omitempty" mapstructure:"token" sensitive:"true"`
APIVersion string `yaml:"api_version,omitempty" json:"api_version,omitempty" mapstructure:"api_version"`
BaseURL string `yaml:"base_url,omitempty" json:"base_url,omitempty" mapstructure:"base_url"`
}
func (WistiaConnection) GetName ¶ added in v0.11.619
func (c WistiaConnection) GetName() string
type ZendeskConnection ¶ added in v0.11.61
type ZendeskConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token" sensitive:"true"`
Email string `yaml:"email,omitempty" json:"email" mapstructure:"email"`
OAuthToken string `yaml:"oauth_token,omitempty" json:"oauth_token" mapstructure:"oauth_token" sensitive:"true"`
Subdomain string `yaml:"sub_domain,omitempty" json:"sub_domain" mapstructure:"sub_domain"`
}
func (ZendeskConnection) GetName ¶ added in v0.11.61
func (c ZendeskConnection) GetName() string
type ZoomConnection ¶ added in v0.11.244
type ZoomConnection struct {
ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
ClientID string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
AccountID string `yaml:"account_id,omitempty" json:"account_id" mapstructure:"account_id"`
}
func (ZoomConnection) GetName ¶ added in v0.11.244
func (c ZoomConnection) GetName() string