persist

Mar 7, 2017

Changes in this version

type PipelineInfo

+ Resources *pps.Resources

+ func (m *PipelineInfo) GetResources() *pps.Resources

Mar 7, 2017

Changes in this version

type JobInfo

+ Resources *pps.Resources

+ func (m *JobInfo) GetResources() *pps.Resources

Feb 16, 2017

Changes in this version

type APIClient

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

type APIServer

+ TouchPipelineInfo func(context.Context, *pps.Pipeline) (*google_protobuf.Empty, error)

Feb 9, 2017

Changes in this version

type AddOutputCommitRequest

+ func (m *AddOutputCommitRequest) GetBranch() string

+ func (m *AddOutputCommitRequest) GetJobID() string

type BlockPipelineStateRequest

+ func (m *BlockPipelineStateRequest) GetPipelineName() string

+ func (m *BlockPipelineStateRequest) GetState() pps.PipelineState

type Chunk

+ func (m *Chunk) GetID() string

+ func (m *Chunk) GetIndex() uint64

+ func (m *Chunk) GetJobID() string

+ func (m *Chunk) GetLeaseTime() uint64

+ func (m *Chunk) GetModuli() []uint64

+ func (m *Chunk) GetOwner() string

+ func (m *Chunk) GetState() ChunkState

type ChunkChange

+ func (m *ChunkChange) GetReady() bool

+ func (m *ChunkChange) GetType() ChangeType

type ClaimChunkRequest

+ func (m *ClaimChunkRequest) GetJobID() string

type FinishChunkRequest

+ func (m *FinishChunkRequest) GetChunkID() string

+ func (m *FinishChunkRequest) GetPodName() string

type JobIDs

+ func (m *JobIDs) GetJobs() []string

type JobInfo

+ func (m *JobInfo) GetBranch() string

+ func (m *JobInfo) GetCommitIndex() string

+ func (m *JobInfo) GetDefaultShardModuli() []uint64

+ func (m *JobInfo) GetGc() bool

+ func (m *JobInfo) GetJobID() string

+ func (m *JobInfo) GetPipelineName() string

+ func (m *JobInfo) GetPipelineVersion() uint64

+ func (m *JobInfo) GetShard() uint64

+ func (m *JobInfo) GetState() pps.JobState

type JobInfoChange

+ func (m *JobInfoChange) GetType() ChangeType

type JobOutput

+ func (m *JobOutput) GetJobID() string

type JobState

+ func (m *JobState) GetJobID() string

+ func (m *JobState) GetState() pps.JobState

type ListGCJobsRequest

+ func (m *ListGCJobsRequest) GetPipelineName() string

type PipelineInfo

+ func (m *PipelineInfo) GetPipelineName() string

+ func (m *PipelineInfo) GetRecentError() string

+ func (m *PipelineInfo) GetShard() uint64

+ func (m *PipelineInfo) GetState() pps.PipelineState

+ func (m *PipelineInfo) GetStopped() bool

+ func (m *PipelineInfo) GetVersion() uint64

type PipelineInfoChange

+ func (m *PipelineInfoChange) GetType() ChangeType

type Pod

+ func (m *Pod) GetName() string

type RenewChunkRequest

+ func (m *RenewChunkRequest) GetChunkID() string

+ func (m *RenewChunkRequest) GetPodName() string

type RevokeChunkRequest

+ func (m *RevokeChunkRequest) GetChunkID() string

+ func (m *RevokeChunkRequest) GetMaxPods() uint64

+ func (m *RevokeChunkRequest) GetPodName() string

type Shard

+ func (m *Shard) GetNumber() uint64

type SubscribeChunksRequest

+ func (m *SubscribeChunksRequest) GetIncludeInitial() bool

type SubscribeJobInfosRequest

+ func (m *SubscribeJobInfosRequest) GetIncludeChanges() bool

+ func (m *SubscribeJobInfosRequest) GetIncludeInitial() bool

+ func (m *SubscribeJobInfosRequest) GetState() []pps.JobState

type SubscribePipelineInfosRequest

+ func (m *SubscribePipelineInfosRequest) GetIncludeInitial() bool

type UpdatePipelineStateRequest

+ func (m *UpdatePipelineStateRequest) GetPipelineName() string

+ func (m *UpdatePipelineStateRequest) GetRecentError() string

+ func (m *UpdatePipelineStateRequest) GetState() pps.PipelineState

type UpdatePipelineStoppedRequest

+ func (m *UpdatePipelineStoppedRequest) GetPipelineName() string

+ func (m *UpdatePipelineStoppedRequest) GetStopped() bool

type WaitJobResponse

+ func (m *WaitJobResponse) GetState() pps.JobState

Dec 21, 2016

Changes in this version

type JobInfo

+ Output *pps.Output

+ func (m *JobInfo) GetOutput() *pps.Output

type PipelineInfo

+ Output *pps.Output

+ func (m *PipelineInfo) GetOutput() *pps.Output

Dec 7, 2016

Changes in this version

type APIClient

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

+ ListGCJobs func(ctx context.Context, in *ListGCJobsRequest, opts ...grpc.CallOption) (*JobIDs, error)

type APIServer

+ GCJob func(context.Context, *pps.Job) (*google_protobuf.Empty, error)

+ ListGCJobs func(context.Context, *ListGCJobsRequest) (*JobIDs, error)

+ type JobIDs struct

+ Jobs []string

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

+ func (*JobIDs) ProtoMessage()

+ func (m *JobIDs) Reset()

+ func (m *JobIDs) String() string

type JobInfo

+ Gc bool

+ Service *pps.Service

+ func (m *JobInfo) GetService() *pps.Service

+ type ListGCJobsRequest struct

+ GcPolicy *pps.GCPolicy

+ PipelineName string

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

+ func (*ListGCJobsRequest) ProtoMessage()

+ func (m *ListGCJobsRequest) GetGcPolicy() *pps.GCPolicy

+ func (m *ListGCJobsRequest) Reset()

+ func (m *ListGCJobsRequest) String() string

type PipelineInfo

+ GcPolicy *pps.GCPolicy

+ func (m *PipelineInfo) GetGcPolicy() *pps.GCPolicy

Nov 23, 2016

Changes in this version

+ var ChunkState_name = map[int32]string

+ var ChunkState_value = map[string]int32

type APIClient

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

+ ClaimChunk func(ctx context.Context, in *ClaimChunkRequest, opts ...grpc.CallOption) (*Chunk, error)

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

+ FinishChunk func(ctx context.Context, in *FinishChunkRequest, opts ...grpc.CallOption) (*Chunk, error)

+ GetChunksForJob func(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*Chunks, error)

+ RenewChunk func(ctx context.Context, in *RenewChunkRequest, opts ...grpc.CallOption) (*Chunk, error)

+ RevokeChunk func(ctx context.Context, in *RevokeChunkRequest, opts ...grpc.CallOption) (*Chunk, error)

+ SubscribeChunks func(ctx context.Context, in *SubscribeChunksRequest, opts ...grpc.CallOption) (API_SubscribeChunksClient, error)

+ SubscribeJobInfos func(ctx context.Context, in *SubscribeJobInfosRequest, opts ...grpc.CallOption) (API_SubscribeJobInfosClient, error)

type APIServer

+ AddChunk func(context.Context, *AddChunkRequest) (*google_protobuf.Empty, error)

+ ClaimChunk func(context.Context, *ClaimChunkRequest) (*Chunk, error)

+ DeleteChunksForJob func(context.Context, *pps.Job) (*google_protobuf.Empty, error)

+ FinishChunk func(context.Context, *FinishChunkRequest) (*Chunk, error)

+ GetChunksForJob func(context.Context, *pps.Job) (*Chunks, error)

+ RenewChunk func(context.Context, *RenewChunkRequest) (*Chunk, error)

+ RevokeChunk func(context.Context, *RevokeChunkRequest) (*Chunk, error)

+ SubscribeChunks func(*SubscribeChunksRequest, API_SubscribeChunksServer) error

+ SubscribeJobInfos func(*SubscribeJobInfosRequest, API_SubscribeJobInfosServer) error

+ type API_SubscribeChunksClient interface

+ Recv func() (*ChunkChange, error)

+ type API_SubscribeChunksServer interface

+ Send func(*ChunkChange) error

+ type API_SubscribeJobInfosClient interface

+ Recv func() (*JobInfoChange, error)

+ type API_SubscribeJobInfosServer interface

+ Send func(*JobInfoChange) error

+ type AddChunkRequest struct

+ Chunks []*Chunk

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

+ func (*AddChunkRequest) ProtoMessage()

+ func (m *AddChunkRequest) GetChunks() []*Chunk

+ func (m *AddChunkRequest) Reset()

+ func (m *AddChunkRequest) String() string

+ type Chunk struct

+ ID string

+ Index uint64

+ JobID string

+ LeaseTime uint64

+ Moduli []uint64

+ Owner string

+ Pods []*Pod

+ State ChunkState

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

+ func (*Chunk) ProtoMessage()

+ func (m *Chunk) GetPods() []*Pod

+ func (m *Chunk) Reset()

+ func (m *Chunk) String() string

+ type ChunkChange struct

+ Chunk *Chunk

+ Ready bool

+ Type ChangeType

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

+ func (*ChunkChange) ProtoMessage()

+ func (m *ChunkChange) GetChunk() *Chunk

+ func (m *ChunkChange) Reset()

+ func (m *ChunkChange) String() string

+ type ChunkState int32

+ const ChunkState_ASSIGNED

+ const ChunkState_FAILED

+ const ChunkState_SPLITTED

+ const ChunkState_SUCCESS

+ const ChunkState_UNASSIGNED

+ func (ChunkState) EnumDescriptor() ([]byte, []int)

+ func (x ChunkState) String() string

+ type Chunks struct

+ Chunks []*Chunk

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

+ func (*Chunks) ProtoMessage()

+ func (m *Chunks) GetChunks() []*Chunk

+ func (m *Chunks) Reset()

+ func (m *Chunks) String() string

+ type ClaimChunkRequest struct

+ JobID string

+ Pod *Pod

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

+ func (*ClaimChunkRequest) ProtoMessage()

+ func (m *ClaimChunkRequest) GetPod() *Pod

+ func (m *ClaimChunkRequest) Reset()

+ func (m *ClaimChunkRequest) String() string

+ type FinishChunkRequest struct

+ ChunkID string

+ PodName string

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

+ func (*FinishChunkRequest) ProtoMessage()

+ func (m *FinishChunkRequest) Reset()

+ func (m *FinishChunkRequest) String() string

type JobInfo

+ DefaultShardModuli []uint64

+ PipelineVersion uint64

+ Shard uint64

+ type JobInfoChange struct

+ JobInfo *JobInfo

+ Type ChangeType

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

+ func (*JobInfoChange) ProtoMessage()

+ func (m *JobInfoChange) GetJobInfo() *JobInfo

+ func (m *JobInfoChange) Reset()

+ func (m *JobInfoChange) String() string

type PipelineInfo

+ Version uint64

+ type Pod struct

+ Name string

+ OutputCommit *pfs.Commit

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

+ func (*Pod) ProtoMessage()

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

+ func (m *Pod) Reset()

+ func (m *Pod) String() string

+ type RenewChunkRequest struct

+ ChunkID string

+ PodName string

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

+ func (*RenewChunkRequest) ProtoMessage()

+ func (m *RenewChunkRequest) Reset()

+ func (m *RenewChunkRequest) String() string

+ type RevokeChunkRequest struct

+ ChunkID string

+ MaxPods uint64

+ PodName string

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

+ func (*RevokeChunkRequest) ProtoMessage()

+ func (m *RevokeChunkRequest) Reset()

+ func (m *RevokeChunkRequest) String() string

+ type SubscribeChunksRequest struct

+ IncludeInitial bool

+ Job *pps.Job

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

+ func (*SubscribeChunksRequest) ProtoMessage()

+ func (m *SubscribeChunksRequest) GetJob() *pps.Job

+ func (m *SubscribeChunksRequest) Reset()

+ func (m *SubscribeChunksRequest) String() string

+ type SubscribeJobInfosRequest struct

+ IncludeChanges bool

+ IncludeInitial bool

+ Shard *Shard

+ State []pps.JobState

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

+ func (*SubscribeJobInfosRequest) ProtoMessage()

+ func (m *SubscribeJobInfosRequest) GetShard() *Shard

+ func (m *SubscribeJobInfosRequest) Reset()

+ func (m *SubscribeJobInfosRequest) String() string

+ type WaitJobResponse struct

+ State pps.JobState

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

+ func (*WaitJobResponse) ProtoMessage()

+ func (m *WaitJobResponse) Reset()

+ func (m *WaitJobResponse) String() string

Sep 23, 2016

Changes in this version

+ var ChangeType_name = map[int32]string

+ var ChangeType_value = map[string]int32

type APIClient

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

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

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

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

type APIServer

+ AddPodCommit func(context.Context, *AddPodCommitRequest) (*google_protobuf.Empty, error)

+ BlockPipelineState func(context.Context, *BlockPipelineStateRequest) (*google_protobuf.Empty, error)

+ UpdatePipelineInfo func(context.Context, *PipelineInfo) (*google_protobuf.Empty, error)

+ UpdatePipelineStopped func(context.Context, *UpdatePipelineStoppedRequest) (*google_protobuf.Empty, error)

+ type AddOutputCommitRequest struct

+ Branch string

+ Commit *pfs.Commit

+ JobID string

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

+ func (*AddOutputCommitRequest) ProtoMessage()

+ func (m *AddOutputCommitRequest) GetCommit() *pfs.Commit

+ func (m *AddOutputCommitRequest) Reset()

+ func (m *AddOutputCommitRequest) String() string

+ type AddPodCommitRequest struct

+ Commit *pfs.Commit

+ JobID string

+ PodIndex uint64

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

+ func (*AddPodCommitRequest) ProtoMessage()

+ func (m *AddPodCommitRequest) GetCommit() *pfs.Commit

+ func (m *AddPodCommitRequest) Reset()

+ func (m *AddPodCommitRequest) String() string

+ type BlockPipelineStateRequest struct

+ PipelineName string

+ State pachyderm_pps.PipelineState

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

+ func (*BlockPipelineStateRequest) ProtoMessage()

+ func (m *BlockPipelineStateRequest) Reset()

+ func (m *BlockPipelineStateRequest) String() string

+ type ChangeType int32

+ const ChangeType_CREATE

+ const ChangeType_DELETE

+ const ChangeType_UPDATE

+ func (ChangeType) EnumDescriptor() ([]byte, []int)

+ func (x ChangeType) String() string

type JobInfo

+ Branch string

+ ParallelismSpec *pachyderm_pps.ParallelismSpec

+ PodCommits map[string]*pfs.Commit

+ func (m *JobInfo) GetParallelismSpec() *pachyderm_pps.ParallelismSpec

+ func (m *JobInfo) GetPodCommits() map[string]*pfs.Commit

type PipelineInfo

+ ParallelismSpec *pachyderm_pps.ParallelismSpec

+ Stopped bool

+ func (m *PipelineInfo) GetParallelismSpec() *pachyderm_pps.ParallelismSpec

type PipelineInfoChange

+ Type ChangeType

+ type UpdatePipelineStoppedRequest struct

+ PipelineName string

+ Stopped bool

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

+ func (*UpdatePipelineStoppedRequest) ProtoMessage()

+ func (m *UpdatePipelineStoppedRequest) Reset()

+ func (m *UpdatePipelineStoppedRequest) String() string

Apr 11, 2016

Changes in this version

type APIClient

+ FailShard func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*JobInfo, error)

+ StartShard func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*JobInfo, error)

+ SucceedShard func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*JobInfo, error)

type APIServer

+ FailShard func(context.Context, *pachyderm_pps.Job) (*JobInfo, error)

+ StartShard func(context.Context, *pachyderm_pps.Job) (*JobInfo, error)

+ SucceedShard func(context.Context, *pachyderm_pps.Job) (*JobInfo, error)

type JobInfo

+ ShardsFailed uint64

+ ShardsStarted uint64

+ ShardsSucceeded uint64

Apr 11, 2016

Changes in this version

type JobInfo

+ CreatedAt *google_protobuf1.Timestamp

+ Shards uint64

+ func (m *JobInfo) GetCreatedAt() *google_protobuf1.Timestamp

type PipelineInfo

+ Shards uint64

Jun 28, 2016

Changes in this version

+ func RegisterAPIServer(s *grpc.Server, srv APIServer)

+ type APIClient interface

+ CreateJobInfo func(ctx context.Context, in *JobInfo, opts ...grpc.CallOption) (*JobInfo, error)

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

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

+ CreatePipelineInfo func(ctx context.Context, in *PipelineInfo, opts ...grpc.CallOption) (*PipelineInfo, error)

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

+ DeleteJobInfo func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ DeleteJobInfosForPipeline func(ctx context.Context, in *pachyderm_pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ DeletePipelineInfo func(ctx context.Context, in *pachyderm_pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ FailPod func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*JobInfo, error)

+ GetPipelineInfo func(ctx context.Context, in *pachyderm_pps.Pipeline, opts ...grpc.CallOption) (*PipelineInfo, error)

+ InspectJob func(ctx context.Context, in *pachyderm_pps.InspectJobRequest, ...) (*JobInfo, error)

+ ListJobInfos func(ctx context.Context, in *pachyderm_pps.ListJobRequest, opts ...grpc.CallOption) (*JobInfos, error)

+ ListPipelineInfos func(ctx context.Context, in *ListPipelineInfosRequest, opts ...grpc.CallOption) (*PipelineInfos, error)

+ StartJob func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ StartPod func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*JobInfo, error)

+ SubscribePipelineInfos func(ctx context.Context, in *SubscribePipelineInfosRequest, ...) (API_SubscribePipelineInfosClient, error)

+ SucceedPod func(ctx context.Context, in *pachyderm_pps.Job, opts ...grpc.CallOption) (*JobInfo, error)

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

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

+ CreateJobInfo func(context.Context, *JobInfo) (*JobInfo, error)

+ CreateJobOutput func(context.Context, *JobOutput) (*google_protobuf.Empty, error)

+ CreateJobState func(context.Context, *JobState) (*google_protobuf.Empty, error)

+ CreatePipelineInfo func(context.Context, *PipelineInfo) (*PipelineInfo, error)

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

+ DeleteJobInfo func(context.Context, *pachyderm_pps.Job) (*google_protobuf.Empty, error)

+ DeleteJobInfosForPipeline func(context.Context, *pachyderm_pps.Pipeline) (*google_protobuf.Empty, error)

+ DeletePipelineInfo func(context.Context, *pachyderm_pps.Pipeline) (*google_protobuf.Empty, error)

+ FailPod func(context.Context, *pachyderm_pps.Job) (*JobInfo, error)

+ GetPipelineInfo func(context.Context, *pachyderm_pps.Pipeline) (*PipelineInfo, error)

+ InspectJob func(context.Context, *pachyderm_pps.InspectJobRequest) (*JobInfo, error)

+ ListJobInfos func(context.Context, *pachyderm_pps.ListJobRequest) (*JobInfos, error)

+ ListPipelineInfos func(context.Context, *ListPipelineInfosRequest) (*PipelineInfos, error)

+ StartJob func(context.Context, *pachyderm_pps.Job) (*google_protobuf.Empty, error)

+ StartPod func(context.Context, *pachyderm_pps.Job) (*JobInfo, error)

+ SubscribePipelineInfos func(*SubscribePipelineInfosRequest, API_SubscribePipelineInfosServer) error

+ SucceedPod func(context.Context, *pachyderm_pps.Job) (*JobInfo, error)

+ UpdatePipelineState func(context.Context, *UpdatePipelineStateRequest) (*google_protobuf.Empty, error)

+ type API_SubscribePipelineInfosClient interface

+ Recv func() (*PipelineInfoChange, error)

+ type API_SubscribePipelineInfosServer interface

+ Send func(*PipelineInfoChange) error

+ type JobInfo struct

+ CommitIndex string

+ Finished *google_protobuf1.Timestamp

+ Inputs []*pachyderm_pps.JobInput

+ JobID string

+ OutputCommit *pfs.Commit

+ Parallelism uint64

+ ParentJob *pachyderm_pps.Job

+ PipelineName string

+ PodsFailed uint64

+ PodsStarted uint64

+ PodsSucceeded uint64

+ ShardModuli []uint64

+ Started *google_protobuf1.Timestamp

+ State pachyderm_pps.JobState

+ Transform *pachyderm_pps.Transform

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

+ func (*JobInfo) ProtoMessage()

+ func (m *JobInfo) GetFinished() *google_protobuf1.Timestamp

+ func (m *JobInfo) GetInputs() []*pachyderm_pps.JobInput

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

+ func (m *JobInfo) GetParentJob() *pachyderm_pps.Job

+ func (m *JobInfo) GetStarted() *google_protobuf1.Timestamp

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

+ func (m *JobInfo) Reset()

+ func (m *JobInfo) String() string

+ type JobInfos struct

+ JobInfo []*JobInfo

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

+ func (*JobInfos) ProtoMessage()

+ func (m *JobInfos) GetJobInfo() []*JobInfo

+ func (m *JobInfos) Reset()

+ func (m *JobInfos) String() string

+ type JobOutput struct

+ JobID string

+ OutputCommit *pfs.Commit

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

+ func (*JobOutput) ProtoMessage()

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

+ func (m *JobOutput) Reset()

+ func (m *JobOutput) String() string

+ type JobState struct

+ Finished *google_protobuf1.Timestamp

+ JobID string

+ State pachyderm_pps.JobState

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

+ func (*JobState) ProtoMessage()

+ func (m *JobState) GetFinished() *google_protobuf1.Timestamp

+ func (m *JobState) Reset()

+ func (m *JobState) String() string

+ type ListPipelineInfosRequest struct

+ Shard *Shard

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

+ func (*ListPipelineInfosRequest) ProtoMessage()

+ func (m *ListPipelineInfosRequest) GetShard() *Shard

+ func (m *ListPipelineInfosRequest) Reset()

+ func (m *ListPipelineInfosRequest) String() string

+ type PipelineInfo struct

+ CreatedAt *google_protobuf1.Timestamp

+ Inputs []*pachyderm_pps.PipelineInput

+ JobCounts map[int32]int32

+ OutputRepo *pfs.Repo

+ Parallelism uint64

+ PipelineName string

+ RecentError string

+ Shard uint64

+ State pachyderm_pps.PipelineState

+ Transform *pachyderm_pps.Transform

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

+ func (*PipelineInfo) ProtoMessage()

+ func (m *PipelineInfo) GetCreatedAt() *google_protobuf1.Timestamp

+ func (m *PipelineInfo) GetInputs() []*pachyderm_pps.PipelineInput

+ func (m *PipelineInfo) GetJobCounts() map[int32]int32

+ func (m *PipelineInfo) GetOutputRepo() *pfs.Repo

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

+ func (m *PipelineInfo) Reset()

+ func (m *PipelineInfo) String() string

+ type PipelineInfoChange struct

+ Pipeline *PipelineInfo

+ Removed bool

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

+ func (*PipelineInfoChange) ProtoMessage()

+ func (m *PipelineInfoChange) GetPipeline() *PipelineInfo

+ func (m *PipelineInfoChange) Reset()

+ func (m *PipelineInfoChange) String() string

+ type PipelineInfos struct

+ PipelineInfo []*PipelineInfo

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

+ func (*PipelineInfos) ProtoMessage()

+ func (m *PipelineInfos) GetPipelineInfo() []*PipelineInfo

+ func (m *PipelineInfos) Reset()

+ func (m *PipelineInfos) String() string

+ type Shard struct

+ Number uint64

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

+ func (*Shard) ProtoMessage()

+ func (m *Shard) Reset()

+ func (m *Shard) String() string

+ type SubscribePipelineInfosRequest struct

+ IncludeInitial bool

+ Shard *Shard

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

+ func (*SubscribePipelineInfosRequest) ProtoMessage()

+ func (m *SubscribePipelineInfosRequest) GetShard() *Shard

+ func (m *SubscribePipelineInfosRequest) Reset()

+ func (m *SubscribePipelineInfosRequest) String() string

+ type UpdatePipelineStateRequest struct

+ PipelineName string

+ RecentError string

+ State pachyderm_pps.PipelineState

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

+ func (*UpdatePipelineStateRequest) ProtoMessage()

+ func (m *UpdatePipelineStateRequest) Reset()

+ func (m *UpdatePipelineStateRequest) String() string