qron

Jun 26, 2023

Changes in this version

+ func IsDuplicated(err error) bool

Jun 26, 2023

Changes in this version

type Scheduled

+ func (j Scheduled[T]) DeduplicationKey(key string) Scheduled[T]

May 12, 2023

Changes in this version

+ func Init(db *pgxpool.Pool, cfg Config) error

+ type JobEntity struct

+ type Scheduled struct

+ ExecutorName string

+ State T

+ func NewScheduled(executorName string) Scheduled[T]

+ func (j Scheduled[T]) Expr(expr string) Scheduled[T]

+ func (j Scheduled[T]) Fetch(ctx context.Context) chan ScheduledJob[T]

+ func (j Scheduled[T]) Name(name string) Scheduled[T]

+ func (j Scheduled[T]) Retries(retries int) Scheduled[T]

+ func (j Scheduled[T]) Schedule(ctx context.Context, state T) (sqlc.TinyJob, error)

+ func (j Scheduled[T]) StartAt(at time.Time) Scheduled[T]

+ func (j Scheduled[T]) Timeout(timeout int) Scheduled[T]

+ type ScheduledJob struct

+ State T

Mar 30, 2023

Changes in this version

type Client

+ MaxFlushSize int

+ func (c *Client) BatchCreateJobs(ctx context.Context, executorName string, args []model.CreateJobArgs) ([]int64, error)

type Config

+ MaxFlushSize int

Feb 18, 2023

Changes in this version

+ type Client struct

+ FlushInterval time.Duration

+ MaxInFlight uint64

+ OwnerSetter func(http.Handler) http.Handler

+ PollInterval time.Duration

+ ResetInterval time.Duration

+ Resolver graph.Resolver

+ func NewClient(db *pgxpool.Pool, cfg Config) (Client, error)

+ func (c *Client) Close()

+ func (c *Client) CreateJob(ctx context.Context, executorName string, args model.CreateJobArgs) (sqlc.TinyJob, error)

+ func (c *Client) DeleteJobByID(ctx context.Context, executorName string, id int64) (sqlc.TinyJob, error)

+ func (c *Client) DeleteJobByName(ctx context.Context, executorName, name string) (sqlc.TinyJob, error)

+ func (c *Client) Fetch(ctx context.Context, executorName string) chan Job

+ func (c *Client) Handler() http.Handler

+ func (c *Client) Migrate() error

+ func (c *Client) QueryJobByID(ctx context.Context, executorName string, id int64) (sqlc.TinyJob, error)

+ func (c *Client) QueryJobByName(ctx context.Context, executorName, name string) (sqlc.TinyJob, error)

+ func (c *Client) RestartJob(ctx context.Context, executorName string, id int64) (sqlc.TinyJob, error)

+ func (c *Client) SearchJobs(ctx context.Context, executorName string, args model.QueryJobsArgs) ([]sqlc.TinyJob, error)

+ func (c *Client) StopJob(ctx context.Context, executorName string, id int64) (sqlc.TinyJob, error)

+ func (c *Client) UpdateJobByID(ctx context.Context, executorName string, id int64, args model.UpdateJobArgs) (sqlc.TinyJob, error)

+ func (c *Client) UpdateJobByName(ctx context.Context, executorName, name string, args model.UpdateJobArgs) (sqlc.TinyJob, error)

+ func (t *Client) DecreaseInFlight()

+ func (t *Client) IncreaseInFlight()

+ type Config struct

+ FlushInterval time.Duration

+ MaxInFlight uint64

+ OwnerSetter func(http.Handler) http.Handler

+ PollInterval time.Duration

+ ResetInterval time.Duration

+ type Job struct

+ func (j Job) Commit()

+ func (j Job) Fail()

+ func (j Job) Retry()