lockers

type Initializer func() Locker

type Locker interface {
	Init(context.Context, map[string]interface{}, ...Option) error

	Lock(context.Context, string, []byte) (bool, error)
	KeepLock(context.Context, string) (chan struct{}, chan error)
	IsLocked(context.Context, string) (bool, error)
	Unlock(context.Context, string) error

	Register(context.Context, *ServiceRegistration) error
	Deregister(string) error

	List(context.Context, string) (map[string]string, error)
	GetServices(ctx context.Context, serviceName string, tags []string) ([]*Service, error)
	WatchServices(ctx context.Context, serviceName string, tags []string, ch chan<- []*Service, dur time.Duration) error

	Stop() error
	SetLogger(*log.Logger)
}

type Option func(Locker)

type Service struct {
	ID      string
	Address string
	Tags    []string
}

type ServiceRegistration struct {
	ID      string
	Name    string
	Address string
	Port    int
	Tags    []string
	TTL     time.Duration
}