Interface ICosmosDbService

Namespace

FoundationaLLM.State.Interfaces

Assembly

FoundationaLLM.State.dll

Provides methods for interacting with the Cosmos DB service.

public interface ICosmosDbService

Extension Methods

ObjectExtensions.GetPropertyValues(object, List<string>)

Methods

GetLongRunningOperation(string, CancellationToken)

Retrieves a long-running operation by its identifier.

Task<LongRunningOperation> GetLongRunningOperation(string id, CancellationToken cancellationToken = default)

Parameters

id string

The long-running operation identifier.

cancellationToken CancellationToken

Returns

Task<LongRunningOperation>

GetLongRunningOperationLogEntries(string, CancellationToken)

Retrieves all log entries for a long-running operation.

Task<List<LongRunningOperationLogEntry>> GetLongRunningOperationLogEntries(string operationId, CancellationToken cancellationToken = default)

Parameters

operationId string

The long-running operation identifier.

cancellationToken CancellationToken

Returns

Task<List<LongRunningOperationLogEntry>>

GetLongRunningOperationResult(string, CancellationToken)

Retrieves the result of a long-running operation.

Task<JsonDocument?> GetLongRunningOperationResult(string operationId, CancellationToken cancellationToken = default)

Parameters

operationId string

The long-running operation identifier.

cancellationToken CancellationToken

Returns

Task<JsonDocument>

GetLongRunningOperations(CancellationToken)

Retrieves all long-running operations.

Task<List<LongRunningOperation>> GetLongRunningOperations(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task<List<LongRunningOperation>>

UpsertLongRunningOperation(LongRunningOperation, CancellationToken)

Inserts or updates a long-running operation and creates a log entry.

Task<LongRunningOperation> UpsertLongRunningOperation(LongRunningOperation operation, CancellationToken cancellationToken = default)

Parameters

operation LongRunningOperation

The long-running operation to insert or update.

cancellationToken CancellationToken

Returns

Task<LongRunningOperation>

UpsertLongRunningOperationResult(dynamic, CancellationToken)

Inserts or updates the result of a long-running operation.

Task<object?> UpsertLongRunningOperationResult(dynamic operationResult, CancellationToken cancellationToken = default)

Parameters

operationResult dynamic

The operation result to insert or update.

cancellationToken CancellationToken

Returns

Task<object>