Skip to content

Commit

Permalink
remove old shard copier service
Browse files Browse the repository at this point in the history
  • Loading branch information
corylanou committed May 10, 2016
1 parent afde7ce commit 4484182
Show file tree
Hide file tree
Showing 5 changed files with 0 additions and 528 deletions.
12 changes: 0 additions & 12 deletions cmd/influxd/run/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ import (
"github.com/influxdata/influxdb/influxql"
"github.com/influxdata/influxdb/models"
"github.com/influxdata/influxdb/monitor"
"github.com/influxdata/influxdb/services/copier"
"github.com/influxdata/influxdb/services/meta"
"github.com/influxdata/influxdb/services/snapshotter"
"github.com/influxdata/influxdb/services/subscriber"
Expand Down Expand Up @@ -67,7 +66,6 @@ type Server struct {
// These references are required for the tcp muxer.
ClusterService *cluster.Service
SnapshotterService *snapshotter.Service
CopierService *copier.Service

Monitor *monitor.Monitor

Expand Down Expand Up @@ -215,13 +213,6 @@ func (s *Server) appendSnapshotterService() {
s.SnapshotterService = srv
}

func (s *Server) appendCopierService() {
srv := copier.NewService()
srv.TSDBStore = s.TSDBStore
s.Services = append(s.Services, srv)
s.CopierService = srv
}

// SetLogOutput sets the logger used for all messages. It must not be called
// after the Open method has been called.
func (s *Server) SetLogOutput(w io.Writer) {
Expand Down Expand Up @@ -253,7 +244,6 @@ func (s *Server) Open() error {
s.appendClusterService(s.config.Cluster)
s.appendPrecreatorService(s.config.Precreator)
s.appendSnapshotterService()
s.appendCopierService()
s.appendAdminService(s.config.Admin)
s.appendContinuousQueryService(s.config.ContinuousQuery)
s.appendHTTPDService(s.config.HTTPD)
Expand Down Expand Up @@ -282,7 +272,6 @@ func (s *Server) Open() error {

s.ClusterService.Listener = mux.Listen(cluster.MuxHeader)
s.SnapshotterService.Listener = mux.Listen(snapshotter.MuxHeader)
s.CopierService.Listener = mux.Listen(copier.MuxHeader)

// Configure logging for all services and clients.
w := s.logOutput
Expand All @@ -296,7 +285,6 @@ func (s *Server) Open() error {
}
s.ClusterService.SetLogOutput(w)
s.SnapshotterService.SetLogOutput(w)
s.CopierService.SetLogOutput(w)
s.Monitor.SetLogOutput(w)

// Open TSDB store.
Expand Down
61 changes: 0 additions & 61 deletions services/copier/internal/internal.pb.go

This file was deleted.

9 changes: 0 additions & 9 deletions services/copier/internal/internal.proto

This file was deleted.

262 changes: 0 additions & 262 deletions services/copier/service.go

This file was deleted.

Loading

0 comments on commit 4484182

Please sign in to comment.