eureka

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(conn fargoConnection, instance *fargo.Instance) *Client
  • func (r *Client) Deregister()
  • func (r *Client) Register()
• type Option
• type Registrar
  • func (registrar *Registrar) Destroy() error
  • func (registrar *Registrar) GetAllInstances(serviceName string) []servicediscovery.ServiceInstance
  • func (registrar *Registrar) GetHealthyInstances(serviceName string) []servicediscovery.ServiceInstance
  • func (registrar *Registrar) GetName() string
  • func (registrar *Registrar) Register() error
  • func (registrar *Registrar) Unregister() error
  • func (registrar *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 {
	sync.Mutex
	// contains filtered or unexported fields
}

Client maintains service instance liveness information in eureka.

func NewClient

func NewClient(conn fargoConnection, instance *fargo.Instance) *Client

NewClient returns an eureka Client acting on behalf of the provided Fargo connection and instance. See the integration test for usage examples.

func (*Client) Deregister

func (r *Client) Deregister()

Deregister implements sd.Client.

func (*Client) Register

func (r *Client) Register()

Register implements sd.Client.

type Option

type Option struct {
	ENV     *abstractions.HostEnvironment
	Address string `mapstructure:"address"`
}

type Registrar

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

func (*Registrar) Destroy

func (registrar *Registrar) Destroy() error

func (*Registrar) GetAllInstances

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

func (*Registrar) GetHealthyInstances

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

func (*Registrar) GetName

func (registrar *Registrar) GetName() string

func (*Registrar) Register

func (registrar *Registrar) Register() error

func (*Registrar) Unregister

func (registrar *Registrar) Unregister() error

func (*Registrar) Update

func (registrar *Registrar) Update() error