jobrpc

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2021 License: CC0-1.0, CC0-1.0, CC0-1.0 Imports: 18 Imported by: 0

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) Download(req *FilePathAndID, srv Jobd_DownloadServer) error

func (*UnimplementedJobdServer) Error 

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

func (*UnimplementedJobdServer) Execute 

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

func (*UnimplementedJobdServer) Fatal 

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

func (*UnimplementedJobdServer) Heartbeat 

func (*UnimplementedJobdServer) Heartbeat(ctx context.Context, req *Task) (*HeartbeatResponse, error)

func (*UnimplementedJobdServer) Info 

func (*UnimplementedJobdServer) Info(ctx context.Context, req *IDAndValue) (*InfoResponse, error)

func (*UnimplementedJobdServer) List 

func (*UnimplementedJobdServer) List(ctx context.Context, req *empty.Empty) (*ListResponse, error)

func (*UnimplementedJobdServer) ListWithPriority 

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

func (*UnimplementedJobdServer) Next 

func (*UnimplementedJobdServer) Next(ctx context.Context, req *WorkerMetadata) (*Task, error)

func (*UnimplementedJobdServer) Requeue 

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

func (*UnimplementedJobdServer) Status 

func (*UnimplementedJobdServer) Status(ctx context.Context, req *ID) (*StatusResponse, error)

func (*UnimplementedJobdServer) Submit 

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

func (*UnimplementedJobdServer) Success 

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

func (*UnimplementedJobdServer) Upload 

func (*UnimplementedJobdServer) Upload(srv Jobd_UploadServer) error

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.