weloe / token-go-extensions Goto Github PK

2024/06/18 16:53:35 Adapter.Get() failed: unable to convert string to []byte

func (r *RedisAdapter) Get(key string, t ...reflect.Type) interface{} {
	value, err := r.client.Get(context.Background(), key).Result()
	if err != nil {
		return nil
	}
        ...
        // ！！问题点：这里不太对，上面 go-redis v8 响应的就是一个 string 类型，这么再一次 util.InterfaceToBytes 转换就会出现异常
	bytes, err := util.InterfaceToBytes(value)
	if err != nil {
		log.Printf("Adapter.Get() failed: %v", err)
		return nil
	}
	instance := reflect.New(t[0].Elem()).Interface()
	err = r.serializer.UnSerialize(bytes, instance)
	...
}

func InterfaceToBytes(data interface{}) ([]byte, error) {
	if b, ok := data.([]byte); ok {
		return b, nil
	}
	return nil, fmt.Errorf("unable to convert %T to []byte", data)
}

func (r *ClusterAdapter) GetCountsFilteredKey(filterKeyPrefix string) (int, error) {
	keys, err := r.client.Keys(context.Background(), filterKeyPrefix).Result()
	if err != nil {
		return 0, err
	}
	return len(keys), nil
}

func (r *RingAdapter) GetCountsFilteredKey(filterKeyPrefix string) (int, error) {
	keys, err := r.client.Keys(context.Background(), filterKeyPrefix).Result()
	if err != nil {
		return 0, err
	}
	return len(keys), nil
}

func (r *SentinelAdapter) GetCountsFilteredKey(filterKeyPrefix string) (int, error) {
	keys, err := r.client.Keys(context.Background(), filterKeyPrefix).Result()
	if err != nil {
		return 0, err
	}
	return len(keys), nil
}