Skip to main content

internal/infra/pg/entityrecovery.go

internal/infra/pg · 73 lines · 2 declarations · source

Declarations​

func validateReceiptEntitiesTx​

func validateReceiptEntitiesTx(ctx context.Context, tx pgx.Tx, schema Schema, scope string, state, left, right []byte) error

Identity must agree with the receipt's endpoint, not just occupy the same UUID. Row locks also allow the caller to repair its alias cache without upgrading competing shared locks. Alias ownership is checked separately through source-owned name receipts.

source

func repairReceiptEntityNamesTx​

func repairReceiptEntityNamesTx(ctx context.Context, tx pgx.Tx, schema Schema, scope string, state []byte) (bool, error)

source