Class InMemoryAuditSink

Namespace

JD.AI.Core.Governance.Audit

Assembly

JD.AI.Core.dll

Thread-safe in-memory audit sink that stores the most recent events in a circular buffer and supports filtered queries.

public sealed class InMemoryAuditSink : IQueryableAuditSink, IAuditSink

Inheritance

object

InMemoryAuditSink

Implements

IQueryableAuditSink

IAuditSink

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

InMemoryAuditSink(int)

public InMemoryAuditSink(int capacity = 10000)

Parameters

capacity int

Maximum number of events to retain (default 10,000).

Properties

Count

Returns the total number of stored events.

public long Count { get; }

Property Value

long

Name

public string Name { get; }

Property Value

string

Methods

FlushAsync(CancellationToken)

public Task FlushAsync(CancellationToken ct = default)

Parameters

ct CancellationToken

Returns

Task

QueryAsync(AuditQuery, CancellationToken)

Queries stored audit events with optional filters. Results are returned in reverse chronological order (newest first).

public Task<AuditQueryResult> QueryAsync(AuditQuery query, CancellationToken ct = default)

Parameters

query AuditQuery

ct CancellationToken

Returns

Task<AuditQueryResult>

WriteAsync(AuditEvent, CancellationToken)

public Task WriteAsync(AuditEvent evt, CancellationToken ct = default)

Parameters

evt AuditEvent

ct CancellationToken

Returns

Task