consul

Documentation

Index

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

Constants

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

Types

type Naming

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

func NewNaming

func NewNaming(address string) (*Naming, error)

func (*Naming) Deregister

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

func (*Naming) Find

func (n *Naming) Find(name string, tags ...string) ([]goim.ServiceRegistration, error)

func (*Naming) Register

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

func (*Naming) Subscribe

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

func (*Naming) Unsubscribe

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

type Watch

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