postgresql

Documentation

Index

• Constants
• Variables
• func NewPostgreSQLIntegrationCreator(deps domain.IntegrationDeps) domain.IntegrationCreator
• type PostgreSQLCredential
• type PostgreSQLIntegration
  • func NewPostgreSQLIntegration(ctx context.Context, deps PostgreSQLIntegrationDependencies) (*PostgreSQLIntegration, error)
  • func (i *PostgreSQLIntegration) Execute(ctx context.Context, params domain.IntegrationInput) (domain.IntegrationOutput, error)
  • func (i *PostgreSQLIntegration) ExecuteQuery(ctx context.Context, params domain.IntegrationInput, item domain.Item) ([]domain.Item, error)
• type PostgreSQLIntegrationCreator
  • func (c *PostgreSQLIntegrationCreator) CreateIntegration(ctx context.Context, p domain.CreateIntegrationParams) (domain.IntegrationExecutor, error)
• type PostgreSQLIntegrationDependencies
• type PostgreSQLParams
• type Query

Constants

const (
	IntegrationActionType_ExecuteQuery domain.IntegrationActionType = "execute_query"
	IntegrationActionType_Delete       domain.IntegrationActionType = "delete"
	IntegrationActionType_Insert       domain.IntegrationActionType = "insert"
	IntegrationActionType_Select       domain.IntegrationActionType = "select"
	IntegrationActionType_Upsert       domain.IntegrationActionType = "upsert"
	IntegrationActionType_Update       domain.IntegrationActionType = "update"
)

const (
	PostgreSQLPeekable_Tables  domain.IntegrationPeekableType = "tables"
	PostgreSQLPeekable_Columns domain.IntegrationPeekableType = "columns"
	PostgreSQLPeekable_Schemas domain.IntegrationPeekableType = "schemas"
)

Variables

var (
	Schema = schema
)

Functions

func NewPostgreSQLIntegrationCreator

func NewPostgreSQLIntegrationCreator(deps domain.IntegrationDeps) domain.IntegrationCreator

Types

type PostgreSQLCredential

type PostgreSQLCredential struct {
	URI string `json:"uri"`
}

type PostgreSQLIntegration

type PostgreSQLIntegration struct {
	// contains filtered or unexported fields
}

func NewPostgreSQLIntegration

func NewPostgreSQLIntegration(ctx context.Context, deps PostgreSQLIntegrationDependencies) (*PostgreSQLIntegration, error)

func (*PostgreSQLIntegration) Execute

func (i *PostgreSQLIntegration) Execute(ctx context.Context, params domain.IntegrationInput) (domain.IntegrationOutput, error)

func (*PostgreSQLIntegration) ExecuteQuery

func (i *PostgreSQLIntegration) ExecuteQuery(ctx context.Context, params domain.IntegrationInput, item domain.Item) ([]domain.Item, error)

type PostgreSQLIntegrationCreator

type PostgreSQLIntegrationCreator struct {
	// contains filtered or unexported fields
}

func (*PostgreSQLIntegrationCreator) CreateIntegration

func (c *PostgreSQLIntegrationCreator) CreateIntegration(ctx context.Context, p domain.CreateIntegrationParams) (domain.IntegrationExecutor, error)

type PostgreSQLIntegrationDependencies

type PostgreSQLIntegrationDependencies struct {
	CredentialID     string
	CredentialGetter domain.CredentialGetter[PostgreSQLCredential]
	ParameterBinder  domain.IntegrationParameterBinder
}

type PostgreSQLParams

type PostgreSQLParams struct {
	Query Query `json:"query"`
}

type Query

type Query struct {
	Content          string `json:"content"`
	Query_Parameters []any  `json:"query_parameters"`
}