From 1a2a1f4735e40675abf6cd9767c99374359ec2bb Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Tue, 22 Jun 2021 11:44:22 +0300 Subject: - Remove all old code, reformat, fix linters, return GA Signed-off-by: Valery Piashchynski --- proto/websockets/v1beta/websockets.pb.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'proto/websockets/v1beta/websockets.pb.go') diff --git a/proto/websockets/v1beta/websockets.pb.go b/proto/websockets/v1beta/websockets.pb.go index ad4ebbe7..a2868118 100644 --- a/proto/websockets/v1beta/websockets.pb.go +++ b/proto/websockets/v1beta/websockets.pb.go @@ -7,10 +7,11 @@ package websocketsv1beta import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" + + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" ) const ( -- cgit v1.2.3 From 2c78e93222cc9d3b88456175348e42f7f40c449b Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Tue, 6 Jul 2021 17:30:31 +0300 Subject: Rework ephemeral and binary heaps Implemented a sync.Cond for binary heap algo to save processor from spinning in the for loop and receiving nil Items until the Queue will be filled. Add num_pollers option to the configuration to specify number of pollers from the queue. Add Resume, ResumeAll, Stop, StopAll, PushBatch methods to the ephemeral. Remove map and use sync.Map in the ephemeral broker. Add protobuf schema. Signed-off-by: Valery Piashchynski --- proto/websockets/v1beta/websockets.pb.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'proto/websockets/v1beta/websockets.pb.go') diff --git a/proto/websockets/v1beta/websockets.pb.go b/proto/websockets/v1beta/websockets.pb.go index a2868118..188dcf08 100644 --- a/proto/websockets/v1beta/websockets.pb.go +++ b/proto/websockets/v1beta/websockets.pb.go @@ -1,17 +1,16 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.26.0 -// protoc v3.16.0 +// protoc-gen-go v1.27.1 +// protoc v3.17.3 // source: websockets.proto package websocketsv1beta import ( - reflect "reflect" - sync "sync" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" ) const ( -- cgit v1.2.3 From 589f759cc2411319adbca2ece0dbe212407d1eba Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Sun, 11 Jul 2021 10:11:22 +0300 Subject: Update informer interface to return slice of pointers (do not over-copy the Stat structure). Make amqp Push concurrent safe. Signed-off-by: Valery Piashchynski --- proto/websockets/v1beta/websockets.pb.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'proto/websockets/v1beta/websockets.pb.go') diff --git a/proto/websockets/v1beta/websockets.pb.go b/proto/websockets/v1beta/websockets.pb.go index 188dcf08..b07c271e 100644 --- a/proto/websockets/v1beta/websockets.pb.go +++ b/proto/websockets/v1beta/websockets.pb.go @@ -7,10 +7,11 @@ package websocketsv1beta import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" + + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" ) const ( -- cgit v1.2.3