memory

Documentation

Index

• func Backend(_ context.Context, opts ...neoq.ConfigOption) (backend neoq.Neoq, err error)
• type MemBackend
  • func (m *MemBackend) Enqueue(_ context.Context, job *jobs.Job) (jobID string, err error)
  • func (m *MemBackend) SetLogger(logger logging.Logger)
  • func (m *MemBackend) Shutdown(_ context.Context)
  • func (m *MemBackend) Start(ctx context.Context, h handler.Handler) (err error)
  • func (m *MemBackend) StartCron(ctx context.Context, cronSpec string, h handler.Handler) (err error)

Functions

func Backend

func Backend(_ context.Context, opts ...neoq.ConfigOption) (backend neoq.Neoq, err error)

Backend is a neoq.BackendInitializer that initializes a new memory-backed neoq backend

Types

type MemBackend

type MemBackend struct {
	neoq.Neoq
	// contains filtered or unexported fields
}

MemBackend is a memory-backed neoq backend

func (*MemBackend) Enqueue

func (m *MemBackend) Enqueue(_ context.Context, job *jobs.Job) (jobID string, err error)

Enqueue queues jobs to be executed asynchronously

func (*MemBackend) SetLogger

func (m *MemBackend) SetLogger(logger logging.Logger)

SetLogger sets this backend's logger

func (*MemBackend) Shutdown

func (m *MemBackend) Shutdown(_ context.Context)

Shutdown halts the worker

func (*MemBackend) Start

func (m *MemBackend) Start(ctx context.Context, h handler.Handler) (err error)

Start starts processing jobs with the specified queue and handler

func (*MemBackend) StartCron

func (m *MemBackend) StartCron(ctx context.Context, cronSpec string, h handler.Handler) (err error)

StartCron starts processing jobs with the specified cron schedule and handler

See: https://pkg.go.dev/github.com/robfig/cron?#hdr-CRON_Expression_Format for details on the cron spec format