pipeliner

Documentation

Index

• type Adapter
  • func NewAdapter(pipeliner redis.Pipeliner) *Adapter
  • func (a *Adapter) Exec(ctx context.Context) ([]redis.Cmder, error)
  • func (a *Adapter) Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
  • func (a *Adapter) ZAdd(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd
  • func (a *Adapter) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd
  • func (a *Adapter) ZRemRangeByScore(ctx context.Context, key string, min, max string) *redis.IntCmd

Types

type Adapter

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

func NewAdapter

func NewAdapter(pipeliner redis.Pipeliner) *Adapter

func (*Adapter) Exec

func (a *Adapter) Exec(ctx context.Context) ([]redis.Cmder, error)

Exec executes all previously queued commands in a transaction and restores the connection state to normal.

func (*Adapter) Expire

func (a *Adapter) Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd

Expire sets a timeout on key. After the timeout has expired, the key will automatically be deleted.

func (*Adapter) ZAdd

func (a *Adapter) ZAdd(ctx context.Context, key string, members ...redis.Z) *redis.IntCmd

ZAdd adds all the specified members with the specified scores to the sorted set stored at key.

func (*Adapter) ZRange

func (a *Adapter) ZRange(ctx context.Context, key string, start, stop int64) *redis.StringSliceCmd

ZRange returns the specified range of elements in the sorted set stored at key.

func (*Adapter) ZRemRangeByScore

func (a *Adapter) ZRemRangeByScore(ctx context.Context, key string, min, max string) *redis.IntCmd

ZRemRangeByScore removes all elements in the sorted set stored at key with a score between min and max (inclusive).