postgres

Jun 5, 2024

Changes in this version

type DatabaseArgs

+ Client string

+ MaxConnsFromEnv string

+ MaxConnsIdleTime *durationpb.Duration

+ func (x *DatabaseArgs) GetClient() string

+ func (x *DatabaseArgs) GetMaxConnsFromEnv() string

+ func (x *DatabaseArgs) GetMaxConnsIdleTime() *durationpb.Duration

type FactoryArgs

+ Client string

+ func (x *FactoryArgs) GetClient() string

Apr 10, 2024

Changes in this version

+ func PgErrCode(err error) string

+ type ConnUri string

+ func ProvideDatabaseReference(ctx context.Context, args *DatabaseReferenceArgs, deps ExtensionDeps) (ConnUri, error)

+ type DatabaseReferenceArgs struct

+ ClusterRef string

+ Database string

+ func (*DatabaseReferenceArgs) Descriptor() ([]byte, []int)

+ func (*DatabaseReferenceArgs) ProtoMessage()

+ func (x *DatabaseReferenceArgs) GetClusterRef() string

+ func (x *DatabaseReferenceArgs) GetDatabase() string

+ func (x *DatabaseReferenceArgs) ProtoReflect() protoreflect.Message

+ func (x *DatabaseReferenceArgs) Reset()

+ func (x *DatabaseReferenceArgs) String() string

Mar 11, 2024

Changes in this version

+ type ConfigOverrides struct

+ MaxConnIdleTime time.Duration

+ MaxConns int32

type DB

+ func NewDatabaseFromConnectionUriWithOverrides(ctx context.Context, db *postgrespb.DatabaseInstance, connuri string, ...) (*DB, error)

type DatabaseArgs

+ MaxConns int32

+ func (x *DatabaseArgs) GetMaxConns() int32

Feb 19, 2024

Changes in this version

type DB

+ func (db DB) PgxPool() *pgxpool.Pool

Feb 12, 2024

Changes in this version

type DB

+ func NewDatabase(instance *postgrespb.DatabaseInstance, conn *pgxpool.Pool, tracer trace.Tracer) *DB

+ func NewDatabaseFromConnectionUri(ctx context.Context, db *postgrespb.DatabaseInstance, connuri string, ...) (*DB, error)

Nov 29, 2023

Changes in this version

type DB

+ func (db DB) Close() error

Nov 2, 2023

Changes in this version

type DB

+ func (db DB) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults

Oct 2, 2023

Changes in this version

type DB

+ func ProvideDatabaseFromResourceRef(ctx context.Context, ref string, opts NewDBOptions) (*DB, error)

+ type Factory struct

+ func ProvideFactory(ctx context.Context, _ *FactoryArgs, deps ExtensionDeps) (Factory, error)

+ func (f Factory) Provide(ctx context.Context, ref string) (*DB, error)

+ func (f Factory) ProvideWithCustomErrors(ctx context.Context, ref string, errW func(context.Context, error) error) (*DB, error)

+ type FactoryArgs struct

+ func (*FactoryArgs) Descriptor() ([]byte, []int)

+ func (*FactoryArgs) ProtoMessage()

+ func (x *FactoryArgs) ProtoReflect() protoreflect.Message

+ func (x *FactoryArgs) Reset()

+ func (x *FactoryArgs) String() string

+ type NewDBOptions struct

+ ErrorWrapper func(context.Context, error) error

+ Tracer trace.Tracer

Jun 26, 2023

Changes in this version

+ func ErrorIsRetryable(err error) bool

type DB

+ func (db DB) Tracer() trace.Tracer

Mar 13, 2023

Changes in this version

+ type TransactionError struct

+ InternalErr error

+ func (p TransactionError) Error() string

+ func (p TransactionError) Unwrap() error

Mar 10, 2023

Changes in this version

+ func ReturnFromReadWriteTx(ctx context.Context, db *DB, b backoff.BackOff, ...) (T, error)

Dec 20, 2022

Changes in this version

+ var File_universe_db_postgres_provider_proto protoreflect.FileDescriptor

+ var Package__sfr1nt = &core.Package

+ var Provider__sfr1nt = core.Provider

type DB

+ func ProvideDatabase(ctx context.Context, db *DatabaseArgs, deps ExtensionDeps) (*DB, error)

+ type DatabaseArgs struct

+ ResourceRef string

+ func (*DatabaseArgs) Descriptor() ([]byte, []int)

+ func (*DatabaseArgs) ProtoMessage()

+ func (x *DatabaseArgs) GetResourceRef() string

+ func (x *DatabaseArgs) ProtoReflect() protoreflect.Message

+ func (x *DatabaseArgs) Reset()

+ func (x *DatabaseArgs) String() string

+ type ExtensionDeps struct

+ OpenTelemetry tracing.DeferredTracerProvider

Dec 16, 2022

Changes in this version

type DB

+ func ConnectToResource(ctx context.Context, res *resources.Parsed, resourceRef string) (*DB, error)

Nov 30, 2022

Changes in this version

+ func ReturnFromTx(ctx context.Context, db *DB, f func(context.Context, pgx.Tx) (T, error)) (T, error)

Oct 24, 2022

Changes in this version

+ var File_universe_db_postgres_database_proto protoreflect.FileDescriptor

+ type DB struct

+ func NewDB(conn *pgxpool.Pool, tracer trace.Tracer) *DB

+ func (db DB) BeginTxFunc(ctx context.Context, txOptions pgx.TxOptions, callback func(pgx.Tx) error) error

+ func (db DB) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)

+ func (db DB) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

+ func (db DB) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, ...) (pgconn.CommandTag, error)

+ func (db DB) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

+ type Database struct

+ Credentials *Database_Credentials

+ HostedAt *Database_Endpoint

+ Name string

+ SchemaFile *types.Resource

+ func (*Database) Descriptor() ([]byte, []int)

+ func (*Database) ProtoMessage()

+ func (x *Database) GetCredentials() *Database_Credentials

+ func (x *Database) GetHostedAt() *Database_Endpoint

+ func (x *Database) GetName() string

+ func (x *Database) GetSchemaFile() *types.Resource

+ func (x *Database) ProtoReflect() protoreflect.Message

+ func (x *Database) Reset()

+ func (x *Database) String() string

+ type Database_Credentials struct

+ Password *Database_Credentials_Secret

+ User *Database_Credentials_Secret

+ func (*Database_Credentials) Descriptor() ([]byte, []int)

+ func (*Database_Credentials) ProtoMessage()

+ func (x *Database_Credentials) GetPassword() *Database_Credentials_Secret

+ func (x *Database_Credentials) GetUser() *Database_Credentials_Secret

+ func (x *Database_Credentials) ProtoReflect() protoreflect.Message

+ func (x *Database_Credentials) Reset()

+ func (x *Database_Credentials) String() string

+ type Database_Credentials_Secret struct

+ FromPath string

+ Value string

+ func (*Database_Credentials_Secret) Descriptor() ([]byte, []int)

+ func (*Database_Credentials_Secret) ProtoMessage()

+ func (x *Database_Credentials_Secret) GetFromPath() string

+ func (x *Database_Credentials_Secret) GetValue() string

+ func (x *Database_Credentials_Secret) ProtoReflect() protoreflect.Message

+ func (x *Database_Credentials_Secret) Reset()

+ func (x *Database_Credentials_Secret) String() string

+ type Database_Endpoint struct

+ Address string

+ Port uint32

+ func (*Database_Endpoint) Descriptor() ([]byte, []int)

+ func (*Database_Endpoint) ProtoMessage()

+ func (x *Database_Endpoint) GetAddress() string

+ func (x *Database_Endpoint) GetPort() uint32

+ func (x *Database_Endpoint) ProtoReflect() protoreflect.Message

+ func (x *Database_Endpoint) Reset()

+ func (x *Database_Endpoint) String() string

+ type InstantiatedDatabase struct

+ Credentials *InstantiatedDatabase_Credentials

+ Database []*Database

+ PackageName string

+ func (*InstantiatedDatabase) Descriptor() ([]byte, []int)

+ func (*InstantiatedDatabase) ProtoMessage()

+ func (x *InstantiatedDatabase) GetCredentials() *InstantiatedDatabase_Credentials

+ func (x *InstantiatedDatabase) GetDatabase() []*Database

+ func (x *InstantiatedDatabase) GetPackageName() string

+ func (x *InstantiatedDatabase) ProtoReflect() protoreflect.Message

+ func (x *InstantiatedDatabase) Reset()

+ func (x *InstantiatedDatabase) String() string

+ type InstantiatedDatabase_Credentials struct

+ SecretMountPath string

+ SecretName string

+ SecretResourceName string

+ func (*InstantiatedDatabase_Credentials) Descriptor() ([]byte, []int)

+ func (*InstantiatedDatabase_Credentials) ProtoMessage()

+ func (x *InstantiatedDatabase_Credentials) GetSecretMountPath() string

+ func (x *InstantiatedDatabase_Credentials) GetSecretName() string

+ func (x *InstantiatedDatabase_Credentials) GetSecretResourceName() string

+ func (x *InstantiatedDatabase_Credentials) ProtoReflect() protoreflect.Message

+ func (x *InstantiatedDatabase_Credentials) Reset()

+ func (x *InstantiatedDatabase_Credentials) String() string

+ type InstantiatedDatabases struct

+ Instantiated []*InstantiatedDatabase

+ func (*InstantiatedDatabases) Descriptor() ([]byte, []int)

+ func (*InstantiatedDatabases) ProtoMessage()

+ func (x *InstantiatedDatabases) GetInstantiated() []*InstantiatedDatabase

+ func (x *InstantiatedDatabases) ProtoReflect() protoreflect.Message

+ func (x *InstantiatedDatabases) Reset()

+ func (x *InstantiatedDatabases) String() string