redis

Documentation

Index

• type KVRedisService
  • func GetKVRedisDriver(ctx context.Context, cfg *models.Config) (*KVRedisService, error)
  • func (r *KVRedisService) AddToSets(ctx context.Context, key string, value string) error
  • func (r *KVRedisService) AddToSortedSets(ctx context.Context, setName string, key string, exp time.Duration) error
  • func (r *KVRedisService) CheckKeyHashMap(ctx context.Context, hash, key string) bool
  • func (r *KVRedisService) CheckRedisKey(ctx context.Context, keys ...string) (bool, error)
  • func (r *KVRedisService) DelValue(ctx context.Context, key string) error
  • func (r *KVRedisService) GetFromHashMap(ctx context.Context, hash, key string) (string, error)
  • func (r *KVRedisService) GetFromSortedSets(ctx context.Context, setName string, key string) (float64, error)
  • func (r *KVRedisService) GetJSONObject(ctx context.Context, key string) (interface{}, error)
  • func (r *KVRedisService) GetStoreDomains(ctx context.Context, sets string, member string) (bool, error)
  • func (r *KVRedisService) GetValue(ctx context.Context, key string) (string, error)
  • func (r *KVRedisService) Publish(ctx context.Context, chanel string, data interface{}) error
  • func (r *KVRedisService) RemoveSets(ctx context.Context, key string, value string) error
  • func (r *KVRedisService) SetJSONObject(ctx context.Context, key string, value interface{}, expiration time.Duration) error
  • func (r *KVRedisService) SetToHashMap(ctx context.Context, hash, key string, value string) error
  • func (r *KVRedisService) SetValue(ctx context.Context, key string, value string, expiration time.Duration) error
  • func (r *KVRedisService) Subscribe(ctx context.Context, chanel string) *redis.PubSub

Types

type KVRedisService

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

func GetKVRedisDriver

func GetKVRedisDriver(ctx context.Context, cfg *models.Config) (*KVRedisService, error)

func (*KVRedisService) AddToSets

func (r *KVRedisService) AddToSets(ctx context.Context, key string, value string) error

func (*KVRedisService) AddToSortedSets

func (r *KVRedisService) AddToSortedSets(ctx context.Context, setName string, key string, exp time.Duration) error

func (*KVRedisService) CheckKeyHashMap

func (r *KVRedisService) CheckKeyHashMap(ctx context.Context, hash, key string) bool

func (*KVRedisService) CheckRedisKey

func (r *KVRedisService) CheckRedisKey(ctx context.Context, keys ...string) (bool, error)

func (*KVRedisService) DelValue

func (r *KVRedisService) DelValue(ctx context.Context, key string) error

func (*KVRedisService) GetFromHashMap

func (r *KVRedisService) GetFromHashMap(ctx context.Context, hash, key string) (string, error)

func (*KVRedisService) GetFromSortedSets

func (r *KVRedisService) GetFromSortedSets(ctx context.Context, setName string, key string) (float64, error)

func (*KVRedisService) GetJSONObject

func (r *KVRedisService) GetJSONObject(ctx context.Context, key string) (interface{}, error)

func (*KVRedisService) GetStoreDomains

func (r *KVRedisService) GetStoreDomains(ctx context.Context, sets string, member string) (bool, error)

func (*KVRedisService) GetValue

func (r *KVRedisService) GetValue(ctx context.Context, key string) (string, error)

func (*KVRedisService) Publish

func (r *KVRedisService) Publish(ctx context.Context, chanel string, data interface{}) error

func (*KVRedisService) RemoveSets

func (r *KVRedisService) RemoveSets(ctx context.Context, key string, value string) error

func (*KVRedisService) SetJSONObject

func (r *KVRedisService) SetJSONObject(ctx context.Context, key string, value interface{}, expiration time.Duration) error

func (*KVRedisService) SetToHashMap

func (r *KVRedisService) SetToHashMap(ctx context.Context, hash, key string, value string) error

func (*KVRedisService) SetValue

func (r *KVRedisService) SetValue(ctx context.Context, key string, value string, expiration time.Duration) error

func (*KVRedisService) Subscribe

func (r *KVRedisService) Subscribe(ctx context.Context, chanel string) *redis.PubSub