kant777

why does conn.Write ignoring the number bytes written?

2

Hi, why does conn.Write ignoring the number bytes written here https://github.com/gobwas/ws/blob/master/write.go#L95 ? It seems to me that there is no guarantee net.Conn will write all the byes in one write...

How to deploy clickhouse along with clickhouse-keeper using the clickhouse operator?

14

Currently the docs still point to Zookeeper and also says Zookeeper is required while Clickhouse 22.3 says Clickhouse-Keeper is production ready! I do see some k8's files for Clickhouse-Keeper but...

How to extract a fd using this library?

1

I am trying to keep track of some user state in my application and I would like to get an integer fd of the connection so I can hash and...

I am new to this library and I am trying to figure out how does this library help batching syscalls for network I/O. my use case is I am trying...

is there a way to visualize the network while it is getting constructed?

1

is there a way to visualize the network while it is getting constructed? I understand this library is very good at providing an easy way to visualize static networks. But...

How to stream filtered values ?

1

Imagine I get a stream of messages like below from a incoming socket ``` {"name": "Alice", "grandslams": 20, "country": "switzerland"} {"name": "Bob", "grandslams": 10, "country": "spain"} {"name": "Charlie", "grandslams": 12,...

How to get the latest two events on a specific window using Flint?

1

How to get the latest two events using this library? Say I have the following ``` time | price --------------- 1000L | 40 2000L | 20 3000L | 80 4000L...

``` 2022-09-10T10:45:33.163613Z info Failed sending transaction {"chain_id": "evmos_9000-4", "msg-0": {"msg_json": "{\"client_state\":{\"chain_id\":\"osmo-test-4\",\"trust_level\":{\"numerator\":\"1\",\"denominator\":\"3\"},\"trusting_period\":\"1026000000000000\",\"unbonding_period\":\"1209600000000000\",\"max_clock_drift\":\"600000000000\",\"frozen_height\":{},\"latest_height\":{\"revision_number\":\"4\",\"revision_height\":\"6583203\"},\"proof_specs\":[{\"leaf_spec\":{\"hash\":1,\"prehash_value\":1,\"length\":1,\"prefix\":\"AA==\"},\"inner_spec\":{\"child_order\":[0,1],\"child_size\":33,\"min_prefix_length\":4,\"max_prefix_length\":12,\"hash\":1}},{\"leaf_spec\":{\"hash\":1,\"prehash_value\":1,\"length\":1,\"prefix\":\"AA==\"},\"inner_spec\":{\"child_order\":[0,1],\"child_size\":32,\"min_prefix_length\":1,\"max_prefix_length\":1,\"hash\":1}}],\"upgrade_path\":[\"upgrade\",\"upgradedIBCState\"],\"allow_update_after_expiry\":true,\"allow_update_after_misbehaviour\":true},\"consensus_state\":{\"timestamp\":\"2022-09-10T10:35:23.830043827Z\",\"root\":{\"hash\":\"oPTaFEgsxaLnku5CprhkOqdILmCvS39RQj77gCh3RI8=\"},\"next_validators_hash\":\"BD0B8F63DAED1E80CF3F36C801ABB325D9252B4B7A7E6902604C4CD27C2AD008\"},\"signer\":\"evmos1w2p5uafz9xlmd5qyz2nntdy9m7tp7t088k3068\"}"}, "error": "timed out after: 600000000000; timed out after waiting for tx to get included in the block"} ``` I...

Can we run ConnectedComponents algorithm in production using this library?

3

Hi! I wondering how stable is this library to use and run Connected Components in production? I see the following https://github.com/vasia/gelly-streaming/blob/master/src/main/java/org/apache/flink/graph/streaming/SummaryBulkAggregation.java#L78 and I am wondering why is it hardcoded to...