db

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

type KVAction struct {
	Key        string
	Value      string
	ActionType string
}

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

type KVStorage interface {
	Get(string) (string, error)
	Set(string, string) error
	List(string, bool) (map[string]string, error)
	Delete(string) (string, error)
	Range(string, string) (map[string]string, error)
	Watch(context.Context, string, bool) <-chan KVAction
	Lock(context.Context, string) error
	Unlock(context.Context, string) error
}