nacs

Documentation

Index

• Variables
• type Configor
  • func NewConfigor(addr, group, service string, files ...string) (*Configor, error)
  • func (loader *Configor) GetByName(name string) []byte
  • func (loader *Configor) GetRawCfg() []byte
  • func (loader *Configor) Watch(ctx context.Context, handler configor.Handler) error
• type Registor
  • func NewRegistor(addr, group string) (*Registor, error)
  • func (r *Registor) DeRegister(ctx context.Context, svc registor.ServiceMeta) error
  • func (r *Registor) Lookup(svc registor.Service) (registor.ServiceMeta, error)
  • func (r *Registor) Register(ctx context.Context, svc registor.ServiceMeta) error
  • func (r *Registor) Watch(ctx context.Context, handler registor.Handler, svcs ...registor.Service) error

Variables

var (
	ErrNoSuchConfigor = errors.New("no such configor")
)

var (
	ErrNoSuchRegistor = errors.New("no such registor")
)

Types

type Configor

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

func NewConfigor

func NewConfigor(addr, group, service string, files ...string) (*Configor, error)

func (*Configor) GetByName

func (loader *Configor) GetByName(name string) []byte

func (*Configor) GetRawCfg

func (loader *Configor) GetRawCfg() []byte

func (*Configor) Watch

func (loader *Configor) Watch(ctx context.Context, handler configor.Handler) error

type Registor

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

func NewRegistor

func NewRegistor(addr, group string) (*Registor, error)

func (*Registor) DeRegister

func (r *Registor) DeRegister(ctx context.Context, svc registor.ServiceMeta) error

func (*Registor) Lookup

func (r *Registor) Lookup(svc registor.Service) (registor.ServiceMeta, error)

func (*Registor) Register

func (r *Registor) Register(ctx context.Context, svc registor.ServiceMeta) error

func (*Registor) Watch

func (r *Registor) Watch(ctx context.Context, handler registor.Handler, svcs ...registor.Service) error