pps

Feb 27, 2018

Changes in this version

+ func DescribeSyntaxError(originalErr error, parsedBuffer bytes.Buffer) error

+ func PipelineReqFromInfo(pipelineInfo *ppsclient.PipelineInfo) *ppsclient.CreatePipelineRequest

+ type PipelineManifestReader struct

+ func NewPipelineManifestReader(path string) (result *PipelineManifestReader, retErr error)

+ func (r *PipelineManifestReader) NextCreatePipelineRequest() (*ppsclient.CreatePipelineRequest, error)

Jul 7, 2017

Changes in this version

+ func GetExpectedNumWorkers(kubeClient *kube.Client, spec *ppsclient.ParallelismSpec) (int, error)

+ func PipelineRcName(name string, version uint64) string

Mar 1, 2017

Changes in this version

+ const JobDataPath

Feb 9, 2017

Changes in this version

type ContinuePodRequest

+ func (m *ContinuePodRequest) GetChunkID() string

+ func (m *ContinuePodRequest) GetPodName() string

type ContinuePodResponse

+ func (m *ContinuePodResponse) GetRestart() bool

type FinishPodRequest

+ func (m *FinishPodRequest) GetChunkID() string

+ func (m *FinishPodRequest) GetPodName() string

+ func (m *FinishPodRequest) GetSuccess() bool

type FinishPodResponse

+ func (m *FinishPodResponse) GetRestart() bool

type StartPodRequest

+ func (m *StartPodRequest) GetPodName() string

type StartPodResponse

+ func (m *StartPodResponse) GetChunkID() string

Dec 1, 2016

Changes in this version

type ContinuePodResponse

+ Restart bool

type FinishPodResponse

+ Restart bool

Nov 23, 2016

Changes in this version

+ func RegisterInternalPodAPIServer(s *grpc.Server, srv InternalPodAPIServer)

+ type ContinuePodRequest struct

+ ChunkID string

+ PodName string

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

+ func (*ContinuePodRequest) ProtoMessage()

+ func (m *ContinuePodRequest) Reset()

+ func (m *ContinuePodRequest) String() string

+ type ContinuePodResponse struct

+ Exit bool

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

+ func (*ContinuePodResponse) ProtoMessage()

+ func (m *ContinuePodResponse) Reset()

+ func (m *ContinuePodResponse) String() string

+ type FinishPodRequest struct

+ ChunkID string

+ PodName string

+ Success bool

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

+ func (*FinishPodRequest) ProtoMessage()

+ func (m *FinishPodRequest) Reset()

+ func (m *FinishPodRequest) String() string

+ type FinishPodResponse struct

+ Fail bool

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

+ func (*FinishPodResponse) ProtoMessage()

+ func (m *FinishPodResponse) Reset()

+ func (m *FinishPodResponse) String() string

+ type InternalPodAPIClient interface

+ ContinuePod func(ctx context.Context, in *ContinuePodRequest, opts ...grpc.CallOption) (*ContinuePodResponse, error)

+ FinishPod func(ctx context.Context, in *FinishPodRequest, opts ...grpc.CallOption) (*FinishPodResponse, error)

+ StartPod func(ctx context.Context, in *StartPodRequest, opts ...grpc.CallOption) (*StartPodResponse, error)

+ func NewInternalPodAPIClient(cc *grpc.ClientConn) InternalPodAPIClient

+ func NewInternalPodAPIClientFromAddress(pachAddr string) (InternalPodAPIClient, error)

+ type InternalPodAPIServer interface

+ ContinuePod func(context.Context, *ContinuePodRequest) (*ContinuePodResponse, error)

+ FinishPod func(context.Context, *FinishPodRequest) (*FinishPodResponse, error)

+ StartPod func(context.Context, *StartPodRequest) (*StartPodResponse, error)

+ type StartPodRequest struct

+ Job *pps1.Job

+ PodName string

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

+ func (*StartPodRequest) ProtoMessage()

+ func (m *StartPodRequest) GetJob() *pps1.Job

+ func (m *StartPodRequest) Reset()

+ func (m *StartPodRequest) String() string

+ type StartPodResponse struct

+ ChunkID string

+ CommitMounts []*fuse.CommitMount

+ Transform *pps1.Transform

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

+ func (*StartPodResponse) ProtoMessage()

+ func (m *StartPodResponse) GetCommitMounts() []*fuse.CommitMount

+ func (m *StartPodResponse) GetTransform() *pps1.Transform

+ func (m *StartPodResponse) Reset()

+ func (m *StartPodResponse) String() string

Sep 23, 2016

Changes in this version

type FinishJobRequest

+ PodIndex uint64

type StartJobResponse

+ PodIndex uint64

Apr 11, 2016

Changes in this version

type FinishJobRequest

+ Index uint64

type StartJobResponse

+ Index uint64

+ OutputCommit *pfs.Commit

+ func (m *StartJobResponse) GetOutputCommit() *pfs.Commit

Jun 28, 2016

Changes in this version

+ func JobRepo(job *ppsclient.Job) *pfs.Repo

+ func PipelineRepo(pipeline *ppsclient.Pipeline) *pfs.Repo

+ func RegisterInternalJobAPIServer(s *grpc.Server, srv InternalJobAPIServer)

+ type FinishJobRequest struct

+ Job *pachyderm_pps.Job

+ Success bool

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

+ func (*FinishJobRequest) ProtoMessage()

+ func (m *FinishJobRequest) GetJob() *pachyderm_pps.Job

+ func (m *FinishJobRequest) Reset()

+ func (m *FinishJobRequest) String() string

+ type Hasher struct

+ JobModulus uint64

+ PipelineModulus uint64

+ func NewHasher(jobModulus uint64, pipelineModulus uint64) *Hasher

+ func (s *Hasher) HashJob(job *ppsclient.Job) uint64

+ func (s *Hasher) HashPipeline(pipeline *ppsclient.Pipeline) uint64

+ type InternalJobAPIClient interface

+ FinishJob func(ctx context.Context, in *FinishJobRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ StartJob func(ctx context.Context, in *StartJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error)

+ func NewInternalJobAPIClient(cc *grpc.ClientConn) InternalJobAPIClient

+ func NewInternalJobAPIClientFromAddress(pachAddr string) (InternalJobAPIClient, error)

+ type InternalJobAPIServer interface

+ FinishJob func(context.Context, *FinishJobRequest) (*google_protobuf.Empty, error)

+ StartJob func(context.Context, *StartJobRequest) (*StartJobResponse, error)

+ type StartJobRequest struct

+ Job *pachyderm_pps.Job

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

+ func (*StartJobRequest) ProtoMessage()

+ func (m *StartJobRequest) GetJob() *pachyderm_pps.Job

+ func (m *StartJobRequest) Reset()

+ func (m *StartJobRequest) String() string

+ type StartJobResponse struct

+ CommitMounts []*fuse.CommitMount

+ Transform *pachyderm_pps.Transform

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

+ func (*StartJobResponse) ProtoMessage()

+ func (m *StartJobResponse) GetCommitMounts() []*fuse.CommitMount

+ func (m *StartJobResponse) GetTransform() *pachyderm_pps.Transform

+ func (m *StartJobResponse) Reset()

+ func (m *StartJobResponse) String() string