Functions — github.com/JasonThon/lightflus

hub / github.com/JasonThon/lightflus / functions

Functions588 in github.com/JasonThon/lightflus

⨍ Functions 588◇ Types & classes 381

↓ 289 callersMethodto_string

(&self)

src/common/src/types.rs:116

↓ 180 callersMethodclone

(&self)

src/proto/src/taskmanager.rs:680

↓ 154 callersMethodmap

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

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

↓ 34 callersMethodget

(&mut self, key: &K)

src/common/src/redis.rs:58

↓ 25 callersMethodset

( &mut self, key: &K, value: &V, )

src/common/src/redis.rs:36

↓ 22 callersMethodget_type

get the data type of TypedValue

src/common/src/types.rs:348

↓ 21 callersMethodas_bytes

(self)

src/proto/src/common_impl.rs:534

↓ 21 callersMethodget_data_bytes

(&self)

src/common/src/types.rs:449

↓ 20 callersMethodget

(&self, job_id: &ResourceId)

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

↓ 20 callersMethodis_empty

(&self)

src/common/src/utils.rs:127

↓ 18 callersMethodas_uri

(&self)

src/proto/src/common_impl.rs:510

↓ 17 callersMethodfilter

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

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

↓ 15 callersFunctionget_env

(k: &str)

src/common/src/utils.rs:137

↓ 14 callersFunctionnow

()

src/common/src/utils.rs:28

↓ 14 callersMethodsend

(&self, key: &[u8], payload: &[u8])

src/common/src/kafka.rs:66

↓ 13 callersMethodclear

(&mut self)

src/common/src/utils.rs:131

↓ 13 callersMethodtoOperatorInfo

()

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

↓ 13 callersFunctionto_typed_value

to_typed_value() will convert v8::Value into TypedValue. */

src/stream/src/v8_runtime.rs:183

↓ 12 callersMethodvalue

(&self)

src/common/src/types.rs:496

↓ 11 callersMethodcall_fn

( &self, event: &KeyedDataEvent, rt_engine: &RefCell<RuntimeEngine<'p, 'i>>, )

src/stream/src/dataflow.rs:141

↓ 11 callersMethodclone

(&self)

src/proto/src/coordinator.rs:500

↓ 11 callersMethoddel

(&mut self, key: &K)

src/common/src/redis.rs:65

↓ 11 callersFunctionget_function_name

(info: &Details)

src/stream/src/dataflow.rs:90

↓ 11 callersFunctioninjectFunctionName

(name: string, func: string)

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

↓ 9 callersMethodget_data

get the slice of bytes with the head of data type symbol Example: ``` use common::types::TypedValue; use proto::common::DataTypeEnum; fn main() { let

src/common/src/types.rs:220

↓ 9 callersMethodinto_tonic_status

(&self)

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

↓ 9 callersFunctionnew_rpc_response

(val: T)

src/lightflus-core/src/lib.rs:13

↓ 9 callersMethodok

()

src/proto/src/common_impl.rs:462

↓ 9 callersMethodpartial_cmp

(&self, other: &Self)

src/common/src/types.rs:40

↓ 8 callersMethodnext

(&mut self)

src/stream/src/edge.rs:241

↓ 8 callersMethodwrite_redis_args

(&self, out: &mut W)

src/common/src/types.rs:100

↓ 7 callersMethodbuild

( &self, host_addr: &HostAddr, task_id: ExecutorId, f: F, )

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

↓ 7 callersMethodcall_one_arg

* call with one argument */

src/stream/src/v8_runtime.rs:61

↓ 7 callersMethodexecute

# Execute the statement and return the whole result set Each SQL statement can be executed by a [MysqlConn] instance with three arguments: - SQL stat

src/common/src/db.rs:56

↓ 7 callersFunctionjoin_all

( cx: &mut Context<'_>, fut_list: &mut Vec<Pin<Box<dyn Future<Output = T> + Send + 'a>>>, callback

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

↓ 6 callersMethodaddChild

(parentId: number, op: T)

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

↓ 6 callersMethodbuild

(&self)

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

↓ 6 callersFunctionfile_common_probe_proto_rawDescGZIP

()

tools/alpha/common/probe/probe.pb.go:379

↓ 6 callersMethodincrementAndGetId

()

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

↓ 6 callersFunctionnew_event_channel

(buf_size: usize)

src/stream/src/lib.rs:23

↓ 6 callersFunctionrun_producer

( brokers: &str, topic: &str, group: &str, partition: i32, )

src/common/src/kafka.rs:38

↓ 6 callersFunctionsetup

()

src/stream/src/dataflow.rs:461

↓ 6 callersFunctionsetup

()

src/stream/src/v8_runtime.rs:289

↓ 5 callersMethodbuild

(&self, gateway: SafeTaskManagerRpcGateway)

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

↓ 5 callersMethodclose

(&mut self)

src/common/src/db.rs:159

↓ 5 callersMethodfetch

(&self, mut processor: F)

src/common/src/kafka.rs:112

↓ 5 callersMethodget_job_id

(&self)

src/proto/src/common_impl.rs:314

↓ 5 callersMethodkey

(&self)

src/common/src/types.rs:492

↓ 5 callersMethodnew

()

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

↓ 5 callersMethodparse

(status: tonic::Status)

src/common/src/err.rs:60

↓ 5 callersMethodreduce

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

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

↓ 5 callersMethodto_json_value

(&self)

src/common/src/types.rs:428

↓ 5 callersMethodvalidate

(&self)

src/proto/src/common_impl.rs:266

↓ 4 callersMethodbuild

(&self)

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

↓ 4 callersMethodconnect

(&mut self)

src/common/src/redis.rs:25

↓ 4 callersMethodget_execution_id

(&self)

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

↓ 4 callersFunctioninit

()

tools/alpha/common/probe/probe.pb.go:406

↓ 4 callersFunctionnow_timestamp

()

src/common/src/utils.rs:49

↓ 4 callersMethodpartition_dataflow

A dataflow will be splitted into several partitions and deploy these sub-dataflow into different workers Graph-Partition is an NP-hard problem. Fortun

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

↓ 4 callersFunctionprost_now

()

src/common/src/utils.rs:41

↓ 4 callersMethodrun

(&self)

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

↓ 4 callersFunctionrun_consumer

( brokers: &str, group_id: &str, topic: &str, )

src/common/src/kafka.rs:12

↓ 4 callersMethodto_tonic_status

(&self)

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

↓ 4 callersMethodtry_for_each

# TryForEach, processing elements iteratively The result set of a SQL statement can be processed by a [MysqlConn] instance iteratively with calling me

src/common/src/db.rs:119

↓ 4 callersFunctionwrap_value

wrap_value() will convert a TypedValue into v8::Value. */

src/stream/src/v8_runtime.rs:110

↓ 4 callersMethodwrite

(&self, val: T)

src/stream/src/edge.rs:73

↓ 3 callersMethodclose_sink

(&mut self)

src/stream/src/connector.rs:193

↓ 3 callersMethodcode

(&self)

src/common/src/err.rs:79

↓ 3 callersMethodconnect

(&mut self)

src/common/src/db.rs:144

↓ 3 callersMethodcreate_stream_executor

(&self, operator_info: &OperatorInfo)

src/stream/src/task.rs:81

↓ 3 callersMethodget_arguments

(&self, msg: &LocalEvent)

src/stream/src/connector.rs:504

↓ 3 callersMethodget_node

(&self, addr: &HostAddr)

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

↓ 3 callersMethodhost

(value: string)

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

↓ 3 callersFunctionhostname

()

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

↓ 3 callersFunctioninitialize_v8

()

src/stream/src/lib.rs:15

↓ 3 callersMethodinto_grpc_status

(&self)

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

↓ 3 callersFunctionlocal

(port: usize)

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

↓ 3 callersFunctionpb_to_bytes_mut

(message: T)

src/common/src/utils.rs:236

↓ 3 callersMethodset_in_edge

(&mut self, in_edge: Box<dyn OutEdge<Output = LocalEvent>>)

src/stream/src/task.rs:119

↓ 3 callersMethodsink

(&mut self, msg: LocalEvent)

src/stream/src/connector.rs:184

↓ 3 callersFunctiontry_catch_log

(try_catch: &mut v8::TryCatch<v8::HandleScope>)

src/stream/src/v8_runtime.rs:268

↓ 2 callersMethodDescriptor

Deprecated: Use ProbeRequest.ProtoReflect.Descriptor instead.

tools/alpha/common/probe/probe.pb.go:155

↓ 2 callersMethodString

()

tools/alpha/common/probe/probe.pb.go:136

↓ 2 callersMethodack

(&mut self, ack: &Ack)

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

↓ 2 callersMethodaddOperator

(operator: T)

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

↓ 2 callersMethodadd_out_edge

( &mut self, executor_id: ExecutorId, out_edge: Box<dyn OutEdge<Output = LocalEvent>>,

src/stream/src/task.rs:248

↓ 2 callersMethodarg

(&self, flag: &str)

src/common/src/utils.rs:90

↓ 2 callersMethodbatch_send_events_to_operator

/ Send all events batchly

src/proto/src/taskmanager.rs:230

↓ 2 callersMethodblocking_fetch

(&self, processor: F)

src/common/src/kafka.rs:139

↓ 2 callersMethodbrokers

(value: string[])

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

↓ 2 callersMethodbuild

(ctor?: new() => T, type?: string)

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

↓ 2 callersMethodbuild_out_edge

(&self)

src/stream/src/task.rs:200

↓ 2 callersMethodbuilder

()

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

↓ 2 callersMethodcall

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

src/proto/src/taskmanager.rs:383

↓ 2 callersMethodcall_two_args

* call with two arguments */

src/stream/src/v8_runtime.rs:81

↓ 2 callersMethodcheck

(&self)

src/proto/src/common_impl.rs:183

↓ 2 callersMethodcheck_operator

(&self, node_id: u32)

src/proto/src/common_impl.rs:294

↓ 2 callersMethodconnect

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

src/proto/src/taskmanager.rs:71

↓ 2 callersMethodcreate_dataflow

(&self, dataflow: Dataflow)

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

↓ 2 callersMethodcreate_sub_dataflow

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

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

next →1–100 of 588, ranked by callers