Functions — github.com/JasonThon/lightflus

CodeHub MCPcopy Create free account

hub / github.com/JasonThon/lightflus / functions

Functions588 in github.com/JasonThon/lightflus

⨍ Functions 588◇ Types & classes 381

Methodget_window

src/proto/src/common_impl.rs:161

(group: string)

typescript-api/src/connectors/connectors.ts:124

Methodhas_window

src/proto/src/common_impl.rs:151

typescript-api/src/connectors/connectors.ts:244

Functionindex_for_each_mut

(elems: &mut Vec<T>, mut callback: F)

src/common/src/collections/lang.rs:113

Methodinto_tonic_status

src/common/src/err.rs:46

Functionlist_resources

(args: web::Path<ListResourcesArgs>)

src/lightflus-core/src/apiserver/handler/resources.rs:46

Functionload_builder

src/lightflus-core/src/coordinator/coord.rs:49

(operator_info: &'a OperatorInfo)

src/stream/src/task.rs:171

tools/health-check/main.go:20

* If proto has been changed. You must remove all comments and rerun build.rs to generate new rust files */

src/proto/build.rs:4

src/coordinator/src/main.rs:20

src/taskmanager/src/main.rs:9

(list: &Vec<U>, mapper: F)

src/common/src/collections/lang.rs:12

(callbackFn: (value: T) => U)

typescript-api/src/stream/dataflow.ts:85

Functionmatch_process_result

( result: Result<T, E>, err_processor: F0, ok_processor: F1, )

src/common/src/utils.rs:59

Methodmay_exists

(&self, job_id: &ResourceId)

src/lightflus-core/src/coordinator/storage.rs:74

( location: &HostAddr, dataflow: Dataflow, storage: &DataflowStorageBuilder, )

src/lightflus-core/src/coordinator/managers.rs:33

(coordinator: coord::Coordinator)

src/lightflus-core/src/coordinator/api.rs:16

src/lightflus-core/src/coordinator/scheduler.rs:16

( execution_id: &SubDataflowId, executor_id: ExecutorId, operator: &OperatorInfo,

src/lightflus-core/src/coordinator/executions.rs:66

src/lightflus-core/src/coordinator/storage.rs:37

(dataflow: &'a Dataflow)

src/lightflus-core/src/taskmanager/taskworker.rs:37

src/proto/src/taskmanager.rs:87

src/proto/src/coordinator.rs:35

src/common/src/types.rs:483

(consumer: StreamConsumer)

src/common/src/kafka.rs:108

(conf: &RedisDesc)

src/common/src/redis.rs:16

(host_addr: HostAddr, gateway: SafeTaskManagerRpcGateway)

src/common/src/net/cluster.rs:42

( ack_buf_size: usize, heartbeat_buf_size: usize, )

src/common/src/net/gateway.rs:60

(tx: Sender<bytes::Bytes>)

src/stream/src/edge.rs:45

( executor_id: ExecutorId, detail: &Details, state_manager: S, scope: &'i mut

src/stream/src/dataflow.rs:24

src/stream/src/state.rs:36

( source_code: &str, fn_name: &str, isolated_scope: &'i mut v8::HandleScope<'s, ()>,

src/stream/src/v8_runtime.rs:22

(job_id: &ResourceId, adjacent_node: &DataflowMeta)

src/stream/src/task.rs:62

(statement: string)

typescript-api/src/connectors/connectors.ts:198

typescript-api/src/connectors/connectors.ts:291

(name: string, namespace: string)

typescript-api/src/stream/context.ts:23

src/stream/src/connector.rs:104

MethodoperatorType

typescript-api/src/stream/operator.ts:44

MethodoperatorType

typescript-api/src/stream/operator.ts:90

MethodoperatorType

typescript-api/src/stream/operator.ts:109

MethodoperatorType

typescript-api/src/stream/operator.ts:132

MethodoperatorType

typescript-api/src/stream/operator.ts:152

MethodoperatorType

typescript-api/src/stream/operator.ts:176

Functionoverview

src/lightflus-core/src/apiserver/handler/resources.rs:51

Methodpartition

(partition: number)

typescript-api/src/connectors/connectors.ts:129

(password: string)

typescript-api/src/connectors/connectors.ts:254

(self: Pin<&mut Self>, cx: &mut task::Context<'_>)

src/common/src/net/mod.rs:168

( self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>,

src/common/src/futures/mod.rs:74

(self: Pin<&mut Self>, cx: &mut Context<'_>)

src/stream/src/task.rs:390

(self: Pin<&mut Self>, cx: &mut Context<'_>)

src/stream/tests/test_sources.rs:94

Methodpoll_next

(&mut self, cx: &mut Context<'_>)

src/stream/src/edge.rs:249

Methodpoll_next

( &mut self, cx: &mut std::task::Context<'_>, )

src/stream/src/connector.rs:124

Methodpoll_next

(&mut self, cx: &mut Context<'_>)

src/stream/src/task.rs:260

Methodpoll_ready

( &mut self, _cx: &mut Context<'_>, )

src/proto/src/taskmanager.rs:377

Methodpoll_ready

( &mut self, _cx: &mut Context<'_>, )

src/proto/src/coordinator.rs:277

( &self, event: &KeyedDataEvent, )

src/stream/src/dataflow.rs:82

Methodprocess_arg

( arg: String, mut current_arg: &mut Arg, map: &mut HashMap<String, Arg>, )

src/common/src/utils.rs:95

Methodreceive_ack

(&self, ack: Ack)

src/lightflus-core/src/coordinator/coord.rs:124

Methodreceive_ack

( &self, request: tonic::Request<Ack>, )

src/lightflus-core/src/coordinator/api.rs:35

Methodreceive_ack

(&self, request: RpcRequest<Ack>)

src/lightflus-core/src/taskmanager/rpc.rs:153

Methodreceive_ack

(&self, ack: &Ack)

src/lightflus-core/src/taskmanager/taskworker.rs:141

Methodreceive_ack

(&self, ack: &Ack)

src/stream/src/task.rs:60

Methodreceive_heartbeat

( &self, request: tonic::Request<Heartbeat>, )

src/lightflus-core/src/coordinator/api.rs:27

Methodreceive_heartbeat

(&self, request: RpcRequest<Heartbeat>)

src/lightflus-core/src/taskmanager/rpc.rs:135

Methodreceive_heartbeat

(&self, heartbeat: &Heartbeat)

src/lightflus-core/src/taskmanager/taskworker.rs:130

Methodreceive_heartbeat

(&self, heartbeat: &Heartbeat)

src/stream/src/task.rs:146

(callbackFn: (agg: T, current: T) => T)

typescript-api/src/stream/dataflow.ts:90

(operator_info: &'a OperatorInfo)

src/stream/src/task.rs:183

Methodrun_async

src/common/src/testutils/mod.rs:14

(left: Poll<Left>, right: Poll<Right>)

src/common/src/futures/mod.rs:35

Methodsend_compressed

(mut self, encoding: CompressionEncoding)

src/proto/src/taskmanager.rs:119

Methodsend_compressed

(mut self, encoding: CompressionEncoding)

src/proto/src/coordinator.rs:67

Methodsend_event_to_operator

( &self, request: RpcRequest<KeyedDataEvent>, )

src/lightflus-core/src/taskmanager/rpc.rs:64

Methodsend_event_to_operator

( &self, event: KeyedDataEvent, )

src/lightflus-core/src/taskmanager/taskworker.rs:114

Methodsend_event_to_operator

( &self, event: KeyedDataEvent, )

src/common/src/net/gateway.rs:189

MethodsetNumber

(index: number, extractor: (v: T) => number)

typescript-api/src/connectors/connectors.ts:210

MethodsetString

(index: number, extractor: (val: T) => string)

typescript-api/src/connectors/connectors.ts:206

Methodstatement

(statement: string)

typescript-api/src/connectors/connectors.ts:168

Methodstop_dataflow

( &self, job_id: ResourceId, )

src/common/src/net/gateway.rs:210

(&self, a: i64, b: i64)

src/common/src/futures/mod.rs:64

Methodterminate_dataflow

src/lightflus-core/src/coordinator/managers.rs:81

Methodterminate_dataflow

( &self, request: tonic::Request<ResourceId>, )

src/lightflus-core/src/coordinator/api.rs:52

Methodterminate_dataflow

src/lightflus-core/src/coordinator/scheduler.rs:32

Methodterminate_dataflow

(&self, req: ResourceId)

src/common/src/net/gateway.rs:482

Functiontest_ack_success

src/common/src/net/mod.rs:357

Functiontest_any_match

src/common/src/collections/lang.rs:360

Functiontest_array_to_json_value

src/common/src/types.rs:1316

Functiontest_array_to_typed_value

src/stream/src/v8_runtime.rs:554

Functiontest_bigint_to_json_value

src/common/src/types.rs:1289

Functiontest_boolean_to_json_value

src/common/src/types.rs:1307

Functiontest_cluster_available

src/common/src/net/cluster.rs:267

Functiontest_cluster_build

src/common/src/net/cluster.rs:462

Functiontest_cluster_builder_derserialize

src/common/src/net/cluster.rs:415

Functiontest_cluster_partition_dataflow

src/common/src/net/cluster.rs:284

Functiontest_dataflow_is_cyclic

src/common/src/utils.rs:419

Functiontest_e2e

src/lightflus-core/tests/test_e2e.rs:203

Functiontest_edge_builder_build_out_edge

src/lightflus-core/src/taskmanager/taskworker.rs:212

Functiontest_env_var_get

src/common/src/utils.rs:481

← previous next →401–500 of 588, ranked by callers