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

Methodas_str_name

String value of the enum field names used in the ProtoBuf definition. The values are not transformed in any way and thus are considered stable (if th

src/proto/src/taskmanager.rs:42

Methodbatch_send_event_to_operator

( &self, event_set: KeyedEventSet, )

src/stream/src/task.rs:124

Methodbatch_send_events_to_operator

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

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

Methodbatch_send_events_to_operator

( &self, req: KeyedEventSet, )

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

Methodbatch_sink

(&mut self, event_set: KeyedEventSet)

src/stream/src/connector.rs:202

(brokers: string[])

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

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

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

(&mut self, req: http::Request<B>)

src/proto/src/coordinator.rs:283

src/common/src/kafka.rs:88

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

(&self, other: &Self)

src/common/src/event.rs:98

Attempt to create a new client by connecting to a given endpoint.

src/proto/src/coordinator.rs:19

Methodconnect_with_timeout

Try to connect to remote coordinator with connection timeout

src/proto/src/coordinator_impl.rs:23

Methodconnect_with_timeout

Try to connect to remote task worker with connection timeout

src/proto/src/taskmanager_impl.rs:23

Methodconnection

(options: IConnectionOpts)

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

Functionconstructor

(operatorId: number)

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

Methodconstructor

(centerId: number, neighbors: number[])

typescript-api/src/common/common.ts:7

Methodconstructor

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

Methodconstructor

(ctx: ExecutionContext)

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

Methodconstructor

(ctx: ExecutionContext)

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

Methodconstructor

(operatorId: number, fn: (value: T) => U[])

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

Methodconstructor

(operatorId: number, fn: (value: T) => U)

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

Methodconstructor

(operatorId: number, sink: ISink)

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

Methodconstructor

(operatorId: number, fn: (agg: T, current: T) => T)

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

Methodconstructor

(operatorId: number, source: ISource)

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

Methodconstructor

(operatorId: number, fn: (value: T) => U)

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

Methodconstructor

(operatorId: number, fn: (value: T) => boolean)

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

FunctioncreateFlow

(ctx: ExecutionContext)

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

Methodcreate_dataflow

( &self, dataflow: Dataflow, )

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

Methodcreate_dataflow

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

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

Methodcreate_dataflow

(&self, dataflow: Dataflow)

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

Functioncreate_resource

(mut req: web::Payload)

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

Methodcreate_sub_dataflow

( &self, req: CreateSubDataflowRequest, )

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

src/common/src/utils.rs:76

src/common/src/types.rs:142

(&mut self, job_id: &ResourceId)

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

src/stream/src/edge.rs:228

src/stream/src/dataflow.rs:458

src/stream/src/connector.rs:697

src/stream/src/v8_runtime.rs:286

src/stream/src/task.rs:446

src/stream/tests/test_sinks.rs:27

(&self, other: &Self)

src/common/src/types.rs:20

Methodevent_time

src/common/src/event.rs:190

Methodextractors

(extractor: (statement: Statement<InputT>) => void)

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

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

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

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

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

(&self, f: &mut fmt::Formatter<'_>)

src/lightflus-core/src/errors/mod.rs:178

(&self, f: &mut std::fmt::Formatter<'_>)

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

(&self, f: &mut std::fmt::Formatter<'_>)

src/proto/src/taskmanager.rs:695

(&self, f: &mut std::fmt::Formatter<'_>)

src/proto/src/coordinator.rs:515

(&self, f: &mut std::fmt::Formatter<'_>)

src/common/src/event.rs:45

(&self, f: &mut std::fmt::Formatter<'_>)

src/common/src/err.rs:22

(&self, f: &mut std::fmt::Formatter<'_>)

src/stream/src/edge.rs:137

(&self, f: &mut fmt::Formatter<'_>)

src/stream/src/err.rs:91

typescript-api/test/dataflow.e2e-spec.ts:5

(err: TryRecvError)

src/lightflus-core/src/errors/mod.rs:51

(entry: &Entry)

src/common/src/types.rs:455

(err: serde_json::Error)

src/common/src/event.rs:125

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

(err: rmp_serde::encode::Error)

src/stream/src/edge.rs:131

(args: (&ResourceId, SourceId, &operator_info::Details))

src/stream/src/connector.rs:150

(err: KafkaException)

src/stream/src/err.rs:28

(inner: Arc<T>)

src/proto/src/taskmanager.rs:338

(inner: Arc<T>)

src/proto/src/coordinator.rs:238

Methodfrom_error

src/lightflus-core/src/errors/mod.rs:184

Methodfrom_json_value

(val: serde_json::Value)

src/common/src/types.rs:399

Functionfrom_prost_timestamp_to_utc_chrono

( timestamp: &prost_types::Timestamp, )

src/common/src/utils.rs:20

Methodfrom_slice

src/proto/src/common_impl.rs:551

Methodfrom_slice

To specify the type of value, we only accept the bytes with the head of data type symbol. It may be panic if the data has uncorrect head of data type

src/common/src/types.rs:311

Methodfrom_slice

src/common/src/event.rs:175

Methodfrom_slice_with_type

(mut data: &[u8], data_type: DataTypeEnum)

src/common/src/types.rs:361

Methodfrom_str_name

Creates an enum from field names used in the ProtoBuf definition.

src/proto/src/apiserver.rs:109

Methodfrom_str_name

Creates an enum from field names used in the ProtoBuf definition.

src/proto/src/common.rs:131

Methodfrom_str_name

Creates an enum from field names used in the ProtoBuf definition.

src/proto/src/taskmanager.rs:50

Functionfrom_type_symbol

(symbol: String)

src/common/src/utils.rs:215

Functionfrom_utc_chrono_to_prost_timestamp

( timestamp: &chrono::DateTime<chrono::Utc>, )

src/common/src/utils.rs:32

To specify the type of value, we only accept the bytes with the head of data type symbol. It may be panic if the data has uncorrect head of data type

src/common/src/types.rs:261

FunctiongetFunctionName

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

Methodget_dataflow

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

Methodget_dataflow

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

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

Methodget_dataflow

(&self, dataflow: &Dataflow)

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

Methodget_dataflow

src/proto/src/apiserver_impl.rs:7

Methodget_dataflow

( &self, req: GetDataflowRequest, )

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

Methodget_execution_id

src/proto/src/common_impl.rs:528

Methodget_host_addr

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

Methodget_period

src/proto/src/common_impl.rs:423

Functionget_resource

(args: web::Path<GetResourceArgs>)

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

src/proto/src/common_impl.rs:141

src/proto/src/common_impl.rs:398

Methodget_source

src/proto/src/common_impl.rs:131

Methodget_state

src/stream/src/task.rs:154

Methodget_status

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

Methodget_sub_dataflow

( &self, req: ResourceId, )

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

Methodget_timeout

src/proto/src/common_impl.rs:432

Methodget_trigger

src/proto/src/common_impl.rs:177

Methodget_trigger_time

src/proto/src/common_impl.rs:407

src/proto/src/common_impl.rs:451

Methodget_value

src/proto/src/common_impl.rs:173

← previous next →301–400 of 588, ranked by callers