consul

Oct 14, 2016

Changes in this version

+ func CreateTestServer(t *testing.T) *testutil.TestServer

+ type Config struct

+ AgentFailuresTolerance uint32

+ Auth Auth

+ ConsulNameSeparator string

+ IgnoredHealthChecks string

+ Port string

+ RequestRetries uint32

+ SslCaCert string

+ SslCert string

+ SslEnabled bool

+ SslVerify bool

+ Tag string

+ Timeout time.Duration

+ Token string

type Consul

+ func ClientAtServer(server *testutil.TestServer) *Consul

+ func FailingClient() *Consul

+ func (c *Consul) AddAgent(agentAddress string) error

+ func (c *Consul) AddAgentsFromApps(apps []*apps.App)

+ func (c *Consul) DeregisterByTask(taskID apps.TaskID) error

+ type Stub struct

+ func (c *Stub) Deregister(toDeregister *service.Service) error

+ func (c *Stub) DeregisterByTask(taskID apps.TaskID) error

+ func (c *Stub) FailDeregisterByTaskForID(taskID apps.TaskID)

+ func (c *Stub) FailDeregisterForID(serviceID service.ServiceId)

+ func (c *Stub) FailGetServicesForName(failOnName string)

+ func (c *Stub) FailRegisterForID(taskID apps.TaskID)

+ func (c *Stub) GetAllServices() ([]*service.Service, error)

+ func (c *Stub) GetServices(name string) ([]*service.Service, error)

+ func (c *Stub) Register(task *apps.Task, app *apps.App) error

+ func (c *Stub) RegisterOnlyFirstRegistrationIntent(task *apps.Task, app *apps.App)

+ func (c *Stub) RegisterWithoutMarathonTaskTag(task *apps.Task, app *apps.App)

+ func (c *Stub) RegisteredTaskIDs() []apps.TaskID

Aug 29, 2016

Changes in this version

+ func GetPorts(number int) ([]int, error)

type Consul

+ func FailingConsulClient() *Consul

+ func (c *Consul) ServiceName(app *apps.App) string

type ConsulConfig

+ ConsulNameSeparator string

type ConsulServices

+ ServiceName func(app *apps.App) string

type ConsulStub

+ func (c *ConsulStub) ServiceName(app *apps.App) string

Mar 30, 2016

Changes in this version

+ type Agent struct

+ Client *consulapi.Client

+ IP string

+ func (a *Agent) ClearFailures()

+ func (a *Agent) IncFailures() uint32

type ConsulConfig

+ AgentFailuresTolerance uint32

+ RequestRetries uint32

Feb 8, 2016

Changes in this version

type Agents

+ RemoveAgent func(agentAddress string)

type ConcurrentAgents

+ func (a *ConcurrentAgents) RemoveAgent(agentAddress string)

+ type ServicesProvider func(*consulapi.Client) ([]*consulapi.CatalogService, error)

Feb 1, 2016

Changes in this version

type ConsulConfig

+ Timeout time.Duration

Jan 20, 2016

Changes in this version

type ConsulConfig

+ Tag string

type ConsulStub

+ ErrorGetServices map[string]error

+ func NewConsulStubWithTag(tag string) *ConsulStub

Jan 12, 2016

Changes in this version

type Consul

+ func (c *Consul) GetAgent(agentAddress string) (*consulapi.Client, error)

+ func (c *Consul) GetServices(name tasks.AppId) ([]*consulapi.CatalogService, error)

type ConsulServices

+ GetAgent func(agentAddress string) (*consulapi.Client, error)

+ GetServices func(name tasks.AppId) ([]*consulapi.CatalogService, error)

type ConsulStub

+ func (c *ConsulStub) GetAgent(agentAddress string) (*consulapi.Client, error)

+ func (c ConsulStub) GetServices(name tasks.AppId) ([]*consulapi.CatalogService, error)

Dec 15, 2015

Changes in this version

+ func CreateConsulTestServer(dc string, t *testing.T) *testutil.TestServer

+ func IsTaskHealthy(healthChecksResults []tasks.HealthCheckResult) bool

+ func MarathonTaskToConsulService(task tasks.Task, healthChecks []apps.HealthCheck, labels map[string]string) *consulapi.AgentServiceRegistration

+ type Agents interface

+ GetAgent func(string) (*consulapi.Client, error)

+ GetAnyAgent func() (*consulapi.Client, error)

+ type Auth struct

+ Enabled bool

+ Password string

+ Username string

+ type ConcurrentAgents struct

+ func NewAgents(config *ConsulConfig) *ConcurrentAgents

+ func (a *ConcurrentAgents) GetAgent(agentHost string) (*consulapi.Client, error)

+ func (a *ConcurrentAgents) GetAnyAgent() (*consulapi.Client, error)

+ type Consul struct

+ func ConsulClientAtServer(server *testutil.TestServer) *Consul

+ func New(config ConsulConfig) *Consul

+ func (c *Consul) Deregister(serviceId string, agentAddress string) error

+ func (c *Consul) GetAllServices() ([]*consulapi.CatalogService, error)

+ func (c *Consul) Register(service *consulapi.AgentServiceRegistration) error

+ type ConsulConfig struct

+ Auth Auth

+ Port string

+ SslCaCert string

+ SslCert string

+ SslEnabled bool

+ SslVerify bool

+ Token string

+ type ConsulServices interface

+ Deregister func(serviceId string, agentAddress string) error

+ GetAllServices func() ([]*consulapi.CatalogService, error)

+ Register func(service *consulapi.AgentServiceRegistration) error

+ type ConsulStub struct

+ ErrorServices map[string]error

+ func NewConsulStub() *ConsulStub

+ func (c *ConsulStub) Deregister(serviceId string, agent string) error

+ func (c *ConsulStub) Register(service *consulapi.AgentServiceRegistration) error

+ func (c *ConsulStub) RegisteredServicesIds() []string

+ func (c ConsulStub) GetAllServices() ([]*consulapi.CatalogService, error)