diff options
Diffstat (limited to 'runtime/perctile_stats.h')
| -rw-r--r-- | runtime/perctile_stats.h | 89 |
1 files changed, 89 insertions, 0 deletions
diff --git a/runtime/perctile_stats.h b/runtime/perctile_stats.h new file mode 100644 index 0000000..6a7ed0d --- /dev/null +++ b/runtime/perctile_stats.h @@ -0,0 +1,89 @@ +/* + * This file is part of the rsyslog runtime library. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * -or- + * see COPYING.ASL20 in the source distribution + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef INCLUDED_PERCTILE_STATS_H +#define INCLUDED_PERCTILE_STATS_H + +#include "hashtable.h" +#include "statsobj.h" + +struct perctile_ctr_s { + // percentile [0,100] + uint8_t percentile; + size_t index; + intctr_t ctr_perctile_stat; + ctr_t *ref_ctr_percentile_stat; +}; + +struct perctile_stat_s { + uchar name[128]; + sbool bReported; + struct ringbuf_s *rb_observed_stats; + // array of requested perctile to track + struct perctile_ctr_s *ctrs; + size_t perctile_ctrs_count; + + pthread_rwlock_t stats_lock; + intctr_t ctrWindowCount; + ctr_t *refCtrWindowCount; + intctr_t ctrWindowMin; + ctr_t *refCtrWindowMin; + intctr_t ctrWindowMax; + ctr_t *refCtrWindowMax; + intctr_t ctrWindowSum; + ctr_t *refCtrWindowSum; +}; + +struct perctile_bucket_s { + uchar *name; + uchar *delim; + // lock for entire bucket + pthread_rwlock_t lock; + struct hashtable *htable; + struct perctile_bucket_s *next; + statsobj_t *statsobj; + STATSCOUNTER_DEF(ctrNewKeyAdd, mutCtrNewKeyAdd); + ctr_t *pNewKeyAddCtr; + STATSCOUNTER_DEF(ctrOpsOverflow, mutCtrOpsOverflow); + ctr_t *pOpsOverflowCtr; + uint32_t window_size; + // These percentile values apply to all perctile stats in this bucket. + uint8_t *perctile_values; + size_t perctile_values_count; +}; + +struct perctile_buckets_s { + uint8_t initialized; + statsobj_t *global_stats; + pthread_rwlock_t lock; + struct perctile_bucket_s *listBuckets; +}; + +// keep these local for now. +typedef struct perctile_ctr_s perctile_ctr_t; +typedef struct perctile_stat_s perctile_stat_t; +typedef struct perctile_bucket_s perctile_bucket_t; + +rsRetVal perctileClassInit(void); +void perctileBucketsDestruct(void); +rsRetVal perctile_initCnf(perctile_buckets_t *b); +perctile_bucket_t* perctile_findBucket(const uchar* name); +rsRetVal perctile_processCnf(struct cnfobj *cnf); +rsRetVal perctile_obs(perctile_bucket_t *perctile_bkt, uchar* key, int64_t value); + +#endif /* #ifndef INCLUDED_PERCTILE_STATS_H */ |