rdapp

Documentation

Index

• Constants
• type PgRedshiftTranslator
  • func NewPgRedshiftTranslator() PgRedshiftTranslator
• type PostgresRedshiftProxy
  • func ConstructProxy(cfg aws.Config, redshiftDataApiConfig RedshiftDataAPIConfig, ...) PostgresRedshiftProxy
  • func NewPostgresRedshiftDataAPIProxy(listenAddress string, simpleQueryFn wire.SimpleQueryFn, logger *zap.Logger) PostgresRedshiftProxy
• type RdappContext
• type RedshiftClient
• type RedshiftDataAPIConfig
• type RedshiftDataAPIService
  • func NewRedshiftDataAPIService(redshiftDataApiClient RedshiftDataApiClient, ...) RedshiftDataAPIService
• type RedshiftDataApiClient
• type RedshiftDataApiQueryHandler
  • func NewRedshiftDataApiQueryHandler(redshiftDataAPIService RedshiftDataAPIService, ...) RedshiftDataApiQueryHandler
• type RedshiftServerlessClient
• type RedshiftService
  • func NewRedshiftService(redshiftClient RedshiftClient, ...) RedshiftService
• type Secrets
  • func (secrets Secrets) GetSecretArns() []string
• type SecretsManagerClient
• type SecretsService
  • func NewSecretsService(secretsManagerClient SecretsManagerClient) SecretsService

Constants

const (
	RedshiftTypeSuper       = "super"
	RedshiftTypeBool        = "bool"
	RedshiftTypeChar        = "char"
	RedshiftTypeVarchar     = "varchar"
	RedshiftTypeBpchar      = "bpchar"
	RedshiftTypeTimestamp   = "timestamp"
	RedshiftTypeTimestamptz = "timestamptz"
	RedshiftTypeFloat4      = "float4"
	RedshiftTypeFloat8      = "float8"
	RedshiftTypeInt2        = "int2"
	RedshiftTypeInt4        = "int4"
	RedshiftTypeInt8        = "int8"
	RedshiftTypeNumeric     = "numeric"
	RedshiftTypeName        = "name"
	RedshiftTypeOid         = "oid"
	RedshiftTypeAclitem     = "_aclitem"
	RedshiftTypeText        = "_text"
)

Types

type PgRedshiftTranslator

type PgRedshiftTranslator interface {
	TranslateToRedshiftQuery(pgQuery string) string
	TranslateToRedshiftQueryParams(pgParams []string) []types.SqlParameter
	TranslateColumnMetaDataToPgFormat(rdappCtx RdappContext, columnMetadata []types.ColumnMetadata) (wire.Columns, error)
	TranslateRowToPgFormat(rdappCtx RdappContext, redshiftRow []types.Field) ([]any, error)
}

func NewPgRedshiftTranslator

func NewPgRedshiftTranslator() PgRedshiftTranslator

type PostgresRedshiftProxy

type PostgresRedshiftProxy interface {
	Run() error
}

func ConstructProxy

func ConstructProxy(cfg aws.Config, redshiftDataApiConfig RedshiftDataAPIConfig, logger *zap.Logger, listenAddress string) PostgresRedshiftProxy

func NewPostgresRedshiftDataAPIProxy

func NewPostgresRedshiftDataAPIProxy(listenAddress string, simpleQueryFn wire.SimpleQueryFn, logger *zap.Logger) PostgresRedshiftProxy

type RdappContext

type RdappContext struct {
	context.Context
	// contains filtered or unexported fields
}

type RedshiftClient

type RedshiftClient interface {
	redshift.DescribeClustersAPIClient
}

type RedshiftDataAPIConfig

type RedshiftDataAPIConfig struct {
	// The name of the database. This parameter is required when authenticating using
	// either Secrets Manager or temporary credentials.
	//
	// This member is required.
	Database *string

	// The cluster identifier. This parameter is required when connecting to a cluster
	// and authenticating using either Secrets Manager or temporary credentials.
	ClusterIdentifier *string

	// The database user name. This parameter is required when connecting to a cluster
	// and authenticating using temporary credentials.
	DbUser *string

	// The name or ARN of the secret that enables access to the database. This
	// parameter is required when authenticating using Secrets Manager.
	SecretArn *string

	// The serverless workgroup name. This parameter is required when connecting to a
	// serverless workgroup and authenticating using either Secrets Manager or
	// temporary credentials.
	WorkgroupName *string
}

type RedshiftDataAPIService

type RedshiftDataAPIService interface {
	ExecuteQuery(ctx RdappContext, query string, parameters []types.SqlParameter) (*redshiftdata.GetStatementResultOutput, error)
}

func NewRedshiftDataAPIService

func NewRedshiftDataAPIService(redshiftDataApiClient RedshiftDataApiClient, redshiftDataAPIConfig RedshiftDataAPIConfig) RedshiftDataAPIService

type RedshiftDataApiClient

type RedshiftDataApiClient interface {
	ExecuteStatement(ctx context.Context, params *redshiftdata.ExecuteStatementInput, optFns ...func(*redshiftdata.Options)) (*redshiftdata.ExecuteStatementOutput, error)
	DescribeStatement(ctx context.Context, params *redshiftdata.DescribeStatementInput, optFns ...func(*redshiftdata.Options)) (*redshiftdata.DescribeStatementOutput, error)
	GetStatementResult(ctx context.Context, params *redshiftdata.GetStatementResultInput, optFns ...func(*redshiftdata.Options)) (*redshiftdata.GetStatementResultOutput, error)
}

type RedshiftDataApiQueryHandler

type RedshiftDataApiQueryHandler interface {
	QueryHandler(ctx context.Context, query string, writer wire.DataWriter, parameters []string) error
}

func NewRedshiftDataApiQueryHandler

func NewRedshiftDataApiQueryHandler(redshiftDataAPIService RedshiftDataAPIService, pgRedshiftTranslator PgRedshiftTranslator, logger *zap.Logger) RedshiftDataApiQueryHandler

type RedshiftServerlessClient

type RedshiftServerlessClient interface {
	redshiftserverless.ListWorkgroupsAPIClient
	redshiftserverless.ListNamespacesAPIClient
}

type RedshiftService

type RedshiftService interface {
	FetchServerlessWorkGroups(ctx context.Context) ([]redshiftserverlesstypes.Workgroup, error)
	FetchServerlessNamespaces(ctx context.Context) ([]redshiftserverlesstypes.Namespace, error)
	FetchProvisionedClusters(ctx context.Context) ([]types.Cluster, error)
}

func NewRedshiftService

func NewRedshiftService(redshiftClient RedshiftClient, redshiftServerlessClient RedshiftServerlessClient) RedshiftService

type Secrets

type Secrets []secretmanagertypes.SecretListEntry

func (Secrets) GetSecretArns

func (secrets Secrets) GetSecretArns() []string

type SecretsManagerClient

type SecretsManagerClient interface {
	secretsmanager.ListSecretsAPIClient
}

type SecretsService

type SecretsService interface {
	FetchSecrets(ctx context.Context) (Secrets, error)
}

func NewSecretsService

func NewSecretsService(secretsManagerClient SecretsManagerClient) SecretsService