I'm using PHP and the gRPC API to talk to an etcd cluster. I'm trying to do a watch on a range of keys. I get a WatchClient and call Watch to get a BiDiStreamingCall object and write a WatchCreateRequest. I then go into a loop reading from the stream and processing Events. If the etcd cluster node I'm communicating with goes down, subsequent calls to BiDiStreamingCall::read() fail. My understanding is that as long as there are nodes available the read function should continue. Is this not the case?
grpc bidir stream not crossing nodes in ETCD cluster
106 Views Asked by Gregg H At
1
There are 1 best solutions below
Related Questions in PHP
- php Variable name must change in for loop
- register_shutdown_function is not getting called
- Query returning zero rows despite entries existing
- Retrieving *number* pages by page id
- Automatically closing tags in form input?
- How to resize images with PHP PARSE SDK
- how to send email from localhost using codeigniter?
- Mariadb max Error while sending QUERY packet PID
- Multiusers login redirect different page in php
- Imaginary folder when I use "DirectoryIterator" in PHP?
- CodeIgniter + XDebug: debug only working in the main controller, index() function
- PHP script timeout when I use sleep()
- posting javascript populated form to another php page
- AJAX PHP - Reload div after submit
- PHP : How can I check Array in array?
Related Questions in GRPC
- protoc not generating service stub files
- Using gRPC with Vert.x, netty dependency issue
- Only put .proto protocol buffer file in a repository?
- Adding servers in the client-side dynamically/Runtime
- Docker connectivity issue with gRPC
- How to call microservice without slowing down the response?
- install gRPC and got make error
- How to do routing and avoid deserialization in Grpc / Protobuf?
- grpc number of active clients/channels
- Why do we need to register reflection service on gRPC server
- gRPC with WPF not working
- TensorFlow Server close the connection within client timeout
- Stub uses a single connection over the channel for multithreaded gRPC Client?
- Java + GRPC, for dummies?
- Trying to run node application with grpc on linux ARM processor
Related Questions in ETCD
- Optimistic locking and re-try
- how do i do an atomic update with etcd
- Distributed microservices using Kite and Kontrol
- Hazelcast (Java) and ETCD (golang) differences/similarities?
- Error while running etcd v3 on Docker
- Azure Container Services: Who patches, updates,... (Kubernetes)
- Private etcd cluster using tokens
- etcd api on CoreOS - setting ip address configurations remotely
- How to solve race condition in etcd leader election?
- Can't use etcd in the cluster
- kubernetes and etcd: No action, but the metric "etcd_server_slow_apply_total" increases to 40
- How to remove a master node from a HA cluster and also from etcd cluster
- How to define static IP address for coreos in VMware ESXi via config-drive
- Limiting interactions with ETCD without impacting Performance
- how etcd processing read request
Related Questions in ETCD3
- Error while running etcd v3 on Docker
- How do I create a EtcdCluster in Kubernetes
- start etcd failed by "bind: cannot assign requested address"
- ETCD Snapshot restore + DNS discovery issue
- ETCD Client Watch Event Load Balancer
- Why do I need to put ETCDCTL_API=3 in front of etcdctl for etcdctl snapshot save to work?
- Best practice for "Watch key changes" in etcd v3
- grpc bidir stream not crossing nodes in ETCD cluster
- Disable history in etcd key value store
- Is there a way to determine to which etcd host the kubernetes apiserver is talking to?
- kubernetes 1.18 Stacked control plane and etcd nodes unable to add second ETCD node
- etcdadm init with 3.4.7 version, command fails with unknown flag
- How do I add a default value to a key in etcd3 if one does not already exist?
- Compare-and-swap in etcd v3?
- Can I use ETCD over Cassandra?
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
The BiDiStreamingCall connection sets up communication with a specific node in the etcd cluster. If the connection to that node is lost, the Watch is terminated.