db

type DBer interface {

	// Cmd is a function which will perform the given cmd/args in redis and
	// returns the resp. It automatically handles using redis cluster, if that
	// is enabled
	Cmd(string, ...interface{}) *redis.Resp

	// Pipe runs a set of commands (given by p) one after the other. It is *not*
	// guaranteed that all the commands will be run on the same client. If any
	// commands return an error the pipeline will stop and return that error.
	// Otherwise the Resp from each command is returned in a slice
	//
	//	r, err := db.Pipe(
	//		db.PP("SET", "foo", "bar"),
	//		db.PP("GET", "foo"),
	//	)
	Pipe(...*PipePart) ([]*redis.Resp, error)

	// Scan is a function which returns a channel to which keys matching the
	// given pattern are written to. The channel must be read from until it is
	// closed, which occurs when there are no more keys or when an error has
	// occurred (this error will be logged)
	//
	// This should not be used in any critical paths
	Scan(string) <-chan string

	// Lua performs one of the preloaded Lua scripts that have been built-in.
	// It's *possible* that the script wasn't loaded in initLuaScripts() for
	// some strange reason, this tries to handle that case as well. The integer
	// passed in is the number of keys the command takes in
	//
	// Example:
	//
	//	db.Lua(redisClient, "LREMRPUSH", 2, "foo", "bar", -1, "value")
	Lua(string, int, ...interface{}) *redis.Resp

	// GetAddr returns any valid address of a redis instance. Useful for cases
	// where we want to create redis connections external to this db package
	GetAddr() (string, error)
}

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