Documentation
¶
Index ¶
- type CacheCollector
- func (c *CacheCollector) Del(ctx context.Context, keys ...string) *redis.IntCmd
- func (c *CacheCollector) Get(ctx context.Context, key string) *redis.StringCmd
- func (c *CacheCollector) GetClient() *redis.Client
- func (c *CacheCollector) HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd
- func (c *CacheCollector) HGet(ctx context.Context, key, field string) *redis.StringCmd
- func (c *CacheCollector) HSet(ctx context.Context, key string, values ...any) *redis.IntCmd
- func (c *CacheCollector) Ping(ctx context.Context) *redis.StatusCmd
- func (c *CacheCollector) PoolStats() *redis.PoolStats
- func (c *CacheCollector) Set(ctx context.Context, key string, value any, expiration time.Duration) *redis.StatusCmd
- type RedisDataCollector
- func (c *RedisDataCollector) Close() error
- func (c *RedisDataCollector) DBConnections(count int)
- func (c *RedisDataCollector) DBQuery(duration time.Duration, err error)
- func (c *RedisDataCollector) DBTransaction(err error)
- func (c *RedisDataCollector) GetStats() map[string]any
- func (c *RedisDataCollector) HealthCheck(component string, healthy bool)
- func (c *RedisDataCollector) MQConsume(system string, err error)
- func (c *RedisDataCollector) MQPublish(system string, err error)
- func (c *RedisDataCollector) MongoOperation(operation string, err error)
- func (c *RedisDataCollector) RedisCommand(command string, err error)
- func (c *RedisDataCollector) RedisConnections(count int)
- func (c *RedisDataCollector) SearchIndex(engine, operation string)
- func (c *RedisDataCollector) SearchQuery(engine string, err error)
- type RedisStorage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CacheCollector ¶
type CacheCollector struct {
// contains filtered or unexported fields
}
func NewCacheCollector ¶
func NewCacheCollector(client *redis.Client, collector metrics.CacheMetricsCollector) *CacheCollector
func (*CacheCollector) GetClient ¶
func (c *CacheCollector) GetClient() *redis.Client
func (*CacheCollector) PoolStats ¶
func (c *CacheCollector) PoolStats() *redis.PoolStats
type RedisDataCollector ¶
type RedisDataCollector struct {
// contains filtered or unexported fields
}
func (*RedisDataCollector) Close ¶
func (c *RedisDataCollector) Close() error
func (*RedisDataCollector) DBConnections ¶
func (c *RedisDataCollector) DBConnections(count int)
func (*RedisDataCollector) DBQuery ¶
func (c *RedisDataCollector) DBQuery(duration time.Duration, err error)
func (*RedisDataCollector) DBTransaction ¶
func (c *RedisDataCollector) DBTransaction(err error)
func (*RedisDataCollector) GetStats ¶
func (c *RedisDataCollector) GetStats() map[string]any
func (*RedisDataCollector) HealthCheck ¶
func (c *RedisDataCollector) HealthCheck(component string, healthy bool)
func (*RedisDataCollector) MQConsume ¶
func (c *RedisDataCollector) MQConsume(system string, err error)
func (*RedisDataCollector) MQPublish ¶
func (c *RedisDataCollector) MQPublish(system string, err error)
func (*RedisDataCollector) MongoOperation ¶
func (c *RedisDataCollector) MongoOperation(operation string, err error)
func (*RedisDataCollector) RedisCommand ¶
func (c *RedisDataCollector) RedisCommand(command string, err error)
func (*RedisDataCollector) RedisConnections ¶
func (c *RedisDataCollector) RedisConnections(count int)
func (*RedisDataCollector) SearchIndex ¶
func (c *RedisDataCollector) SearchIndex(engine, operation string)
func (*RedisDataCollector) SearchQuery ¶
func (c *RedisDataCollector) SearchQuery(engine string, err error)
type RedisStorage ¶
type RedisStorage struct {
// contains filtered or unexported fields
}
func NewRedisStorage ¶
func (*RedisStorage) Close ¶
func (r *RedisStorage) Close() error
func (*RedisStorage) Query ¶
func (r *RedisStorage) Query(query metrics.QueryRequest) ([]metrics.Metric, error)
Source Files
Click to show internal directories.
Click to hide internal directories.