Versions in this module Expand all Collapse all v0 v0.0.2 Apr 15, 2021 Changes in this version + func RegisterJobdServer(s *grpc.Server, srv JobdServer) + func ToBoolean(hr *HeartbeatResponse) (bool, error) + func ToDirPath(dp *DirPath) (string, error) + func ToFilePath(fp *FilePath) (string, error) + func ToFilePathAndID(fi *FilePathAndID) (string, job.ID, error) + func ToID(id *ID) (job.ID, error) + func ToIDAndValue(iv *IDAndValue) (job.ID, int64, error) + func ToIDs(lr *ListResponse) ([]job.ID, error) + func ToInfo(ir *InfoResponse) (job.Info, error) + func ToManifest(M *Manifest) (job.Manifest, error) + func ToMetadata(mt *Metadata) (map[string]string, error) + func ToPriority(pr *Priority) (job.Priority, error) + func ToRange(R *Range) (irange.Range, error) + func ToSpecification(spec *Specification) (*job.Specification, error) + func ToState(st *State) (job.State, error) + func ToStatus(sr *StatusResponse) (job.Status, error) + func ToTask(t *Task) (job.Task, error) + func ToTaskID(id *TaskID) (job.TaskID, error) + func ToWorkerMetadata(wm *WorkerMetadata) (job.Metadata, error) + type DirPath struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromDirPath(p string) *DirPath + func (*DirPath) Descriptor() ([]byte, []int) + func (*DirPath) ProtoMessage() + func (m *DirPath) GetPath() string + func (m *DirPath) Reset() + func (m *DirPath) String() string + func (m *DirPath) XXX_DiscardUnknown() + func (m *DirPath) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DirPath) XXX_Merge(src proto.Message) + func (m *DirPath) XXX_Size() int + func (m *DirPath) XXX_Unmarshal(b []byte) error + type FileChunk struct + Chunk isFileChunk_Chunk + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FileChunkFromData(b []byte) *FileChunk + func FileChunkFromPathAndID(path string, id job.ID) *FileChunk + func (*FileChunk) Descriptor() ([]byte, []int) + func (*FileChunk) ProtoMessage() + func (*FileChunk) XXX_OneofWrappers() []interface{} + func (m *FileChunk) GetChunk() isFileChunk_Chunk + func (m *FileChunk) GetData() []byte + func (m *FileChunk) GetPathId() *FilePathAndID + func (m *FileChunk) Reset() + func (m *FileChunk) String() string + func (m *FileChunk) XXX_DiscardUnknown() + func (m *FileChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FileChunk) XXX_Merge(src proto.Message) + func (m *FileChunk) XXX_Size() int + func (m *FileChunk) XXX_Unmarshal(b []byte) error + type FileChunk_Data struct + Data []byte + type FileChunk_PathId struct + PathId *FilePathAndID + type FileOrDirectory struct + Path isFileOrDirectory_Path + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FileOrDirectory) Descriptor() ([]byte, []int) + func (*FileOrDirectory) ProtoMessage() + func (*FileOrDirectory) XXX_OneofWrappers() []interface{} + func (m *FileOrDirectory) GetDir() *DirPath + func (m *FileOrDirectory) GetFile() *FilePath + func (m *FileOrDirectory) GetPath() isFileOrDirectory_Path + func (m *FileOrDirectory) Reset() + func (m *FileOrDirectory) String() string + func (m *FileOrDirectory) XXX_DiscardUnknown() + func (m *FileOrDirectory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FileOrDirectory) XXX_Merge(src proto.Message) + func (m *FileOrDirectory) XXX_Size() int + func (m *FileOrDirectory) XXX_Unmarshal(b []byte) error + type FileOrDirectory_Dir struct + Dir *DirPath + type FileOrDirectory_File struct + File *FilePath + type FilePath struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromFilePath(p string) *FilePath + func (*FilePath) Descriptor() ([]byte, []int) + func (*FilePath) ProtoMessage() + func (m *FilePath) GetPath() string + func (m *FilePath) Reset() + func (m *FilePath) String() string + func (m *FilePath) XXX_DiscardUnknown() + func (m *FilePath) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FilePath) XXX_Merge(src proto.Message) + func (m *FilePath) XXX_Size() int + func (m *FilePath) XXX_Unmarshal(b []byte) error + type FilePathAndID struct + Id *ID + Path *FilePath + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromFilePathAndID(p string, id job.ID) *FilePathAndID + func (*FilePathAndID) Descriptor() ([]byte, []int) + func (*FilePathAndID) ProtoMessage() + func (m *FilePathAndID) GetId() *ID + func (m *FilePathAndID) GetPath() *FilePath + func (m *FilePathAndID) Reset() + func (m *FilePathAndID) String() string + func (m *FilePathAndID) XXX_DiscardUnknown() + func (m *FilePathAndID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FilePathAndID) XXX_Merge(src proto.Message) + func (m *FilePathAndID) XXX_Size() int + func (m *FilePathAndID) XXX_Unmarshal(b []byte) error + type HeartbeatResponse struct + CarryOn bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromBoolean(b bool) *HeartbeatResponse + func (*HeartbeatResponse) Descriptor() ([]byte, []int) + func (*HeartbeatResponse) ProtoMessage() + func (m *HeartbeatResponse) GetCarryOn() bool + func (m *HeartbeatResponse) Reset() + func (m *HeartbeatResponse) String() string + func (m *HeartbeatResponse) XXX_DiscardUnknown() + func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HeartbeatResponse) XXX_Merge(src proto.Message) + func (m *HeartbeatResponse) XXX_Size() int + func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error + type ID struct + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromID(j job.ID) *ID + func (*ID) Descriptor() ([]byte, []int) + func (*ID) ProtoMessage() + func (m *ID) GetId() string + func (m *ID) Reset() + func (m *ID) String() string + func (m *ID) XXX_DiscardUnknown() + func (m *ID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ID) XXX_Merge(src proto.Message) + func (m *ID) XXX_Size() int + func (m *ID) XXX_Unmarshal(b []byte) error + type IDAndValue struct + Id *ID + Value int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromIDAndValue(id job.ID, n int64) *IDAndValue + func (*IDAndValue) Descriptor() ([]byte, []int) + func (*IDAndValue) ProtoMessage() + func (m *IDAndValue) GetId() *ID + func (m *IDAndValue) GetValue() int64 + func (m *IDAndValue) Reset() + func (m *IDAndValue) String() string + func (m *IDAndValue) XXX_DiscardUnknown() + func (m *IDAndValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IDAndValue) XXX_Merge(src proto.Message) + func (m *IDAndValue) XXX_Size() int + func (m *IDAndValue) XXX_Unmarshal(b []byte) error + type InfoResponse struct + AppName string + Deadline *timestamp.Timestamp + Failures int64 + Hostname string + Start *timestamp.Timestamp + State *State + Value int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromInfo(inf job.Info) (*InfoResponse, error) + func (*InfoResponse) Descriptor() ([]byte, []int) + func (*InfoResponse) ProtoMessage() + func (m *InfoResponse) GetAppName() string + func (m *InfoResponse) GetDeadline() *timestamp.Timestamp + func (m *InfoResponse) GetFailures() int64 + func (m *InfoResponse) GetHostname() string + func (m *InfoResponse) GetStart() *timestamp.Timestamp + func (m *InfoResponse) GetState() *State + func (m *InfoResponse) GetValue() int64 + func (m *InfoResponse) Reset() + func (m *InfoResponse) String() string + func (m *InfoResponse) XXX_DiscardUnknown() + func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InfoResponse) XXX_Merge(src proto.Message) + func (m *InfoResponse) XXX_Size() int + func (m *InfoResponse) XXX_Unmarshal(b []byte) error + type JobdClient interface + Delete func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*empty.Empty, error) + Describe func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Specification, error) + Download func(ctx context.Context, in *FilePathAndID, opts ...grpc.CallOption) (Jobd_DownloadClient, error) + Error func(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error) + Execute func(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error) + Fatal func(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error) + Heartbeat func(ctx context.Context, in *Task, opts ...grpc.CallOption) (*HeartbeatResponse, error) + Info func(ctx context.Context, in *IDAndValue, opts ...grpc.CallOption) (*InfoResponse, error) + List func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListResponse, error) + ListWithPriority func(ctx context.Context, in *Priority, opts ...grpc.CallOption) (*ListResponse, error) + Next func(ctx context.Context, in *WorkerMetadata, opts ...grpc.CallOption) (*Task, error) + Requeue func(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error) + Status func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*StatusResponse, error) + Submit func(ctx context.Context, in *Specification, opts ...grpc.CallOption) (*ID, error) + Success func(ctx context.Context, in *Task, opts ...grpc.CallOption) (*empty.Empty, error) + Upload func(ctx context.Context, opts ...grpc.CallOption) (Jobd_UploadClient, error) + func NewJobdClient(cc *grpc.ClientConn) JobdClient + type JobdServer interface + Delete func(context.Context, *ID) (*empty.Empty, error) + Describe func(context.Context, *ID) (*Specification, error) + Download func(*FilePathAndID, Jobd_DownloadServer) error + Error func(context.Context, *Task) (*empty.Empty, error) + Execute func(context.Context, *Task) (*empty.Empty, error) + Fatal func(context.Context, *Task) (*empty.Empty, error) + Heartbeat func(context.Context, *Task) (*HeartbeatResponse, error) + Info func(context.Context, *IDAndValue) (*InfoResponse, error) + List func(context.Context, *empty.Empty) (*ListResponse, error) + ListWithPriority func(context.Context, *Priority) (*ListResponse, error) + Next func(context.Context, *WorkerMetadata) (*Task, error) + Requeue func(context.Context, *Task) (*empty.Empty, error) + Status func(context.Context, *ID) (*StatusResponse, error) + Submit func(context.Context, *Specification) (*ID, error) + Success func(context.Context, *Task) (*empty.Empty, error) + Upload func(Jobd_UploadServer) error + type Jobd_DownloadClient interface + Recv func() (*FileChunk, error) + type Jobd_DownloadServer interface + Send func(*FileChunk) error + type Jobd_UploadClient interface + CloseAndRecv func() (*empty.Empty, error) + Send func(*FileChunk) error + type Jobd_UploadServer interface + Recv func() (*FileChunk, error) + SendAndClose func(*empty.Empty) error + type ListResponse struct + Ids []*ID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromIDs(ids []job.ID) (*ListResponse, error) + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (m *ListResponse) GetIds() []*ID + func (m *ListResponse) Reset() + func (m *ListResponse) String() string + func (m *ListResponse) XXX_DiscardUnknown() + func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResponse) XXX_Merge(src proto.Message) + func (m *ListResponse) XXX_Size() int + func (m *ListResponse) XXX_Unmarshal(b []byte) error + type Manifest struct + Paths []*FileOrDirectory + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromManifest(M job.Manifest) *Manifest + func (*Manifest) Descriptor() ([]byte, []int) + func (*Manifest) ProtoMessage() + func (m *Manifest) GetPaths() []*FileOrDirectory + func (m *Manifest) Reset() + func (m *Manifest) String() string + func (m *Manifest) XXX_DiscardUnknown() + func (m *Manifest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Manifest) XXX_Merge(src proto.Message) + func (m *Manifest) XXX_Size() int + func (m *Manifest) XXX_Unmarshal(b []byte) error + type Metadata struct + Json string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromMetadata(m map[string]string) (*Metadata, error) + func (*Metadata) Descriptor() ([]byte, []int) + func (*Metadata) ProtoMessage() + func (m *Metadata) GetJson() string + func (m *Metadata) Reset() + func (m *Metadata) String() string + func (m *Metadata) XXX_DiscardUnknown() + func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Metadata) XXX_Merge(src proto.Message) + func (m *Metadata) XXX_Size() int + func (m *Metadata) XXX_Unmarshal(b []byte) error + type Priority struct + Priority uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromPriority(p job.Priority) *Priority + func (*Priority) Descriptor() ([]byte, []int) + func (*Priority) ProtoMessage() + func (m *Priority) GetPriority() uint32 + func (m *Priority) Reset() + func (m *Priority) String() string + func (m *Priority) XXX_DiscardUnknown() + func (m *Priority) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Priority) XXX_Merge(src proto.Message) + func (m *Priority) XXX_Size() int + func (m *Priority) XXX_Unmarshal(b []byte) error + type Range struct + Range string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromRange(R irange.Range) *Range + func (*Range) Descriptor() ([]byte, []int) + func (*Range) ProtoMessage() + func (m *Range) GetRange() string + func (m *Range) Reset() + func (m *Range) String() string + func (m *Range) XXX_DiscardUnknown() + func (m *Range) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Range) XXX_Merge(src proto.Message) + func (m *Range) XXX_Size() int + func (m *Range) XXX_Unmarshal(b []byte) error + type RangeMetadata struct + AppName string + Hostname string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RangeMetadata) Descriptor() ([]byte, []int) + func (*RangeMetadata) ProtoMessage() + func (m *RangeMetadata) GetAppName() string + func (m *RangeMetadata) GetHostname() string + func (m *RangeMetadata) Reset() + func (m *RangeMetadata) String() string + func (m *RangeMetadata) XXX_DiscardUnknown() + func (m *RangeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RangeMetadata) XXX_Merge(src proto.Message) + func (m *RangeMetadata) XXX_Size() int + func (m *RangeMetadata) XXX_Unmarshal(b []byte) error + type Specification struct + Lifetime *duration.Duration + Manifest *Manifest + MaxConcurrency int64 + MaxRetries int64 + Metadata *Metadata + Name string + Priority *Priority + Range *Range + Script string + WorkingDir string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromSpecification(spec *job.Specification) (*Specification, error) + func (*Specification) Descriptor() ([]byte, []int) + func (*Specification) ProtoMessage() + func (m *Specification) GetLifetime() *duration.Duration + func (m *Specification) GetManifest() *Manifest + func (m *Specification) GetMaxConcurrency() int64 + func (m *Specification) GetMaxRetries() int64 + func (m *Specification) GetMetadata() *Metadata + func (m *Specification) GetName() string + func (m *Specification) GetPriority() *Priority + func (m *Specification) GetRange() *Range + func (m *Specification) GetScript() string + func (m *Specification) GetWorkingDir() string + func (m *Specification) Reset() + func (m *Specification) String() string + func (m *Specification) XXX_DiscardUnknown() + func (m *Specification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Specification) XXX_Merge(src proto.Message) + func (m *Specification) XXX_Size() int + func (m *Specification) XXX_Unmarshal(b []byte) error + type State struct + State uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromState(st job.State) *State + func (*State) Descriptor() ([]byte, []int) + func (*State) ProtoMessage() + func (m *State) GetState() uint32 + func (m *State) Reset() + func (m *State) String() string + func (m *State) XXX_DiscardUnknown() + func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *State) XXX_Merge(src proto.Message) + func (m *State) XXX_Size() int + func (m *State) XXX_Unmarshal(b []byte) error + type StatusResponse struct + Active *Range + Failed *Range + Pending *Range + Succeeded *Range + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromStatus(st job.Status) (*StatusResponse, error) + func (*StatusResponse) Descriptor() ([]byte, []int) + func (*StatusResponse) ProtoMessage() + func (m *StatusResponse) GetActive() *Range + func (m *StatusResponse) GetFailed() *Range + func (m *StatusResponse) GetPending() *Range + func (m *StatusResponse) GetSucceeded() *Range + func (m *StatusResponse) Reset() + func (m *StatusResponse) String() string + func (m *StatusResponse) XXX_DiscardUnknown() + func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatusResponse) XXX_Merge(src proto.Message) + func (m *StatusResponse) XXX_Size() int + func (m *StatusResponse) XXX_Unmarshal(b []byte) error + type Task struct + Deadline *timestamp.Timestamp + Failures int64 + Id *TaskID + JobId *ID + Manifest *Manifest + Metadata *Metadata + Name string + Priority *Priority + Script string + Value int64 + WorkingDir string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromTask(t job.Task) (*Task, error) + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (m *Task) GetDeadline() *timestamp.Timestamp + func (m *Task) GetFailures() int64 + func (m *Task) GetId() *TaskID + func (m *Task) GetJobId() *ID + func (m *Task) GetManifest() *Manifest + func (m *Task) GetMetadata() *Metadata + func (m *Task) GetName() string + func (m *Task) GetPriority() *Priority + func (m *Task) GetScript() string + func (m *Task) GetValue() int64 + func (m *Task) GetWorkingDir() string + func (m *Task) Reset() + func (m *Task) String() string + func (m *Task) XXX_DiscardUnknown() + func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Task) XXX_Merge(src proto.Message) + func (m *Task) XXX_Size() int + func (m *Task) XXX_Unmarshal(b []byte) error + type TaskID struct + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromTaskID(t job.TaskID) *TaskID + func (*TaskID) Descriptor() ([]byte, []int) + func (*TaskID) ProtoMessage() + func (m *TaskID) GetId() string + func (m *TaskID) Reset() + func (m *TaskID) String() string + func (m *TaskID) XXX_DiscardUnknown() + func (m *TaskID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaskID) XXX_Merge(src proto.Message) + func (m *TaskID) XXX_Size() int + func (m *TaskID) XXX_Unmarshal(b []byte) error + type UnimplementedJobdServer struct + func (*UnimplementedJobdServer) Delete(ctx context.Context, req *ID) (*empty.Empty, error) + func (*UnimplementedJobdServer) Describe(ctx context.Context, req *ID) (*Specification, error) + func (*UnimplementedJobdServer) Download(req *FilePathAndID, srv Jobd_DownloadServer) error + func (*UnimplementedJobdServer) Error(ctx context.Context, req *Task) (*empty.Empty, error) + func (*UnimplementedJobdServer) Execute(ctx context.Context, req *Task) (*empty.Empty, error) + func (*UnimplementedJobdServer) Fatal(ctx context.Context, req *Task) (*empty.Empty, error) + func (*UnimplementedJobdServer) Heartbeat(ctx context.Context, req *Task) (*HeartbeatResponse, error) + func (*UnimplementedJobdServer) Info(ctx context.Context, req *IDAndValue) (*InfoResponse, error) + func (*UnimplementedJobdServer) List(ctx context.Context, req *empty.Empty) (*ListResponse, error) + func (*UnimplementedJobdServer) ListWithPriority(ctx context.Context, req *Priority) (*ListResponse, error) + func (*UnimplementedJobdServer) Next(ctx context.Context, req *WorkerMetadata) (*Task, error) + func (*UnimplementedJobdServer) Requeue(ctx context.Context, req *Task) (*empty.Empty, error) + func (*UnimplementedJobdServer) Status(ctx context.Context, req *ID) (*StatusResponse, error) + func (*UnimplementedJobdServer) Submit(ctx context.Context, req *Specification) (*ID, error) + func (*UnimplementedJobdServer) Success(ctx context.Context, req *Task) (*empty.Empty, error) + func (*UnimplementedJobdServer) Upload(srv Jobd_UploadServer) error + type WorkerMetadata struct + AppName string + Hostname string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func FromWorkerMetadata(mt job.Metadata) (*WorkerMetadata, error) + func (*WorkerMetadata) Descriptor() ([]byte, []int) + func (*WorkerMetadata) ProtoMessage() + func (m *WorkerMetadata) GetAppName() string + func (m *WorkerMetadata) GetHostname() string + func (m *WorkerMetadata) Reset() + func (m *WorkerMetadata) String() string + func (m *WorkerMetadata) XXX_DiscardUnknown() + func (m *WorkerMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkerMetadata) XXX_Merge(src proto.Message) + func (m *WorkerMetadata) XXX_Size() int + func (m *WorkerMetadata) XXX_Unmarshal(b []byte) error
Go to main page