3414: rename replicator to pull_list

[arvados.git] / services / keepstore / replicator / replica.go

diff --git a/services/keepstore/replicator/replica.go b/services/keepstore/replicator/replica.go
deleted file mode 100644 (file)
index e314b86..0000000
--- a/services/keepstore/replicator/replica.go
+++ /dev/null
@@ -1,80 +0,0 @@
-package replicator
-
-/* The Keep replicator package fulfills replication pull requests sent
-   by Data Manager.
-
-   The interface is:
-
-   replicator.New() launches a replication goroutine and returns the
-   new Replicator object.
-
-   replicator.SetList() assigns a new pull list to the goroutine. Any
-   existing list is discarded.
-
-   replicator.GetList() reports the goroutine's current pull list.
-
-   replicator.Close() shuts down the replicator.
-*/
-
-type PullRequest struct {
-       Locator string
-       Servers []string
-}
-
-type Replicator struct {
-       queue chan []PullRequest
-       dump  chan []PullRequest
-}
-
-// New returns a new Replicator object.  It launches a goroutine that
-// waits for pull requests.
-//
-func New() *Replicator {
-       r := Replicator{
-               make(chan []PullRequest),
-               make(chan []PullRequest),
-       }
-       go r.listen()
-       return &r
-}
-
-// SetList sends a new list of pull requests to the replicator goroutine.
-// The replicator will discard any outstanding pull list and begin
-// working on the new list.
-//
-func (r *Replicator) SetList(pr []PullRequest) {
-       r.queue <- pr
-}
-
-// GetList reports the contents of the current pull list.
-func (r *Replicator) GetList() []PullRequest {
-       return <-r.dump
-}
-
-// Close shuts down the replicator and terminates the goroutine, which
-// completes any pull request in progress and abandons any pending
-// requests.
-//
-func (r *Replicator) Close() {
-       close(r.queue)
-}
-
-// listen is run in a goroutine. It reads new pull lists from its
-// input queue until the queue is closed.
-func (r *Replicator) listen() {
-       var current []PullRequest
-       for {
-               select {
-               case p, ok := <-r.queue:
-                       if ok {
-                               current = p
-                       } else {
-                               // The input channel is closed; time to shut down
-                               close(r.dump)
-                               return
-                       }
-               case r.dump <- current:
-                       // no-op
-               }
-       }
-}