storage

Documentation

Index

• type Redis
  • func NewRedis(ctx context.Context, conf *utils.Config) (*Redis, error)
  • func (r *Redis) BatchDelTentacle(ctx context.Context, infoList map[uint32]*pb.TentacleInfo) (map[uint32]bool, error)
  • func (r *Redis) BatchGetTentacle(ctx context.Context, idList []uint32) (map[uint32]map[string]string, error)
  • func (r *Redis) BatchPeekTentacle(ctx context.Context, idList []uint32) (map[uint32]bool, error)
  • func (r *Redis) BatchSetTentacle(ctx context.Context, infoList map[uint32]*pb.TentacleInfo) (map[uint32]bool, error)
  • func (r *Redis) Close(ctx context.Context) error
  • func (r *Redis) DelTentacle(ctx context.Context, id uint32, infoList []*pb.Tentacle) (bool, error)
  • func (r *Redis) GetTentacle(ctx context.Context, id uint32) (map[string]string, error)
  • func (r *Redis) GetTentacleHistory(ctx context.Context, id uint32, from, to time.Time) ([]string, error)
  • func (r *Redis) PeekTentacle(ctx context.Context, id uint32) (bool, error)
  • func (r *Redis) SetTentacle(ctx context.Context, id uint32, infoList []*pb.Tentacle) (bool, error)
  • func (r *Redis) SetTentacleHistory(ctx context.Context, id uint32, record string, ts time.Time) error

Types

type Redis

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

func NewRedis

func NewRedis(ctx context.Context, conf *utils.Config) (*Redis, error)

func (*Redis) BatchDelTentacle

func (r *Redis) BatchDelTentacle(ctx context.Context, infoList map[uint32]*pb.TentacleInfo) (map[uint32]bool, error)

func (*Redis) BatchGetTentacle

func (r *Redis) BatchGetTentacle(ctx context.Context, idList []uint32) (map[uint32]map[string]string, error)

func (*Redis) BatchPeekTentacle

func (r *Redis) BatchPeekTentacle(ctx context.Context, idList []uint32) (map[uint32]bool, error)

func (*Redis) BatchSetTentacle

func (r *Redis) BatchSetTentacle(ctx context.Context, infoList map[uint32]*pb.TentacleInfo) (map[uint32]bool, error)

func (*Redis) Close

func (r *Redis) Close(ctx context.Context) error

func (*Redis) DelTentacle

func (r *Redis) DelTentacle(ctx context.Context, id uint32, infoList []*pb.Tentacle) (bool, error)

func (*Redis) GetTentacle

func (r *Redis) GetTentacle(ctx context.Context, id uint32) (map[string]string, error)

func (*Redis) GetTentacleHistory

func (r *Redis) GetTentacleHistory(ctx context.Context, id uint32, from, to time.Time) ([]string, error)

func (*Redis) PeekTentacle

func (r *Redis) PeekTentacle(ctx context.Context, id uint32) (bool, error)

func (*Redis) SetTentacle

func (r *Redis) SetTentacle(ctx context.Context, id uint32, infoList []*pb.Tentacle) (bool, error)

func (*Redis) SetTentacleHistory

func (r *Redis) SetTentacleHistory(ctx context.Context, id uint32, record string, ts time.Time) error