Directories ¶
Path | Synopsis |
---|---|
Package batcher provides retriable batch queue: all succeed or rollback for all.
|
Package batcher provides retriable batch queue: all succeed or rollback for all. |
mockproducer
A smoke test for batcher package.
|
A smoke test for batcher package. |
Package checkpoint persists event log state information so that event log consumer can resume from the last read event in the case of a restart or unexpected interruption.
|
Package checkpoint persists event log state information so that event log consumer can resume from the last read event in the case of a restart or unexpected interruption. |
Package cluster provides helix-alike leader/standby model and layered resource scheduler.
|
Package cluster provides helix-alike leader/standby model and layered resource scheduler. |
raft
Package raft implements cluster via Raft protocol.
|
Package raft implements cluster via Raft protocol. |
Package dsn provides unified DSN scheme.
|
Package dsn provides unified DSN scheme. |
Package es provides functionalities of ElasticSearch.
|
Package es provides functionalities of ElasticSearch. |
Package idempotent provides storage to filter duplicated content.
|
Package idempotent provides storage to filter duplicated content. |
kpub
A script to test kafka async and ack mechanism.
|
A script to test kafka async and ack mechanism. |
Package middleware provides middleware for HTTP handlers.
|
Package middleware provides middleware for HTTP handlers. |
Package model defines data structure that is shared across different categories of plugins.
|
Package model defines data structure that is shared across different categories of plugins. |
Package myslave simulates a mysql slave and listens for master to push the binlog stream.
|
Package myslave simulates a mysql slave and listens for master to push the binlog stream. |
Package sys provides internal data that is OS dependent.
|
Package sys provides internal data that is OS dependent. |
Click to show internal directories.
Click to hide internal directories.