Function UpdateSubscriptionStatus

pgserver/logrepl/subscription.go:111–114

(ctx *sql.Context, enabled bool, name string)

}

func UpdateSubscriptionStatus(ctx *sql.Context, enabled bool, name string) error {
	_, err := adapter.ExecCatalogInTxn(ctx, catalog.InternalTables.PgSubscription.UpdateStmt(keyColumns, statusValueColumns), enabled, name)
	return err
}

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