reqqueue

Documentation

Index

• type ReqQueue
  • 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
• type ReqQueueEntry
• type ReqQueueEntryProcessFn
• type ReqQueueReq
• type ReqType

Types

type ReqQueue

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

func (*ReqQueue) Add

func (q *ReqQueue) Add(req ReqQueueReq)

func (*ReqQueue) CancelCurrentEntry

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

func (*ReqQueue) CurrentEntryParams

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

func (*ReqQueue) GotImage

func (q *ReqQueue) GotImage(ctx context.Context, updateMsg *models.Message, imageData *telegram.ImageFileData)

func (*ReqQueue) Init

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

func (*ReqQueue) IsCurrentEntryChat

func (q *ReqQueue) IsCurrentEntryChat() bool

func (*ReqQueue) IsImageForMessage

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

func (*ReqQueue) SendReplyToCurrentEntry

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

type ReqQueueCurrentEntry

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

type ReqQueueEntry

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

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

type ReqQueueEntryProcessFn

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

type ReqQueueReq

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

type ReqType

type ReqType int

const (
	ReqTypeRender ReqType = iota
	ReqTypeUpscale
)