@terascope/job-components / builtin/test-reader/slicer / default

Class: default

The simpliest form a "Slicer"

See [[SlicerCore]]

Extends

• default<TestReaderConfig>

Constructors

new default()

new default(context, opConfig, executionConfig): default

Parameters

Parameter	Type
context	Context
opConfig	OpConfig & TestReaderConfig
executionConfig	ExecutionConfig

Returns

default

Inherited from

default.constructor

Source

packages/job-components/src/operations/core/slicer-core.ts:30

Properties

context

readonly context: Readonly<Context>

Inherited from

default.context

Source

packages/job-components/src/operations/core/core.ts:10

---

events

readonly events: EventEmitter<DefaultEventMap>

Inherited from

default.events

Source

packages/job-components/src/operations/core/core.ts:13

---

executionConfig

readonly executionConfig: Readonly<ExecutionConfig>

Inherited from

default.executionConfig

Source

packages/job-components/src/operations/core/core.ts:11

---

isFinished

isFinished: boolean = false

Inherited from

default.isFinished

Source

packages/job-components/src/operations/slicer.ts:16

---

logger

readonly logger: Logger

Inherited from

default.logger

Source

packages/job-components/src/operations/core/core.ts:12

---

opConfig

protected readonly opConfig: Readonly<OpConfig & TestReaderConfig>

Inherited from

default.opConfig

Source

packages/job-components/src/operations/core/slicer-core.ts:27

---

position

position: number = 0

Source

packages/job-components/src/builtin/test-reader/slicer.ts:11

---

recoveryData

protected recoveryData: SlicerRecoveryData[]

Inherited from

default.recoveryData

Source

packages/job-components/src/operations/core/slicer-core.ts:26

---

requests

requests: Record<string, any>[] = []

Source

packages/job-components/src/builtin/test-reader/slicer.ts:10

---

stats

protected stats: ExecutionStats

Inherited from

default.stats

Source

packages/job-components/src/operations/core/slicer-core.ts:25

Accessors

workersConnected

get protected workersConnected(): number

Returns

number

Source

packages/job-components/src/operations/core/slicer-core.ts:176

Methods

canComplete()

protected canComplete(): boolean

Returns

boolean

Inherited from

default.canComplete

Source

packages/job-components/src/operations/core/slicer-core.ts:172

---

createAPI()

createAPI<A>(name, ...params): Promise<A>

Create an API and add it to the operation lifecycle

Type parameters

Type parameter	Value
A extends OpAPI	OpAPI

Parameters

Parameter	Type
name	string
...params	any[]

Returns

Promise<A>

Inherited from

default.createAPI

Source

packages/job-components/src/operations/core/slicer-core.ts:67

---

createSlice()

createSlice(input, order, id): void

Create a Slice object from a slice request. In the case of recovery the "Slice" already has the required This will be enqueued and dequeued by the "Execution Controller"

Parameters

Parameter	Type	Default value
input	SliceRequest | Slice	undefined
order	number	undefined
id	number	0

Returns

void

Inherited from

default.createSlice

Source

packages/job-components/src/operations/core/slicer-core.ts:95

---

getAPI()

getAPI<A>(name): A

Get a reference to an existing API

Type parameters

Type parameter	Value
A extends OpAPI	OpAPI

Parameters

Parameter	Type
name	string

Returns

A

Inherited from

default.getAPI

Source

packages/job-components/src/operations/core/slicer-core.ts:74

---

getSlice()

getSlice(): null | Slice

A method called by the "Execution Controller" to dequeue a created "Slice"

Returns

null | Slice

Inherited from

default.getSlice

Source

packages/job-components/src/operations/core/slicer-core.ts:112

---

getSlices()

getSlices(max): Slice[]

A method called by the "Execution Controller" to dequeue many created slices

Parameters

Parameter	Type
max	number

Returns

Slice[]

Inherited from

default.getSlices

Source

packages/job-components/src/operations/core/slicer-core.ts:121

---

handle()

handle(): Promise<boolean>

A generic method called by the Teraslice framework to a give a "Slicer" the ability to handle creating slices.

Returns

Promise<boolean>

a boolean depending on whether the slicer is done

Inherited from

default.handle

Source

packages/job-components/src/operations/slicer.ts:28

---

initialize()

initialize(recoveryData): Promise<void>

Called during execution initialization

Parameters

Parameter	Type	Description
recoveryData	SlicerRecoveryData[]	is the data to recover from

Returns

Promise<void>

Overrides

default.initialize

Source

packages/job-components/src/builtin/test-reader/slicer.ts:13

---

isRecoverable()

isRecoverable(): boolean

Used to indicate whether this slicer is recoverable.

Returns

boolean

Inherited from

default.isRecoverable

Source

packages/job-components/src/operations/core/slicer-core.ts:146

---

isRelocatable()

isRelocatable(): boolean

Used to indicate whether this slicer is relocatable. Only relevant for kubernetesV2 backend

Returns

boolean

Inherited from

default.isRelocatable

Source

packages/job-components/src/operations/core/slicer-core.ts:154

---

maxQueueLength()

maxQueueLength(): number

Used to determine the maximum number of slices queued. Defaults to 10000 NOTE: if you want to base of the number of workers use #workersConnected

Returns

number

Inherited from

default.maxQueueLength

Source

packages/job-components/src/operations/core/slicer-core.ts:164

---

onExecutionStats()

onExecutionStats(stats): void

A method called by the "Execution Controller" to give a "Slicer" the opportunity to track various slicer satistics

Parameters

Parameter	Type
stats	ExecutionStats

Returns

void

Inherited from

default.onExecutionStats

Source

packages/job-components/src/operations/core/slicer-core.ts:168

---

shutdown()

shutdown(): Promise<void>

Called during execution shutdown, when this is cleanup any open connections or destroy any in-memory state.

Returns

Promise<void>

Overrides

default.shutdown

Source

packages/job-components/src/builtin/test-reader/slicer.ts:29

---

slice()

slice(): Promise<any>

A method called by Slicer#handle

Returns

Promise<any>

a Slice, or SliceRequest

Overrides

default.slice

Source

packages/job-components/src/builtin/test-reader/slicer.ts:34

---

sliceCount()

sliceCount(): number

The number of enqueued slices

Returns

number

Inherited from

default.sliceCount

Source

packages/job-components/src/operations/core/slicer-core.ts:139

---

slicers()

slicers(): number

Return the number of registered slicers

Returns

number

Inherited from

default.slicers

Source

packages/job-components/src/operations/slicer.ts:24