minio

Commit Graph

Author	SHA1	Message	Date
Aditya Manthramurthy	c3bbadacbf	Improve Peer RPC error handling (Fixes #2992 ) (#2995 ) * Check for RPC connection shutdown and try again just once. * Refactor SendRPC to use sync.WaitGroup	2016-10-18 21:26:58 -07:00
Aditya Manthramurthy	d02cb963d5	Fix listen-bucket (Fixes #2942 ) (#2949 ) Don't close socket while re-initializing notify-listeners, as the rpc client object is shared between notify-listeners and peer clients. Also, improves SendRPC() readability by using GetPeerClient().	2016-10-16 20:52:10 -07:00
Aditya Manthramurthy	6199aa0707	Peer RPCs for bucket notifications (#2877 ) * Implements a Peer RPC router that sends info to all Minio servers in the cluster. * Bucket notifications are propagated to all nodes via this RPC router. * Bucket listener configuration is persisted to separate object layer file (`listener.json`) and peer RPCs are used to communicate changes throughout the cluster. * When events are generated, RPC calls to send them to other servers where bucket listeners may be connected is implemented. * Some bucket notification tests are now disabled as they cannot work in the new design. * Minor fix in `funcFromPC` to use `path.Join`	2016-10-12 01:03:50 -07:00

Author

SHA1

Message

Date

Aditya Manthramurthy

c3bbadacbf

Improve Peer RPC error handling (Fixes #2992 ) (#2995 )

* Check for RPC connection shutdown and try again just once.

* Refactor SendRPC to use sync.WaitGroup

2016-10-18 21:26:58 -07:00

Aditya Manthramurthy

d02cb963d5

Fix listen-bucket (Fixes #2942 ) (#2949 )

Don't close socket while re-initializing notify-listeners, as the rpc
client object is shared between notify-listeners and peer clients.

Also, improves SendRPC() readability by using GetPeerClient().

2016-10-16 20:52:10 -07:00

Aditya Manthramurthy

6199aa0707

Peer RPCs for bucket notifications (#2877 )

* Implements a Peer RPC router that sends info to all Minio servers in the cluster.
* Bucket notifications are propagated to all nodes via this RPC router.
* Bucket listener configuration is persisted to separate object layer
  file (`listener.json`) and peer RPCs are used to communicate changes
  throughout the cluster.
* When events are generated, RPC calls to send them to other servers
  where bucket listeners may be connected is implemented.
* Some bucket notification tests are now disabled as they cannot work in
  the new design.
* Minor fix in `funcFromPC` to use `path.Join`

2016-10-12 01:03:50 -07:00

3 Commits