From d6029e64fc46a5de6a2492aa82dc6f46aa01f3f5 Mon Sep 17 00:00:00 2001 From: Matt Jaffee Date: Wed, 27 Jun 2018 15:33:53 -0500 Subject: [PATCH] remove EventReceiver - not used anymore --- cluster.go | 10 +++------- event.go | 18 ------------------ 2 files changed, 3 insertions(+), 25 deletions(-) diff --git a/cluster.go b/cluster.go index e10aae84e..e1ea2ada7 100644 --- a/cluster.go +++ b/cluster.go @@ -231,9 +231,6 @@ type Cluster struct { // Maximum number of Set() or Clear() commands per request. MaxWritesPerRequest int - // EventReceiver receives NodeEvents pertaining to node membership. - EventReceiver EventReceiver - // Data directory path. Path string Topology *Topology @@ -268,10 +265,9 @@ type Cluster struct { // NewCluster returns a new instance of Cluster with defaults. func NewCluster() *Cluster { return &Cluster{ - Hasher: &jmphasher{}, - PartitionN: DefaultPartitionN, - ReplicaN: 1, - EventReceiver: NopEventReceiver, + Hasher: &jmphasher{}, + PartitionN: DefaultPartitionN, + ReplicaN: 1, joiningLeavingNodes: make(chan nodeAction, 10), // buffered channel jobs: make(map[int64]*resizeJob), diff --git a/event.go b/event.go index 5df69361b..69229b1e4 100644 --- a/event.go +++ b/event.go @@ -35,21 +35,3 @@ type NodeEvent struct { type EventHandler interface { ReceiveEvent(e *NodeEvent) error } - -// EventReceiver is the interface for the object which will listen for and -// decode broadcast messages before passing them to pilosa to handle. The -// implementation of this could be an http server which listens for messages, -// gets the protobuf payload, and then passes it to -// EventHandler.ReceiveMessage. -type EventReceiver interface { - // Start starts listening for broadcast messages - it should return - // immediately, spawning a goroutine if necessary. - Start(EventHandler) error -} - -type nopEventReceiver struct{} - -func (n *nopEventReceiver) Start(e EventHandler) error { return nil } - -// NopEventReceiver is a no-op implementation of the EventReceiver. -var NopEventReceiver = &nopEventReceiver{}