ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Konstantin Boudnik <...@apache.org>
Subject Re: Persistent Distributed Store Metrics
Date Tue, 06 Jun 2017 01:46:25 GMT
Wow, hold on - as far as I remember there was a VOTE to accept the
contribution of the code into the project _on a branch_. We haven't vetted its
inclusion into the next release, We are still at the phase of getting familiar
with the code. 

And from what I am seeing in the discussions like this [1], we need to be
extra careful.

BTW, you have sent this email 9 days before the vote had happened! A bit too
soon, if you ask me.

[1] https://is.gd/UQCr51

Cos

On Wed, May 17, 2017 at 11:16AM, Dmitriy Govorukhin wrote:
> Folk,
> 
> As you know, ignite 2.1 will contain new module (pds), it will be
> provide ability to store data on disk. Let's discuss what type of
> metrics we need for this?
> I think it must be metrics per memory policy, per cache, checkpoint,
> and global metrics which will be aggregate all metrics.
> 
> I did sketch.
> 
> PersistentStoreMetrics.java
> 
> public interface PersistentStoreMetrics {
> 
>     // Global metrics.
> 
>     public long getMemorySize();
> 
>     public long getDiskSize();
> 
>     public long getPagesInMemory();
> 
>     public long getPagesSizeInMemory();
> 
>     public long getPagesOnDisk();
> 
>     public long getPagesSizeOnDisk();
> 
>     public long getFreePages();
> 
>     public long getFreePagesSize();
> 
>     public long getDirtyPages();
> 
>     public long getDirtyPagesSize();
> 
>     public long walLog();
> 
>     public long walLogSize();
> 
>     // Frequency.
> 
>     public long getPagesRead();
> 
>     public long getPagesWrite();
> 
>     public long getFsync();
> 
>     public long getWal();
> 
>     public long getAverageWalFsyncTime();
> 
>     // Per cache.
> 
>     public PersistentStoreCacheMetrics cache(String name);
> 
>     public PersistentStoreCacheMetrics cache(int cacheId);
> 
>     // For last checkpoint.
> 
>     public PersistentStoreCheckpointMetrics getLastCheckPoint();
> }
> 
> >>>>>>>>>>>>>>>>>>>>>>>
> 
> PersistentStoreCacheMetrics.java
> 
> public interface PersistentStoreCacheMetrics {
> 
>     public String name();
> 
>     public double getFillFactor();
> 
>     public double getFillFactor(int part);
> 
>     public long getMemorySize();
> 
>     public long getDiskSize();
> 
>     public long getPagesInMemory();
> 
>     public long getPagesSizeInMemory();
> 
>     public long getPagesOnDisk();
> 
>     public long getPagesSizeOnDisk();
> 
>     public long getFreePages();
> 
>     public long getFreePagesSize();
> 
>     public long getDirtyPages();
> 
>     public long getDirtyPagesSize();
> 
>     public long getPagesRead();
> 
>     public long getPagesWritten();
> }
> 
> >>>>>>>>>>>>>>>>>>>>>>>
> 
> PersistentStoreCheckpointMetrics.java
> 
> public interface PersistentStoreCheckpointMetrics {
> 
>     public long getTotalPages();
> 
>     //TODO Page type is internal?
>     public long[] pagesType();
> 
>     public long getExecutingTime();
> 
>     public long getFsyncTime();
> 
>     public long getPagesCopyOnWrite();
> }

Mime
View raw message