Functions — github.com/JasonThon/lightflus

hub / github.com/JasonThon/lightflus / functions

Functions588 in github.com/JasonThon/lightflus

⨍ Functions 588◇ Types & classes 381

↓ 1 callersFunctionnew_state_mgt

(resource_id: &ResourceId)

src/stream/src/state.rs:24

↓ 1 callersFunctionnot_found_dataflow

(job_id: &ResourceId)

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

↓ 1 callersMethodoperatorType

()

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

↓ 1 callersMethodpartial_cmp

(&self, other: &Self)

src/common/src/event.rs:86

↓ 1 callersMethodpartition

(value: number)

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

↓ 1 callersMethodpartition_key

(&self, keyed: &T)

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

↓ 1 callersMethodpassword

(value: string)

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

↓ 1 callersMethodprocess

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

src/stream/src/task.rs:277

↓ 1 callersMethodprocess_event

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

src/stream/src/dataflow.rs:121

↓ 1 callersMethodreceive_ack

/ Receive ack

src/proto/src/taskmanager.rs:210

↓ 1 callersMethodreceive_ack

/ Receive ack

src/proto/src/coordinator.rs:145

↓ 1 callersMethodreceive_ack

(&self, req: Ack)

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

↓ 1 callersMethodreceive_heartbeart

(&self, heartbeat: &Heartbeat)

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

↓ 1 callersMethodreceive_heartbeat

(&self, heartbeat: &Heartbeat)

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

↓ 1 callersMethodreceive_heartbeat

/ Receive heartbeat

src/proto/src/taskmanager.rs:190

↓ 1 callersMethodreceive_heartbeat

/ Receive heartbeat

src/proto/src/coordinator.rs:165

↓ 1 callersMethodreceive_heartbeat

(&self, request: Heartbeat)

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

↓ 1 callersFunctionreplace_builder_args_by_env

(_builder: &mut coord::CoordinatorBuilder)

src/coordinator/src/main.rs:65

↓ 1 callersFunctionresource_id_unprovided

()

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

↓ 1 callersMethodsave

(&mut self, dataflow: &Dataflow)

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

↓ 1 callersMethodsend_event_to_operator

/ Send event to operator

src/proto/src/taskmanager.rs:130

↓ 1 callersMethodsend_event_to_operator

(&self, event: LocalEvent)

src/stream/src/task.rs:109

↓ 1 callersMethodset_key_state

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

src/stream/src/state.rs:54

↓ 1 callersMethodset_to_operator_id

(&mut self, to_operator_id: u32)

src/common/src/event.rs:107

↓ 1 callersFunctionsetup

()

src/lightflus-core/tests/test_taskmanager.rs:25

↓ 1 callersFunctionsetup

()

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

↓ 1 callersFunctionsetup

()

src/stream/src/task.rs:449

↓ 1 callersFunctionsetup_builder

(port: usize)

src/lightflus-core/tests/test_taskmanager.rs:16

↓ 1 callersFunctionsetup_builder

(port: usize)

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

↓ 1 callersFunctionsetup_dataflow

(resource_id: ResourceId, server_port: usize)

src/lightflus-core/tests/test_taskmanager.rs:40

↓ 1 callersFunctionsetup_server

(port: usize)

src/lightflus-core/tests/test_taskmanager.rs:33

↓ 1 callersFunctionsetup_server

(port: usize)

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

↓ 1 callersFunctionsetup_v8

()

src/stream/src/connector.rs:700

↓ 1 callersFunctionsetup_wordcount_dataflow

(worker_port: u32)

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

↓ 1 callersMethodsink_event_to_external_and_local

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

src/stream/src/task.rs:315

↓ 1 callersMethodsink_id

(&self)

src/stream/src/connector.rs:175

↓ 1 callersMethodsource_id

(&self)

src/stream/src/connector.rs:97

↓ 1 callersFunctionstate_mgt_type

()

src/stream/src/state.rs:68

↓ 1 callersMethodstop_dataflow

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

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

↓ 1 callersMethodstop_dataflow

/ Attempt to terminate a sub-dataflow

src/proto/src/taskmanager.rs:150

↓ 1 callersFunctiontask_deployment_err

(message: &str)

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

↓ 1 callersMethodterminate_dataflow

( &self, job_id: &ResourceId, )

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

↓ 1 callersMethodterminate_dataflow

/ Attempt to terminate a dataflow / Unless bump into network problems, JobManager will be informed the status of the deployed dataflow asynchronously.

src/proto/src/coordinator.rs:101

↓ 1 callersFunctionto_connection_info

(conf: &RedisDesc)

src/common/src/redis.rs:73

↓ 1 callersFunctionto_dataflow

( job_id: &ResourceId, operators: &Vec<OperatorInfo>, meta: &[DataflowMeta], )

src/common/src/utils.rs:193

↓ 1 callersMethodto_resource_id

(&self)

src/lightflus-core/src/apiserver/types.rs:11

↓ 1 callersMethodtry_terminate

(&self)

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

↓ 1 callersFunctionunexpected_dataflow_staus

(status: &DataflowStatus)

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

↓ 1 callersMethodunsubscribe

(&self)

src/common/src/kafka.rs:164

↓ 1 callersMethodupdate_heartbeat_status

(&self, heartbeat: &Heartbeat)

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

↓ 1 callersMethodupdate_status

(&mut self, status: NodeStatus)

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

↓ 1 callersMethodupdate_task_manager_heartbeat_status

(&self, heartbeat: &Heartbeat)

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

↓ 1 callersFunctionuserAction

(ctx: ExecutionContext)

typescript-api/src/userAction.ts:14

↓ 1 callersMethodusername

(username: string)

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

↓ 1 callersMethodvalidate

()

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

↓ 1 callersFunctionwordCount

(ctx: ExecutionContext)

typescript-api/src/wordCount.ts:9

MethodDescriptor

Deprecated: Use ProbeResponse.ProtoReflect.Descriptor instead.

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

MethodDescriptor

Deprecated: Use EventRequest.ProtoReflect.Descriptor instead.

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

MethodDescriptor

Deprecated: Use EventResponse.ProtoReflect.Descriptor instead.

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

MethodEnum

()

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

MethodEnum

()

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

MethodEnumDescriptor

Deprecated: Use ProbeRequest_NodeType.Descriptor instead.

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

MethodEnumDescriptor

Deprecated: Use ProbeRequest_ProbeType.Descriptor instead.

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

MethodGetAvailable

()

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

MethodGetCode

()

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

MethodGetCpu

()

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

MethodGetData

()

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

MethodGetMemory

()

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

MethodGetMsg

()

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

MethodGetNodeType

()

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

MethodGetProbeType

()

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

MethodNumber

()

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

MethodNumber

()

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

MethodProtoMessage

()

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

MethodProtoMessage

()

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

MethodProtoMessage

()

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

MethodProtoMessage

()

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

MethodProtoReflect

()

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

MethodProtoReflect

()

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

MethodProtoReflect

()

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

MethodProtoReflect

()

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

MethodReset

()

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

MethodReset

()

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

MethodReset

()

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

MethodReset

()

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

MethodString

()

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

MethodString

()

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

MethodString

()

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

MethodString

()

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

MethodString

()

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

MethodType

()

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

MethodType

()

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

Methodaccept_compressed

(mut self, encoding: CompressionEncoding)

src/proto/src/taskmanager.rs:125

Methodaccept_compressed

(mut self, encoding: CompressionEncoding)

src/proto/src/coordinator.rs:73

Functionall_match_mut

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

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

Functionany_match

(elems: &Vec<T>, predicate: F)

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

Functionany_match_mut

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

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

MethodasISink

()

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

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/apiserver.rs:102

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/common.rs:125

← previous next →201–300 of 588, ranked by callers