definition

type CreateMqArgs struct {
	Mq string
}

type CreateMqReply struct{}

type DeleteMqArgs struct {
	Mq string
}

type DeleteMqReply struct{}

type Mq interface {
	// 创建队列
	CreateMq(mq string) (err error)

	// 删除队列
	DeleteMq(mq string) (err error)

	// 向队列里添加消息
	Push(mq string, msg string) (id uint64, err error)

	// 读取指定条数消息，并设置超时时间
	// 在时间范围内，消息不能再次被读取
	// 如果超出时间范围没有将消息删除或归档，消息会在下次被读取
	Read(mq string, num int, timeout time.Duration) (msgs []Msg, err error)

	// 从队列中读取指定条数消息
	// 并在队列中删除消息
	Pop(mq string, num int) (msgs []Msg, err error)

	// 从队列中删除指定消息
	Delete(mq string, id uint64) (err error)

	// 清空队列
	Drop(mq string) (err error)

	// 将消息存档
	Active(mq string, id uint64) (err error)

	// 获取队列长度
	Len(mq string) (int, error)

	// 设置键值对
	SetKeyValue(mq string, key string, value string, expire time.Duration) (err error)

	GetKeyValue(mq string, key string) (value *Value, ok bool, err error)

	DeleteKeyValue(mq string, key string) (err error)
}

type MqActiveArgs struct {
	Mq string
	Id uint64
}

type MqActiveReply struct{}

type MqDeleteArgs struct {
	Mq string
	Id uint64
}

type MqDeleteKeyValueArgs struct {
	Mq  string
	Key string
}

type MqDeleteKeyValueReply struct{}

type MqDeleteReply struct{}

type MqDropArgs struct {
	Mq string
}

type MqDropReply struct{}

type MqGetKeyValueArgs struct {
	Mq  string
	Key string
}

type MqGetKeyValueReply struct {
	Value *Value
	Ok    bool
}

type MqLenArgs struct {
	Mq string
}

type MqLenReply struct {
	Len int
}

type MqPopArgs struct {
	Mq  string
	Num int
}

type MqPopReply struct {
	Msgs []Msg
}

type MqPushArgs struct {
	Mq  string
	Msg string
}

type MqPushReply struct {
	Id uint64
}

type MqRPC interface {
	CreateMq(args CreateMqArgs, reply *CreateMqReply) (err error)

	DeleteMq(args DeleteMqArgs, reply *DeleteMqReply) (err error)

	Push(args MqPushArgs, reply *MqPushReply) (err error)

	Read(args MqReadArgs, reply *MqReadReply) (err error)

	Pop(args MqPopArgs, reply *MqPopReply) (err error)

	Delete(args MqDeleteArgs, reply *MqDeleteReply) (err error)

	Drop(args MqDropArgs, reply *MqDropReply) (err error)

	Active(args MqActiveArgs, reply *MqActiveReply) (err error)

	Len(args MqLenArgs, reply *MqLenReply) (err error)

	SetKeyValue(args MqSetKeyValueArgs, reply *MqSetKeyValueReply) (err error)
	GetKeyValue(args MqGetKeyValueArgs, reply *MqGetKeyValueReply) (err error)
	DeleteKeyValue(args MqDeleteKeyValueArgs, reply *MqDeleteKeyValueReply) (err error)

	Ping(PingArgs, *PingReply) (err error)
}

type MqReadArgs struct {
	Mq      string
	Num     int
	Timeout time.Duration
}

type MqReadReply struct {
	Msgs []Msg
}

type MqSetKeyValueArgs struct {
	Mq     string
	Key    string
	Value  string
	Expire *time.Time
}

type MqSetKeyValueReply struct{}

type Msg struct {
	Id        uint64
	Text      string
	CreatedAt time.Time
}

type PingArgs struct{}

type PingReply struct{}

type Value struct {
	Value     string
	UpdatedAt time.Time
	ExpireAt  time.Time
}