Function UpdateAllSubscriptionStatus

pgserver/logrepl/subscription.go:116–119

(ctx *sql.Context, enabled bool)

}

func UpdateAllSubscriptionStatus(ctx *sql.Context, enabled bool) error {
	_, err := adapter.ExecCatalogInTxn(ctx, catalog.InternalTables.PgSubscription.UpdateAllStmt(statusValueColumns), enabled)
	return err
}

func DeleteSubscription(ctx *sql.Context, name string) error {
	_, err := adapter.ExecCatalogInTxn(ctx, catalog.InternalTables.PgSubscription.DeleteStmt(), name)