api: queue works with connection_pool

[oleg-jukovec]

The patchet allows to use the queue subpackage with the connection_pool subpackage:

1. It adds missed Execute* methods to ConnectionPool.
2. It adds ConnectorAdaptor to the connection_pool subpackage to be able to use ConnectionPool as Connector.

Finally, it adds an example how-to use a Queue with ConnectionPool.

I didn't forget about (remove if it is not applicable):

• Tests (see documentation for a testing package)
• Changelog (see documentation for changelog format)
• Documentation (see documentation for documentation style guide)

Related issues:

Closes #176

[oleg-jukovec]

This pull request is ready for review in general, but I'll wait for #210 to spend less time on rebase.

Also there is a bug in the queue that needs to be fixed to make tests successful.
tarantool/queue#185

[oleg-jukovec]

There is a problem with download from tarantool.io, so we have 2.x-latest tests failed:

2022-09-12T13:08:26.7307211Z ##[group]Run curl -L https://tarantool.io/pre-release/2/installer.sh | sudo bash
2022-09-12T13:08:26.7307719Z �[36;1mcurl -L https://tarantool.io/pre-release/2/installer.sh | sudo bash�[0m
2022-09-12T13:08:26.7308061Z �[36;1msudo apt install -y tarantool tarantool-dev�[0m
2022-09-12T13:08:26.7365945Z shell: /usr/bin/bash -e {0}
2022-09-12T13:08:26.7366196Z ##[endgroup]
2022-09-12T13:08:26.7606388Z   % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current
2022-09-12T13:08:26.7608586Z                                  Dload  Upload   Total   Spent    Left  Speed
2022-09-12T13:08:26.7608776Z 
2022-09-12T13:08:27.3371045Z   0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0
2022-09-12T13:08:27.3414516Z   0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0
2022-09-12T13:08:27.3415325Z   0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0
2022-09-12T13:08:27.3420023Z curl: (60) SSL certificate problem: certificate has expired
2022-09-12T13:08:27.3420600Z More details here: https://curl.haxx.se/docs/sslcerts.html

I think we can ignore this problem for a couple of days.

[DifferentialOrange]

Thank you for your patch!

I have lest several questions. Most of them are not of a great importance, except for the lack of test for the main feature. (Maybe I had missed something.)

[DifferentialOrange]

Sorry, it doesn't seems nice to remove the approval (especially since nothing had changed since last revision), but I've tried to manually run the examples and it wasn't an immediate success.

[oleg-jukovec]

Sorry, it doesn't seems nice to remove the approval (especially since nothing had changed since last revision), but I've tried to manually run the examples and it wasn't an immediate success.

I have updated the example connection_pool + queue. Let's have another round of review.

[DifferentialOrange]

Sorry, I don't get how force-pulling the branch had resulted in its deleting on the remote.

[DifferentialOrange]

Thank you, seems awesome.

I've also tried to ack the taken task after one more master switch, it was a success. If you want, you may add it too, see git diff below.

diff --git a/queue/example_connection_pool_test.go b/queue/example_connection_pool_test.go
index bf1d53d..7b4deae 100644
--- a/queue/example_connection_pool_test.go
+++ b/queue/example_connection_pool_test.go
@@ -185,17 +185,50 @@ func Example_connectionPool() {
        }
 
        // Take a data from the new master instance.
-       if task, err := q.Take(); err == nil || task.Data() == nil {
-               task.Ack()
+       var task *queue.Task
+       task, err = q.Take()
+       if err == nil || task.Data() == nil {
                fmt.Println("Got data:", task.Data())
        } else {
                fmt.Println("Unable to got data:", err)
        }
 
+       // Switch a master instance in the pool.
+       roles = []bool{false, true}
+       err = test_helpers.SetClusterRO(servers, connOpts, roles)
+       if err != nil {
+               fmt.Printf("Unable to set cluster roles: %s", err)
+               return
+       }
+
+       // Wait for a new master instance re-identification.
+       <-h.masterUpdated
+       if h.err != nil {
+               fmt.Printf("Unable to re-identify in the pool: %s", h.err)
+               return
+       }
+
+       err = task.Ack()
+
+       if err != nil {
+               fmt.Printf("Unable to ack the task: %s", err)
+               return
+       }
+
+       var stats interface{}
+       stats, err = q.Statistic()
+       if err != nil {
+               fmt.Printf("Unable to get stats: %s", err)
+               return
+       }
+       fmt.Println(stats)
+
        // Output:
        // Master 127.0.0.1:3014 is ready to work!
        // A Queue object is ready to work.
        // Send data: test_data
        // Master 127.0.0.1:3014 is ready to work!
        // A Queue object is ready to work.
        // Send data: test_data
        // Master 127.0.0.1:3015 is ready to work!
        // Got data: test_data
+       // Master 127.0.0.1:3014 is ready to work!
+       // map[calls:map[ack:1 bury:0 delay:0 delete:0 kick:0 put:1 release:0 take:0 touch:0 ttl:0 ttr:0] tasks:map[buried:0 delayed:0 done:1 ready:0 taken:0 total:0]]
 }

[vr009]

LGTM