reqqueue

Apr 2, 2024

Changes in this version

type ReqQueue

+ ProcessTimeout time.Duration

Mar 28, 2024

Changes in this version

+ type ReqQueue struct

+ func (q *ReqQueue) Add(req ReqQueueReq)

+ func (q *ReqQueue) CancelCurrentEntry(ctx context.Context) (err error)

+ func (q *ReqQueue) CurrentEntryParams() reqparams.ReqParams

+ func (q *ReqQueue) GotImage(ctx context.Context, updateMsg *models.Message, ...)

+ func (q *ReqQueue) Init(ctx context.Context, sdApi *sdapi.SdAPIType, bot *telegram.SDBot)

+ func (q *ReqQueue) IsCurrentEntryChat() bool

+ func (q *ReqQueue) IsImageForMessage(msg *models.Message) bool

+ func (q *ReqQueue) SendReplyToCurrentEntry(ctx context.Context, text string)

+ type ReqQueueCurrentEntry struct

+ type ReqQueueEntry struct

+ Message *models.Message

+ Params reqparams.ReqParams

+ ReplyMessage *models.Message

+ TaskID uint64

+ Type ReqType

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

+ type ReqQueueReq struct

+ Message *models.Message

+ Params reqparams.ReqParams

+ Type ReqType

+ type ReqType int

+ const ReqTypeRender

+ const ReqTypeUpscale