connection

package
v2.7.2 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2025 License: AGPL-3.0 Imports: 30 Imported by: 1

Documentation

Index

Constants

View Source 
const AbuseIPDBConnectionType = "abuseipdb"
View Source 
const AlicloudConnectionType = "alicloud"
View Source 
const (
	AwsConnectionType = "aws"
)
View Source 
const AzureConnectionType = "azure"
View Source 
const BitbucketConnectionType = "bitbucket"
View Source 
const ClickUpConnectionType = "clickup"
View Source 
const DatadogConnectionType = "datadog"
View Source 
const DiscordConnectionType = "discord"
View Source 
const DuckDbConnectionType = "duckdb"
View Source 
const FreshdeskConnectionType = "freshdesk"
View Source 
const (
	GcpConnectionType = "gcp"
)
View Source 
const GitLabConnectionType = "gitlab"
View Source 
const GithubConnectionType = "github"
View Source 
const GuardrailsConnectionType = "guardrails"
View Source 
const IP2LocationIOConnectionType = "ip2locationio"
View Source 
const IPstackConnectionType = "ipstack"
View Source 
const JiraConnectionType = "jira"
View Source 
const JumpCloudConnectionType = "jumpcloud"
View Source 
const MastodonConnectionType = "mastodon"
View Source 
const MicrosoftTeamsConnectionType = "teams"
View Source 
const MysqlConnectionType = "mysql"
View Source 
const OktaConnectionType = "okta"
View Source 
const OpenAIConnectionType = "openai"
View Source 
const OpsgenieConnectionType = "opsgenie"
View Source 
const PagerDutyConnectionType = "pagerduty"
View Source 
const PipesConnectionType = "pipes"
View Source 
const PostgresConnectionType = "postgres"
View Source 
const SendGridConnectionType = "sendgrid"
View Source 
const ServiceNowConnectionType = "servicenow"
View Source 
const SlackConnectionType = "slack"
View Source 
const SqliteConnectionType = "sqlite"
View Source 
const SteampipeConnectionType = "steampipe"
View Source 
const TailpipeConnectionType = "tailpipe"
View Source 
const TrelloConnectionType = "trello"
View Source 
const UptimeRobotConnectionType = "uptimerobot"
View Source 
const UrlscanConnectionType = "urlscan"
View Source 
const VaultConnectionType = "vault"
View Source 
const VirusTotalConnectionType = "virustotal"
View Source 
const ZendeskConnectionType = "zendesk"

Variables

This section is empty.

Functions

func ConnectionTypeMeetsRequiredType 

func ConnectionTypeMeetsRequiredType(requiredType, actualResourceType, actualType string) bool

Types

type AbuseIPDBConnection 

type AbuseIPDBConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*AbuseIPDBConnection) CtyValue 

func (c *AbuseIPDBConnection) CtyValue() (cty.Value, error)

func (*AbuseIPDBConnection) Equals 

func (c *AbuseIPDBConnection) Equals(otherConnection PipelingConnection) bool

func (*AbuseIPDBConnection) GetConnectionType 

func (c *AbuseIPDBConnection) GetConnectionType() string

func (*AbuseIPDBConnection) GetEnv 

func (c *AbuseIPDBConnection) GetEnv() map[string]cty.Value

func (*AbuseIPDBConnection) Resolve 

func (c *AbuseIPDBConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*AbuseIPDBConnection) Validate 

func (c *AbuseIPDBConnection) Validate() hcl.Diagnostics

type AlicloudConnection 

type AlicloudConnection struct {
	ConnectionImpl

	AccessKey *string `json:"access_key,omitempty" cty:"access_key" hcl:"access_key,optional"`
	SecretKey *string `json:"secret_key,omitempty" cty:"secret_key" hcl:"secret_key,optional"`
}

func (*AlicloudConnection) CtyValue 

func (c *AlicloudConnection) CtyValue() (cty.Value, error)

func (*AlicloudConnection) Equals 

func (c *AlicloudConnection) Equals(otherConnection PipelingConnection) bool

func (*AlicloudConnection) GetConnectionType 

func (c *AlicloudConnection) GetConnectionType() string

func (*AlicloudConnection) GetEnv 

func (c *AlicloudConnection) GetEnv() map[string]cty.Value

func (*AlicloudConnection) Resolve 

func (c *AlicloudConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*AlicloudConnection) Validate 

func (c *AlicloudConnection) Validate() hcl.Diagnostics

type AwsConnection 

type AwsConnection struct {
	ConnectionImpl

	AccessKey    *string `json:"access_key,omitempty" cty:"access_key" hcl:"access_key,optional"`
	SecretKey    *string `json:"secret_key,omitempty" cty:"secret_key" hcl:"secret_key,optional"`
	SessionToken *string `json:"session_token,omitempty" cty:"session_token" hcl:"session_token,optional"`
	Profile      *string `json:"profile,omitempty" cty:"profile" hcl:"profile,optional"`
}

func (*AwsConnection) CtyValue 

func (c *AwsConnection) CtyValue() (cty.Value, error)

func (*AwsConnection) Equals 

func (c *AwsConnection) Equals(otherConnection PipelingConnection) bool

func (*AwsConnection) GetConnectionType 

func (c *AwsConnection) GetConnectionType() string

func (*AwsConnection) GetEnv 

func (c *AwsConnection) GetEnv() map[string]cty.Value

func (*AwsConnection) Resolve 

func (c *AwsConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*AwsConnection) Validate 

func (c *AwsConnection) Validate() hcl.Diagnostics

type AzureConnection 

type AzureConnection struct {
	ConnectionImpl

	ClientID     *string `json:"client_id,omitempty" cty:"client_id" hcl:"client_id,optional"`
	ClientSecret *string `json:"client_secret,omitempty" cty:"client_secret" hcl:"client_secret,optional"`
	TenantID     *string `json:"tenant_id,omitempty" cty:"tenant_id" hcl:"tenant_id,optional"`
	Environment  *string `json:"environment,omitempty" cty:"environment" hcl:"environment,optional"`
}

func (*AzureConnection) CtyValue 

func (c *AzureConnection) CtyValue() (cty.Value, error)

func (*AzureConnection) Equals 

func (c *AzureConnection) Equals(otherConnection PipelingConnection) bool

func (*AzureConnection) GetConnectionType 

func (c *AzureConnection) GetConnectionType() string

func (*AzureConnection) GetEnv 

func (c *AzureConnection) GetEnv() map[string]cty.Value

func (*AzureConnection) Resolve 

func (c *AzureConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*AzureConnection) Validate 

func (c *AzureConnection) Validate() hcl.Diagnostics

type BitbucketConnection 

type BitbucketConnection struct {
	ConnectionImpl

	BaseURL  *string `json:"base_url,omitempty" cty:"base_url" hcl:"base_url,optional"`
	Username *string `json:"username,omitempty" cty:"username" hcl:"username,optional"`
	Password *string `json:"password,omitempty" cty:"password" hcl:"password,optional"`
}

func (*BitbucketConnection) CtyValue 

func (c *BitbucketConnection) CtyValue() (cty.Value, error)

func (*BitbucketConnection) Equals 

func (c *BitbucketConnection) Equals(otherConnection PipelingConnection) bool

func (*BitbucketConnection) GetConnectionType 

func (c *BitbucketConnection) GetConnectionType() string

func (*BitbucketConnection) GetEnv 

func (c *BitbucketConnection) GetEnv() map[string]cty.Value

func (*BitbucketConnection) Resolve 

func (c *BitbucketConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*BitbucketConnection) Validate 

func (c *BitbucketConnection) Validate() hcl.Diagnostics

type ClickUpConnection 

type ClickUpConnection struct {
	ConnectionImpl

	Token *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*ClickUpConnection) CtyValue 

func (c *ClickUpConnection) CtyValue() (cty.Value, error)

func (*ClickUpConnection) Equals 

func (c *ClickUpConnection) Equals(otherConnection PipelingConnection) bool

func (*ClickUpConnection) GetConnectionType 

func (c *ClickUpConnection) GetConnectionType() string

func (*ClickUpConnection) GetEnv 

func (c *ClickUpConnection) GetEnv() map[string]cty.Value

func (*ClickUpConnection) Resolve 

func (c *ClickUpConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*ClickUpConnection) Validate 

func (c *ClickUpConnection) Validate() hcl.Diagnostics

type ConnectionDependency 

type ConnectionDependency struct {
	ConnectionName string
}

ConnectionDependency is a ConnectionStringProvider implementation that contains a dependency to another connection

func (ConnectionDependency) GetConnectionString 

func (c ConnectionDependency) GetConnectionString(opt ...ConnectionStringOpt) (string, error)

type ConnectionImpl 

type ConnectionImpl struct {
	Pipes *PipesConnectionMetadata `json:"pipes,omitempty" cty:"pipes" hcl:"pipes,block"`

	ShortName string `json:"short_name" cty:"short_name"`
	FullName  string `json:"full_name,omitempty" cty:"name"`
	// DeclRange uses the hclhelpers.Range type which reimplements hcl.Range with custom serialisation
	DeclRange hclhelpers.Range `json:"decl_range,omitempty" cty:"decl_range"`
	// cache ttl in seconds
	Ttl int `json:"ttl,omitempty" cty:"ttl" hcl:"ttl,optional"`
}

func NewConnectionImpl 

func NewConnectionImpl(connectionType, shortName string, declRange hcl.Range) ConnectionImpl

func (*ConnectionImpl) CustomType 

func (c *ConnectionImpl) CustomType()

CustomType implements custom_type.CustomType interface

func (*ConnectionImpl) Equals 

func (c *ConnectionImpl) Equals(other *ConnectionImpl) bool

func (*ConnectionImpl) GetConnectionImpl 

func (c *ConnectionImpl) GetConnectionImpl() *ConnectionImpl

func (*ConnectionImpl) GetConnectionType 

func (c *ConnectionImpl) GetConnectionType() string

func (*ConnectionImpl) GetShortName 

func (c *ConnectionImpl) GetShortName() string

func (*ConnectionImpl) GetTtl 

func (c *ConnectionImpl) GetTtl() int

func (*ConnectionImpl) LateBinding 

func (c *ConnectionImpl) LateBinding()

LateBinding implements the LateBinding interface, marking this as a type whose value is not known until runtime

func (*ConnectionImpl) Name 

func (c *ConnectionImpl) Name() string

func (*ConnectionImpl) SetTtl 

func (c *ConnectionImpl) SetTtl(ttl int)

type ConnectionString 

type ConnectionString struct {
	ConnectionString string
}

ConnectionString is a ConnectionStringProvider implementation that has a static connection string

func (ConnectionString) GetConnectionString 

func (c ConnectionString) GetConnectionString(...ConnectionStringOpt) (string, error)

type ConnectionStringOpt 

type ConnectionStringOpt func(ConnectionStringProvider)

func WithFilter 

func WithFilter(f *backend.DatabaseFilters) ConnectionStringOpt

WithFilter is a ConnectionStringOpt that sets the filters for the connection it currently only supports TailpipeConnection

type ConnectionStringProvider 

type ConnectionStringProvider interface {
	GetConnectionString(...ConnectionStringOpt) (string, error)
}

ConnectionStringProvider is implemented by all connections which can provide a connection string

func NewConnectionDependency 

func NewConnectionDependency(depPath string) ConnectionStringProvider

func NewConnectionString 

func NewConnectionString(connectionString string) ConnectionStringProvider

type DatadogConnection 

type DatadogConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
	AppKey *string `json:"app_key,omitempty" cty:"app_key" hcl:"app_key,optional"`
	APIUrl *string `json:"api_url,omitempty" cty:"api_url" hcl:"api_url,optional"`
}

func (*DatadogConnection) CtyValue 

func (c *DatadogConnection) CtyValue() (cty.Value, error)

func (*DatadogConnection) Equals 

func (c *DatadogConnection) Equals(otherConnection PipelingConnection) bool

func (*DatadogConnection) GetConnectionType 

func (c *DatadogConnection) GetConnectionType() string

func (*DatadogConnection) GetEnv 

func (c *DatadogConnection) GetEnv() map[string]cty.Value

func (*DatadogConnection) Resolve 

func (c *DatadogConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*DatadogConnection) Validate 

func (c *DatadogConnection) Validate() hcl.Diagnostics

type DiscordConnection 

type DiscordConnection struct {
	ConnectionImpl

	Token *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*DiscordConnection) CtyValue 

func (c *DiscordConnection) CtyValue() (cty.Value, error)

func (*DiscordConnection) Equals 

func (c *DiscordConnection) Equals(otherConnection PipelingConnection) bool

func (*DiscordConnection) GetConnectionType 

func (c *DiscordConnection) GetConnectionType() string

func (*DiscordConnection) GetEnv 

func (c *DiscordConnection) GetEnv() map[string]cty.Value

func (*DiscordConnection) Resolve 

func (c *DiscordConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*DiscordConnection) Validate 

func (c *DiscordConnection) Validate() hcl.Diagnostics

type DuckDbConnection 

type DuckDbConnection struct {
	ConnectionImpl
	FileName *string `json:"file_name,omitempty" cty:"file_name" hcl:"file_name,optional"`
	// used only to set the connection string from command line variable value with a connection string
	ConnectionString *string `json:"connection_string,omitempty" cty:"connection_string"`
}

func (*DuckDbConnection) CtyValue 

func (c *DuckDbConnection) CtyValue() (cty.Value, error)

func (*DuckDbConnection) Equals 

func (c *DuckDbConnection) Equals(otherConnection PipelingConnection) bool

func (*DuckDbConnection) GetConnectionString 

func (c *DuckDbConnection) GetConnectionString(opts ...ConnectionStringOpt) (string, error)

func (*DuckDbConnection) GetConnectionType 

func (c *DuckDbConnection) GetConnectionType() string

func (*DuckDbConnection) GetEnv 

func (c *DuckDbConnection) GetEnv() map[string]cty.Value

func (*DuckDbConnection) Resolve 

func (c *DuckDbConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*DuckDbConnection) Validate 

func (c *DuckDbConnection) Validate() hcl.Diagnostics

type DynamicConnectionStringProvider 

type DynamicConnectionStringProvider interface {
	IsDynamic()
}

DynamicConnectionStringProvider is implemented by all connections for which the connection string may change (for example as a result of ConnectionStringOpts)

type FreshdeskConnection 

type FreshdeskConnection struct {
	ConnectionImpl

	APIKey    *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
	Subdomain *string `json:"subdomain,omitempty" cty:"subdomain" hcl:"subdomain,optional"`
}

func (*FreshdeskConnection) CtyValue 

func (c *FreshdeskConnection) CtyValue() (cty.Value, error)

func (*FreshdeskConnection) Equals 

func (c *FreshdeskConnection) Equals(otherConnection PipelingConnection) bool

func (*FreshdeskConnection) GetConnectionType 

func (c *FreshdeskConnection) GetConnectionType() string

func (*FreshdeskConnection) GetEnv 

func (c *FreshdeskConnection) GetEnv() map[string]cty.Value

func (*FreshdeskConnection) Resolve 

func (c *FreshdeskConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*FreshdeskConnection) Validate 

func (c *FreshdeskConnection) Validate() hcl.Diagnostics

type GcpConnection 

type GcpConnection struct {
	ConnectionImpl

	Credentials *string `json:"credentials,omitempty" cty:"credentials" hcl:"credentials,optional"`
	AccessToken *string `json:"access_token,omitempty" cty:"access_token" hcl:"access_token,optional"`
}

func (*GcpConnection) CtyValue 

func (c *GcpConnection) CtyValue() (cty.Value, error)

func (*GcpConnection) Equals 

func (c *GcpConnection) Equals(otherConnection PipelingConnection) bool

func (*GcpConnection) GetConnectionType 

func (c *GcpConnection) GetConnectionType() string

func (*GcpConnection) GetEnv 

func (c *GcpConnection) GetEnv() map[string]cty.Value

func (*GcpConnection) Resolve 

func (c *GcpConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*GcpConnection) Validate 

func (c *GcpConnection) Validate() hcl.Diagnostics

type GitLabConnection 

type GitLabConnection struct {
	ConnectionImpl

	Token *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*GitLabConnection) CtyValue 

func (c *GitLabConnection) CtyValue() (cty.Value, error)

func (*GitLabConnection) Equals 

func (c *GitLabConnection) Equals(otherConnection PipelingConnection) bool

func (*GitLabConnection) GetConnectionType 

func (c *GitLabConnection) GetConnectionType() string

func (*GitLabConnection) GetEnv 

func (c *GitLabConnection) GetEnv() map[string]cty.Value

func (*GitLabConnection) Resolve 

func (c *GitLabConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*GitLabConnection) Validate 

func (c *GitLabConnection) Validate() hcl.Diagnostics

type GithubConnection 

type GithubConnection struct {
	ConnectionImpl

	Token *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*GithubConnection) CtyValue 

func (c *GithubConnection) CtyValue() (cty.Value, error)

func (*GithubConnection) Equals 

func (c *GithubConnection) Equals(otherConnection PipelingConnection) bool

func (*GithubConnection) GetConnectionType 

func (c *GithubConnection) GetConnectionType() string

func (*GithubConnection) GetEnv 

func (c *GithubConnection) GetEnv() map[string]cty.Value

func (*GithubConnection) Resolve 

func (c *GithubConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*GithubConnection) Validate 

func (c *GithubConnection) Validate() hcl.Diagnostics

type GuardrailsConnection 

type GuardrailsConnection struct {
	ConnectionImpl

	AccessKey *string `json:"access_key,omitempty" cty:"access_key" hcl:"access_key,optional"`
	SecretKey *string `json:"secret_key,omitempty" cty:"secret_key" hcl:"secret_key,optional"`
	Workspace *string `json:"workspace,omitempty" cty:"workspace" hcl:"workspace,optional"`
}

func (*GuardrailsConnection) CtyValue 

func (c *GuardrailsConnection) CtyValue() (cty.Value, error)

func (*GuardrailsConnection) Equals 

func (c *GuardrailsConnection) Equals(otherConnection PipelingConnection) bool

func (*GuardrailsConnection) GetConnectionType 

func (c *GuardrailsConnection) GetConnectionType() string

func (*GuardrailsConnection) GetEnv 

func (c *GuardrailsConnection) GetEnv() map[string]cty.Value

func (*GuardrailsConnection) Resolve 

func (c *GuardrailsConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*GuardrailsConnection) Validate 

func (c *GuardrailsConnection) Validate() hcl.Diagnostics

type IP2LocationIOConnection 

type IP2LocationIOConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*IP2LocationIOConnection) CtyValue 

func (c *IP2LocationIOConnection) CtyValue() (cty.Value, error)

func (*IP2LocationIOConnection) Equals 

func (c *IP2LocationIOConnection) Equals(otherConnection PipelingConnection) bool

func (*IP2LocationIOConnection) GetConnectionType 

func (c *IP2LocationIOConnection) GetConnectionType() string

func (*IP2LocationIOConnection) GetEnv 

func (c *IP2LocationIOConnection) GetEnv() map[string]cty.Value

func (*IP2LocationIOConnection) Resolve 

func (c *IP2LocationIOConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*IP2LocationIOConnection) Validate 

func (c *IP2LocationIOConnection) Validate() hcl.Diagnostics

type IPstackConnection 

type IPstackConnection struct {
	ConnectionImpl

	AccessKey *string `json:"access_key,omitempty" cty:"access_key" hcl:"access_key,optional"`
}

func (*IPstackConnection) CtyValue 

func (c *IPstackConnection) CtyValue() (cty.Value, error)

func (*IPstackConnection) Equals 

func (c *IPstackConnection) Equals(otherConnection PipelingConnection) bool

func (*IPstackConnection) GetConnectionType 

func (c *IPstackConnection) GetConnectionType() string

func (*IPstackConnection) GetEnv 

func (c *IPstackConnection) GetEnv() map[string]cty.Value

func (*IPstackConnection) Resolve 

func (c *IPstackConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*IPstackConnection) Validate 

func (c *IPstackConnection) Validate() hcl.Diagnostics

type JiraConnection 

type JiraConnection struct {
	ConnectionImpl

	APIToken *string `json:"api_token,omitempty" cty:"api_token" hcl:"api_token,optional"`
	BaseURL  *string `json:"base_url,omitempty" cty:"base_url" hcl:"base_url,optional"`
	Username *string `json:"username,omitempty" cty:"username" hcl:"username,optional"`
}

func (*JiraConnection) CtyValue 

func (c *JiraConnection) CtyValue() (cty.Value, error)

func (*JiraConnection) Equals 

func (c *JiraConnection) Equals(otherConnection PipelingConnection) bool

func (*JiraConnection) GetConnectionType 

func (c *JiraConnection) GetConnectionType() string

func (*JiraConnection) GetEnv 

func (c *JiraConnection) GetEnv() map[string]cty.Value

func (*JiraConnection) Resolve 

func (c *JiraConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*JiraConnection) Validate 

func (c *JiraConnection) Validate() hcl.Diagnostics

type JumpCloudConnection 

type JumpCloudConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*JumpCloudConnection) CtyValue 

func (c *JumpCloudConnection) CtyValue() (cty.Value, error)

func (*JumpCloudConnection) Equals 

func (c *JumpCloudConnection) Equals(otherConnection PipelingConnection) bool

func (*JumpCloudConnection) GetConnectionType 

func (c *JumpCloudConnection) GetConnectionType() string

func (*JumpCloudConnection) GetEnv 

func (c *JumpCloudConnection) GetEnv() map[string]cty.Value

func (*JumpCloudConnection) Resolve 

func (c *JumpCloudConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*JumpCloudConnection) Validate 

func (c *JumpCloudConnection) Validate() hcl.Diagnostics

type MastodonConnection 

type MastodonConnection struct {
	ConnectionImpl

	AccessToken *string `json:"access_token,omitempty" cty:"access_token" hcl:"access_token,optional"`
	Server      *string `json:"server,omitempty" cty:"server" hcl:"server,optional"`
}

func (*MastodonConnection) CtyValue 

func (c *MastodonConnection) CtyValue() (cty.Value, error)

func (*MastodonConnection) Equals 

func (c *MastodonConnection) Equals(otherConnection PipelingConnection) bool

func (*MastodonConnection) GetConnectionType 

func (c *MastodonConnection) GetConnectionType() string

func (*MastodonConnection) GetEnv 

func (c *MastodonConnection) GetEnv() map[string]cty.Value

func (*MastodonConnection) Resolve 

func (c *MastodonConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*MastodonConnection) Validate 

func (c *MastodonConnection) Validate() hcl.Diagnostics

type MicrosoftTeamsConnection 

type MicrosoftTeamsConnection struct {
	ConnectionImpl

	AccessToken *string `json:"access_token,omitempty" cty:"access_token" hcl:"access_token,optional"`
}

func (*MicrosoftTeamsConnection) CtyValue 

func (c *MicrosoftTeamsConnection) CtyValue() (cty.Value, error)

func (*MicrosoftTeamsConnection) Equals 

func (c *MicrosoftTeamsConnection) Equals(otherConnection PipelingConnection) bool

func (*MicrosoftTeamsConnection) GetConnectionType 

func (c *MicrosoftTeamsConnection) GetConnectionType() string

func (*MicrosoftTeamsConnection) GetEnv 

func (c *MicrosoftTeamsConnection) GetEnv() map[string]cty.Value

func (*MicrosoftTeamsConnection) Resolve 

func (c *MicrosoftTeamsConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*MicrosoftTeamsConnection) Validate 

func (c *MicrosoftTeamsConnection) Validate() hcl.Diagnostics

type MysqlConnection 

type MysqlConnection struct {
	ConnectionImpl
	DbName           *string `json:"db,omitempty" cty:"db" hcl:"db,optional"`
	UserName         *string `json:"username,omitempty" cty:"username" hcl:"username,optional"`
	Host             *string `json:"host,omitempty" cty:"host" hcl:"host,optional"`
	Port             *int    `json:"port,omitempty" cty:"port" hcl:"port,optional"`
	Password         *string `json:"password,omitempty" cty:"password" hcl:"password,optional"`
	ConnectionString *string `json:"connection_string,omitempty" cty:"connection_string"`
}

func (*MysqlConnection) CtyValue 

func (c *MysqlConnection) CtyValue() (cty.Value, error)

func (*MysqlConnection) Equals 

func (c *MysqlConnection) Equals(otherConnection PipelingConnection) bool

func (*MysqlConnection) GetConnectionString 

func (c *MysqlConnection) GetConnectionString(opts ...ConnectionStringOpt) (string, error)

func (*MysqlConnection) GetConnectionType 

func (c *MysqlConnection) GetConnectionType() string

func (*MysqlConnection) GetEnv 

func (c *MysqlConnection) GetEnv() map[string]cty.Value

func (*MysqlConnection) Resolve 

func (c *MysqlConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*MysqlConnection) Validate 

func (c *MysqlConnection) Validate() hcl.Diagnostics

type OktaConnection 

type OktaConnection struct {
	ConnectionImpl

	Domain *string `json:"domain,omitempty" cty:"domain" hcl:"domain,optional"`
	Token  *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*OktaConnection) CtyValue 

func (c *OktaConnection) CtyValue() (cty.Value, error)

func (*OktaConnection) Equals 

func (c *OktaConnection) Equals(otherConnection PipelingConnection) bool

func (*OktaConnection) GetConnectionType 

func (c *OktaConnection) GetConnectionType() string

func (*OktaConnection) GetEnv 

func (c *OktaConnection) GetEnv() map[string]cty.Value

func (*OktaConnection) Resolve 

func (c *OktaConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*OktaConnection) Validate 

func (c *OktaConnection) Validate() hcl.Diagnostics

type OpenAIConnection 

type OpenAIConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*OpenAIConnection) CtyValue 

func (c *OpenAIConnection) CtyValue() (cty.Value, error)

func (*OpenAIConnection) Equals 

func (c *OpenAIConnection) Equals(otherConnection PipelingConnection) bool

func (*OpenAIConnection) GetConnectionType 

func (c *OpenAIConnection) GetConnectionType() string

func (*OpenAIConnection) GetEnv 

func (c *OpenAIConnection) GetEnv() map[string]cty.Value

func (*OpenAIConnection) Resolve 

func (c *OpenAIConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*OpenAIConnection) Validate 

func (c *OpenAIConnection) Validate() hcl.Diagnostics

type OpsgenieConnection 

type OpsgenieConnection struct {
	ConnectionImpl

	AlertAPIKey    *string `json:"alert_api_key,omitempty" cty:"alert_api_key" hcl:"alert_api_key,optional"`
	IncidentAPIKey *string `json:"incident_api_key,omitempty" cty:"incident_api_key" hcl:"incident_api_key,optional"`
}

func (*OpsgenieConnection) CtyValue 

func (c *OpsgenieConnection) CtyValue() (cty.Value, error)

func (*OpsgenieConnection) Equals 

func (c *OpsgenieConnection) Equals(otherConnection PipelingConnection) bool

func (*OpsgenieConnection) GetConnectionType 

func (c *OpsgenieConnection) GetConnectionType() string

func (*OpsgenieConnection) GetEnv 

func (c *OpsgenieConnection) GetEnv() map[string]cty.Value

func (*OpsgenieConnection) Resolve 

func (c *OpsgenieConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*OpsgenieConnection) Validate 

func (c *OpsgenieConnection) Validate() hcl.Diagnostics

type PagerDutyConnection 

type PagerDutyConnection struct {
	ConnectionImpl

	Token *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*PagerDutyConnection) CtyValue 

func (c *PagerDutyConnection) CtyValue() (cty.Value, error)

func (*PagerDutyConnection) Equals 

func (c *PagerDutyConnection) Equals(otherConnection PipelingConnection) bool

func (*PagerDutyConnection) GetConnectionType 

func (c *PagerDutyConnection) GetConnectionType() string

func (*PagerDutyConnection) GetEnv 

func (c *PagerDutyConnection) GetEnv() map[string]cty.Value

func (*PagerDutyConnection) Resolve 

func (c *PagerDutyConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*PagerDutyConnection) Validate 

func (c *PagerDutyConnection) Validate() hcl.Diagnostics

type PipelingConnection 

type PipelingConnection interface {
	GetConnectionType() string
	GetShortName() string
	Name() string

	CtyValue() (cty.Value, error)
	Resolve(ctx context.Context) (PipelingConnection, error)
	GetTtl() int // in seconds

	Validate() hcl.Diagnostics
	GetEnv() map[string]cty.Value

	Equals(PipelingConnection) bool
	GetConnectionImpl() *ConnectionImpl

	SetTtl(int)
}

func NewAbuseIPDBConnection 

func NewAbuseIPDBConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewAlicloudConnection 

func NewAlicloudConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewAwsConnection 

func NewAwsConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewAzureConnection 

func NewAzureConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewBitbucketConnection 

func NewBitbucketConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewClickUpConnection 

func NewClickUpConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewDatadogConnection 

func NewDatadogConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewDiscordConnection 

func NewDiscordConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewDuckDbConnection 

func NewDuckDbConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewFreshdeskConnection 

func NewFreshdeskConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewGcpConnection 

func NewGcpConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewGitLabConnection 

func NewGitLabConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewGithubConnection 

func NewGithubConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewGuardrailsConnection 

func NewGuardrailsConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewIP2LocationIOConnection 

func NewIP2LocationIOConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewIPstackConnection 

func NewIPstackConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewJiraConnection 

func NewJiraConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewJumpCloudConnection 

func NewJumpCloudConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewMastodonConnection 

func NewMastodonConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewMicrosoftTeamsConnection 

func NewMicrosoftTeamsConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewMysqlConnection 

func NewMysqlConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewOktaConnection 

func NewOktaConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewOpenAIConnection 

func NewOpenAIConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewOpsgenieConnection 

func NewOpsgenieConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewPagerDutyConnection 

func NewPagerDutyConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewPipesConnection 

func NewPipesConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewPostgresConnection 

func NewPostgresConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewSendGridConnection 

func NewSendGridConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewServiceNowConnection 

func NewServiceNowConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewSlackConnection 

func NewSlackConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewSqliteConnection 

func NewSqliteConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewSteampipePgConnection 

func NewSteampipePgConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewTailpipeConnection 

func NewTailpipeConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewTrelloConnection 

func NewTrelloConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewUptimeRobotConnection 

func NewUptimeRobotConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewUrlscanConnection 

func NewUrlscanConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewVaultConnection 

func NewVaultConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewVirusTotalConnection 

func NewVirusTotalConnection(shortName string, declRange hcl.Range) PipelingConnection

func NewZendeskConnection 

func NewZendeskConnection(shortName string, declRange hcl.Range) PipelingConnection

type PipesConnection 

type PipesConnection struct {
	ConnectionImpl

	Token *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*PipesConnection) CtyValue 

func (c *PipesConnection) CtyValue() (cty.Value, error)

func (*PipesConnection) Equals 

func (c *PipesConnection) Equals(otherConnection PipelingConnection) bool

func (*PipesConnection) GetConnectionType 

func (c *PipesConnection) GetConnectionType() string

func (*PipesConnection) GetEnv 

func (c *PipesConnection) GetEnv() map[string]cty.Value

func (*PipesConnection) Resolve 

func (c *PipesConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*PipesConnection) Validate 

func (c *PipesConnection) Validate() hcl.Diagnostics

type PipesConnectionMetadata 

type PipesConnectionMetadata struct {
	CloudHost  *string `json:"cloud_host,omitempty" cty:"cloud_host" hcl:"cloud_host,optional"`
	User       *string `json:"user,omitempty" cty:"user" hcl:"user,optional"`
	Org        *string `json:"org,omitempty" cty:"org" hcl:"org,optional"`
	Workspace  *string `json:"workspace,omitempty" cty:"workspace" hcl:"workspace,optional"`
	Connection *string `json:"connection,omitempty" cty:"connection" hcl:"connection,optional"`
}

func (PipesConnectionMetadata) Resolve 

func (m PipesConnectionMetadata) Resolve(ctx context.Context, target PipelingConnection) (PipelingConnection, error)

type PostgresConnection 

type PostgresConnection struct {
	ConnectionImpl
	DbName           *string   `json:"db,omitempty" cty:"db" hcl:"db,optional"`
	UserName         *string   `json:"username,omitempty" cty:"username" hcl:"username,optional"`
	Host             *string   `json:"host,omitempty" cty:"host" hcl:"host,optional"`
	Port             *int      `json:"port,omitempty" cty:"port" hcl:"port,optional"`
	Password         *string   `json:"password,omitempty" cty:"password" hcl:"password,optional"`
	SearchPath       *[]string `json:"search_path,omitempty" cty:"search_path" hcl:"search_path,optional"`
	SearchPathPrefix *[]string `json:"search_path_prefix,omitempty" cty:"search_path_prefix" hcl:"search_path_prefix,optional"`
	SslMode          *string   `json:"sslmode,omitempty" cty:"sslmode" hcl:"sslmode,optional"`
	ConnectionString *string   `json:"connection_string,omitempty" cty:"connection_string"`
}

func (*PostgresConnection) CtyValue 

func (c *PostgresConnection) CtyValue() (cty.Value, error)

func (*PostgresConnection) Equals 

func (c *PostgresConnection) Equals(otherConnection PipelingConnection) bool

func (*PostgresConnection) GetConnectionString 

func (c *PostgresConnection) GetConnectionString(opts ...ConnectionStringOpt) (string, error)

func (*PostgresConnection) GetConnectionType 

func (c *PostgresConnection) GetConnectionType() string

func (*PostgresConnection) GetEnv 

func (c *PostgresConnection) GetEnv() map[string]cty.Value

func (*PostgresConnection) GetSearchPath 

func (c *PostgresConnection) GetSearchPath() []string

func (*PostgresConnection) GetSearchPathPrefix 

func (c *PostgresConnection) GetSearchPathPrefix() []string

func (*PostgresConnection) Resolve 

func (c *PostgresConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*PostgresConnection) Validate 

func (c *PostgresConnection) Validate() hcl.Diagnostics

type SearchPathProvider 

type SearchPathProvider interface {
	ConnectionStringProvider
	GetSearchPath() []string
	GetSearchPathPrefix() []string
}

SearchPathProvider is implemented by all connections which can provide a connection string

type SendGridConnection 

type SendGridConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*SendGridConnection) CtyValue 

func (c *SendGridConnection) CtyValue() (cty.Value, error)

func (*SendGridConnection) Equals 

func (c *SendGridConnection) Equals(otherConnection PipelingConnection) bool

func (*SendGridConnection) GetConnectionType 

func (c *SendGridConnection) GetConnectionType() string

func (*SendGridConnection) GetEnv 

func (c *SendGridConnection) GetEnv() map[string]cty.Value

func (*SendGridConnection) Resolve 

func (c *SendGridConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*SendGridConnection) Validate 

func (c *SendGridConnection) Validate() hcl.Diagnostics

type ServiceNowConnection 

type ServiceNowConnection struct {
	ConnectionImpl

	InstanceURL *string `json:"instance_url,omitempty" cty:"instance_url" hcl:"instance_url,optional"`
	Username    *string `json:"username,omitempty" cty:"username" hcl:"username,optional"`
	Password    *string `json:"password,omitempty" cty:"password" hcl:"password,optional"`
}

func (*ServiceNowConnection) CtyValue 

func (c *ServiceNowConnection) CtyValue() (cty.Value, error)

func (*ServiceNowConnection) Equals 

func (c *ServiceNowConnection) Equals(otherConnection PipelingConnection) bool

func (*ServiceNowConnection) GetConnectionType 

func (c *ServiceNowConnection) GetConnectionType() string

func (*ServiceNowConnection) GetEnv 

func (c *ServiceNowConnection) GetEnv() map[string]cty.Value

func (*ServiceNowConnection) Resolve 

func (c *ServiceNowConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*ServiceNowConnection) Validate 

func (c *ServiceNowConnection) Validate() hcl.Diagnostics

type SlackConnection 

type SlackConnection struct {
	ConnectionImpl

	Token *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*SlackConnection) CtyValue 

func (c *SlackConnection) CtyValue() (cty.Value, error)

func (*SlackConnection) Equals 

func (c *SlackConnection) Equals(otherConnection PipelingConnection) bool

func (*SlackConnection) GetConnectionType 

func (c *SlackConnection) GetConnectionType() string

func (*SlackConnection) GetEnv 

func (c *SlackConnection) GetEnv() map[string]cty.Value

func (*SlackConnection) Resolve 

func (c *SlackConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*SlackConnection) Validate 

func (c *SlackConnection) Validate() hcl.Diagnostics

type SqliteConnection 

type SqliteConnection struct {
	ConnectionImpl
	FileName *string `json:"file_name,omitempty" cty:"file_name" hcl:"file_name,optional"`
	// used only to set the connection string from command line variable value with a connection string
	ConnectionString *string `json:"connection_string,omitempty" cty:"connection_string"`
}

func (*SqliteConnection) CtyValue 

func (c *SqliteConnection) CtyValue() (cty.Value, error)

func (*SqliteConnection) Equals 

func (c *SqliteConnection) Equals(otherConnection PipelingConnection) bool

func (*SqliteConnection) GetConnectionString 

func (c *SqliteConnection) GetConnectionString(opts ...ConnectionStringOpt) (string, error)

func (*SqliteConnection) GetConnectionType 

func (c *SqliteConnection) GetConnectionType() string

func (*SqliteConnection) GetEnv 

func (c *SqliteConnection) GetEnv() map[string]cty.Value

func (*SqliteConnection) Resolve 

func (c *SqliteConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*SqliteConnection) Validate 

func (c *SqliteConnection) Validate() hcl.Diagnostics

type SteampipePgConnection 

type SteampipePgConnection struct {
	ConnectionImpl
	DbName           *string   `json:"db,omitempty" cty:"db" hcl:"db,optional"`
	UserName         *string   `json:"username,omitempty" cty:"username" hcl:"username,optional"`
	Host             *string   `json:"host,omitempty" cty:"host" hcl:"host,optional"`
	Port             *int      `json:"port,omitempty" cty:"port" hcl:"port,optional"`
	Password         *string   `json:"password,omitempty" cty:"password" hcl:"password,optional"`
	SearchPath       *[]string `json:"search_path,omitempty" cty:"search_path" hcl:"search_path,optional"`
	SearchPathPrefix *[]string `json:"search_path_prefix,omitempty" cty:"search_path_prefix" hcl:"search_path_prefix,optional"`
	SslMode          *string   `json:"sslmode,omitempty" cty:"sslmode" hcl:"sslmode,optional"`
	ConnectionString *string   `json:"connection_string,omitempty" cty:"connection_string"`
}

func (*SteampipePgConnection) CtyValue 

func (c *SteampipePgConnection) CtyValue() (cty.Value, error)

func (*SteampipePgConnection) Equals 

func (c *SteampipePgConnection) Equals(otherConnection PipelingConnection) bool

func (*SteampipePgConnection) GetConnectionString 

func (c *SteampipePgConnection) GetConnectionString(opts ...ConnectionStringOpt) (string, error)

func (*SteampipePgConnection) GetConnectionType 

func (c *SteampipePgConnection) GetConnectionType() string

func (*SteampipePgConnection) GetEnv 

func (c *SteampipePgConnection) GetEnv() map[string]cty.Value

func (*SteampipePgConnection) GetSearchPath 

func (c *SteampipePgConnection) GetSearchPath() []string

func (*SteampipePgConnection) GetSearchPathPrefix 

func (c *SteampipePgConnection) GetSearchPathPrefix() []string

func (*SteampipePgConnection) Resolve 

func (c *SteampipePgConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*SteampipePgConnection) Validate 

func (c *SteampipePgConnection) Validate() hcl.Diagnostics

type TailpipeConnectResponse 

type TailpipeConnectResponse struct {
	DatabaseFilepath string `json:"database_filepath,omitempty"`
	InitScriptPath   string `json:"init_script_path,omitempty"`
	Error            string `json:"error,omitempty"`
}

type TailpipeConnection 

type TailpipeConnection struct {
	ConnectionImpl

	From       *string   `cty:"from" hcl:"from"`
	To         *string   `cty:"to" hcl:"to"`
	Indexes    *[]string `cty:"indexes" hcl:"indexes"`
	Partitions *[]string `cty:"partitions" hcl:"partitions"`

	// if an option is passed to GetConnectionString, it may override the From, To, Indexes or Partitions values
	OverrideFilters *backend.DatabaseFilters
	// contains filtered or unexported fields
}

TailpipeConnection represents a connection to a tailpipe database It uses the `tailpipe connect` command to get a connection string The connection string is cached based on the filters used to create the database so that subsequent calls with the same filters do not require calling the command again

func (*TailpipeConnection) CtyValue 

func (c *TailpipeConnection) CtyValue() (cty.Value, error)

func (*TailpipeConnection) Equals 

func (c *TailpipeConnection) Equals(otherConnection PipelingConnection) bool

func (*TailpipeConnection) GetConnectionString 

func (c *TailpipeConnection) GetConnectionString(opts ...ConnectionStringOpt) (string, error)

GetConnectionString implements the ConnectionStringProvider interface it calls the `tailpipe connect` command to get a connection string it caches the connection string based on the filters used to create the database so that subsequent calls with the same filters do not require calling the command again it supports the following ConnectionStringOpt options: - WithFilter: to override the filters used to create the database NOTE: the connection string returned is either of duckdb://<db path> or duckdbinit://<init script location> The format depends on the tailpipe version

  • for <= v0.6.x it is duckdb://<db path>
  • for >= v0.7.x it is duckdbinit://<init script location>

func (*TailpipeConnection) GetConnectionType 

func (c *TailpipeConnection) GetConnectionType() string

func (*TailpipeConnection) GetEnv 

func (c *TailpipeConnection) GetEnv() map[string]cty.Value

func (*TailpipeConnection) IsDynamic 

func (c *TailpipeConnection) IsDynamic()

IsDynamic implements the DynamicConnectionStringProvider interface indicating that the connection string may change

func (*TailpipeConnection) Resolve 

func (c *TailpipeConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*TailpipeConnection) Validate 

func (c *TailpipeConnection) Validate() hcl.Diagnostics

type TimeRangeProvider 

type TimeRangeProvider interface {
	SetTimeRange(utils.TimeRange)
}

type TrelloConnection 

type TrelloConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
	Token  *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*TrelloConnection) CtyValue 

func (c *TrelloConnection) CtyValue() (cty.Value, error)

func (*TrelloConnection) Equals 

func (c *TrelloConnection) Equals(otherConnection PipelingConnection) bool

func (*TrelloConnection) GetConnectionType 

func (c *TrelloConnection) GetConnectionType() string

func (*TrelloConnection) GetEnv 

func (c *TrelloConnection) GetEnv() map[string]cty.Value

func (*TrelloConnection) Resolve 

func (c *TrelloConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*TrelloConnection) Validate 

func (c *TrelloConnection) Validate() hcl.Diagnostics

type UptimeRobotConnection 

type UptimeRobotConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*UptimeRobotConnection) CtyValue 

func (c *UptimeRobotConnection) CtyValue() (cty.Value, error)

func (*UptimeRobotConnection) Equals 

func (c *UptimeRobotConnection) Equals(otherConnection PipelingConnection) bool

func (*UptimeRobotConnection) GetConnectionType 

func (c *UptimeRobotConnection) GetConnectionType() string

func (*UptimeRobotConnection) GetEnv 

func (c *UptimeRobotConnection) GetEnv() map[string]cty.Value

func (*UptimeRobotConnection) Resolve 

func (c *UptimeRobotConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*UptimeRobotConnection) Validate 

func (c *UptimeRobotConnection) Validate() hcl.Diagnostics

type UrlscanConnection 

type UrlscanConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*UrlscanConnection) CtyValue 

func (c *UrlscanConnection) CtyValue() (cty.Value, error)

func (*UrlscanConnection) Equals 

func (c *UrlscanConnection) Equals(otherConnection PipelingConnection) bool

func (*UrlscanConnection) GetConnectionType 

func (c *UrlscanConnection) GetConnectionType() string

func (*UrlscanConnection) GetEnv 

func (c *UrlscanConnection) GetEnv() map[string]cty.Value

func (*UrlscanConnection) Resolve 

func (c *UrlscanConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*UrlscanConnection) Validate 

func (c *UrlscanConnection) Validate() hcl.Diagnostics

type VaultConnection 

type VaultConnection struct {
	ConnectionImpl

	Address *string `json:"address,omitempty" cty:"address" hcl:"address,optional"`
	Token   *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*VaultConnection) CtyValue 

func (c *VaultConnection) CtyValue() (cty.Value, error)

func (*VaultConnection) Equals 

func (c *VaultConnection) Equals(otherConnection PipelingConnection) bool

func (*VaultConnection) GetConnectionType 

func (c *VaultConnection) GetConnectionType() string

func (*VaultConnection) GetEnv 

func (c *VaultConnection) GetEnv() map[string]cty.Value

func (*VaultConnection) Resolve 

func (c *VaultConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*VaultConnection) Validate 

func (c *VaultConnection) Validate() hcl.Diagnostics

type VirusTotalConnection 

type VirusTotalConnection struct {
	ConnectionImpl

	APIKey *string `json:"api_key,omitempty" cty:"api_key" hcl:"api_key,optional"`
}

func (*VirusTotalConnection) CtyValue 

func (c *VirusTotalConnection) CtyValue() (cty.Value, error)

func (*VirusTotalConnection) Equals 

func (c *VirusTotalConnection) Equals(otherConnection PipelingConnection) bool

func (*VirusTotalConnection) GetConnectionType 

func (c *VirusTotalConnection) GetConnectionType() string

func (*VirusTotalConnection) GetEnv 

func (c *VirusTotalConnection) GetEnv() map[string]cty.Value

func (*VirusTotalConnection) Resolve 

func (c *VirusTotalConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*VirusTotalConnection) Validate 

func (c *VirusTotalConnection) Validate() hcl.Diagnostics

type ZendeskConnection 

type ZendeskConnection struct {
	ConnectionImpl

	Email     *string `json:"email,omitempty" cty:"email" hcl:"email,optional"`
	Subdomain *string `json:"subdomain,omitempty" cty:"subdomain" hcl:"subdomain,optional"`
	Token     *string `json:"token,omitempty" cty:"token" hcl:"token,optional"`
}

func (*ZendeskConnection) CtyValue 

func (c *ZendeskConnection) CtyValue() (cty.Value, error)

func (*ZendeskConnection) Equals 

func (c *ZendeskConnection) Equals(otherConnection PipelingConnection) bool

func (*ZendeskConnection) GetConnectionType 

func (c *ZendeskConnection) GetConnectionType() string

func (*ZendeskConnection) GetEnv 

func (c *ZendeskConnection) GetEnv() map[string]cty.Value

func (*ZendeskConnection) Resolve 

func (c *ZendeskConnection) Resolve(ctx context.Context) (PipelingConnection, error)

func (*ZendeskConnection) Validate 

func (c *ZendeskConnection) Validate() hcl.Diagnostics

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.