worker

Jul 7, 2017

Changes in this version

+ var ErrIntOverflowWorkerService = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthWorkerService = fmt.Errorf("proto: negative length found during unmarshaling")

type APIServer

+ func NewAPIServer(pachClient *client.APIClient, etcdClient *etcd.Client, etcdPrefix string, ...) (*APIServer, error)

type CancelRequest

+ func (m *CancelRequest) Marshal() (dAtA []byte, err error)

+ func (m *CancelRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CancelRequest) Size() (n int)

+ func (m *CancelRequest) Unmarshal(dAtA []byte) error

type CancelResponse

+ func (m *CancelResponse) Marshal() (dAtA []byte, err error)

+ func (m *CancelResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CancelResponse) Size() (n int)

+ func (m *CancelResponse) Unmarshal(dAtA []byte) error

type Input

+ func (m *Input) Marshal() (dAtA []byte, err error)

+ func (m *Input) MarshalTo(dAtA []byte) (int, error)

+ func (m *Input) Size() (n int)

+ func (m *Input) Unmarshal(dAtA []byte) error

type ProcessRequest

+ func (m *ProcessRequest) Marshal() (dAtA []byte, err error)

+ func (m *ProcessRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProcessRequest) Size() (n int)

+ func (m *ProcessRequest) Unmarshal(dAtA []byte) error

type ProcessResponse

+ func (m *ProcessResponse) Marshal() (dAtA []byte, err error)

+ func (m *ProcessResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProcessResponse) Size() (n int)

+ func (m *ProcessResponse) Unmarshal(dAtA []byte) error

Jun 14, 2017

Changes in this version

+ func HashDatum(pipelineInfo *pps.PipelineInfo, data []*Input) (string, error)

type Input

+ Branch string

+ ParentCommit *pfs.Commit

+ func (m *Input) GetBranch() string

+ func (m *Input) GetParentCommit() *pfs.Commit

type ProcessRequest

+ ParentOutput *pfs.Tag

+ func (m *ProcessRequest) GetParentOutput() *pfs.Tag

May 5, 2017

Changes in this version

type Input

+ FileInfo *pfs.FileInfo

+ func (*Input) Descriptor() ([]byte, []int)

+ func (*Input) ProtoMessage()

+ func (m *Input) GetFileInfo() *pfs.FileInfo

+ func (m *Input) GetLazy() bool

+ func (m *Input) GetName() string

+ func (m *Input) Reset()

+ func (m *Input) String() string

Apr 15, 2017

Changes in this version

+ func MatchDatum(filter []string, data []*pps.Datum) bool

type APIServer

+ func (a *APIServer) Cancel(ctx context.Context, request *CancelRequest) (*CancelResponse, error)

+ func (a *APIServer) Status(ctx context.Context, _ *types.Empty) (*pps.WorkerStatus, error)

+ type CancelRequest struct

+ DataFilters []string

+ JobID string

+ func (*CancelRequest) Descriptor() ([]byte, []int)

+ func (*CancelRequest) ProtoMessage()

+ func (m *CancelRequest) GetDataFilters() []string

+ func (m *CancelRequest) GetJobID() string

+ func (m *CancelRequest) Reset()

+ func (m *CancelRequest) String() string

+ type CancelResponse struct

+ Success bool

+ func (*CancelResponse) Descriptor() ([]byte, []int)

+ func (*CancelResponse) ProtoMessage()

+ func (m *CancelResponse) GetSuccess() bool

+ func (m *CancelResponse) Reset()

+ func (m *CancelResponse) String() string

type WorkerClient

+ Cancel func(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*CancelResponse, error)

+ Status func(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*pps.WorkerStatus, error)

type WorkerServer

+ Cancel func(context.Context, *CancelRequest) (*CancelResponse, error)

+ Status func(context.Context, *google_protobuf.Empty) (*pps.WorkerStatus, error)

Apr 7, 2017

Changes in this version

type ProcessResponse

+ Failed bool

+ func (m *ProcessResponse) GetFailed() bool

Mar 29, 2017

Changes in this version

+ func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

+ type APIServer struct

+ func NewJobAPIServer(pachClient *client.APIClient, jobInfo *pps.JobInfo, workerName string) *APIServer

+ func NewPipelineAPIServer(pachClient *client.APIClient, pipelineInfo *pps.PipelineInfo, ...) *APIServer

+ func (a *APIServer) HashDatum(data []*pfs.FileInfo) (string, error)

+ func (a *APIServer) Process(ctx context.Context, req *ProcessRequest) (resp *ProcessResponse, retErr error)

+ type Input struct

+ Lazy bool

+ Name string

+ type ProcessRequest struct

+ Data []*pfs.FileInfo

+ JobID string

+ func (*ProcessRequest) Descriptor() ([]byte, []int)

+ func (*ProcessRequest) ProtoMessage()

+ func (m *ProcessRequest) GetData() []*pfs.FileInfo

+ func (m *ProcessRequest) GetJobID() string

+ func (m *ProcessRequest) Reset()

+ func (m *ProcessRequest) String() string

+ type ProcessResponse struct

+ Log string

+ Tag *pfs.Tag

+ func (*ProcessResponse) Descriptor() ([]byte, []int)

+ func (*ProcessResponse) ProtoMessage()

+ func (m *ProcessResponse) GetLog() string

+ func (m *ProcessResponse) GetTag() *pfs.Tag

+ func (m *ProcessResponse) Reset()

+ func (m *ProcessResponse) String() string

+ type WorkerClient interface

+ Process func(ctx context.Context, in *ProcessRequest, opts ...grpc.CallOption) (*ProcessResponse, error)

+ func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

+ type WorkerServer interface

+ Process func(context.Context, *ProcessRequest) (*ProcessResponse, error)