Function DeleteSubscription

pgserver/logrepl/subscription.go:121–124

(ctx *sql.Context, name string)

}

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

func UpdateSubscriptionLsn(ctx *sql.Context, lsn, name string) error {
	_, err := adapter.ExecCatalogInTxn(ctx, catalog.InternalTables.PgSubscription.UpdateStmt(keyColumns, lsnValueColumns), lsn, name)