NotifyingMcpTaskStoreBase

CloudNimble.McpEssentials.Core.Tasks.NotifyingMcpTaskStoreBase

protected McpTaskStoreBase(System.Func<string> getCurrentUserId)

protected McpTaskStoreBase(string userId)

protected McpTaskStoreBase(System.Func<System.Security.Claims.ClaimsPrincipal> getPrincipal)

public Object()

public virtual bool AutoSweep { get; set; }

public virtual long DefaultPollIntervalMs { get; set; }

public virtual System.Nullable<System.TimeSpan> DefaultTimeToLive { get; set; }

protected System.Func<string> GetCurrentUserId { get; }

protected long LastSweepTicks { get; set; }

public virtual bool ServeAndDrop { get; set; }

public virtual System.TimeSpan SweepInterval { get; set; }

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> CreateTaskAsync(System.Threading.CancellationToken cancellationToken = null)

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> CreateTaskAsync(System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> CreateTaskCoreAsync(string userId, System.Threading.CancellationToken cancellationToken)

public virtual void Dispose()

public virtual bool Equals(object obj)

public static bool Equals(object objA, object objB)

public virtual int GetHashCode()

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> GetTaskAsync(string taskId, System.Threading.CancellationToken cancellationToken = null)

public virtual System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> GetTaskAsync(string taskId, System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task<ModelContextProtocol.Extensions.Tasks.McpTaskInfo> GetTaskCoreAsync(string taskId, string userId, System.Threading.CancellationToken cancellationToken)

public System.Type GetType()

public static string GetUserId(System.Security.Claims.ClaimsPrincipal principal)

protected virtual System.DateTimeOffset GetUtcNow()

protected virtual bool IsOwnedBy(string ownerUserId, string currentUserId)

protected internal object MemberwiseClone()

protected virtual string NewTaskId()

protected virtual System.Nullable<System.TimeSpan> NormalizeTimeToLive(System.Nullable<System.TimeSpan> timeToLive)

protected virtual void OnInputResponseReceived(string taskId, string requestId, ModelContextProtocol.Protocol.InputResponse response)

protected virtual System.Threading.Tasks.Task PulseSweepAsync(System.DateTimeOffset now, System.Threading.CancellationToken cancellationToken)

public static bool ReferenceEquals(object objA, object objB)

protected virtual string RequireUserId()

protected virtual string RequireUserId(System.Security.Claims.ClaimsPrincipal user)

public virtual System.Threading.Tasks.Task ResolveInputRequestsAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputResponse> inputResponses, System.Threading.CancellationToken cancellationToken = null)

public virtual System.Threading.Tasks.Task ResolveInputRequestsAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputResponse> inputResponses, System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task ResolveInputRequestsCoreAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputResponse> inputResponses, string userId, System.Threading.CancellationToken cancellationToken)

public virtual System.Threading.Tasks.Task<bool> SetCancelledAsync(string taskId, System.Threading.CancellationToken cancellationToken = null)

public virtual System.Threading.Tasks.Task<bool> SetCancelledAsync(string taskId, System.Security.Claims.ClaimsPrincipal user, System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task<bool> SetCancelledCoreAsync(string taskId, string userId, System.Threading.CancellationToken cancellationToken)

public virtual System.Threading.Tasks.Task SetCompletedAsync(string taskId, System.Text.Json.JsonElement result, System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task SetCompletedCoreAsync(string taskId, System.Text.Json.JsonElement result, System.Threading.CancellationToken cancellationToken)

public virtual System.Threading.Tasks.Task SetFailedAsync(string taskId, System.Text.Json.JsonElement error, System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task SetFailedCoreAsync(string taskId, System.Text.Json.JsonElement error, System.Threading.CancellationToken cancellationToken)

public virtual System.Threading.Tasks.Task SetInputRequestsAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputRequest> inputRequests, System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task SetInputRequestsCoreAsync(string taskId, System.Collections.Generic.IDictionary<string, ModelContextProtocol.Protocol.InputRequest> inputRequests, System.Threading.CancellationToken cancellationToken)

protected virtual bool ShouldDiscard(CloudNimble.McpEssentials.Core.Tasks.StoredMcpTask task, System.DateTimeOffset now)

public virtual System.Threading.Tasks.Task SweepExpiredAsync(System.Threading.CancellationToken cancellationToken = null)

protected abstract System.Threading.Tasks.Task SweepExpiredCoreAsync(System.DateTimeOffset now, System.Threading.CancellationToken cancellationToken)

public virtual string ToString()

protected virtual bool TryClaimSweep(System.DateTimeOffset now)

public virtual System.Action<ModelContextProtocol.Extensions.Tasks.InputResponseReceivedEventArgs> InputResponseReceived