ECommon by tangxuehua

API Diff between 1.4.2 and 2.5.1

246 Additions 145 Removals

ECommon.Components

public interface IObjectContainer
- void Build()
- void Register<TService, TImplementer>(string serviceName = null, LifeStyle life = 1) where TImplementer : TService
- void RegisterInstance<TService, TImplementer>(TImplementer instance, string serviceName = null) where TImplementer : TService
- void RegisterType(Type implementationType, string serviceName = null, LifeStyle life = 1)
- void RegisterType(Type serviceType, Type implementationType, string serviceName = null, LifeStyle life = 1)
- void Register<TService, TImplementer>(LifeStyle life = 1) where TImplementer : TService
- void RegisterInstance<TService, TImplementer>(TImplementer instance) where TImplementer : TService
- void RegisterType(Type implementationType, LifeStyle life = 1)
- void RegisterType(Type serviceType, Type implementationType, LifeStyle life = 1)
- TService ResolveNamed<TService>(string serviceName)
- object ResolveNamed(string serviceName, Type serviceType)
- bool TryResolve<TService>(out TService instance)
- bool TryResolve(Type serviceType, out object instance)
- bool TryResolveNamed(string serviceName, Type serviceType, out object instance)
public class ObjectContainer
- public static void Build()
- public static void Register<TService, TImplementer>(string serviceName = null, LifeStyle life = 1) where TImplementer : TService
- public static void RegisterInstance<TService, TImplementer>(TImplementer instance, string serviceName = null) where TImplementer : TService
- public static void RegisterType(Type implementationType, string serviceName = null, LifeStyle life = 1)
- public static void RegisterType(Type serviceType, Type implementationType, string serviceName = null, LifeStyle life = 1)
- public static void Register<TService, TImplementer>(LifeStyle life = 1) where TImplementer : TService
- public static void RegisterInstance<TService, TImplementer>(TImplementer instance) where TImplementer : TService
- public static void RegisterType(Type implementationType, LifeStyle life = 1)
- public static void RegisterType(Type serviceType, Type implementationType, LifeStyle life = 1)
- public static TService ResolveNamed<TService>(string serviceName)
- public static object ResolveNamed(string serviceName, Type serviceType)
- public static bool TryResolve<TService>(out TService instance)
- public static bool TryResolve(Type serviceType, out object instance)
- public static bool TryResolveNamed(string serviceName, Type serviceType, out object instance)

ECommon.Configurations

public class Configuration
- public static Configuration Create()
- public Configuration BuildContainer()
- public Setting Setting { get; }
- public static Configuration Create(Setting setting = null)
- public Configuration SetDefault<TService, TImplementer>(string serviceName = null, LifeStyle life = 1) where TImplementer : TService
- public Configuration SetDefault<TService, TImplementer>(TImplementer instance, string serviceName = null) where TImplementer : TService
- public Configuration SetDefault<TService, TImplementer>(LifeStyle life = 1) where TImplementer : TService
- public Configuration SetDefault<TService, TImplementer>(TImplementer instance) where TImplementer : TService
public class Setting
- public int RetryActionDefaultPeriod { get; set; }
- public TcpConfiguration TcpConfiguration { get; set; }
- public Setting()

ECommon.Extensions

public static class BinaryWriterExtensions
public static class ConcurrentDictionaryExtensions
- public static bool Remove<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> dict, TKey key)
- public static void Remove<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> dict, TKey key)
public static class EndPointExtensions
public static class RemotingClientUtils
public static class StringExtensions
public static class TaskExtensions
- public static Task TimeoutAfter(this Task task, int millisecondsDelay)
- public static Task<TResult> TimeoutAfter<TResult>(this Task<TResult> task, int millisecondsDelay)

ECommon.IO

public class AsyncTaskResult
public class AsyncTaskResult<T> : AsyncTaskResult
public enum AsyncTaskStatus
public class IOException : Exception
public class IOHelper

ECommon.Remoting

public class HeaderUtil
public interface IRemotingServerMessageHandler
public interface IRequestHandlerContext
- ITcpConnection Connection { get; }
- ISocketChannel Channel { get; }
public interface IResponseHandler
public interface ISocketChannel
- Guid Id { get; }
- IPEndPoint LocalEndPoint { get; }
- IPEndPoint RemoteEndPoint { get; }
- void Close()
public class RemotingClientSetting
- public IPEndPoint LocalEndPoint
- public int ReconnectInterval
- public RemotingClientSetting()
public class RemotingMessage
- public byte[] Body { get; }
- public int Code { get; }
- public long Sequence { get; }
- public RemotingMessage(int code, long sequence, byte[] body)
public class RemotingRequest : RemotingMessage
- public byte[] Body { get; set; }
- public short Code { get; set; }
- public DateTime CreatedTime { get; set; }
- public IDictionary<string, string> Header { get; set; }
- public string Id { get; set; }
- public long Sequence { get; set; }
- public short Type { get; set; }
- public RemotingRequest()
- public RemotingRequest(short code, byte[] body, IDictionary<string, string> header = null)
- public RemotingRequest(string id, short code, long sequence, byte[] body, DateTime createdTime, IDictionary<string, string> header)
- public bool IsOneway { get; set; }
- public RemotingRequest(int code, byte[] body)
- public RemotingRequest(int code, byte[] body, bool isOneway)
- public RemotingRequest(int code, long sequence, byte[] body, bool isOneway)
public class RemotingRequestType
public class RemotingResponse : RemotingMessage
- public short RequestCode { get; set; }
- public IDictionary<string, string> RequestHeader { get; set; }
- public long RequestSequence { get; set; }
- public DateTime RequestTime { get; set; }
- public short RequestType { get; set; }
- public byte[] ResponseBody { get; set; }
- public short ResponseCode { get; set; }
- public IDictionary<string, string> ResponseHeader { get; set; }
- public DateTime ResponseTime { get; set; }
- public RemotingResponse()
- public RemotingResponse(short requestType, short requestCode, long requestSequence, DateTime requestTime, short responseCode, byte[] responseBody, DateTime responseTime, IDictionary<string, string> requestHeader, IDictionary<string, string> responseHeader)
- public RemotingResponse(int code, long sequence, byte[] body)
public class RemotingServerMessage
public class RemotingServerMessageType
public class RemotingUtil
- public static byte[] BuildRemotingServerMessage(RemotingServerMessage message)
- public static RemotingServerMessage ParseRemotingServerMessage(byte[] data)
public class ResponseFuture
- public bool SetResponse(RemotingResponse response)
- public void SetException(Exception exception)
- public void SetResponse(RemotingResponse response)
public class SocketChannel : ISocketChannel
- public Guid Id { get; }
- public IPEndPoint LocalEndPoint { get; }
- public IPEndPoint RemoteEndPoint { get; }
- public SocketChannel(ITcpConnection connection)
- public void Close()
public class SocketRemotingClient : ISocketClientEventListener
- public IBufferPool BufferPool { get; }
- public ClientSocket ClientSocket { get; }
- public bool IsConnected { get; }
- public EndPoint LocalEndPoint { get; }
- public EndPoint ServerEndPoint { get; }
- public SocketRemotingClient()
- public SocketRemotingClient(EndPoint serverEndPoint, SocketSetting setting = null, EndPoint localEndPoint = null)
- public SocketRemotingClient(string name, IPEndPoint serverEndPoint, RemotingClientSetting setting = null, ISocketClientEventListener eventListener = null)
- public void InvokeOneway(RemotingRequest request)
- public void InvokeOneway(RemotingRequest request, int timeoutMillis)
- public void InvokeWithCallback(RemotingRequest request)
- public SocketRemotingClient RegisterConnectionEventListener(IConnectionEventListener listener)
- public SocketRemotingClient RegisterRemotingServerMessageHandler(int messageCode, IRemotingServerMessageHandler messageHandler)
- public SocketRemotingClient RegisterResponseHandler(int requestCode, IResponseHandler responseHandler)
- public SocketRemotingClient Start()
- public void Start()
public class SocketRemotingServer
- public IBufferPool BufferPool { get; }
- public ServerSocket ServerSocket { get; }
- public SocketRemotingServer()
- public SocketRemotingServer(string name, IPEndPoint listeningEndPoint, SocketSetting setting = null)
- public IList<ITcpConnection> GetAllConnections()
- public void PushMessageToAllConnections(RemotingServerMessage message)
- public void PushMessageToConnection(Guid connectionId, byte[] message)
- public SocketRemotingServer RegisterConnectionEventListener(IConnectionEventListener listener)
- public SocketRemotingServer RegisterRequestHandler(int requestCode, IRequestHandler requestHandler)
- public SocketRemotingServer Shutdown()
- public SocketRemotingServer Start()
- public SocketRemotingServer(string name, IPEndPoint serverEndPoint, ISocketServerEventListener eventListener = null)
- public void RegisterRequestHandler(int requestCode, IRequestHandler requestHandler)
- public void Shutdown()
- public void Start()
public class SocketRequestHandlerContext : IRequestHandlerContext
- public ITcpConnection Connection { get; }
- public ISocketChannel Channel { get; }
- public SocketRequestHandlerContext(ITcpConnection connection, Action<byte[]> sendReplyAction)
- public SocketRequestHandlerContext(ITcpConnection connection, Action<byte[]> sendReplyAction)

ECommon.Remoting.Exceptions

public class RemotingRequestException : Exception
- public RemotingRequestException(EndPoint serverEndPoint, RemotingRequest request, string errorMessage)
- public RemotingRequestException(EndPoint serverEndPoint, RemotingRequest request, Exception exception)
- public RemotingRequestException(IPEndPoint serverEndPoint, RemotingRequest request, string errorMessage)
- public RemotingRequestException(IPEndPoint serverEndPoint, RemotingRequest request, Exception exception)
public class RemotingServerUnAvailableException : Exception
public class RemotingServerNotConnectedException : Exception
- public RemotingServerNotConnectedException(IPEndPoint serverEndPoint)
public class RemotingTimeoutException : Exception
- public RemotingTimeoutException(EndPoint serverEndPoint, RemotingRequest request, long timeoutMillis)
- public RemotingTimeoutException(IPEndPoint serverEndPoint, RemotingRequest request, long timeoutMillis)

ECommon.Retring

public class ActionExecutionService : IActionExecutionService
- public ActionExecutionService(ILoggerFactory loggerFactory)
- public void TryAction(string actionName, Func<bool> action, int maxRetryCount, ActionInfo nextAction)
- public bool TryRecursively(string actionName, Func<bool> action, int maxRetryCount)
public class ActionInfo
- public Func<object, bool> Action { get; }
- public object Data { get; }
- public string Name { get; }
- public ActionInfo Next { get; }
- public ActionInfo(string name, Func<object, bool> action, object data, ActionInfo next)
public interface IActionExecutionService
- void TryAction(string actionName, Func<bool> action, int maxRetryCount, ActionInfo nextAction)
- bool TryRecursively(string actionName, Func<bool> action, int maxRetryCount)

ECommon.Scheduling

public interface IScheduleService
- void StartTask(string name, Action action, int dueTime, int period)
- void StopTask(string name)
- int ScheduleTask(string actionName, Action action, int dueTime, int period)
- void ShutdownTask(int taskId)
public class ScheduleService : IScheduleService
- public void StartTask(string name, Action action, int dueTime, int period)
- public void StopTask(string name)
- public int ScheduleTask(string actionName, Action action, int dueTime, int period)
- public void ShutdownTask(int taskId)

ECommon.Socketing

public class ClientSocket
public interface IConnectionEventListener
public interface ITcpConnection
public class ServerSocket
public class SocketSetting
public class SocketUtils
public class TcpConnection : ITcpConnection
public interface ISocketClientEventListener
- void OnConnectionClosed(ITcpConnectionInfo connectionInfo, SocketError socketError)
- void OnConnectionEstablished(ITcpConnectionInfo connectionInfo)
- void OnConnectionFailed(ITcpConnectionInfo connectionInfo, SocketError socketError)
public interface ISocketServerEventListener
- void OnConnectionAccepted(ITcpConnectionInfo connectionInfo)
- void OnConnectionClosed(ITcpConnectionInfo connectionInfo, SocketError socketError)

ECommon.Socketing.BufferManagement

public interface IBufferPool : IPool<byte[]>, IPool
public class IntelliPool<T> : IntelliPoolBase<T>
public abstract class IntelliPoolBase<T> : IPool<T>, IPool
public interface IPool
public interface IPool<T> : IPool
public interface IPoolItemCreator<T>

ECommon.Socketing.Framing

public interface IMessageFramer
public class LengthPrefixMessageFramer : IMessageFramer

ECommon.Storage

public class Chunk : IDisposable
public class ChunkFooter
public class ChunkHeader
public class ChunkManager : IDisposable
public class ChunkManagerConfig
public class ChunkReader
public class ChunkWriter
public enum FlushOption
public interface ILogRecord
public interface IStream
public struct RecordBufferReadResult
public struct RecordWriteResult

ECommon.Storage.Exceptions

public class ChunkBadDataException : Exception
public class ChunkCompleteException : Exception
public class ChunkCreateException : Exception
public class ChunkFileNotExistException : Exception
public class ChunkNotExistException : Exception
public class ChunkReadException : Exception
public class ChunkWriteException : Exception

ECommon.Storage.FileNamingStrategies

public class DefaultFileNamingStrategy : IFileNamingStrategy
public interface IFileNamingStrategy

ECommon.TcpTransport

public interface ITcpConnection : ITcpConnectionInfo
- bool IsClosed { get; }
- int SendQueueSize { get; }
- event Action<ITcpConnection, SocketError> ConnectionClosed
- void Close()
- void Close(SocketError socketError, string reason)
- void EnqueueSend(IEnumerable<ArraySegment<byte>> data)
- void ReceiveAsync(Action<ITcpConnection, IEnumerable<ArraySegment<byte>>> callback)
public interface ITcpConnectionInfo
- Guid ConnectionId { get; }
- IPEndPoint LocalEndPoint { get; }
- IPEndPoint RemoteEndPoint { get; }
public class TcpClient
- public TcpConnectionStatus ConnectionStatus { get; }
- public bool IsStopped { get; }
- public TcpClient(IPEndPoint serverEndPoint, Action<byte[]> replyHandler, ISocketClientEventListener eventListener = null)
- public TcpClient(IPEndPoint localEndPoint, IPEndPoint serverEndPoint, Action<byte[]> replyHandler, ISocketClientEventListener eventListener = null)
- public void ReconnectToServer()
- public void SendAsync(byte[] message)
- public void Start()
- public void Stop()
public class TcpClientConnector
- public TcpClientConnector()
- public ITcpConnection ConnectTo(Guid connectionId, IPEndPoint localEndPoint, IPEndPoint remoteEndPoint, Action<ITcpConnection> onConnectionEstablished = null, Action<ITcpConnection, SocketError> onConnectionFailed = null)
public class TcpConfiguration
- public int AcceptBacklogCount
- public int AcceptPoolSize
- public int BufferChunksCount
- public int ConcurrentAccepts
- public TimeSpan ConnectionTimeout
- public int ConnectPoolSize
- public int MaxSendPacketSize
- public int SendReceivePoolSize
- public int SocketBufferSize
- public int SocketCloseTimeoutMs
- public TcpConfiguration()
public class TcpConnection : TcpConnectionBase, ITcpConnection, ITcpConnectionInfo
- public Guid ConnectionId { get; }
- public int SendQueueSize { get; }
- public event Action<ITcpConnection, SocketError> ConnectionClosed
- public static ITcpConnection CreateAcceptedTcpConnection(Guid connectionId, IPEndPoint remoteEndPoint, Socket socket)
- public static ITcpConnection CreateConnectingTcpConnection(Guid connectionId, IPEndPoint localEndPoint, IPEndPoint remoteEndPoint, TcpClientConnector connector, Action<ITcpConnection> onConnectionEstablished, Action<ITcpConnection, SocketError> onConnectionFailed)
- public void Close()
- public void Close(SocketError socketError, string reason)
- public void EnqueueSend(IEnumerable<ArraySegment<byte>> data)
- public void ReceiveAsync(Action<ITcpConnection, IEnumerable<ArraySegment<byte>>> callback)
public class TcpConnectionBase
- public bool IsClosed { get; }
- public bool IsInitialized { get; }
- public IPEndPoint LocalEndPoint { get; }
- public IPEndPoint RemoteEndPoint { get; }
- public TcpConnectionBase(IPEndPoint remoteEndPoint)
- protected void InitConnectionBase(Socket socket)
- protected void NotifyClosed()
public enum TcpConnectionStatus
- ConnectionClosed = 2
- ConnectionEstablished = 0
- ConnectionFailed = 1
public class TcpServerListener
- public TcpServerListener(IPEndPoint serverEndPoint, ISocketServerEventListener eventListener, Action<ITcpConnection, byte[], Action<byte[]>> messageHandler)
- public void Start()
- public void Stop()
public class TcpStats
- public readonly int Connections
- public readonly long InSend
- public readonly TimeSpan MeasureTime
- public readonly long PendingReceived
- public readonly long PendingSend
- public readonly long ReceivedBytesSinceLastRun
- public readonly long ReceivedBytesTotal
- public readonly double ReceivingSpeed
- public readonly double SendingSpeed
- public readonly long SentBytesSinceLastRun
- public readonly long SentBytesTotal
- public TcpStats(int connections, long sentBytesTotal, long receivedBytesTotal, long sentBytesSinceLastRunSinceLastRun, long receivedBytesSinceLastRun, long pendingSend, long inSend, long pendingReceived, TimeSpan measureTime)

ECommon.TcpTransport.BufferManagement

public class BufferManager
- public static BufferManager Default { get; }
- public int AvailableBuffers { get; }
- public int ChunkSize { get; }
- public int SegmentChunksCount { get; }
- public int SegmentsCount { get; }
- public int TotalBufferSize { get; }
- public BufferManager(int segmentChunks, int chunkSize)
- public BufferManager(int segmentChunks, int chunkSize, int initialSegments)
- public BufferManager(int segmentChunks, int chunkSize, int initialSegments, bool allowedToCreateMemory)
- public static void SetDefaultBufferManager(BufferManager manager)
- public void CheckIn(ArraySegment<byte> buffer)
- public void CheckIn(IEnumerable<ArraySegment<byte>> buffersToReturn)
- public ArraySegment<byte> CheckOut()
- public IEnumerable<ArraySegment<byte>> CheckOut(int toGet)
public class BufferPool : IDisposable
- public int Capacity { get; }
- public IEnumerable<ArraySegment<byte>> EffectiveBuffers { get; }
- public byte this[int index] { get; set; }
- public int Length { get; }
- public BufferPool()
- public BufferPool(BufferManager bufferManager)
- public BufferPool(int initialBufferCount, BufferManager bufferManager)
- public void Append(byte[] data)
- public void Append(byte[] data, int offset, int count)
- public void Dispose()
- protected virtual void DisposeInternal()
- public int ReadFrom(int position, byte[] data, int offset, int count)
- public int ReadFrom(int position, ArraySegment<byte> data)
- public void SetLength(int newLength)
- public void SetLength(int newLength, bool releaseMemory)
- public byte[] ToByteArray()
- public void Write(int position, byte[] data, int offset, int count)
- public void Write(int position, ArraySegment<byte> data)
public class BufferPoolStream : Stream
- public BufferPool BufferPool { get; }
- public int Capacity { get; }
- public BufferPoolStream(BufferPool bufferPool)
- public byte[] ToArray()
public class UnableToAllocateBufferException : Exception
- public UnableToAllocateBufferException()
public class UnableToCreateMemoryException : Exception
- public UnableToCreateMemoryException()

ECommon.TcpTransport.Framing

public interface IMessageFramer
- IEnumerable<ArraySegment<byte>> FrameData(ArraySegment<byte> data)
- void RegisterMessageArrivedCallback(Action<ArraySegment<byte>> handler)
- void UnFrameData(IEnumerable<ArraySegment<byte>> data)
- void UnFrameData(ArraySegment<byte> data)
public class LengthPrefixMessageFramer : IMessageFramer
- public const int HeaderLength = 4
- public LengthPrefixMessageFramer(int maxPackageSize = 67108864)
- public IEnumerable<ArraySegment<byte>> FrameData(ArraySegment<byte> data)
- public void RegisterMessageArrivedCallback(Action<ArraySegment<byte>> handler)
- public void Reset()
- public void UnFrameData(IEnumerable<ArraySegment<byte>> data)
- public void UnFrameData(ArraySegment<byte> data)
public class LengthPrefixMessageFramerWithBufferPool
- public LengthPrefixMessageFramerWithBufferPool(BufferManager bufferManager, int maxPackageSize = 16777216)
- public IEnumerable<ArraySegment<byte>> FrameData(ArraySegment<byte> data)
- public void RegisterMessageArrivedCallback(Action<BufferPool> handler)
- public void Reset()
- public void UnFrameData(IEnumerable<ArraySegment<byte>> data)
- public void UnFrameData(ArraySegment<byte> data)
public class PackageFramingException : Exception
- public PackageFramingException()
- public PackageFramingException(string message)
- public PackageFramingException(string message, Exception innerException)
- protected PackageFramingException(SerializationInfo info, StreamingContext context)
public class StxEtxMessageFramer : IMessageFramer
- public StxEtxMessageFramer(int initialBufferSize)
- public IEnumerable<ArraySegment<byte>> FrameData(ArraySegment<byte> data)
- public void RegisterMessageArrivedCallback(Action<ArraySegment<byte>> handler)
- public void UnFrameData(IEnumerable<ArraySegment<byte>> data)
- public void UnFrameData(ArraySegment<byte> data)

ECommon.TcpTransport.Utils

public static class DumpHelper
- public static string FormatBinaryDump(ArraySegment<byte> logBulk)
public static class Empty
- public static readonly Action Action
- public static readonly byte[] ByteArray
- public static readonly object[] ObjectArray
- public static readonly string[] StringArray

ECommon.Utilities

public class BufferQueue<TMessage>
public class ByteUtil
public class ConsoleEventHandlerService : IDisposable
public class DefaultPerformanceService : IPerformanceService
public static class FlowControlUtil
public interface IPerformanceService
public static class LockUtility
- public static void Lock(object key, Action action)
public struct ObjectId : IComparable<ObjectId>, IEquatable<ObjectId>
- public static bool TryParse(string s, out ObjectId objectId)
- public static bool TryParseHexString(string s, out byte bytes)
public class PerformanceInfo
public class PerformanceServiceSetting
public class SocketUtils
- public SocketUtils()
- public static IPAddress GetLocalIPV4()