consul

package

v0.1.0 Latest Latest Go to latest Published: Feb 2, 2018 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/servicekit/servicekit-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Consul
- func NewConsul(addr, scheme, token string, log *logger.Logger) (*Consul, error)
type TestConsul

Constants ¶

View Source

const (
	// DefaultTTL use to describe consul update period
	DefaultTTL = time.Minute
	// EnableTLS use to enable TSL
	EnableTLS = true
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Consul ¶

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

Consul is an implementation of coodinator

func NewConsul ¶

func NewConsul(addr, scheme, token string, log *logger.Logger) (*Consul, error)

NewConsul returns a Consul

func (*Consul) Deregister ¶

func (c *Consul) Deregister(ctx context.Context, serviceID string) error

Deregister deregister a service

func (*Consul) GetServices ¶

func (c *Consul) GetServices(ctx context.Context, name string, tag string) ([]*spec.Service, interface{}, error)

GetServices returns all service by context, name and tag

func (*Consul) Register ¶

func (c *Consul) Register(ctx context.Context, serv *spec.Service, ttl time.Duration) error

Register register a new service

type TestConsul ¶

type TestConsul struct {
	GetServicesServices []*spec.Service
	GetServicesMeta     *api.QueryMeta
	GetServicesError    error
	RegisterError       error
	DeregisterError     error
}

TestConsul is a help stub for test

func (*TestConsul) Deregister ¶

func (t *TestConsul) Deregister(ctx context.Context, serviceID string) error

Deregister deregister a service which service do we want to deregister

func (*TestConsul) GetServices ¶

func (t *TestConsul) GetServices(ctx context.Context, name string, tag string) ([]*spec.Service, interface{}, error)

GetServices returns some service which services do we want to return

func (*TestConsul) Register ¶

func (t *TestConsul) Register(ctx context.Context, serv *spec.Service, ttl time.Duration) error

Register register a service which service do we want to register

Source Files ¶

View all Source files

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