|
|
|
@ -9,20 +9,20 @@ import (
|
|
|
|
|
"sync/atomic"
|
|
|
|
|
"time"
|
|
|
|
|
|
|
|
|
|
"github.com/hashicorp/consul/acl"
|
|
|
|
|
"github.com/hashicorp/consul/acl/resolver"
|
|
|
|
|
"github.com/hashicorp/consul/agent/structs"
|
|
|
|
|
"github.com/hashicorp/consul/agent/token"
|
|
|
|
|
"github.com/hashicorp/consul/api"
|
|
|
|
|
"github.com/hashicorp/consul/lib"
|
|
|
|
|
"github.com/hashicorp/consul/lib/stringslice"
|
|
|
|
|
"github.com/hashicorp/consul/types"
|
|
|
|
|
|
|
|
|
|
"github.com/armon/go-metrics"
|
|
|
|
|
"github.com/armon/go-metrics/prometheus"
|
|
|
|
|
"github.com/hashicorp/go-hclog"
|
|
|
|
|
"github.com/hashicorp/go-multierror"
|
|
|
|
|
"github.com/mitchellh/copystructure"
|
|
|
|
|
|
|
|
|
|
"github.com/hashicorp/consul/acl"
|
|
|
|
|
"github.com/hashicorp/consul/agent/structs"
|
|
|
|
|
"github.com/hashicorp/consul/agent/token"
|
|
|
|
|
"github.com/hashicorp/consul/api"
|
|
|
|
|
"github.com/hashicorp/consul/lib"
|
|
|
|
|
"github.com/hashicorp/consul/types"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
var StateCounters = []prometheus.CounterDefinition{
|
|
|
|
@ -1224,6 +1224,7 @@ func (l *State) SyncChanges() error {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var errs error
|
|
|
|
|
// Sync the services
|
|
|
|
|
// (logging happens in the helper methods)
|
|
|
|
|
for id, s := range l.services {
|
|
|
|
@ -1237,7 +1238,7 @@ func (l *State) SyncChanges() error {
|
|
|
|
|
l.logger.Debug("Service in sync", "service", id.String())
|
|
|
|
|
}
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
errs = multierror.Append(errs, err)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -1258,10 +1259,10 @@ func (l *State) SyncChanges() error {
|
|
|
|
|
l.logger.Debug("Check in sync", "check", id.String())
|
|
|
|
|
}
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
errs = multierror.Append(errs, err)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return nil
|
|
|
|
|
return errs
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// deleteService is used to delete a service from the server
|
|
|
|
|