justinweng-instaclustr:handle-offline-shotover-nodes - Branch - shotover/shotover-proxy

Exclude offline shotover nodes when rewriting responses

#1770Merged

Comparing

justinweng-instaclustr:handle-offline-shotover-nodes

(

6f5edc2

) with

main

(

de0fca3

)

Untouched: 38

Benchmarks

Passed

encode_system.local_query_v4_no_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::encode_system.local_query_v4_no_compression

+5%

14.5 µs13.9 µs

encode_request_fetch

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::encode_request_fetch

+4%

12.4 µs12 µs

decode_request_list_offsets_drop

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_list_offsets_drop

+3%

4 µs3.9 µs

encode_request_metadata

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::encode_request_metadata

+2%

11.7 µs11.4 µs

encode_system.local_query_v4_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::encode_system.local_query_v4_lz4_compression

+2%

13.8 µs13.6 µs

decode_request_fetch_drop

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_fetch_drop

+1%

4.1 µs4 µs

encode_system.local_query_v5_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::encode_system.local_query_v5_lz4_compression

+1%

26.7 µs26.4 µs

decode_request_fetch_create

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_fetch_create

+1%

13 µs12.8 µs

encode_request_list_offsets

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::encode_request_list_offsets

+1%

11.9 µs11.8 µs

decode_request_produce_drop

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_produce_drop

+1%

4.1 µs4.1 µs

encode_system.local_query_v5_no_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::encode_system.local_query_v5_no_compression

+1%

15 µs14.9 µs

decode_system.local_result_v4_no_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_result_v4_no_compression

+1%

14.8 µs14.7 µs

decode_system.local_query_v5_no_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_query_v5_no_compression

+1%

57 µs56.7 µs

decode_system.local_query_v4_no_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_query_v4_no_compression

+1%

55.2 µs54.9 µs

decode_system.local_query_v4_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_query_v4_lz4_compression

55.2 µs55 µs

cassandra_rewrite_peers_passthrough

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::cassandra_rewrite_peers_passthrough

81.4 µs81.1 µs

decode_system.local_result_v5_no_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_result_v5_no_compression

14.9 µs14.9 µs

decode_request_produce_create

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_produce_create

14.4 µs14.3 µs

cassandra_protect_protected

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::cassandra_protect_protected

74 µs73.8 µs

decode_system.local_result_v5_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_result_v5_lz4_compression

45 µs44.8 µs

cassandra_protect_unprotected

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::cassandra_protect_unprotected

41.4 µs41.3 µs

encode_all

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::encode_all

19.3 µs19.2 µs

encode_system.local_result_v4_no_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::encode_system.local_result_v4_no_compression

93.1 µs92.8 µs

decode_system.local_result_v4_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_result_v4_lz4_compression

45 µs45 µs

cassandra_request_throttling_unparsed

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::cassandra_request_throttling_unparsed

14.6 µs14.6 µs

decode_request_list_offsets_create

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_list_offsets_create

11.6 µs11.6 µs

decode_system.local_query_v5_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::decode_system.local_query_v5_lz4_compression

56.7 µs56.8 µs

encode_request_produce

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::encode_request_produce

8.5 µs8.6 µs

encode_system.local_result_v5_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::encode_system.local_result_v5_lz4_compression

199.4 µs200 µs

encode_system.local_result_v4_lz4_compression

shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec::encode_system.local_result_v4_lz4_compression

201.6 µs202.4 µs

query_counter_fresh

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::query_counter_fresh

-1%

14.6 µs14.6 µs

redis_filter

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::redis_filter

-1%

22.8 µs22.9 µs

query_counter_pre_used

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::query_counter_pre_used

-1%

11.3 µs11.4 µs

loopback

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::loopback

-1%

6.4 µs6.5 µs

decode_request_metadata_create

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_metadata_create

-1%

10.2 µs10.3 µs

redis_cluster_ports_rewrite

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::redis_cluster_ports_rewrite

-1%

18.1 µs18.2 µs

nullsink

shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform::nullsink

-1%

14.1 µs14.3 µs

decode_request_metadata_drop

shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec::decode_request_metadata_drop

-4%

3.3 µs3.4 µs

Commits

Click on a commit to change the comparison range

Base

main

de0fca3

-22.59%

renaming

132ff42

1 year ago

by justinweng-instaclustr

+22.61%

Merge branch 'main' into handle-offline-shotover-nodes

d7f553a

1 year ago

by justinweng-instaclustr

-0.02%

change shotovernode visibility

f45682c

1 year ago

by justinweng-instaclustr

+10.67%

Merge branch 'refs/heads/main' into handle-offline-shotover-nodes

1b90587

1 year ago

by justinweng-instaclustr

-9.99%

update test case

5fd897c

1 year ago

by justinweng-instaclustr

-0.01%

fix test

98c71d8

1 year ago

by justinweng-instaclustr

+0.18%

add doco about new config field

f9be00d

1 year ago

by justinweng-instaclustr

-0.38%

update test

c6c63c2

1 year ago

by justinweng-instaclustr

-0.11%

fix log format

57a8a03

1 year ago

by justinweng-instaclustr

-0.07%

fix infinite loop when shotover_peers is empty

ff16443

11 months ago

by justinweng-instaclustr

-14.19%

add new config for tests

1ae95b3

11 months ago

by justinweng-instaclustr

+0.39%

update changelog

9c9ec2e

11 months ago

by justinweng-instaclustr

-0.66%

address comments

db16134

11 months ago

by justinweng-instaclustr

+2.01%

add expected warn logs

eeb8f54

11 months ago

by justinweng-instaclustr

+12.33%

add expected warn logs

74c41d3

11 months ago

by justinweng-instaclustr

-12.01%

Merge branch 'main' into handle-offline-shotover-nodes

b1e7742

11 months ago

by justinweng-instaclustr

+11.78%

exclude down shotover nodes when rewriting responses

848813c

11 months ago

by justinweng-instaclustr

+0.49%

add fallback to out of rack shotover nodes

b4a2eb4

11 months ago

by justinweng-instaclustr

-13.64%

Merge branch 'refs/heads/main' into handle-offline-shotover-nodes # Conflicts: # shotover/src/transforms/kafka/sink_cluster/mod.rs

a82ea8e

11 months ago

by justinweng-instaclustr

+13.72%

address comments

0b845bb

11 months ago

by justinweng-instaclustr

+0.1%

Merge branch 'main' into handle-offline-shotover-nodes

58b5b60

11 months ago

by justinweng-instaclustr

-0.48%

update test cases

3b4a34e

11 months ago

by justinweng-instaclustr

+0.06%

disable tests for cpp driver

d4b3a6a

11 months ago

by justinweng-instaclustr

+0.22%

update tests

6f5edc2

11 months ago

by justinweng-instaclustr

Home Terms Privacy Docs