mq

type Channel string

type Handle struct {
	HandleFunc HandleFunc `json:"handle_func,omitempty"`
	// 默认为无限重试
	MaxAttempts uint16 `json:"max_attempts,omitempty"`

	MaxProcessCnt int64 `json:"max_process_cnt,omitempty"`

	// 消息超时时间
	MsgTimeout time.Duration `json:"msg_timeout,omitempty"`
}

type HandleFunc func(msg *HandleReq) (*HandleRsp, error)

type HandleReq struct {
	MsgId    string    `json:"msg_id,omitempty"`
	Attempts uint16    `json:"attempts,omitempty"`
	PubAt    time.Time `json:"pub_at,omitempty"`

	Body    []byte      `json:"body,omitempty"`
	Message interface{} `json:"message,omitempty"`
}

type HandleRsp struct {
	NeedRetry    bool `json:"need_retry,omitempty"`
	SkipRetryCnt bool `json:"skip_retry_cnt,omitempty"`

	WaitTime time.Duration `json:"wait_time,omitempty"`
}

type Logger struct {
}

type Option struct {
	// 数据存储的路径
	DataPath string `json:"data_path,omitempty"`
	// 内存队列的大小
	MemQueueSize int64 `json:"mem_queue_size,omitempty"`
}

type PublishRsp struct {
	Version uint32 `json:"version,omitempty"`
	MsgId   string `json:"msgid,omitempty"`
}

type Topic string