kvcpiped

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

type VKOptions struct {
	WriteClient *redis.Client
	ReadClient  *redis.Client
	Addr        string
	Password    string
	DB          int
	PoolSize    int

	PipeSize      int
	FlushInterval time.Duration
	Workers       int
	QueueCapacity int

	EnqueueTimeout     time.Duration
	WaitAckTimeout     time.Duration
	ExecTimeout        time.Duration
	DirectWriteTimeout time.Duration

	Prefix string

	ResetUseFlushDB bool
	ResetScanCount  int
}