commRedisList

Documentation

Index

• type RedisListService
  • func (e *RedisListService) BPop(key string, timeout time.Duration) (string, error)
  • func (e *RedisListService) GetRange(key string) (string, error)
  • func (e *RedisListService) IsBlock(key string) (bool, error)
  • func (e *RedisListService) IsBusy(key string, percentage int64) (bool, error)
  • func (e *RedisListService) KBPop(key string, timeout time.Duration) (string, error)
  • func (e *RedisListService) KPush(key string, value string) error
  • func (e *RedisListService) Pop(key string) (string, error)
  • func (e *RedisListService) Push(key string, value string) error
  • func (e *RedisListService) Size(key string) (int64, error)
• type RedisValueService
  • func (e *RedisValueService) GetValue(mainKey string, timeout time.Duration) (string, error)
  • func (e *RedisValueService) PHGet(prefixKey string, hashKey string, timeout time.Duration) (string, error)
  • func (e *RedisValueService) PHSet(prefixKey string, hashKey string, value interface{}) error

Types

type RedisListService

type RedisListService struct {
	MaxSize int64 // 最大数量
}

func (*RedisListService) BPop

func (e *RedisListService) BPop(key string, timeout time.Duration) (string, error)

func (*RedisListService) GetRange

func (e *RedisListService) GetRange(key string) (string, error)

func (*RedisListService) IsBlock

func (e *RedisListService) IsBlock(key string) (bool, error)

func (*RedisListService) IsBusy

func (e *RedisListService) IsBusy(key string, percentage int64) (bool, error)

func (*RedisListService) KBPop

func (e *RedisListService) KBPop(key string, timeout time.Duration) (string, error)

func (*RedisListService) KPush

func (e *RedisListService) KPush(key string, value string) error

func (*RedisListService) Pop

func (e *RedisListService) Pop(key string) (string, error)

func (*RedisListService) Push

func (e *RedisListService) Push(key string, value string) error

func (*RedisListService) Size

func (e *RedisListService) Size(key string) (int64, error)

type RedisValueService

type RedisValueService struct {
	Timeout int64
	// contains filtered or unexported fields
}

func (*RedisValueService) GetValue

func (e *RedisValueService) GetValue(mainKey string, timeout time.Duration) (string, error)

func (*RedisValueService) PHGet

func (e *RedisValueService) PHGet(prefixKey string, hashKey string, timeout time.Duration) (string, error)

func (*RedisValueService) PHSet

func (e *RedisValueService) PHSet(prefixKey string, hashKey string, value interface{}) error