consul

Apr 9, 2019

Changes in this version

+ type ConsulServiceAPI interface

+ AllocRegistrations func(allocID string) (*consul.AllocRegistration, error)

+ RegisterTask func(*consul.TaskServices) error

+ RemoveTask func(*consul.TaskServices)

+ UpdateTask func(old, newTask *consul.TaskServices) error

+ type MockConsulOp struct

+ AllocID string

+ Op string

+ Task string

+ func NewMockConsulOp(op, allocID, task string) MockConsulOp

+ type MockConsulServiceClient struct

+ AllocRegistrationsFn func(allocID string) (*consul.AllocRegistration, error)

+ func NewMockConsulServiceClient(t testing.T, logger log.Logger) *MockConsulServiceClient

+ func (m *MockConsulServiceClient) AllocRegistrations(allocID string) (*consul.AllocRegistration, error)

+ func (m *MockConsulServiceClient) GetOps() []MockConsulOp

+ func (m *MockConsulServiceClient) RegisterTask(task *consul.TaskServices) error

+ func (m *MockConsulServiceClient) RemoveTask(task *consul.TaskServices)

+ func (m *MockConsulServiceClient) UpdateTask(old, newSvcs *consul.TaskServices) error

Apr 22, 2016

Changes in this version

+ type Check interface

+ ID func() string

+ Interval func() time.Duration

+ Run func() *cstructs.CheckResult

+ type CheckRunner struct

+ func NewCheckRunner(check Check, runCheck func(Check), logger *log.Logger) *CheckRunner

+ func (r *CheckRunner) Start()

+ func (r *CheckRunner) Stop()

+ type ConsulConfig struct

+ Addr string

+ Auth string

+ CAFile string

+ CertFile string

+ EnableSSL bool

+ KeyFile string

+ Token string

+ VerifySSL bool

+ type ConsulService struct

+ func NewConsulService(config *ConsulConfig, logger *log.Logger, allocID string) (*ConsulService, error)

+ func (c *ConsulService) KeepServices(services map[string]struct{}) error

+ func (c *ConsulService) PeriodicSync()

+ func (c *ConsulService) SetDelegatedChecks(delegateChecks map[string]struct{}, ...) *ConsulService

+ func (c *ConsulService) Shutdown() error

+ func (c *ConsulService) SyncTask(task *structs.Task) error