@sora-soft/framework / Node
Class: Node
Defined in: packages/framework/src/lib/Node.ts:12
Extends
Constructors
Constructor
new Node(options, listeners): Node;Defined in: packages/framework/src/lib/Node.ts:38
Parameters
| Parameter | Type |
|---|---|
options | INodeOptions |
listeners | Listener[] |
Returns
Node
Overrides
Properties
| Property | Modifier | Type | Inherited from | Defined in |
|---|---|---|---|---|
executor_ | protected | Executor | Service.executor_ | packages/framework/src/lib/Worker.ts:207 |
intervalJobTimer_ | protected | Timer | Service.intervalJobTimer_ | packages/framework/src/lib/Worker.ts:208 |
lifeCycle_ | protected | LifeCycle<WorkerState> | SingletonService.lifeCycle_ | packages/framework/src/lib/Worker.ts:206 |
options_ | protected | IServiceOptions | Service.options_ | packages/framework/src/lib/Service.ts:174 |
scope_ | protected | WorkerScope | Service.scope_ | packages/framework/src/lib/Worker.ts:211 |
startTime_ | protected | number | Service.startTime_ | packages/framework/src/lib/Worker.ts:209 |
Accessors
executor
Get Signature
get executor(): Executor<Scope<unknown>>;Defined in: packages/framework/src/lib/Worker.ts:187
Returns
Inherited from
id
Get Signature
get id(): string;Defined in: packages/framework/src/lib/Worker.ts:183
Returns
string
Inherited from
isIdle
Get Signature
get isIdle(): boolean;Defined in: packages/framework/src/lib/Worker.ts:171
Returns
boolean
Inherited from
lifeCycle
Get Signature
get lifeCycle(): LifeCycle<WorkerState>;Defined in: packages/framework/src/lib/Worker.ts:179
Returns
Inherited from
listenerPool
Get Signature
get protected listenerPool(): Map<string, Listener>;Defined in: packages/framework/src/lib/Service.ts:170
Returns
Map<string, Listener>
Inherited from
metaData
Get Signature
get metaData(): IServiceMetaData;Defined in: packages/framework/src/lib/Service.ts:144
Returns
Inherited from
name
Get Signature
get name(): string;Defined in: packages/framework/src/lib/Worker.ts:163
Returns
string
Inherited from
nodeRunData
Get Signature
get nodeRunData(): INodeRunData;Defined in: packages/framework/src/lib/Node.ts:53
Returns
nodeStateData
Get Signature
get nodeStateData(): INodeMetaData;Defined in: packages/framework/src/lib/Node.ts:63
Returns
runData
Get Signature
get runData(): IServiceRunData;Defined in: packages/framework/src/lib/Service.ts:156
Returns
Inherited from
scope
Get Signature
get scope(): WorkerScope;Defined in: packages/framework/src/lib/Worker.ts:191
Returns
Inherited from
state
Get Signature
get state(): WorkerState;Defined in: packages/framework/src/lib/Worker.ts:167
Returns
Inherited from
stateSubject
Get Signature
get stateSubject(): BehaviorSubject<WorkerState>;Defined in: packages/framework/src/lib/Worker.ts:175
Returns
BehaviorSubject<WorkerState>
Inherited from
Methods
connectComponent()
connectComponent(component): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:126
Parameters
| Parameter | Type |
|---|---|
component | Component |
Returns
Promise<void>
Inherited from
connectComponents()
connectComponents(components): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:120
Parameters
| Parameter | Type |
|---|---|
components | Component[] |
Returns
Promise<void>
Inherited from
disconnectComponent()
disconnectComponent(name): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:136
Parameters
| Parameter | Type |
|---|---|
name | string |
Returns
Promise<void>
Inherited from
doJob()
protected doJob<T>(executor): Promise<T | undefined>;Defined in: packages/framework/src/lib/Worker.ts:68
Type Parameters
| Type Parameter |
|---|
T |
Parameters
| Parameter | Type |
|---|---|
executor | JobExecutor<T> |
Returns
Promise<T | undefined>
Inherited from
doJobInterval()
protected doJobInterval(executor, timeMS): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:72
Parameters
| Parameter | Type |
|---|---|
executor | JobExecutor |
timeMS | number |
Returns
Promise<void>
Inherited from
getListenerMetaData()
protected getListenerMetaData(listener): {
codecs: string[];
endpoint: string;
id: string;
labels: {
[key: string]: string;
};
protocol: string;
state: ListenerState;
targetId: string;
targetName: string;
version: string;
weight: number;
};Defined in: packages/framework/src/lib/Service.ts:126
Parameters
| Parameter | Type |
|---|---|
listener | Listener |
Returns
{
codecs: string[];
endpoint: string;
id: string;
labels: {
[key: string]: string;
};
protocol: string;
state: ListenerState;
targetId: string;
targetName: string;
version: string;
weight: number;
}| Name | Type | Default value | Defined in |
|---|---|---|---|
codecs | string[] | - | packages/framework/src/interface/rpc.ts:11 |
endpoint | string | - | packages/framework/src/interface/rpc.ts:10 |
id | string | listener.id | packages/framework/src/lib/Service.ts:134 |
labels | { [key: string]: string; } | - | packages/framework/src/lib/Service.ts:140 |
protocol | string | - | packages/framework/src/interface/rpc.ts:9 |
state | ListenerState | listener.state | packages/framework/src/lib/Service.ts:135 |
targetId | string | - | packages/framework/src/lib/Service.ts:136 |
targetName | string | - | packages/framework/src/lib/Service.ts:137 |
version | string | listener.version | packages/framework/src/lib/Service.ts:139 |
weight | number | listener.weight | packages/framework/src/lib/Service.ts:138 |
Inherited from
hasComponent()
hasComponent(id): boolean;Defined in: packages/framework/src/lib/Worker.ts:153
Parameters
| Parameter | Type |
|---|---|
id | string |
Returns
boolean
Inherited from
hasProvider()
hasProvider(id): boolean;Defined in: packages/framework/src/lib/Worker.ts:149
Parameters
| Parameter | Type |
|---|---|
id | string |
Returns
boolean
Inherited from
installListener()
installListener(listener): Promise<void>;Defined in: packages/framework/src/lib/Service.ts:58
Parameters
| Parameter | Type |
|---|---|
listener | Listener |
Returns
Promise<void>
Inherited from
onError()
protected onError(err): void;Defined in: packages/framework/src/lib/Worker.ts:157
Parameters
| Parameter | Type |
|---|---|
err | Error |
Returns
void
Inherited from
registerEndpoint()
registerEndpoint(listener): Promise<void>;Defined in: packages/framework/src/lib/Service.ts:98
Parameters
| Parameter | Type |
|---|---|
listener | Listener |
Returns
Promise<void>
Inherited from
registerEndpoints()
registerEndpoints(): Promise<void>;Defined in: packages/framework/src/lib/Service.ts:107
Returns
Promise<void>
Inherited from
registerProvider()
registerProvider(provider): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:98
Parameters
| Parameter | Type |
|---|---|
provider | Provider |
Returns
Promise<void>
Inherited from
registerProviders()
registerProviders(providers): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:92
Parameters
| Parameter | Type |
|---|---|
providers | Provider<Route>[] |
Returns
Promise<void>
Inherited from
runCommand()
runCommand(...args): Promise<boolean>;Defined in: packages/framework/src/lib/Worker.ts:64
Parameters
| Parameter | Type |
|---|---|
...args | unknown[] |
Returns
Promise<boolean>
Inherited from
shutdown()
shutdown(): Promise<void>;Defined in: packages/framework/src/lib/Node.ts:51
Returns
Promise<void>
Overrides
start()
start(): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:34
Returns
Promise<void>
Inherited from
startup()
startup(): Promise<void>;Defined in: packages/framework/src/lib/Node.ts:45
Returns
Promise<void>
Overrides
stop()
stop(reason): Promise<void>;Defined in: packages/framework/src/lib/Service.ts:42
Parameters
| Parameter | Type |
|---|---|
reason | string |
Returns
Promise<void>
Inherited from
uninstallListener()
uninstallListener(id): Promise<void>;Defined in: packages/framework/src/lib/Service.ts:113
Parameters
| Parameter | Type |
|---|---|
id | string |
Returns
Promise<void>
Inherited from
unregisterProvider()
unregisterProvider(name): Promise<void>;Defined in: packages/framework/src/lib/Worker.ts:108
Parameters
| Parameter | Type |
|---|---|
name | string |
Returns
Promise<void>
Inherited from
registerService()
static registerService<T>(name, builder): void;Defined in: packages/framework/src/lib/Node.ts:24
Type Parameters
| Type Parameter |
|---|
T extends IServiceOptions |
Parameters
| Parameter | Type |
|---|---|
name | string |
builder | ServiceBuilder<T> |
Returns
void
registerWorker()
static registerWorker<T>(name, builder): void;Defined in: packages/framework/src/lib/Node.ts:13
Type Parameters
| Type Parameter |
|---|
T extends IWorkerOptions |
Parameters
| Parameter | Type |
|---|---|
name | string |
builder | WorkerBuilder<T> |
Returns
void
serviceFactory()
static serviceFactory(name, options): Service | null;Defined in: packages/framework/src/lib/Node.ts:28
Parameters
| Parameter | Type |
|---|---|
name | string |
options | IServiceOptions |
Returns
Service | null
workerFactory()
static workerFactory(name, options): Worker | null;Defined in: packages/framework/src/lib/Node.ts:17
Parameters
| Parameter | Type |
|---|---|
name | string |
options | IWorkerOptions |
Returns
Worker | null