agent

type Auth struct {
	Validators []Validator
}

type MasterAgent struct {
	Address string
	http.Handler
	MasterService
}

type MasterService interface {
	AssignNode(userID int64, queueName string, squadName string) (string, error)
	AddNode(info models.NodeInfo)
}

type QueueAgent struct {
	Address string
	http.Handler
	QueueService
}

type QueueService interface {
	ApplyMessageIDRange(userID int64, queueName string, size int) (maxID int64, err error)
	PushMessage(userID int64, queueName, content string, index int64) error
	PullMessages(userID int64, queueName, squadName string, length int) ([]models.Message, error)
	ReportMaxReceivedMessageID(userID int64, queueName, squadName string, messageID int64) error
	Info() models.NodeInfo
}

type Validator interface {
	Validate(accessKey string, secretKey string) (err error)
}

type ValidatorFunc func(accessKey string, secretKey string) (err error)