config

package
v0.11.693 Latest Latest
Warning

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

Go to latest
Published: Jul 22, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

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

func GetConnectionsSchema() (string, error)

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 ConcurrencyLimitedConnection interface {
	GetName() string
	GetMaxConcurrentAssets() *int
}

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 LoadFromFileOrEnv(fs afero.Fs, path string) (*Config, error)

func LoadOrCreate

func LoadOrCreate(fs afero.Fs, path string) (*Config, error)

func LoadOrCreateWithoutPathAbsolutization added in v0.11.138

func LoadOrCreateWithoutPathAbsolutization(fs afero.Fs, path string) (*Config, error)

func (*Config) AddConnection added in v0.11.22

func (c *Config) AddConnection(environmentName, name, connType string, creds map[string]interface{}) error

func (*Config) AddEnvironment added in v0.11.252

func (c *Config) AddEnvironment(name, schemaPrefix string) error

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 (c *Config) CanRunTaskInstances(p *pipeline.Pipeline, tasks []scheduler.TaskInstance) error

func (*Config) CloneEnvironment added in v0.11.280

func (c *Config) CloneEnvironment(sourceName, targetName, schemaPrefix string) error

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 (c *Config) DeleteConnection(environmentName, connectionName string) error

func (*Config) DeleteEnvironment added in v0.11.254

func (c *Config) DeleteEnvironment(name string) error

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

func (c *Config) EnvironmentExists(name string) bool

EnvironmentExists checks if an environment exists in the configuration.

func (*Config) GetEnvironmentNames added in v0.11.4

func (c *Config) GetEnvironmentNames() []string

func (*Config) Path added in v0.11.472

func (c *Config) Path() string

func (*Config) Persist

func (c *Config) Persist() error

func (*Config) PersistToFs

func (c *Config) PersistToFs(fs afero.Fs) error

func (*Config) SelectEnvironment

func (c *Config) SelectEnvironment(name string) error

func (*Config) UpdateEnvironment added in v0.11.254

func (c *Config) UpdateEnvironment(oldName, newName, schemaPrefix string) error

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 ConnectionDetailsGetter interface {
	GetConnectionDetails(name string) any
	GetConnectionType(name string) string
}

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 ConnectionGetter interface {
	GetConnection(name string) any
}

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

type ConnectionResolver interface {
	ResolveConnection(name string) (any, error)
}

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"`
	SharePoint          []SharePointConnection          `yaml:"sharepoint,omitempty" json:"sharepoint,omitempty" mapstructure:"sharepoint"`
	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

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 (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 Named added in v0.11.22

type Named interface {
	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 {
	ConnectionMetadata `yaml:",inline" mapstructure:",squash"`
	TenantID           string `yaml:"tenant_id" json:"tenant_id" mapstructure:"tenant_id"`
	ClientID           string `yaml:"client_id" json:"client_id" mapstructure:"client_id"`
	ClientSecret       string `yaml:"client_secret" json:"client_secret" mapstructure:"client_secret" sensitive:"true"`
	Hostname           string `yaml:"hostname" json:"hostname" mapstructure:"hostname"`
	Site               string `yaml:"site" json:"site" mapstructure:"site"`
	Library            string `yaml:"library,omitempty" json:"library,omitempty" mapstructure:"library"`
	MaxFileSize        *int64 `yaml:"max_file_size,omitempty" json:"max_file_size,omitempty" mapstructure:"max_file_size"`
	MaxFiles           *int64 `yaml:"max_files,omitempty" json:"max_files,omitempty" mapstructure:"max_files"`
	DownloadTimeout    string `yaml:"download_timeout,omitempty" json:"download_timeout,omitempty" mapstructure:"download_timeout"`
}

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"`

	// Azure credentials. ConnectionString authenticates with an account key;
	// when empty, AccountName selects DuckDB's credential_chain provider
	// (managed identity / az login / env).
	ConnectionString string `yaml:"connection_string,omitempty" json:"connection_string,omitempty" mapstructure:"connection_string" sensitive:"true"`
	AccountName      string `yaml:"account_name,omitempty" json:"account_name,omitempty" mapstructure:"account_name"`
}

func (StorageAuth) IsAzure added in v0.11.692

func (a StorageAuth) IsAzure() bool

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"
	StorageTypeAzure StorageType = "azure"
)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL