Functions — github.com/Rustixir/tokio

hub / github.com/Rustixir/tokio_sky / functions

Functions148 in github.com/Rustixir/tokio_sky

⨍ Functions 148◇ Types & classes 65

↓ 30 callersFunctionstart_processor

(processor_factory: F, mut concurrency: i32,

src/topology.rs:104

↓ 10 callersFunctionstart_producer

(producer_factory: F, mut concurrency: i32, rout

src/topology.rs:48

↓ 6 callersFunctionrun_topology_1

producer -> processor

src/topology.rs:215

↓ 5 callersFunctionstart_batch_processor

(batcher_factory: F, mut concurrency: i32,

src/topology.rs:152

↓ 4 callersFunctionrun_topology_1_with_batcher

producer -> processor -> batcher

↓ 3 callersFunctionrun_topology_2

producer -> processor -> processor

src/topology.rs:261

↓ 2 callersMethoddispatch

(&mut self, msg: T, batch_key: Option<String>)

src/dispatcher.rs:104

↓ 2 callersMethodinit

(&mut self)

src/builtin/collector.rs:46

↓ 2 callersMethodpartition

(&mut self, msg: T, batch_key: String)

src/dispatcher.rs:179

↓ 2 callersMethodterminate

(&mut self)

src/builtin/collector.rs:48

↓ 1 callersMethodadmin_handle

(&self, msg: User)

examples/ordering_and_paritioning.rs:141

↓ 1 callersMethodbatch_accessories_insert

(&self, msg: Product)

examples/dynamic_batching.rs:137

↓ 1 callersMethodbatch_cars_insert

(&self, batch: Vec<Product>)

examples/dynamic_batching.rs:131

↓ 1 callersMethodbatch_mobiles_insert

(&self, msg: Product)

examples/dynamic_batching.rs:134

↓ 1 callersMethodbroadcast

(&mut self, msg: T)

src/dispatcher.rs:218

↓ 1 callersMethodclient_handle

(&self, msg: User)

examples/ordering_and_paritioning.rs:144

↓ 1 callersMethoddrain

(&mut self, _buffer: VecDeque<Input>)

src/builtin/collector.rs:50

↓ 1 callersMethodfill_buffer

(&mut self, buffer_size:usize)

src/builtin/collector.rs:52

↓ 1 callersFunctionget_new_id

()

src/builtin/pulsar_processor.rs:90

↓ 1 callersFunctionget_new_id

()

src/builtin/pulsar_batcher.rs:80

↓ 1 callersFunctionget_new_id

()

src/builtin/pulsar_producer.rs:167

↓ 1 callersMethodhandle_message

(&mut self, msg: ProcKafkaMessage)

src/builtin/kafka_processor.rs:58

↓ 1 callersMethodlogic_roundrobin

(&mut self, mut msg: T)

src/dispatcher.rs:319

↓ 1 callersMethodnext_index

(&mut self)

src/dispatcher.rs:368

↓ 1 callersMethodroundrobin

(&mut self, mut msg: T)

src/dispatcher.rs:270

↓ 1 callersFunctionrun_topology_3

producer -> processor -> processor -> processor

src/topology.rs:332

↓ 1 callersFunctionstart_shutdown_manager

(shutdown_recv: oneshot::Receiver<()>, list_shutdown: Vec<oneshot::Sender<()>>)

src/shutdown_manager.rs:5

Methodcommit_callback

(&self, result: KafkaResult<()>, _offsets: &TopicPartitionList)

src/builtin/kafka_producer.rs:47

Methoddrain

(&mut self, batch: Vec<Input>)

src/builtin/pulsar_batcher.rs:62

Methoddrain

(&mut self, _buffer: VecDeque<ProdKafkaMessage>)

src/builtin/kafka_producer.rs:98

Methoddrain

(&mut self, buffer: VecDeque<Output>)

src/builtin/pulsar_producer.rs:83

Methoddrain

(&mut self, _buffer: VecDeque<usize>)

examples/complex(2 layer).rs:74

Methoddrain

(&mut self, _buffer: VecDeque<User>)

examples/batch_insert_mysql.rs:80

Methoddrain

(&mut self, _buffer: VecDeque<TestData>)

examples/pulsar_processor.rs:95

Methoddrain

(&mut self, _buffer: VecDeque<usize>)

examples/simple(1 layer).rs:61

Methoddrain

(&mut self, _buffer: VecDeque<ProcKafkaMessage>)

examples/kafka_processor_complex.rs:79

Methoddrain

(&mut self, _buffer: VecDeque<Product>)

examples/dynamic_batching.rs:83

Methoddrain

(&mut self, _buffer: VecDeque<Cat>)

examples/pulsar_batcher.rs:104

Methoddrain

(&mut self, _buffer: VecDeque<usize>)

examples/complex(3 layer).rs:85

Methoddrain

(&mut self, _buffer: VecDeque<User>)

examples/ordering_and_paritioning.rs:102

Methoddrain

(&mut self, _buffer: VecDeque<ProcKafkaMessage>)

examples/pulsar_processor_complex.rs:89

Methoddrain

(&mut self, _buffer: VecDeque<ProcKafkaMessage>)

examples/kafka_processor.rs:69

Methodfill_buffer

(&mut self, buffer_size:usize)

src/builtin/kafka_producer.rs:102

Methodfill_buffer

(&mut self, buffer_size: usize)

src/builtin/pulsar_producer.rs:85

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/complex(2 layer).rs:77

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/batch_insert_mysql.rs:82

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/pulsar_processor.rs:97

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/simple(1 layer).rs:63

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/kafka_processor_complex.rs:81

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/dynamic_batching.rs:86

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/pulsar_batcher.rs:106

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/complex(3 layer).rs:87

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/ordering_and_paritioning.rs:105

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/pulsar_processor_complex.rs:91

Methodfill_buffer

(&mut self, buffer_size: usize)

examples/kafka_processor.rs:71

Methodhandle_batch

(&mut self, batch: Vec<Input>)

src/builtin/pulsar_batcher.rs:65

Methodhandle_batch

(&mut self, batch: Vec<User>)

examples/batch_insert_mysql.rs:137

Methodhandle_batch

(&mut self, batch: Vec<Product>)

examples/dynamic_batching.rs:148

Methodhandle_message

(&mut self, msg: Input)

src/builtin/pulsar_processor.rs:74

Methodhandle_message

(&mut self, msg: usize)

examples/complex(2 layer).rs:93

Methodhandle_message

(&mut self, msg: User)

examples/batch_insert_mysql.rs:105

Methodhandle_message

(&mut self, msg: usize)

examples/simple(1 layer).rs:79

Methodhandle_message

(&mut self, msg: OwnedDeliveryResult)

examples/kafka_processor_complex.rs:110

Methodhandle_message

(&mut self, msg: Product)

examples/dynamic_batching.rs:115

Methodhandle_message

(&mut self, msg: Cat)

examples/pulsar_batcher.rs:128

Methodhandle_message

(&mut self, msg: ProdKafkaMessage)

examples/kafka_producer.rs:79

Methodhandle_message

(&mut self, msg: TestData)

examples/pulsar_producer.rs:87

Methodhandle_message

(&mut self, msg: usize)

examples/complex(3 layer).rs:103

Methodhandle_message

(&mut self, msg: i32)

examples/collector.rs:76

Methodhandle_message

(&mut self, msg: User)

examples/ordering_and_paritioning.rs:126

Methodhandle_message

(&mut self, msg: DeliveryResult)

examples/pulsar_processor_complex.rs:117

Methodinit

(&mut self)

src/builtin/pulsar_processor.rs:70

Methodinit

(&mut self)

src/builtin/pulsar_batcher.rs:58

Methodinit

(&mut self)

src/builtin/kafka_producer.rs:94

Methodinit

(&mut self)

src/builtin/pulsar_producer.rs:79

Methodinit

(&mut self)

src/builtin/kafka_processor.rs:54

Methodinit

(&mut self)

examples/complex(2 layer).rs:71

Methodinit

(&mut self)

examples/batch_insert_mysql.rs:76

Methodinit

(&mut self)

examples/pulsar_processor.rs:91

Methodinit

(&mut self)

examples/simple(1 layer).rs:57

Methodinit

(&mut self)

examples/kafka_processor_complex.rs:75

Methodinit

(&mut self)

examples/dynamic_batching.rs:80

Methodinit

(&mut self)

examples/pulsar_batcher.rs:100

Methodinit

(&mut self)

examples/kafka_producer.rs:76

Methodinit

(&mut self)

examples/pulsar_producer.rs:84

Methodinit

(&mut self)

examples/complex(3 layer).rs:82

Methodinit

(&mut self)

examples/collector.rs:73

Methodinit

(&mut self)

examples/ordering_and_paritioning.rs:99

Methodinit

(&mut self)

examples/pulsar_processor_complex.rs:85

Methodinit

(&mut self)

examples/kafka_processor.rs:65

Methodlist_check

Check channels to not be repetive

src/dispatcher.rs:383

Functionmain

()

examples/complex(2 layer).rs:5

Functionmain

()

examples/batch_insert_mysql.rs:5

Functionmain

()

examples/pulsar_processor.rs:5

Functionmain

()

examples/simple(1 layer).rs:4

Functionmain

()

examples/kafka_processor_complex.rs:5

Functionmain

()

examples/dynamic_batching.rs:6

Functionmain

()

examples/pulsar_batcher.rs:6

Functionmain

()

examples/kafka_producer.rs:5

next →1–100 of 148, ranked by callers