Help us shape the future of Go! Take the 2026 Go Developer Survey

consul

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2019 License: MPL-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConsulServiceAPI added in v0.9.0

type ConsulServiceAPI interface {
	RegisterTask(*consul.TaskServices) error
	RemoveTask(*consul.TaskServices)
	UpdateTask(old, newTask *consul.TaskServices) error
	AllocRegistrations(allocID string) (*consul.AllocRegistration, error)
}

ConsulServiceAPI is the interface the Nomad Client uses to register and remove services and checks from Consul.

type MockConsulOp added in v0.9.0

type MockConsulOp struct {
	Op      string // add, remove, or update
	AllocID string
	Task    string
}

MockConsulOp represents the register/deregister operations.

func NewMockConsulOp added in v0.9.0

func NewMockConsulOp(op, allocID, task string) MockConsulOp

type MockConsulServiceClient added in v0.9.0

type MockConsulServiceClient struct {

	// AllocRegistrationsFn allows injecting return values for the
	// AllocRegistrations function.
	AllocRegistrationsFn func(allocID string) (*consul.AllocRegistration, error)
	// contains filtered or unexported fields
}

MockConsulServiceClient implements the ConsulServiceAPI interface to record and log task registration/deregistration.

func NewMockConsulServiceClient added in v0.9.0

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

func (*MockConsulServiceClient) AllocRegistrations added in v0.9.0

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

func (*MockConsulServiceClient) GetOps added in v0.9.0

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

func (*MockConsulServiceClient) RegisterTask added in v0.9.0

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

func (*MockConsulServiceClient) RemoveTask added in v0.9.0

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

func (*MockConsulServiceClient) UpdateTask added in v0.9.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL