Interface IWorkflowHistoryGraphStore

Namespace

JD.AI.Workflows.History

Assembly

JD.AI.Workflows.dll

public interface IWorkflowHistoryGraphStore

Methods

GetEdgesForWorkflowAsync(string, CancellationToken)

Task<IReadOnlyList<WorkflowHistoryEdge>> GetEdgesForWorkflowAsync(string workflowName, CancellationToken ct = default)

Parameters

workflowName string

ct CancellationToken

Returns

Task<IReadOnlyList<WorkflowHistoryEdge>>

GetNodeAsync(string, CancellationToken)

Task<WorkflowHistoryNode?> GetNodeAsync(string fingerprint, CancellationToken ct = default)

Parameters

fingerprint string

ct CancellationToken

Returns

Task<WorkflowHistoryNode>

GetTopEdgesFromAsync(string, int, CancellationToken)

Task<IReadOnlyList<WorkflowHistoryEdge>> GetTopEdgesFromAsync(string fingerprint, int topN = 10, CancellationToken ct = default)

Parameters

fingerprint string

topN int

ct CancellationToken

Returns

Task<IReadOnlyList<WorkflowHistoryEdge>>

LoadAsync(CancellationToken)

Task<WorkflowHistoryGraph> LoadAsync(CancellationToken ct = default)

Parameters

ct CancellationToken

Returns

Task<WorkflowHistoryGraph>

SaveAsync(WorkflowHistoryGraph, CancellationToken)

Task SaveAsync(WorkflowHistoryGraph graph, CancellationToken ct = default)

Parameters

graph WorkflowHistoryGraph

ct CancellationToken

Returns

Task

SearchNodesAsync(string, int, CancellationToken)

Task<IReadOnlyList<WorkflowHistoryNode>> SearchNodesAsync(string query, int limit = 20, CancellationToken ct = default)

Parameters

query string

limit int

ct CancellationToken

Returns

Task<IReadOnlyList<WorkflowHistoryNode>>

UpsertEdgeAsync(WorkflowHistoryEdge, CancellationToken)

Task UpsertEdgeAsync(WorkflowHistoryEdge edge, CancellationToken ct = default)

Parameters

edge WorkflowHistoryEdge

ct CancellationToken

Returns

Task

UpsertNodeAsync(WorkflowHistoryNode, CancellationToken)

Task UpsertNodeAsync(WorkflowHistoryNode node, CancellationToken ct = default)

Parameters

node WorkflowHistoryNode

ct CancellationToken

Returns

Task