Versions in this module Expand all Collapse all v3 v3.0.0 Jun 8, 2026 Changes in this version + const BURIED + const DELAYED + const DONE + const FIFO + const FIFO_TTL + const READY + const TAKEN + const UTUBE + const UTUBE_TTL + type Cfg struct + IfNotExists bool + Kind queueType + Temporary bool + type CfgOpts struct + InReplicaset bool + Ttr time.Duration + type Opts struct + Delay time.Duration + Pri int + Ttl time.Duration + Ttr time.Duration + Utube string + type Queue interface + Cfg func(opts CfgOpts) error + Create func(cfg Cfg) error + Delete func(taskId uint64) error + Drop func() error + Exists func() (bool, error) + Identify func(u *uuid.UUID) (uuid.UUID, error) + Kick func(count uint64) (uint64, error) + Peek func(taskId uint64) (*Task, error) + Put func(data any) (*Task, error) + PutWithOpts func(data any, cfg Opts) (*Task, error) + ReleaseAll func() error + State func() (State, error) + Statistic func() (any, error) + Take func() (*Task, error) + TakeTimeout func(timeout time.Duration) (*Task, error) + TakeTyped func(result any) (*Task, error) + TakeTypedTimeout func(timeout time.Duration, result any) (*Task, error) + func New(conn tarantool.Connector, name string) Queue + type State int + const EndingState + const InitState + const RunningState + const StartupState + const UnknownState + const WaitingState + type Task struct + func (t *Task) Ack() error + func (t *Task) Bury() error + func (t *Task) Data() any + func (t *Task) DecodeMsgpack(d *msgpack.Decoder) error + func (t *Task) Delete() error + func (t *Task) Id() uint64 + func (t *Task) IsBuried() bool + func (t *Task) IsDelayed() bool + func (t *Task) IsDone() bool + func (t *Task) IsReady() bool + func (t *Task) IsTaken() bool + func (t *Task) Release() error + func (t *Task) ReleaseCfg(cfg Opts) error + func (t *Task) Status() string + func (t *Task) Touch(increment time.Duration) error Other modules containing this package github.com/tarantool/go-tarantool github.com/tarantool/go-tarantool/v2
Go to main page