Packages

super_cache

0.9.0
1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 0.11.0 0.10.1 0.10.0 0.9.0 0.8.0 0.7.1 0.7.0 0.6.1 0.6.0 0.5.2 0.5.1 0.5.1-dev 0.4.1 0.4.0 0.4.0-dev2 0.4.0-dev 0.3.1 0.3.1-dev 0.3.0-dev

An in-memory caching library using tuples as the core data type, with support for structs, key/value pairs, queues, and stacks. Includes experimental distributed caching.

HexDocs

Current section

Files

Jump to
Readme
25 Versions
0 Dependencies
Dependants
Files
Activity
super_cache lib cluster router.md
Raw

lib/cluster/router.md 

# Api route for distributed



```mermaid

flowchart TD

    Client(["Any node\nDistributed.put!(data)"])

    Router["Router\npartition_idx = hash(data)\nprimary = Manager.get_replicas(idx)"]



    Client --> Router



    Router -->|"primary == node()"| LocalWrite["Local ETS write\nStorage.put(data, partition)"]

    Router -->|"primary != node()"| Forward["erpc.call(primary,\nRouter.remote_put, data)"]



    Forward -->|"on primary node"| LocalWrite



    LocalWrite --> Replicator["Replicator.replicate(idx, :put, data)\n(async, fire-and-forget)"]

    Replicator -->|"spawn"| R1["erpc → replica 1\nReplicator.apply_op"]

    Replicator -->|"spawn"| R2["erpc → replica 2\nReplicator.apply_op"]



    R1 --> ETS1[("Replica 1 ETS")]

    R2 --> ETS2[("Replica 2 ETS")]

    LocalWrite --> ETS0[("Primary ETS")]



    style LocalWrite fill:#2d6a4f,color:#fff

    style Forward fill:#e76f51,color:#fff

    style Replicator fill:#457b9d,color:#fff

    style ETS0 fill:#2d6a4f,color:#fff

    style ETS1 fill:#457b9d,color:#fff

    style ETS2 fill:#457b9d,color:#fff

```