config

package
v0.11.310 Latest Latest
Warning

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

Go to latest
Published: Oct 7, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetConnectionsSchema added in v0.11.55

func GetConnectionsSchema() (string, error)

Types

type AdjustConnection added in v0.11.30

type AdjustConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (AdjustConnection) GetName added in v0.11.30

func (c AdjustConnection) GetName() string

type AirtableConnection added in v0.11.49

type AirtableConnection struct {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	BaseID      string `yaml:"base_id,omitempty" json:"base_id" mapstructure:"base_id"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
}

func (AirtableConnection) GetName added in v0.11.49

func (c AirtableConnection) GetName() string

type AnthropicConnection added in v0.11.296

type AnthropicConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (AnthropicConnection) GetName added in v0.11.296

func (c AnthropicConnection) GetName() string

type AppLovinConnection added in v0.11.186

type AppLovinConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (AppLovinConnection) GetName added in v0.11.186

func (c AppLovinConnection) GetName() string

type AppStoreConnection added in v0.11.132

type AppStoreConnection struct {
	Name     string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
}

func (AppStoreConnection) GetName added in v0.11.132

func (c AppStoreConnection) GetName() string

type ApplovinMaxConnection added in v0.11.138

type ApplovinMaxConnection struct {
	Name   string `yaml:"name" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key" json:"api_key" mapstructure:"api_key"`
}

func (ApplovinMaxConnection) GetName added in v0.11.138

func (c ApplovinMaxConnection) GetName() string

type AppsflyerConnection added in v0.11.35

type AppsflyerConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (AppsflyerConnection) GetName added in v0.11.35

func (c AppsflyerConnection) GetName() string

type AsanaConnection added in v0.11.123

type AsanaConnection struct {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
	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 {
	Name             string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessKey        string `yaml:"access_key_id,omitempty" json:"access_key_id" mapstructure:"access_key_id"`
	SecretKey        string `yaml:"secret_access_key,omitempty" json:"secret_access_key" mapstructure:"secret_access_key"`
	SessionToken     string `yaml:"session_token,omitempty" json:"session_token" mapstructure:"session_token"`
	QueryResultsPath string `yaml:"query_results_path,omitempty" json:"query_results_path" mapstructure:"query_results_path"`
	Region           string `yaml:"region,omitempty" json:"region" 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) 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 {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (AttioConnection) GetName added in v0.11.220

func (c AttioConnection) GetName() string

type AwsConnection added in v0.11.20

type AwsConnection struct {
	Name      string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessKey string `yaml:"access_key,omitempty" json:"access_key" mapstructure:"access_key"`
	SecretKey string `yaml:"secret_key,omitempty" json:"secret_key" mapstructure:"secret_key"`
	Region    string `yaml:"region,omitempty" json:"region" mapstructure:"region"`
}

func (AwsConnection) GetName added in v0.11.22

func (c AwsConnection) GetName() string

type ChessConnection added in v0.11.49

type ChessConnection struct {
	Name    string   `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Players []string `` /* 135-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 {
	Name     string `yaml:"name" json:"name" mapstructure:"name"`
	Username string `yaml:"username" json:"username" mapstructure:"username"`
	Password string `yaml:"password" json:"password" mapstructure:"password"`
	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" json:"http_port" mapstructure:"http_port"`
	Secure   *int   `yaml:"secure" json:"secure" 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 {
	Name     string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token"`
}

func (ClickupConnection) GetName added in v0.11.264

func (c ClickupConnection) GetName() string

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) 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
}

type ConnectionGetter added in v0.11.255

type ConnectionGetter interface {
	GetConnection(name string) any
}

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"`
	Synapse             []SynapseConnection             `yaml:"synapse,omitempty" json:"synapse,omitempty" mapstructure:"synapse"`
	Mongo               []MongoConnection               `yaml:"mongo,omitempty" json:"mongo,omitempty" mapstructure:"mongo"`
	MongoAtlas          []MongoAtlasConnection          `yaml:"mongo_atlas,omitempty" json:"mongo_atlas,omitempty" mapstructure:"mongo_atlas"`
	MySQL               []MySQLConnection               `yaml:"mysql,omitempty" json:"mysql,omitempty" mapstructure:"mysql"`
	Notion              []NotionConnection              `yaml:"notion,omitempty" json:"notion,omitempty" mapstructure:"notion"`
	HANA                []HANAConnection                `yaml:"hana,omitempty" json:"hana,omitempty" mapstructure:"hana"`
	Shopify             []ShopifyConnection             `yaml:"shopify,omitempty" json:"shopify,omitempty" mapstructure:"shopify"`
	Gorgias             []GorgiasConnection             `yaml:"gorgias,omitempty" json:"gorgias,omitempty" mapstructure:"gorgias"`
	Klaviyo             []KlaviyoConnection             `yaml:"klaviyo,omitempty" json:"klaviyo,omitempty" mapstructure:"klaviyo"`
	Adjust              []AdjustConnection              `yaml:"adjust,omitempty" json:"adjust,omitempty" mapstructure:"adjust"`
	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"`
	Appsflyer           []AppsflyerConnection           `yaml:"appsflyer,omitempty" json:"appsflyer,omitempty" mapstructure:"appsflyer"`
	Kafka               []KafkaConnection               `yaml:"kafka,omitempty" json:"kafka,omitempty" mapstructure:"kafka"`
	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"`
	Zendesk             []ZendeskConnection             `yaml:"zendesk,omitempty" json:"zendesk,omitempty" mapstructure:"zendesk"`
	TikTokAds           []TikTokAdsConnection           `yaml:"tiktokads,omitempty" json:"tiktokads,omitempty" mapstructure:"tiktokads"`
	S3                  []S3Connection                  `yaml:"s3,omitempty" json:"s3,omitempty" mapstructure:"s3"`
	Slack               []SlackConnection               `yaml:"slack,omitempty" json:"slack,omitempty" mapstructure:"slack"`
	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"`
	LinkedInAds         []LinkedInAdsConnection         `yaml:"linkedinads,omitempty" json:"linkedinads,omitempty" mapstructure:"linkedinads"`
	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"`
	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"`
	Mixpanel            []MixpanelConnection            `yaml:"mixpanel,omitempty" json:"mixpanel,omitempty" mapstructure:"mixpanel"`
	Clickup             []ClickupConnection             `yaml:"clickup,omitempty" json:"clickup,omitempty" mapstructure:"clickup"`
	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"`
	Zoom                []ZoomConnection                `yaml:"zoom,omitempty" json:"zoom,omitempty" mapstructure:"zoom"`
	EMRServerless       []EMRServerlessConnection       `yaml:"emr_serverless,omitempty" json:"emr_serverless,omitempty" mapstructure:"emr_serverless"`
	GoogleAnalytics     []GoogleAnalyticsConnection     `yaml:"googleanalytics,omitempty" json:"googleanalytics,omitempty" mapstructure:"googleanalytics"`
	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"`
	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"`
	Trino               []TrinoConnection               `yaml:"trino,omitempty" json:"trino,omitempty" mapstructure:"trino"`
	Fluxx               []FluxxConnection               `yaml:"fluxx,omitempty" json:"fluxx,omitempty" mapstructure:"fluxx"`
	FundraiseUp         []FundraiseUpConnection         `yaml:"fundraiseup,omitempty" json:"fundraiseup,omitempty" mapstructure:"fundraiseup"`
	Jira                []JiraConnection                `yaml:"jira,omitempty" json:"jira,omitempty" mapstructure:"jira"`
	PlusVibeAI          []PlusVibeAIConnection          `yaml:"plusvibeai,omitempty" json:"plusvibeai,omitempty" mapstructure:"plusvibeai"`
	// contains filtered or unexported fields
}

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) MergeFrom added in v0.11.138

func (c *Connections) MergeFrom(source *Connections) error

MergeFrom implements ConnectionMerger interface.

type DB2Connection added in v0.11.191

type DB2Connection 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"`
	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 {
	Name    string `yaml:"name,omitempty"  json:"name" mapstructure:"name"`
	Token   string `yaml:"token,omitempty" json:"token" mapstructure:"token"`
	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"`
}

func (DatabricksConnection) GetName added in v0.11.22

func (c DatabricksConnection) GetName() string

type DoceboConnection added in v0.11.296

type DoceboConnection struct {
	Name         string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
	Username     string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
	Password     string `yaml:"password,omitempty" json:"password" mapstructure:"password"`
}

func (DoceboConnection) GetName added in v0.11.296

func (c DoceboConnection) GetName() string

type DuckDBConnection added in v0.11.41

type DuckDBConnection struct {
	Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Path string `yaml:"path,omitempty" json:"path" mapstructure:"path"`
}

func (DuckDBConnection) GetName added in v0.11.41

func (d DuckDBConnection) GetName() string

type DynamoDBConnection added in v0.11.123

type DynamoDBConnection struct {
	Name            string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessKeyID     string `yaml:"access_key_id,omitempty" json:"access_key_id" mapstructure:"access_key_id"`
	SecretAccessKey string `yaml:"secret_access_key,omitempty" json:"secret_access_key" mapstructure:"secret_access_key"`
	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 {
	Name          string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessKey     string `yaml:"access_key" json:"access_key" mapstructure:"access_key"`
	SecretKey     string `yaml:"secret_key" json:"secret_key" mapstructure:"secret_key"`
	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 {
	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"`
	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"
)

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

type FacebookAdsConnection added in v0.11.30

type FacebookAdsConnection struct {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
	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 FluxxConnection added in v0.11.287

type FluxxConnection struct {
	Name         string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
}

func (FluxxConnection) GetName added in v0.11.287

func (c FluxxConnection) GetName() string

type FrankfurterConnection added in v0.11.189

type FrankfurterConnection struct {
	Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
}

func (FrankfurterConnection) GetName added in v0.11.189

func (c FrankfurterConnection) GetName() string

type FundraiseUpConnection added in v0.11.296

type FundraiseUpConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (FundraiseUpConnection) GetName added in v0.11.296

func (c FundraiseUpConnection) GetName() string

type GCSConnection added in v0.11.136

type GCSConnection struct {
	Name               string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	ServiceAccountFile string `` /* 160-byte string literal not displayed */
	ServiceAccountJSON string `` /* 160-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 GenericConnection

type GenericConnection struct {
	Name  string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Value string `yaml:"value,omitempty" json:"value" mapstructure:"value"`
}

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 {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token,omitempty" mapstructure:"access_token"`
	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 GoogleAdsConnection added in v0.11.136

type GoogleAdsConnection struct {
	Name               string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	CustomerID         string `yaml:"customer_id,omitempty" json:"customer_id" mapstructure:"customer_id"`
	ServiceAccountJSON string `yaml:"service_account_json,omitempty" json:"service_account_json,omitempty" mapstructure:"service_account_json"`
	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"`
}

func (GoogleAdsConnection) GetName added in v0.11.136

func (c GoogleAdsConnection) GetName() string

type GoogleAnalyticsConnection added in v0.11.184

type GoogleAnalyticsConnection struct {
	Name               string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	ServiceAccountFile string `yaml:"service_account_file,omitempty" json:"service_account_file" mapstructure:"service_account_file"`
	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 {
	Name               string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	ServiceAccountJSON string `yaml:"service_account_json,omitempty" json:"service_account_json,omitempty" mapstructure:"service_account_json"`
	ServiceAccountFile string `yaml:"service_account_file,omitempty" json:"service_account_file,omitempty" mapstructure:"service_account_file"`
	ProjectID          string `yaml:"project_id,omitempty" json:"project_id" mapstructure:"project_id"`
	Location           string `yaml:"location,omitempty" json:"location,omitempty" mapstructure:"location"`
	// 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 {
	Name               string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	ServiceAccountJSON string `yaml:"service_account_json,omitempty" json:"service_account_json,omitempty" mapstructure:"service_account_json"`
	ServiceAccountFile string `yaml:"service_account_file,omitempty" json:"service_account_file,omitempty" mapstructure:"service_account_file"`
}

func (GoogleSheetsConnection) GetName added in v0.11.47

func (c GoogleSheetsConnection) GetName() string

type GorgiasConnection added in v0.11.5

type GorgiasConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Domain string `yaml:"domain,omitempty" json:"domain" mapstructure:"domain"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
	Email  string `yaml:"email,omitempty" json:"email" mapstructure:"email"`
}

func (GorgiasConnection) GetName added in v0.11.22

func (c GorgiasConnection) GetName() string

type HANAConnection added in v0.8.2

type HANAConnection 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"`
	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 HubspotConnection added in v0.11.43

type HubspotConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (HubspotConnection) GetName added in v0.11.43

func (c HubspotConnection) GetName() string

type ISOCPulseConnection added in v0.11.244

type ISOCPulseConnection struct {
	Name  string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Token string `yaml:"token,omitempty" json:"token" mapstructure:"token"`
}

func (ISOCPulseConnection) GetName added in v0.11.244

func (c ISOCPulseConnection) GetName() string

type InfluxDBConnection added in v0.11.270

type InfluxDBConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
	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 {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
	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 {
	Name     string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
}

func (JiraConnection) GetName added in v0.11.300

func (c JiraConnection) GetName() string

type KafkaConnection added in v0.11.40

type KafkaConnection struct {
	Name             string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
	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 KinesisConnection added in v0.11.161

type KinesisConnection struct {
	Name            string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessKeyID     string `yaml:"access_key_id,omitempty" json:"access_key_id" mapstructure:"access_key_id"`
	SecretAccessKey string `yaml:"secret_access_key,omitempty" json:"secret_access_key" mapstructure:"secret_access_key"`
	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 {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (KlaviyoConnection) GetName added in v0.11.26

func (c KlaviyoConnection) GetName() string

type LinearConnection added in v0.11.249

type LinearConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (LinearConnection) GetName added in v0.11.249

func (c LinearConnection) GetName() string

type LinkedInAdsConnection added in v0.11.133

type LinkedInAdsConnection struct {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
	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 MixpanelConnection added in v0.11.238

type MixpanelConnection 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"`
	ProjectID string `yaml:"project_id,omitempty" json:"project_id" 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 MongoAtlasConnection added in v0.11.309

type MongoAtlasConnection 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"`
	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 {
	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"`
	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 {
	Name     string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Token    string `yaml:"token,omitempty" json:"token" mapstructure:"token"`
	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 {
	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"`
	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"`
}

func (MsSQLConnection) GetName added in v0.11.22

func (c MsSQLConnection) GetName() string

type MySQLConnection added in v0.7.8

type MySQLConnection 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"`
	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 {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (NotionConnection) GetName added in v0.11.22

func (c NotionConnection) GetName() string

type OracleConnection added in v0.11.193

type OracleConnection 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"`
	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 PersonioConnection added in v0.11.139

type PersonioConnection struct {
	Name         string `yaml:"name" json:"name" mapstructure:"name"`
	ClientID     string `yaml:"client_id" json:"client_id" mapstructure:"client_id"`
	ClientSecret string `yaml:"client_secret" json:"client_secret" mapstructure:"client_secret"`
}

func (PersonioConnection) GetName added in v0.11.139

func (c PersonioConnection) GetName() string

type PhantombusterConnection added in v0.11.203

type PhantombusterConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (PhantombusterConnection) GetName added in v0.11.203

func (c PhantombusterConnection) GetName() string

type PinterestConnection added in v0.11.248

type PinterestConnection struct {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
}

func (PinterestConnection) GetName added in v0.11.248

func (c PinterestConnection) GetName() string

type PipedriveConnection added in v0.11.179

type PipedriveConnection struct {
	Name     string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIToken string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token"`
}

func (PipedriveConnection) GetName added in v0.11.179

func (c PipedriveConnection) GetName() string

type PlusVibeAIConnection added in v0.11.308

type PlusVibeAIConnection struct {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey      string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
	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 PostgresConnection added in v0.5.0

type PostgresConnection 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"`
	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 QuickBooksConnection added in v0.11.239

type QuickBooksConnection struct {
	Name         string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
	RefreshToken string `yaml:"refresh_token,omitempty" json:"refresh_token" mapstructure:"refresh_token"`
	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 RedshiftConnection added in v0.11.55

type RedshiftConnection 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"`
	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 {
	Name      string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey    string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
	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 {
	Name            string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
	SecretAccessKey string `yaml:"secret_access_key,omitempty" json:"secret_access_key" mapstructure:"secret_access_key"`
	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 {
	Name     string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
}

func (SFTPConnection) GetName added in v0.11.226

func (c SFTPConnection) GetName() string

type SQLiteConnection added in v0.11.190

type SQLiteConnection struct {
	Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Path string `yaml:"path,omitempty" json:"path" mapstructure:"path"`
}

func (SQLiteConnection) GetName added in v0.11.190

func (c SQLiteConnection) GetName() string

type SalesforceConnection added in v0.11.188

type SalesforceConnection 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"`
	Token    string `yaml:"token,omitempty" json:"token" mapstructure:"token"`
	Domain   string `yaml:"domain" json:"domain" mapstructure:"domain"`
}

func (SalesforceConnection) GetName added in v0.11.188

func (c SalesforceConnection) GetName() string

type ShopifyConnection added in v0.11.5

type ShopifyConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	URL    string `yaml:"url,omitempty" json:"url" mapstructure:"url"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (ShopifyConnection) GetName added in v0.11.22

func (c ShopifyConnection) GetName() string

type SlackConnection added in v0.11.62

type SlackConnection struct {
	Name   string `yaml:"name" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key" json:"api_key" mapstructure:"api_key"`
}

func (SlackConnection) GetName added in v0.11.62

func (c SlackConnection) GetName() string

type SmartsheetConnection added in v0.11.217

type SmartsheetConnection struct {
	Name        string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
}

func (SmartsheetConnection) GetName added in v0.11.217

func (c SmartsheetConnection) GetName() string

type SnowflakeConnection

type SnowflakeConnection struct {
	Name           string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Account        string `yaml:"account,omitempty" json:"account" mapstructure:"account"`
	Username       string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
	Password       string `yaml:"password,omitempty" json:"password,omitempty" jsonschema:"oneof_required=password" mapstructure:"password"`
	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 `` /* 144-byte string literal not displayed */
	PrivateKey     string `yaml:"private_key,omitempty" json:"private_key,omitempty" jsonschema:"oneof_required=private_key" mapstructure:"private_key"`
}

func (SnowflakeConnection) GetName added in v0.11.22

func (c SnowflakeConnection) GetName() string

func (SnowflakeConnection) MarshalJSON

func (c SnowflakeConnection) MarshalJSON() ([]byte, error)

type SolidgateConnection added in v0.11.215

type SolidgateConnection struct {
	Name      string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	PublicKey string `yaml:"public_key,omitempty" json:"public_key" mapstructure:"public_key"`
	SecretKey string `yaml:"secret_key,omitempty" json:"secret_key" mapstructure:"secret_key"`
}

func (SolidgateConnection) GetName added in v0.11.215

func (c SolidgateConnection) GetName() string

type SpannerConnection added in v0.11.209

type SpannerConnection struct {
	Name               string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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 `yaml:"service_account_json,omitempty" json:"service_account_json,omitempty" mapstructure:"service_account_json"`
	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 StripeConnection added in v0.11.32

type StripeConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (StripeConnection) GetName added in v0.11.32

func (c StripeConnection) GetName() string

type SynapseConnection added in v0.11.55

type SynapseConnection 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"`
	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"`
}

func (SynapseConnection) GetName added in v0.11.55

func (c SynapseConnection) GetName() string

type TableauConnection added in v0.11.250

type TableauConnection struct {
	Name                      string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	Host                      string `yaml:"host,omitempty" json:"host" mapstructure:"host"`
	Username                  string `yaml:"username,omitempty" json:"username" mapstructure:"username"`
	Password                  string `yaml:"password,omitempty" json:"password" mapstructure:"password"`
	PersonalAccessTokenName   string `yaml:"personal_access_token_name,omitempty" json:"personal_access_token_name" mapstructure:"personal_access_token_name"`
	PersonalAccessTokenSecret string `yaml:"personal_access_token_secret,omitempty" json:"personal_access_token_secret" mapstructure:"personal_access_token_secret"`
	SiteID                    string `yaml:"site_id,omitempty" json:"site_id" mapstructure:"site_id"`
	APIVersion                string `yaml:"api_version,omitempty" json:"api_version" 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 {
	Name          string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	AccessToken   string `yaml:"access_token,omitempty" json:"access_token" mapstructure:"access_token"`
	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 TrinoConnection added in v0.11.274

type TrinoConnection struct {
	Name     string `yaml:"name" json:"name" mapstructure:"name"`
	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"`
	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 {
	Name           string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	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"`
}

func (TrustpilotConnection) GetName added in v0.11.249

func (c TrustpilotConnection) GetName() string

type WiseConnection added in v0.11.277

type WiseConnection struct {
	Name   string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIKey string `yaml:"api_key,omitempty" json:"api_key" mapstructure:"api_key"`
}

func (WiseConnection) GetName added in v0.11.277

func (c WiseConnection) GetName() string

type ZendeskConnection added in v0.11.61

type ZendeskConnection struct {
	Name       string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	APIToken   string `yaml:"api_token,omitempty" json:"api_token" mapstructure:"api_token"`
	Email      string `yaml:"email,omitempty" json:"email" mapstructure:"email"`
	OAuthToken string `yaml:"oauth_token,omitempty" json:"oauth_token" mapstructure:"oauth_token"`
	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 {
	Name         string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
	ClientID     string `yaml:"client_id,omitempty" json:"client_id" mapstructure:"client_id"`
	ClientSecret string `yaml:"client_secret,omitempty" json:"client_secret" mapstructure:"client_secret"`
	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