Jonathan Strong
96a8d44b97
silence compiler warning
3 years ago
Jonathan Strong
c47903d464
add a drop deadline to exit routine
3 years ago
Jonathan Strong
3c9988dd42
upgrade decimal crate to v2.4, add more robust handling for int conversion errors in AsI64 impls
4 years ago
Jonathan Strong
e380a77113
skip serializing NaN f64/d128 values, rather than previous strategy of supplying -999.0 signal value
I find excluding -999.0 values annoying in practice.
4 years ago
Jonathan Strong
5830d1d13c
in measure, allow `Option<d128>` fields with "D" prefix
example:
```
let a: Option<d128> = Some(d128::from_str("123.456").unwrap());
let b: Option<d128> = None;
measure!(influx, meas, D(a), D(b));
```
in the `None` case, no field is added at all.
4 years ago
Jonathan Strong
a68306df1f
prefix various log messages with "InfluxWriter: "
4 years ago
Jonathan Strong
50c7892809
reduce frequency of status update log message from 60s to 300s
4 years ago
Jonathan Strong
0a805ab609
reverse InfluxWriter::with_logger deprecation in face of overwhelming popular demand
4 years ago
Jonathan Strong
58bc3b9a39
remove obe 'mm' prefix to InfluxWriter thread name
4 years ago
Jonathan Strong
e8872c9004
reduce sleep duration when closing thread from 1s -> 10ms
4 years ago
Jonathan Strong
f944dba825
add authenticated writes functionality
4 years ago
Jonathan Strong
9178b7a13b
validate memory scaling, add logging
- adds example to repeatedly send many measurements to InfluxWriter for purposes of stress testing (i.e. shut influxdb off, see if InfluxWriter recovers correctly)
- InfluxWriter now tracks allocated buffer memory and logs it
- lower INITIAL_BACKLOG
4 years ago
Jonathan Strong
3e476ce20e
allow writer thread to scale up from INITIAL_BACKLOG to MAX_BACKLOG and then back down
4 years ago
Jonathan Strong
29dc9b8010
fix misc other broken things
4 years ago
Jonathan Strong
94f1e93026
get rid of everything else except the influx mod, and rename the crate influx-writer
4 years ago
Jonathan Strong
102312efb6
minor fix in measure!
4 years ago
Jonathan Strong
b6fc9a97e6
significant cleanup
4 years ago
Jonathan Strong
1da2c1ab09
fix minor blemishes
4 years ago
Jonathan Strong
903b4c4005
small settings tweaks
5 years ago
Jonathan Strong
87302bd2fa
change sleep 100ms -> 1ms
5 years ago
Jonathan Strong
a7ffcba0e5
adds InfluxWriter::is_full
5 years ago
Jonathan Strong
86542209b1
min changes to allow string tags in feature gate
5 years ago
Jonathan Strong
c4959c6e06
tone it down a notch
5 years ago
Jonathan Strong
7a75c7b494
ignore measure bench for tests
5 years ago
Jonathan Strong
63c9314b5b
add one million writes bench
5 years ago
Jonathan Strong
7a0684371f
adds `pub fn rotating_file_logger<P>(path: P, level: Severity, compress: bool) -> slog::Logger`
allows optional compression on rotated logfiles
5 years ago
Jonathan Strong
7d2fce56a4
add test to verify Utc -> nanos is lossless
5 years ago
Jonathan Strong
dbd72c21fa
upgrade sloggers to v0.3 and use new log rotation/compression features
6 years ago
Jonathan Strong
4a28334f4a
log(InfluxWriter): add msg when recovers from request failure
6 years ago
Jonathan Strong
4830a27c3b
revamped InfluxWriter passed its tests with flying colors
this thing is a fucking rock now
6 years ago
Jonathan Strong
d1b895468c
beffudling fixes from cargo fix --edition
6 years ago
Jonathan Strong
11b214da7a
feat(InfluxWriter): huge refactor so InfluxWriter queues a backlog on failed db requests
will need extensive testing before prod use
6 years ago
Jonathan Strong
045302465b
InfluxWriter::placeholder() -> no thread for tests, etc
6 years ago
Jonathan Strong
13dd21f730
change nan replacement value from 0.0 to -999.0 so it's obvious
6 years ago
Jonathan Strong
ac6076e45a
add host, db accessors
6 years ago
Jonathan Strong
25f6d4c206
add logging/anal retentiveness to kill routine
6 years ago
Jonathan Strong
aa5cdf2b3b
adds pub fn secs(Duration) -> f64 at crate root and InfluxWriter::secs(&self, Duration) -> f64
6 years ago
Jonathan Strong
77a1fd79d4
hide latency mod behind feature gate
6 years ago
Jonathan Strong
102f6ac7e8
changes default InfluxWriter buffer to 4096 (anal retentive)
6 years ago
Jonathan Strong
37d8e7ad59
AsI64 for i16, i8, u8
6 years ago
Jonathan Strong
33519ceece
pub fn nanos_utc(t: i64) -> DateTime<Utc>
6 years ago
Jonathan Strong
0a10d55142
whitespace removal
6 years ago
Jonathan Strong
01eb000131
moves `Default` `InfluxWriter` log path to /tmp
6 years ago
Jonathan Strong
2b303be4ec
swaps in the dirs crate home_dir() instead of deprecated std fn
6 years ago
Jonathan Strong
0928bd4f74
adds HistLog::with_path constructor
6 years ago
Jonathan Strong
00d0e1a427
makes zmq optional dep
6 years ago
Jonathan Strong
f59c627187
check if floats are finite, replacing NaNs with 0.0 to avoid influx server errors
6 years ago
Jonathan Strong
e47c0952fb
check if there are no fields (only tags), in which case add an integer field "n" with value 1
6 years ago
Jonathan Strong
d1849fad78
changes InfluxWriter to buffer size of 4096, or if 2 seconds since last send
6 years ago
Jonathan Strong
a1922b387e
adds InfluxWriter::secs(&self, Duration) -> f64
6 years ago