mirror of
				https://github.com/go-gitea/gitea
				synced 2025-11-04 05:18:25 +00:00 
			
		
		
		
	* Update go-redis to v8.4.0 * github.com/go-redis/redis/v8 v8.4.0 -> v8.5.0 * Apply suggestions from code review Co-authored-by: zeripath <art27@cantab.net> * TODO * Use the Queue termination channel as the default context for pushes Signed-off-by: Andrew Thornton <art27@cantab.net> * missed one Signed-off-by: Andrew Thornton <art27@cantab.net> Co-authored-by: zeripath <art27@cantab.net>
		
			
				
	
	
		
			181 lines
		
	
	
		
			4.8 KiB
		
	
	
	
		
			Go
		
	
	
	
		
			Vendored
		
	
	
	
			
		
		
	
	
			181 lines
		
	
	
		
			4.8 KiB
		
	
	
	
		
			Go
		
	
	
	
		
			Vendored
		
	
	
	
package redis
 | 
						|
 | 
						|
import "time"
 | 
						|
 | 
						|
// NewCmdResult returns a Cmd initialised with val and err for testing.
 | 
						|
func NewCmdResult(val interface{}, err error) *Cmd {
 | 
						|
	var cmd Cmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewSliceResult returns a SliceCmd initialised with val and err for testing.
 | 
						|
func NewSliceResult(val []interface{}, err error) *SliceCmd {
 | 
						|
	var cmd SliceCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewStatusResult returns a StatusCmd initialised with val and err for testing.
 | 
						|
func NewStatusResult(val string, err error) *StatusCmd {
 | 
						|
	var cmd StatusCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewIntResult returns an IntCmd initialised with val and err for testing.
 | 
						|
func NewIntResult(val int64, err error) *IntCmd {
 | 
						|
	var cmd IntCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewDurationResult returns a DurationCmd initialised with val and err for testing.
 | 
						|
func NewDurationResult(val time.Duration, err error) *DurationCmd {
 | 
						|
	var cmd DurationCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewBoolResult returns a BoolCmd initialised with val and err for testing.
 | 
						|
func NewBoolResult(val bool, err error) *BoolCmd {
 | 
						|
	var cmd BoolCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewStringResult returns a StringCmd initialised with val and err for testing.
 | 
						|
func NewStringResult(val string, err error) *StringCmd {
 | 
						|
	var cmd StringCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewFloatResult returns a FloatCmd initialised with val and err for testing.
 | 
						|
func NewFloatResult(val float64, err error) *FloatCmd {
 | 
						|
	var cmd FloatCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewStringSliceResult returns a StringSliceCmd initialised with val and err for testing.
 | 
						|
func NewStringSliceResult(val []string, err error) *StringSliceCmd {
 | 
						|
	var cmd StringSliceCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewBoolSliceResult returns a BoolSliceCmd initialised with val and err for testing.
 | 
						|
func NewBoolSliceResult(val []bool, err error) *BoolSliceCmd {
 | 
						|
	var cmd BoolSliceCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewStringStringMapResult returns a StringStringMapCmd initialised with val and err for testing.
 | 
						|
func NewStringStringMapResult(val map[string]string, err error) *StringStringMapCmd {
 | 
						|
	var cmd StringStringMapCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewStringIntMapCmdResult returns a StringIntMapCmd initialised with val and err for testing.
 | 
						|
func NewStringIntMapCmdResult(val map[string]int64, err error) *StringIntMapCmd {
 | 
						|
	var cmd StringIntMapCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewTimeCmdResult returns a TimeCmd initialised with val and err for testing.
 | 
						|
func NewTimeCmdResult(val time.Time, err error) *TimeCmd {
 | 
						|
	var cmd TimeCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewZSliceCmdResult returns a ZSliceCmd initialised with val and err for testing.
 | 
						|
func NewZSliceCmdResult(val []Z, err error) *ZSliceCmd {
 | 
						|
	var cmd ZSliceCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewZWithKeyCmdResult returns a NewZWithKeyCmd initialised with val and err for testing.
 | 
						|
func NewZWithKeyCmdResult(val *ZWithKey, err error) *ZWithKeyCmd {
 | 
						|
	var cmd ZWithKeyCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewScanCmdResult returns a ScanCmd initialised with val and err for testing.
 | 
						|
func NewScanCmdResult(keys []string, cursor uint64, err error) *ScanCmd {
 | 
						|
	var cmd ScanCmd
 | 
						|
	cmd.page = keys
 | 
						|
	cmd.cursor = cursor
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewClusterSlotsCmdResult returns a ClusterSlotsCmd initialised with val and err for testing.
 | 
						|
func NewClusterSlotsCmdResult(val []ClusterSlot, err error) *ClusterSlotsCmd {
 | 
						|
	var cmd ClusterSlotsCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewGeoLocationCmdResult returns a GeoLocationCmd initialised with val and err for testing.
 | 
						|
func NewGeoLocationCmdResult(val []GeoLocation, err error) *GeoLocationCmd {
 | 
						|
	var cmd GeoLocationCmd
 | 
						|
	cmd.locations = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewGeoPosCmdResult returns a GeoPosCmd initialised with val and err for testing.
 | 
						|
func NewGeoPosCmdResult(val []*GeoPos, err error) *GeoPosCmd {
 | 
						|
	var cmd GeoPosCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewCommandsInfoCmdResult returns a CommandsInfoCmd initialised with val and err for testing.
 | 
						|
func NewCommandsInfoCmdResult(val map[string]*CommandInfo, err error) *CommandsInfoCmd {
 | 
						|
	var cmd CommandsInfoCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewXMessageSliceCmdResult returns a XMessageSliceCmd initialised with val and err for testing.
 | 
						|
func NewXMessageSliceCmdResult(val []XMessage, err error) *XMessageSliceCmd {
 | 
						|
	var cmd XMessageSliceCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 | 
						|
 | 
						|
// NewXStreamSliceCmdResult returns a XStreamSliceCmd initialised with val and err for testing.
 | 
						|
func NewXStreamSliceCmdResult(val []XStream, err error) *XStreamSliceCmd {
 | 
						|
	var cmd XStreamSliceCmd
 | 
						|
	cmd.val = val
 | 
						|
	cmd.SetErr(err)
 | 
						|
	return &cmd
 | 
						|
}
 |