commit 42e73b02c466a846302a6229b7d975c4f0562c89 · nekomimi.pet/microcosm-rs

Constellation, Spacedust, Slingshot, UFOs: atproto crates and services for microcosm

increase queue by 16x

this should give a bunch of seconds of buffer for the writer to get through stuff before we let pressure reach back to the remote jetstream instance. *hopefully* this will lead to fewer reconnects due to getting booted by jetstream for being slow.

bad-example.com 9 months ago 42e73b02 8f368ff7

options

unified split

Changed files

+1 -1

constellation

src

consumer

mod.rs

+1 -1

constellation/src/consumer/mod.rs

···

       50
       50
        
                   thread::spawn(move || consume_jsonl_file(f, sender)),

     

       51
       51
        
               )

     

       52
       52
        
           } else {

     

       53
       53
       -
               let (sender, receiver) = flume::bounded(2048); // eek

     

       53
       53
       +
               let (sender, receiver) = flume::bounded(32_768); // eek

     

       54
       54
        
               let cursor = store.get_cursor().unwrap();

     

       55
       55
        
               (

     

       56
       56
        
                   receiver,