Documentation ¶
Index ¶
- func NewRedisRecorder(appName string, config Config) metrics.RedisRecorder
- type CollectHook
- func (h *CollectHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
- func (h *CollectHook) AfterProcessPipeline(_ context.Context, _ []redis.Cmder) error
- func (h *CollectHook) BeforeProcess(ctx context.Context, _ redis.Cmder) (context.Context, error)
- func (h *CollectHook) BeforeProcessPipeline(ctx context.Context, _ []redis.Cmder) (context.Context, error)
- func (r CollectHook) Collect(props metrics.RedisReqProperties, duration time.Duration)
- func (r CollectHook) NewCollectHook() redis.Hook
- func (r CollectHook) Unregister()
- type Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRedisRecorder ¶
func NewRedisRecorder(appName string, config Config) metrics.RedisRecorder
Types ¶
type CollectHook ¶
type CollectHook struct {
// contains filtered or unexported fields
}
CollectHook is an implementation of redis.Hook interface
func (*CollectHook) AfterProcess ¶
func (h *CollectHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
func (*CollectHook) AfterProcessPipeline ¶
func (h *CollectHook) AfterProcessPipeline(_ context.Context, _ []redis.Cmder) error
func (*CollectHook) BeforeProcess ¶
func (*CollectHook) BeforeProcessPipeline ¶
func (CollectHook) Collect ¶
func (r CollectHook) Collect(props metrics.RedisReqProperties, duration time.Duration)
Collect updates metrics using passed properties
func (CollectHook) NewCollectHook ¶
func (r CollectHook) NewCollectHook() redis.Hook
Click to show internal directories.
Click to hide internal directories.