v1

type AckJobsRequest struct {
	Acks []*AckJobsRequestArgs `protobuf:"bytes,1,rep,name=acks,proto3" json:"acks,omitempty"`
	// contains filtered or unexported fields
}

type AckJobsRequestArgs struct {
	Id     string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status v1.Status `protobuf:"varint,2,opt,name=status,proto3,enum=job.v1.Status" json:"status,omitempty"`
	Data   []byte    `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Error  string    `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type BlockQueueRequest struct {
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type BlockQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type DeleteQueueRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type DequeueJobsRequest struct {
	Num       int32    `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
	Queues    []string `protobuf:"bytes,2,rep,name=queues,proto3" json:"queues,omitempty"`
	Selectors []string `protobuf:"bytes,3,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Claims    []string `protobuf:"bytes,4,rep,name=claims,proto3" json:"claims,omitempty"`
	// contains filtered or unexported fields
}

type DequeueJobsResponse struct {
	Items  []*v1.Job        `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Errors []*ErrorResponse `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

type EnqueueJobsRequest struct {
	Jobs []*EnqueueJobsRequestArgs `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type EnqueueJobsRequestArgs struct {
	Job  string   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Args []byte   `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	Data *v1.Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type EnqueueJobsResponse struct {
	Jobs   []string         `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Errors []*ErrorResponse `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

type ErrorResponse struct {

	// Types that are assignable to ErrorResponse:
	//	*ErrorResponse_Error
	//	*ErrorResponse_Invalid
	ErrorResponse isErrorResponse_ErrorResponse `protobuf_oneof:"error_response"`
	// contains filtered or unexported fields
}

type ErrorResponse_Error struct {
	Error *GenericError `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type ErrorResponse_Invalid struct {
	Invalid *ValidationErrorResponse `protobuf:"bytes,2,opt,name=invalid,proto3,oneof"`
}

type GenericError struct {
	Kind       string             `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Message    string             `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Resource   string             `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	ResourceId string             `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Reason     string             `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	Ids        []string           `protobuf:"bytes,6,rep,name=ids,proto3" json:"ids,omitempty"`
	Invalid    []*ValidationError `protobuf:"bytes,7,rep,name=invalid,proto3" json:"invalid,omitempty"`
	// contains filtered or unexported fields
}

type GetJobRequest struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Include []string `protobuf:"bytes,2,rep,name=include,proto3" json:"include,omitempty"`
	// contains filtered or unexported fields
}

type GetQueueRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetQueueResponse struct {
	Data *v1.Queue `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsRequest struct {
	Queue        []string             `protobuf:"bytes,1,rep,name=queue,proto3" json:"queue,omitempty"`
	Status       []string             `protobuf:"bytes,2,rep,name=status,proto3" json:"status,omitempty"`
	Selector     []string             `protobuf:"bytes,3,rep,name=selector,proto3" json:"selector,omitempty"`
	Claim        []string             `protobuf:"bytes,4,rep,name=claim,proto3" json:"claim,omitempty"`
	NoUnclaimed  bool                 `protobuf:"varint,5,opt,name=no_unclaimed,json=noUnclaimed,proto3" json:"no_unclaimed,omitempty"`
	CreatedSince *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created_since,json=createdSince,proto3" json:"created_since,omitempty"`
	CreatedUntil *timestamp.Timestamp `protobuf:"bytes,7,opt,name=created_until,json=createdUntil,proto3" json:"created_until,omitempty"`
	Page         *Pagination          `protobuf:"bytes,8,opt,name=page,proto3" json:"page,omitempty"`
	Include      []string             `protobuf:"bytes,9,rep,name=include,proto3" json:"include,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsResponse struct {
	Items  []*v1.Job        `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Errors []*ErrorResponse `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

type ListQueuesRequest struct {
	Names     []string    `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	Selectors []string    `protobuf:"bytes,2,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Page      *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	Include   []string    `protobuf:"bytes,4,rep,name=include,proto3" json:"include,omitempty"`
	// contains filtered or unexported fields
}

type ListQueuesResponse struct {
	Items []*v1.Queue `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type Pagination struct {
	Limit  int64  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	LastId string `protobuf:"bytes,2,opt,name=last_id,json=lastId,proto3" json:"last_id,omitempty"`
	// contains filtered or unexported fields
}

type PauseQueueRequest struct {
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type PauseQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type SaveQueueParamArgs struct {
	Name                   string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	V                      int32              `protobuf:"varint,2,opt,name=v,proto3" json:"v,omitempty"`
	MaxRetries             int32              `protobuf:"varint,3,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	Duration               *duration.Duration `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"`
	ClaimDuration          *duration.Duration `protobuf:"bytes,5,opt,name=claim_duration,json=claimDuration,proto3" json:"claim_duration,omitempty"`
	CheckinDuration        *duration.Duration `protobuf:"bytes,6,opt,name=checkin_duration,json=checkinDuration,proto3" json:"checkin_duration,omitempty"`
	Labels                 map[string]string  `` /* 153-byte string literal not displayed */
	Schema                 []byte             `protobuf:"bytes,8,opt,name=schema,proto3" json:"schema,omitempty"`
	Unique                 bool               `protobuf:"varint,9,opt,name=unique,proto3" json:"unique,omitempty"`
	BackoffInitialDuration *duration.Duration `` /* 130-byte string literal not displayed */
	BackoffMaxDuration     *duration.Duration `protobuf:"bytes,11,opt,name=backoff_max_duration,json=backoffMaxDuration,proto3" json:"backoff_max_duration,omitempty"`
	BackoffFactor          float32            `protobuf:"fixed32,12,opt,name=backoff_factor,json=backoffFactor,proto3" json:"backoff_factor,omitempty"`
	// contains filtered or unexported fields
}

type SaveQueueRequest struct {
	Queues []*SaveQueueParamArgs `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
	// contains filtered or unexported fields
}

type SaveQueueResponse struct {
	Queue *v1.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

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

type StatsResponse struct {
	Queued               int64 `protobuf:"varint,1,opt,name=queued,proto3" json:"queued,omitempty"`
	Running              int64 `protobuf:"varint,2,opt,name=running,proto3" json:"running,omitempty"`
	Complete             int64 `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	Dead                 int64 `protobuf:"varint,4,opt,name=dead,proto3" json:"dead,omitempty"`
	Cancelled            int64 `protobuf:"varint,5,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	Invalid              int64 `protobuf:"varint,6,opt,name=invalid,proto3" json:"invalid,omitempty"`
	Failed               int64 `protobuf:"varint,7,opt,name=failed,proto3" json:"failed,omitempty"`
	LongestUnstartedSecs int64 `protobuf:"varint,8,opt,name=longest_unstarted_secs,json=longestUnstartedSecs,proto3" json:"longest_unstarted_secs,omitempty"`
	// contains filtered or unexported fields
}

type UnblockQueueRequest struct {
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type UnblockQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type UnpauseQueueRequest struct {
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type UnpauseQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type ValidationError struct {
	Path    string         `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Message string         `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value   *_struct.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ValidationErrorArg struct {
	Path    string         `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Message string         `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value   *_struct.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ValidationErrorResponse struct {
	Errs []*ValidationErrorArg `protobuf:"bytes,1,rep,name=errs,proto3" json:"errs,omitempty"`
	// contains filtered or unexported fields
}