kssenii
29362bb483
Support vhost
2021-02-16 22:05:14 +00:00
kssenii
2a887b9772
Add missing format factory settings
2021-02-15 22:06:10 +00:00
Azat Khuzhin
acde56ff8a
Add separate pool for message brokers (RabbitMQ and Kafka)
...
background_message_broker_schedule_pool_size was introduced in #13939 ,
but never used actually, use it for RabbitMQ and Kafka.
2021-01-27 21:08:41 +03:00
Azat Khuzhin
5b3ab48861
More forward declaration for generic headers
...
The following headers are pretty generic, so use forward declaration as
much as possible:
- Context.h
- Settings.h
- ConnectionTimeouts.h
(Also this shows that some missing some includes -- this has been fixed)
And split ConnectionTimeouts.h into ConnectionTimeoutsContext.h (since
module part cannot be added for it, due to recursive build dependencies
that will be introduced)
Also remove Settings from the RemoteBlockInputStream/RemoteQueryExecutor
and just pass the context, since settings was passed only in speicifc
places, that can allow making a copy of Context (i.e. Copier).
Approx results (How much units will be recompiled after changing file X?):
- ConnectionTimeouts.h
- mainline: 100
- Context.h:
- mainline: ~800
- patched: 415
- Settings.h:
- mainline: 900-1K
- patched: 440 (most of them because of the Context.h)
2020-12-12 17:43:10 +03:00
kssenii
8f1ed36897
Fix races
2020-12-06 00:24:49 +00:00
kssenii
448463ebe0
Better
2020-12-04 14:50:42 +00:00
kssenii
f16d6a4128
Better
2020-12-03 14:11:35 +00:00
kssenii
ebab21178e
Fix, add test
2020-12-02 18:45:30 +00:00
kssenii
8d3a538629
Better startup
2020-12-02 01:17:50 +00:00
alesapin
7e014967db
Less broken ugly hack
2020-11-25 00:07:56 +03:00
alesapin
b28fc3d4f6
Ugly fix for dangling reference
2020-11-24 19:24:36 +03:00
Amos Bird
1d9d586e20
Make global_context consistent.
2020-11-20 18:23:14 +08:00
Alexander Tokmakov
b94cc5c4e5
remove more stringstreams
2020-11-10 21:22:26 +03:00
alexey-milovidov
f4ba5f1f9a
Merge pull request #16772 from ClickHouse/fix-stringstream
...
Fix "server failed to start" error
2020-11-08 14:27:08 +03:00
Alexey Milovidov
5314185e25
Merge branch 'master' into azat-optimize_skip_unused_shards-optimization
2020-11-08 00:17:59 +03:00
Alexey Milovidov
fd84d16387
Fix "server failed to start" error
2020-11-07 03:14:53 +03:00
alesapin
617e42ddb4
Merge branch 'master' into rabbit-optimize
2020-10-28 10:24:05 +03:00
kssenii
4b59882c30
Remove redundant, add virt col
2020-10-27 20:34:31 +00:00
Mikhail Filimonov
41971e073a
Fix typos reported by codespell
2020-10-27 12:04:03 +01:00
kssenii
db03cd7dd7
Much more optimal queues setup
2020-10-27 11:00:01 +00:00
kssenii
7beddceadd
Fix bug that caused awful CPU usage
2020-10-27 10:02:27 +00:00
kssenii
cd0dbcb9d8
Minimize event loop lifetime
2020-10-27 10:01:39 +00:00
Alexey Milovidov
5b482f4191
Cleanups
2020-10-10 19:31:10 +03:00
Azat Khuzhin
b838214a35
Pass non-const SelectQueryInfo (and drop mutable qualifiers)
2020-10-02 22:42:35 +03:00
Nikolai Kochetov
6eac433c55
Review fixes.
2020-09-15 13:40:39 +03:00
Nikolai Kochetov
bcfc83022a
Return query plan from storage.
2020-09-14 17:13:58 +03:00
kssenii
40c8290dde
Tiny fixes, better tests
2020-09-07 14:48:50 +00:00
alesapin
17650e803f
Tiny improvements
2020-09-07 14:08:53 +03:00
kssenii
e1ef558a2d
Fixes
2020-09-03 06:50:20 +00:00
kssenii
6682c62a90
Fixes
2020-09-01 20:07:34 +00:00
kssenii
c2fb72abf8
Better mv, more comments
2020-09-01 07:58:41 +00:00
kssenii
e57d1c827f
Better shutdown
2020-08-31 10:00:28 +00:00
kssenii
647cf5718e
Better settings
2020-08-31 09:27:42 +00:00
kssenii
4e0c619721
Global refactoring
2020-08-28 10:03:54 +00:00
kssenii
4fecfdbe2f
Better & cleaner
2020-08-26 18:52:45 +00:00
kssenii
1e7eb49481
Add one more mes property, support format_schema
2020-08-15 15:05:53 +00:00
kssenii
c6fdeb6c02
Better
2020-08-15 08:00:56 +00:00
kssenii
9a409db5c0
Merge branch 'master' of https://github.com/ClickHouse/ClickHouse into rabbitmq-improvements
2020-08-15 06:51:22 +00:00
kssenii
2ea32a710a
More tests, better reconnect
2020-08-08 17:03:55 +00:00
kssenii
1213161cf4
Add some message properties
2020-08-06 20:34:13 +00:00
kssenii
24b032b378
Allow multiple consumers for same queues
2020-08-06 13:50:44 +00:00
Nikolai Kochetov
20e63d2271
Refactor Pipe [part 6]
2020-08-06 15:24:05 +03:00
kssenii
62293f80c0
Small fixes
2020-08-03 09:14:25 +00:00
kssenii
c2bed351ae
Add consumer connection track and restore
2020-08-01 13:05:06 +00:00
kssenii
763c337be9
Remove redundant, move subscription
2020-07-31 04:59:18 +00:00
kssenii
0ee54c8a4a
Fix build, async acks -> sync acks, fix tests
2020-07-28 10:43:25 +00:00
kssenii
22b16060f6
More reliable publishing
2020-07-25 16:56:29 +00:00
kssenii
2b57857afc
Add dl-exchange, commits
2020-07-25 16:56:12 +00:00
kssenii
f9a4bf9e61
Add queue resume read
2020-07-25 16:55:58 +00:00
kssenii
f0f6111655
Move exchange init, add bridge-exchange
2020-07-25 16:55:44 +00:00
kssenii
ac448db491
Add virtuals
2020-07-25 16:55:32 +00:00
kssenii
a88e391bd2
Fix bug with insert, simplify exchanges logic
2020-07-25 16:55:18 +00:00
Alexey Milovidov
8f2055b0a0
Fix trash from RabbitMQ
2020-07-13 04:11:48 +03:00
alesapin
c57edd2018
Tiny fixes
2020-07-03 11:02:35 +03:00
alesapin
c6c7ee30d9
Less race conditions
2020-07-02 19:44:04 +03:00
alesapin
96df2e6b71
Better shutdown and conversion
2020-07-02 17:35:10 +03:00
kssenii
f797efb04c
Fix build
2020-06-30 01:48:11 +00:00
kssenii
fd9b416871
Fix and simplify code
2020-06-29 15:47:25 +00:00
kssenii
88ece429c9
Move writing to RabbitMQ into background task
2020-06-29 12:33:01 +00:00
kssenii
649eb8e348
Move reading from RabbitMQ into background task
2020-06-28 18:20:18 +00:00
alesapin
d5847d29d6
Avoid memory leaks
2020-06-25 12:44:39 +03:00
alesapin
addee61bcb
Trying to do everything on top of libuv, add heartbeats
2020-06-25 00:14:49 +03:00
alesapin
cb30dbfe28
Correct merge with master
2020-06-24 20:32:57 +03:00
kssenii
9e1b8b2872
Better exchanges, fix build, better comments, better tests
2020-06-14 18:36:56 +00:00
kssenii
dcd7b7351c
Support headers-exchange type
2020-06-13 21:47:22 +00:00
kssenii
b8a4c7708a
Make local exchanges unique for each table
2020-06-13 18:15:59 +00:00
kssenii
462e8bcdc9
Support transactions for publishing
2020-06-12 18:10:13 +00:00
kssenii
3b0a3e00c0
Some fixes
2020-06-12 18:09:49 +00:00
kssenii
626eb53baa
Fix multiple bindings for single queue & rm hardcoded strings
2020-06-11 11:13:13 +00:00
kssenii
9350472ee4
Support multiple bindings
2020-06-11 10:29:08 +00:00
kssenii
d7b2694806
Support all exchange types
2020-06-10 23:06:23 +00:00
kssenii
68b94c5c20
Fixes
2020-06-05 13:46:20 +00:00
kssenii
786874e867
Better publish & some fixes
2020-06-02 15:57:30 +00:00
kssenii
806fd27395
Fix build & fix style & fix
2020-06-01 20:48:24 +00:00
kssenii
5757dd1d57
Add insert part
2020-06-01 17:01:41 +00:00
kssenii
e80b405359
Merge branch 'master' of https://github.com/ClickHouse/ClickHouse into add-storage-rabbitmq-read-only
2020-05-31 10:30:53 +00:00
kssenii
037ed3a02c
Code fix & style fix & merge fix
2020-05-31 09:34:57 +00:00
kssenii
8266715c49
Fix build & fix style
2020-05-31 08:39:22 +00:00
kssenii
0362bb2d2f
Make connection between concurrent consumers shared - not private
2020-05-29 16:28:52 +00:00
kssenii
5e472af425
Fix merge & small fix
2020-05-26 20:43:20 +00:00
kssenii
14c67c6ae6
Fixes
2020-05-26 17:34:57 +00:00
kssenii
aeffab3fdb
Enable SELECT and CREATE MV queries with engine RabbitMQ
2020-05-20 09:40:49 +00:00
kssenii
3b75f214c5
Register RabbitMQ storage
2020-05-20 09:09:20 +03:00