etcdq

type Client interface {
	ReadItem(string) KV
	ReadItems(string) KVs
	WriteItem(string, string)
	DeleteItem(string)
	Atomic(writes KVs, deletes Ks) *v3.TxnResponse
	WatchPrefix(prefix string, startRevision int64, eventCh chan Events, stopCh chan struct{})
	SpinLock(name string, ttl int64) func() bool // A distributed lock, return func for lockAliveCheck
}

type Etcd struct {
	MaxTxnOps int
	// contains filtered or unexported fields
}

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

type Event_EventType int32

type Events []Event

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

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

type KVs []KV

type Ks []string

type Q interface {
	// contains filtered or unexported methods
}

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

type QueueValue struct {
	EventType Event_EventType
	Value     interface{}
}

type Schedule interface {
	InitPrevAliveHandlers(handlerPrefix string)
	Distribute(handlerPrefix string, queue Queue)
	Redistribute(handlerLockPrefix string, queue Queue)
}

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

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

type SyncHandle interface {
	Receive() KVs            // receive events distributed from queue
	GroupBy(*KVs)            // group tasks by prefix
	Merge(taskPrefix string) // merge events of one item

	Execute() // execute tasks with WaitGroup
	// contains filtered or unexported methods
}

type Watch interface {
	WatchPrefix(stopCh chan struct{})
	// contains filtered or unexported methods
}

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

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