client

package

v0.0.0-...-e65d92b Latest Latest Go to latest Published: Aug 22, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type APIError struct {
	StatusCode int
	models.ErrorResponse
}

func (e *APIError) Conflict() bool

func (e *APIError) Error() string

func (e *APIError) NotFound() bool

type Client struct {
	// contains filtered or unexported fields
}

func New(o *Opt) *Client

func (c *Client) CancelJob(ctx context.Context, id string, version int32) (models.JobResponse, error)

func (c *Client) DeleteJob(ctx context.Context, id string) error

func (c *Client) GetAttemptLogs(ctx context.Context, jobID, attemptID string, q LogQuery) (models.JobLogListResponse, error)

func (c *Client) GetHandler(ctx context.Context, name string) (models.HandlerDetailResponse, error)

func (c *Client) GetHandlers(ctx context.Context) (models.HandlerListResponse, error)

func (c *Client) GetJob(ctx context.Context, id string) (models.JobResponse, error)

func (c *Client) GetJobAttempts(ctx context.Context, id string, q PageQuery) (models.JobAttemptListResponse, error)

func (c *Client) GetJobs(ctx context.Context, q JobQuery) (models.JobListResponse, error)

func (c *Client) GetQueues(ctx context.Context) (models.QueueListResponse, error)

func (c *Client) GetWorkers(ctx context.Context) (models.WorkerListResponse, error)

func (c *Client) PauseJob(ctx context.Context, id string, version int32, paused bool) (models.JobResponse, error)

func (c *Client) PostJob(ctx context.Context, j models.CreateJobRequest, idempotencyKey string) (models.JobResponse, error)

func (c *Client) RerunJob(ctx context.Context, id string, version int32) (models.JobResponse, error)

func (c *Client) RescheduleJob(ctx context.Context, id string, s models.RescheduleRequest) (models.JobResponse, error)

type JobQuery struct {
	States  []string
	Queue   string
	Handler string
	JobType string
	Search  string
	Limit   int32
	Offset  int32
}

type LogQuery struct {
	AfterSeq int32
	Limit    int32
}

type Opt struct {
	RootURL    string
	HTTPClient *http.Client
}

type PageQuery struct {
	Limit  int32
	Offset int32
}