jobrpc

type DirPath struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FileChunk struct {
	// Types that are valid to be assigned to Chunk:
	//	*FileChunk_PathId
	//	*FileChunk_Data
	Chunk                isFileChunk_Chunk `protobuf_oneof:"chunk"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type FileChunk_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type FileChunk_PathId struct {
	PathId *FilePathAndID `protobuf:"bytes,1,opt,name=path_id,json=pathId,proto3,oneof"`
}

type FileOrDirectory struct {
	// Types that are valid to be assigned to Path:
	//	*FileOrDirectory_File
	//	*FileOrDirectory_Dir
	Path                 isFileOrDirectory_Path `protobuf_oneof:"path"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

type FileOrDirectory_Dir struct {
	Dir *DirPath `protobuf:"bytes,2,opt,name=dir,proto3,oneof"`
}

type FileOrDirectory_File struct {
	File *FilePath `protobuf:"bytes,1,opt,name=file,proto3,oneof"`
}

type FilePath struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FilePathAndID struct {
	Path                 *FilePath `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Id                   *ID       `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

type HeartbeatResponse struct {
	CarryOn              bool     `protobuf:"varint,1,opt,name=CarryOn,proto3" json:"CarryOn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ID struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type IDAndValue struct {
	Id                   *ID      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value                int64    `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type InfoResponse struct {
	Value                int64                `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	State                *State               `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	AppName              string               `protobuf:"bytes,3,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Hostname             string               `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Start                *timestamp.Timestamp `protobuf:"bytes,5,opt,name=start,proto3" json:"start,omitempty"`
	Deadline             *timestamp.Timestamp `protobuf:"bytes,6,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Failures             int64                `protobuf:"varint,7,opt,name=failures,proto3" json:"failures,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

type JobdClient interface {
	// Submit submits a job.
	Submit(ctx context.Context, in *Specification, opts ...grpc.CallOption) (*ID, error)
	// Upload uploads a file. The first FileChunk MUST contain the path; all subsequent FileChunks MUST contain the data.
	Upload(ctx context.Context, opts ...grpc.CallOption) (Jobd_UploadClient, error)
	// Download downloads the file with a given path. The first FileChunk will contain the path; all subsequent FileChunks will contain the data.
	Download(ctx context.Context, in *FilePathAndID, opts ...grpc.CallOption) (Jobd_DownloadClient, error)
	// Status returns the status of the job.
	Status(ctx context.Context, in *ID, opts ...grpc.CallOption) (*StatusResponse, error)
	// Info returns information about a task.
	Info(ctx context.Context, in *IDAndValue, opts ...grpc.CallOption) (*InfoResponse, error)
	// List returns the IDs of all jobs.
	List(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListResponse, error)
	// ListWithPriority returns the IDs of all jobs with the given priority.
	ListWithPriority(ctx context.Context, in *Priority, opts ...grpc.CallOption) (*ListResponse, error)
	// Delete deletes the job.
	Delete(ctx context.Context, in *ID, opts ...grpc.CallOption) (*empty.Empty, error)
	// Describe returns the submission data for a job.
	Describe(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Specification, error)
	// Next returns the next entry in a range.
	Next(ctx context.Context, in *WorkerMetadata, opts ...grpc.CallOption) (*Task, error)
	// Execute executes the task.
	Execute(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error)
	// Success indicates that the task has succeeded.
	Success(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error)
	// Error indicates that the task has failed and should be retried.
	Error(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error)
	// Requeue indicates that the task should be retried, without incrementing the number of failures.
	Requeue(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error)
	// Fatal indicates that the task has failed and should not be retried.
	Fatal(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error)
	// Heartbeat sends a heartbeat.
	Heartbeat(ctx context.Context, in *Task, opts ...grpc.CallOption) (*HeartbeatResponse, error)
}

type JobdServer interface {
	// Submit submits a job.
	Submit(context.Context, *Specification) (*ID, error)
	// Upload uploads a file. The first FileChunk MUST contain the path; all subsequent FileChunks MUST contain the data.
	Upload(Jobd_UploadServer) error
	// Download downloads the file with a given path. The first FileChunk will contain the path; all subsequent FileChunks will contain the data.
	Download(*FilePathAndID, Jobd_DownloadServer) error
	// Status returns the status of the job.
	Status(context.Context, *ID) (*StatusResponse, error)
	// Info returns information about a task.
	Info(context.Context, *IDAndValue) (*InfoResponse, error)
	// List returns the IDs of all jobs.
	List(context.Context, *empty.Empty) (*ListResponse, error)
	// ListWithPriority returns the IDs of all jobs with the given priority.
	ListWithPriority(context.Context, *Priority) (*ListResponse, error)
	// Delete deletes the job.
	Delete(context.Context, *ID) (*empty.Empty, error)
	// Describe returns the submission data for a job.
	Describe(context.Context, *ID) (*Specification, error)
	// Next returns the next entry in a range.
	Next(context.Context, *WorkerMetadata) (*Task, error)
	// Execute executes the task.
	Execute(context.Context, *Task) (*empty.Empty, error)
	// Success indicates that the task has succeeded.
	Success(context.Context, *Task) (*empty.Empty, error)
	// Error indicates that the task has failed and should be retried.
	Error(context.Context, *Task) (*empty.Empty, error)
	// Requeue indicates that the task should be retried, without incrementing the number of failures.
	Requeue(context.Context, *Task) (*empty.Empty, error)
	// Fatal indicates that the task has failed and should not be retried.
	Fatal(context.Context, *Task) (*empty.Empty, error)
	// Heartbeat sends a heartbeat.
	Heartbeat(context.Context, *Task) (*HeartbeatResponse, error)
}

type Jobd_DownloadClient interface {
	Recv() (*FileChunk, error)
	grpc.ClientStream
}

type Jobd_DownloadServer interface {
	Send(*FileChunk) error
	grpc.ServerStream
}

type Jobd_UploadClient interface {
	Send(*FileChunk) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type Jobd_UploadServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*FileChunk, error)
	grpc.ServerStream
}

type ListResponse struct {
	Ids                  []*ID    `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Manifest struct {
	Paths                []*FileOrDirectory `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type Metadata struct {
	Json                 string   `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Priority struct {
	Priority             uint32   `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Range struct {
	Range                string   `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RangeMetadata struct {
	AppName              string   `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Hostname             string   `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Specification struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Manifest             *Manifest          `protobuf:"bytes,2,opt,name=manifest,proto3" json:"manifest,omitempty"`
	Script               string             `protobuf:"bytes,3,opt,name=script,proto3" json:"script,omitempty"`
	WorkingDir           string             `protobuf:"bytes,4,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	Metadata             *Metadata          `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Range                *Range             `protobuf:"bytes,6,opt,name=range,proto3" json:"range,omitempty"`
	Priority             *Priority          `protobuf:"bytes,7,opt,name=priority,proto3" json:"priority,omitempty"`
	Lifetime             *duration.Duration `protobuf:"bytes,8,opt,name=lifetime,proto3" json:"lifetime,omitempty"`
	MaxRetries           int64              `protobuf:"varint,9,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	MaxConcurrency       int64              `protobuf:"varint,10,opt,name=max_concurrency,json=maxConcurrency,proto3" json:"max_concurrency,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type State struct {
	State                uint32   `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type StatusResponse struct {
	Pending              *Range   `protobuf:"bytes,1,opt,name=pending,proto3" json:"pending,omitempty"`
	Active               *Range   `protobuf:"bytes,2,opt,name=active,proto3" json:"active,omitempty"`
	Succeeded            *Range   `protobuf:"bytes,3,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	Failed               *Range   `protobuf:"bytes,4,opt,name=failed,proto3" json:"failed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Task struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Manifest             *Manifest            `protobuf:"bytes,2,opt,name=manifest,proto3" json:"manifest,omitempty"`
	Script               string               `protobuf:"bytes,3,opt,name=script,proto3" json:"script,omitempty"`
	WorkingDir           string               `protobuf:"bytes,4,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	Metadata             *Metadata            `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Priority             *Priority            `protobuf:"bytes,6,opt,name=priority,proto3" json:"priority,omitempty"`
	JobId                *ID                  `protobuf:"bytes,7,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Id                   *TaskID              `protobuf:"bytes,8,opt,name=id,proto3" json:"id,omitempty"`
	Value                int64                `protobuf:"varint,9,opt,name=value,proto3" json:"value,omitempty"`
	Deadline             *timestamp.Timestamp `protobuf:"bytes,10,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Failures             int64                `protobuf:"varint,11,opt,name=failures,proto3" json:"failures,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

type TaskID struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type UnimplementedJobdServer struct {
}

type WorkerMetadata struct {
	AppName              string   `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Hostname             string   `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}