Commit Graph

25 Commits

Author SHA1 Message Date
4da14b61c1 update micro to v3.1.1
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-16 00:17:42 +03:00
36040a5765 codec rewrite
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-11-26 01:17:21 +03:00
46ed1f8fa4 fix for latest micro
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-11-03 02:15:31 +03:00
4209736cb8 move extractor to micro
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-10-09 16:26:35 +03:00
2c03ee8ec6 use own fork
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 16:08:45 +03:00
4c65c013e5 use server context when create handler context
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:22:13 +03:00
Asim Aslam
242c0acf1e Decruft the broker by removing Event interface (#1940) 2020-09-20 15:11:09 +03:00
Asim Aslam
9365b1fe9b Add subscriber naem 2020-09-20 15:11:09 +03:00
Asim Aslam
b021fcb130 v3 refactor (#1868)
* Move to v3

Co-authored-by: Ben Toogood <bentoogood@gmail.com>
2020-09-20 15:11:09 +03:00
05b18c03dc minimize allocations in logger and tunnel code (#1323)
* logs alloc

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* fix allocs

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* fix allocs

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* tunnel allocs

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* try to fix tunnel

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* cache cipher for send

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* more logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:09 +03:00
Jake Sanders
b0164dca94 Comment typo in gRPC subscriber (#1304) 2020-09-20 15:11:09 +03:00
b48f919b7b server/grpc: avoid panic in case of nil Header (#1303)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:09 +03:00
6ebe79538a various fixes (#1267)
* logger: remove Panic log level

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server/grpc: add missing Unlock in Subscribe error

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server: minor code change

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server/grpc: extend test suite with pub/sub testing

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server/grpc: fix invalid check and allow subscriber error to be returned

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* server/grpc: add pubsub tests

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* client/grpc: check for nil req/rsp

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:09 +03:00
78d2884ced allocations improvements and tunnel fixes (#1248)
* reduce allocations in tunnel code

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* another allocation fix

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* allocate maps with len if it known

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* allocate key for send once

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:09 +03:00
28ef20ef4a prune util/log and user logger (#1237)
* prune util/log and user logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* plaintext logger

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

* add newline

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:08 +03:00
6b5eb3555b fix import paths for v2 release
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:08 +03:00
Astone
c1382ac0b7 named return value for error defer modify. 2020-09-20 15:11:08 +03:00
b78060a571 subscriber recovery
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-20 15:11:08 +03:00
Asim Aslam
15b405b1a9 The mega cruft proxy PR (#974)
* the mega cruft proxy PR

* Rename broker id

* add protocol=grpc

* fix compilation breaks

* Add the tunnel broker to the network

* fix broker id

* continue to be backwards compatible in the protocol
2020-09-20 15:11:08 +03:00
Asim Aslam
4a4159a9f6 Force grpc client/server to use grpc codec for broker 2020-09-20 15:11:08 +03:00
Asim Aslam
7d6efd8a74 move all the buffer references to util/buf 2020-09-20 15:11:08 +03:00
Asim Aslam
5cedaef171 Change Publication to Event 2020-09-20 15:11:08 +03:00
johnson
6f50ba3575 a. add default context type when header not found
b. return subscribe error after handler finished
2020-09-20 15:11:08 +03:00
johnson
6d0872a1df missing nil check for grpc WaitGroup 2020-09-20 15:11:08 +03:00
Asim Aslam
8a3538eb77 Further consolidate the libraries 2020-09-20 15:11:08 +03:00