From ab63c8e7b6894b34121eaa274041f5fcfdc5eaae Mon Sep 17 00:00:00 2001 From: Matt Jaffee Date: Thu, 9 Aug 2018 16:07:05 -0500 Subject: [PATCH] add forgotten server changes which support AE test --- server.go | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/server.go b/server.go index c556f77f1..819d1d80d 100644 --- a/server.go +++ b/server.go @@ -232,11 +232,12 @@ func OptServerClusterHasher(h Hasher) ServerOption { // NewServer returns a new instance of Server. func NewServer(opts ...ServerOption) (*Server, error) { s := &Server{ - closing: make(chan struct{}), - cluster: newCluster(), - holder: NewHolder(), - diagnostics: newDiagnosticsCollector(defaultDiagnosticServer), - systemInfo: newNopSystemInfo(), + closing: make(chan struct{}), + cluster: newCluster(), + holder: NewHolder(), + diagnostics: newDiagnosticsCollector(defaultDiagnosticServer), + systemInfo: newNopSystemInfo(), + defaultClient: nopInternalClient{}, gcNotifier: NopGCNotifier, @@ -246,6 +247,9 @@ func NewServer(opts ...ServerOption) (*Server, error) { logger: NopLogger, } + s.executor = newExecutor(optExecutorInternalQueryClient(s.defaultClient)) + s.cluster.InternalClient = s.defaultClient + s.diagnostics.server = s for _, opt := range opts {