reader

type ClientOptions struct {
	DB int
	//InitVersion int64
	Plain  bool
	Global *GlobalOptions
}

type DeltaReceiver struct {
	DB           int
	DBtype       int
	StartVersion uint64
	//
	DrainVer <-chan VersionData // for final database replication
	//
	//
	NotifyVer chan<- string // for versionable database replication

	DrainString chan<- string // for non-versionless databases replication
	// contains filtered or unexported fields
}

type GlobalOptions struct {
	LocalVersion bool
	RedisURL     *string
}

type KHV struct {
	Key  string
	Hash uint64
	Size uint32
}

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

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

type ReadOperation func(int64, string, redis.Conn) (error, RedisKV)

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

type RedisKV = *sendrecv.Msg_SendValues

type RedisOperation func(redis.Conn) error

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

type RetriveOperation func(string, redis.Conn) error

type ServerOptions struct {
	DB    int
	Index int
	//InitVersion int64
	Plain  bool
	Global *GlobalOptions
}

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

type VersionData struct {
	Version     uint64
	DeltaFor    uint64
	VersionData []RedisKV
}