bememory

Mar 9, 2021

Changes in this version

+ type Memory struct

+ func New() *Memory

+ func (m *Memory) AckJobs(ctx context.Context, acks *resource.Acks) error

+ func (m *Memory) DeleteJobUniqueArgs(ctx context.Context, ids, keys []string) error

+ func (m *Memory) DequeueJobs(ctx context.Context, limit int, opts *resource.JobListParams) (*resource.Jobs, error)

+ func (m *Memory) EnqueueJobs(ctx context.Context, jobArgs *resource.Jobs) (*resource.Jobs, error)

+ func (m *Memory) GetJobByID(ctx context.Context, id string, opts *resource.GetByIDOpts) (*resource.Job, error)

+ func (m *Memory) GetJobUniqueArgs(ctx context.Context, keys []string) ([]string, bool, error)

+ func (m *Memory) GetQueue(ctx context.Context, name string, opts *resource.GetByIDOpts) (*resource.Queue, error)

+ func (m *Memory) ListJobs(ctx context.Context, limit int, opts *resource.JobListParams) (*resource.Jobs, error)

+ func (m *Memory) ListQueues(ctx context.Context, opts *resource.QueueListParams) (*resource.Queues, error)

+ func (m *Memory) Ping(ctx context.Context) error

+ func (m *Memory) Reset(ctx context.Context) error

+ func (m *Memory) SaveQueue(ctx context.Context, queue *resource.Queue) (*resource.Queue, error)

+ func (m *Memory) SetJobUniqueArgs(ctx context.Context, ids, keys []string) error

+ func (m *Memory) Stats(ctx context.Context, queue string) (*resource.Stats, error)