rdb

package

Go to main page

Versions in this module

v0

v0.24.1

May 1, 2023

v0.24.0

Jan 2, 2023

v0.23.0

Apr 11, 2022

Changes in this version

+ type GroupStat struct

+ Group string

+ Size int

type RDB

+ func (r *RDB) AddToGroup(ctx context.Context, msg *base.TaskMessage, groupKey string) error

+ func (r *RDB) AddToGroupUnique(ctx context.Context, msg *base.TaskMessage, groupKey string, ttl time.Duration) error

+ func (r *RDB) AggregationCheck(qname, gname string, t time.Time, gracePeriod, maxDelay time.Duration, ...) (string, error)

+ func (r *RDB) ArchiveAllAggregatingTasks(qname, gname string) (int64, error)

+ func (r *RDB) DeleteAggregationSet(ctx context.Context, qname, gname, setID string) error

+ func (r *RDB) DeleteAllAggregatingTasks(qname, gname string) (int64, error)

+ func (r *RDB) GroupStats(qname string) ([]*GroupStat, error)

+ func (r *RDB) ListAggregating(qname, gname string, pgn Pagination) ([]*base.TaskInfo, error)

+ func (r *RDB) ListGroups(qname string) ([]string, error)

+ func (r *RDB) ReadAggregationSet(qname, gname, setID string) ([]*base.TaskMessage, time.Time, error)

+ func (r *RDB) ReclaimStaleAggregationSets(qname string) error

+ func (r *RDB) RunAllAggregatingTasks(qname, gname string) (int64, error)

type Stats

+ Aggregating int

+ Groups int

v0.22.1

Feb 20, 2022

v0.22.0

Feb 19, 2022

Changes in this version

+ const LeaseDuration

type RDB

+ func (r *RDB) ExtendLease(qname string, ids ...string) (expirationTime time.Time, err error)

+ func (r *RDB) ListLeaseExpired(cutoff time.Time, qnames ...string) ([]*base.TaskMessage, error)

v0.21.0

Jan 22, 2022

v0.20.0

Dec 19, 2021

Changes in this version

type Stats

+ FailedTotal int

+ ProcessedTotal int

v0.19.1

Dec 12, 2021

Changes in this version

type RDB

+ func (r *RDB) SetClock(c timeutil.Clock)

type Stats

+ Latency time.Duration

v0.19.0

Nov 6, 2021

Changes in this version

type RDB

+ func (r *RDB) DeleteAllCompletedTasks(qname string) (int64, error)

+ func (r *RDB) DeleteExpiredCompletedTasks(qname string) error

+ func (r *RDB) ListCompleted(qname string, pgn Pagination) ([]*base.TaskInfo, error)

+ func (r *RDB) MarkAsComplete(msg *base.TaskMessage) error

+ func (r *RDB) WriteResult(qname, taskID string, data []byte) (int, error)

type Stats

+ Completed int

v0.18.6

Oct 3, 2021

v0.18.5

Sep 1, 2021

v0.18.4

Aug 18, 2021

v0.18.3

Aug 9, 2021

v0.18.2

Jul 15, 2021

v0.18.1

Jul 4, 2021

v0.18.0

Jun 29, 2021

Changes in this version

type RDB

+ func (r *RDB) ArchiveTask(qname string, id uuid.UUID) error

+ func (r *RDB) Client() redis.UniversalClient

+ func (r *RDB) DeleteTask(qname string, id uuid.UUID) error

+ func (r *RDB) ForwardIfReady(qnames ...string) error

+ func (r *RDB) GetTaskInfo(qname string, id uuid.UUID) (*base.TaskInfo, error)

+ func (r *RDB) RunTask(qname string, id uuid.UUID) error

v0.17.2

Jun 6, 2021

v0.17.1

Apr 4, 2021

v0.17.0

Mar 24, 2021

v0.16.1

Mar 20, 2021

v0.16.0

Mar 11, 2021

v0.15.0

Jan 31, 2021

Changes in this version

type RDB

+ func (r *RDB) ArchiveAllPendingTasks(qname string) (int64, error)

+ func (r *RDB) ArchivePendingTask(qname string, id uuid.UUID) error

+ func (r *RDB) ClearSchedulerHistory(entryID string) error

+ func (r *RDB) DeleteAllPendingTasks(qname string) (int64, error)

+ func (r *RDB) DeletePendingTask(qname string, id uuid.UUID) error

type Stats

+ MemoryUsage int64

v0.14.1

Jan 19, 2021

v0.14.0

Jan 14, 2021

Changes in this version

type RDB

+ func (r *RDB) Archive(msg *base.TaskMessage, errMsg string) error

+ func (r *RDB) ArchiveAllRetryTasks(qname string) (int64, error)

+ func (r *RDB) ArchiveAllScheduledTasks(qname string) (int64, error)

+ func (r *RDB) ArchiveRetryTask(qname string, id uuid.UUID, score int64) error

+ func (r *RDB) ArchiveScheduledTask(qname string, id uuid.UUID, score int64) error

+ func (r *RDB) DeleteAllArchivedTasks(qname string) (int64, error)

+ func (r *RDB) DeleteArchivedTask(qname string, id uuid.UUID, score int64) error

+ func (r *RDB) ListArchived(qname string, pgn Pagination) ([]base.Z, error)

+ func (r *RDB) RunAllArchivedTasks(qname string) (int64, error)

+ func (r *RDB) RunArchivedTask(qname string, id uuid.UUID, score int64) error

type Stats

+ Archived int

v0.13.1

Nov 22, 2020

v0.13.0

Oct 13, 2020

Changes in this version

type RDB

+ func (r *RDB) ClearSchedulerEntries(scheduelrID string) error

+ func (r *RDB) ListSchedulerEnqueueEvents(entryID string) ([]*base.SchedulerEnqueueEvent, error)

+ func (r *RDB) ListSchedulerEntries() ([]*base.SchedulerEntry, error)

+ func (r *RDB) RecordSchedulerEnqueueEvent(entryID string, event *base.SchedulerEnqueueEvent) error

+ func (r *RDB) WriteSchedulerEntries(schedulerID string, entries []*base.SchedulerEntry, ttl time.Duration) error

v0.12.0

Sep 12, 2020

Changes in this version

type DailyStats

+ Queue string

type RDB

+ func (r *RDB) AllQueues() ([]string, error)

+ func (r *RDB) ClusterKeySlot(qname string) (int64, error)

+ func (r *RDB) ClusterNodes(qname string) ([]redis.ClusterNode, error)

+ func (r *RDB) ListActive(qname string, pgn Pagination) ([]*base.TaskMessage, error)

+ func (r *RDB) ListPending(qname string, pgn Pagination) ([]*base.TaskMessage, error)

+ func (r *RDB) RedisClusterInfo() (map[string]string, error)

+ func (r *RDB) RunAllDeadTasks(qname string) (int64, error)

+ func (r *RDB) RunAllRetryTasks(qname string) (int64, error)

+ func (r *RDB) RunAllScheduledTasks(qname string) (int64, error)

+ func (r *RDB) RunDeadTask(qname string, id uuid.UUID, score int64) error

+ func (r *RDB) RunRetryTask(qname string, id uuid.UUID, score int64) error

+ func (r *RDB) RunScheduledTask(qname string, id uuid.UUID, score int64) error

type Stats

+ Active int

+ Paused bool

+ Pending int

+ Queue string

+ Size int

v0.11.0

Jul 29, 2020

Changes in this version

type RDB

+ func (r *RDB) Ping() error

v0.10.0

Jul 6, 2020

Changes in this version

type RDB

+ func (r *RDB) ListDeadlineExceeded(deadline time.Time) ([]*base.TaskMessage, error)

v0.9.4

Jun 13, 2020

v0.9.3

Jun 12, 2020

v0.9.2

Jun 8, 2020

Changes in this version

+ type Queue struct

+ Name string

+ Paused bool

+ Size int

type RDB

+ func (r *RDB) Pause(qname string) error

+ func (r *RDB) Unpause(qname string) error

v0.9.1

May 29, 2020

v0.9.0

May 16, 2020

v0.8.3

May 8, 2020

v0.8.2

May 3, 2020

v0.8.1

Apr 27, 2020

v0.8.0

Apr 19, 2020

Changes in this version

type RDB

+ func (r *RDB) ClearServerState(ss *base.ServerState) error

+ func (r *RDB) ListServers() ([]*base.ServerInfo, error)

+ func (r *RDB) WriteServerState(ss *base.ServerState, ttl time.Duration) error

v0.7.1

Apr 5, 2020

v0.7.0

Mar 22, 2020

Changes in this version

+ var ErrDuplicateTask = errors.New("task already exists")

type RDB

+ func (r *RDB) EnqueueUnique(msg *base.TaskMessage, ttl time.Duration) error

+ func (r *RDB) ScheduleUnique(msg *base.TaskMessage, processAt time.Time, ttl time.Duration) error

v0.6.2

Mar 16, 2020

v0.6.1

Mar 12, 2020

v0.6.0

Mar 1, 2020

v0.5.0

Feb 24, 2020

Changes in this version

type RDB

+ func (r *RDB) ClearProcessState(ps *base.ProcessState) error

+ func (r *RDB) ListWorkers() ([]*base.WorkerInfo, error)

+ func (r *RDB) WriteProcessState(ps *base.ProcessState, ttl time.Duration) error

v0.4.0

Feb 13, 2020

Changes in this version

type RDB

+ func (r *RDB) CancelationPubSub() (*redis.PubSub, error)

+ func (r *RDB) PublishCancelation(id string) error

+ func (r *RDB) RequeueAll() (int64, error)

v0.3.0

Feb 4, 2020

Changes in this version

type RDB

+ func (r *RDB) ClearProcessInfo(ps *base.ProcessInfo) error

+ func (r *RDB) ListProcesses() ([]*base.ProcessInfo, error)

+ func (r *RDB) ReadProcessInfo(host string, pid int) (*base.ProcessInfo, error)

+ func (r *RDB) WriteProcessInfo(ps *base.ProcessInfo, ttl time.Duration) error

v0.2.2

Jan 27, 2020

Changes in this version

+ type Pagination struct

+ Page uint

+ Size uint

v0.2.1

Jan 22, 2020

v0.2.0

Jan 19, 2020

Changes in this version

+ var ErrNoProcessableTask = errors.New("no tasks are ready for processing")

type DeadTask

+ Queue string

type EnqueuedTask

+ Queue string

+ type ErrQueueNotEmpty struct

+ func (e *ErrQueueNotEmpty) Error() string

+ type ErrQueueNotFound struct

+ func (e *ErrQueueNotFound) Error() string

type RDB

+ func (r *RDB) RemoveQueue(qname string, force bool) error

type RetryTask

+ Queue string

type ScheduledTask

+ Queue string

type Stats

+ Queues map[string]int

v0.1.0

Jan 4, 2020

Changes in this version

+ var ErrDequeueTimeout = errors.New("blocking dequeue operation timed out")

+ var ErrTaskNotFound = errors.New("could not find a task")

+ type DailyStats struct

+ Failed int

+ Processed int

+ Time time.Time

+ type DeadTask struct

+ ErrorMsg string

+ ID xid.ID

+ LastFailedAt time.Time

+ Payload map[string]interface{}

+ Score int64

+ Type string

+ type EnqueuedTask struct

+ ID xid.ID

+ Payload map[string]interface{}

+ Type string

+ type InProgressTask struct

+ ID xid.ID

+ Payload map[string]interface{}

+ Type string

+ type RDB struct

+ func NewRDB(client *redis.Client) *RDB

+ func (r *RDB) CheckAndEnqueue() error

+ func (r *RDB) Close() error

+ func (r *RDB) CurrentStats() (*Stats, error)

+ func (r *RDB) DeleteAllDeadTasks() error

+ func (r *RDB) DeleteAllRetryTasks() error

+ func (r *RDB) DeleteAllScheduledTasks() error

+ func (r *RDB) DeleteDeadTask(id xid.ID, score int64) error

+ func (r *RDB) DeleteRetryTask(id xid.ID, score int64) error

+ func (r *RDB) DeleteScheduledTask(id xid.ID, score int64) error

+ func (r *RDB) Dequeue(timeout time.Duration) (*base.TaskMessage, error)

+ func (r *RDB) Done(msg *base.TaskMessage) error

+ func (r *RDB) Enqueue(msg *base.TaskMessage) error

+ func (r *RDB) EnqueueAllDeadTasks() (int64, error)

+ func (r *RDB) EnqueueAllRetryTasks() (int64, error)

+ func (r *RDB) EnqueueAllScheduledTasks() (int64, error)

+ func (r *RDB) EnqueueDeadTask(id xid.ID, score int64) error

+ func (r *RDB) EnqueueRetryTask(id xid.ID, score int64) error

+ func (r *RDB) EnqueueScheduledTask(id xid.ID, score int64) error

+ func (r *RDB) HistoricalStats(n int) ([]*DailyStats, error)

+ func (r *RDB) Kill(msg *base.TaskMessage, errMsg string) error

+ func (r *RDB) KillAllRetryTasks() (int64, error)

+ func (r *RDB) KillAllScheduledTasks() (int64, error)

+ func (r *RDB) KillRetryTask(id xid.ID, score int64) error

+ func (r *RDB) KillScheduledTask(id xid.ID, score int64) error

+ func (r *RDB) ListDead() ([]*DeadTask, error)

+ func (r *RDB) ListEnqueued() ([]*EnqueuedTask, error)

+ func (r *RDB) ListInProgress() ([]*InProgressTask, error)

+ func (r *RDB) ListRetry() ([]*RetryTask, error)

+ func (r *RDB) ListScheduled() ([]*ScheduledTask, error)

+ func (r *RDB) RedisInfo() (map[string]string, error)

+ func (r *RDB) Requeue(msg *base.TaskMessage) error

+ func (r *RDB) RestoreUnfinished() (int64, error)

+ func (r *RDB) Retry(msg *base.TaskMessage, processAt time.Time, errMsg string) error

+ func (r *RDB) Schedule(msg *base.TaskMessage, processAt time.Time) error

+ type RetryTask struct

+ ErrorMsg string

+ ID xid.ID

+ Payload map[string]interface{}

+ ProcessAt time.Time

+ Retried int

+ Retry int

+ Score int64

+ Type string

+ type ScheduledTask struct

+ ID xid.ID

+ Payload map[string]interface{}

+ ProcessAt time.Time

+ Score int64

+ Type string

+ type Stats struct

+ Dead int

+ Enqueued int

+ Failed int

+ InProgress int

+ Processed int

+ Retry int

+ Scheduled int

+ Timestamp time.Time

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL