client

type APIError struct {
	*apiv1.GenericError
}

type AckJobOpts struct {
	Data interface{}
}

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

type Config struct {
	Host string `envconfig:"host" json:"host"`
}

type DequeueOpts struct {
	Queues    []string
	Selectors []string
	Claims    label.Claims
	// Args provides an array of types to convert job arguments into when
	// deserializing.
	Args []interface{}
}

type EnqueueOpts struct {
	Data   interface{}
	Claims label.Claims
}

type GetJobOpts struct {
	Includes []string
}

type Interface interface {
	// Resource(name string) resource.Interface
	Ping(ctx context.Context) error

	// consumer rpcs
	// EnqueueJobs(ctx context.Context, jobs *resource.Jobs) ([]string, error)
	// EnqueueJobsOpts(ctx context.Context, jobs *resource.Jobs, opts EnqueueOpts) ([]string, error)
	EnqueueJob(ctx context.Context, job string, args ...interface{}) (string, error)
	EnqueueJobOpts(ctx context.Context, job string, opts EnqueueOpts, args ...interface{}) (string, error)
	DequeueJobs(ctx context.Context, num int, id string) (*resource.Jobs, error)
	DequeueJobsOpts(ctx context.Context, num int, opts DequeueOpts) (*resource.Jobs, error)
	AckJob(ctx context.Context, id string, status resource.Status) error
	AckJobOpts(ctx context.Context, id string, status resource.Status, opts AckJobOpts) error

	ListJobs(ctx context.Context, opts ListJobsOpts) (*resource.Jobs, error)
	GetJob(ctx context.Context, id string, opts *GetJobOpts) (*resource.Job, error)

	SaveQueue(ctx context.Context, name string, opts SaveQueueOpts) (*resource.Queue, error)
	// SaveQueues(ctx context.Context, queue *resource.Queues) error
	ListQueues(ctx context.Context, opts ListQueuesOpts) (*resource.Queues, error)
	GetQueue(ctx context.Context, id string) (*resource.Queue, error)
	DeleteQueue(ctx context.Context, queue string) error
	PauseQueue(ctx context.Context, queue string) error
	UnpauseQueue(ctx context.Context, queue string) error
	BlockQueue(ctx context.Context, queue string) error
	UnblockQueue(ctx context.Context, queue string) error
}

type ListJobsOpts struct {
	Queues    []string
	Selectors []string
	Statuses  []resource.Status
	Page      *resource.Pagination
	Includes  []string
}

type ListQueuesOpts struct {
	Names     []string
	Selectors []string
	Page      *resource.Pagination
	Includes  []string
}

type Provider func(c *Client) *Client

type Queue struct {
	*jobv1.Queue
}

type SaveQueueOpts struct {
	MaxRetries      int
	JobDuration     time.Duration
	CheckinDuration time.Duration
	ClaimDuration   time.Duration
	Labels          map[string]string
	Schema          []byte
	Unique          bool
	Version         string
	BackoffInitial  time.Duration
	BackoffMax      time.Duration
	BackoffFactor   float32
}