registry

type Config struct {
	Driver       string
	ConsulConfig ConsulConfig
}

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

type ConsulConfig struct {
	api.Config
}

type ConsulWatcher struct {
	Config *WatchConfig
	// contains filtered or unexported fields
}

type HandlerFunc func(context.Context, []Pair)

type IRegistry interface {
	// Register a node with the Registry with a given name
	// Returns a Registration id or error
	Register(ctx context.Context, name string, ttl time.Duration) (string, error)

	// Deregister a node which was registered with a id
	// Returns error on failure
	Deregister(ctx context.Context, id string) error

	// IsRegistered checks is node with registration_id is registred with registry
	IsRegistered(ctx context.Context, id string) bool

	// Renew a registration using registration_id
	Renew(ctx context.Context, id string) error

	// RenewPeriodic renews a registration id periodically based on TTL
	RenewPeriodic(ctx context.Context, id string, ttl time.Duration, doneCh <-chan struct{}) error

	// Acquire a lock for a registration_id on a given key and value pair
	Acquire(ctx context.Context, id string, key string, value []byte) (bool, error)

	// Release a lock for a registration_id on a given key and value pair
	Release(ctx context.Context, id string, key string, value string) bool

	// Watch on a key/keyprefix in registry
	Watch(ctx context.Context, wh *WatchConfig) (IWatcher, error)

	// Put a key value pair
	Put(ctx context.Context, key string, value []byte) (string, error)

	// Get returns a value for a key
	Get(ctx context.Context, key string) (*Pair, error)

	// List returns a keys with matching key prefix
	ListKeys(ctx context.Context, prefix string) ([]string, error)

	// List returns a slice of pairs with matching key prefix
	List(ctx context.Context, prefix string) ([]Pair, error)

	// Exists checks the existence of a key
	Exists(ctx context.Context, key string) (bool, error)

	// DeleteTree deletes all keys under a prefix
	DeleteTree(ctx context.Context, key string) error

	// IsAlive checks the health of the registry
	IsAlive(context.Context) (bool, error)
}

type IWatcher interface {
	// StartWatch interface implemented by registry watcher to start a watch
	StartWatch() error

	// StopWatch interface implemented by registry watcher to stop a watch
	// it should also release the resources held
	StopWatch()
}

type Pair struct {
	Key   string
	Value []byte
	// Version - The version of the stored key-value pair
	// Set by the registry, ModifyIndex in case of consul
	Version   string
	SessionID string
}

type WatchConfig struct {
	WatchType string
	WatchPath string
	Handler   HandlerFunc
}