redis

Mar 27, 2024

Changes in this version

type Client

+ func (r Client) MarshalJSONPB(_ *jsonpb.Marshaler) ([]byte, error)

Jan 8, 2024

Changes in this version

type Options

+ TLSConfig tls.TLSOptions

Jan 3, 2024

Changes in this version

type Options

+ URL string

Dec 12, 2023

Changes in this version

+ type Options struct

+ DB *int

+ DialTimeout *model.Duration

+ IdleCheckFrequency *time.Duration

+ IdleTimeout *time.Duration

+ MaxConnAge *time.Duration

+ MaxRetries *int

+ MaxRetryBackoff *model.Duration

+ MinIdleConns *int

+ MinRetryBackoff *model.Duration

+ Password safe.String

+ PoolSize *int

+ PoolTimeout *time.Duration

+ ReadTimeout *model.Duration

+ Url string

+ WriteTimeout *model.Duration

+ func (o *Options) GetPeer() (string, int)

+ func (o *Options) UnmarshalJSON(data []byte) (err error)

Nov 27, 2023

Changes in this version

+ var ErrStopLoop = errors.New("stop")

+ func ForeachSet(ctx context.Context, c *redis.Client, key string, cursor uint64, ...) (err error)

+ func NewRedisClient(ctx context.Context, option *RedisOptions) (*redis.Client, error)

+ type Client struct

+ func (r *Client) Merge(src proto.Message)

+ func (r *Client) ProtoMessage()

+ func (r *Client) Redis(ctx context.Context) *redis.Client

+ func (r *Client) Reset()

+ func (r *Client) Unmarshal(data []byte) (err error)

+ func (r *Client) UnmarshalJSON(data []byte) (err error)

+ func (r Client) Marshal() ([]byte, error)

+ func (r Client) MarshalJSON() ([]byte, error)

+ func (r Client) String() string

+ type Cmder struct

+ func (c Cmder) String() string

+ type RedisOptions struct

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RedisOptions) Descriptor() ([]byte, []int)

+ func (*RedisOptions) ProtoMessage()

+ func (m *RedisOptions) GetUrl() string

+ func (m *RedisOptions) Reset()

+ func (m *RedisOptions) String() string

+ func (m *RedisOptions) XXX_DiscardUnknown()

+ func (m *RedisOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisOptions) XXX_Merge(src proto.Message)

+ func (m *RedisOptions) XXX_Size() int

+ func (m *RedisOptions) XXX_Unmarshal(b []byte) error

+ func (o *RedisOptions) GetPeer() (string, int)

+ func (o *RedisOptions) UnmarshalJSON(data []byte) (err error)

+ type Session struct