consul

Documentation

Index

• Constants
• func NewNaming(consulUrl string) (naming.Naming, error)
• type Naming
  • func (n *Naming) Deregister(serviceID string) error
  • func (n *Naming) Find(serviceName string, tags ...string) ([]him.ServiceRegistration, error)
  • func (n *Naming) Register(s him.ServiceRegistration) error
  • func (n *Naming) Subscribe(serviceName string, callback func(services []him.ServiceRegistration)) error
  • func (n *Naming) Unsubscribe(serviceName string) error
• type Watch

Constants

const (
	KeyProtocol  = "protocol"
	KeyHealthURL = "health_url"
)

const (
	HealthPassing     = "passing"
	HealthWarning     = "warning"
	HealthCritical    = "critical"
	HealthMaintenance = "maintenance"
)

Functions

func NewNaming

func NewNaming(consulUrl string) (naming.Naming, error)

Types

type Naming

type Naming struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Naming) Deregister

func (n *Naming) Deregister(serviceID string) error

func (*Naming) Find

func (n *Naming) Find(serviceName string, tags ...string) ([]him.ServiceRegistration, error)

func (*Naming) Register

func (n *Naming) Register(s him.ServiceRegistration) error

func (*Naming) Subscribe

func (n *Naming) Subscribe(serviceName string, callback func(services []him.ServiceRegistration)) error

func (*Naming) Unsubscribe

func (n *Naming) Unsubscribe(serviceName string) error

type Watch

type Watch struct {
	Service   string
	Callback  func([]him.ServiceRegistration)
	WaitIndex uint64
	Quit      chan struct{}
}