consul

Documentation

Index

• func NewServerDiscovery(option Option) servicediscovery.IServiceDiscovery
• func NewServerDiscoveryWithDI(configuration abstractions.IConfiguration, env *abstractions.HostEnvironment) servicediscovery.IServiceDiscovery
• func UseServiceDiscovery(serviceCollection *dependencyinjection.ServiceCollection)
• type Client
  • func NewClient(op Option) *Client
  • func (c *Client) Deregister(r *consul.AgentServiceRegistration) error
  • func (c *Client) GetService(service, tag string, passingOnly bool, queryOpts *consul.QueryOptions) ([]*consul.ServiceEntry, *consul.QueryMeta, error)
  • func (c *Client) Register(r *consul.AgentServiceRegistration) error
• type Option
• type Registrar
  • func (register Registrar) Destroy() error
  • func (register Registrar) GetAllInstances(serviceName string) []servicediscovery.ServiceInstance
  • func (register Registrar) GetHealthyInstances(serviceName string) []servicediscovery.ServiceInstance
  • func (register Registrar) GetName() string
  • func (register *Registrar) Register() error
  • func (register Registrar) Unregister() error
  • func (register Registrar) Update() error

Functions

func NewServerDiscovery

func NewServerDiscovery(option Option) servicediscovery.IServiceDiscovery

func NewServerDiscoveryWithDI

func NewServerDiscoveryWithDI(configuration abstractions.IConfiguration, env *abstractions.HostEnvironment) servicediscovery.IServiceDiscovery

func UseServiceDiscovery

func UseServiceDiscovery(serviceCollection *dependencyinjection.ServiceCollection)

Types

type Client

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

func NewClient

func NewClient(op Option) *Client

NewClient returns an implementation of the Client interface, wrapping a concrete consul client.

func (*Client) Deregister

func (c *Client) Deregister(r *consul.AgentServiceRegistration) error

func (*Client) GetService

func (c *Client) GetService(service, tag string, passingOnly bool, queryOpts *consul.QueryOptions) ([]*consul.ServiceEntry, *consul.QueryMeta, error)

func (*Client) Register

func (c *Client) Register(r *consul.AgentServiceRegistration) error

type Option

type Option struct {
	ENV     *abstractions.HostEnvironment
	Address string   `mapstructure:"address"`
	Token   string   `mapstructure:"token"`
	Tags    []string `mapstructure:"tags"`
}

type Registrar

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

func (Registrar) Destroy

func (register Registrar) Destroy() error

func (Registrar) GetAllInstances

func (register Registrar) GetAllInstances(serviceName string) []servicediscovery.ServiceInstance

func (Registrar) GetHealthyInstances

func (register Registrar) GetHealthyInstances(serviceName string) []servicediscovery.ServiceInstance

func (Registrar) GetName

func (register Registrar) GetName() string

func (*Registrar) Register

func (register *Registrar) Register() error

func (Registrar) Unregister

func (register Registrar) Unregister() error

func (Registrar) Update

func (register Registrar) Update() error