connection

package
v1.7.2 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 2024 License: AGPL-3.0 Imports: 25 Imported by: 0

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 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 (*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 (*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 (*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 (*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 (*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 (*ClickUpConnection) Validate

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

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 ConnectionStringProvider

type ConnectionStringProvider interface {
	GetConnectionString() string
}

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

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 (*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 (*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() string

func (*DuckDbConnection) GetConnectionType

func (c *DuckDbConnection) GetConnectionType() string

func (*DuckDbConnection) GetEnv

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

func (*DuckDbConnection) Resolve

func (*DuckDbConnection) Validate

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

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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() string

func (*MysqlConnection) GetConnectionType

func (c *MysqlConnection) GetConnectionType() string

func (*MysqlConnection) GetEnv

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

func (*MysqlConnection) Resolve

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 (*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 (*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 (*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 (*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 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 (*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

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() string

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 (*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 (*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 (*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 (*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() string

func (*SqliteConnection) GetConnectionType

func (c *SqliteConnection) GetConnectionType() string

func (*SqliteConnection) GetEnv

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

func (*SqliteConnection) Resolve

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() string

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 (*SteampipePgConnection) Validate

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

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 (*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 (*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 (*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 (*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 (*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 (*ZendeskConnection) Validate

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

Jump to

Keyboard shortcuts

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