Class LinkTraversalManagerMediated

A link traversal manager that traverses over the link queue by resolving query sources for each link, extracting additional links, and appending those to the queue.

Implements

ILinkTraversalManager

Constructors

constructor

new LinkTraversalManagerMediated(
    linkParallelizationDefault: number,
    linkParallelizationLimit: number,
    seeds: ILink[],
    linkQueue: ILinkQueue,
    aggregatedStore: IAggregatedStore,
    context: IActionContext,
    dataFactory: ComunicaDataFactory,
    bindingsFactory: BindingsFactory,
    mediatorRdfResolveHypermediaLinks: MediatorRdfResolveHypermediaLinks,
    mediatorQuerySourceDereferenceLink: MediatorQuerySourceDereferenceLink,
): LinkTraversalManagerMediated
Parameters
- linkParallelizationDefault: number
- linkParallelizationLimit: number
- seeds: ILink[]
- linkQueue: ILinkQueue
- aggregatedStore: IAggregatedStore
- context: IActionContext
- dataFactory: ComunicaDataFactory
- bindingsFactory: BindingsFactory
- mediatorRdfResolveHypermediaLinks: MediatorRdfResolveHypermediaLinks
- mediatorQuerySourceDereferenceLink: MediatorQuerySourceDereferenceLink
Returns LinkTraversalManagerMediated
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:36

Properties

`Readonly`aggregatedStore

aggregatedStore: IAggregatedStore

`Protected` `Readonly`bindingsFactory

bindingsFactory: BindingsFactory

`Protected` `Readonly`context

context: IActionContext

`Protected` `Readonly`dataFactory

dataFactory: ComunicaDataFactory

`Protected`ended

ended: boolean = false

`Protected` `Readonly`handledUrls

handledUrls: Record<string, boolean> = {}

`Protected`linkParallelization

linkParallelization: number

`Protected` `Readonly`linkParallelizationDefault

linkParallelizationDefault: number

`Protected` `Readonly`linkParallelizationLimit

linkParallelizationLimit: number

`Readonly`linkQueue

linkQueue: ILinkQueue

The queue of links to be followed.

`Protected`linksDereferencing

linksDereferencing: Set<AbortController> = ...

`Protected` `Readonly`mediatorQuerySourceDereferenceLink

mediatorQuerySourceDereferenceLink: MediatorQuerySourceDereferenceLink

`Protected` `Readonly`mediatorRdfResolveHypermediaLinks

mediatorRdfResolveHypermediaLinks: MediatorRdfResolveHypermediaLinks

`Protected`querySourceAggregated

querySourceAggregated: IQuerySource

`Protected`querySourcesNonAggregated

querySourcesNonAggregated: AsyncReiterable<IQuerySource>

`Protected`rejectionHandler

rejectionHandler: ((error: Error) => void) | undefined

`Protected`running

running: boolean = false

`Readonly`seeds

seeds: ILink[]

The seed links used for populating the link queue.

`Protected` `Readonly`stopListeners

stopListeners: (() => void)[] = []

Accessors

started

get started(): boolean
If the traversal has been initiated.

Returns boolean
Implementation of ILinkTraversalManager.started
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:57

stopped

get stopped(): boolean
If the traversal has ended, either forcefully, or after draining the link queue completely.

Returns boolean
Implementation of ILinkTraversalManager.stopped
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:61

Methods

addStopListener

addStopListener(cb: () => void): void
Register a listener to listen to stop events.
Parameters
- cb: () => void
  Listener that will be invoked once the traversal stops.
Returns void
Implementation of ILinkTraversalManager.addStopListener
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:107

`Protected`followLink

followLink(nextLink: ILink): void
Parameters
- nextLink: ILink
Returns void
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:167

getQuerySourceAggregated

getQuerySourceAggregated(): IQuerySource
Get the query source containing all triples obtained from traversal. This excludes sources that can not be aggregated, such as SPARQL endpoints.

Returns IQuerySource
Implementation of ILinkTraversalManager.getQuerySourceAggregated
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:99

getQuerySourcesNonAggregated

getQuerySourcesNonAggregated(): AsyncIterator<IQuerySource>
Create a new iterator over all query sources that could not be aggregated in the main query source. This iterator will only end once traversal stops.

Returns AsyncIterator<IQuerySource>
Implementation of ILinkTraversalManager.getQuerySourcesNonAggregated
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:103

`Protected`getSourceLinks

getSourceLinks(
metadata: Record<string, any>,
startLink: ILink,
): Promise<ILink[]>
Parameters
- metadata: Record<string, any>
- startLink: ILink
Returns Promise<ILink[]>
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:145

start

start(rejectionHandler: (error: Error) => void, context: IActionContext): void
Start traversal over the link queue.
Parameters
- rejectionHandler: (error: Error) => void
  A callback for error events.
- context: IActionContext
  The query context.
Returns void
Implementation of ILinkTraversalManager.start
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:65

stop

stop(): void
Terminate traversal.

Returns void
Implementation of ILinkTraversalManager.stop
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:91

`Protected`tryTraversingNextLinks

tryTraversingNextLinks(): void
Returns void
- Defined in packages/actor-optimize-query-operation-initialize-link-traversal-manager/lib/LinkTraversalManagerMediated.ts:111

Class LinkTraversalManagerMediated

Implements

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Parameters

Returns LinkTraversalManagerMediated

Properties

ReadonlyaggregatedStore

Protected ReadonlybindingsFactory

Protected Readonlycontext

Protected ReadonlydataFactory

Protectedended

Protected ReadonlyhandledUrls

ProtectedlinkParallelization

Protected ReadonlylinkParallelizationDefault

Protected ReadonlylinkParallelizationLimit

ReadonlylinkQueue

ProtectedlinksDereferencing

Protected ReadonlymediatorQuerySourceDereferenceLink

Protected ReadonlymediatorRdfResolveHypermediaLinks

ProtectedquerySourceAggregated

ProtectedquerySourcesNonAggregated

ProtectedrejectionHandler

Protectedrunning

Readonlyseeds

Protected ReadonlystopListeners

Accessors

started

Returns boolean

stopped

Returns boolean

Methods

addStopListener

Parameters

Returns void

ProtectedfollowLink

Parameters

Returns void

getQuerySourceAggregated

Returns IQuerySource

getQuerySourcesNonAggregated

Returns AsyncIterator<IQuerySource>

ProtectedgetSourceLinks

Parameters

Returns Promise<ILink[]>

start

Parameters

Returns void

stop

Returns void

ProtectedtryTraversingNextLinks

Returns void

Settings

On This Page

`Readonly`aggregatedStore

`Protected` `Readonly`bindingsFactory

`Protected` `Readonly`context

`Protected` `Readonly`dataFactory

`Protected`ended

`Protected` `Readonly`handledUrls

`Protected`linkParallelization

`Protected` `Readonly`linkParallelizationDefault

`Protected` `Readonly`linkParallelizationLimit

`Readonly`linkQueue

`Protected`linksDereferencing

`Protected` `Readonly`mediatorQuerySourceDereferenceLink

`Protected` `Readonly`mediatorRdfResolveHypermediaLinks

`Protected`querySourceAggregated

`Protected`querySourcesNonAggregated

`Protected`rejectionHandler

`Protected`running

`Readonly`seeds

`Protected` `Readonly`stopListeners

`Protected`followLink

`Protected`getSourceLinks

`Protected`tryTraversingNextLinks