discovery

package

v0.0.0-...-e6f4ba9 Latest Latest Go to latest Published: Feb 14, 2019 License: Apache-2.0 Imports: 15 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/mjarco/akubra

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DiscardBody(resp *http.Response) error
func DoRequestWithDiscoveryService(httpClient *http.Client, host, path, username, password, payload string) (resp *http.Response, endpoint string, err error)
func GetHTTPClient() *http.Client
type ClientWrapper
- func (c *ClientWrapper) Health() IHealth
type HealthWrapper
- func (hw *HealthWrapper) Service(service, tag string, passingOnly bool, q *api.QueryOptions) ([]*api.ServiceEntry, *api.QueryMeta, error)
type IClient
- func NewClientWrapper(config *api.Config, httpClient *http.Client) (IClient, error)
type IHealth
type Resolver
- func NewResolver(consulClient IClient) *Resolver
- func (r *Resolver) GetNodesFromConsul(service string) (entries []*api.ServiceEntry)
type Services
- func NewServices(consulClient IClient, cacheInvalidationTimeout int64) *Services
- func (s *Services) GetEndpoint(serviceName string) (url *url.URL, err error)
- func (s *Services) UpdateInstances(serviceName string) (resolver *Resolver)

Constants ¶

View Source

const (
	DefaultCacheInvalidationTimeout = 10
)

DefaultCacheInvalidationTimeout for updating instances

Variables ¶

This section is empty.

Functions ¶

func DiscardBody ¶

func DiscardBody(resp *http.Response) error

DiscardBody from response

func DoRequestWithDiscoveryService ¶

func DoRequestWithDiscoveryService(httpClient *http.Client, host, path, username, password, payload string) (resp *http.Response, endpoint string, err error)

DoRequestWithDiscoveryService with hostname (username + password) and payload

func GetHTTPClient ¶

func GetHTTPClient() *http.Client

GetHTTPClient for service discovery

Types ¶

type ClientWrapper ¶

type ClientWrapper struct {
	Client *api.Client
}

ClientWrapper for consul api.Client

func (*ClientWrapper) Health ¶

func (c *ClientWrapper) Health() IHealth

Health function wrapper

type HealthWrapper ¶

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

HealthWrapper for consul api.Health

func (*HealthWrapper) Service ¶

func (hw *HealthWrapper) Service(service, tag string, passingOnly bool, q *api.QueryOptions) ([]*api.ServiceEntry, *api.QueryMeta, error)

Service function wrapper

type IClient ¶

type IClient interface {
	Health() IHealth
}

IClient interface

func NewClientWrapper ¶

func NewClientWrapper(config *api.Config, httpClient *http.Client) (IClient, error)

NewClientWrapper returns a new Consul client wrapper

type IHealth ¶

type IHealth interface {
	Service(service, tag string, passingOnly bool, q *api.QueryOptions) ([]*api.ServiceEntry, *api.QueryMeta, error)
}

IHealth interface

type Resolver ¶

type Resolver struct {
	LastUpdateTimestamp int64
	// contains filtered or unexported fields
}

Resolver for discovery service

func NewResolver ¶

func NewResolver(consulClient IClient) *Resolver

NewResolver for discovery client

func (*Resolver) GetNodesFromConsul ¶

func (r *Resolver) GetNodesFromConsul(service string) (entries []*api.ServiceEntry)

GetNodesFromConsul get service nodes form service discovery

type Services ¶

type Services struct {
	ConsulClient IClient
	Instances    *syncmap.Map
	CacheTTL     int64
}

Services for discovery service

func NewServices ¶

func NewServices(consulClient IClient, cacheInvalidationTimeout int64) *Services

NewServices constructor

func (*Services) GetEndpoint ¶

func (s *Services) GetEndpoint(serviceName string) (url *url.URL, err error)

GetEndpoint by service name

func (*Services) UpdateInstances ¶

func (s *Services) UpdateInstances(serviceName string) (resolver *Resolver)

UpdateInstances get service instances from service discovery

Source Files ¶

View all Source files

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