mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-09-07 17:15:56 +00:00
add forgotten server changes which support AE test
This commit is contained in:
parent
b761121f47
commit
ab63c8e7b6
1 changed files with 9 additions and 5 deletions
14
server.go
14
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 {
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue