cache

type CacheEntry struct {
	Version int64  `json:"vrs"`
	Data    []byte `json:"data"`
}

type CacheUpdateMessage struct {
	Key     string `json:"key"`
	Action  string `json:"act"`
	Data    []byte `json:"data,omitempty"`
	Version int64  `json:"vrs"`
}

type DistributedCache struct {
	*redis.ClusterClient
}

type LocalCache struct {
	*bigcache.BigCache
	// contains filtered or unexported fields
}

type MultiCache struct {
	EnableTracing bool
	//该Expire只能为distributedCache设置,localCache的超时一旦设置之后无法改变
	ExpireTime time.Duration
	//redlock    *redlock.RedLock
	//使用版本控制将带来更高的一致性,但是需要Set系列的函数传入的data是可以得到version字段的
	UseVersionControll bool
	RocketmqConsumer   rocketmq.PushConsumer
	//这个mtx只是保证本地缓存更新时是一致的,防止老版本更新慢于新版本更新
	Mtx *sync.RWMutex

	Logger *otelzap.SugaredLogger
	// contains filtered or unexported fields
}

type OptionFunc func(*MultiCache)