Method Running

pgserver/logrepl/replication.go:481–485

Running returns whether replication is currently running

()

	r.commitOngoingTxnIfClean(state, delta.OnCloseFlushReason)

	// Rollback any open transaction
	r.rollback(ctx)

	r.running = false
	close(r.stop)
}