consul

Documentation

Index

• func CreateTestServer(t *testing.T) *testutil.TestServer
• type Agent
  • func (a *Agent) ClearFailures()
  • func (a *Agent) IncFailures() uint32
• type Agents
• type Auth
• type ConcurrentAgents
  • func NewAgents(config *Config) *ConcurrentAgents
  • func (a *ConcurrentAgents) GetAgent(agentAddress string) (*consulapi.Client, error)
  • func (a *ConcurrentAgents) GetAnyAgent() (*Agent, error)
  • func (a *ConcurrentAgents) RemoveAgent(agentAddress string)
• type Config
• type Consul
  • func ClientAtServer(server *testutil.TestServer) *Consul
  • func FailingClient() *Consul
  • func New(config Config) *Consul
  • func (c *Consul) AddAgent(agentAddress string) error
  • func (c *Consul) AddAgentsFromApps(apps []*apps.App)
  • func (c *Consul) Deregister(toDeregister *service.Service) error
  • func (c *Consul) DeregisterByTask(taskID apps.TaskID) error
  • func (c *Consul) GetAllServices() ([]*service.Service, error)
  • func (c *Consul) GetServices(name string) ([]*service.Service, error)
  • func (c *Consul) Register(task *apps.Task, app *apps.App) error
• type ServicesProvider
• type Stub
  • func NewConsulStub() *Stub
  • func NewConsulStubWithTag(tag string) *Stub
  • 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

Functions

func CreateTestServer

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

Types

type Agent

type Agent struct {
	Client *consulapi.Client
	IP     string
	// contains filtered or unexported fields
}

func (*Agent) ClearFailures

func (a *Agent) ClearFailures()

func (*Agent) IncFailures

func (a *Agent) IncFailures() uint32

type Agents

type Agents interface {
	GetAgent(agentAddress string) (agent *consulapi.Client, err error)
	GetAnyAgent() (agent *Agent, err error)
	RemoveAgent(agentAddress string)
}

type Auth

type Auth struct {
	Enabled  bool
	Username string
	Password string
}

type ConcurrentAgents

type ConcurrentAgents struct {
	// contains filtered or unexported fields
}

func NewAgents

func NewAgents(config *Config) *ConcurrentAgents

func (*ConcurrentAgents) GetAgent

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

func (*ConcurrentAgents) GetAnyAgent

func (a *ConcurrentAgents) GetAnyAgent() (*Agent, error)

func (*ConcurrentAgents) RemoveAgent

func (a *ConcurrentAgents) RemoveAgent(agentAddress string)

type Config

type Config struct {
	Auth                   Auth
	Port                   string
	SslEnabled             bool
	SslVerify              bool
	SslCert                string
	SslCaCert              string
	Token                  string
	Tag                    string
	Timeout                time.Interval
	RequestRetries         uint32
	AgentFailuresTolerance uint32
	ConsulNameSeparator    string
	IgnoredHealthChecks    string
}

type Consul

type Consul struct {
	// contains filtered or unexported fields
}

func ClientAtServer

func ClientAtServer(server *testutil.TestServer) *Consul

func FailingClient

func FailingClient() *Consul

func New

func New(config Config) *Consul

func (*Consul) AddAgent

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

func (*Consul) AddAgentsFromApps

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

func (*Consul) Deregister

func (c *Consul) Deregister(toDeregister *service.Service) error

func (*Consul) DeregisterByTask

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

func (*Consul) GetAllServices

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

func (*Consul) GetServices

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

func (*Consul) Register

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

type ServicesProvider

type ServicesProvider func(agent *consulapi.Client) ([]*service.Service, error)

type Stub

type Stub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

TODO this should be a service registry stub in the service package, requires abstracting from AgentServiceRegistration

func NewConsulStub

func NewConsulStub() *Stub

func NewConsulStubWithTag

func NewConsulStubWithTag(tag string) *Stub

func (*Stub) Deregister

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

func (*Stub) DeregisterByTask

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

func (*Stub) FailDeregisterByTaskForID

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

func (*Stub) FailDeregisterForID

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

func (*Stub) FailGetServicesForName

func (c *Stub) FailGetServicesForName(failOnName string)

func (*Stub) FailRegisterForID

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

func (*Stub) GetAllServices

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

func (*Stub) GetServices

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

func (*Stub) Register

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

func (*Stub) RegisterOnlyFirstRegistrationIntent

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

func (*Stub) RegisterWithoutMarathonTaskTag

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

func (*Stub) RegisteredTaskIDs

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