postgres

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: May 6, 2026 License: PostgreSQL Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SubStatusInitializing = "initializing" // Worker running, sync in progress
	SubStatusReplicating  = "replicating"  // Worker running, sync ready
	SubStatusUnknown      = "unknown"      // Worker running, no sync status record
	SubStatusDisabled     = "disabled"     // Worker not running, subscription disabled
	SubStatusDown         = "down"         // Worker not running, subscription enabled
)

Spock subscription statuses returned by spock.sub_show_status(). See: https://github.com/pgEdge/spock/blob/main/src/spock_functions.c

Variables

This section is empty.

Functions

func DefaultGUCs 

func DefaultGUCs() map[string]any

func DefaultTunableGUCs 

func DefaultTunableGUCs(memBytes uint64, cpus float64, clusterSize int) map[string]any

func IsDatabaseNotExists added in v0.8.0 

func IsDatabaseNotExists(err error) bool

func IsSpockNodeNotConfigured added in v0.7.0 

func IsSpockNodeNotConfigured(err error) bool

IsSpockNodeNotConfigured reports whether err is a PostgreSQL error indicating that the current database has not been initialized as a spock node (SQLSTATE 55000 — object_not_in_prerequisite_state, as raised by spock.sync_event and related functions when spock.node_create has not been called or the node has been dropped via spock.node_drop).

Source: https://github.com/pgEdge/spock/blob/main/src/spock_functions.c PostgreSQL SQLSTATE reference: https://www.postgresql.org/docs/current/errcodes-appendix.html

func QuoteIdentifier added in v0.8.0 

func QuoteIdentifier(in string) string

QuoteIdentifier quotes and sanitizes identifiers. Callers must execute the SetEncode statements to consider the output of this method safe.

func ReplicationSlotName 

func ReplicationSlotName(databaseName, providerName, subscriberName string) string

func SnowflakeLolorGUCs 

func SnowflakeLolorGUCs(nodeOrdinal int) map[string]any

func Spock4DefaultGUCs 

func Spock4DefaultGUCs() map[string]any

func StartRepairModeTxn added in v0.8.0 

func StartRepairModeTxn(ctx context.Context, conn *pgx.Conn) (pgx.Tx, error)

StartRepairModeTxn will start a new transaction and, if Spock is enabled, enable repair mode for the transaction. Callers are responsible for calling Rollback and Commit on the returned transaction.

func UnquoteIdentifier added in v0.8.0 

func UnquoteIdentifier(in string) string

UnquoteIdentifier removes quotes from a quoted identifier.

Types

type BuiltinRoleOptions 

type BuiltinRoleOptions struct {
	PGVersion string
}

type BuiltinRolePrivilegeOptions added in v0.8.0 

type BuiltinRolePrivilegeOptions struct {
	DBName       string
	ExtraSchemas []string
}

func (BuiltinRolePrivilegeOptions) Schemas added in v0.8.0 

func (o BuiltinRolePrivilegeOptions) Schemas() []string

type ConditionalStatement 

type ConditionalStatement struct {
	If   Query[bool]
	Then IStatement
	Else IStatement
}

func CreateDatabase 

func CreateDatabase(name string) ConditionalStatement

func CreateReplicationSlot 

func CreateReplicationSlot(databaseName, providerNode, subscriberNode string) ConditionalStatement

func CreateRoleIfNotExists added in v0.8.0 

func CreateRoleIfNotExists(name string) ConditionalStatement

func CreateSubscription 

func CreateSubscription(providerName, subscriberName string, providerDSN *DSN, disabled bool, syncStructure bool, syncData bool) ConditionalStatement

func DropReplicationSlot added in v0.7.0 

func DropReplicationSlot(databaseName, providerNode, subscriberNode string) ConditionalStatement

func EnableSubscription 

func EnableSubscription(providerNode, subscriberNode string, disabled bool) ConditionalStatement

func RenameDB 

func RenameDB(oldName, newName string) ConditionalStatement

func TerminateReplicationSlot added in v0.7.0 

func TerminateReplicationSlot(databaseName, providerNode, subscriberNode string) ConditionalStatement

TerminateReplicationSlot terminates the walsender process using a replication slot, if one is active. This must be called before dropping a slot whose subscriber has gone down, since pg_drop_replication_slot fails on active slots.

func (ConditionalStatement) Exec 

func (s ConditionalStatement) Exec(ctx context.Context, conn Executor) error

type DSN 

type DSN struct {
	Hosts              []string
	Ports              []int
	User               string
	Password           string
	DBName             string
	SSLCert            string
	SSLKey             string
	SSLRootCert        string
	Service            string
	ApplicationName    string
	TargetSessionAttrs string
	Extra              map[string]string
}

func (*DSN) Fields added in v0.8.0 

func (d *DSN) Fields() []string

func (*DSN) Host added in v0.8.0 

func (d *DSN) Host() string

func (*DSN) Port added in v0.8.0 

func (d *DSN) Port() string

func (*DSN) String 

func (d *DSN) String() string

type Executor 

type Executor interface {
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, arguments ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, arguments ...any) pgx.Row
}

type IStatement 

type IStatement interface {
	Exec(ctx context.Context, conn Executor) error
}

type PgServiceConf added in v0.8.0 

type PgServiceConf struct {
	Services map[string]*DSN
}

func NewPgServiceConf added in v0.8.0 

func NewPgServiceConf() *PgServiceConf

func (*PgServiceConf) String added in v0.8.0 

func (c *PgServiceConf) String() string

type Query 

type Query[T any] struct {
	SQL  string
	Args pgx.NamedArgs
}

func CurrentReplicationSlotLSN 

func CurrentReplicationSlotLSN(databaseName, providerNode, subscriberNode string) Query[string]

func GetPostgresVersion 

func GetPostgresVersion() Query[string]

func GetReplicationSetTables 

func GetReplicationSetTables() Query[ReplicationSetTable]

func GetReplicationSets 

func GetReplicationSets() Query[ReplicationSet]

func GetReplicationSlotLSNFromCommitTS 

func GetReplicationSlotLSNFromCommitTS(databaseName, providerNode, subscriberNode string, commitTS time.Time) Query[string]

func GetSpockReadOnly 

func GetSpockReadOnly() Query[string]

func GetSpockVersion 

func GetSpockVersion() Query[string]

func GetSubscriptionStatus added in v0.7.0 

func GetSubscriptionStatus(providerNode, subscriberNode string) Query[string]

GetSubscriptionStatus returns the current status of a specific subscription

func GetSubscriptionStatuses 

func GetSubscriptionStatuses() Query[SubscriptionStatus]

func IsInRecovery added in v0.8.0 

func IsInRecovery() Query[bool]

func IsReplicationSlotActive added in v0.7.0 

func IsReplicationSlotActive(databaseName, providerNode, subscriberNode string) Query[bool]

IsReplicationSlotActive checks if a replication slot is currently being used by an active walsender process. Uses EXISTS to always return exactly one row.

func IsSpockEnabled 

func IsSpockEnabled() Query[bool]

func LagTrackerCommitTimestamp 

func LagTrackerCommitTimestamp(originNode, receiverNode string) Query[time.Time]

func NodeNeedsCreate added in v0.8.0 

func NodeNeedsCreate(nodeName string) Query[bool]

func ReplicationSlotNeedsCreate 

func ReplicationSlotNeedsCreate(databaseName, providerNode, subscriberNode string) Query[bool]

func SubscriptionDsnNeedsUpdate 

func SubscriptionDsnNeedsUpdate(providerName, subscriberName string, providerDSN *DSN) Query[bool]

func SubscriptionNeedsCreate 

func SubscriptionNeedsCreate(providerName, subscriberName string) Query[bool]

func SubscriptionNeedsEnable 

func SubscriptionNeedsEnable(providerName, subscriberName string, disabled bool) Query[bool]

func SyncEvent 

func SyncEvent() Query[string]

func UserRoleNeedsCreate added in v0.8.0 

func UserRoleNeedsCreate(name string) Query[bool]

UserRoleNeedsCreate returns a query that evaluates to true when the named role does not yet exist in pg_catalog.pg_roles.

func WaitForSyncEvent 

func WaitForSyncEvent(originNode, lsn string, timeoutSeconds int) Query[bool]

func (Query[T]) Scalar 

func (q Query[T]) Scalar(ctx context.Context, conn Executor) (T, error)

func (Query[T]) Scalars 

func (q Query[T]) Scalars(ctx context.Context, conn Executor) ([]T, error)

func (Query[T]) Structs 

func (q Query[T]) Structs(ctx context.Context, conn Executor) ([]T, error)

type ReplicationSet 

type ReplicationSet struct {
	SetID       uint32
	SetNodeID   uint32
	SetName     string
	RepInsert   bool
	RepUpdate   bool
	RepDelete   bool
	RepTruncate bool
}

type ReplicationSetTable 

type ReplicationSetTable struct {
	SetID        uint32
	SetRelOID    uint32
	SetAttList   []string
	SetRowFilter string
}

type Statement 

type Statement struct {
	SQL  string
	Args pgx.NamedArgs
}

func AddReplicationSetTable 

func AddReplicationSetTable(
	setName string,
	relOID uint32,
	columns []string,
	rowFilter string,
	sync bool,
	includePartitions bool,
) Statement

https://docs.pgedge.com/spock_ext/spock_functions/functions/spock_repset_add_table

func AdvanceReplicationSlotToLSN 

func AdvanceReplicationSlotToLSN(databaseName, providerNode, subscriberNode string, targetLSN string) Statement

func AlterOwner added in v0.8.0 

func AlterOwner(dbName, owner string) Statement

func CreateReplicationSet 

func CreateReplicationSet(r ReplicationSet) Statement

https://docs.pgedge.com/spock_ext/spock_functions/functions/spock_repset_create

func DropAllSubscriptions 

func DropAllSubscriptions() Statement

func DropSubscription 

func DropSubscription(providerName, subscriberName string) Statement

func EnableRepairMode 

func EnableRepairMode() Statement

func TerminateOtherConnections 

func TerminateOtherConnections(dbName string) Statement

func (Statement) Exec 

func (s Statement) Exec(ctx context.Context, conn Executor) error

type Statements 

type Statements []IStatement

func CreateBuiltInRoles 

func CreateBuiltInRoles(opts BuiltinRoleOptions) (Statements, error)

func CreatePgEdgeSuperuserRole 

func CreatePgEdgeSuperuserRole(opts BuiltinRoleOptions) (Statements, error)

func CreateUserRole 

func CreateUserRole(opts UserRoleOptions) (Statements, error)

func DropSpockAndCleanupSlots 

func DropSpockAndCleanupSlots(dbName string) Statements

func GrantBuiltinRolePrivileges added in v0.8.0 

func GrantBuiltinRolePrivileges(opts BuiltinRolePrivilegeOptions) Statements

func InitializeSpockNode added in v0.8.0 

func InitializeSpockNode(nodeName string, nodeDSN *DSN) Statements

func RestoreReplicationSets 

func RestoreReplicationSets(sets []ReplicationSet, tabs []ReplicationSetTable) Statements

func SetSafeIdentifiers added in v0.8.0 

func SetSafeIdentifiers() Statements

SetSafeIdentifiers ensures that the escaped identifiers produced by the QuoteIdentifier method are safe for the duration of the session.

func (Statements) Exec 

func (s Statements) Exec(ctx context.Context, conn Executor) error

type SubscriptionStatus 

type SubscriptionStatus struct {
	SubscriptionName string   `json:"subscription_name"`
	Status           string   `json:"status"`
	ProviderNode     string   `json:"provider_node"`
	ProviderDSN      string   `json:"provider_dsn"`
	SlotName         string   `json:"slot_name"`
	ReplicationSets  []string `json:"replication_sets"`
	ForwardOrigins   []string `json:"forward_origins"`
}

type UserRoleOptions 

type UserRoleOptions struct {
	Name       string
	Password   string
	Attributes []string
	Roles      []string
}

Source Files

View all Source files

Directories

Path Synopsis

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.