consul

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

type Leader interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	IsLeader() bool
}

type Locker interface {
	Acquire(ctx context.Context, key, sessionID string) (bool, error)
	Release(ctx context.Context, key, sessionID string) (bool, error)
	KeyOwner(ctx context.Context, key string) (string, error)
}

type ServiceDiscovery interface {
	ServiceInfo(ctx context.Context, serviceName string, tags []string) ([]*api.ServiceEntry, error)
	ServiceList(ctx context.Context) (map[string][]string, error)
	ServiceRegister(ctx context.Context, reg *api.AgentServiceRegistration) error
	ServiceDeregister(ctx context.Context, serviceID string) error
}

type Session interface {
	Create(ctx context.Context) (string, error)
	Destroy(ctx context.Context) error
	Renew(ctx context.Context) <-chan error
	SessionID() string
	SessionKey() string
}

type Watcher interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	WatchKeys(keys watcher.WatchKeys) error
	WatchPrefixKeys(keys watcher.WatchPrefixKey) error
}