kvs

type NextNode struct {
	Host net.TCPAddr
}

type QueueManager struct {
	QueuePrimary   redis.Conn
	QueueSecondary redis.Conn
	Queue          []UpdateQueue
	NextNode       *NextNode // Next node when replacing kvs node
	// contains filtered or unexported fields
}

type QueueManagerI interface {
	Enqueue(u UpdateQueue)
	Forward()
}

type UpdateQueue struct {
	Data     string `json:"data"`
	Key      string `json:"key"`
	UpdateAt int64  `json:"update_at"`
}