Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterJobdServer

func RegisterJobdServer(s *grpc.Server, srv JobdServer)

func ToBoolean

func ToBoolean(hr *HeartbeatResponse) (bool, error)

    ToBoolean converts a *HeartbeatResponse into a boolean.

    func ToDirPath

    func ToDirPath(dp *DirPath) (string, error)

      ToDirPath converts a *DirPath to a string.

      func ToFilePath

      func ToFilePath(fp *FilePath) (string, error)

        ToFilePath converts a *FilePath to a string.

        func ToFilePathAndID

        func ToFilePathAndID(fi *FilePathAndID) (string, job.ID, error)

          ToFilePathAndID converts a *FilePathAndID into a string and a job.ID

          func ToID

          func ToID(id *ID) (job.ID, error)

            ToID converts a *ID into a job.ID

            func ToIDAndValue

            func ToIDAndValue(iv *IDAndValue) (job.ID, int64, error)

              ToIDAndValue converts a *IDAndValue to a job.ID and an int64.

              func ToIDs

              func ToIDs(lr *ListResponse) ([]job.ID, error)

                ToIDs converts a *ListResponse into a []job.ID.

                func ToInfo

                func ToInfo(ir *InfoResponse) (job.Info, error)

                  ToInfo converts a *InfoResponse into a job.Info.

                  func ToManifest

                  func ToManifest(M *Manifest) (job.Manifest, error)

                    ToManifest converts a *Manifest to a job.Manifest.

                    func ToMetadata

                    func ToMetadata(mt *Metadata) (map[string]string, error)

                      ToMetadata converts a *Metadata to a map[string]string

                      func ToPriority

                      func ToPriority(pr *Priority) (job.Priority, error)

                        ToPriority converts a *Priority to a job.Priority.

                        func ToRange

                        func ToRange(R *Range) (irange.Range, error)

                          ToRange converts a *Range to an irange.Range.

                          func ToSpecification

                          func ToSpecification(spec *Specification) (*job.Specification, error)

                            ToSpecification converts a *Specification into a *job.Specification.

                            func ToState

                            func ToState(st *State) (job.State, error)

                              ToState converts a *State into a job.State.

                              func ToStatus

                              func ToStatus(sr *StatusResponse) (job.Status, error)

                                ToStatus converts a *StatusResponse into a job.Status.

                                func ToTask

                                func ToTask(t *Task) (job.Task, error)

                                  ToTask converts a *Task into a job.Task.

                                  func ToTaskID

                                  func ToTaskID(id *TaskID) (job.TaskID, error)

                                    ToTaskID converts a *TaskID into a job.TaskID

                                    func ToWorkerMetadata

                                    func ToWorkerMetadata(wm *WorkerMetadata) (job.Metadata, error)

                                      ToWorkerMetadata converts a *WorkerMetadata to a *irange.Metadata.

                                      Types

                                      type DirPath

                                      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:"-"`
                                      }

                                        DirPath represents a path to a directory

                                        func FromDirPath

                                        func FromDirPath(p string) *DirPath

                                          FromDirPath converts a string to a *DirPath.

                                          func (*DirPath) Descriptor

                                          func (*DirPath) Descriptor() ([]byte, []int)

                                          func (*DirPath) GetPath

                                          func (m *DirPath) GetPath() string

                                          func (*DirPath) ProtoMessage

                                          func (*DirPath) ProtoMessage()

                                          func (*DirPath) Reset

                                          func (m *DirPath) Reset()

                                          func (*DirPath) String

                                          func (m *DirPath) String() string

                                          func (*DirPath) XXX_DiscardUnknown

                                          func (m *DirPath) XXX_DiscardUnknown()

                                          func (*DirPath) XXX_Marshal

                                          func (m *DirPath) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                          func (*DirPath) XXX_Merge

                                          func (m *DirPath) XXX_Merge(src proto.Message)

                                          func (*DirPath) XXX_Size

                                          func (m *DirPath) XXX_Size() int

                                          func (*DirPath) XXX_Unmarshal

                                          func (m *DirPath) XXX_Unmarshal(b []byte) error

                                          type FileChunk

                                          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:"-"`
                                          }

                                            FileChunk represents a chunk of a file

                                            func FileChunkFromData

                                            func FileChunkFromData(b []byte) *FileChunk

                                              FileChunkFromData converts the slice b to a *FileChunk.

                                              func FileChunkFromPathAndID

                                              func FileChunkFromPathAndID(path string, id job.ID) *FileChunk

                                                FileChunkFromPathAndID converts the given path and id to a *FileChunk.

                                                func (*FileChunk) Descriptor

                                                func (*FileChunk) Descriptor() ([]byte, []int)

                                                func (*FileChunk) GetChunk

                                                func (m *FileChunk) GetChunk() isFileChunk_Chunk

                                                func (*FileChunk) GetData

                                                func (m *FileChunk) GetData() []byte

                                                func (*FileChunk) GetPathId

                                                func (m *FileChunk) GetPathId() *FilePathAndID

                                                func (*FileChunk) ProtoMessage

                                                func (*FileChunk) ProtoMessage()

                                                func (*FileChunk) Reset

                                                func (m *FileChunk) Reset()

                                                func (*FileChunk) String

                                                func (m *FileChunk) String() string

                                                func (*FileChunk) XXX_DiscardUnknown

                                                func (m *FileChunk) XXX_DiscardUnknown()

                                                func (*FileChunk) XXX_Marshal

                                                func (m *FileChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                func (*FileChunk) XXX_Merge

                                                func (m *FileChunk) XXX_Merge(src proto.Message)

                                                func (*FileChunk) XXX_OneofWrappers

                                                func (*FileChunk) XXX_OneofWrappers() []interface{}

                                                  XXX_OneofWrappers is for the internal use of the proto package.

                                                  func (*FileChunk) XXX_Size

                                                  func (m *FileChunk) XXX_Size() int

                                                  func (*FileChunk) XXX_Unmarshal

                                                  func (m *FileChunk) XXX_Unmarshal(b []byte) error

                                                  type FileChunk_Data

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

                                                  type FileChunk_PathId

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

                                                  type FileOrDirectory

                                                  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:"-"`
                                                  }

                                                    FileOrDirectory represents a path to a file or directory

                                                    func (*FileOrDirectory) Descriptor

                                                    func (*FileOrDirectory) Descriptor() ([]byte, []int)

                                                    func (*FileOrDirectory) GetDir

                                                    func (m *FileOrDirectory) GetDir() *DirPath

                                                    func (*FileOrDirectory) GetFile

                                                    func (m *FileOrDirectory) GetFile() *FilePath

                                                    func (*FileOrDirectory) GetPath

                                                    func (m *FileOrDirectory) GetPath() isFileOrDirectory_Path

                                                    func (*FileOrDirectory) ProtoMessage

                                                    func (*FileOrDirectory) ProtoMessage()

                                                    func (*FileOrDirectory) Reset

                                                    func (m *FileOrDirectory) Reset()

                                                    func (*FileOrDirectory) String

                                                    func (m *FileOrDirectory) String() string

                                                    func (*FileOrDirectory) XXX_DiscardUnknown

                                                    func (m *FileOrDirectory) XXX_DiscardUnknown()

                                                    func (*FileOrDirectory) XXX_Marshal

                                                    func (m *FileOrDirectory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                    func (*FileOrDirectory) XXX_Merge

                                                    func (m *FileOrDirectory) XXX_Merge(src proto.Message)

                                                    func (*FileOrDirectory) XXX_OneofWrappers

                                                    func (*FileOrDirectory) XXX_OneofWrappers() []interface{}

                                                      XXX_OneofWrappers is for the internal use of the proto package.

                                                      func (*FileOrDirectory) XXX_Size

                                                      func (m *FileOrDirectory) XXX_Size() int

                                                      func (*FileOrDirectory) XXX_Unmarshal

                                                      func (m *FileOrDirectory) XXX_Unmarshal(b []byte) error

                                                      type FileOrDirectory_Dir

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

                                                      type FileOrDirectory_File

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

                                                      type FilePath

                                                      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:"-"`
                                                      }

                                                        FilePath represents a path to a file

                                                        func FromFilePath

                                                        func FromFilePath(p string) *FilePath

                                                          FromFilePath converts a string to a *FilePath.

                                                          func (*FilePath) Descriptor

                                                          func (*FilePath) Descriptor() ([]byte, []int)

                                                          func (*FilePath) GetPath

                                                          func (m *FilePath) GetPath() string

                                                          func (*FilePath) ProtoMessage

                                                          func (*FilePath) ProtoMessage()

                                                          func (*FilePath) Reset

                                                          func (m *FilePath) Reset()

                                                          func (*FilePath) String

                                                          func (m *FilePath) String() string

                                                          func (*FilePath) XXX_DiscardUnknown

                                                          func (m *FilePath) XXX_DiscardUnknown()

                                                          func (*FilePath) XXX_Marshal

                                                          func (m *FilePath) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                          func (*FilePath) XXX_Merge

                                                          func (m *FilePath) XXX_Merge(src proto.Message)

                                                          func (*FilePath) XXX_Size

                                                          func (m *FilePath) XXX_Size() int

                                                          func (*FilePath) XXX_Unmarshal

                                                          func (m *FilePath) XXX_Unmarshal(b []byte) error

                                                          type FilePathAndID

                                                          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:"-"`
                                                          }

                                                            FilePathAndID represents a path to a file and a job ID.

                                                            func FromFilePathAndID

                                                            func FromFilePathAndID(p string, id job.ID) *FilePathAndID

                                                              FromFilePathAndID converts a string and a job.ID into a *FilePathAndID.

                                                              func (*FilePathAndID) Descriptor

                                                              func (*FilePathAndID) Descriptor() ([]byte, []int)

                                                              func (*FilePathAndID) GetId

                                                              func (m *FilePathAndID) GetId() *ID

                                                              func (*FilePathAndID) GetPath

                                                              func (m *FilePathAndID) GetPath() *FilePath

                                                              func (*FilePathAndID) ProtoMessage

                                                              func (*FilePathAndID) ProtoMessage()

                                                              func (*FilePathAndID) Reset

                                                              func (m *FilePathAndID) Reset()

                                                              func (*FilePathAndID) String

                                                              func (m *FilePathAndID) String() string

                                                              func (*FilePathAndID) XXX_DiscardUnknown

                                                              func (m *FilePathAndID) XXX_DiscardUnknown()

                                                              func (*FilePathAndID) XXX_Marshal

                                                              func (m *FilePathAndID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                              func (*FilePathAndID) XXX_Merge

                                                              func (m *FilePathAndID) XXX_Merge(src proto.Message)

                                                              func (*FilePathAndID) XXX_Size

                                                              func (m *FilePathAndID) XXX_Size() int

                                                              func (*FilePathAndID) XXX_Unmarshal

                                                              func (m *FilePathAndID) XXX_Unmarshal(b []byte) error

                                                              type HeartbeatResponse

                                                              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:"-"`
                                                              }

                                                                HeartbeatResponse is a boolean, indicating whether or not execution of the current task should continue.

                                                                func FromBoolean

                                                                func FromBoolean(b bool) *HeartbeatResponse

                                                                  FromBoolean converts a boolean into a *HeartbeatResponse.

                                                                  func (*HeartbeatResponse) Descriptor

                                                                  func (*HeartbeatResponse) Descriptor() ([]byte, []int)

                                                                  func (*HeartbeatResponse) GetCarryOn

                                                                  func (m *HeartbeatResponse) GetCarryOn() bool

                                                                  func (*HeartbeatResponse) ProtoMessage

                                                                  func (*HeartbeatResponse) ProtoMessage()

                                                                  func (*HeartbeatResponse) Reset

                                                                  func (m *HeartbeatResponse) Reset()

                                                                  func (*HeartbeatResponse) String

                                                                  func (m *HeartbeatResponse) String() string

                                                                  func (*HeartbeatResponse) XXX_DiscardUnknown

                                                                  func (m *HeartbeatResponse) XXX_DiscardUnknown()

                                                                  func (*HeartbeatResponse) XXX_Marshal

                                                                  func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                  func (*HeartbeatResponse) XXX_Merge

                                                                  func (m *HeartbeatResponse) XXX_Merge(src proto.Message)

                                                                  func (*HeartbeatResponse) XXX_Size

                                                                  func (m *HeartbeatResponse) XXX_Size() int

                                                                  func (*HeartbeatResponse) XXX_Unmarshal

                                                                  func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error

                                                                  type ID

                                                                  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:"-"`
                                                                  }

                                                                    ID represents a unique identifier for a job

                                                                    func FromID

                                                                    func FromID(j job.ID) *ID

                                                                      FromID converts a job.ID into a *ID

                                                                      func (*ID) Descriptor

                                                                      func (*ID) Descriptor() ([]byte, []int)

                                                                      func (*ID) GetId

                                                                      func (m *ID) GetId() string

                                                                      func (*ID) ProtoMessage

                                                                      func (*ID) ProtoMessage()

                                                                      func (*ID) Reset

                                                                      func (m *ID) Reset()

                                                                      func (*ID) String

                                                                      func (m *ID) String() string

                                                                      func (*ID) XXX_DiscardUnknown

                                                                      func (m *ID) XXX_DiscardUnknown()

                                                                      func (*ID) XXX_Marshal

                                                                      func (m *ID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                      func (*ID) XXX_Merge

                                                                      func (m *ID) XXX_Merge(src proto.Message)

                                                                      func (*ID) XXX_Size

                                                                      func (m *ID) XXX_Size() int

                                                                      func (*ID) XXX_Unmarshal

                                                                      func (m *ID) XXX_Unmarshal(b []byte) error

                                                                      type IDAndValue

                                                                      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:"-"`
                                                                      }

                                                                        IDAndValue is a job ID together with a value in the range for that job.

                                                                        func FromIDAndValue

                                                                        func FromIDAndValue(id job.ID, n int64) *IDAndValue

                                                                          FromIDAndValue converts a job.ID and int64 to a *IDAndValue.

                                                                          func (*IDAndValue) Descriptor

                                                                          func (*IDAndValue) Descriptor() ([]byte, []int)

                                                                          func (*IDAndValue) GetId

                                                                          func (m *IDAndValue) GetId() *ID

                                                                          func (*IDAndValue) GetValue

                                                                          func (m *IDAndValue) GetValue() int64

                                                                          func (*IDAndValue) ProtoMessage

                                                                          func (*IDAndValue) ProtoMessage()

                                                                          func (*IDAndValue) Reset

                                                                          func (m *IDAndValue) Reset()

                                                                          func (*IDAndValue) String

                                                                          func (m *IDAndValue) String() string

                                                                          func (*IDAndValue) XXX_DiscardUnknown

                                                                          func (m *IDAndValue) XXX_DiscardUnknown()

                                                                          func (*IDAndValue) XXX_Marshal

                                                                          func (m *IDAndValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                          func (*IDAndValue) XXX_Merge

                                                                          func (m *IDAndValue) XXX_Merge(src proto.Message)

                                                                          func (*IDAndValue) XXX_Size

                                                                          func (m *IDAndValue) XXX_Size() int

                                                                          func (*IDAndValue) XXX_Unmarshal

                                                                          func (m *IDAndValue) XXX_Unmarshal(b []byte) error

                                                                          type InfoResponse

                                                                          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:"-"`
                                                                          }

                                                                            InfoResponse represents information about a task.

                                                                            func FromInfo

                                                                            func FromInfo(inf job.Info) (*InfoResponse, error)

                                                                              FromInfo converts a job.Info to a *InfoResponse.

                                                                              func (*InfoResponse) Descriptor

                                                                              func (*InfoResponse) Descriptor() ([]byte, []int)

                                                                              func (*InfoResponse) GetAppName

                                                                              func (m *InfoResponse) GetAppName() string

                                                                              func (*InfoResponse) GetDeadline

                                                                              func (m *InfoResponse) GetDeadline() *timestamp.Timestamp

                                                                              func (*InfoResponse) GetFailures

                                                                              func (m *InfoResponse) GetFailures() int64

                                                                              func (*InfoResponse) GetHostname

                                                                              func (m *InfoResponse) GetHostname() string

                                                                              func (*InfoResponse) GetStart

                                                                              func (m *InfoResponse) GetStart() *timestamp.Timestamp

                                                                              func (*InfoResponse) GetState

                                                                              func (m *InfoResponse) GetState() *State

                                                                              func (*InfoResponse) GetValue

                                                                              func (m *InfoResponse) GetValue() int64

                                                                              func (*InfoResponse) ProtoMessage

                                                                              func (*InfoResponse) ProtoMessage()

                                                                              func (*InfoResponse) Reset

                                                                              func (m *InfoResponse) Reset()

                                                                              func (*InfoResponse) String

                                                                              func (m *InfoResponse) String() string

                                                                              func (*InfoResponse) XXX_DiscardUnknown

                                                                              func (m *InfoResponse) XXX_DiscardUnknown()

                                                                              func (*InfoResponse) XXX_Marshal

                                                                              func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                              func (*InfoResponse) XXX_Merge

                                                                              func (m *InfoResponse) XXX_Merge(src proto.Message)

                                                                              func (*InfoResponse) XXX_Size

                                                                              func (m *InfoResponse) XXX_Size() int

                                                                              func (*InfoResponse) XXX_Unmarshal

                                                                              func (m *InfoResponse) XXX_Unmarshal(b []byte) error

                                                                              type JobdClient

                                                                              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)
                                                                              }

                                                                                JobdClient is the client API for Jobd service.

                                                                                For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

                                                                                func NewJobdClient

                                                                                func NewJobdClient(cc *grpc.ClientConn) JobdClient

                                                                                type JobdServer

                                                                                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)
                                                                                }

                                                                                  JobdServer is the server API for Jobd service.

                                                                                  type Jobd_DownloadClient

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

                                                                                  type Jobd_DownloadServer

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

                                                                                  type Jobd_UploadClient

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

                                                                                  type Jobd_UploadServer

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

                                                                                  type ListResponse

                                                                                  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:"-"`
                                                                                  }

                                                                                    ListResponse is a sequence of job IDs.

                                                                                    func FromIDs

                                                                                    func FromIDs(ids []job.ID) (*ListResponse, error)

                                                                                      FromIDs converts a []job.ID into a *ListResponse.

                                                                                      func (*ListResponse) Descriptor

                                                                                      func (*ListResponse) Descriptor() ([]byte, []int)

                                                                                      func (*ListResponse) GetIds

                                                                                      func (m *ListResponse) GetIds() []*ID

                                                                                      func (*ListResponse) ProtoMessage

                                                                                      func (*ListResponse) ProtoMessage()

                                                                                      func (*ListResponse) Reset

                                                                                      func (m *ListResponse) Reset()

                                                                                      func (*ListResponse) String

                                                                                      func (m *ListResponse) String() string

                                                                                      func (*ListResponse) XXX_DiscardUnknown

                                                                                      func (m *ListResponse) XXX_DiscardUnknown()

                                                                                      func (*ListResponse) XXX_Marshal

                                                                                      func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                      func (*ListResponse) XXX_Merge

                                                                                      func (m *ListResponse) XXX_Merge(src proto.Message)

                                                                                      func (*ListResponse) XXX_Size

                                                                                      func (m *ListResponse) XXX_Size() int

                                                                                      func (*ListResponse) XXX_Unmarshal

                                                                                      func (m *ListResponse) XXX_Unmarshal(b []byte) error

                                                                                      type Manifest

                                                                                      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:"-"`
                                                                                      }

                                                                                        Manifest represents a collection of files and directories on a pcas fs server.

                                                                                        func FromManifest

                                                                                        func FromManifest(M job.Manifest) *Manifest

                                                                                          FromManifest converts a job.Manifest to a *Manifest.

                                                                                          func (*Manifest) Descriptor

                                                                                          func (*Manifest) Descriptor() ([]byte, []int)

                                                                                          func (*Manifest) GetPaths

                                                                                          func (m *Manifest) GetPaths() []*FileOrDirectory

                                                                                          func (*Manifest) ProtoMessage

                                                                                          func (*Manifest) ProtoMessage()

                                                                                          func (*Manifest) Reset

                                                                                          func (m *Manifest) Reset()

                                                                                          func (*Manifest) String

                                                                                          func (m *Manifest) String() string

                                                                                          func (*Manifest) XXX_DiscardUnknown

                                                                                          func (m *Manifest) XXX_DiscardUnknown()

                                                                                          func (*Manifest) XXX_Marshal

                                                                                          func (m *Manifest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                          func (*Manifest) XXX_Merge

                                                                                          func (m *Manifest) XXX_Merge(src proto.Message)

                                                                                          func (*Manifest) XXX_Size

                                                                                          func (m *Manifest) XXX_Size() int

                                                                                          func (*Manifest) XXX_Unmarshal

                                                                                          func (m *Manifest) XXX_Unmarshal(b []byte) error

                                                                                          type Metadata

                                                                                          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:"-"`
                                                                                          }

                                                                                            Metadata represents user-provided metadata.

                                                                                            func FromMetadata

                                                                                            func FromMetadata(m map[string]string) (*Metadata, error)

                                                                                              FromMetadata converts m to a *Metadata

                                                                                              func (*Metadata) Descriptor

                                                                                              func (*Metadata) Descriptor() ([]byte, []int)

                                                                                              func (*Metadata) GetJson

                                                                                              func (m *Metadata) GetJson() string

                                                                                              func (*Metadata) ProtoMessage

                                                                                              func (*Metadata) ProtoMessage()

                                                                                              func (*Metadata) Reset

                                                                                              func (m *Metadata) Reset()

                                                                                              func (*Metadata) String

                                                                                              func (m *Metadata) String() string

                                                                                              func (*Metadata) XXX_DiscardUnknown

                                                                                              func (m *Metadata) XXX_DiscardUnknown()

                                                                                              func (*Metadata) XXX_Marshal

                                                                                              func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                              func (*Metadata) XXX_Merge

                                                                                              func (m *Metadata) XXX_Merge(src proto.Message)

                                                                                              func (*Metadata) XXX_Size

                                                                                              func (m *Metadata) XXX_Size() int

                                                                                              func (*Metadata) XXX_Unmarshal

                                                                                              func (m *Metadata) XXX_Unmarshal(b []byte) error

                                                                                              type Priority

                                                                                              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:"-"`
                                                                                              }

                                                                                                Priority represents the priority level of a job.

                                                                                                func FromPriority

                                                                                                func FromPriority(p job.Priority) *Priority

                                                                                                  FromPriority converts a job.Priority to a *Priority.

                                                                                                  func (*Priority) Descriptor

                                                                                                  func (*Priority) Descriptor() ([]byte, []int)

                                                                                                  func (*Priority) GetPriority

                                                                                                  func (m *Priority) GetPriority() uint32

                                                                                                  func (*Priority) ProtoMessage

                                                                                                  func (*Priority) ProtoMessage()

                                                                                                  func (*Priority) Reset

                                                                                                  func (m *Priority) Reset()

                                                                                                  func (*Priority) String

                                                                                                  func (m *Priority) String() string

                                                                                                  func (*Priority) XXX_DiscardUnknown

                                                                                                  func (m *Priority) XXX_DiscardUnknown()

                                                                                                  func (*Priority) XXX_Marshal

                                                                                                  func (m *Priority) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                  func (*Priority) XXX_Merge

                                                                                                  func (m *Priority) XXX_Merge(src proto.Message)

                                                                                                  func (*Priority) XXX_Size

                                                                                                  func (m *Priority) XXX_Size() int

                                                                                                  func (*Priority) XXX_Unmarshal

                                                                                                  func (m *Priority) XXX_Unmarshal(b []byte) error

                                                                                                  type Range

                                                                                                  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:"-"`
                                                                                                  }

                                                                                                    Range represents a range.

                                                                                                    func FromRange

                                                                                                    func FromRange(R irange.Range) *Range

                                                                                                      FromRange converts an irange.Range to a *Range.

                                                                                                      func (*Range) Descriptor

                                                                                                      func (*Range) Descriptor() ([]byte, []int)

                                                                                                      func (*Range) GetRange

                                                                                                      func (m *Range) GetRange() string

                                                                                                      func (*Range) ProtoMessage

                                                                                                      func (*Range) ProtoMessage()

                                                                                                      func (*Range) Reset

                                                                                                      func (m *Range) Reset()

                                                                                                      func (*Range) String

                                                                                                      func (m *Range) String() string

                                                                                                      func (*Range) XXX_DiscardUnknown

                                                                                                      func (m *Range) XXX_DiscardUnknown()

                                                                                                      func (*Range) XXX_Marshal

                                                                                                      func (m *Range) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                      func (*Range) XXX_Merge

                                                                                                      func (m *Range) XXX_Merge(src proto.Message)

                                                                                                      func (*Range) XXX_Size

                                                                                                      func (m *Range) XXX_Size() int

                                                                                                      func (*Range) XXX_Unmarshal

                                                                                                      func (m *Range) XXX_Unmarshal(b []byte) error

                                                                                                      type RangeMetadata

                                                                                                      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:"-"`
                                                                                                      }

                                                                                                        RangeMetadata is an application name and a hostname.

                                                                                                        func (*RangeMetadata) Descriptor

                                                                                                        func (*RangeMetadata) Descriptor() ([]byte, []int)

                                                                                                        func (*RangeMetadata) GetAppName

                                                                                                        func (m *RangeMetadata) GetAppName() string

                                                                                                        func (*RangeMetadata) GetHostname

                                                                                                        func (m *RangeMetadata) GetHostname() string

                                                                                                        func (*RangeMetadata) ProtoMessage

                                                                                                        func (*RangeMetadata) ProtoMessage()

                                                                                                        func (*RangeMetadata) Reset

                                                                                                        func (m *RangeMetadata) Reset()

                                                                                                        func (*RangeMetadata) String

                                                                                                        func (m *RangeMetadata) String() string

                                                                                                        func (*RangeMetadata) XXX_DiscardUnknown

                                                                                                        func (m *RangeMetadata) XXX_DiscardUnknown()

                                                                                                        func (*RangeMetadata) XXX_Marshal

                                                                                                        func (m *RangeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                        func (*RangeMetadata) XXX_Merge

                                                                                                        func (m *RangeMetadata) XXX_Merge(src proto.Message)

                                                                                                        func (*RangeMetadata) XXX_Size

                                                                                                        func (m *RangeMetadata) XXX_Size() int

                                                                                                        func (*RangeMetadata) XXX_Unmarshal

                                                                                                        func (m *RangeMetadata) XXX_Unmarshal(b []byte) error

                                                                                                        type Specification

                                                                                                        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:"-"`
                                                                                                        }

                                                                                                          Specification represents a job submitted by a client.

                                                                                                          func FromSpecification

                                                                                                          func FromSpecification(spec *job.Specification) (*Specification, error)

                                                                                                            FromSpecification converts a *job.Specification to a *Specification.

                                                                                                            func (*Specification) Descriptor

                                                                                                            func (*Specification) Descriptor() ([]byte, []int)

                                                                                                            func (*Specification) GetLifetime

                                                                                                            func (m *Specification) GetLifetime() *duration.Duration

                                                                                                            func (*Specification) GetManifest

                                                                                                            func (m *Specification) GetManifest() *Manifest

                                                                                                            func (*Specification) GetMaxConcurrency

                                                                                                            func (m *Specification) GetMaxConcurrency() int64

                                                                                                            func (*Specification) GetMaxRetries

                                                                                                            func (m *Specification) GetMaxRetries() int64

                                                                                                            func (*Specification) GetMetadata

                                                                                                            func (m *Specification) GetMetadata() *Metadata

                                                                                                            func (*Specification) GetName

                                                                                                            func (m *Specification) GetName() string

                                                                                                            func (*Specification) GetPriority

                                                                                                            func (m *Specification) GetPriority() *Priority

                                                                                                            func (*Specification) GetRange

                                                                                                            func (m *Specification) GetRange() *Range

                                                                                                            func (*Specification) GetScript

                                                                                                            func (m *Specification) GetScript() string

                                                                                                            func (*Specification) GetWorkingDir

                                                                                                            func (m *Specification) GetWorkingDir() string

                                                                                                            func (*Specification) ProtoMessage

                                                                                                            func (*Specification) ProtoMessage()

                                                                                                            func (*Specification) Reset

                                                                                                            func (m *Specification) Reset()

                                                                                                            func (*Specification) String

                                                                                                            func (m *Specification) String() string

                                                                                                            func (*Specification) XXX_DiscardUnknown

                                                                                                            func (m *Specification) XXX_DiscardUnknown()

                                                                                                            func (*Specification) XXX_Marshal

                                                                                                            func (m *Specification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                            func (*Specification) XXX_Merge

                                                                                                            func (m *Specification) XXX_Merge(src proto.Message)

                                                                                                            func (*Specification) XXX_Size

                                                                                                            func (m *Specification) XXX_Size() int

                                                                                                            func (*Specification) XXX_Unmarshal

                                                                                                            func (m *Specification) XXX_Unmarshal(b []byte) error

                                                                                                            type State

                                                                                                            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:"-"`
                                                                                                            }

                                                                                                              State represents the state of a task.

                                                                                                              func FromState

                                                                                                              func FromState(st job.State) *State

                                                                                                                FromState converts a job.State into a *State.

                                                                                                                func (*State) Descriptor

                                                                                                                func (*State) Descriptor() ([]byte, []int)

                                                                                                                func (*State) GetState

                                                                                                                func (m *State) GetState() uint32

                                                                                                                func (*State) ProtoMessage

                                                                                                                func (*State) ProtoMessage()

                                                                                                                func (*State) Reset

                                                                                                                func (m *State) Reset()

                                                                                                                func (*State) String

                                                                                                                func (m *State) String() string

                                                                                                                func (*State) XXX_DiscardUnknown

                                                                                                                func (m *State) XXX_DiscardUnknown()

                                                                                                                func (*State) XXX_Marshal

                                                                                                                func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                                func (*State) XXX_Merge

                                                                                                                func (m *State) XXX_Merge(src proto.Message)

                                                                                                                func (*State) XXX_Size

                                                                                                                func (m *State) XXX_Size() int

                                                                                                                func (*State) XXX_Unmarshal

                                                                                                                func (m *State) XXX_Unmarshal(b []byte) error

                                                                                                                type StatusResponse

                                                                                                                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:"-"`
                                                                                                                }

                                                                                                                  StatusResponse represents the status of a job

                                                                                                                  func FromStatus

                                                                                                                  func FromStatus(st job.Status) (*StatusResponse, error)

                                                                                                                    FromStatus converts a job.Status into a *StatusResponse.

                                                                                                                    func (*StatusResponse) Descriptor

                                                                                                                    func (*StatusResponse) Descriptor() ([]byte, []int)

                                                                                                                    func (*StatusResponse) GetActive

                                                                                                                    func (m *StatusResponse) GetActive() *Range

                                                                                                                    func (*StatusResponse) GetFailed

                                                                                                                    func (m *StatusResponse) GetFailed() *Range

                                                                                                                    func (*StatusResponse) GetPending

                                                                                                                    func (m *StatusResponse) GetPending() *Range

                                                                                                                    func (*StatusResponse) GetSucceeded

                                                                                                                    func (m *StatusResponse) GetSucceeded() *Range

                                                                                                                    func (*StatusResponse) ProtoMessage

                                                                                                                    func (*StatusResponse) ProtoMessage()

                                                                                                                    func (*StatusResponse) Reset

                                                                                                                    func (m *StatusResponse) Reset()

                                                                                                                    func (*StatusResponse) String

                                                                                                                    func (m *StatusResponse) String() string

                                                                                                                    func (*StatusResponse) XXX_DiscardUnknown

                                                                                                                    func (m *StatusResponse) XXX_DiscardUnknown()

                                                                                                                    func (*StatusResponse) XXX_Marshal

                                                                                                                    func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                                    func (*StatusResponse) XXX_Merge

                                                                                                                    func (m *StatusResponse) XXX_Merge(src proto.Message)

                                                                                                                    func (*StatusResponse) XXX_Size

                                                                                                                    func (m *StatusResponse) XXX_Size() int

                                                                                                                    func (*StatusResponse) XXX_Unmarshal

                                                                                                                    func (m *StatusResponse) XXX_Unmarshal(b []byte) error

                                                                                                                    type Task

                                                                                                                    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:"-"`
                                                                                                                    }

                                                                                                                      Task represents a task

                                                                                                                      func FromTask

                                                                                                                      func FromTask(t job.Task) (*Task, error)

                                                                                                                        FromTask converts a job.Task into a *Task.

                                                                                                                        func (*Task) Descriptor

                                                                                                                        func (*Task) Descriptor() ([]byte, []int)

                                                                                                                        func (*Task) GetDeadline

                                                                                                                        func (m *Task) GetDeadline() *timestamp.Timestamp

                                                                                                                        func (*Task) GetFailures

                                                                                                                        func (m *Task) GetFailures() int64

                                                                                                                        func (*Task) GetId

                                                                                                                        func (m *Task) GetId() *TaskID

                                                                                                                        func (*Task) GetJobId

                                                                                                                        func (m *Task) GetJobId() *ID

                                                                                                                        func (*Task) GetManifest

                                                                                                                        func (m *Task) GetManifest() *Manifest

                                                                                                                        func (*Task) GetMetadata

                                                                                                                        func (m *Task) GetMetadata() *Metadata

                                                                                                                        func (*Task) GetName

                                                                                                                        func (m *Task) GetName() string

                                                                                                                        func (*Task) GetPriority

                                                                                                                        func (m *Task) GetPriority() *Priority

                                                                                                                        func (*Task) GetScript

                                                                                                                        func (m *Task) GetScript() string

                                                                                                                        func (*Task) GetValue

                                                                                                                        func (m *Task) GetValue() int64

                                                                                                                        func (*Task) GetWorkingDir

                                                                                                                        func (m *Task) GetWorkingDir() string

                                                                                                                        func (*Task) ProtoMessage

                                                                                                                        func (*Task) ProtoMessage()

                                                                                                                        func (*Task) Reset

                                                                                                                        func (m *Task) Reset()

                                                                                                                        func (*Task) String

                                                                                                                        func (m *Task) String() string

                                                                                                                        func (*Task) XXX_DiscardUnknown

                                                                                                                        func (m *Task) XXX_DiscardUnknown()

                                                                                                                        func (*Task) XXX_Marshal

                                                                                                                        func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                                        func (*Task) XXX_Merge

                                                                                                                        func (m *Task) XXX_Merge(src proto.Message)

                                                                                                                        func (*Task) XXX_Size

                                                                                                                        func (m *Task) XXX_Size() int

                                                                                                                        func (*Task) XXX_Unmarshal

                                                                                                                        func (m *Task) XXX_Unmarshal(b []byte) error

                                                                                                                        type TaskID

                                                                                                                        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:"-"`
                                                                                                                        }

                                                                                                                          TaskID represents a unique identifies for a task

                                                                                                                          func FromTaskID

                                                                                                                          func FromTaskID(t job.TaskID) *TaskID

                                                                                                                            FromTaskID converts a job.TaskID into a *TaskID.

                                                                                                                            func (*TaskID) Descriptor

                                                                                                                            func (*TaskID) Descriptor() ([]byte, []int)

                                                                                                                            func (*TaskID) GetId

                                                                                                                            func (m *TaskID) GetId() string

                                                                                                                            func (*TaskID) ProtoMessage

                                                                                                                            func (*TaskID) ProtoMessage()

                                                                                                                            func (*TaskID) Reset

                                                                                                                            func (m *TaskID) Reset()

                                                                                                                            func (*TaskID) String

                                                                                                                            func (m *TaskID) String() string

                                                                                                                            func (*TaskID) XXX_DiscardUnknown

                                                                                                                            func (m *TaskID) XXX_DiscardUnknown()

                                                                                                                            func (*TaskID) XXX_Marshal

                                                                                                                            func (m *TaskID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                                            func (*TaskID) XXX_Merge

                                                                                                                            func (m *TaskID) XXX_Merge(src proto.Message)

                                                                                                                            func (*TaskID) XXX_Size

                                                                                                                            func (m *TaskID) XXX_Size() int

                                                                                                                            func (*TaskID) XXX_Unmarshal

                                                                                                                            func (m *TaskID) XXX_Unmarshal(b []byte) error

                                                                                                                            type UnimplementedJobdServer

                                                                                                                            type UnimplementedJobdServer struct {
                                                                                                                            }

                                                                                                                              UnimplementedJobdServer can be embedded to have forward compatible implementations.

                                                                                                                              func (*UnimplementedJobdServer) Delete

                                                                                                                              func (*UnimplementedJobdServer) Delete(ctx context.Context, req *ID) (*empty.Empty, error)

                                                                                                                              func (*UnimplementedJobdServer) Describe

                                                                                                                              func (*UnimplementedJobdServer) Describe(ctx context.Context, req *ID) (*Specification, error)

                                                                                                                              func (*UnimplementedJobdServer) Download

                                                                                                                              func (*UnimplementedJobdServer) Error

                                                                                                                              func (*UnimplementedJobdServer) Execute

                                                                                                                              func (*UnimplementedJobdServer) Execute(ctx context.Context, req *Task) (*empty.Empty, error)

                                                                                                                              func (*UnimplementedJobdServer) Fatal

                                                                                                                              func (*UnimplementedJobdServer) Heartbeat

                                                                                                                              func (*UnimplementedJobdServer) Info

                                                                                                                              func (*UnimplementedJobdServer) List

                                                                                                                              func (*UnimplementedJobdServer) ListWithPriority

                                                                                                                              func (*UnimplementedJobdServer) ListWithPriority(ctx context.Context, req *Priority) (*ListResponse, error)

                                                                                                                              func (*UnimplementedJobdServer) Next

                                                                                                                              func (*UnimplementedJobdServer) Requeue

                                                                                                                              func (*UnimplementedJobdServer) Requeue(ctx context.Context, req *Task) (*empty.Empty, error)

                                                                                                                              func (*UnimplementedJobdServer) Status

                                                                                                                              func (*UnimplementedJobdServer) Submit

                                                                                                                              func (*UnimplementedJobdServer) Success

                                                                                                                              func (*UnimplementedJobdServer) Success(ctx context.Context, req *Task) (*empty.Empty, error)

                                                                                                                              func (*UnimplementedJobdServer) Upload

                                                                                                                              type WorkerMetadata

                                                                                                                              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:"-"`
                                                                                                                              }

                                                                                                                                WorkerMetadata is an application name and a hostname.

                                                                                                                                func FromWorkerMetadata

                                                                                                                                func FromWorkerMetadata(mt job.Metadata) (*WorkerMetadata, error)

                                                                                                                                  FromWorkerMetadata converts a job.Metadata to a *WorkerMetadata.

                                                                                                                                  func (*WorkerMetadata) Descriptor

                                                                                                                                  func (*WorkerMetadata) Descriptor() ([]byte, []int)

                                                                                                                                  func (*WorkerMetadata) GetAppName

                                                                                                                                  func (m *WorkerMetadata) GetAppName() string

                                                                                                                                  func (*WorkerMetadata) GetHostname

                                                                                                                                  func (m *WorkerMetadata) GetHostname() string

                                                                                                                                  func (*WorkerMetadata) ProtoMessage

                                                                                                                                  func (*WorkerMetadata) ProtoMessage()

                                                                                                                                  func (*WorkerMetadata) Reset

                                                                                                                                  func (m *WorkerMetadata) Reset()

                                                                                                                                  func (*WorkerMetadata) String

                                                                                                                                  func (m *WorkerMetadata) String() string

                                                                                                                                  func (*WorkerMetadata) XXX_DiscardUnknown

                                                                                                                                  func (m *WorkerMetadata) XXX_DiscardUnknown()

                                                                                                                                  func (*WorkerMetadata) XXX_Marshal

                                                                                                                                  func (m *WorkerMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                                                  func (*WorkerMetadata) XXX_Merge

                                                                                                                                  func (m *WorkerMetadata) XXX_Merge(src proto.Message)

                                                                                                                                  func (*WorkerMetadata) XXX_Size

                                                                                                                                  func (m *WorkerMetadata) XXX_Size() int

                                                                                                                                  func (*WorkerMetadata) XXX_Unmarshal

                                                                                                                                  func (m *WorkerMetadata) XXX_Unmarshal(b []byte) error