consul

Documentation

Index

• type Registry
  • func NewRegistry(addr string) (*Registry, error)
  • func (r *Registry) Deregister(ctx context.Context, instanceID string, _ string) error
  • func (r *Registry) Register(ctx context.Context, instanceID string, serviceName string, hostPort string) error
  • func (r *Registry) ReportHealthyState(instanceID string, _ string) error
  • func (r *Registry) ServiceAddress(ctx context.Context, serviceName string) ([]string, error)

Types

type Registry

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

Registry defines a Consul-based service registry.

func NewRegistry

func NewRegistry(addr string) (*Registry, error)

NewRegistry creates a new Consul-based service registry instance.

func (*Registry) Deregister

func (r *Registry) Deregister(ctx context.Context, instanceID string, _ string) error

Deregister removes a service record from the registry.

func (*Registry) Register

func (r *Registry) Register(
	ctx context.Context,
	instanceID string,
	serviceName string,
	hostPort string,
) error

func (*Registry) ReportHealthyState

func (r *Registry) ReportHealthyState(instanceID string, _ string) error

ReportHealthyState is a push mechanism for reporting healthy state to the registry.

func (*Registry) ServiceAddress

func (r *Registry) ServiceAddress(ctx context.Context, serviceName string) ([]string, error)

ServiceAddress return the list of address of active instances of the given service