Versions in this module Expand all Collapse all v1 v1.9.4 Sep 6, 2019 v1.9.4-6277238fa1e72d2adcbab36c2a829b0eb6309533 Sep 10, 2019 v1.9.3 Aug 7, 2019 v1.9.3-6221e9ed57a10b39d363e0e97cdd6e4e41796af2 Aug 13, 2019 v1.9.2 Jul 25, 2019 v1.9.1 Jul 18, 2019 v1.9.0 Jun 12, 2019 v1.9.0-1ff617394086e2ac29d786b2c19a63288572383a Jun 6, 2019 v1.8.8 Sep 11, 2019 Changes in this version + var DatumState_name = map[int32]string + var DatumState_value = map[string]int32 + var ErrIntOverflowPps = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPps = fmt.Errorf("proto: negative length found during unmarshaling") + var JobState_name = map[int32]string + var JobState_value = map[string]int32 + var PipelineState_name = map[int32]string + var PipelineState_value = map[string]int32 + var WorkerState_name = map[int32]string + var WorkerState_value = map[string]int32 + func RegisterAPIServer(s *grpc.Server, srv APIServer) + type APIClient interface + ActivateAuth func(ctx context.Context, in *ActivateAuthRequest, opts ...grpc.CallOption) (*ActivateAuthResponse, error) + CreateJob func(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error) + CreatePipeline func(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error) + DeleteAll func(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error) + DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*types.Empty, error) + DeletePipeline func(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error) + FlushJob func(ctx context.Context, in *FlushJobRequest, opts ...grpc.CallOption) (API_FlushJobClient, error) + GarbageCollect func(ctx context.Context, in *GarbageCollectRequest, opts ...grpc.CallOption) (*GarbageCollectResponse, error) + GetLogs func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error) + InspectDatum func(ctx context.Context, in *InspectDatumRequest, opts ...grpc.CallOption) (*DatumInfo, error) + InspectJob func(ctx context.Context, in *InspectJobRequest, opts ...grpc.CallOption) (*JobInfo, error) + InspectPipeline func(ctx context.Context, in *InspectPipelineRequest, opts ...grpc.CallOption) (*PipelineInfo, error) + ListDatum func(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (*ListDatumResponse, error) + ListDatumStream func(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (API_ListDatumStreamClient, error) + ListJob func(ctx context.Context, in *ListJobRequest, opts ...grpc.CallOption) (*JobInfos, error) + ListJobStream func(ctx context.Context, in *ListJobRequest, opts ...grpc.CallOption) (API_ListJobStreamClient, error) + ListPipeline func(ctx context.Context, in *ListPipelineRequest, opts ...grpc.CallOption) (*PipelineInfos, error) + RerunPipeline func(ctx context.Context, in *RerunPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error) + RestartDatum func(ctx context.Context, in *RestartDatumRequest, opts ...grpc.CallOption) (*types.Empty, error) + StartPipeline func(ctx context.Context, in *StartPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error) + StopJob func(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*types.Empty, error) + StopPipeline func(ctx context.Context, in *StopPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error) + func NewAPIClient(cc *grpc.ClientConn) APIClient + type APIServer interface + ActivateAuth func(context.Context, *ActivateAuthRequest) (*ActivateAuthResponse, error) + CreateJob func(context.Context, *CreateJobRequest) (*Job, error) + CreatePipeline func(context.Context, *CreatePipelineRequest) (*types.Empty, error) + DeleteAll func(context.Context, *types.Empty) (*types.Empty, error) + DeleteJob func(context.Context, *DeleteJobRequest) (*types.Empty, error) + DeletePipeline func(context.Context, *DeletePipelineRequest) (*types.Empty, error) + FlushJob func(*FlushJobRequest, API_FlushJobServer) error + GarbageCollect func(context.Context, *GarbageCollectRequest) (*GarbageCollectResponse, error) + GetLogs func(*GetLogsRequest, API_GetLogsServer) error + InspectDatum func(context.Context, *InspectDatumRequest) (*DatumInfo, error) + InspectJob func(context.Context, *InspectJobRequest) (*JobInfo, error) + InspectPipeline func(context.Context, *InspectPipelineRequest) (*PipelineInfo, error) + ListDatum func(context.Context, *ListDatumRequest) (*ListDatumResponse, error) + ListDatumStream func(*ListDatumRequest, API_ListDatumStreamServer) error + ListJob func(context.Context, *ListJobRequest) (*JobInfos, error) + ListJobStream func(*ListJobRequest, API_ListJobStreamServer) error + ListPipeline func(context.Context, *ListPipelineRequest) (*PipelineInfos, error) + RerunPipeline func(context.Context, *RerunPipelineRequest) (*types.Empty, error) + RestartDatum func(context.Context, *RestartDatumRequest) (*types.Empty, error) + StartPipeline func(context.Context, *StartPipelineRequest) (*types.Empty, error) + StopJob func(context.Context, *StopJobRequest) (*types.Empty, error) + StopPipeline func(context.Context, *StopPipelineRequest) (*types.Empty, error) + type API_FlushJobClient interface + Recv func() (*JobInfo, error) + type API_FlushJobServer interface + Send func(*JobInfo) error + type API_GetLogsClient interface + Recv func() (*LogMessage, error) + type API_GetLogsServer interface + Send func(*LogMessage) error + type API_ListDatumStreamClient interface + Recv func() (*ListDatumStreamResponse, error) + type API_ListDatumStreamServer interface + Send func(*ListDatumStreamResponse) error + type API_ListJobStreamClient interface + Recv func() (*JobInfo, error) + type API_ListJobStreamServer interface + Send func(*JobInfo) error + type ActivateAuthRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ActivateAuthRequest) Descriptor() ([]byte, []int) + func (*ActivateAuthRequest) ProtoMessage() + func (m *ActivateAuthRequest) Marshal() (dAtA []byte, err error) + func (m *ActivateAuthRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ActivateAuthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ActivateAuthRequest) Reset() + func (m *ActivateAuthRequest) Size() (n int) + func (m *ActivateAuthRequest) String() string + func (m *ActivateAuthRequest) Unmarshal(dAtA []byte) error + func (m *ActivateAuthRequest) XXX_DiscardUnknown() + func (m *ActivateAuthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ActivateAuthRequest) XXX_Merge(src proto.Message) + func (m *ActivateAuthRequest) XXX_Size() int + func (m *ActivateAuthRequest) XXX_Unmarshal(b []byte) error + type ActivateAuthResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ActivateAuthResponse) Descriptor() ([]byte, []int) + func (*ActivateAuthResponse) ProtoMessage() + func (m *ActivateAuthResponse) Marshal() (dAtA []byte, err error) + func (m *ActivateAuthResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ActivateAuthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ActivateAuthResponse) Reset() + func (m *ActivateAuthResponse) Size() (n int) + func (m *ActivateAuthResponse) String() string + func (m *ActivateAuthResponse) Unmarshal(dAtA []byte) error + func (m *ActivateAuthResponse) XXX_DiscardUnknown() + func (m *ActivateAuthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ActivateAuthResponse) XXX_Merge(src proto.Message) + func (m *ActivateAuthResponse) XXX_Size() int + func (m *ActivateAuthResponse) XXX_Unmarshal(b []byte) error + type Aggregate struct + Count int64 + FifthPercentile float64 + Mean float64 + NinetyFifthPercentile float64 + Stddev float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Aggregate) Descriptor() ([]byte, []int) + func (*Aggregate) ProtoMessage() + func (m *Aggregate) GetCount() int64 + func (m *Aggregate) GetFifthPercentile() float64 + func (m *Aggregate) GetMean() float64 + func (m *Aggregate) GetNinetyFifthPercentile() float64 + func (m *Aggregate) GetStddev() float64 + func (m *Aggregate) Marshal() (dAtA []byte, err error) + func (m *Aggregate) MarshalTo(dAtA []byte) (int, error) + func (m *Aggregate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Aggregate) Reset() + func (m *Aggregate) Size() (n int) + func (m *Aggregate) String() string + func (m *Aggregate) Unmarshal(dAtA []byte) error + func (m *Aggregate) XXX_DiscardUnknown() + func (m *Aggregate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Aggregate) XXX_Merge(src proto.Message) + func (m *Aggregate) XXX_Size() int + func (m *Aggregate) XXX_Unmarshal(b []byte) error + type AggregateProcessStats struct + DownloadBytes *Aggregate + DownloadTime *Aggregate + ProcessTime *Aggregate + UploadBytes *Aggregate + UploadTime *Aggregate + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AggregateProcessStats) Descriptor() ([]byte, []int) + func (*AggregateProcessStats) ProtoMessage() + func (m *AggregateProcessStats) GetDownloadBytes() *Aggregate + func (m *AggregateProcessStats) GetDownloadTime() *Aggregate + func (m *AggregateProcessStats) GetProcessTime() *Aggregate + func (m *AggregateProcessStats) GetUploadBytes() *Aggregate + func (m *AggregateProcessStats) GetUploadTime() *Aggregate + func (m *AggregateProcessStats) Marshal() (dAtA []byte, err error) + func (m *AggregateProcessStats) MarshalTo(dAtA []byte) (int, error) + func (m *AggregateProcessStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AggregateProcessStats) Reset() + func (m *AggregateProcessStats) Size() (n int) + func (m *AggregateProcessStats) String() string + func (m *AggregateProcessStats) Unmarshal(dAtA []byte) error + func (m *AggregateProcessStats) XXX_DiscardUnknown() + func (m *AggregateProcessStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AggregateProcessStats) XXX_Merge(src proto.Message) + func (m *AggregateProcessStats) XXX_Size() int + func (m *AggregateProcessStats) XXX_Unmarshal(b []byte) error + type AtomInput struct + Branch string + Commit string + EmptyFiles bool + Glob string + Lazy bool + Name string + Repo string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AtomInput) Descriptor() ([]byte, []int) + func (*AtomInput) ProtoMessage() + func (m *AtomInput) GetBranch() string + func (m *AtomInput) GetCommit() string + func (m *AtomInput) GetEmptyFiles() bool + func (m *AtomInput) GetGlob() string + func (m *AtomInput) GetLazy() bool + func (m *AtomInput) GetName() string + func (m *AtomInput) GetRepo() string + func (m *AtomInput) Marshal() (dAtA []byte, err error) + func (m *AtomInput) MarshalTo(dAtA []byte) (int, error) + func (m *AtomInput) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AtomInput) Reset() + func (m *AtomInput) Size() (n int) + func (m *AtomInput) String() string + func (m *AtomInput) Unmarshal(dAtA []byte) error + func (m *AtomInput) XXX_DiscardUnknown() + func (m *AtomInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AtomInput) XXX_Merge(src proto.Message) + func (m *AtomInput) XXX_Size() int + func (m *AtomInput) XXX_Unmarshal(b []byte) error + type ChunkSpec struct + Number int64 + SizeBytes int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChunkSpec) Descriptor() ([]byte, []int) + func (*ChunkSpec) ProtoMessage() + func (m *ChunkSpec) GetNumber() int64 + func (m *ChunkSpec) GetSizeBytes() int64 + func (m *ChunkSpec) Marshal() (dAtA []byte, err error) + func (m *ChunkSpec) MarshalTo(dAtA []byte) (int, error) + func (m *ChunkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChunkSpec) Reset() + func (m *ChunkSpec) Size() (n int) + func (m *ChunkSpec) String() string + func (m *ChunkSpec) Unmarshal(dAtA []byte) error + func (m *ChunkSpec) XXX_DiscardUnknown() + func (m *ChunkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChunkSpec) XXX_Merge(src proto.Message) + func (m *ChunkSpec) XXX_Size() int + func (m *ChunkSpec) XXX_Unmarshal(b []byte) error + type CreateJobRequest struct + OutputCommit *pfs.Commit + Pipeline *Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateJobRequest) Descriptor() ([]byte, []int) + func (*CreateJobRequest) ProtoMessage() + func (m *CreateJobRequest) GetOutputCommit() *pfs.Commit + func (m *CreateJobRequest) GetPipeline() *Pipeline + func (m *CreateJobRequest) Marshal() (dAtA []byte, err error) + func (m *CreateJobRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreateJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateJobRequest) Reset() + func (m *CreateJobRequest) Size() (n int) + func (m *CreateJobRequest) String() string + func (m *CreateJobRequest) Unmarshal(dAtA []byte) error + func (m *CreateJobRequest) XXX_DiscardUnknown() + func (m *CreateJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateJobRequest) XXX_Merge(src proto.Message) + func (m *CreateJobRequest) XXX_Size() int + func (m *CreateJobRequest) XXX_Unmarshal(b []byte) error + type CreatePipelineRequest struct + Batch bool + CacheSize string + ChunkSpec *ChunkSpec + DatumTimeout *types.Duration + DatumTries int64 + Description string + Egress *Egress + EnableStats bool + HashtreeSpec *HashtreeSpec + Input *Input + JobTimeout *types.Duration + MaxQueueSize int64 + OutputBranch string + ParallelismSpec *ParallelismSpec + Pipeline *Pipeline + PodPatch string + PodSpec string + Reprocess bool + ResourceLimits *ResourceSpec + ResourceRequests *ResourceSpec + Salt string + ScaleDownThreshold *types.Duration + SchedulingSpec *SchedulingSpec + Service *Service + Spout *Spout + Standby bool + Transform *Transform + Update bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePipelineRequest) Descriptor() ([]byte, []int) + func (*CreatePipelineRequest) ProtoMessage() + func (m *CreatePipelineRequest) GetBatch() bool + func (m *CreatePipelineRequest) GetCacheSize() string + func (m *CreatePipelineRequest) GetChunkSpec() *ChunkSpec + func (m *CreatePipelineRequest) GetDatumTimeout() *types.Duration + func (m *CreatePipelineRequest) GetDatumTries() int64 + func (m *CreatePipelineRequest) GetDescription() string + func (m *CreatePipelineRequest) GetEgress() *Egress + func (m *CreatePipelineRequest) GetEnableStats() bool + func (m *CreatePipelineRequest) GetHashtreeSpec() *HashtreeSpec + func (m *CreatePipelineRequest) GetInput() *Input + func (m *CreatePipelineRequest) GetJobTimeout() *types.Duration + func (m *CreatePipelineRequest) GetMaxQueueSize() int64 + func (m *CreatePipelineRequest) GetOutputBranch() string + func (m *CreatePipelineRequest) GetParallelismSpec() *ParallelismSpec + func (m *CreatePipelineRequest) GetPipeline() *Pipeline + func (m *CreatePipelineRequest) GetPodPatch() string + func (m *CreatePipelineRequest) GetPodSpec() string + func (m *CreatePipelineRequest) GetReprocess() bool + func (m *CreatePipelineRequest) GetResourceLimits() *ResourceSpec + func (m *CreatePipelineRequest) GetResourceRequests() *ResourceSpec + func (m *CreatePipelineRequest) GetSalt() string + func (m *CreatePipelineRequest) GetScaleDownThreshold() *types.Duration + func (m *CreatePipelineRequest) GetSchedulingSpec() *SchedulingSpec + func (m *CreatePipelineRequest) GetService() *Service + func (m *CreatePipelineRequest) GetSpout() *Spout + func (m *CreatePipelineRequest) GetStandby() bool + func (m *CreatePipelineRequest) GetTransform() *Transform + func (m *CreatePipelineRequest) GetUpdate() bool + func (m *CreatePipelineRequest) Marshal() (dAtA []byte, err error) + func (m *CreatePipelineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreatePipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreatePipelineRequest) Reset() + func (m *CreatePipelineRequest) Size() (n int) + func (m *CreatePipelineRequest) String() string + func (m *CreatePipelineRequest) Unmarshal(dAtA []byte) error + func (m *CreatePipelineRequest) XXX_DiscardUnknown() + func (m *CreatePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePipelineRequest) XXX_Merge(src proto.Message) + func (m *CreatePipelineRequest) XXX_Size() int + func (m *CreatePipelineRequest) XXX_Unmarshal(b []byte) error + type CronInput struct + Commit string + Name string + Overwrite bool + Repo string + Spec string + Start *types.Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CronInput) Descriptor() ([]byte, []int) + func (*CronInput) ProtoMessage() + func (m *CronInput) GetCommit() string + func (m *CronInput) GetName() string + func (m *CronInput) GetOverwrite() bool + func (m *CronInput) GetRepo() string + func (m *CronInput) GetSpec() string + func (m *CronInput) GetStart() *types.Timestamp + func (m *CronInput) Marshal() (dAtA []byte, err error) + func (m *CronInput) MarshalTo(dAtA []byte) (int, error) + func (m *CronInput) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CronInput) Reset() + func (m *CronInput) Size() (n int) + func (m *CronInput) String() string + func (m *CronInput) Unmarshal(dAtA []byte) error + func (m *CronInput) XXX_DiscardUnknown() + func (m *CronInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CronInput) XXX_Merge(src proto.Message) + func (m *CronInput) XXX_Size() int + func (m *CronInput) XXX_Unmarshal(b []byte) error + type Datum struct + ID string + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Datum) Descriptor() ([]byte, []int) + func (*Datum) ProtoMessage() + func (m *Datum) GetID() string + func (m *Datum) GetJob() *Job + func (m *Datum) Marshal() (dAtA []byte, err error) + func (m *Datum) MarshalTo(dAtA []byte) (int, error) + func (m *Datum) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Datum) Reset() + func (m *Datum) Size() (n int) + func (m *Datum) String() string + func (m *Datum) Unmarshal(dAtA []byte) error + func (m *Datum) XXX_DiscardUnknown() + func (m *Datum) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Datum) XXX_Merge(src proto.Message) + func (m *Datum) XXX_Size() int + func (m *Datum) XXX_Unmarshal(b []byte) error + type DatumInfo struct + Data []*pfs.FileInfo + Datum *Datum + PfsState *pfs.File + State DatumState + Stats *ProcessStats + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DatumInfo) Descriptor() ([]byte, []int) + func (*DatumInfo) ProtoMessage() + func (m *DatumInfo) GetData() []*pfs.FileInfo + func (m *DatumInfo) GetDatum() *Datum + func (m *DatumInfo) GetPfsState() *pfs.File + func (m *DatumInfo) GetState() DatumState + func (m *DatumInfo) GetStats() *ProcessStats + func (m *DatumInfo) Marshal() (dAtA []byte, err error) + func (m *DatumInfo) MarshalTo(dAtA []byte) (int, error) + func (m *DatumInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DatumInfo) Reset() + func (m *DatumInfo) Size() (n int) + func (m *DatumInfo) String() string + func (m *DatumInfo) Unmarshal(dAtA []byte) error + func (m *DatumInfo) XXX_DiscardUnknown() + func (m *DatumInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DatumInfo) XXX_Merge(src proto.Message) + func (m *DatumInfo) XXX_Size() int + func (m *DatumInfo) XXX_Unmarshal(b []byte) error + type DatumState int32 + const DatumState_FAILED + const DatumState_SKIPPED + const DatumState_STARTING + const DatumState_SUCCESS + func (DatumState) EnumDescriptor() ([]byte, []int) + func (x DatumState) String() string + type DeleteJobRequest struct + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteJobRequest) Descriptor() ([]byte, []int) + func (*DeleteJobRequest) ProtoMessage() + func (m *DeleteJobRequest) GetJob() *Job + func (m *DeleteJobRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteJobRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteJobRequest) Reset() + func (m *DeleteJobRequest) Size() (n int) + func (m *DeleteJobRequest) String() string + func (m *DeleteJobRequest) Unmarshal(dAtA []byte) error + func (m *DeleteJobRequest) XXX_DiscardUnknown() + func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteJobRequest) XXX_Merge(src proto.Message) + func (m *DeleteJobRequest) XXX_Size() int + func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error + type DeletePipelineRequest struct + All bool + Force bool + Pipeline *Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePipelineRequest) Descriptor() ([]byte, []int) + func (*DeletePipelineRequest) ProtoMessage() + func (m *DeletePipelineRequest) GetAll() bool + func (m *DeletePipelineRequest) GetForce() bool + func (m *DeletePipelineRequest) GetPipeline() *Pipeline + func (m *DeletePipelineRequest) Marshal() (dAtA []byte, err error) + func (m *DeletePipelineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeletePipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeletePipelineRequest) Reset() + func (m *DeletePipelineRequest) Size() (n int) + func (m *DeletePipelineRequest) String() string + func (m *DeletePipelineRequest) Unmarshal(dAtA []byte) error + func (m *DeletePipelineRequest) XXX_DiscardUnknown() + func (m *DeletePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePipelineRequest) XXX_Merge(src proto.Message) + func (m *DeletePipelineRequest) XXX_Size() int + func (m *DeletePipelineRequest) XXX_Unmarshal(b []byte) error + type Egress struct + URL string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Egress) Descriptor() ([]byte, []int) + func (*Egress) ProtoMessage() + func (m *Egress) GetURL() string + func (m *Egress) Marshal() (dAtA []byte, err error) + func (m *Egress) MarshalTo(dAtA []byte) (int, error) + func (m *Egress) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Egress) Reset() + func (m *Egress) Size() (n int) + func (m *Egress) String() string + func (m *Egress) Unmarshal(dAtA []byte) error + func (m *Egress) XXX_DiscardUnknown() + func (m *Egress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Egress) XXX_Merge(src proto.Message) + func (m *Egress) XXX_Size() int + func (m *Egress) XXX_Unmarshal(b []byte) error + type EtcdJobInfo struct + DataFailed int64 + DataProcessed int64 + DataSkipped int64 + DataTotal int64 + Finished *types.Timestamp + Job *Job + OutputCommit *pfs.Commit + Pipeline *Pipeline + Reason string + Restart uint64 + Started *types.Timestamp + State JobState + Stats *ProcessStats + StatsCommit *pfs.Commit + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EtcdJobInfo) Descriptor() ([]byte, []int) + func (*EtcdJobInfo) ProtoMessage() + func (m *EtcdJobInfo) GetDataFailed() int64 + func (m *EtcdJobInfo) GetDataProcessed() int64 + func (m *EtcdJobInfo) GetDataSkipped() int64 + func (m *EtcdJobInfo) GetDataTotal() int64 + func (m *EtcdJobInfo) GetFinished() *types.Timestamp + func (m *EtcdJobInfo) GetJob() *Job + func (m *EtcdJobInfo) GetOutputCommit() *pfs.Commit + func (m *EtcdJobInfo) GetPipeline() *Pipeline + func (m *EtcdJobInfo) GetReason() string + func (m *EtcdJobInfo) GetRestart() uint64 + func (m *EtcdJobInfo) GetStarted() *types.Timestamp + func (m *EtcdJobInfo) GetState() JobState + func (m *EtcdJobInfo) GetStats() *ProcessStats + func (m *EtcdJobInfo) GetStatsCommit() *pfs.Commit + func (m *EtcdJobInfo) Marshal() (dAtA []byte, err error) + func (m *EtcdJobInfo) MarshalTo(dAtA []byte) (int, error) + func (m *EtcdJobInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EtcdJobInfo) Reset() + func (m *EtcdJobInfo) Size() (n int) + func (m *EtcdJobInfo) String() string + func (m *EtcdJobInfo) Unmarshal(dAtA []byte) error + func (m *EtcdJobInfo) XXX_DiscardUnknown() + func (m *EtcdJobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EtcdJobInfo) XXX_Merge(src proto.Message) + func (m *EtcdJobInfo) XXX_Size() int + func (m *EtcdJobInfo) XXX_Unmarshal(b []byte) error + type EtcdPipelineInfo struct + AuthToken string + JobCounts map[int32]int32 + LastJobState JobState + Reason string + SpecCommit *pfs.Commit + State PipelineState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EtcdPipelineInfo) Descriptor() ([]byte, []int) + func (*EtcdPipelineInfo) ProtoMessage() + func (m *EtcdPipelineInfo) GetAuthToken() string + func (m *EtcdPipelineInfo) GetJobCounts() map[int32]int32 + func (m *EtcdPipelineInfo) GetLastJobState() JobState + func (m *EtcdPipelineInfo) GetReason() string + func (m *EtcdPipelineInfo) GetSpecCommit() *pfs.Commit + func (m *EtcdPipelineInfo) GetState() PipelineState + func (m *EtcdPipelineInfo) Marshal() (dAtA []byte, err error) + func (m *EtcdPipelineInfo) MarshalTo(dAtA []byte) (int, error) + func (m *EtcdPipelineInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EtcdPipelineInfo) Reset() + func (m *EtcdPipelineInfo) Size() (n int) + func (m *EtcdPipelineInfo) String() string + func (m *EtcdPipelineInfo) Unmarshal(dAtA []byte) error + func (m *EtcdPipelineInfo) XXX_DiscardUnknown() + func (m *EtcdPipelineInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EtcdPipelineInfo) XXX_Merge(src proto.Message) + func (m *EtcdPipelineInfo) XXX_Size() int + func (m *EtcdPipelineInfo) XXX_Unmarshal(b []byte) error + type FlushJobRequest struct + Commits []*pfs.Commit + ToPipelines []*Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FlushJobRequest) Descriptor() ([]byte, []int) + func (*FlushJobRequest) ProtoMessage() + func (m *FlushJobRequest) GetCommits() []*pfs.Commit + func (m *FlushJobRequest) GetToPipelines() []*Pipeline + func (m *FlushJobRequest) Marshal() (dAtA []byte, err error) + func (m *FlushJobRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FlushJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FlushJobRequest) Reset() + func (m *FlushJobRequest) Size() (n int) + func (m *FlushJobRequest) String() string + func (m *FlushJobRequest) Unmarshal(dAtA []byte) error + func (m *FlushJobRequest) XXX_DiscardUnknown() + func (m *FlushJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FlushJobRequest) XXX_Merge(src proto.Message) + func (m *FlushJobRequest) XXX_Size() int + func (m *FlushJobRequest) XXX_Unmarshal(b []byte) error + type GPUSpec struct + Number int64 + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GPUSpec) Descriptor() ([]byte, []int) + func (*GPUSpec) ProtoMessage() + func (m *GPUSpec) GetNumber() int64 + func (m *GPUSpec) GetType() string + func (m *GPUSpec) Marshal() (dAtA []byte, err error) + func (m *GPUSpec) MarshalTo(dAtA []byte) (int, error) + func (m *GPUSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GPUSpec) Reset() + func (m *GPUSpec) Size() (n int) + func (m *GPUSpec) String() string + func (m *GPUSpec) Unmarshal(dAtA []byte) error + func (m *GPUSpec) XXX_DiscardUnknown() + func (m *GPUSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GPUSpec) XXX_Merge(src proto.Message) + func (m *GPUSpec) XXX_Size() int + func (m *GPUSpec) XXX_Unmarshal(b []byte) error + type GarbageCollectRequest struct + MemoryBytes int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GarbageCollectRequest) Descriptor() ([]byte, []int) + func (*GarbageCollectRequest) ProtoMessage() + func (m *GarbageCollectRequest) GetMemoryBytes() int64 + func (m *GarbageCollectRequest) Marshal() (dAtA []byte, err error) + func (m *GarbageCollectRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GarbageCollectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GarbageCollectRequest) Reset() + func (m *GarbageCollectRequest) Size() (n int) + func (m *GarbageCollectRequest) String() string + func (m *GarbageCollectRequest) Unmarshal(dAtA []byte) error + func (m *GarbageCollectRequest) XXX_DiscardUnknown() + func (m *GarbageCollectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GarbageCollectRequest) XXX_Merge(src proto.Message) + func (m *GarbageCollectRequest) XXX_Size() int + func (m *GarbageCollectRequest) XXX_Unmarshal(b []byte) error + type GarbageCollectResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GarbageCollectResponse) Descriptor() ([]byte, []int) + func (*GarbageCollectResponse) ProtoMessage() + func (m *GarbageCollectResponse) Marshal() (dAtA []byte, err error) + func (m *GarbageCollectResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GarbageCollectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GarbageCollectResponse) Reset() + func (m *GarbageCollectResponse) Size() (n int) + func (m *GarbageCollectResponse) String() string + func (m *GarbageCollectResponse) Unmarshal(dAtA []byte) error + func (m *GarbageCollectResponse) XXX_DiscardUnknown() + func (m *GarbageCollectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GarbageCollectResponse) XXX_Merge(src proto.Message) + func (m *GarbageCollectResponse) XXX_Size() int + func (m *GarbageCollectResponse) XXX_Unmarshal(b []byte) error + type GetLogsRequest struct + DataFilters []string + Datum *Datum + Follow bool + Job *Job + Master bool + Pipeline *Pipeline + Tail int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetLogsRequest) Descriptor() ([]byte, []int) + func (*GetLogsRequest) ProtoMessage() + func (m *GetLogsRequest) GetDataFilters() []string + func (m *GetLogsRequest) GetDatum() *Datum + func (m *GetLogsRequest) GetFollow() bool + func (m *GetLogsRequest) GetJob() *Job + func (m *GetLogsRequest) GetMaster() bool + func (m *GetLogsRequest) GetPipeline() *Pipeline + func (m *GetLogsRequest) GetTail() int64 + func (m *GetLogsRequest) Marshal() (dAtA []byte, err error) + func (m *GetLogsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetLogsRequest) Reset() + func (m *GetLogsRequest) Size() (n int) + func (m *GetLogsRequest) String() string + func (m *GetLogsRequest) Unmarshal(dAtA []byte) error + func (m *GetLogsRequest) XXX_DiscardUnknown() + func (m *GetLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetLogsRequest) XXX_Merge(src proto.Message) + func (m *GetLogsRequest) XXX_Size() int + func (m *GetLogsRequest) XXX_Unmarshal(b []byte) error + type GitInput struct + Branch string + Commit string + Name string + URL string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GitInput) Descriptor() ([]byte, []int) + func (*GitInput) ProtoMessage() + func (m *GitInput) GetBranch() string + func (m *GitInput) GetCommit() string + func (m *GitInput) GetName() string + func (m *GitInput) GetURL() string + func (m *GitInput) Marshal() (dAtA []byte, err error) + func (m *GitInput) MarshalTo(dAtA []byte) (int, error) + func (m *GitInput) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GitInput) Reset() + func (m *GitInput) Size() (n int) + func (m *GitInput) String() string + func (m *GitInput) Unmarshal(dAtA []byte) error + func (m *GitInput) XXX_DiscardUnknown() + func (m *GitInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GitInput) XXX_Merge(src proto.Message) + func (m *GitInput) XXX_Size() int + func (m *GitInput) XXX_Unmarshal(b []byte) error + type HashtreeSpec struct + Constant uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HashtreeSpec) Descriptor() ([]byte, []int) + func (*HashtreeSpec) ProtoMessage() + func (m *HashtreeSpec) GetConstant() uint64 + func (m *HashtreeSpec) Marshal() (dAtA []byte, err error) + func (m *HashtreeSpec) MarshalTo(dAtA []byte) (int, error) + func (m *HashtreeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HashtreeSpec) Reset() + func (m *HashtreeSpec) Size() (n int) + func (m *HashtreeSpec) String() string + func (m *HashtreeSpec) Unmarshal(dAtA []byte) error + func (m *HashtreeSpec) XXX_DiscardUnknown() + func (m *HashtreeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HashtreeSpec) XXX_Merge(src proto.Message) + func (m *HashtreeSpec) XXX_Size() int + func (m *HashtreeSpec) XXX_Unmarshal(b []byte) error + type Input struct + Atom *AtomInput + Cron *CronInput + Cross []*Input + Git *GitInput + Pfs *PFSInput + Union []*Input + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Input) Descriptor() ([]byte, []int) + func (*Input) ProtoMessage() + func (m *Input) GetAtom() *AtomInput + func (m *Input) GetCron() *CronInput + func (m *Input) GetCross() []*Input + func (m *Input) GetGit() *GitInput + func (m *Input) GetPfs() *PFSInput + func (m *Input) GetUnion() []*Input + func (m *Input) Marshal() (dAtA []byte, err error) + func (m *Input) MarshalTo(dAtA []byte) (int, error) + func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Input) Reset() + func (m *Input) Size() (n int) + func (m *Input) String() string + func (m *Input) Unmarshal(dAtA []byte) error + func (m *Input) XXX_DiscardUnknown() + func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Input) XXX_Merge(src proto.Message) + func (m *Input) XXX_Size() int + func (m *Input) XXX_Unmarshal(b []byte) error + type InputFile struct + Hash []byte + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InputFile) Descriptor() ([]byte, []int) + func (*InputFile) ProtoMessage() + func (m *InputFile) GetHash() []byte + func (m *InputFile) GetPath() string + func (m *InputFile) Marshal() (dAtA []byte, err error) + func (m *InputFile) MarshalTo(dAtA []byte) (int, error) + func (m *InputFile) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *InputFile) Reset() + func (m *InputFile) Size() (n int) + func (m *InputFile) String() string + func (m *InputFile) Unmarshal(dAtA []byte) error + func (m *InputFile) XXX_DiscardUnknown() + func (m *InputFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InputFile) XXX_Merge(src proto.Message) + func (m *InputFile) XXX_Size() int + func (m *InputFile) XXX_Unmarshal(b []byte) error + type InspectDatumRequest struct + Datum *Datum + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InspectDatumRequest) Descriptor() ([]byte, []int) + func (*InspectDatumRequest) ProtoMessage() + func (m *InspectDatumRequest) GetDatum() *Datum + func (m *InspectDatumRequest) Marshal() (dAtA []byte, err error) + func (m *InspectDatumRequest) MarshalTo(dAtA []byte) (int, error) + func (m *InspectDatumRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *InspectDatumRequest) Reset() + func (m *InspectDatumRequest) Size() (n int) + func (m *InspectDatumRequest) String() string + func (m *InspectDatumRequest) Unmarshal(dAtA []byte) error + func (m *InspectDatumRequest) XXX_DiscardUnknown() + func (m *InspectDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InspectDatumRequest) XXX_Merge(src proto.Message) + func (m *InspectDatumRequest) XXX_Size() int + func (m *InspectDatumRequest) XXX_Unmarshal(b []byte) error + type InspectJobRequest struct + BlockState bool + Job *Job + OutputCommit *pfs.Commit + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InspectJobRequest) Descriptor() ([]byte, []int) + func (*InspectJobRequest) ProtoMessage() + func (m *InspectJobRequest) GetBlockState() bool + func (m *InspectJobRequest) GetJob() *Job + func (m *InspectJobRequest) GetOutputCommit() *pfs.Commit + func (m *InspectJobRequest) Marshal() (dAtA []byte, err error) + func (m *InspectJobRequest) MarshalTo(dAtA []byte) (int, error) + func (m *InspectJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *InspectJobRequest) Reset() + func (m *InspectJobRequest) Size() (n int) + func (m *InspectJobRequest) String() string + func (m *InspectJobRequest) Unmarshal(dAtA []byte) error + func (m *InspectJobRequest) XXX_DiscardUnknown() + func (m *InspectJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InspectJobRequest) XXX_Merge(src proto.Message) + func (m *InspectJobRequest) XXX_Size() int + func (m *InspectJobRequest) XXX_Unmarshal(b []byte) error + type InspectPipelineRequest struct + Pipeline *Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InspectPipelineRequest) Descriptor() ([]byte, []int) + func (*InspectPipelineRequest) ProtoMessage() + func (m *InspectPipelineRequest) GetPipeline() *Pipeline + func (m *InspectPipelineRequest) Marshal() (dAtA []byte, err error) + func (m *InspectPipelineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *InspectPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *InspectPipelineRequest) Reset() + func (m *InspectPipelineRequest) Size() (n int) + func (m *InspectPipelineRequest) String() string + func (m *InspectPipelineRequest) Unmarshal(dAtA []byte) error + func (m *InspectPipelineRequest) XXX_DiscardUnknown() + func (m *InspectPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InspectPipelineRequest) XXX_Merge(src proto.Message) + func (m *InspectPipelineRequest) XXX_Size() int + func (m *InspectPipelineRequest) XXX_Unmarshal(b []byte) error + type Job struct + ID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (m *Job) GetID() string + func (m *Job) Marshal() (dAtA []byte, err error) + func (m *Job) MarshalTo(dAtA []byte) (int, error) + func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Job) Reset() + func (m *Job) Size() (n int) + func (m *Job) String() string + func (m *Job) Unmarshal(dAtA []byte) error + func (m *Job) XXX_DiscardUnknown() + func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Job) XXX_Merge(src proto.Message) + func (m *Job) XXX_Size() int + func (m *Job) XXX_Unmarshal(b []byte) error + type JobInfo struct + Batch bool + ChunkSpec *ChunkSpec + DataFailed int64 + DataProcessed int64 + DataSkipped int64 + DataTotal int64 + DatumTimeout *types.Duration + DatumTries int64 + Egress *Egress + EnableStats bool + Finished *types.Timestamp + Input *Input + Job *Job + JobTimeout *types.Duration + NewBranch *pfs.BranchInfo + OutputBranch string + OutputCommit *pfs.Commit + OutputRepo *pfs.Repo + ParallelismSpec *ParallelismSpec + ParentJob *Job + Pipeline *Pipeline + PipelineVersion uint64 + PodPatch string + PodSpec string + Reason string + ResourceLimits *ResourceSpec + ResourceRequests *ResourceSpec + Restart uint64 + Salt string + SchedulingSpec *SchedulingSpec + Service *Service + Spout *Spout + Started *types.Timestamp + State JobState + Stats *ProcessStats + StatsCommit *pfs.Commit + Transform *Transform + WorkerStatus []*WorkerStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*JobInfo) Descriptor() ([]byte, []int) + func (*JobInfo) ProtoMessage() + func (m *JobInfo) GetBatch() bool + func (m *JobInfo) GetChunkSpec() *ChunkSpec + func (m *JobInfo) GetDataFailed() int64 + func (m *JobInfo) GetDataProcessed() int64 + func (m *JobInfo) GetDataSkipped() int64 + func (m *JobInfo) GetDataTotal() int64 + func (m *JobInfo) GetDatumTimeout() *types.Duration + func (m *JobInfo) GetDatumTries() int64 + func (m *JobInfo) GetEgress() *Egress + func (m *JobInfo) GetEnableStats() bool + func (m *JobInfo) GetFinished() *types.Timestamp + func (m *JobInfo) GetInput() *Input + func (m *JobInfo) GetJob() *Job + func (m *JobInfo) GetJobTimeout() *types.Duration + func (m *JobInfo) GetNewBranch() *pfs.BranchInfo + func (m *JobInfo) GetOutputBranch() string + func (m *JobInfo) GetOutputCommit() *pfs.Commit + func (m *JobInfo) GetOutputRepo() *pfs.Repo + func (m *JobInfo) GetParallelismSpec() *ParallelismSpec + func (m *JobInfo) GetParentJob() *Job + func (m *JobInfo) GetPipeline() *Pipeline + func (m *JobInfo) GetPipelineVersion() uint64 + func (m *JobInfo) GetPodPatch() string + func (m *JobInfo) GetPodSpec() string + func (m *JobInfo) GetReason() string + func (m *JobInfo) GetResourceLimits() *ResourceSpec + func (m *JobInfo) GetResourceRequests() *ResourceSpec + func (m *JobInfo) GetRestart() uint64 + func (m *JobInfo) GetSalt() string + func (m *JobInfo) GetSchedulingSpec() *SchedulingSpec + func (m *JobInfo) GetService() *Service + func (m *JobInfo) GetSpout() *Spout + func (m *JobInfo) GetStarted() *types.Timestamp + func (m *JobInfo) GetState() JobState + func (m *JobInfo) GetStats() *ProcessStats + func (m *JobInfo) GetStatsCommit() *pfs.Commit + func (m *JobInfo) GetTransform() *Transform + func (m *JobInfo) GetWorkerStatus() []*WorkerStatus + func (m *JobInfo) Marshal() (dAtA []byte, err error) + func (m *JobInfo) MarshalTo(dAtA []byte) (int, error) + func (m *JobInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *JobInfo) Reset() + func (m *JobInfo) Size() (n int) + func (m *JobInfo) String() string + func (m *JobInfo) Unmarshal(dAtA []byte) error + func (m *JobInfo) XXX_DiscardUnknown() + func (m *JobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JobInfo) XXX_Merge(src proto.Message) + func (m *JobInfo) XXX_Size() int + func (m *JobInfo) XXX_Unmarshal(b []byte) error + type JobInfos struct + JobInfo []*JobInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*JobInfos) Descriptor() ([]byte, []int) + func (*JobInfos) ProtoMessage() + func (m *JobInfos) GetJobInfo() []*JobInfo + func (m *JobInfos) Marshal() (dAtA []byte, err error) + func (m *JobInfos) MarshalTo(dAtA []byte) (int, error) + func (m *JobInfos) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *JobInfos) Reset() + func (m *JobInfos) Size() (n int) + func (m *JobInfos) String() string + func (m *JobInfos) Unmarshal(dAtA []byte) error + func (m *JobInfos) XXX_DiscardUnknown() + func (m *JobInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JobInfos) XXX_Merge(src proto.Message) + func (m *JobInfos) XXX_Size() int + func (m *JobInfos) XXX_Unmarshal(b []byte) error + type JobInput struct + Commit *pfs.Commit + Glob string + Lazy bool + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*JobInput) Descriptor() ([]byte, []int) + func (*JobInput) ProtoMessage() + func (m *JobInput) GetCommit() *pfs.Commit + func (m *JobInput) GetGlob() string + func (m *JobInput) GetLazy() bool + func (m *JobInput) GetName() string + func (m *JobInput) Marshal() (dAtA []byte, err error) + func (m *JobInput) MarshalTo(dAtA []byte) (int, error) + func (m *JobInput) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *JobInput) Reset() + func (m *JobInput) Size() (n int) + func (m *JobInput) String() string + func (m *JobInput) Unmarshal(dAtA []byte) error + func (m *JobInput) XXX_DiscardUnknown() + func (m *JobInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JobInput) XXX_Merge(src proto.Message) + func (m *JobInput) XXX_Size() int + func (m *JobInput) XXX_Unmarshal(b []byte) error + type JobState int32 + const JobState_JOB_FAILURE + const JobState_JOB_KILLED + const JobState_JOB_MERGING + const JobState_JOB_RUNNING + const JobState_JOB_STARTING + const JobState_JOB_SUCCESS + func (JobState) EnumDescriptor() ([]byte, []int) + func (x JobState) String() string + type ListDatumRequest struct + Job *Job + Page int64 + PageSize int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListDatumRequest) Descriptor() ([]byte, []int) + func (*ListDatumRequest) ProtoMessage() + func (m *ListDatumRequest) GetJob() *Job + func (m *ListDatumRequest) GetPage() int64 + func (m *ListDatumRequest) GetPageSize() int64 + func (m *ListDatumRequest) Marshal() (dAtA []byte, err error) + func (m *ListDatumRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListDatumRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListDatumRequest) Reset() + func (m *ListDatumRequest) Size() (n int) + func (m *ListDatumRequest) String() string + func (m *ListDatumRequest) Unmarshal(dAtA []byte) error + func (m *ListDatumRequest) XXX_DiscardUnknown() + func (m *ListDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListDatumRequest) XXX_Merge(src proto.Message) + func (m *ListDatumRequest) XXX_Size() int + func (m *ListDatumRequest) XXX_Unmarshal(b []byte) error + type ListDatumResponse struct + DatumInfos []*DatumInfo + Page int64 + TotalPages int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListDatumResponse) Descriptor() ([]byte, []int) + func (*ListDatumResponse) ProtoMessage() + func (m *ListDatumResponse) GetDatumInfos() []*DatumInfo + func (m *ListDatumResponse) GetPage() int64 + func (m *ListDatumResponse) GetTotalPages() int64 + func (m *ListDatumResponse) Marshal() (dAtA []byte, err error) + func (m *ListDatumResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListDatumResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListDatumResponse) Reset() + func (m *ListDatumResponse) Size() (n int) + func (m *ListDatumResponse) String() string + func (m *ListDatumResponse) Unmarshal(dAtA []byte) error + func (m *ListDatumResponse) XXX_DiscardUnknown() + func (m *ListDatumResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListDatumResponse) XXX_Merge(src proto.Message) + func (m *ListDatumResponse) XXX_Size() int + func (m *ListDatumResponse) XXX_Unmarshal(b []byte) error + type ListDatumStreamResponse struct + DatumInfo *DatumInfo + Page int64 + TotalPages int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListDatumStreamResponse) Descriptor() ([]byte, []int) + func (*ListDatumStreamResponse) ProtoMessage() + func (m *ListDatumStreamResponse) GetDatumInfo() *DatumInfo + func (m *ListDatumStreamResponse) GetPage() int64 + func (m *ListDatumStreamResponse) GetTotalPages() int64 + func (m *ListDatumStreamResponse) Marshal() (dAtA []byte, err error) + func (m *ListDatumStreamResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListDatumStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListDatumStreamResponse) Reset() + func (m *ListDatumStreamResponse) Size() (n int) + func (m *ListDatumStreamResponse) String() string + func (m *ListDatumStreamResponse) Unmarshal(dAtA []byte) error + func (m *ListDatumStreamResponse) XXX_DiscardUnknown() + func (m *ListDatumStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListDatumStreamResponse) XXX_Merge(src proto.Message) + func (m *ListDatumStreamResponse) XXX_Size() int + func (m *ListDatumStreamResponse) XXX_Unmarshal(b []byte) error + type ListJobRequest struct + InputCommit []*pfs.Commit + OutputCommit *pfs.Commit + Pipeline *Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListJobRequest) Descriptor() ([]byte, []int) + func (*ListJobRequest) ProtoMessage() + func (m *ListJobRequest) GetInputCommit() []*pfs.Commit + func (m *ListJobRequest) GetOutputCommit() *pfs.Commit + func (m *ListJobRequest) GetPipeline() *Pipeline + func (m *ListJobRequest) Marshal() (dAtA []byte, err error) + func (m *ListJobRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListJobRequest) Reset() + func (m *ListJobRequest) Size() (n int) + func (m *ListJobRequest) String() string + func (m *ListJobRequest) Unmarshal(dAtA []byte) error + func (m *ListJobRequest) XXX_DiscardUnknown() + func (m *ListJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListJobRequest) XXX_Merge(src proto.Message) + func (m *ListJobRequest) XXX_Size() int + func (m *ListJobRequest) XXX_Unmarshal(b []byte) error + type ListPipelineRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPipelineRequest) Descriptor() ([]byte, []int) + func (*ListPipelineRequest) ProtoMessage() + func (m *ListPipelineRequest) Marshal() (dAtA []byte, err error) + func (m *ListPipelineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListPipelineRequest) Reset() + func (m *ListPipelineRequest) Size() (n int) + func (m *ListPipelineRequest) String() string + func (m *ListPipelineRequest) Unmarshal(dAtA []byte) error + func (m *ListPipelineRequest) XXX_DiscardUnknown() + func (m *ListPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPipelineRequest) XXX_Merge(src proto.Message) + func (m *ListPipelineRequest) XXX_Size() int + func (m *ListPipelineRequest) XXX_Unmarshal(b []byte) error + type LogMessage struct + Data []*InputFile + DatumID string + JobID string + Master bool + Message string + PipelineName string + Ts *types.Timestamp + User bool + WorkerID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogMessage) Descriptor() ([]byte, []int) + func (*LogMessage) ProtoMessage() + func (m *LogMessage) GetData() []*InputFile + func (m *LogMessage) GetDatumID() string + func (m *LogMessage) GetJobID() string + func (m *LogMessage) GetMaster() bool + func (m *LogMessage) GetMessage() string + func (m *LogMessage) GetPipelineName() string + func (m *LogMessage) GetTs() *types.Timestamp + func (m *LogMessage) GetUser() bool + func (m *LogMessage) GetWorkerID() string + func (m *LogMessage) Marshal() (dAtA []byte, err error) + func (m *LogMessage) MarshalTo(dAtA []byte) (int, error) + func (m *LogMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LogMessage) Reset() + func (m *LogMessage) Size() (n int) + func (m *LogMessage) String() string + func (m *LogMessage) Unmarshal(dAtA []byte) error + func (m *LogMessage) XXX_DiscardUnknown() + func (m *LogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogMessage) XXX_Merge(src proto.Message) + func (m *LogMessage) XXX_Size() int + func (m *LogMessage) XXX_Unmarshal(b []byte) error + type PFSInput struct + Branch string + Commit string + EmptyFiles bool + Glob string + Lazy bool + Name string + Repo string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PFSInput) Descriptor() ([]byte, []int) + func (*PFSInput) ProtoMessage() + func (m *PFSInput) GetBranch() string + func (m *PFSInput) GetCommit() string + func (m *PFSInput) GetEmptyFiles() bool + func (m *PFSInput) GetGlob() string + func (m *PFSInput) GetLazy() bool + func (m *PFSInput) GetName() string + func (m *PFSInput) GetRepo() string + func (m *PFSInput) Marshal() (dAtA []byte, err error) + func (m *PFSInput) MarshalTo(dAtA []byte) (int, error) + func (m *PFSInput) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PFSInput) Reset() + func (m *PFSInput) Size() (n int) + func (m *PFSInput) String() string + func (m *PFSInput) Unmarshal(dAtA []byte) error + func (m *PFSInput) XXX_DiscardUnknown() + func (m *PFSInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PFSInput) XXX_Merge(src proto.Message) + func (m *PFSInput) XXX_Size() int + func (m *PFSInput) XXX_Unmarshal(b []byte) error + type ParallelismSpec struct + Coefficient float64 + Constant uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ParallelismSpec) Descriptor() ([]byte, []int) + func (*ParallelismSpec) ProtoMessage() + func (m *ParallelismSpec) GetCoefficient() float64 + func (m *ParallelismSpec) GetConstant() uint64 + func (m *ParallelismSpec) Marshal() (dAtA []byte, err error) + func (m *ParallelismSpec) MarshalTo(dAtA []byte) (int, error) + func (m *ParallelismSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ParallelismSpec) Reset() + func (m *ParallelismSpec) Size() (n int) + func (m *ParallelismSpec) String() string + func (m *ParallelismSpec) Unmarshal(dAtA []byte) error + func (m *ParallelismSpec) XXX_DiscardUnknown() + func (m *ParallelismSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ParallelismSpec) XXX_Merge(src proto.Message) + func (m *ParallelismSpec) XXX_Size() int + func (m *ParallelismSpec) XXX_Unmarshal(b []byte) error + type Pipeline struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Pipeline) Descriptor() ([]byte, []int) + func (*Pipeline) ProtoMessage() + func (m *Pipeline) GetName() string + func (m *Pipeline) Marshal() (dAtA []byte, err error) + func (m *Pipeline) MarshalTo(dAtA []byte) (int, error) + func (m *Pipeline) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Pipeline) Reset() + func (m *Pipeline) Size() (n int) + func (m *Pipeline) String() string + func (m *Pipeline) Unmarshal(dAtA []byte) error + func (m *Pipeline) XXX_DiscardUnknown() + func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Pipeline) XXX_Merge(src proto.Message) + func (m *Pipeline) XXX_Size() int + func (m *Pipeline) XXX_Unmarshal(b []byte) error + type PipelineInfo struct + Batch bool + CacheSize string + ChunkSpec *ChunkSpec + CreatedAt *types.Timestamp + DatumTimeout *types.Duration + DatumTries int64 + Description string + Egress *Egress + EnableStats bool + GithookURL string + HashtreeSpec *HashtreeSpec + ID string + Input *Input + JobCounts map[int32]int32 + JobTimeout *types.Duration + LastJobState JobState + MaxQueueSize int64 + OutputBranch string + ParallelismSpec *ParallelismSpec + Pipeline *Pipeline + PodPatch string + PodSpec string + Reason string + RecentError string + ResourceLimits *ResourceSpec + ResourceRequests *ResourceSpec + Salt string + ScaleDownThreshold *types.Duration + SchedulingSpec *SchedulingSpec + Service *Service + SpecCommit *pfs.Commit + Spout *Spout + Standby bool + State PipelineState + Stopped bool + Transform *Transform + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PipelineInfo) Descriptor() ([]byte, []int) + func (*PipelineInfo) ProtoMessage() + func (m *PipelineInfo) GetBatch() bool + func (m *PipelineInfo) GetCacheSize() string + func (m *PipelineInfo) GetChunkSpec() *ChunkSpec + func (m *PipelineInfo) GetCreatedAt() *types.Timestamp + func (m *PipelineInfo) GetDatumTimeout() *types.Duration + func (m *PipelineInfo) GetDatumTries() int64 + func (m *PipelineInfo) GetDescription() string + func (m *PipelineInfo) GetEgress() *Egress + func (m *PipelineInfo) GetEnableStats() bool + func (m *PipelineInfo) GetGithookURL() string + func (m *PipelineInfo) GetHashtreeSpec() *HashtreeSpec + func (m *PipelineInfo) GetID() string + func (m *PipelineInfo) GetInput() *Input + func (m *PipelineInfo) GetJobCounts() map[int32]int32 + func (m *PipelineInfo) GetJobTimeout() *types.Duration + func (m *PipelineInfo) GetLastJobState() JobState + func (m *PipelineInfo) GetMaxQueueSize() int64 + func (m *PipelineInfo) GetOutputBranch() string + func (m *PipelineInfo) GetParallelismSpec() *ParallelismSpec + func (m *PipelineInfo) GetPipeline() *Pipeline + func (m *PipelineInfo) GetPodPatch() string + func (m *PipelineInfo) GetPodSpec() string + func (m *PipelineInfo) GetReason() string + func (m *PipelineInfo) GetRecentError() string + func (m *PipelineInfo) GetResourceLimits() *ResourceSpec + func (m *PipelineInfo) GetResourceRequests() *ResourceSpec + func (m *PipelineInfo) GetSalt() string + func (m *PipelineInfo) GetScaleDownThreshold() *types.Duration + func (m *PipelineInfo) GetSchedulingSpec() *SchedulingSpec + func (m *PipelineInfo) GetService() *Service + func (m *PipelineInfo) GetSpecCommit() *pfs.Commit + func (m *PipelineInfo) GetSpout() *Spout + func (m *PipelineInfo) GetStandby() bool + func (m *PipelineInfo) GetState() PipelineState + func (m *PipelineInfo) GetStopped() bool + func (m *PipelineInfo) GetTransform() *Transform + func (m *PipelineInfo) GetVersion() uint64 + func (m *PipelineInfo) Marshal() (dAtA []byte, err error) + func (m *PipelineInfo) MarshalTo(dAtA []byte) (int, error) + func (m *PipelineInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PipelineInfo) Reset() + func (m *PipelineInfo) Size() (n int) + func (m *PipelineInfo) String() string + func (m *PipelineInfo) Unmarshal(dAtA []byte) error + func (m *PipelineInfo) XXX_DiscardUnknown() + func (m *PipelineInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PipelineInfo) XXX_Merge(src proto.Message) + func (m *PipelineInfo) XXX_Size() int + func (m *PipelineInfo) XXX_Unmarshal(b []byte) error + type PipelineInfos struct + PipelineInfo []*PipelineInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PipelineInfos) Descriptor() ([]byte, []int) + func (*PipelineInfos) ProtoMessage() + func (m *PipelineInfos) GetPipelineInfo() []*PipelineInfo + func (m *PipelineInfos) Marshal() (dAtA []byte, err error) + func (m *PipelineInfos) MarshalTo(dAtA []byte) (int, error) + func (m *PipelineInfos) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PipelineInfos) Reset() + func (m *PipelineInfos) Size() (n int) + func (m *PipelineInfos) String() string + func (m *PipelineInfos) Unmarshal(dAtA []byte) error + func (m *PipelineInfos) XXX_DiscardUnknown() + func (m *PipelineInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PipelineInfos) XXX_Merge(src proto.Message) + func (m *PipelineInfos) XXX_Size() int + func (m *PipelineInfos) XXX_Unmarshal(b []byte) error + type PipelineInput struct + Branch string + From *pfs.Commit + Glob string + Lazy bool + Name string + Repo *pfs.Repo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PipelineInput) Descriptor() ([]byte, []int) + func (*PipelineInput) ProtoMessage() + func (m *PipelineInput) GetBranch() string + func (m *PipelineInput) GetFrom() *pfs.Commit + func (m *PipelineInput) GetGlob() string + func (m *PipelineInput) GetLazy() bool + func (m *PipelineInput) GetName() string + func (m *PipelineInput) GetRepo() *pfs.Repo + func (m *PipelineInput) Marshal() (dAtA []byte, err error) + func (m *PipelineInput) MarshalTo(dAtA []byte) (int, error) + func (m *PipelineInput) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PipelineInput) Reset() + func (m *PipelineInput) Size() (n int) + func (m *PipelineInput) String() string + func (m *PipelineInput) Unmarshal(dAtA []byte) error + func (m *PipelineInput) XXX_DiscardUnknown() + func (m *PipelineInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PipelineInput) XXX_Merge(src proto.Message) + func (m *PipelineInput) XXX_Size() int + func (m *PipelineInput) XXX_Unmarshal(b []byte) error + type PipelineState int32 + const PipelineState_PIPELINE_FAILURE + const PipelineState_PIPELINE_PAUSED + const PipelineState_PIPELINE_RESTARTING + const PipelineState_PIPELINE_RUNNING + const PipelineState_PIPELINE_STANDBY + const PipelineState_PIPELINE_STARTING + func (PipelineState) EnumDescriptor() ([]byte, []int) + func (x PipelineState) String() string + type ProcessStats struct + DownloadBytes uint64 + DownloadTime *types.Duration + ProcessTime *types.Duration + UploadBytes uint64 + UploadTime *types.Duration + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ProcessStats) Descriptor() ([]byte, []int) + func (*ProcessStats) ProtoMessage() + func (m *ProcessStats) GetDownloadBytes() uint64 + func (m *ProcessStats) GetDownloadTime() *types.Duration + func (m *ProcessStats) GetProcessTime() *types.Duration + func (m *ProcessStats) GetUploadBytes() uint64 + func (m *ProcessStats) GetUploadTime() *types.Duration + func (m *ProcessStats) Marshal() (dAtA []byte, err error) + func (m *ProcessStats) MarshalTo(dAtA []byte) (int, error) + func (m *ProcessStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ProcessStats) Reset() + func (m *ProcessStats) Size() (n int) + func (m *ProcessStats) String() string + func (m *ProcessStats) Unmarshal(dAtA []byte) error + func (m *ProcessStats) XXX_DiscardUnknown() + func (m *ProcessStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ProcessStats) XXX_Merge(src proto.Message) + func (m *ProcessStats) XXX_Size() int + func (m *ProcessStats) XXX_Unmarshal(b []byte) error + type RerunPipelineRequest struct + Exclude []*pfs.Commit + Include []*pfs.Commit + Pipeline *Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RerunPipelineRequest) Descriptor() ([]byte, []int) + func (*RerunPipelineRequest) ProtoMessage() + func (m *RerunPipelineRequest) GetExclude() []*pfs.Commit + func (m *RerunPipelineRequest) GetInclude() []*pfs.Commit + func (m *RerunPipelineRequest) GetPipeline() *Pipeline + func (m *RerunPipelineRequest) Marshal() (dAtA []byte, err error) + func (m *RerunPipelineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RerunPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RerunPipelineRequest) Reset() + func (m *RerunPipelineRequest) Size() (n int) + func (m *RerunPipelineRequest) String() string + func (m *RerunPipelineRequest) Unmarshal(dAtA []byte) error + func (m *RerunPipelineRequest) XXX_DiscardUnknown() + func (m *RerunPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RerunPipelineRequest) XXX_Merge(src proto.Message) + func (m *RerunPipelineRequest) XXX_Size() int + func (m *RerunPipelineRequest) XXX_Unmarshal(b []byte) error + type ResourceSpec struct + Cpu float32 + Disk string + Gpu *GPUSpec + Memory string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResourceSpec) Descriptor() ([]byte, []int) + func (*ResourceSpec) ProtoMessage() + func (m *ResourceSpec) GetCpu() float32 + func (m *ResourceSpec) GetDisk() string + func (m *ResourceSpec) GetGpu() *GPUSpec + func (m *ResourceSpec) GetMemory() string + func (m *ResourceSpec) Marshal() (dAtA []byte, err error) + func (m *ResourceSpec) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceSpec) Reset() + func (m *ResourceSpec) Size() (n int) + func (m *ResourceSpec) String() string + func (m *ResourceSpec) Unmarshal(dAtA []byte) error + func (m *ResourceSpec) XXX_DiscardUnknown() + func (m *ResourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceSpec) XXX_Merge(src proto.Message) + func (m *ResourceSpec) XXX_Size() int + func (m *ResourceSpec) XXX_Unmarshal(b []byte) error + type RestartDatumRequest struct + DataFilters []string + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RestartDatumRequest) Descriptor() ([]byte, []int) + func (*RestartDatumRequest) ProtoMessage() + func (m *RestartDatumRequest) GetDataFilters() []string + func (m *RestartDatumRequest) GetJob() *Job + func (m *RestartDatumRequest) Marshal() (dAtA []byte, err error) + func (m *RestartDatumRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RestartDatumRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RestartDatumRequest) Reset() + func (m *RestartDatumRequest) Size() (n int) + func (m *RestartDatumRequest) String() string + func (m *RestartDatumRequest) Unmarshal(dAtA []byte) error + func (m *RestartDatumRequest) XXX_DiscardUnknown() + func (m *RestartDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RestartDatumRequest) XXX_Merge(src proto.Message) + func (m *RestartDatumRequest) XXX_Size() int + func (m *RestartDatumRequest) XXX_Unmarshal(b []byte) error + type SchedulingSpec struct + NodeSelector map[string]string + PriorityClassName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SchedulingSpec) Descriptor() ([]byte, []int) + func (*SchedulingSpec) ProtoMessage() + func (m *SchedulingSpec) GetNodeSelector() map[string]string + func (m *SchedulingSpec) GetPriorityClassName() string + func (m *SchedulingSpec) Marshal() (dAtA []byte, err error) + func (m *SchedulingSpec) MarshalTo(dAtA []byte) (int, error) + func (m *SchedulingSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SchedulingSpec) Reset() + func (m *SchedulingSpec) Size() (n int) + func (m *SchedulingSpec) String() string + func (m *SchedulingSpec) Unmarshal(dAtA []byte) error + func (m *SchedulingSpec) XXX_DiscardUnknown() + func (m *SchedulingSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SchedulingSpec) XXX_Merge(src proto.Message) + func (m *SchedulingSpec) XXX_Size() int + func (m *SchedulingSpec) XXX_Unmarshal(b []byte) error + type Secret struct + EnvVar string + Key string + MountPath string + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Secret) Descriptor() ([]byte, []int) + func (*Secret) ProtoMessage() + func (m *Secret) GetEnvVar() string + func (m *Secret) GetKey() string + func (m *Secret) GetMountPath() string + func (m *Secret) GetName() string + func (m *Secret) Marshal() (dAtA []byte, err error) + func (m *Secret) MarshalTo(dAtA []byte) (int, error) + func (m *Secret) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Secret) Reset() + func (m *Secret) Size() (n int) + func (m *Secret) String() string + func (m *Secret) Unmarshal(dAtA []byte) error + func (m *Secret) XXX_DiscardUnknown() + func (m *Secret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Secret) XXX_Merge(src proto.Message) + func (m *Secret) XXX_Size() int + func (m *Secret) XXX_Unmarshal(b []byte) error + type Service struct + ExternalPort int32 + IP string + InternalPort int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (m *Service) GetExternalPort() int32 + func (m *Service) GetIP() string + func (m *Service) GetInternalPort() int32 + func (m *Service) Marshal() (dAtA []byte, err error) + func (m *Service) MarshalTo(dAtA []byte) (int, error) + func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Service) Reset() + func (m *Service) Size() (n int) + func (m *Service) String() string + func (m *Service) Unmarshal(dAtA []byte) error + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Merge(src proto.Message) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + type Spout struct + Overwrite bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Spout) Descriptor() ([]byte, []int) + func (*Spout) ProtoMessage() + func (m *Spout) GetOverwrite() bool + func (m *Spout) Marshal() (dAtA []byte, err error) + func (m *Spout) MarshalTo(dAtA []byte) (int, error) + func (m *Spout) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Spout) Reset() + func (m *Spout) Size() (n int) + func (m *Spout) String() string + func (m *Spout) Unmarshal(dAtA []byte) error + func (m *Spout) XXX_DiscardUnknown() + func (m *Spout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Spout) XXX_Merge(src proto.Message) + func (m *Spout) XXX_Size() int + func (m *Spout) XXX_Unmarshal(b []byte) error + type StartPipelineRequest struct + Pipeline *Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StartPipelineRequest) Descriptor() ([]byte, []int) + func (*StartPipelineRequest) ProtoMessage() + func (m *StartPipelineRequest) GetPipeline() *Pipeline + func (m *StartPipelineRequest) Marshal() (dAtA []byte, err error) + func (m *StartPipelineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StartPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StartPipelineRequest) Reset() + func (m *StartPipelineRequest) Size() (n int) + func (m *StartPipelineRequest) String() string + func (m *StartPipelineRequest) Unmarshal(dAtA []byte) error + func (m *StartPipelineRequest) XXX_DiscardUnknown() + func (m *StartPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StartPipelineRequest) XXX_Merge(src proto.Message) + func (m *StartPipelineRequest) XXX_Size() int + func (m *StartPipelineRequest) XXX_Unmarshal(b []byte) error + type StopJobRequest struct + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StopJobRequest) Descriptor() ([]byte, []int) + func (*StopJobRequest) ProtoMessage() + func (m *StopJobRequest) GetJob() *Job + func (m *StopJobRequest) Marshal() (dAtA []byte, err error) + func (m *StopJobRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StopJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StopJobRequest) Reset() + func (m *StopJobRequest) Size() (n int) + func (m *StopJobRequest) String() string + func (m *StopJobRequest) Unmarshal(dAtA []byte) error + func (m *StopJobRequest) XXX_DiscardUnknown() + func (m *StopJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StopJobRequest) XXX_Merge(src proto.Message) + func (m *StopJobRequest) XXX_Size() int + func (m *StopJobRequest) XXX_Unmarshal(b []byte) error + type StopPipelineRequest struct + Pipeline *Pipeline + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StopPipelineRequest) Descriptor() ([]byte, []int) + func (*StopPipelineRequest) ProtoMessage() + func (m *StopPipelineRequest) GetPipeline() *Pipeline + func (m *StopPipelineRequest) Marshal() (dAtA []byte, err error) + func (m *StopPipelineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StopPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StopPipelineRequest) Reset() + func (m *StopPipelineRequest) Size() (n int) + func (m *StopPipelineRequest) String() string + func (m *StopPipelineRequest) Unmarshal(dAtA []byte) error + func (m *StopPipelineRequest) XXX_DiscardUnknown() + func (m *StopPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StopPipelineRequest) XXX_Merge(src proto.Message) + func (m *StopPipelineRequest) XXX_Size() int + func (m *StopPipelineRequest) XXX_Unmarshal(b []byte) error + type Transform struct + AcceptReturnCode []int64 + Cmd []string + Debug bool + Dockerfile string + Env map[string]string + Image string + ImagePullSecrets []string + Secrets []*Secret + Stdin []string + User string + WorkingDir string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Transform) Descriptor() ([]byte, []int) + func (*Transform) ProtoMessage() + func (m *Transform) GetAcceptReturnCode() []int64 + func (m *Transform) GetCmd() []string + func (m *Transform) GetDebug() bool + func (m *Transform) GetDockerfile() string + func (m *Transform) GetEnv() map[string]string + func (m *Transform) GetImage() string + func (m *Transform) GetImagePullSecrets() []string + func (m *Transform) GetSecrets() []*Secret + func (m *Transform) GetStdin() []string + func (m *Transform) GetUser() string + func (m *Transform) GetWorkingDir() string + func (m *Transform) Marshal() (dAtA []byte, err error) + func (m *Transform) MarshalTo(dAtA []byte) (int, error) + func (m *Transform) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Transform) Reset() + func (m *Transform) Size() (n int) + func (m *Transform) String() string + func (m *Transform) Unmarshal(dAtA []byte) error + func (m *Transform) XXX_DiscardUnknown() + func (m *Transform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Transform) XXX_Merge(src proto.Message) + func (m *Transform) XXX_Size() int + func (m *Transform) XXX_Unmarshal(b []byte) error + type UnimplementedAPIServer struct + func (*UnimplementedAPIServer) ActivateAuth(ctx context.Context, req *ActivateAuthRequest) (*ActivateAuthResponse, error) + func (*UnimplementedAPIServer) CreateJob(ctx context.Context, req *CreateJobRequest) (*Job, error) + func (*UnimplementedAPIServer) CreatePipeline(ctx context.Context, req *CreatePipelineRequest) (*types.Empty, error) + func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *types.Empty) (*types.Empty, error) + func (*UnimplementedAPIServer) DeleteJob(ctx context.Context, req *DeleteJobRequest) (*types.Empty, error) + func (*UnimplementedAPIServer) DeletePipeline(ctx context.Context, req *DeletePipelineRequest) (*types.Empty, error) + func (*UnimplementedAPIServer) FlushJob(req *FlushJobRequest, srv API_FlushJobServer) error + func (*UnimplementedAPIServer) GarbageCollect(ctx context.Context, req *GarbageCollectRequest) (*GarbageCollectResponse, error) + func (*UnimplementedAPIServer) GetLogs(req *GetLogsRequest, srv API_GetLogsServer) error + func (*UnimplementedAPIServer) InspectDatum(ctx context.Context, req *InspectDatumRequest) (*DatumInfo, error) + func (*UnimplementedAPIServer) InspectJob(ctx context.Context, req *InspectJobRequest) (*JobInfo, error) + func (*UnimplementedAPIServer) InspectPipeline(ctx context.Context, req *InspectPipelineRequest) (*PipelineInfo, error) + func (*UnimplementedAPIServer) ListDatum(ctx context.Context, req *ListDatumRequest) (*ListDatumResponse, error) + func (*UnimplementedAPIServer) ListDatumStream(req *ListDatumRequest, srv API_ListDatumStreamServer) error + func (*UnimplementedAPIServer) ListJob(ctx context.Context, req *ListJobRequest) (*JobInfos, error) + func (*UnimplementedAPIServer) ListJobStream(req *ListJobRequest, srv API_ListJobStreamServer) error + func (*UnimplementedAPIServer) ListPipeline(ctx context.Context, req *ListPipelineRequest) (*PipelineInfos, error) + func (*UnimplementedAPIServer) RerunPipeline(ctx context.Context, req *RerunPipelineRequest) (*types.Empty, error) + func (*UnimplementedAPIServer) RestartDatum(ctx context.Context, req *RestartDatumRequest) (*types.Empty, error) + func (*UnimplementedAPIServer) StartPipeline(ctx context.Context, req *StartPipelineRequest) (*types.Empty, error) + func (*UnimplementedAPIServer) StopJob(ctx context.Context, req *StopJobRequest) (*types.Empty, error) + func (*UnimplementedAPIServer) StopPipeline(ctx context.Context, req *StopPipelineRequest) (*types.Empty, error) + type Worker struct + Name string + State WorkerState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Worker) Descriptor() ([]byte, []int) + func (*Worker) ProtoMessage() + func (m *Worker) GetName() string + func (m *Worker) GetState() WorkerState + func (m *Worker) Marshal() (dAtA []byte, err error) + func (m *Worker) MarshalTo(dAtA []byte) (int, error) + func (m *Worker) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Worker) Reset() + func (m *Worker) Size() (n int) + func (m *Worker) String() string + func (m *Worker) Unmarshal(dAtA []byte) error + func (m *Worker) XXX_DiscardUnknown() + func (m *Worker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Worker) XXX_Merge(src proto.Message) + func (m *Worker) XXX_Size() int + func (m *Worker) XXX_Unmarshal(b []byte) error + type WorkerState int32 + const WorkerState_POD_FAILED + const WorkerState_POD_RUNNING + const WorkerState_POD_SUCCESS + func (WorkerState) EnumDescriptor() ([]byte, []int) + func (x WorkerState) String() string + type WorkerStatus struct + Data []*InputFile + JobID string + QueueSize int64 + Started *types.Timestamp + Stats *ProcessStats + WorkerID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkerStatus) Descriptor() ([]byte, []int) + func (*WorkerStatus) ProtoMessage() + func (m *WorkerStatus) GetData() []*InputFile + func (m *WorkerStatus) GetJobID() string + func (m *WorkerStatus) GetQueueSize() int64 + func (m *WorkerStatus) GetStarted() *types.Timestamp + func (m *WorkerStatus) GetStats() *ProcessStats + func (m *WorkerStatus) GetWorkerID() string + func (m *WorkerStatus) Marshal() (dAtA []byte, err error) + func (m *WorkerStatus) MarshalTo(dAtA []byte) (int, error) + func (m *WorkerStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WorkerStatus) Reset() + func (m *WorkerStatus) Size() (n int) + func (m *WorkerStatus) String() string + func (m *WorkerStatus) Unmarshal(dAtA []byte) error + func (m *WorkerStatus) XXX_DiscardUnknown() + func (m *WorkerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkerStatus) XXX_Merge(src proto.Message) + func (m *WorkerStatus) XXX_Size() int + func (m *WorkerStatus) XXX_Unmarshal(b []byte) error