diff --git a/src/ServiceStack.Interfaces/Caching/ICacheClient.cs b/src/ServiceStack.Interfaces/Caching/ICacheClient.cs index 98b443576fe..2b038fb0b8b 100644 --- a/src/ServiceStack.Interfaces/Caching/ICacheClient.cs +++ b/src/ServiceStack.Interfaces/Caching/ICacheClient.cs @@ -3,112 +3,112 @@ namespace ServiceStack.Caching { - /// - /// A common interface implementation that is implemented by most cache providers - /// - public interface ICacheClient - : IDisposable - { - /// - /// Removes the specified item from the cache. - /// - /// The identifier for the item to delete. - /// - /// true if the item was successfully removed from the cache; false otherwise. - /// - bool Remove(string key); + /// + /// A common interface implementation that is implemented by most cache providers + /// + public interface ICacheClient + : IDisposable + { + /// + /// Removes the specified item from the cache. + /// + /// The identifier for the item to delete. + /// + /// true if the item was successfully removed from the cache; false otherwise. + /// + bool Remove(string key); - /// - /// Removes the cache for all the keys provided. - /// - /// The keys. - void RemoveAll(IEnumerable keys); + /// + /// Removes the cache for all the keys provided. + /// + /// The keys. + void RemoveAll(IEnumerable keys); - /// - /// Retrieves the specified item from the cache. - /// - /// - /// The identifier for the item to retrieve. - /// - /// The retrieved item, or null if the key was not found. - /// - T Get(string key); + /// + /// Retrieves the specified item from the cache. + /// + /// + /// The identifier for the item to retrieve. + /// + /// The retrieved item, or null if the key was not found. + /// + T Get(string key); - /// - /// Increments the value of the specified key by the given amount. - /// The operation is atomic and happens on the server. - /// A non existent value at key starts at 0 - /// - /// The identifier for the item to increment. - /// The amount by which the client wants to increase the item. - /// - /// The new value of the item or -1 if not found. - /// - /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. - long Increment(string key, uint amount); + /// + /// Increments the value of the specified key by the given amount. + /// The operation is atomic and happens on the server. + /// A non existent value at key starts at 0 + /// + /// The identifier for the item to increment. + /// The amount by which the client wants to increase the item. + /// + /// The new value of the item or -1 if not found. + /// + /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. + long Increment(string key, uint amount); - /// - /// Increments the value of the specified key by the given amount. - /// The operation is atomic and happens on the server. - /// A non existent value at key starts at 0 - /// - /// The identifier for the item to increment. - /// The amount by which the client wants to decrease the item. - /// - /// The new value of the item or -1 if not found. - /// - /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. - long Decrement(string key, uint amount); + /// + /// Increments the value of the specified key by the given amount. + /// The operation is atomic and happens on the server. + /// A non existent value at key starts at 0 + /// + /// The identifier for the item to increment. + /// The amount by which the client wants to decrease the item. + /// + /// The new value of the item or -1 if not found. + /// + /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. + long Decrement(string key, uint amount); - /// - /// Adds a new item into the cache at the specified cache key only if the cache is empty. - /// - /// The key used to reference the item. - /// The object to be inserted into the cache. - /// - /// true if the item was successfully stored in the cache; false otherwise. - /// - /// The item does not expire unless it is removed due memory pressure. - bool Add(string key, T value); + /// + /// Adds a new item into the cache at the specified cache key only if the cache is empty. + /// + /// The key used to reference the item. + /// The object to be inserted into the cache. + /// + /// true if the item was successfully stored in the cache; false otherwise. + /// + /// The item does not expire unless it is removed due memory pressure. + bool Add(string key, T value); - /// - /// Sets an item into the cache at the cache key specified regardless if it already exists or not. - /// - bool Set(string key, T value); + /// + /// Sets an item into the cache at the cache key specified regardless if it already exists or not. + /// + bool Set(string key, T value); - /// - /// Replaces the item at the cachekey specified only if an items exists at the location already. - /// - bool Replace(string key, T value); + /// + /// Replaces the item at the cachekey specified only if an items exists at the location already. + /// + bool Replace(string key, T value); - bool Add(string key, T value, DateTime expiresAt); - bool Set(string key, T value, DateTime expiresAt); - bool Replace(string key, T value, DateTime expiresAt); + bool Add(string key, T value, DateTime expiresAt); + bool Set(string key, T value, DateTime expiresAt); + bool Replace(string key, T value, DateTime expiresAt); - bool Add(string key, T value, TimeSpan expiresIn); - bool Set(string key, T value, TimeSpan expiresIn); - bool Replace(string key, T value, TimeSpan expiresIn); + bool Add(string key, T value, TimeSpan expiresIn); + bool Set(string key, T value, TimeSpan expiresIn); + bool Replace(string key, T value, TimeSpan expiresIn); - /// - /// Invalidates all data on the cache. - /// - void FlushAll(); + /// + /// Invalidates all data on the cache. + /// + void FlushAll(); - /// - /// Retrieves multiple items from the cache. - /// The default value of T is set for all keys that do not exist. - /// - /// The list of identifiers for the items to retrieve. - /// - /// a Dictionary holding all items indexed by their key. - /// - IDictionary GetAll(IEnumerable keys); + /// + /// Retrieves multiple items from the cache. + /// The default value of T is set for all keys that do not exist. + /// + /// The list of identifiers for the items to retrieve. + /// + /// a Dictionary holding all items indexed by their key. + /// + IDictionary GetAll(IEnumerable keys); - /// - /// Sets multiple items to the cache. - /// - /// - /// The values. - void SetAll(IDictionary values); - } + /// + /// Sets multiple items to the cache. + /// + /// + /// The values. + void SetAll(IDictionary values); + } } diff --git a/src/ServiceStack.Interfaces/Caching/IDeflateProvider.cs b/src/ServiceStack.Interfaces/Caching/IDeflateProvider.cs index cff6e25ab6b..2ce65ffe904 100644 --- a/src/ServiceStack.Interfaces/Caching/IDeflateProvider.cs +++ b/src/ServiceStack.Interfaces/Caching/IDeflateProvider.cs @@ -1,9 +1,9 @@ namespace ServiceStack.Caching { - public interface IDeflateProvider - { - byte[] Deflate(string text); - - string Inflate(byte[] gzBuffer); - } + public interface IDeflateProvider + { + byte[] Deflate(string text); + + string Inflate(byte[] gzBuffer); + } } diff --git a/src/ServiceStack.Interfaces/Caching/IGZipProvider.cs b/src/ServiceStack.Interfaces/Caching/IGZipProvider.cs index 5967465fbeb..97fc8f77d7e 100644 --- a/src/ServiceStack.Interfaces/Caching/IGZipProvider.cs +++ b/src/ServiceStack.Interfaces/Caching/IGZipProvider.cs @@ -1,9 +1,9 @@ namespace ServiceStack.Caching { - public interface IGZipProvider - { - byte[] GZip(string text); + public interface IGZipProvider + { + byte[] GZip(string text); - string GUnzip(byte[] gzBuffer); - } + string GUnzip(byte[] gzBuffer); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Caching/IMemcachedClient.cs b/src/ServiceStack.Interfaces/Caching/IMemcachedClient.cs index 735ddecaad7..0e58d2af85f 100644 --- a/src/ServiceStack.Interfaces/Caching/IMemcachedClient.cs +++ b/src/ServiceStack.Interfaces/Caching/IMemcachedClient.cs @@ -3,105 +3,105 @@ namespace ServiceStack.Caching { - /// - /// A light interface over a cache client. - /// This interface was inspired by Enyim.Caching.MemcachedClient - /// - /// Only the methods that are intended to be used are required, if you require - /// extra functionality you can uncomment the unused methods below as they have been - /// implemented in DdnMemcachedClient - /// - public interface IMemcachedClient : IDisposable - { - /// - /// Removes the specified item from the cache. - /// - /// The identifier for the item to delete. - /// - /// true if the item was successfully removed from the cache; false otherwise. - /// - bool Remove(string key); + /// + /// A light interface over a cache client. + /// This interface was inspired by Enyim.Caching.MemcachedClient + /// + /// Only the methods that are intended to be used are required, if you require + /// extra functionality you can uncomment the unused methods below as they have been + /// implemented in DdnMemcachedClient + /// + public interface IMemcachedClient : IDisposable + { + /// + /// Removes the specified item from the cache. + /// + /// The identifier for the item to delete. + /// + /// true if the item was successfully removed from the cache; false otherwise. + /// + bool Remove(string key); - /// - /// Removes the cache for all the keys provided. - /// - /// The keys. - void RemoveAll(IEnumerable keys); + /// + /// Removes the cache for all the keys provided. + /// + /// The keys. + void RemoveAll(IEnumerable keys); - /// - /// Retrieves the specified item from the cache. - /// - /// The identifier for the item to retrieve. - /// - /// The retrieved item, or null if the key was not found. - /// - object Get(string key); - object Get(string key, out ulong lastModifiedValue); + /// + /// Retrieves the specified item from the cache. + /// + /// The identifier for the item to retrieve. + /// + /// The retrieved item, or null if the key was not found. + /// + object Get(string key); + object Get(string key, out ulong lastModifiedValue); - /// - /// Increments the value of the specified key by the given amount. The operation is atomic and happens on the server. - /// - /// The identifier for the item to increment. - /// The amount by which the client wants to increase the item. - /// - /// The new value of the item or -1 if not found. - /// - /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. - long Increment(string key, uint amount); + /// + /// Increments the value of the specified key by the given amount. The operation is atomic and happens on the server. + /// + /// The identifier for the item to increment. + /// The amount by which the client wants to increase the item. + /// + /// The new value of the item or -1 if not found. + /// + /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. + long Increment(string key, uint amount); - /// - /// Increments the value of the specified key by the given amount. The operation is atomic and happens on the server. - /// - /// The identifier for the item to increment. - /// The amount by which the client wants to decrease the item. - /// - /// The new value of the item or -1 if not found. - /// - /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. - long Decrement(string key, uint amount); + /// + /// Increments the value of the specified key by the given amount. The operation is atomic and happens on the server. + /// + /// The identifier for the item to increment. + /// The amount by which the client wants to decrease the item. + /// + /// The new value of the item or -1 if not found. + /// + /// The item must be inserted into the cache before it can be changed. The item must be inserted as a . The operation only works with values, so -1 always indicates that the item was not found. + long Decrement(string key, uint amount); - /// - /// Inserts an item into the cache with a cache key to reference its location. - /// - /// The key used to reference the item. - /// The object to be inserted into the cache. - /// - /// true if the item was successfully stored in the cache; false otherwise. - /// - /// The item does not expire unless it is removed due memory pressure. - bool Add(string key, object value); - bool Set(string key, object value); - bool Replace(string key, object value); + /// + /// Inserts an item into the cache with a cache key to reference its location. + /// + /// The key used to reference the item. + /// The object to be inserted into the cache. + /// + /// true if the item was successfully stored in the cache; false otherwise. + /// + /// The item does not expire unless it is removed due memory pressure. + bool Add(string key, object value); + bool Set(string key, object value); + bool Replace(string key, object value); - /// - /// Inserts an item into the cache with a cache key to reference its location. - /// - /// The key used to reference the item. - /// The object to be inserted into the cache. - /// The time when the item is invalidated in the cache. - /// true if the item was successfully stored in the cache; false otherwise. - bool Add(string key, object value, DateTime expiresAt); - bool Set(string key, object value, DateTime expiresAt); - bool Replace(string key, object value, DateTime expiresAt); + /// + /// Inserts an item into the cache with a cache key to reference its location. + /// + /// The key used to reference the item. + /// The object to be inserted into the cache. + /// The time when the item is invalidated in the cache. + /// true if the item was successfully stored in the cache; false otherwise. + bool Add(string key, object value, DateTime expiresAt); + bool Set(string key, object value, DateTime expiresAt); + bool Replace(string key, object value, DateTime expiresAt); - /// - /// Removes all data from the cache. - /// - void FlushAll(); + /// + /// Removes all data from the cache. + /// + void FlushAll(); - /// - /// Retrieves multiple items from the cache. - /// - /// The list of identifiers for the items to retrieve. - /// - /// a Dictionary holding all items indexed by their key. - /// - IDictionary GetAll(IEnumerable keys); + /// + /// Retrieves multiple items from the cache. + /// + /// The list of identifiers for the items to retrieve. + /// + /// a Dictionary holding all items indexed by their key. + /// + IDictionary GetAll(IEnumerable keys); - bool CheckAndSet(string key, object value, ulong lastModifiedValue); + bool CheckAndSet(string key, object value, ulong lastModifiedValue); - bool CheckAndSet(string key, object value, ulong lastModifiedValue, DateTime expiresAt); + bool CheckAndSet(string key, object value, ulong lastModifiedValue, DateTime expiresAt); - IDictionary GetAll(IEnumerable keys, out IDictionary lastModifiedValues); - } + IDictionary GetAll(IEnumerable keys, out IDictionary lastModifiedValues); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Caching/IRemoveByPattern.cs b/src/ServiceStack.Interfaces/Caching/IRemoveByPattern.cs index 254670c22da..e3533d8f6de 100644 --- a/src/ServiceStack.Interfaces/Caching/IRemoveByPattern.cs +++ b/src/ServiceStack.Interfaces/Caching/IRemoveByPattern.cs @@ -1,16 +1,16 @@ namespace ServiceStack.Caching { - public interface IRemoveByPattern - { - /// - /// Removes items from cache that have keys matching the specified wildcard pattern - /// - /// The wildcard, where "*" means any sequence of characters and "?" means any single character. - void RemoveByPattern(string pattern); - /// - /// Removes items from the cache based on the specified regular expression pattern - /// - /// Regular expression pattern to search cache keys - void RemoveByRegex(string regex); - } + public interface IRemoveByPattern + { + /// + /// Removes items from cache that have keys matching the specified wildcard pattern + /// + /// The wildcard, where "*" means any sequence of characters and "?" means any single character. + void RemoveByPattern(string pattern); + /// + /// Removes items from the cache based on the specified regular expression pattern + /// + /// Regular expression pattern to search cache keys + void RemoveByRegex(string regex); + } } diff --git a/src/ServiceStack.Interfaces/Caching/ISession.cs b/src/ServiceStack.Interfaces/Caching/ISession.cs index f7849692710..433b348dc42 100644 --- a/src/ServiceStack.Interfaces/Caching/ISession.cs +++ b/src/ServiceStack.Interfaces/Caching/ISession.cs @@ -1,31 +1,31 @@ namespace ServiceStack.Caching { - /// - /// A Users Session - /// - public interface ISession - { - /// - /// Store any object at key - /// - /// - /// - object this[string key] { get; set; } + /// + /// A Users Session + /// + public interface ISession + { + /// + /// Store any object at key + /// + /// + /// + object this[string key] { get; set; } - /// - /// Set a typed value at key - /// - /// - /// - /// - void Set(string key, T value); - - /// - /// Get a typed value at key - /// - /// - /// - /// - T Get(string key); - } + /// + /// Set a typed value at key + /// + /// + /// + /// + void Set(string key, T value); + + /// + /// Get a typed value at key + /// + /// + /// + /// + T Get(string key); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Caching/ISessionFactory.cs b/src/ServiceStack.Interfaces/Caching/ISessionFactory.cs index 075e77f8820..b2b63222186 100644 --- a/src/ServiceStack.Interfaces/Caching/ISessionFactory.cs +++ b/src/ServiceStack.Interfaces/Caching/ISessionFactory.cs @@ -2,23 +2,23 @@ namespace ServiceStack.Caching { - /// - /// Retrieves a User Session - /// - public interface ISessionFactory - { - /// - /// Gets the session for this request, creates one if it doesn't exist. - /// - /// - /// - /// - ISession GetOrCreateSession(IRequest httpReq, IResponse httpRes); + /// + /// Retrieves a User Session + /// + public interface ISessionFactory + { + /// + /// Gets the session for this request, creates one if it doesn't exist. + /// + /// + /// + /// + ISession GetOrCreateSession(IRequest httpReq, IResponse httpRes); - /// - /// Gets the session for this request, creates one if it doesn't exist. - /// Only for ASP.NET apps. Uses the HttpContext.Current singleton. - /// - ISession GetOrCreateSession(); - } + /// + /// Gets the session for this request, creates one if it doesn't exist. + /// Only for ASP.NET apps. Uses the HttpContext.Current singleton. + /// + ISession GetOrCreateSession(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Data/DataException.cs b/src/ServiceStack.Interfaces/Data/DataException.cs index 747f657cdd0..ee2bc771687 100644 --- a/src/ServiceStack.Interfaces/Data/DataException.cs +++ b/src/ServiceStack.Interfaces/Data/DataException.cs @@ -5,11 +5,11 @@ namespace ServiceStack.Data { - public class DataException : Exception - { - public DataException() {} - public DataException(string message) : base(message) {} - public DataException(string message, Exception innerException) - : base(message, innerException) {} - } + public class DataException : Exception + { + public DataException() { } + public DataException(string message) : base(message) { } + public DataException(string message, Exception innerException) + : base(message, innerException) { } + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Data/IEntityStore.Generic.cs b/src/ServiceStack.Interfaces/Data/IEntityStore.Generic.cs index df73d5649db..fccdaf0b2f4 100644 --- a/src/ServiceStack.Interfaces/Data/IEntityStore.Generic.cs +++ b/src/ServiceStack.Interfaces/Data/IEntityStore.Generic.cs @@ -7,28 +7,28 @@ namespace ServiceStack.Data { - /// - /// For providers that want a cleaner API with a little more perf - /// - /// - public interface IEntityStore - { - T GetById(object id); + /// + /// For providers that want a cleaner API with a little more perf + /// + /// + public interface IEntityStore + { + T GetById(object id); - IList GetByIds(IEnumerable ids); + IList GetByIds(IEnumerable ids); - IList GetAll(); + IList GetAll(); - T Store(T entity); + T Store(T entity); - void StoreAll(IEnumerable entities); + void StoreAll(IEnumerable entities); - void Delete(T entity); + void Delete(T entity); - void DeleteById(object id); + void DeleteById(object id); - void DeleteByIds(IEnumerable ids); + void DeleteByIds(IEnumerable ids); - void DeleteAll(); - } + void DeleteAll(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Data/IEntityStore.cs b/src/ServiceStack.Interfaces/Data/IEntityStore.cs index 389ccd4629c..74ab2349841 100644 --- a/src/ServiceStack.Interfaces/Data/IEntityStore.cs +++ b/src/ServiceStack.Interfaces/Data/IEntityStore.cs @@ -7,22 +7,22 @@ namespace ServiceStack.Data { - public interface IEntityStore : IDisposable - { - T GetById(object id); - - IList GetByIds(ICollection ids); + public interface IEntityStore : IDisposable + { + T GetById(object id); - T Store(T entity); + IList GetByIds(ICollection ids); - void StoreAll(IEnumerable entities); + T Store(T entity); - void Delete(T entity); + void StoreAll(IEnumerable entities); - void DeleteById(object id); + void Delete(T entity); - void DeleteByIds(ICollection ids); + void DeleteById(object id); - void DeleteAll(); - } + void DeleteByIds(ICollection ids); + + void DeleteAll(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/AliasAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/AliasAttribute.cs index 981be2812af..8baefb69a28 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/AliasAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/AliasAttribute.cs @@ -2,14 +2,14 @@ namespace ServiceStack.DataAnnotations { - [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Class | AttributeTargets.Struct)] + [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Class | AttributeTargets.Struct)] public class AliasAttribute : AttributeBase - { - public string Name { get; set; } + { + public string Name { get; set; } - public AliasAttribute(string name) - { - this.Name = name; - } - } + public AliasAttribute(string name) + { + this.Name = name; + } + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/AutoIncrementAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/AutoIncrementAttribute.cs index 6a5dea073fd..5a8bff18270 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/AutoIncrementAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/AutoIncrementAttribute.cs @@ -2,8 +2,8 @@ namespace ServiceStack.DataAnnotations { - [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field)] + [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field)] public class AutoIncrementAttribute : AttributeBase - { - } + { + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/CompositeIndexAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/CompositeIndexAttribute.cs index 22cf82e31a8..4c5410087b7 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/CompositeIndexAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/CompositeIndexAttribute.cs @@ -3,29 +3,29 @@ namespace ServiceStack.DataAnnotations { - [AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct, AllowMultiple = true)] + [AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct, AllowMultiple = true)] public class CompositeIndexAttribute : AttributeBase - { - public CompositeIndexAttribute() - { - this.FieldNames = new List(); - } + { + public CompositeIndexAttribute() + { + this.FieldNames = new List(); + } - public CompositeIndexAttribute(params string[] fieldNames) - { - this.FieldNames = new List(fieldNames); - } + public CompositeIndexAttribute(params string[] fieldNames) + { + this.FieldNames = new List(fieldNames); + } - public CompositeIndexAttribute(bool unique, params string[] fieldNames) - { - this.Unique = unique; - this.FieldNames = new List(fieldNames); - } + public CompositeIndexAttribute(bool unique, params string[] fieldNames) + { + this.Unique = unique; + this.FieldNames = new List(fieldNames); + } - public List FieldNames { get; set; } + public List FieldNames { get; set; } - public bool Unique { get; set; } + public bool Unique { get; set; } - public string Name { get; set; } - } + public string Name { get; set; } + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/DecimalLengthAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/DecimalLengthAttribute.cs index a78ffc3296f..05dd6a48fc5 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/DecimalLengthAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/DecimalLengthAttribute.cs @@ -2,27 +2,31 @@ namespace ServiceStack.DataAnnotations { - /// - /// Decimal length attribute. - /// - [AttributeUsage(AttributeTargets.Property)] + /// + /// Decimal length attribute. + /// + [AttributeUsage(AttributeTargets.Property)] public class DecimalLengthAttribute : AttributeBase - { - public int Precision { get; set;} - public int Scale { get; set;} - - public DecimalLengthAttribute(int precision, int scale) - { - Precision= precision; - Scale= scale; - } - - public DecimalLengthAttribute(int precision):this(precision,0){ - } - - public DecimalLengthAttribute():this(18,0){ - } - - } + { + public int Precision { get; set; } + public int Scale { get; set; } + + public DecimalLengthAttribute(int precision, int scale) + { + Precision = precision; + Scale = scale; + } + + public DecimalLengthAttribute(int precision) + : this(precision, 0) + { + } + + public DecimalLengthAttribute() + : this(18, 0) + { + } + + } } diff --git a/src/ServiceStack.Interfaces/DataAnnotations/DefaultAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/DefaultAttribute.cs index f2e6791f045..4730e5f4aa1 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/DefaultAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/DefaultAttribute.cs @@ -2,29 +2,29 @@ namespace ServiceStack.DataAnnotations { - [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field)] + [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field)] public class DefaultAttribute : AttributeBase - { - public int IntValue { get; set; } - public double DoubleValue { get; set; } + { + public int IntValue { get; set; } + public double DoubleValue { get; set; } - public Type DefaultType { get; set; } - public string DefaultValue { get; set; } + public Type DefaultType { get; set; } + public string DefaultValue { get; set; } - public DefaultAttribute(int intValue) - { - this.IntValue = intValue; - } + public DefaultAttribute(int intValue) + { + this.IntValue = intValue; + } - public DefaultAttribute(double doubleValue) - { - this.DoubleValue = doubleValue; - } + public DefaultAttribute(double doubleValue) + { + this.DoubleValue = doubleValue; + } - public DefaultAttribute(Type defaultType, string defaultValue) - { - this.DefaultValue = defaultValue; - this.DefaultType = defaultType; - } - } + public DefaultAttribute(Type defaultType, string defaultValue) + { + this.DefaultValue = defaultValue; + this.DefaultType = defaultType; + } + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/DescriptionAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/DescriptionAttribute.cs index 8844bff3180..3d36f00c962 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/DescriptionAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/DescriptionAttribute.cs @@ -5,7 +5,7 @@ namespace ServiceStack.DataAnnotations { public class DescriptionAttribute : AttributeBase - { + { public string Description { get; set; } public DescriptionAttribute(string description) diff --git a/src/ServiceStack.Interfaces/DataAnnotations/ForeignKeyAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/ForeignKeyAttribute.cs index 0f947618ebf..eadf2b0afff 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/ForeignKeyAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/ForeignKeyAttribute.cs @@ -5,7 +5,8 @@ namespace ServiceStack.DataAnnotations [AttributeUsage(AttributeTargets.Property)] public class ForeignKeyAttribute : ReferencesAttribute { - public ForeignKeyAttribute(Type type) : base(type) + public ForeignKeyAttribute(Type type) + : base(type) { } diff --git a/src/ServiceStack.Interfaces/DataAnnotations/IndexAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/IndexAttribute.cs index c3327abac72..fb91762f0bd 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/IndexAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/IndexAttribute.cs @@ -2,17 +2,17 @@ namespace ServiceStack.DataAnnotations { - [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Class | AttributeTargets.Struct)] + [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Class | AttributeTargets.Struct)] public class IndexAttribute : AttributeBase - { - public IndexAttribute() {} + { + public IndexAttribute() { } - public IndexAttribute(bool unique) - { - Unique = unique; - } + public IndexAttribute(bool unique) + { + Unique = unique; + } - public bool Unique { get; set; } + public bool Unique { get; set; } public bool Clustered { get; set; } diff --git a/src/ServiceStack.Interfaces/DataAnnotations/PrimaryKeyAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/PrimaryKeyAttribute.cs index 4d972ea8b63..40ebd09e1d2 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/PrimaryKeyAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/PrimaryKeyAttribute.cs @@ -2,12 +2,12 @@ namespace ServiceStack.DataAnnotations { - /// - /// Primary key attribute. - /// use to indicate that property is part of the pk - /// - [AttributeUsage( AttributeTargets.Property)] + /// + /// Primary key attribute. + /// use to indicate that property is part of the pk + /// + [AttributeUsage(AttributeTargets.Property)] public class PrimaryKeyAttribute : AttributeBase - { - } + { + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/ReferenceAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/ReferenceAttribute.cs index 9bc543b13b8..978647a46c2 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/ReferenceAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/ReferenceAttribute.cs @@ -2,8 +2,8 @@ namespace ServiceStack.DataAnnotations { - [AttributeUsage(AttributeTargets.Property)] + [AttributeUsage(AttributeTargets.Property)] public class ReferenceAttribute : AttributeBase - { - } + { + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/ReferencesAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/ReferencesAttribute.cs index a26a3c3dd00..a63ce5a2a01 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/ReferencesAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/ReferencesAttribute.cs @@ -2,14 +2,14 @@ namespace ServiceStack.DataAnnotations { - [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Class | AttributeTargets.Struct)] + [AttributeUsage(AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Class | AttributeTargets.Struct)] public class ReferencesAttribute : AttributeBase - { - public Type Type { get; set; } + { + public Type Type { get; set; } - public ReferencesAttribute(Type type) - { - this.Type = type; - } - } + public ReferencesAttribute(Type type) + { + this.Type = type; + } + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/RequiredAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/RequiredAttribute.cs index f9ffcd56b9f..7e8619a48e8 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/RequiredAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/RequiredAttribute.cs @@ -5,6 +5,6 @@ namespace ServiceStack.DataAnnotations { public class RequiredAttribute : AttributeBase - { + { } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/DataAnnotations/StringLengthAttribute.cs b/src/ServiceStack.Interfaces/DataAnnotations/StringLengthAttribute.cs index 8a65181b941..367fa42106a 100644 --- a/src/ServiceStack.Interfaces/DataAnnotations/StringLengthAttribute.cs +++ b/src/ServiceStack.Interfaces/DataAnnotations/StringLengthAttribute.cs @@ -6,7 +6,7 @@ namespace ServiceStack.DataAnnotations { public class StringLengthAttribute : AttributeBase { - public const int MaxText = int.MaxValue; + public const int MaxText = int.MaxValue; public int MinimumLength { get; set; } public int MaximumLength { get; private set; } diff --git a/src/ServiceStack.Interfaces/Redis/Generic/IRedisHash.Generic.cs b/src/ServiceStack.Interfaces/Redis/Generic/IRedisHash.Generic.cs index 7d45ecdeacc..047ed0bbfc8 100644 --- a/src/ServiceStack.Interfaces/Redis/Generic/IRedisHash.Generic.cs +++ b/src/ServiceStack.Interfaces/Redis/Generic/IRedisHash.Generic.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -15,9 +15,9 @@ namespace ServiceStack.Redis.Generic { - public interface IRedisHash : IDictionary, IHasStringId - { - Dictionary GetAll(); - } + public interface IRedisHash : IDictionary, IHasStringId + { + Dictionary GetAll(); + } } diff --git a/src/ServiceStack.Interfaces/Redis/Generic/IRedisList.Generic.cs b/src/ServiceStack.Interfaces/Redis/Generic/IRedisList.Generic.cs index cd250893624..fb045c0e597 100644 --- a/src/ServiceStack.Interfaces/Redis/Generic/IRedisList.Generic.cs +++ b/src/ServiceStack.Interfaces/Redis/Generic/IRedisList.Generic.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -16,35 +16,35 @@ namespace ServiceStack.Redis.Generic { - /// - /// Wrap the common redis list operations under a IList[string] interface. - /// + /// + /// Wrap the common redis list operations under a IList[string] interface. + /// - public interface IRedisList - : IList, IHasStringId - { - List GetAll(); - List GetRange(int startingFrom, int endingAt); - List GetRangeFromSortedList(int startingFrom, int endingAt); - void RemoveAll(); - void Trim(int keepStartingFrom, int keepEndingAt); - long RemoveValue(T value); - long RemoveValue(T value, int noOfMatches); + public interface IRedisList + : IList, IHasStringId + { + List GetAll(); + List GetRange(int startingFrom, int endingAt); + List GetRangeFromSortedList(int startingFrom, int endingAt); + void RemoveAll(); + void Trim(int keepStartingFrom, int keepEndingAt); + long RemoveValue(T value); + long RemoveValue(T value, int noOfMatches); - void AddRange(IEnumerable values); - void Append(T value); - void Prepend(T value); - T RemoveStart(); - T BlockingRemoveStart(TimeSpan? timeOut); - T RemoveEnd(); + void AddRange(IEnumerable values); + void Append(T value); + void Prepend(T value); + T RemoveStart(); + T BlockingRemoveStart(TimeSpan? timeOut); + T RemoveEnd(); - void Enqueue(T value); - T Dequeue(); - T BlockingDequeue(TimeSpan? timeOut); + void Enqueue(T value); + T Dequeue(); + T BlockingDequeue(TimeSpan? timeOut); - void Push(T value); - T Pop(); - T BlockingPop(TimeSpan? timeOut); - T PopAndPush(IRedisList toList); - } + void Push(T value); + T Pop(); + T BlockingPop(TimeSpan? timeOut); + T PopAndPush(IRedisList toList); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Generic/IRedisSet.Generic.cs b/src/ServiceStack.Interfaces/Redis/Generic/IRedisSet.Generic.cs index 21bddd5f488..eb0a347c6b7 100644 --- a/src/ServiceStack.Interfaces/Redis/Generic/IRedisSet.Generic.cs +++ b/src/ServiceStack.Interfaces/Redis/Generic/IRedisSet.Generic.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -15,17 +15,17 @@ namespace ServiceStack.Redis.Generic { - public interface IRedisSet : ICollection, IHasStringId - { - List Sort(int startingFrom, int endingAt); - HashSet GetAll(); - T PopRandomItem(); - T GetRandomItem(); - void MoveTo(T item, IRedisSet toSet); - void PopulateWithIntersectOf(params IRedisSet[] sets); - void PopulateWithUnionOf(params IRedisSet[] sets); - void GetDifferences(params IRedisSet[] withSets); - void PopulateWithDifferencesOf(IRedisSet fromSet, params IRedisSet[] withSets); - } + public interface IRedisSet : ICollection, IHasStringId + { + List Sort(int startingFrom, int endingAt); + HashSet GetAll(); + T PopRandomItem(); + T GetRandomItem(); + void MoveTo(T item, IRedisSet toSet); + void PopulateWithIntersectOf(params IRedisSet[] sets); + void PopulateWithUnionOf(params IRedisSet[] sets); + void GetDifferences(params IRedisSet[] withSets); + void PopulateWithDifferencesOf(IRedisSet fromSet, params IRedisSet[] withSets); + } } diff --git a/src/ServiceStack.Interfaces/Redis/Generic/IRedisSortedSet.Generic.cs b/src/ServiceStack.Interfaces/Redis/Generic/IRedisSortedSet.Generic.cs index 554b64c282f..a90fd17d7f0 100644 --- a/src/ServiceStack.Interfaces/Redis/Generic/IRedisSortedSet.Generic.cs +++ b/src/ServiceStack.Interfaces/Redis/Generic/IRedisSortedSet.Generic.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -15,24 +15,24 @@ namespace ServiceStack.Redis.Generic { - public interface IRedisSortedSet : ICollection, IHasStringId - { - T PopItemWithHighestScore(); - T PopItemWithLowestScore(); - double IncrementItem(T item, double incrementBy); - int IndexOf(T item); - long IndexOfDescending(T item); - List GetAll(); - List GetAllDescending(); - List GetRange(int fromRank, int toRank); - List GetRangeByLowestScore(double fromScore, double toScore); - List GetRangeByLowestScore(double fromScore, double toScore, int? skip, int? take); - List GetRangeByHighestScore(double fromScore, double toScore); - List GetRangeByHighestScore(double fromScore, double toScore, int? skip, int? take); - long RemoveRange(int minRank, int maxRank); - long RemoveRangeByScore(double fromScore, double toScore); - double GetItemScore(T item); - long PopulateWithIntersectOf(params IRedisSortedSet[] setIds); - long PopulateWithUnionOf(params IRedisSortedSet[] setIds); - } + public interface IRedisSortedSet : ICollection, IHasStringId + { + T PopItemWithHighestScore(); + T PopItemWithLowestScore(); + double IncrementItem(T item, double incrementBy); + int IndexOf(T item); + long IndexOfDescending(T item); + List GetAll(); + List GetAllDescending(); + List GetRange(int fromRank, int toRank); + List GetRangeByLowestScore(double fromScore, double toScore); + List GetRangeByLowestScore(double fromScore, double toScore, int? skip, int? take); + List GetRangeByHighestScore(double fromScore, double toScore); + List GetRangeByHighestScore(double fromScore, double toScore, int? skip, int? take); + long RemoveRange(int minRank, int maxRank); + long RemoveRangeByScore(double fromScore, double toScore); + double GetItemScore(T item); + long PopulateWithIntersectOf(params IRedisSortedSet[] setIds); + long PopulateWithUnionOf(params IRedisSortedSet[] setIds); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Generic/IRedisTransaction.cs b/src/ServiceStack.Interfaces/Redis/Generic/IRedisTransaction.cs index 8c617a738f9..4073c933c72 100644 --- a/src/ServiceStack.Interfaces/Redis/Generic/IRedisTransaction.cs +++ b/src/ServiceStack.Interfaces/Redis/Generic/IRedisTransaction.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -18,9 +18,9 @@ namespace ServiceStack.Redis.Generic /// Redis transaction for typed client /// /// - public interface IRedisTypedTransaction: IRedisTypedQueueableOperation, IDisposable - { - bool Commit(); - void Rollback(); - } + public interface IRedisTypedTransaction : IRedisTypedQueueableOperation, IDisposable + { + bool Commit(); + void Rollback(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedClient.cs b/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedClient.cs index 73531f8faf5..213db6af5a6 100644 --- a/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedClient.cs +++ b/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedClient.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -17,175 +17,175 @@ namespace ServiceStack.Redis.Generic { - public interface IRedisTypedClient - : IEntityStore - { - IHasNamed> Lists { get; set; } - IHasNamed> Sets { get; set; } - IHasNamed> SortedSets { get; set; } - IRedisHash GetHash(string hashId); - - IRedisTypedTransaction CreateTransaction(); + public interface IRedisTypedClient + : IEntityStore + { + IHasNamed> Lists { get; set; } + IHasNamed> Sets { get; set; } + IHasNamed> SortedSets { get; set; } + IRedisHash GetHash(string hashId); + + IRedisTypedTransaction CreateTransaction(); IRedisTypedPipeline CreatePipeline(); IRedisClient RedisClient { get; } - - IDisposable AcquireLock(); - IDisposable AcquireLock(TimeSpan timeOut); - - long Db { get; set; } - List GetAllKeys(); - IRedisSet TypeIdsSet { get; } - - T this[string key] { get; set; } - - string SequenceKey { get; set; } - void SetSequence(int value); - long GetNextSequence(); - long GetNextSequence(int incrBy); - RedisKeyType GetEntryType(string key); - string GetRandomKey(); - - void SetEntry(string key, T value); - void SetEntry(string key, T value, TimeSpan expireIn); - bool SetEntryIfNotExists(string key, T value); - T GetValue(string key); - T GetAndSetValue(string key, T value); - bool ContainsKey(string key); - bool RemoveEntry(string key); - bool RemoveEntry(params string[] args); - bool RemoveEntry(params IHasStringId[] entities); - long IncrementValue(string key); - long IncrementValueBy(string key, int count); - long DecrementValue(string key); - long DecrementValueBy(string key, int count); - - bool ExpireIn(object id, TimeSpan expiresAt); - bool ExpireAt(object id, DateTime dateTime); - bool ExpireEntryIn(string key, TimeSpan expiresAt); - bool ExpireEntryAt(string key, DateTime dateTime); - - TimeSpan GetTimeToLive(string key); - void Save(); - void SaveAsync(); - void FlushDb(); - void FlushAll(); - T[] SearchKeys(string pattern); - List GetValues(List keys); - List GetSortedEntryValues(IRedisSet fromSet, int startingFrom, int endingAt); - - void StoreAsHash(T entity); - T GetFromHash(object id); - - //Set operations - HashSet GetAllItemsFromSet(IRedisSet fromSet); - void AddItemToSet(IRedisSet toSet, T item); - void RemoveItemFromSet(IRedisSet fromSet, T item); - T PopItemFromSet(IRedisSet fromSet); - void MoveBetweenSets(IRedisSet fromSet, IRedisSet toSet, T item); - long GetSetCount(IRedisSet set); - bool SetContainsItem(IRedisSet set, T item); - HashSet GetIntersectFromSets(params IRedisSet[] sets); - void StoreIntersectFromSets(IRedisSet intoSet, params IRedisSet[] sets); - HashSet GetUnionFromSets(params IRedisSet[] sets); - void StoreUnionFromSets(IRedisSet intoSet, params IRedisSet[] sets); - HashSet GetDifferencesFromSet(IRedisSet fromSet, params IRedisSet[] withSets); - void StoreDifferencesFromSet(IRedisSet intoSet, IRedisSet fromSet, params IRedisSet[] withSets); - T GetRandomItemFromSet(IRedisSet fromSet); - - //List operations - List GetAllItemsFromList(IRedisList fromList); - List GetRangeFromList(IRedisList fromList, int startingFrom, int endingAt); - List SortList(IRedisList fromList, int startingFrom, int endingAt); - void AddItemToList(IRedisList fromList, T value); - void PrependItemToList(IRedisList fromList, T value); - T RemoveStartFromList(IRedisList fromList); - T BlockingRemoveStartFromList(IRedisList fromList, TimeSpan? timeOut); - T RemoveEndFromList(IRedisList fromList); - void RemoveAllFromList(IRedisList fromList); - void TrimList(IRedisList fromList, int keepStartingFrom, int keepEndingAt); - long RemoveItemFromList(IRedisList fromList, T value); - long RemoveItemFromList(IRedisList fromList, T value, int noOfMatches); - long GetListCount(IRedisList fromList); - T GetItemFromList(IRedisList fromList, int listIndex); - void SetItemInList(IRedisList toList, int listIndex, T value); + + IDisposable AcquireLock(); + IDisposable AcquireLock(TimeSpan timeOut); + + long Db { get; set; } + List GetAllKeys(); + IRedisSet TypeIdsSet { get; } + + T this[string key] { get; set; } + + string SequenceKey { get; set; } + void SetSequence(int value); + long GetNextSequence(); + long GetNextSequence(int incrBy); + RedisKeyType GetEntryType(string key); + string GetRandomKey(); + + void SetEntry(string key, T value); + void SetEntry(string key, T value, TimeSpan expireIn); + bool SetEntryIfNotExists(string key, T value); + T GetValue(string key); + T GetAndSetValue(string key, T value); + bool ContainsKey(string key); + bool RemoveEntry(string key); + bool RemoveEntry(params string[] args); + bool RemoveEntry(params IHasStringId[] entities); + long IncrementValue(string key); + long IncrementValueBy(string key, int count); + long DecrementValue(string key); + long DecrementValueBy(string key, int count); + + bool ExpireIn(object id, TimeSpan expiresAt); + bool ExpireAt(object id, DateTime dateTime); + bool ExpireEntryIn(string key, TimeSpan expiresAt); + bool ExpireEntryAt(string key, DateTime dateTime); + + TimeSpan GetTimeToLive(string key); + void Save(); + void SaveAsync(); + void FlushDb(); + void FlushAll(); + T[] SearchKeys(string pattern); + List GetValues(List keys); + List GetSortedEntryValues(IRedisSet fromSet, int startingFrom, int endingAt); + + void StoreAsHash(T entity); + T GetFromHash(object id); + + //Set operations + HashSet GetAllItemsFromSet(IRedisSet fromSet); + void AddItemToSet(IRedisSet toSet, T item); + void RemoveItemFromSet(IRedisSet fromSet, T item); + T PopItemFromSet(IRedisSet fromSet); + void MoveBetweenSets(IRedisSet fromSet, IRedisSet toSet, T item); + long GetSetCount(IRedisSet set); + bool SetContainsItem(IRedisSet set, T item); + HashSet GetIntersectFromSets(params IRedisSet[] sets); + void StoreIntersectFromSets(IRedisSet intoSet, params IRedisSet[] sets); + HashSet GetUnionFromSets(params IRedisSet[] sets); + void StoreUnionFromSets(IRedisSet intoSet, params IRedisSet[] sets); + HashSet GetDifferencesFromSet(IRedisSet fromSet, params IRedisSet[] withSets); + void StoreDifferencesFromSet(IRedisSet intoSet, IRedisSet fromSet, params IRedisSet[] withSets); + T GetRandomItemFromSet(IRedisSet fromSet); + + //List operations + List GetAllItemsFromList(IRedisList fromList); + List GetRangeFromList(IRedisList fromList, int startingFrom, int endingAt); + List SortList(IRedisList fromList, int startingFrom, int endingAt); + void AddItemToList(IRedisList fromList, T value); + void PrependItemToList(IRedisList fromList, T value); + T RemoveStartFromList(IRedisList fromList); + T BlockingRemoveStartFromList(IRedisList fromList, TimeSpan? timeOut); + T RemoveEndFromList(IRedisList fromList); + void RemoveAllFromList(IRedisList fromList); + void TrimList(IRedisList fromList, int keepStartingFrom, int keepEndingAt); + long RemoveItemFromList(IRedisList fromList, T value); + long RemoveItemFromList(IRedisList fromList, T value, int noOfMatches); + long GetListCount(IRedisList fromList); + T GetItemFromList(IRedisList fromList, int listIndex); + void SetItemInList(IRedisList toList, int listIndex, T value); void InsertBeforeItemInList(IRedisList toList, T pivot, T value); void InsertAfterItemInList(IRedisList toList, T pivot, T value); - //Queue operations - void EnqueueItemOnList(IRedisList fromList, T item); - T DequeueItemFromList(IRedisList fromList); - T BlockingDequeueItemFromList(IRedisList fromList, TimeSpan? timeOut); - - //Stack operations - void PushItemToList(IRedisList fromList, T item); - T PopItemFromList(IRedisList fromList); - T BlockingPopItemFromList(IRedisList fromList, TimeSpan? timeOut); - T PopAndPushItemBetweenLists(IRedisList fromList, IRedisList toList); + //Queue operations + void EnqueueItemOnList(IRedisList fromList, T item); + T DequeueItemFromList(IRedisList fromList); + T BlockingDequeueItemFromList(IRedisList fromList, TimeSpan? timeOut); + + //Stack operations + void PushItemToList(IRedisList fromList, T item); + T PopItemFromList(IRedisList fromList); + T BlockingPopItemFromList(IRedisList fromList, TimeSpan? timeOut); + T PopAndPushItemBetweenLists(IRedisList fromList, IRedisList toList); T BlockingPopAndPushItemBetweenLists(IRedisList fromList, IRedisList toList, TimeSpan? timeOut); - //Sorted Set operations - void AddItemToSortedSet(IRedisSortedSet toSet, T value); - void AddItemToSortedSet(IRedisSortedSet toSet, T value, double score); - bool RemoveItemFromSortedSet(IRedisSortedSet fromSet, T value); - T PopItemWithLowestScoreFromSortedSet(IRedisSortedSet fromSet); - T PopItemWithHighestScoreFromSortedSet(IRedisSortedSet fromSet); - bool SortedSetContainsItem(IRedisSortedSet set, T value); - double IncrementItemInSortedSet(IRedisSortedSet set, T value, double incrementBy); - long GetItemIndexInSortedSet(IRedisSortedSet set, T value); - long GetItemIndexInSortedSetDesc(IRedisSortedSet set, T value); - List GetAllItemsFromSortedSet(IRedisSortedSet set); - List GetAllItemsFromSortedSetDesc(IRedisSortedSet set); - List GetRangeFromSortedSet(IRedisSortedSet set, int fromRank, int toRank); - List GetRangeFromSortedSetDesc(IRedisSortedSet set, int fromRank, int toRank); - IDictionary GetAllWithScoresFromSortedSet(IRedisSortedSet set); - IDictionary GetRangeWithScoresFromSortedSet(IRedisSortedSet set, int fromRank, int toRank); - IDictionary GetRangeWithScoresFromSortedSetDesc(IRedisSortedSet set, int fromRank, int toRank); - List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); - List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); - List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore); - List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); - IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); - IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); - IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore); - IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); - List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); - List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); - List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore); - List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); - IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); - IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); - IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore); - IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); - long RemoveRangeFromSortedSet(IRedisSortedSet set, int minRank, int maxRank); - long RemoveRangeFromSortedSetByScore(IRedisSortedSet set, double fromScore, double toScore); - long GetSortedSetCount(IRedisSortedSet set); - double GetItemScoreInSortedSet(IRedisSortedSet set, T value); - long StoreIntersectFromSortedSets(IRedisSortedSet intoSetId, params IRedisSortedSet[] setIds); - long StoreUnionFromSortedSets(IRedisSortedSet intoSetId, params IRedisSortedSet[] setIds); - - //Hash operations - bool HashContainsEntry(IRedisHash hash, TKey key); - bool SetEntryInHash(IRedisHash hash, TKey key, T value); - bool SetEntryInHashIfNotExists(IRedisHash hash, TKey key, T value); - void SetRangeInHash(IRedisHash hash, IEnumerable> keyValuePairs); - T GetValueFromHash(IRedisHash hash, TKey key); - bool RemoveEntryFromHash(IRedisHash hash, TKey key); - long GetHashCount(IRedisHash hash); - List GetHashKeys(IRedisHash hash); - List GetHashValues(IRedisHash hash); - Dictionary GetAllEntriesFromHash(IRedisHash hash); - - //Useful common app-logic - void StoreRelatedEntities(object parentId, List children); - void StoreRelatedEntities(object parentId, params TChild[] children); - void DeleteRelatedEntities(object parentId); - void DeleteRelatedEntity(object parentId, object childId); - List GetRelatedEntities(object parentId); - long GetRelatedEntitiesCount(object parentId); - void AddToRecentsList(T value); - List GetLatestFromRecentsList(int skip, int take); - List GetEarliestFromRecentsList(int skip, int take); - } + //Sorted Set operations + void AddItemToSortedSet(IRedisSortedSet toSet, T value); + void AddItemToSortedSet(IRedisSortedSet toSet, T value, double score); + bool RemoveItemFromSortedSet(IRedisSortedSet fromSet, T value); + T PopItemWithLowestScoreFromSortedSet(IRedisSortedSet fromSet); + T PopItemWithHighestScoreFromSortedSet(IRedisSortedSet fromSet); + bool SortedSetContainsItem(IRedisSortedSet set, T value); + double IncrementItemInSortedSet(IRedisSortedSet set, T value, double incrementBy); + long GetItemIndexInSortedSet(IRedisSortedSet set, T value); + long GetItemIndexInSortedSetDesc(IRedisSortedSet set, T value); + List GetAllItemsFromSortedSet(IRedisSortedSet set); + List GetAllItemsFromSortedSetDesc(IRedisSortedSet set); + List GetRangeFromSortedSet(IRedisSortedSet set, int fromRank, int toRank); + List GetRangeFromSortedSetDesc(IRedisSortedSet set, int fromRank, int toRank); + IDictionary GetAllWithScoresFromSortedSet(IRedisSortedSet set); + IDictionary GetRangeWithScoresFromSortedSet(IRedisSortedSet set, int fromRank, int toRank); + IDictionary GetRangeWithScoresFromSortedSetDesc(IRedisSortedSet set, int fromRank, int toRank); + List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); + List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); + List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore); + List GetRangeFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); + IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); + IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); + IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore); + IDictionary GetRangeWithScoresFromSortedSetByLowestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); + List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); + List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); + List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore); + List GetRangeFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); + IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore); + IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, string fromStringScore, string toStringScore, int? skip, int? take); + IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore); + IDictionary GetRangeWithScoresFromSortedSetByHighestScore(IRedisSortedSet set, double fromScore, double toScore, int? skip, int? take); + long RemoveRangeFromSortedSet(IRedisSortedSet set, int minRank, int maxRank); + long RemoveRangeFromSortedSetByScore(IRedisSortedSet set, double fromScore, double toScore); + long GetSortedSetCount(IRedisSortedSet set); + double GetItemScoreInSortedSet(IRedisSortedSet set, T value); + long StoreIntersectFromSortedSets(IRedisSortedSet intoSetId, params IRedisSortedSet[] setIds); + long StoreUnionFromSortedSets(IRedisSortedSet intoSetId, params IRedisSortedSet[] setIds); + + //Hash operations + bool HashContainsEntry(IRedisHash hash, TKey key); + bool SetEntryInHash(IRedisHash hash, TKey key, T value); + bool SetEntryInHashIfNotExists(IRedisHash hash, TKey key, T value); + void SetRangeInHash(IRedisHash hash, IEnumerable> keyValuePairs); + T GetValueFromHash(IRedisHash hash, TKey key); + bool RemoveEntryFromHash(IRedisHash hash, TKey key); + long GetHashCount(IRedisHash hash); + List GetHashKeys(IRedisHash hash); + List GetHashValues(IRedisHash hash); + Dictionary GetAllEntriesFromHash(IRedisHash hash); + + //Useful common app-logic + void StoreRelatedEntities(object parentId, List children); + void StoreRelatedEntities(object parentId, params TChild[] children); + void DeleteRelatedEntities(object parentId); + void DeleteRelatedEntity(object parentId, object childId); + List GetRelatedEntities(object parentId); + long GetRelatedEntitiesCount(object parentId); + void AddToRecentsList(T value); + List GetLatestFromRecentsList(int skip, int take); + List GetEarliestFromRecentsList(int skip, int take); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedQueueableOperation.cs b/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedQueueableOperation.cs index f044ea17039..83f609e39d9 100644 --- a/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedQueueableOperation.cs +++ b/src/ServiceStack.Interfaces/Redis/Generic/IRedisTypedQueueableOperation.cs @@ -48,6 +48,6 @@ public interface IRedisTypedQueueableOperation void QueueCommand(Func, List> command); void QueueCommand(Func, List> command, Action> onSuccessCallback); void QueueCommand(Func, List> command, Action> onSuccessCallback, Action onErrorCallback); - + } } diff --git a/src/ServiceStack.Interfaces/Redis/IRedisClientCacheManager.cs b/src/ServiceStack.Interfaces/Redis/IRedisClientCacheManager.cs index 97d4f46fe12..6fc42770978 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisClientCacheManager.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisClientCacheManager.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -15,31 +15,31 @@ namespace ServiceStack.Redis { - public interface IRedisClientCacheManager - : IDisposable - { - /// - /// Returns a Read/Write client (The default) using the hosts defined in ReadWriteHosts - /// - /// - IRedisClient GetClient(); + public interface IRedisClientCacheManager + : IDisposable + { + /// + /// Returns a Read/Write client (The default) using the hosts defined in ReadWriteHosts + /// + /// + IRedisClient GetClient(); - /// - /// Returns a ReadOnly client using the hosts defined in ReadOnlyHosts. - /// - /// - IRedisClient GetReadOnlyClient(); + /// + /// Returns a ReadOnly client using the hosts defined in ReadOnlyHosts. + /// + /// + IRedisClient GetReadOnlyClient(); - /// - /// Returns a Read/Write ICacheClient (The default) using the hosts defined in ReadWriteHosts - /// - /// - ICacheClient GetCacheClient(); + /// + /// Returns a Read/Write ICacheClient (The default) using the hosts defined in ReadWriteHosts + /// + /// + ICacheClient GetCacheClient(); - /// - /// Returns a ReadOnly ICacheClient using the hosts defined in ReadOnlyHosts. - /// - /// - ICacheClient GetReadOnlyCacheClient(); - } + /// + /// Returns a ReadOnly ICacheClient using the hosts defined in ReadOnlyHosts. + /// + /// + ICacheClient GetReadOnlyCacheClient(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/IRedisClientsManager.cs b/src/ServiceStack.Interfaces/Redis/IRedisClientsManager.cs index b07942c6ca5..4061e714187 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisClientsManager.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisClientsManager.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -15,30 +15,30 @@ namespace ServiceStack.Redis { - public interface IRedisClientsManager : IDisposable - { - /// - /// Returns a Read/Write client (The default) using the hosts defined in ReadWriteHosts - /// - /// - IRedisClient GetClient(); + public interface IRedisClientsManager : IDisposable + { + /// + /// Returns a Read/Write client (The default) using the hosts defined in ReadWriteHosts + /// + /// + IRedisClient GetClient(); - /// - /// Returns a ReadOnly client using the hosts defined in ReadOnlyHosts. - /// - /// - IRedisClient GetReadOnlyClient(); + /// + /// Returns a ReadOnly client using the hosts defined in ReadOnlyHosts. + /// + /// + IRedisClient GetReadOnlyClient(); - /// - /// Returns a Read/Write ICacheClient (The default) using the hosts defined in ReadWriteHosts - /// - /// - ICacheClient GetCacheClient(); + /// + /// Returns a Read/Write ICacheClient (The default) using the hosts defined in ReadWriteHosts + /// + /// + ICacheClient GetCacheClient(); - /// - /// Returns a ReadOnly ICacheClient using the hosts defined in ReadOnlyHosts. - /// - /// - ICacheClient GetReadOnlyCacheClient(); - } + /// + /// Returns a ReadOnly ICacheClient using the hosts defined in ReadOnlyHosts. + /// + /// + ICacheClient GetReadOnlyCacheClient(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/IRedisHash.cs b/src/ServiceStack.Interfaces/Redis/IRedisHash.cs index d63d159f11d..12275ccd4f1 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisHash.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisHash.cs @@ -3,11 +3,11 @@ namespace ServiceStack.Redis { - public interface IRedisHash - : IDictionary, IHasStringId - { - bool AddIfNotExists(KeyValuePair item); - void AddRange(IEnumerable> items); - long IncrementValue(string key, int incrementBy); - } + public interface IRedisHash + : IDictionary, IHasStringId + { + bool AddIfNotExists(KeyValuePair item); + void AddRange(IEnumerable> items); + long IncrementValue(string key, int incrementBy); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/IRedisList.cs b/src/ServiceStack.Interfaces/Redis/IRedisList.cs index 3238fbe6535..3622ea31f65 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisList.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisList.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -16,30 +16,30 @@ namespace ServiceStack.Redis { - public interface IRedisList - : IList, IHasStringId - { - List GetAll(); - List GetRange(int startingFrom, int endingAt); - List GetRangeFromSortedList(int startingFrom, int endingAt); - void RemoveAll(); - void Trim(int keepStartingFrom, int keepEndingAt); - long RemoveValue(string value); - long RemoveValue(string value, int noOfMatches); + public interface IRedisList + : IList, IHasStringId + { + List GetAll(); + List GetRange(int startingFrom, int endingAt); + List GetRangeFromSortedList(int startingFrom, int endingAt); + void RemoveAll(); + void Trim(int keepStartingFrom, int keepEndingAt); + long RemoveValue(string value); + long RemoveValue(string value, int noOfMatches); - void Prepend(string value); - void Append(string value); - string RemoveStart(); - string BlockingRemoveStart(TimeSpan? timeOut); - string RemoveEnd(); + void Prepend(string value); + void Append(string value); + string RemoveStart(); + string BlockingRemoveStart(TimeSpan? timeOut); + string RemoveEnd(); - void Enqueue(string value); - string Dequeue(); - string BlockingDequeue(TimeSpan? timeOut); + void Enqueue(string value); + string Dequeue(); + string BlockingDequeue(TimeSpan? timeOut); - void Push(string value); - string Pop(); - string BlockingPop(TimeSpan? timeOut); - string PopAndPush(IRedisList toList); - } + void Push(string value); + string Pop(); + string BlockingPop(TimeSpan? timeOut); + string PopAndPush(IRedisList toList); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/IRedisNativeClient.cs b/src/ServiceStack.Interfaces/Redis/IRedisNativeClient.cs index 39c1971930a..cc6d81e507c 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisNativeClient.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisNativeClient.cs @@ -15,193 +15,193 @@ namespace ServiceStack.Redis { - public interface IRedisNativeClient - : IDisposable - { - //Redis utility operations - Dictionary Info { get; } - long Db { get; set; } - long DbSize { get; } - DateTime LastSave { get; } - void Save(); - void BgSave(); - void Shutdown(); - void BgRewriteAof(); - void Quit(); - void FlushDb(); - void FlushAll(); - bool Ping(); - string Echo(string text); - void SlaveOf(string hostname, int port); - void SlaveOfNoOne(); - byte[][] ConfigGet(string pattern); - void ConfigSet(string item, byte[] value); - void ConfigResetStat(); - byte[][] Time(); - void DebugSegfault(); - byte[] Dump(string key); - byte[] Restore(string key, long expireMs, byte[] dumpValue); - void Migrate(string host, int port, int destinationDb, long timeoutMs); - bool Move(string key, int db); - long ObjectIdleTime(string key); + public interface IRedisNativeClient + : IDisposable + { + //Redis utility operations + Dictionary Info { get; } + long Db { get; set; } + long DbSize { get; } + DateTime LastSave { get; } + void Save(); + void BgSave(); + void Shutdown(); + void BgRewriteAof(); + void Quit(); + void FlushDb(); + void FlushAll(); + bool Ping(); + string Echo(string text); + void SlaveOf(string hostname, int port); + void SlaveOfNoOne(); + byte[][] ConfigGet(string pattern); + void ConfigSet(string item, byte[] value); + void ConfigResetStat(); + byte[][] Time(); + void DebugSegfault(); + byte[] Dump(string key); + byte[] Restore(string key, long expireMs, byte[] dumpValue); + void Migrate(string host, int port, int destinationDb, long timeoutMs); + bool Move(string key, int db); + long ObjectIdleTime(string key); - //Common key-value Redis operations - byte[][] Keys(string pattern); - long Exists(string key); - long StrLen(string key); - void Set(string key, byte[] value); - void SetEx(string key, int expireInSeconds, byte[] value); - bool Persist(string key); - void PSetEx(string key, long expireInMs, byte[] value); - long SetNX(string key, byte[] value); - void MSet(byte[][] keys, byte[][] values); - void MSet(string[] keys, byte[][] values); - bool MSetNx(byte[][] keys, byte[][] values); - bool MSetNx(string[] keys, byte[][] values); - byte[] Get(string key); - byte[] GetSet(string key, byte[] value); - byte[][] MGet(params byte[][] keysAndArgs); - byte[][] MGet(params string[] keys); - long Del(string key); - long Del(params string[] keys); - long Incr(string key); - long IncrBy(string key, int incrBy); - double IncrByFloat(string key, double incrBy); - long Decr(string key); - long DecrBy(string key, int decrBy); - long Append(string key, byte[] value); - byte[] GetRange(string key, int fromIndex, int toIndex); - long SetRange(string key, int offset, byte[] value); - long GetBit(string key, int offset); - long SetBit(string key, int offset, int value); - - string RandomKey(); - void Rename(string oldKeyname, string newKeyname); - bool RenameNx(string oldKeyname, string newKeyname); - bool Expire(string key, int seconds); - bool PExpire(string key, long ttlMs); - bool ExpireAt(string key, long unixTime); - bool PExpireAt(string key, long unixTimeMs); - long Ttl(string key); - long PTtl(string key); + //Common key-value Redis operations + byte[][] Keys(string pattern); + long Exists(string key); + long StrLen(string key); + void Set(string key, byte[] value); + void SetEx(string key, int expireInSeconds, byte[] value); + bool Persist(string key); + void PSetEx(string key, long expireInMs, byte[] value); + long SetNX(string key, byte[] value); + void MSet(byte[][] keys, byte[][] values); + void MSet(string[] keys, byte[][] values); + bool MSetNx(byte[][] keys, byte[][] values); + bool MSetNx(string[] keys, byte[][] values); + byte[] Get(string key); + byte[] GetSet(string key, byte[] value); + byte[][] MGet(params byte[][] keysAndArgs); + byte[][] MGet(params string[] keys); + long Del(string key); + long Del(params string[] keys); + long Incr(string key); + long IncrBy(string key, int incrBy); + double IncrByFloat(string key, double incrBy); + long Decr(string key); + long DecrBy(string key, int decrBy); + long Append(string key, byte[] value); + byte[] GetRange(string key, int fromIndex, int toIndex); + long SetRange(string key, int offset, byte[] value); + long GetBit(string key, int offset); + long SetBit(string key, int offset, int value); + + string RandomKey(); + void Rename(string oldKeyname, string newKeyname); + bool RenameNx(string oldKeyname, string newKeyname); + bool Expire(string key, int seconds); + bool PExpire(string key, long ttlMs); + bool ExpireAt(string key, long unixTime); + bool PExpireAt(string key, long unixTimeMs); + long Ttl(string key); + long PTtl(string key); //Scan APIs - ScanResult Scan(ulong cursor, int count = 10, string match = null); - ScanResult SScan(string setId, ulong cursor, int count = 10, string match = null); - ScanResult ZScan(string setId, ulong cursor, int count = 10, string match = null); - ScanResult HScan(string hashId, ulong cursor, int count = 10, string match = null); + ScanResult Scan(ulong cursor, int count = 10, string match = null); + ScanResult SScan(string setId, ulong cursor, int count = 10, string match = null); + ScanResult ZScan(string setId, ulong cursor, int count = 10, string match = null); + ScanResult HScan(string hashId, ulong cursor, int count = 10, string match = null); //Hyperlog - bool PfAdd(string key, params byte[][] elements); + bool PfAdd(string key, params byte[][] elements); long PfCount(string key); - void PfMerge(string toKeyId, params string[] fromKeys); + void PfMerge(string toKeyId, params string[] fromKeys); - //Redis Sort operation (works on lists, sets or hashes) - byte[][] Sort(string listOrSetId, SortOptions sortOptions); + //Redis Sort operation (works on lists, sets or hashes) + byte[][] Sort(string listOrSetId, SortOptions sortOptions); - //Redis List operations - byte[][] LRange(string listId, int startingFrom, int endingAt); - long RPush(string listId, byte[] value); - long RPushX(string listId, byte[] value); - long LPush(string listId, byte[] value); - long LPushX(string listId, byte[] value); - void LTrim(string listId, int keepStartingFrom, int keepEndingAt); - long LRem(string listId, int removeNoOfMatches, byte[] value); - long LLen(string listId); - byte[] LIndex(string listId, int listIndex); + //Redis List operations + byte[][] LRange(string listId, int startingFrom, int endingAt); + long RPush(string listId, byte[] value); + long RPushX(string listId, byte[] value); + long LPush(string listId, byte[] value); + long LPushX(string listId, byte[] value); + void LTrim(string listId, int keepStartingFrom, int keepEndingAt); + long LRem(string listId, int removeNoOfMatches, byte[] value); + long LLen(string listId); + byte[] LIndex(string listId, int listIndex); void LInsert(string listId, bool insertBefore, byte[] pivot, byte[] value); - void LSet(string listId, int listIndex, byte[] value); - byte[] LPop(string listId); - byte[] RPop(string listId); - byte[][] BLPop(string listId, int timeOutSecs); - byte[][] BLPop(string[] listIds, int timeOutSecs); - byte[] BLPopValue(string listId, int timeOutSecs); - byte[][] BLPopValue(string[] listIds, int timeOutSecs); - byte[][] BRPop(string listId, int timeOutSecs); - byte[][] BRPop(string[] listIds, int timeOutSecs); - byte[] RPopLPush(string fromListId, string toListId); - byte[] BRPopValue(string listId, int timeOutSecs); + void LSet(string listId, int listIndex, byte[] value); + byte[] LPop(string listId); + byte[] RPop(string listId); + byte[][] BLPop(string listId, int timeOutSecs); + byte[][] BLPop(string[] listIds, int timeOutSecs); + byte[] BLPopValue(string listId, int timeOutSecs); + byte[][] BLPopValue(string[] listIds, int timeOutSecs); + byte[][] BRPop(string listId, int timeOutSecs); + byte[][] BRPop(string[] listIds, int timeOutSecs); + byte[] RPopLPush(string fromListId, string toListId); + byte[] BRPopValue(string listId, int timeOutSecs); byte[][] BRPopValue(string[] listIds, int timeOutSecs); byte[] BRPopLPush(string fromListId, string toListId, int timeOutSecs); - //Redis Set operations - byte[][] SMembers(string setId); - long SAdd(string setId, byte[] value); - long SAdd(string setId, byte[][] value); - long SRem(string setId, byte[] value); - byte[] SPop(string setId); - void SMove(string fromSetId, string toSetId, byte[] value); - long SCard(string setId); - long SIsMember(string setId, byte[] value); - byte[][] SInter(params string[] setIds); - void SInterStore(string intoSetId, params string[] setIds); - byte[][] SUnion(params string[] setIds); - void SUnionStore(string intoSetId, params string[] setIds); - byte[][] SDiff(string fromSetId, params string[] withSetIds); - void SDiffStore(string intoSetId, string fromSetId, params string[] withSetIds); - byte[] SRandMember(string setId); + //Redis Set operations + byte[][] SMembers(string setId); + long SAdd(string setId, byte[] value); + long SAdd(string setId, byte[][] value); + long SRem(string setId, byte[] value); + byte[] SPop(string setId); + void SMove(string fromSetId, string toSetId, byte[] value); + long SCard(string setId); + long SIsMember(string setId, byte[] value); + byte[][] SInter(params string[] setIds); + void SInterStore(string intoSetId, params string[] setIds); + byte[][] SUnion(params string[] setIds); + void SUnionStore(string intoSetId, params string[] setIds); + byte[][] SDiff(string fromSetId, params string[] withSetIds); + void SDiffStore(string intoSetId, string fromSetId, params string[] withSetIds); + byte[] SRandMember(string setId); - //Redis Sorted Set operations - long ZAdd(string setId, double score, byte[] value); - long ZAdd(string setId, long score, byte[] value); - long ZRem(string setId, byte[] value); - double ZIncrBy(string setId, double incrBy, byte[] value); - double ZIncrBy(string setId, long incrBy, byte[] value); - long ZRank(string setId, byte[] value); - long ZRevRank(string setId, byte[] value); - byte[][] ZRange(string setId, int min, int max); - byte[][] ZRangeWithScores(string setId, int min, int max); - byte[][] ZRevRange(string setId, int min, int max); - byte[][] ZRevRangeWithScores(string setId, int min, int max); - byte[][] ZRangeByScore(string setId, double min, double max, int? skip, int? take); - byte[][] ZRangeByScore(string setId, long min, long max, int? skip, int? take); - byte[][] ZRangeByScoreWithScores(string setId, double min, double max, int? skip, int? take); - byte[][] ZRangeByScoreWithScores(string setId, long min, long max, int? skip, int? take); - byte[][] ZRevRangeByScore(string setId, double min, double max, int? skip, int? take); - byte[][] ZRevRangeByScore(string setId, long min, long max, int? skip, int? take); - byte[][] ZRevRangeByScoreWithScores(string setId, double min, double max, int? skip, int? take); - byte[][] ZRevRangeByScoreWithScores(string setId, long min, long max, int? skip, int? take); - long ZRemRangeByRank(string setId, int min, int max); - long ZRemRangeByScore(string setId, double fromScore, double toScore); - long ZRemRangeByScore(string setId, long fromScore, long toScore); - long ZCard(string setId); - double ZScore(string setId, byte[] value); - long ZUnionStore(string intoSetId, params string[] setIds); - long ZInterStore(string intoSetId, params string[] setIds); - byte[][] ZRangeByLex(string setId, string min, string max, int? skip = null, int? take = null); - long ZLexCount(string setId, string min, string max); - long ZRemRangeByLex(string setId, string min, string max); + //Redis Sorted Set operations + long ZAdd(string setId, double score, byte[] value); + long ZAdd(string setId, long score, byte[] value); + long ZRem(string setId, byte[] value); + double ZIncrBy(string setId, double incrBy, byte[] value); + double ZIncrBy(string setId, long incrBy, byte[] value); + long ZRank(string setId, byte[] value); + long ZRevRank(string setId, byte[] value); + byte[][] ZRange(string setId, int min, int max); + byte[][] ZRangeWithScores(string setId, int min, int max); + byte[][] ZRevRange(string setId, int min, int max); + byte[][] ZRevRangeWithScores(string setId, int min, int max); + byte[][] ZRangeByScore(string setId, double min, double max, int? skip, int? take); + byte[][] ZRangeByScore(string setId, long min, long max, int? skip, int? take); + byte[][] ZRangeByScoreWithScores(string setId, double min, double max, int? skip, int? take); + byte[][] ZRangeByScoreWithScores(string setId, long min, long max, int? skip, int? take); + byte[][] ZRevRangeByScore(string setId, double min, double max, int? skip, int? take); + byte[][] ZRevRangeByScore(string setId, long min, long max, int? skip, int? take); + byte[][] ZRevRangeByScoreWithScores(string setId, double min, double max, int? skip, int? take); + byte[][] ZRevRangeByScoreWithScores(string setId, long min, long max, int? skip, int? take); + long ZRemRangeByRank(string setId, int min, int max); + long ZRemRangeByScore(string setId, double fromScore, double toScore); + long ZRemRangeByScore(string setId, long fromScore, long toScore); + long ZCard(string setId); + double ZScore(string setId, byte[] value); + long ZUnionStore(string intoSetId, params string[] setIds); + long ZInterStore(string intoSetId, params string[] setIds); + byte[][] ZRangeByLex(string setId, string min, string max, int? skip = null, int? take = null); + long ZLexCount(string setId, string min, string max); + long ZRemRangeByLex(string setId, string min, string max); - //Redis Hash operations - long HSet(string hashId, byte[] key, byte[] value); - void HMSet(string hashId, byte[][] keys, byte[][] values); - long HSetNX(string hashId, byte[] key, byte[] value); - long HIncrby(string hashId, byte[] key, int incrementBy); - double HIncrbyFloat(string hashId, byte[] key, double incrementBy); - byte[] HGet(string hashId, byte[] key); - byte[][] HMGet(string hashId, params byte[][] keysAndArgs); - long HDel(string hashId, byte[] key); - long HExists(string hashId, byte[] key); - long HLen(string hashId); - byte[][] HKeys(string hashId); - byte[][] HVals(string hashId); - byte[][] HGetAll(string hashId); + //Redis Hash operations + long HSet(string hashId, byte[] key, byte[] value); + void HMSet(string hashId, byte[][] keys, byte[][] values); + long HSetNX(string hashId, byte[] key, byte[] value); + long HIncrby(string hashId, byte[] key, int incrementBy); + double HIncrbyFloat(string hashId, byte[] key, double incrementBy); + byte[] HGet(string hashId, byte[] key); + byte[][] HMGet(string hashId, params byte[][] keysAndArgs); + long HDel(string hashId, byte[] key); + long HExists(string hashId, byte[] key); + long HLen(string hashId); + byte[][] HKeys(string hashId); + byte[][] HVals(string hashId); + byte[][] HGetAll(string hashId); - //Redis Pub/Sub operations - void Watch(params string[] keys); - void UnWatch(); - long Publish(string toChannel, byte[] message); - byte[][] Subscribe(params string[] toChannels); - byte[][] UnSubscribe(params string[] toChannels); - byte[][] PSubscribe(params string[] toChannelsMatchingPatterns); - byte[][] PUnSubscribe(params string[] toChannelsMatchingPatterns); - byte[][] ReceiveMessages(); + //Redis Pub/Sub operations + void Watch(params string[] keys); + void UnWatch(); + long Publish(string toChannel, byte[] message); + byte[][] Subscribe(params string[] toChannels); + byte[][] UnSubscribe(params string[] toChannels); + byte[][] PSubscribe(params string[] toChannelsMatchingPatterns); + byte[][] PUnSubscribe(params string[] toChannelsMatchingPatterns); + byte[][] ReceiveMessages(); IRedisSubscription CreateSubscription(); //Redis LUA support - long EvalInt(string luaBody, int numberOfKeys, params byte[][] keysAndArgs); - long EvalShaInt(string sha1, int numberOfKeys, params byte[][] keysAndArgs); + long EvalInt(string luaBody, int numberOfKeys, params byte[][] keysAndArgs); + long EvalShaInt(string sha1, int numberOfKeys, params byte[][] keysAndArgs); string EvalStr(string luaBody, int numberOfKeys, params byte[][] keysAndArgs); string EvalShaStr(string sha1, int numberOfKeys, params byte[][] keysAndArgs); byte[][] Eval(string luaBody, int numberOfKeys, params byte[][] keysAndArgs); @@ -209,8 +209,8 @@ public interface IRedisNativeClient string CalculateSha1(string luaBody); byte[][] ScriptExists(params byte[][] sha1Refs); - void ScriptFlush(); - void ScriptKill(); - byte[] ScriptLoad(string body); - } + void ScriptFlush(); + void ScriptKill(); + byte[] ScriptLoad(string body); + } } diff --git a/src/ServiceStack.Interfaces/Redis/IRedisSet.cs b/src/ServiceStack.Interfaces/Redis/IRedisSet.cs index c00c7fda86f..5c9d386f86b 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisSet.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisSet.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -15,19 +15,19 @@ namespace ServiceStack.Redis { - public interface IRedisSet - : ICollection, IHasStringId - { - List GetRangeFromSortedSet(int startingFrom, int endingAt); - HashSet GetAll(); - string Pop(); - void Move(string value, IRedisSet toSet); - HashSet Intersect(params IRedisSet[] withSets); - void StoreIntersect(params IRedisSet[] withSets); - HashSet Union(params IRedisSet[] withSets); - void StoreUnion(params IRedisSet[] withSets); - HashSet Diff(IRedisSet[] withSets); - void StoreDiff(IRedisSet fromSet, params IRedisSet[] withSets); - string GetRandomEntry(); - } + public interface IRedisSet + : ICollection, IHasStringId + { + List GetRangeFromSortedSet(int startingFrom, int endingAt); + HashSet GetAll(); + string Pop(); + void Move(string value, IRedisSet toSet); + HashSet Intersect(params IRedisSet[] withSets); + void StoreIntersect(params IRedisSet[] withSets); + HashSet Union(params IRedisSet[] withSets); + void StoreUnion(params IRedisSet[] withSets); + HashSet Diff(IRedisSet[] withSets); + void StoreDiff(IRedisSet fromSet, params IRedisSet[] withSets); + string GetRandomEntry(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/IRedisSortedSet.cs b/src/ServiceStack.Interfaces/Redis/IRedisSortedSet.cs index 7f87e627541..8e588c4f1fb 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisSortedSet.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisSortedSet.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -15,23 +15,23 @@ namespace ServiceStack.Redis { - public interface IRedisSortedSet - : ICollection, IHasStringId - { - List GetAll(); - List GetRange(int startingRank, int endingRank); - List GetRangeByScore(string fromStringScore, string toStringScore); - List GetRangeByScore(string fromStringScore, string toStringScore, int? skip, int? take); - List GetRangeByScore(double fromScore, double toScore); - List GetRangeByScore(double fromScore, double toScore, int? skip, int? take); - void RemoveRange(int fromRank, int toRank); - void RemoveRangeByScore(double fromScore, double toScore); - void StoreFromIntersect(params IRedisSortedSet[] ofSets); - void StoreFromUnion(params IRedisSortedSet[] ofSets); - long GetItemIndex(string value); - double GetItemScore(string value); - void IncrementItemScore(string value, double incrementByScore); - string PopItemWithHighestScore(); - string PopItemWithLowestScore(); - } + public interface IRedisSortedSet + : ICollection, IHasStringId + { + List GetAll(); + List GetRange(int startingRank, int endingRank); + List GetRangeByScore(string fromStringScore, string toStringScore); + List GetRangeByScore(string fromStringScore, string toStringScore, int? skip, int? take); + List GetRangeByScore(double fromScore, double toScore); + List GetRangeByScore(double fromScore, double toScore, int? skip, int? take); + void RemoveRange(int fromRank, int toRank); + void RemoveRangeByScore(double fromScore, double toScore); + void StoreFromIntersect(params IRedisSortedSet[] ofSets); + void StoreFromUnion(params IRedisSortedSet[] ofSets); + long GetItemIndex(string value); + double GetItemScore(string value); + void IncrementItemScore(string value, double incrementByScore); + string PopItemWithHighestScore(); + string PopItemWithLowestScore(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/IRedisSubscription.cs b/src/ServiceStack.Interfaces/Redis/IRedisSubscription.cs index 35f88c6f7b7..316dd58afcb 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisSubscription.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisSubscription.cs @@ -2,43 +2,43 @@ namespace ServiceStack.Redis { - public interface IRedisSubscription - : IDisposable - { - /// - /// The number of active subscriptions this client has - /// - long SubscriptionCount { get; } - - /// - /// Registered handler called after client *Subscribes* to each new channel - /// - Action OnSubscribe { get; set; } - - /// - /// Registered handler called when each message is received - /// - Action OnMessage { get; set; } + public interface IRedisSubscription + : IDisposable + { + /// + /// The number of active subscriptions this client has + /// + long SubscriptionCount { get; } - /// - /// Registered handler called when each channel is unsubscribed - /// - Action OnUnSubscribe { get; set; } + /// + /// Registered handler called after client *Subscribes* to each new channel + /// + Action OnSubscribe { get; set; } - /// - /// Subscribe to channels by name - /// - /// - void SubscribeToChannels(params string[] channels); + /// + /// Registered handler called when each message is received + /// + Action OnMessage { get; set; } - /// - /// Subscribe to channels matching the supplied patterns - /// - /// - void SubscribeToChannelsMatching(params string[] patterns); - - void UnSubscribeFromAllChannels(); - void UnSubscribeFromChannels(params string[] channels); - void UnSubscribeFromChannelsMatching(params string[] patterns); - } + /// + /// Registered handler called when each channel is unsubscribed + /// + Action OnUnSubscribe { get; set; } + + /// + /// Subscribe to channels by name + /// + /// + void SubscribeToChannels(params string[] channels); + + /// + /// Subscribe to channels matching the supplied patterns + /// + /// + void SubscribeToChannelsMatching(params string[] patterns); + + void UnSubscribeFromAllChannels(); + void UnSubscribeFromChannels(params string[] channels); + void UnSubscribeFromChannelsMatching(params string[] patterns); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/IRedisTransaction.cs b/src/ServiceStack.Interfaces/Redis/IRedisTransaction.cs index a7ee9701274..4a95924319a 100644 --- a/src/ServiceStack.Interfaces/Redis/IRedisTransaction.cs +++ b/src/ServiceStack.Interfaces/Redis/IRedisTransaction.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: @@ -18,10 +18,10 @@ namespace ServiceStack.Redis /// /// Interface to redis transaction /// - public interface IRedisTransaction + public interface IRedisTransaction : IRedisTransactionBase, IRedisQueueableOperation, IDisposable - { - bool Commit(); - void Rollback(); - } + { + bool Commit(); + void Rollback(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipeline.cs b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipeline.cs index dc0395a6c5a..fd5748c7aa8 100644 --- a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipeline.cs +++ b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipeline.cs @@ -1,9 +1,9 @@ namespace ServiceStack.Redis.Pipeline { - /// - /// Interface to redis pipeline - /// - public interface IRedisPipeline : IRedisPipelineShared, IRedisQueueableOperation - { - } + /// + /// Interface to redis pipeline + /// + public interface IRedisPipeline : IRedisPipelineShared, IRedisQueueableOperation + { + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipelineShared.cs b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipelineShared.cs index 47b97496f55..306cea18ac1 100644 --- a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipelineShared.cs +++ b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisPipelineShared.cs @@ -2,12 +2,12 @@ namespace ServiceStack.Redis.Pipeline { - /// - /// Pipeline interface shared by typed and non-typed pipelines - /// - public interface IRedisPipelineShared : IDisposable, IRedisQueueCompletableOperation - { - void Flush(); - bool Replay(); - } + /// + /// Pipeline interface shared by typed and non-typed pipelines + /// + public interface IRedisPipelineShared : IDisposable, IRedisQueueCompletableOperation + { + void Flush(); + bool Replay(); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueCompletableOperation.cs b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueCompletableOperation.cs index 2daaa0d9f95..9749114c9dd 100644 --- a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueCompletableOperation.cs +++ b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueCompletableOperation.cs @@ -3,18 +3,18 @@ namespace ServiceStack.Redis.Pipeline { - /// - /// Interface to operations that allow queued commands to be completed - /// - public interface IRedisQueueCompletableOperation - { - void CompleteVoidQueuedCommand(Action voidReadCommand); - void CompleteIntQueuedCommand(Func intReadCommand); - void CompleteLongQueuedCommand(Func longReadCommand); - void CompleteBytesQueuedCommand(Func bytesReadCommand); - void CompleteMultiBytesQueuedCommand(Func multiBytesReadCommand); - void CompleteStringQueuedCommand(Func stringReadCommand); - void CompleteMultiStringQueuedCommand(Func> multiStringReadCommand); - void CompleteDoubleQueuedCommand(Func doubleReadCommand); - } + /// + /// Interface to operations that allow queued commands to be completed + /// + public interface IRedisQueueCompletableOperation + { + void CompleteVoidQueuedCommand(Action voidReadCommand); + void CompleteIntQueuedCommand(Func intReadCommand); + void CompleteLongQueuedCommand(Func longReadCommand); + void CompleteBytesQueuedCommand(Func bytesReadCommand); + void CompleteMultiBytesQueuedCommand(Func multiBytesReadCommand); + void CompleteStringQueuedCommand(Func stringReadCommand); + void CompleteMultiStringQueuedCommand(Func> multiStringReadCommand); + void CompleteDoubleQueuedCommand(Func doubleReadCommand); + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueableOperation.cs b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueableOperation.cs index b57ad66fb58..a5add01c44a 100644 --- a/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueableOperation.cs +++ b/src/ServiceStack.Interfaces/Redis/Pipeline/IRedisQueueableOperation.cs @@ -3,47 +3,47 @@ namespace ServiceStack.Redis.Pipeline { - /// - /// interface to operation that can queue commands - /// - public interface IRedisQueueableOperation - { - void QueueCommand(Action command); - void QueueCommand(Action command, Action onSuccessCallback); - void QueueCommand(Action command, Action onSuccessCallback, Action onErrorCallback); - - void QueueCommand(Func command); - void QueueCommand(Func command, Action onSuccessCallback); - void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); - - void QueueCommand(Func command); - void QueueCommand(Func command, Action onSuccessCallback); - void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); - - void QueueCommand(Func command); - void QueueCommand(Func command, Action onSuccessCallback); - void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); - - void QueueCommand(Func command); - void QueueCommand(Func command, Action onSuccessCallback); - void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); - - void QueueCommand(Func command); - void QueueCommand(Func command, Action onSuccessCallback); - void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); + /// + /// interface to operation that can queue commands + /// + public interface IRedisQueueableOperation + { + void QueueCommand(Action command); + void QueueCommand(Action command, Action onSuccessCallback); + void QueueCommand(Action command, Action onSuccessCallback, Action onErrorCallback); + + void QueueCommand(Func command); + void QueueCommand(Func command, Action onSuccessCallback); + void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); + + void QueueCommand(Func command); + void QueueCommand(Func command, Action onSuccessCallback); + void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); + + void QueueCommand(Func command); + void QueueCommand(Func command, Action onSuccessCallback); + void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); + + void QueueCommand(Func command); + void QueueCommand(Func command, Action onSuccessCallback); + void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); + + void QueueCommand(Func command); + void QueueCommand(Func command, Action onSuccessCallback); + void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); void QueueCommand(Func command); void QueueCommand(Func command, Action onSuccessCallback); void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); - void QueueCommand(Func command); - void QueueCommand(Func command, Action onSuccessCallback); - void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); + void QueueCommand(Func command); + void QueueCommand(Func command, Action onSuccessCallback); + void QueueCommand(Func command, Action onSuccessCallback, Action onErrorCallback); - void QueueCommand(Func> command); - void QueueCommand(Func> command, Action> onSuccessCallback); - void QueueCommand(Func> command, Action> onSuccessCallback, Action onErrorCallback); - - } + void QueueCommand(Func> command); + void QueueCommand(Func> command, Action> onSuccessCallback); + void QueueCommand(Func> command, Action> onSuccessCallback, Action onErrorCallback); + + } } \ No newline at end of file diff --git a/src/ServiceStack.Interfaces/Redis/RedisKeyType.cs b/src/ServiceStack.Interfaces/Redis/RedisKeyType.cs index b1545787ea3..aae919349f8 100644 --- a/src/ServiceStack.Interfaces/Redis/RedisKeyType.cs +++ b/src/ServiceStack.Interfaces/Redis/RedisKeyType.cs @@ -1,5 +1,5 @@ // -// https://github.com/mythz/ServiceStack.Redis +// https://github.com/ServiceStack/ServiceStack.Redis // ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system // // Authors: