redis

Documentation

Index

• Constants
• Variables
• func Client() redis.UniversalClient
• type Metric
  • func (m *Metric) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (m *Metric) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (m *Metric) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (m *Metric) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)
• type OptionFunc
• type Options
• type Redis
  • func New(optionFunc ...OptionFunc) *Redis
  • func (r *Redis) Client() redis.UniversalClient
  • func (r *Redis) Name() string
  • func (r *Redis) Serve(ctx context.Context) error
  • func (r *Redis) Shutdown(ctx context.Context) error

Constants

const (
	Nil         = redis.Nil
	TxFailedErr = redis.TxFailedErr
)

Variables

var (
	Default   = New()
	ErrClosed = redis.ErrClosed
)

Functions

func Client

func Client() redis.UniversalClient

Types

type Metric

type Metric struct {
	// contains filtered or unexported fields
}

func (*Metric) AfterProcess

func (m *Metric) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*Metric) AfterProcessPipeline

func (m *Metric) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*Metric) BeforeProcess

func (m *Metric) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (*Metric) BeforeProcessPipeline

func (m *Metric) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

type OptionFunc

type OptionFunc func(*Options)

type Options

type Options struct {
	// contains filtered or unexported fields
}

type Redis

type Redis struct {
	dummybox.DummyBox
	// contains filtered or unexported fields
}

func New

func New(optionFunc ...OptionFunc) *Redis

func (*Redis) Client

func (r *Redis) Client() redis.UniversalClient

func (*Redis) Name

func (r *Redis) Name() string

func (*Redis) Serve

func (r *Redis) Serve(ctx context.Context) error

func (*Redis) Shutdown

func (r *Redis) Shutdown(ctx context.Context) error