reqqueue

type ReqQueue struct {
	ProcessTimeout time.Duration
	// contains filtered or unexported fields
}

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

type ReqQueueEntry struct {
	Type   ReqType
	Params reqparams.ReqParams
	TaskID uint64

	ReplyMessage *models.Message
	Message      *models.Message
	// contains filtered or unexported fields
}

type ReqQueueEntryProcessFn func(context.Context, reqparams.ReqParams, []byte) (imgs [][]byte, err error)

type ReqQueueReq struct {
	Type    ReqType
	Message *models.Message
	Params  reqparams.ReqParams
}

type ReqType int