Types & classes — github.com/Rustixir/tokio_sky

CodeHub MCPcopy Create free account

hub / github.com/Rustixir/tokio_sky / types & classes

Types & classes65 in github.com/Rustixir/tokio_sky

⨍ Functions 148◇ Types & classes 65

↓ 1 callersClassMessage

examples/complex(3 layer).rs:113

↓ 1 callersClassOffset

src/builtin/kafka_processor.rs:48

↓ 1 callersClassPartition

src/builtin/kafka_processor.rs:45

InterfaceBatchProcessor

src/batcher.rs:14

examples/dynamic_batching.rs:129

ClassBatcherTerminate

src/batcher.rs:9

examples/pulsar_batcher.rs:80

examples/dynamic_batching.rs:65

This module provide a data collector listen on channel get and push to buffer when buffer was full then dispatch or timeout happen, then dispatch( i

src/builtin/collector.rs:24

src/topology.rs:98

src/processor.rs:39

src/batcher.rs:29

src/producer.rs:42

ClassCustomContext

src/builtin/kafka_producer.rs:34

ClassDeliveryHandler

examples/kafka_processor_complex.rs:101

ClassDeliveryHandler

examples/pulsar_processor_complex.rs:111

EnumDispatchError

src/dispatcher.rs:34

ClassDispatcher

src/dispatcher.rs:56

EnumInternalDispatchError

src/dispatcher.rs:22

ClassKafkaProcessor

src/builtin/kafka_processor.rs:17

ClassKafkaProducer

src/builtin/kafka_producer.rs:53

ClassLayer1Process

examples/complex(2 layer).rs:87

ClassLayer1Process

examples/batch_insert_mysql.rs:99

ClassLayer1Process

examples/simple(1 layer).rs:73

ClassLayer1Process

examples/dynamic_batching.rs:109

ClassLayer1Process

examples/pulsar_batcher.rs:122

ClassLayer1Process

examples/kafka_producer.rs:73

ClassLayer1Process

examples/pulsar_producer.rs:81

ClassLayer1Process

examples/complex(3 layer).rs:97

ClassLayer1Process

examples/collector.rs:70

ClassLayer1Process

examples/ordering_and_paritioning.rs:120

ClassLayer2Process

examples/complex(2 layer).rs:102

ClassLayer2Process

examples/complex(3 layer).rs:115

ClassLayer2Process

examples/ordering_and_paritioning.rs:139

ClassLayer3Process

examples/complex(3 layer).rs:130

ClassMysqlBatcher

examples/batch_insert_mysql.rs:117

ClassProcKafkaMessage

src/builtin/kafka_processor.rs:10

src/processor.rs:24

EnumProcessingType

Realtime, timeout is 1 milliseconds Batch, timeout is 50 milliseconds ## Batch producer await until buffer full or timeout in Batch timeout is 50

src/topology.rs:39

InterfaceProcessor

src/processor.rs:9

examples/complex(2 layer).rs:67

examples/batch_insert_mysql.rs:72

examples/pulsar_processor.rs:87

examples/simple(1 layer).rs:53

examples/kafka_processor_complex.rs:71

examples/dynamic_batching.rs:76

examples/pulsar_batcher.rs:96

examples/complex(3 layer).rs:78

examples/ordering_and_paritioning.rs:95

examples/pulsar_processor_complex.rs:81

examples/kafka_processor.rs:61

ClassProdKafkaMessage

src/builtin/kafka_producer.rs:23

InterfaceProducer

src/producer.rs:17

examples/dynamic_batching.rs:71

ClassPulsarBatchProcessor

src/builtin/pulsar_batcher.rs:21

ClassPulsarProcessor

src/builtin/pulsar_processor.rs:21

ClassPulsarProducer

PulsarProducer when created need to unique name for each instance this module privade a Global Atomic Counter for PulsarProducer

src/builtin/pulsar_producer.rs:37

src/dispatcher.rs:43

EnumStatusResult

src/dispatcher.rs:51

src/producer.rs:13

examples/pulsar_processor.rs:71

examples/pulsar_producer.rs:76

examples/batch_insert_mysql.rs:155

examples/ordering_and_paritioning.rs:89

examples/ordering_and_paritioning.rs:84