redis

Documentation

Index

• Constants
• Variables
• func ErrSpanLost(format string, a ...interface{}) error
• func IsErrSpanLost(err error) bool
• func IsNil(err error) bool
• func IsRedisNil(err error) bool
• func NewRedisTracingHook() *tracingHook
• func NewSpanContext(ctx context.Context, s trace.Span) context.Context
• func RedisNil(err redis.Error) error
• func SpanFromContext(ctx context.Context) (s trace.Span, ok bool)
• type Client
  • func New(c *Conf) *Client
• type Conf
  • func (*Conf) Descriptor() ([]byte, []int)
  • func (x *Conf) GetAddr() string
  • func (x *Conf) GetDb() int32
  • func (x *Conf) GetDialTimeout() *durationpb.Duration
  • func (x *Conf) GetExpireTimeout() *durationpb.Duration
  • func (x *Conf) GetNetwork() string
  • func (x *Conf) GetPassword() string
  • func (x *Conf) GetReadTimeout() *durationpb.Duration
  • func (x *Conf) GetUsername() string
  • func (x *Conf) GetWriteTimeout() *durationpb.Duration
  • func (*Conf) ProtoMessage()
  • func (x *Conf) ProtoReflect() protoreflect.Message
  • func (x *Conf) Reset()
  • func (x *Conf) String() string
  • func (m *Conf) Validate() error
• type ConfValidationError
  • func (e ConfValidationError) Cause() error
  • func (e ConfValidationError) Error() string
  • func (e ConfValidationError) ErrorName() string
  • func (e ConfValidationError) Field() string
  • func (e ConfValidationError) Key() bool
  • func (e ConfValidationError) Reason() string
• type Pipeliner
• type RedisTextMapCarrier
  • func (carrier *RedisTextMapCarrier) Get(key string) string
  • func (carrier *RedisTextMapCarrier) Keys() []string
  • func (carrier *RedisTextMapCarrier) Set(key string, value string)
• type Script
  • func NewScript(src string) *Script
• type StringStringMapCmd
• type Z
• type ZAddArgs
• type ZRangeBy

Constants

const KeepTTL = redis.KeepTTL

Variables

var File_client_redis_conf_proto protoreflect.FileDescriptor

Functions

func ErrSpanLost

func ErrSpanLost(format string, a ...interface{}) error

func IsErrSpanLost

func IsErrSpanLost(err error) bool

func IsNil

func IsNil(err error) bool

func IsRedisNil

func IsRedisNil(err error) bool

func NewRedisTracingHook

func NewRedisTracingHook() *tracingHook

func NewSpanContext

func NewSpanContext(ctx context.Context, s trace.Span) context.Context

func RedisNil

func RedisNil(err redis.Error) error

RedisNil 没有值

func SpanFromContext

func SpanFromContext(ctx context.Context) (s trace.Span, ok bool)

SpanFromContext returns the Transport value stored in ctx, if any.

Types

type Client

type Client struct {
	redis.Client
	// contains filtered or unexported fields
}

func New

func New(c *Conf) *Client

type Conf

type Conf struct {
	Network       string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	Addr          string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	ReadTimeout   *durationpb.Duration `protobuf:"bytes,3,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`
	WriteTimeout  *durationpb.Duration `protobuf:"bytes,4,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"`
	DialTimeout   *durationpb.Duration `protobuf:"bytes,5,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"`
	ExpireTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=expire_timeout,json=expireTimeout,proto3" json:"expire_timeout,omitempty"`
	Username      string               `protobuf:"bytes,7,opt,name=username,proto3" json:"username,omitempty"`
	Password      string               `protobuf:"bytes,8,opt,name=password,proto3" json:"password,omitempty"`
	Db            int32                `protobuf:"varint,9,opt,name=db,proto3" json:"db,omitempty"`
	// contains filtered or unexported fields
}

func (*Conf) Descriptor

func (*Conf) Descriptor() ([]byte, []int)

Deprecated: Use Conf.ProtoReflect.Descriptor instead.

func (*Conf) GetAddr

func (x *Conf) GetAddr() string

func (*Conf) GetDb

func (x *Conf) GetDb() int32

func (*Conf) GetDialTimeout

func (x *Conf) GetDialTimeout() *durationpb.Duration

func (*Conf) GetExpireTimeout

func (x *Conf) GetExpireTimeout() *durationpb.Duration

func (*Conf) GetNetwork

func (x *Conf) GetNetwork() string

func (*Conf) GetPassword

func (x *Conf) GetPassword() string

func (*Conf) GetReadTimeout

func (x *Conf) GetReadTimeout() *durationpb.Duration

func (*Conf) GetUsername

func (x *Conf) GetUsername() string

func (*Conf) GetWriteTimeout

func (x *Conf) GetWriteTimeout() *durationpb.Duration

func (*Conf) ProtoMessage

func (*Conf) ProtoMessage()

func (*Conf) ProtoReflect

func (x *Conf) ProtoReflect() protoreflect.Message

func (*Conf) Reset

func (x *Conf) Reset()

func (*Conf) String

func (x *Conf) String() string

func (*Conf) Validate

func (m *Conf) Validate() error

Validate checks the field values on Conf with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type ConfValidationError

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

ConfValidationError is the validation error returned by Conf.Validate if the designated constraints aren't met.

func (ConfValidationError) Cause

func (e ConfValidationError) Cause() error

Cause function returns cause value.

func (ConfValidationError) Error

func (e ConfValidationError) Error() string

Error satisfies the builtin error interface

func (ConfValidationError) ErrorName

func (e ConfValidationError) ErrorName() string

ErrorName returns error name.

func (ConfValidationError) Field

func (e ConfValidationError) Field() string

Field function returns field value.

func (ConfValidationError) Key

func (e ConfValidationError) Key() bool

Key function returns key value.

func (ConfValidationError) Reason

func (e ConfValidationError) Reason() string

Reason function returns reason value.

type Pipeliner

type Pipeliner = redis.Pipeliner

type RedisTextMapCarrier

type RedisTextMapCarrier struct {
}

func (*RedisTextMapCarrier) Get

func (carrier *RedisTextMapCarrier) Get(key string) string

Get returns the value associated with the passed key.

func (*RedisTextMapCarrier) Keys

func (carrier *RedisTextMapCarrier) Keys() []string

Keys lists the keys stored in this carrier.

func (*RedisTextMapCarrier) Set

func (carrier *RedisTextMapCarrier) Set(key string, value string)

Set stores the key-value pair.

type Script

type Script = redis.Script

func NewScript

func NewScript(src string) *Script

type StringStringMapCmd

type StringStringMapCmd = redis.StringStringMapCmd

type Z

type Z = redis.Z

type ZAddArgs

type ZAddArgs = redis.ZAddArgs

type ZRangeBy

type ZRangeBy = redis.ZRangeBy