pps

package
v1.8.2-b01811d728f42be... Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPps = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPps   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DatumState_name = map[int32]string{
	0: "FAILED",
	1: "SUCCESS",
	2: "SKIPPED",
	3: "STARTING",
}
View Source 
var DatumState_value = map[string]int32{
	"FAILED":   0,
	"SUCCESS":  1,
	"SKIPPED":  2,
	"STARTING": 3,
}
View Source 
var JobState_name = map[int32]string{
	0: "JOB_STARTING",
	1: "JOB_RUNNING",
	2: "JOB_FAILURE",
	3: "JOB_SUCCESS",
	4: "JOB_KILLED",
}
View Source 
var JobState_value = map[string]int32{
	"JOB_STARTING": 0,
	"JOB_RUNNING":  1,
	"JOB_FAILURE":  2,
	"JOB_SUCCESS":  3,
	"JOB_KILLED":   4,
}
View Source 
var PipelineState_name = map[int32]string{
	0: "PIPELINE_STARTING",
	1: "PIPELINE_RUNNING",
	2: "PIPELINE_RESTARTING",
	3: "PIPELINE_FAILURE",
	4: "PIPELINE_PAUSED",
	5: "PIPELINE_STANDBY",
}
View Source 
var PipelineState_value = map[string]int32{
	"PIPELINE_STARTING":   0,
	"PIPELINE_RUNNING":    1,
	"PIPELINE_RESTARTING": 2,
	"PIPELINE_FAILURE":    3,
	"PIPELINE_PAUSED":     4,
	"PIPELINE_STANDBY":    5,
}
View Source 
var WorkerState_name = map[int32]string{
	0: "POD_RUNNING",
	1: "POD_SUCCESS",
	2: "POD_FAILED",
}
View Source 
var WorkerState_value = map[string]int32{
	"POD_RUNNING": 0,
	"POD_SUCCESS": 1,
	"POD_FAILED":  2,
}

Functions

func RegisterAPIServer 

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

Types

type APIClient 

type APIClient interface {
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
	InspectJob(ctx context.Context, in *InspectJobRequest, opts ...grpc.CallOption) (*JobInfo, error)
	// ListJob returns information about current and past Pachyderm jobs. This is
	// deprecated in favor of ListJobStream
	ListJob(ctx context.Context, in *ListJobRequest, opts ...grpc.CallOption) (*JobInfos, error)
	// ListJobStream returns information about current and past Pachyderm jobs.
	ListJobStream(ctx context.Context, in *ListJobRequest, opts ...grpc.CallOption) (API_ListJobStreamClient, error)
	FlushJob(ctx context.Context, in *FlushJobRequest, opts ...grpc.CallOption) (API_FlushJobClient, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*types.Empty, error)
	StopJob(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*types.Empty, error)
	InspectDatum(ctx context.Context, in *InspectDatumRequest, opts ...grpc.CallOption) (*DatumInfo, error)
	// ListDatum returns information about each datum fed to a Pachyderm job. This
	// is deprecated in favor of ListDatumStream
	ListDatum(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (*ListDatumResponse, error)
	// ListDatumStream returns information about each datum fed to a Pachyderm job
	ListDatumStream(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (API_ListDatumStreamClient, error)
	RestartDatum(ctx context.Context, in *RestartDatumRequest, opts ...grpc.CallOption) (*types.Empty, error)
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	InspectPipeline(ctx context.Context, in *InspectPipelineRequest, opts ...grpc.CallOption) (*PipelineInfo, error)
	ListPipeline(ctx context.Context, in *ListPipelineRequest, opts ...grpc.CallOption) (*PipelineInfos, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	StartPipeline(ctx context.Context, in *StartPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	StopPipeline(ctx context.Context, in *StopPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	RerunPipeline(ctx context.Context, in *RerunPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// DeleteAll deletes everything
	DeleteAll(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error)
	// Garbage collection
	GarbageCollect(ctx context.Context, in *GarbageCollectRequest, opts ...grpc.CallOption) (*GarbageCollectResponse, error)
	// An internal call that causes PPS to put itself into an auth-enabled state
	// (all pipeline have tokens, correct permissions, etcd)
	ActivateAuth(ctx context.Context, in *ActivateAuthRequest, opts ...grpc.CallOption) (*ActivateAuthResponse, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	CreateJob(context.Context, *CreateJobRequest) (*Job, error)
	InspectJob(context.Context, *InspectJobRequest) (*JobInfo, error)
	// ListJob returns information about current and past Pachyderm jobs. This is
	// deprecated in favor of ListJobStream
	ListJob(context.Context, *ListJobRequest) (*JobInfos, error)
	// ListJobStream returns information about current and past Pachyderm jobs.
	ListJobStream(*ListJobRequest, API_ListJobStreamServer) error
	FlushJob(*FlushJobRequest, API_FlushJobServer) error
	DeleteJob(context.Context, *DeleteJobRequest) (*types.Empty, error)
	StopJob(context.Context, *StopJobRequest) (*types.Empty, error)
	InspectDatum(context.Context, *InspectDatumRequest) (*DatumInfo, error)
	// ListDatum returns information about each datum fed to a Pachyderm job. This
	// is deprecated in favor of ListDatumStream
	ListDatum(context.Context, *ListDatumRequest) (*ListDatumResponse, error)
	// ListDatumStream returns information about each datum fed to a Pachyderm job
	ListDatumStream(*ListDatumRequest, API_ListDatumStreamServer) error
	RestartDatum(context.Context, *RestartDatumRequest) (*types.Empty, error)
	CreatePipeline(context.Context, *CreatePipelineRequest) (*types.Empty, error)
	InspectPipeline(context.Context, *InspectPipelineRequest) (*PipelineInfo, error)
	ListPipeline(context.Context, *ListPipelineRequest) (*PipelineInfos, error)
	DeletePipeline(context.Context, *DeletePipelineRequest) (*types.Empty, error)
	StartPipeline(context.Context, *StartPipelineRequest) (*types.Empty, error)
	StopPipeline(context.Context, *StopPipelineRequest) (*types.Empty, error)
	RerunPipeline(context.Context, *RerunPipelineRequest) (*types.Empty, error)
	// DeleteAll deletes everything
	DeleteAll(context.Context, *types.Empty) (*types.Empty, error)
	GetLogs(*GetLogsRequest, API_GetLogsServer) error
	// Garbage collection
	GarbageCollect(context.Context, *GarbageCollectRequest) (*GarbageCollectResponse, error)
	// An internal call that causes PPS to put itself into an auth-enabled state
	// (all pipeline have tokens, correct permissions, etcd)
	ActivateAuth(context.Context, *ActivateAuthRequest) (*ActivateAuthResponse, error)
}

APIServer is the server API for API service.

type API_FlushJobClient 

type API_FlushJobClient interface {
	Recv() (*JobInfo, error)
	grpc.ClientStream
}

type API_FlushJobServer 

type API_FlushJobServer interface {
	Send(*JobInfo) error
	grpc.ServerStream
}

type API_GetLogsClient 

type API_GetLogsClient interface {
	Recv() (*LogMessage, error)
	grpc.ClientStream
}

type API_GetLogsServer 

type API_GetLogsServer interface {
	Send(*LogMessage) error
	grpc.ServerStream
}

type API_ListDatumStreamClient 

type API_ListDatumStreamClient interface {
	Recv() (*ListDatumStreamResponse, error)
	grpc.ClientStream
}

type API_ListDatumStreamServer 

type API_ListDatumStreamServer interface {
	Send(*ListDatumStreamResponse) error
	grpc.ServerStream
}

type API_ListJobStreamClient 

type API_ListJobStreamClient interface {
	Recv() (*JobInfo, error)
	grpc.ClientStream
}

type API_ListJobStreamServer 

type API_ListJobStreamServer interface {
	Send(*JobInfo) error
	grpc.ServerStream
}

type ActivateAuthRequest 

type ActivateAuthRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateAuthRequest) Descriptor 

func (*ActivateAuthRequest) Descriptor() ([]byte, []int)

func (*ActivateAuthRequest) Marshal 

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

func (*ActivateAuthRequest) MarshalTo 

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

func (*ActivateAuthRequest) ProtoMessage 

func (*ActivateAuthRequest) ProtoMessage()

func (*ActivateAuthRequest) Reset 

func (m *ActivateAuthRequest) Reset()

func (*ActivateAuthRequest) Size 

func (m *ActivateAuthRequest) Size() (n int)

func (*ActivateAuthRequest) String 

func (m *ActivateAuthRequest) String() string

func (*ActivateAuthRequest) Unmarshal 

func (m *ActivateAuthRequest) Unmarshal(dAtA []byte) error

func (*ActivateAuthRequest) XXX_DiscardUnknown 

func (m *ActivateAuthRequest) XXX_DiscardUnknown()

func (*ActivateAuthRequest) XXX_Marshal 

func (m *ActivateAuthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateAuthRequest) XXX_Merge 

func (dst *ActivateAuthRequest) XXX_Merge(src proto.Message)

func (*ActivateAuthRequest) XXX_Size 

func (m *ActivateAuthRequest) XXX_Size() int

func (*ActivateAuthRequest) XXX_Unmarshal 

func (m *ActivateAuthRequest) XXX_Unmarshal(b []byte) error

type ActivateAuthResponse 

type ActivateAuthResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateAuthResponse) Descriptor 

func (*ActivateAuthResponse) Descriptor() ([]byte, []int)

func (*ActivateAuthResponse) Marshal 

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

func (*ActivateAuthResponse) MarshalTo 

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

func (*ActivateAuthResponse) ProtoMessage 

func (*ActivateAuthResponse) ProtoMessage()

func (*ActivateAuthResponse) Reset 

func (m *ActivateAuthResponse) Reset()

func (*ActivateAuthResponse) Size 

func (m *ActivateAuthResponse) Size() (n int)

func (*ActivateAuthResponse) String 

func (m *ActivateAuthResponse) String() string

func (*ActivateAuthResponse) Unmarshal 

func (m *ActivateAuthResponse) Unmarshal(dAtA []byte) error

func (*ActivateAuthResponse) XXX_DiscardUnknown 

func (m *ActivateAuthResponse) XXX_DiscardUnknown()

func (*ActivateAuthResponse) XXX_Marshal 

func (m *ActivateAuthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateAuthResponse) XXX_Merge 

func (dst *ActivateAuthResponse) XXX_Merge(src proto.Message)

func (*ActivateAuthResponse) XXX_Size 

func (m *ActivateAuthResponse) XXX_Size() int

func (*ActivateAuthResponse) XXX_Unmarshal 

func (m *ActivateAuthResponse) XXX_Unmarshal(b []byte) error

type Aggregate 

type Aggregate struct {
	Count                 int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Mean                  float64  `protobuf:"fixed64,2,opt,name=mean,proto3" json:"mean,omitempty"`
	Stddev                float64  `protobuf:"fixed64,3,opt,name=stddev,proto3" json:"stddev,omitempty"`
	FifthPercentile       float64  `protobuf:"fixed64,4,opt,name=fifth_percentile,json=fifthPercentile,proto3" json:"fifth_percentile,omitempty"`
	NinetyFifthPercentile float64  `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*Aggregate) Descriptor 

func (*Aggregate) Descriptor() ([]byte, []int)

func (*Aggregate) GetCount 

func (m *Aggregate) GetCount() int64

func (*Aggregate) GetFifthPercentile 

func (m *Aggregate) GetFifthPercentile() float64

func (*Aggregate) GetMean 

func (m *Aggregate) GetMean() float64

func (*Aggregate) GetNinetyFifthPercentile 

func (m *Aggregate) GetNinetyFifthPercentile() float64

func (*Aggregate) GetStddev 

func (m *Aggregate) GetStddev() float64

func (*Aggregate) Marshal 

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

func (*Aggregate) MarshalTo 

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

func (*Aggregate) ProtoMessage 

func (*Aggregate) ProtoMessage()

func (*Aggregate) Reset 

func (m *Aggregate) Reset()

func (*Aggregate) Size 

func (m *Aggregate) Size() (n int)

func (*Aggregate) String 

func (m *Aggregate) String() string

func (*Aggregate) Unmarshal 

func (m *Aggregate) Unmarshal(dAtA []byte) error

func (*Aggregate) XXX_DiscardUnknown 

func (m *Aggregate) XXX_DiscardUnknown()

func (*Aggregate) XXX_Marshal 

func (m *Aggregate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Aggregate) XXX_Merge 

func (dst *Aggregate) XXX_Merge(src proto.Message)

func (*Aggregate) XXX_Size 

func (m *Aggregate) XXX_Size() int

func (*Aggregate) XXX_Unmarshal 

func (m *Aggregate) XXX_Unmarshal(b []byte) error

type AggregateProcessStats 

type AggregateProcessStats struct {
	DownloadTime         *Aggregate `protobuf:"bytes,1,opt,name=download_time,json=downloadTime,proto3" json:"download_time,omitempty"`
	ProcessTime          *Aggregate `protobuf:"bytes,2,opt,name=process_time,json=processTime,proto3" json:"process_time,omitempty"`
	UploadTime           *Aggregate `protobuf:"bytes,3,opt,name=upload_time,json=uploadTime,proto3" json:"upload_time,omitempty"`
	DownloadBytes        *Aggregate `protobuf:"bytes,4,opt,name=download_bytes,json=downloadBytes,proto3" json:"download_bytes,omitempty"`
	UploadBytes          *Aggregate `protobuf:"bytes,5,opt,name=upload_bytes,json=uploadBytes,proto3" json:"upload_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*AggregateProcessStats) Descriptor 

func (*AggregateProcessStats) Descriptor() ([]byte, []int)

func (*AggregateProcessStats) GetDownloadBytes 

func (m *AggregateProcessStats) GetDownloadBytes() *Aggregate

func (*AggregateProcessStats) GetDownloadTime 

func (m *AggregateProcessStats) GetDownloadTime() *Aggregate

func (*AggregateProcessStats) GetProcessTime 

func (m *AggregateProcessStats) GetProcessTime() *Aggregate

func (*AggregateProcessStats) GetUploadBytes 

func (m *AggregateProcessStats) GetUploadBytes() *Aggregate

func (*AggregateProcessStats) GetUploadTime 

func (m *AggregateProcessStats) GetUploadTime() *Aggregate

func (*AggregateProcessStats) Marshal 

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

func (*AggregateProcessStats) MarshalTo 

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

func (*AggregateProcessStats) ProtoMessage 

func (*AggregateProcessStats) ProtoMessage()

func (*AggregateProcessStats) Reset 

func (m *AggregateProcessStats) Reset()

func (*AggregateProcessStats) Size 

func (m *AggregateProcessStats) Size() (n int)

func (*AggregateProcessStats) String 

func (m *AggregateProcessStats) String() string

func (*AggregateProcessStats) Unmarshal 

func (m *AggregateProcessStats) Unmarshal(dAtA []byte) error

func (*AggregateProcessStats) XXX_DiscardUnknown 

func (m *AggregateProcessStats) XXX_DiscardUnknown()

func (*AggregateProcessStats) XXX_Marshal 

func (m *AggregateProcessStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggregateProcessStats) XXX_Merge 

func (dst *AggregateProcessStats) XXX_Merge(src proto.Message)

func (*AggregateProcessStats) XXX_Size 

func (m *AggregateProcessStats) XXX_Size() int

func (*AggregateProcessStats) XXX_Unmarshal 

func (m *AggregateProcessStats) XXX_Unmarshal(b []byte) error

type AtomInput 

type AtomInput struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Repo   string `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Branch string `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"`
	Commit string `protobuf:"bytes,4,opt,name=commit,proto3" json:"commit,omitempty"`
	Glob   string `protobuf:"bytes,5,opt,name=glob,proto3" json:"glob,omitempty"`
	Lazy   bool   `protobuf:"varint,6,opt,name=lazy,proto3" json:"lazy,omitempty"`
	// EmptyFiles, if true, will cause files from this atom to be presented as
	// empty files. This is useful in shuffle pipelines where you want to read
	// the names of files and reorganize them using symlinks.
	EmptyFiles           bool     `protobuf:"varint,8,opt,name=empty_files,json=emptyFiles,proto3" json:"empty_files,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AtomInput) Descriptor 

func (*AtomInput) Descriptor() ([]byte, []int)

func (*AtomInput) GetBranch 

func (m *AtomInput) GetBranch() string

func (*AtomInput) GetCommit 

func (m *AtomInput) GetCommit() string

func (*AtomInput) GetEmptyFiles 

func (m *AtomInput) GetEmptyFiles() bool

func (*AtomInput) GetGlob 

func (m *AtomInput) GetGlob() string

func (*AtomInput) GetLazy 

func (m *AtomInput) GetLazy() bool

func (*AtomInput) GetName 

func (m *AtomInput) GetName() string

func (*AtomInput) GetRepo 

func (m *AtomInput) GetRepo() string

func (*AtomInput) Marshal 

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

func (*AtomInput) MarshalTo 

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

func (*AtomInput) ProtoMessage 

func (*AtomInput) ProtoMessage()

func (*AtomInput) Reset 

func (m *AtomInput) Reset()

func (*AtomInput) Size 

func (m *AtomInput) Size() (n int)

func (*AtomInput) String 

func (m *AtomInput) String() string

func (*AtomInput) Unmarshal 

func (m *AtomInput) Unmarshal(dAtA []byte) error

func (*AtomInput) XXX_DiscardUnknown 

func (m *AtomInput) XXX_DiscardUnknown()

func (*AtomInput) XXX_Marshal 

func (m *AtomInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AtomInput) XXX_Merge 

func (dst *AtomInput) XXX_Merge(src proto.Message)

func (*AtomInput) XXX_Size 

func (m *AtomInput) XXX_Size() int

func (*AtomInput) XXX_Unmarshal 

func (m *AtomInput) XXX_Unmarshal(b []byte) error

type ChunkSpec 

type ChunkSpec struct {
	// number, if nonzero, specifies that each chunk should contain `number`
	// datums. Chunks may contain fewer if the total number of datums don't
	// divide evenly.
	Number int64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// size_bytes, if nonzero, specifies a target size for each chunk of datums.
	// Chunks may be larger or smaller than size_bytes, but will usually be
	// pretty close to size_bytes in size.
	SizeBytes            int64    `protobuf:"varint,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChunkSpec specifies how a pipeline should chunk its datums.

func (*ChunkSpec) Descriptor 

func (*ChunkSpec) Descriptor() ([]byte, []int)

func (*ChunkSpec) GetNumber 

func (m *ChunkSpec) GetNumber() int64

func (*ChunkSpec) GetSizeBytes 

func (m *ChunkSpec) GetSizeBytes() int64

func (*ChunkSpec) Marshal 

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

func (*ChunkSpec) MarshalTo 

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

func (*ChunkSpec) ProtoMessage 

func (*ChunkSpec) ProtoMessage()

func (*ChunkSpec) Reset 

func (m *ChunkSpec) Reset()

func (*ChunkSpec) Size 

func (m *ChunkSpec) Size() (n int)

func (*ChunkSpec) String 

func (m *ChunkSpec) String() string

func (*ChunkSpec) Unmarshal 

func (m *ChunkSpec) Unmarshal(dAtA []byte) error

func (*ChunkSpec) XXX_DiscardUnknown 

func (m *ChunkSpec) XXX_DiscardUnknown()

func (*ChunkSpec) XXX_Marshal 

func (m *ChunkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChunkSpec) XXX_Merge 

func (dst *ChunkSpec) XXX_Merge(src proto.Message)

func (*ChunkSpec) XXX_Size 

func (m *ChunkSpec) XXX_Size() int

func (*ChunkSpec) XXX_Unmarshal 

func (m *ChunkSpec) XXX_Unmarshal(b []byte) error

type CreateJobRequest 

type CreateJobRequest struct {
	Pipeline             *Pipeline   `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	OutputCommit         *pfs.Commit `protobuf:"bytes,25,opt,name=output_commit,json=outputCommit,proto3" json:"output_commit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CreateJobRequest) Descriptor 

func (*CreateJobRequest) Descriptor() ([]byte, []int)

func (*CreateJobRequest) GetOutputCommit 

func (m *CreateJobRequest) GetOutputCommit() *pfs.Commit

func (*CreateJobRequest) GetPipeline 

func (m *CreateJobRequest) GetPipeline() *Pipeline

func (*CreateJobRequest) Marshal 

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

func (*CreateJobRequest) MarshalTo 

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

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) Reset 

func (m *CreateJobRequest) Reset()

func (*CreateJobRequest) Size 

func (m *CreateJobRequest) Size() (n int)

func (*CreateJobRequest) String 

func (m *CreateJobRequest) String() string

func (*CreateJobRequest) Unmarshal 

func (m *CreateJobRequest) Unmarshal(dAtA []byte) error

func (*CreateJobRequest) XXX_DiscardUnknown 

func (m *CreateJobRequest) XXX_DiscardUnknown()

func (*CreateJobRequest) XXX_Marshal 

func (m *CreateJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateJobRequest) XXX_Merge 

func (dst *CreateJobRequest) XXX_Merge(src proto.Message)

func (*CreateJobRequest) XXX_Size 

func (m *CreateJobRequest) XXX_Size() int

func (*CreateJobRequest) XXX_Unmarshal 

func (m *CreateJobRequest) XXX_Unmarshal(b []byte) error

type CreatePipelineRequest 

type CreatePipelineRequest struct {
	Pipeline           *Pipeline        `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Transform          *Transform       `protobuf:"bytes,2,opt,name=transform,proto3" json:"transform,omitempty"`
	ParallelismSpec    *ParallelismSpec `protobuf:"bytes,7,opt,name=parallelism_spec,json=parallelismSpec,proto3" json:"parallelism_spec,omitempty"`
	HashtreeSpec       *HashtreeSpec    `protobuf:"bytes,31,opt,name=hashtree_spec,json=hashtreeSpec,proto3" json:"hashtree_spec,omitempty"`
	Egress             *Egress          `protobuf:"bytes,9,opt,name=egress,proto3" json:"egress,omitempty"`
	Update             bool             `protobuf:"varint,5,opt,name=update,proto3" json:"update,omitempty"`
	OutputBranch       string           `protobuf:"bytes,10,opt,name=output_branch,json=outputBranch,proto3" json:"output_branch,omitempty"`
	ScaleDownThreshold *types.Duration  `protobuf:"bytes,11,opt,name=scale_down_threshold,json=scaleDownThreshold,proto3" json:"scale_down_threshold,omitempty"`
	ResourceRequests   *ResourceSpec    `protobuf:"bytes,12,opt,name=resource_requests,json=resourceRequests,proto3" json:"resource_requests,omitempty"`
	ResourceLimits     *ResourceSpec    `protobuf:"bytes,22,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	Input              *Input           `protobuf:"bytes,13,opt,name=input,proto3" json:"input,omitempty"`
	Description        string           `protobuf:"bytes,14,opt,name=description,proto3" json:"description,omitempty"`
	Incremental        bool             `protobuf:"varint,15,opt,name=incremental,proto3" json:"incremental,omitempty"`
	CacheSize          string           `protobuf:"bytes,16,opt,name=cache_size,json=cacheSize,proto3" json:"cache_size,omitempty"`
	EnableStats        bool             `protobuf:"varint,17,opt,name=enable_stats,json=enableStats,proto3" json:"enable_stats,omitempty"`
	// Reprocess forces the pipeline to reprocess all datums.
	// It only has meaning if Update is true
	Reprocess            bool            `protobuf:"varint,18,opt,name=reprocess,proto3" json:"reprocess,omitempty"`
	Batch                bool            `protobuf:"varint,19,opt,name=batch,proto3" json:"batch,omitempty"`
	MaxQueueSize         int64           `protobuf:"varint,20,opt,name=max_queue_size,json=maxQueueSize,proto3" json:"max_queue_size,omitempty"`
	Service              *Service        `protobuf:"bytes,21,opt,name=service,proto3" json:"service,omitempty"`
	ChunkSpec            *ChunkSpec      `protobuf:"bytes,23,opt,name=chunk_spec,json=chunkSpec,proto3" json:"chunk_spec,omitempty"`
	DatumTimeout         *types.Duration `protobuf:"bytes,24,opt,name=datum_timeout,json=datumTimeout,proto3" json:"datum_timeout,omitempty"`
	JobTimeout           *types.Duration `protobuf:"bytes,25,opt,name=job_timeout,json=jobTimeout,proto3" json:"job_timeout,omitempty"`
	Salt                 string          `protobuf:"bytes,26,opt,name=salt,proto3" json:"salt,omitempty"`
	Standby              bool            `protobuf:"varint,27,opt,name=standby,proto3" json:"standby,omitempty"`
	DatumTries           int64           `protobuf:"varint,28,opt,name=datum_tries,json=datumTries,proto3" json:"datum_tries,omitempty"`
	SchedulingSpec       *SchedulingSpec `protobuf:"bytes,29,opt,name=scheduling_spec,json=schedulingSpec,proto3" json:"scheduling_spec,omitempty"`
	PodSpec              string          `protobuf:"bytes,30,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CreatePipelineRequest) Descriptor 

func (*CreatePipelineRequest) Descriptor() ([]byte, []int)

func (*CreatePipelineRequest) GetBatch 

func (m *CreatePipelineRequest) GetBatch() bool

func (*CreatePipelineRequest) GetCacheSize 

func (m *CreatePipelineRequest) GetCacheSize() string

func (*CreatePipelineRequest) GetChunkSpec 

func (m *CreatePipelineRequest) GetChunkSpec() *ChunkSpec

func (*CreatePipelineRequest) GetDatumTimeout 

func (m *CreatePipelineRequest) GetDatumTimeout() *types.Duration

func (*CreatePipelineRequest) GetDatumTries 

func (m *CreatePipelineRequest) GetDatumTries() int64

func (*CreatePipelineRequest) GetDescription 

func (m *CreatePipelineRequest) GetDescription() string

func (*CreatePipelineRequest) GetEgress 

func (m *CreatePipelineRequest) GetEgress() *Egress

func (*CreatePipelineRequest) GetEnableStats 

func (m *CreatePipelineRequest) GetEnableStats() bool

func (*CreatePipelineRequest) GetHashtreeSpec 

func (m *CreatePipelineRequest) GetHashtreeSpec() *HashtreeSpec

func (*CreatePipelineRequest) GetIncremental 

func (m *CreatePipelineRequest) GetIncremental() bool

func (*CreatePipelineRequest) GetInput 

func (m *CreatePipelineRequest) GetInput() *Input

func (*CreatePipelineRequest) GetJobTimeout 

func (m *CreatePipelineRequest) GetJobTimeout() *types.Duration

func (*CreatePipelineRequest) GetMaxQueueSize 

func (m *CreatePipelineRequest) GetMaxQueueSize() int64

func (*CreatePipelineRequest) GetOutputBranch 

func (m *CreatePipelineRequest) GetOutputBranch() string

func (*CreatePipelineRequest) GetParallelismSpec 

func (m *CreatePipelineRequest) GetParallelismSpec() *ParallelismSpec

func (*CreatePipelineRequest) GetPipeline 

func (m *CreatePipelineRequest) GetPipeline() *Pipeline

func (*CreatePipelineRequest) GetPodSpec 

func (m *CreatePipelineRequest) GetPodSpec() string

func (*CreatePipelineRequest) GetReprocess 

func (m *CreatePipelineRequest) GetReprocess() bool

func (*CreatePipelineRequest) GetResourceLimits 

func (m *CreatePipelineRequest) GetResourceLimits() *ResourceSpec

func (*CreatePipelineRequest) GetResourceRequests 

func (m *CreatePipelineRequest) GetResourceRequests() *ResourceSpec

func (*CreatePipelineRequest) GetSalt 

func (m *CreatePipelineRequest) GetSalt() string

func (*CreatePipelineRequest) GetScaleDownThreshold 

func (m *CreatePipelineRequest) GetScaleDownThreshold() *types.Duration

func (*CreatePipelineRequest) GetSchedulingSpec 

func (m *CreatePipelineRequest) GetSchedulingSpec() *SchedulingSpec

func (*CreatePipelineRequest) GetService 

func (m *CreatePipelineRequest) GetService() *Service

func (*CreatePipelineRequest) GetStandby 

func (m *CreatePipelineRequest) GetStandby() bool

func (*CreatePipelineRequest) GetTransform 

func (m *CreatePipelineRequest) GetTransform() *Transform

func (*CreatePipelineRequest) GetUpdate 

func (m *CreatePipelineRequest) GetUpdate() bool

func (*CreatePipelineRequest) Marshal 

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

func (*CreatePipelineRequest) MarshalTo 

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

func (*CreatePipelineRequest) ProtoMessage 

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) Reset 

func (m *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) Size 

func (m *CreatePipelineRequest) Size() (n int)

func (*CreatePipelineRequest) String 

func (m *CreatePipelineRequest) String() string

func (*CreatePipelineRequest) Unmarshal 

func (m *CreatePipelineRequest) Unmarshal(dAtA []byte) error

func (*CreatePipelineRequest) XXX_DiscardUnknown 

func (m *CreatePipelineRequest) XXX_DiscardUnknown()

func (*CreatePipelineRequest) XXX_Marshal 

func (m *CreatePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreatePipelineRequest) XXX_Merge 

func (dst *CreatePipelineRequest) XXX_Merge(src proto.Message)

func (*CreatePipelineRequest) XXX_Size 

func (m *CreatePipelineRequest) XXX_Size() int

func (*CreatePipelineRequest) XXX_Unmarshal 

func (m *CreatePipelineRequest) XXX_Unmarshal(b []byte) error

type CronInput 

type CronInput struct {
	Name                 string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Repo                 string           `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Commit               string           `protobuf:"bytes,3,opt,name=commit,proto3" json:"commit,omitempty"`
	Spec                 string           `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	Start                *types.Timestamp `protobuf:"bytes,5,opt,name=start,proto3" json:"start,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CronInput) Descriptor 

func (*CronInput) Descriptor() ([]byte, []int)

func (*CronInput) GetCommit 

func (m *CronInput) GetCommit() string

func (*CronInput) GetName 

func (m *CronInput) GetName() string

func (*CronInput) GetRepo 

func (m *CronInput) GetRepo() string

func (*CronInput) GetSpec 

func (m *CronInput) GetSpec() string

func (*CronInput) GetStart 

func (m *CronInput) GetStart() *types.Timestamp

func (*CronInput) Marshal 

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

func (*CronInput) MarshalTo 

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

func (*CronInput) ProtoMessage 

func (*CronInput) ProtoMessage()

func (*CronInput) Reset 

func (m *CronInput) Reset()

func (*CronInput) Size 

func (m *CronInput) Size() (n int)

func (*CronInput) String 

func (m *CronInput) String() string

func (*CronInput) Unmarshal 

func (m *CronInput) Unmarshal(dAtA []byte) error

func (*CronInput) XXX_DiscardUnknown 

func (m *CronInput) XXX_DiscardUnknown()

func (*CronInput) XXX_Marshal 

func (m *CronInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CronInput) XXX_Merge 

func (dst *CronInput) XXX_Merge(src proto.Message)

func (*CronInput) XXX_Size 

func (m *CronInput) XXX_Size() int

func (*CronInput) XXX_Unmarshal 

func (m *CronInput) XXX_Unmarshal(b []byte) error

type Datum 

type Datum struct {
	// ID is the hash computed from all the files
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Job                  *Job     `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Datum) Descriptor 

func (*Datum) Descriptor() ([]byte, []int)

func (*Datum) GetID 

func (m *Datum) GetID() string

func (*Datum) GetJob 

func (m *Datum) GetJob() *Job

func (*Datum) Marshal 

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

func (*Datum) MarshalTo 

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

func (*Datum) ProtoMessage 

func (*Datum) ProtoMessage()

func (*Datum) Reset 

func (m *Datum) Reset()

func (*Datum) Size 

func (m *Datum) Size() (n int)

func (*Datum) String 

func (m *Datum) String() string

func (*Datum) Unmarshal 

func (m *Datum) Unmarshal(dAtA []byte) error

func (*Datum) XXX_DiscardUnknown 

func (m *Datum) XXX_DiscardUnknown()

func (*Datum) XXX_Marshal 

func (m *Datum) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Datum) XXX_Merge 

func (dst *Datum) XXX_Merge(src proto.Message)

func (*Datum) XXX_Size 

func (m *Datum) XXX_Size() int

func (*Datum) XXX_Unmarshal 

func (m *Datum) XXX_Unmarshal(b []byte) error

type DatumInfo 

type DatumInfo struct {
	Datum                *Datum          `protobuf:"bytes,1,opt,name=datum,proto3" json:"datum,omitempty"`
	State                DatumState      `protobuf:"varint,2,opt,name=state,proto3,enum=pps_1_7.DatumState" json:"state,omitempty"`
	Stats                *ProcessStats   `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	PfsState             *pfs.File       `protobuf:"bytes,4,opt,name=pfs_state,json=pfsState,proto3" json:"pfs_state,omitempty"`
	Data                 []*pfs.FileInfo `protobuf:"bytes,5,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*DatumInfo) Descriptor 

func (*DatumInfo) Descriptor() ([]byte, []int)

func (*DatumInfo) GetData 

func (m *DatumInfo) GetData() []*pfs.FileInfo

func (*DatumInfo) GetDatum 

func (m *DatumInfo) GetDatum() *Datum

func (*DatumInfo) GetPfsState 

func (m *DatumInfo) GetPfsState() *pfs.File

func (*DatumInfo) GetState 

func (m *DatumInfo) GetState() DatumState

func (*DatumInfo) GetStats 

func (m *DatumInfo) GetStats() *ProcessStats

func (*DatumInfo) Marshal 

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

func (*DatumInfo) MarshalTo 

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

func (*DatumInfo) ProtoMessage 

func (*DatumInfo) ProtoMessage()

func (*DatumInfo) Reset 

func (m *DatumInfo) Reset()

func (*DatumInfo) Size 

func (m *DatumInfo) Size() (n int)

func (*DatumInfo) String 

func (m *DatumInfo) String() string

func (*DatumInfo) Unmarshal 

func (m *DatumInfo) Unmarshal(dAtA []byte) error

func (*DatumInfo) XXX_DiscardUnknown 

func (m *DatumInfo) XXX_DiscardUnknown()

func (*DatumInfo) XXX_Marshal 

func (m *DatumInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatumInfo) XXX_Merge 

func (dst *DatumInfo) XXX_Merge(src proto.Message)

func (*DatumInfo) XXX_Size 

func (m *DatumInfo) XXX_Size() int

func (*DatumInfo) XXX_Unmarshal 

func (m *DatumInfo) XXX_Unmarshal(b []byte) error

type DatumState 

type DatumState int32
const (
	DatumState_FAILED   DatumState = 0
	DatumState_SUCCESS  DatumState = 1
	DatumState_SKIPPED  DatumState = 2
	DatumState_STARTING DatumState = 3
)

func (DatumState) EnumDescriptor 

func (DatumState) EnumDescriptor() ([]byte, []int)

func (DatumState) String 

func (x DatumState) String() string

type DeleteJobRequest 

type DeleteJobRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteJobRequest) Descriptor 

func (*DeleteJobRequest) Descriptor() ([]byte, []int)

func (*DeleteJobRequest) GetJob 

func (m *DeleteJobRequest) GetJob() *Job

func (*DeleteJobRequest) Marshal 

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

func (*DeleteJobRequest) MarshalTo 

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

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) Reset 

func (m *DeleteJobRequest) Reset()

func (*DeleteJobRequest) Size 

func (m *DeleteJobRequest) Size() (n int)

func (*DeleteJobRequest) String 

func (m *DeleteJobRequest) String() string

func (*DeleteJobRequest) Unmarshal 

func (m *DeleteJobRequest) Unmarshal(dAtA []byte) error

func (*DeleteJobRequest) XXX_DiscardUnknown 

func (m *DeleteJobRequest) XXX_DiscardUnknown()

func (*DeleteJobRequest) XXX_Marshal 

func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteJobRequest) XXX_Merge 

func (dst *DeleteJobRequest) XXX_Merge(src proto.Message)

func (*DeleteJobRequest) XXX_Size 

func (m *DeleteJobRequest) XXX_Size() int

func (*DeleteJobRequest) XXX_Unmarshal 

func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error

type DeletePipelineRequest 

type DeletePipelineRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	All                  bool      `protobuf:"varint,4,opt,name=all,proto3" json:"all,omitempty"`
	Force                bool      `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeletePipelineRequest) Descriptor 

func (*DeletePipelineRequest) Descriptor() ([]byte, []int)

func (*DeletePipelineRequest) GetAll 

func (m *DeletePipelineRequest) GetAll() bool

func (*DeletePipelineRequest) GetForce 

func (m *DeletePipelineRequest) GetForce() bool

func (*DeletePipelineRequest) GetPipeline 

func (m *DeletePipelineRequest) GetPipeline() *Pipeline

func (*DeletePipelineRequest) Marshal 

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

func (*DeletePipelineRequest) MarshalTo 

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

func (*DeletePipelineRequest) ProtoMessage 

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) Reset 

func (m *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) Size 

func (m *DeletePipelineRequest) Size() (n int)

func (*DeletePipelineRequest) String 

func (m *DeletePipelineRequest) String() string

func (*DeletePipelineRequest) Unmarshal 

func (m *DeletePipelineRequest) Unmarshal(dAtA []byte) error

func (*DeletePipelineRequest) XXX_DiscardUnknown 

func (m *DeletePipelineRequest) XXX_DiscardUnknown()

func (*DeletePipelineRequest) XXX_Marshal 

func (m *DeletePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePipelineRequest) XXX_Merge 

func (dst *DeletePipelineRequest) XXX_Merge(src proto.Message)

func (*DeletePipelineRequest) XXX_Size 

func (m *DeletePipelineRequest) XXX_Size() int

func (*DeletePipelineRequest) XXX_Unmarshal 

func (m *DeletePipelineRequest) XXX_Unmarshal(b []byte) error

type Egress 

type Egress struct {
	URL                  string   `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Egress) Descriptor 

func (*Egress) Descriptor() ([]byte, []int)

func (*Egress) GetURL 

func (m *Egress) GetURL() string

func (*Egress) Marshal 

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

func (*Egress) MarshalTo 

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

func (*Egress) ProtoMessage 

func (*Egress) ProtoMessage()

func (*Egress) Reset 

func (m *Egress) Reset()

func (*Egress) Size 

func (m *Egress) Size() (n int)

func (*Egress) String 

func (m *Egress) String() string

func (*Egress) Unmarshal 

func (m *Egress) Unmarshal(dAtA []byte) error

func (*Egress) XXX_DiscardUnknown 

func (m *Egress) XXX_DiscardUnknown()

func (*Egress) XXX_Marshal 

func (m *Egress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Egress) XXX_Merge 

func (dst *Egress) XXX_Merge(src proto.Message)

func (*Egress) XXX_Size 

func (m *Egress) XXX_Size() int

func (*Egress) XXX_Unmarshal 

func (m *Egress) XXX_Unmarshal(b []byte) error

type EtcdJobInfo 

type EtcdJobInfo struct {
	Job          *Job        `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Pipeline     *Pipeline   `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	OutputCommit *pfs.Commit `protobuf:"bytes,3,opt,name=output_commit,json=outputCommit,proto3" json:"output_commit,omitempty"`
	// Job restart count (e.g. due to datum failure)
	Restart uint64 `protobuf:"varint,4,opt,name=restart,proto3" json:"restart,omitempty"`
	// Counts of how many times we processed or skipped a datum
	DataProcessed int64 `protobuf:"varint,5,opt,name=data_processed,json=dataProcessed,proto3" json:"data_processed,omitempty"`
	DataSkipped   int64 `protobuf:"varint,6,opt,name=data_skipped,json=dataSkipped,proto3" json:"data_skipped,omitempty"`
	DataTotal     int64 `protobuf:"varint,7,opt,name=data_total,json=dataTotal,proto3" json:"data_total,omitempty"`
	DataFailed    int64 `protobuf:"varint,8,opt,name=data_failed,json=dataFailed,proto3" json:"data_failed,omitempty"`
	// Download/process/upload time and download/upload bytes
	Stats                *ProcessStats    `protobuf:"bytes,9,opt,name=stats,proto3" json:"stats,omitempty"`
	StatsCommit          *pfs.Commit      `protobuf:"bytes,10,opt,name=stats_commit,json=statsCommit,proto3" json:"stats_commit,omitempty"`
	State                JobState         `protobuf:"varint,11,opt,name=state,proto3,enum=pps_1_7.JobState" json:"state,omitempty"`
	Reason               string           `protobuf:"bytes,12,opt,name=reason,proto3" json:"reason,omitempty"`
	Started              *types.Timestamp `protobuf:"bytes,13,opt,name=started,proto3" json:"started,omitempty"`
	Finished             *types.Timestamp `protobuf:"bytes,14,opt,name=finished,proto3" json:"finished,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

EtcdJobInfo is the portion of the JobInfo that gets stored in etcd during job execution. It contains fields which change over the lifetime of the job but aren't used in the execution of the job.

func (*EtcdJobInfo) Descriptor 

func (*EtcdJobInfo) Descriptor() ([]byte, []int)

func (*EtcdJobInfo) GetDataFailed 

func (m *EtcdJobInfo) GetDataFailed() int64

func (*EtcdJobInfo) GetDataProcessed 

func (m *EtcdJobInfo) GetDataProcessed() int64

func (*EtcdJobInfo) GetDataSkipped 

func (m *EtcdJobInfo) GetDataSkipped() int64

func (*EtcdJobInfo) GetDataTotal 

func (m *EtcdJobInfo) GetDataTotal() int64

func (*EtcdJobInfo) GetFinished 

func (m *EtcdJobInfo) GetFinished() *types.Timestamp

func (*EtcdJobInfo) GetJob 

func (m *EtcdJobInfo) GetJob() *Job

func (*EtcdJobInfo) GetOutputCommit 

func (m *EtcdJobInfo) GetOutputCommit() *pfs.Commit

func (*EtcdJobInfo) GetPipeline 

func (m *EtcdJobInfo) GetPipeline() *Pipeline

func (*EtcdJobInfo) GetReason 

func (m *EtcdJobInfo) GetReason() string

func (*EtcdJobInfo) GetRestart 

func (m *EtcdJobInfo) GetRestart() uint64

func (*EtcdJobInfo) GetStarted 

func (m *EtcdJobInfo) GetStarted() *types.Timestamp

func (*EtcdJobInfo) GetState 

func (m *EtcdJobInfo) GetState() JobState

func (*EtcdJobInfo) GetStats 

func (m *EtcdJobInfo) GetStats() *ProcessStats

func (*EtcdJobInfo) GetStatsCommit 

func (m *EtcdJobInfo) GetStatsCommit() *pfs.Commit

func (*EtcdJobInfo) Marshal 

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

func (*EtcdJobInfo) MarshalTo 

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

func (*EtcdJobInfo) ProtoMessage 

func (*EtcdJobInfo) ProtoMessage()

func (*EtcdJobInfo) Reset 

func (m *EtcdJobInfo) Reset()

func (*EtcdJobInfo) Size 

func (m *EtcdJobInfo) Size() (n int)

func (*EtcdJobInfo) String 

func (m *EtcdJobInfo) String() string

func (*EtcdJobInfo) Unmarshal 

func (m *EtcdJobInfo) Unmarshal(dAtA []byte) error

func (*EtcdJobInfo) XXX_DiscardUnknown 

func (m *EtcdJobInfo) XXX_DiscardUnknown()

func (*EtcdJobInfo) XXX_Marshal 

func (m *EtcdJobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EtcdJobInfo) XXX_Merge 

func (dst *EtcdJobInfo) XXX_Merge(src proto.Message)

func (*EtcdJobInfo) XXX_Size 

func (m *EtcdJobInfo) XXX_Size() int

func (*EtcdJobInfo) XXX_Unmarshal 

func (m *EtcdJobInfo) XXX_Unmarshal(b []byte) error

type EtcdPipelineInfo 

type EtcdPipelineInfo struct {
	State                PipelineState   `protobuf:"varint,1,opt,name=state,proto3,enum=pps_1_7.PipelineState" json:"state,omitempty"`
	Reason               string          `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	SpecCommit           *pfs.Commit     `protobuf:"bytes,2,opt,name=spec_commit,json=specCommit,proto3" json:"spec_commit,omitempty"`
	JobCounts            map[int32]int32 `` /* 178-byte string literal not displayed */
	AuthToken            string          `protobuf:"bytes,5,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

EtcdPipelineInfo is proto that Pachd stores in etcd for each pipeline. It tracks the state of the pipeline, and points to its metadata in PFS (and, by pointing to a PFS commit, de facto tracks the pipeline's version)

func (*EtcdPipelineInfo) Descriptor 

func (*EtcdPipelineInfo) Descriptor() ([]byte, []int)

func (*EtcdPipelineInfo) GetAuthToken 

func (m *EtcdPipelineInfo) GetAuthToken() string

func (*EtcdPipelineInfo) GetJobCounts 

func (m *EtcdPipelineInfo) GetJobCounts() map[int32]int32

func (*EtcdPipelineInfo) GetReason 

func (m *EtcdPipelineInfo) GetReason() string

func (*EtcdPipelineInfo) GetSpecCommit 

func (m *EtcdPipelineInfo) GetSpecCommit() *pfs.Commit

func (*EtcdPipelineInfo) GetState 

func (m *EtcdPipelineInfo) GetState() PipelineState

func (*EtcdPipelineInfo) Marshal 

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

func (*EtcdPipelineInfo) MarshalTo 

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

func (*EtcdPipelineInfo) ProtoMessage 

func (*EtcdPipelineInfo) ProtoMessage()

func (*EtcdPipelineInfo) Reset 

func (m *EtcdPipelineInfo) Reset()

func (*EtcdPipelineInfo) Size 

func (m *EtcdPipelineInfo) Size() (n int)

func (*EtcdPipelineInfo) String 

func (m *EtcdPipelineInfo) String() string

func (*EtcdPipelineInfo) Unmarshal 

func (m *EtcdPipelineInfo) Unmarshal(dAtA []byte) error

func (*EtcdPipelineInfo) XXX_DiscardUnknown 

func (m *EtcdPipelineInfo) XXX_DiscardUnknown()

func (*EtcdPipelineInfo) XXX_Marshal 

func (m *EtcdPipelineInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EtcdPipelineInfo) XXX_Merge 

func (dst *EtcdPipelineInfo) XXX_Merge(src proto.Message)

func (*EtcdPipelineInfo) XXX_Size 

func (m *EtcdPipelineInfo) XXX_Size() int

func (*EtcdPipelineInfo) XXX_Unmarshal 

func (m *EtcdPipelineInfo) XXX_Unmarshal(b []byte) error

type FlushJobRequest 

type FlushJobRequest struct {
	Commits              []*pfs.Commit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
	ToPipelines          []*Pipeline   `protobuf:"bytes,2,rep,name=to_pipelines,json=toPipelines,proto3" json:"to_pipelines,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*FlushJobRequest) Descriptor 

func (*FlushJobRequest) Descriptor() ([]byte, []int)

func (*FlushJobRequest) GetCommits 

func (m *FlushJobRequest) GetCommits() []*pfs.Commit

func (*FlushJobRequest) GetToPipelines 

func (m *FlushJobRequest) GetToPipelines() []*Pipeline

func (*FlushJobRequest) Marshal 

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

func (*FlushJobRequest) MarshalTo 

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

func (*FlushJobRequest) ProtoMessage 

func (*FlushJobRequest) ProtoMessage()

func (*FlushJobRequest) Reset 

func (m *FlushJobRequest) Reset()

func (*FlushJobRequest) Size 

func (m *FlushJobRequest) Size() (n int)

func (*FlushJobRequest) String 

func (m *FlushJobRequest) String() string

func (*FlushJobRequest) Unmarshal 

func (m *FlushJobRequest) Unmarshal(dAtA []byte) error

func (*FlushJobRequest) XXX_DiscardUnknown 

func (m *FlushJobRequest) XXX_DiscardUnknown()

func (*FlushJobRequest) XXX_Marshal 

func (m *FlushJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushJobRequest) XXX_Merge 

func (dst *FlushJobRequest) XXX_Merge(src proto.Message)

func (*FlushJobRequest) XXX_Size 

func (m *FlushJobRequest) XXX_Size() int

func (*FlushJobRequest) XXX_Unmarshal 

func (m *FlushJobRequest) XXX_Unmarshal(b []byte) error

type GarbageCollectRequest 

type GarbageCollectRequest struct {
	// Memory is how much memory to use in computing which objects are alive. A
	// larger number will result in more precise garbage collection (at the
	// cost of more memory usage).
	MemoryBytes          int64    `protobuf:"varint,1,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GarbageCollectRequest) Descriptor 

func (*GarbageCollectRequest) Descriptor() ([]byte, []int)

func (*GarbageCollectRequest) GetMemoryBytes 

func (m *GarbageCollectRequest) GetMemoryBytes() int64

func (*GarbageCollectRequest) Marshal 

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

func (*GarbageCollectRequest) MarshalTo 

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

func (*GarbageCollectRequest) ProtoMessage 

func (*GarbageCollectRequest) ProtoMessage()

func (*GarbageCollectRequest) Reset 

func (m *GarbageCollectRequest) Reset()

func (*GarbageCollectRequest) Size 

func (m *GarbageCollectRequest) Size() (n int)

func (*GarbageCollectRequest) String 

func (m *GarbageCollectRequest) String() string

func (*GarbageCollectRequest) Unmarshal 

func (m *GarbageCollectRequest) Unmarshal(dAtA []byte) error

func (*GarbageCollectRequest) XXX_DiscardUnknown 

func (m *GarbageCollectRequest) XXX_DiscardUnknown()

func (*GarbageCollectRequest) XXX_Marshal 

func (m *GarbageCollectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GarbageCollectRequest) XXX_Merge 

func (dst *GarbageCollectRequest) XXX_Merge(src proto.Message)

func (*GarbageCollectRequest) XXX_Size 

func (m *GarbageCollectRequest) XXX_Size() int

func (*GarbageCollectRequest) XXX_Unmarshal 

func (m *GarbageCollectRequest) XXX_Unmarshal(b []byte) error

type GarbageCollectResponse 

type GarbageCollectResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GarbageCollectResponse) Descriptor 

func (*GarbageCollectResponse) Descriptor() ([]byte, []int)

func (*GarbageCollectResponse) Marshal 

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

func (*GarbageCollectResponse) MarshalTo 

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

func (*GarbageCollectResponse) ProtoMessage 

func (*GarbageCollectResponse) ProtoMessage()

func (*GarbageCollectResponse) Reset 

func (m *GarbageCollectResponse) Reset()

func (*GarbageCollectResponse) Size 

func (m *GarbageCollectResponse) Size() (n int)

func (*GarbageCollectResponse) String 

func (m *GarbageCollectResponse) String() string

func (*GarbageCollectResponse) Unmarshal 

func (m *GarbageCollectResponse) Unmarshal(dAtA []byte) error

func (*GarbageCollectResponse) XXX_DiscardUnknown 

func (m *GarbageCollectResponse) XXX_DiscardUnknown()

func (*GarbageCollectResponse) XXX_Marshal 

func (m *GarbageCollectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GarbageCollectResponse) XXX_Merge 

func (dst *GarbageCollectResponse) XXX_Merge(src proto.Message)

func (*GarbageCollectResponse) XXX_Size 

func (m *GarbageCollectResponse) XXX_Size() int

func (*GarbageCollectResponse) XXX_Unmarshal 

func (m *GarbageCollectResponse) XXX_Unmarshal(b []byte) error

type GetLogsRequest 

type GetLogsRequest struct {
	// The pipeline from which we want to get logs (required if the job in 'job'
	// was created as part of a pipeline. To get logs from a non-orphan job
	// without the pipeline that created it, you need to use ElasticSearch).
	Pipeline *Pipeline `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// The job from which we want to get logs.
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// Names of input files from which we want processing logs. This may contain
	// multiple files, to query pipelines that contain multiple inputs. Each
	// filter may be an absolute path of a file within a pps repo, or it may be
	// a hash for that file (to search for files at specific versions)
	DataFilters []string `protobuf:"bytes,3,rep,name=data_filters,json=dataFilters,proto3" json:"data_filters,omitempty"`
	Datum       *Datum   `protobuf:"bytes,6,opt,name=datum,proto3" json:"datum,omitempty"`
	// If true get logs from the master process
	Master bool `protobuf:"varint,5,opt,name=master,proto3" json:"master,omitempty"`
	// Continue to follow new logs as they become available.
	Follow bool `protobuf:"varint,7,opt,name=follow,proto3" json:"follow,omitempty"`
	// If nonzero, the number of lines from the end of the logs to return.  Note:
	// tail applies per container, so you will get tail * <number of pods> total
	// lines back.
	Tail                 int64    `protobuf:"varint,8,opt,name=tail,proto3" json:"tail,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetLogsRequest) Descriptor 

func (*GetLogsRequest) Descriptor() ([]byte, []int)

func (*GetLogsRequest) GetDataFilters 

func (m *GetLogsRequest) GetDataFilters() []string

func (*GetLogsRequest) GetDatum 

func (m *GetLogsRequest) GetDatum() *Datum

func (*GetLogsRequest) GetFollow 

func (m *GetLogsRequest) GetFollow() bool

func (*GetLogsRequest) GetJob 

func (m *GetLogsRequest) GetJob() *Job

func (*GetLogsRequest) GetMaster 

func (m *GetLogsRequest) GetMaster() bool

func (*GetLogsRequest) GetPipeline 

func (m *GetLogsRequest) GetPipeline() *Pipeline

func (*GetLogsRequest) GetTail 

func (m *GetLogsRequest) GetTail() int64

func (*GetLogsRequest) Marshal 

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

func (*GetLogsRequest) MarshalTo 

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

func (*GetLogsRequest) ProtoMessage 

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) Reset 

func (m *GetLogsRequest) Reset()

func (*GetLogsRequest) Size 

func (m *GetLogsRequest) Size() (n int)

func (*GetLogsRequest) String 

func (m *GetLogsRequest) String() string

func (*GetLogsRequest) Unmarshal 

func (m *GetLogsRequest) Unmarshal(dAtA []byte) error

func (*GetLogsRequest) XXX_DiscardUnknown 

func (m *GetLogsRequest) XXX_DiscardUnknown()

func (*GetLogsRequest) XXX_Marshal 

func (m *GetLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLogsRequest) XXX_Merge 

func (dst *GetLogsRequest) XXX_Merge(src proto.Message)

func (*GetLogsRequest) XXX_Size 

func (m *GetLogsRequest) XXX_Size() int

func (*GetLogsRequest) XXX_Unmarshal 

func (m *GetLogsRequest) XXX_Unmarshal(b []byte) error

type GitInput 

type GitInput struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	URL                  string   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Branch               string   `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"`
	Commit               string   `protobuf:"bytes,4,opt,name=commit,proto3" json:"commit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GitInput) Descriptor 

func (*GitInput) Descriptor() ([]byte, []int)

func (*GitInput) GetBranch 

func (m *GitInput) GetBranch() string

func (*GitInput) GetCommit 

func (m *GitInput) GetCommit() string

func (*GitInput) GetName 

func (m *GitInput) GetName() string

func (*GitInput) GetURL 

func (m *GitInput) GetURL() string

func (*GitInput) Marshal 

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

func (*GitInput) MarshalTo 

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

func (*GitInput) ProtoMessage 

func (*GitInput) ProtoMessage()

func (*GitInput) Reset 

func (m *GitInput) Reset()

func (*GitInput) Size 

func (m *GitInput) Size() (n int)

func (*GitInput) String 

func (m *GitInput) String() string

func (*GitInput) Unmarshal 

func (m *GitInput) Unmarshal(dAtA []byte) error

func (*GitInput) XXX_DiscardUnknown 

func (m *GitInput) XXX_DiscardUnknown()

func (*GitInput) XXX_Marshal 

func (m *GitInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GitInput) XXX_Merge 

func (dst *GitInput) XXX_Merge(src proto.Message)

func (*GitInput) XXX_Size 

func (m *GitInput) XXX_Size() int

func (*GitInput) XXX_Unmarshal 

func (m *GitInput) XXX_Unmarshal(b []byte) error

type HashtreeSpec 

type HashtreeSpec struct {
	Constant             uint64   `protobuf:"varint,1,opt,name=constant,proto3" json:"constant,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

HashTreeSpec sets the number of shards into which pps splits a pipeline's output commits (sharded commits are implemented in Pachyderm 1.8+ only)

func (*HashtreeSpec) Descriptor 

func (*HashtreeSpec) Descriptor() ([]byte, []int)

func (*HashtreeSpec) GetConstant 

func (m *HashtreeSpec) GetConstant() uint64

func (*HashtreeSpec) Marshal 

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

func (*HashtreeSpec) MarshalTo 

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

func (*HashtreeSpec) ProtoMessage 

func (*HashtreeSpec) ProtoMessage()

func (*HashtreeSpec) Reset 

func (m *HashtreeSpec) Reset()

func (*HashtreeSpec) Size 

func (m *HashtreeSpec) Size() (n int)

func (*HashtreeSpec) String 

func (m *HashtreeSpec) String() string

func (*HashtreeSpec) Unmarshal 

func (m *HashtreeSpec) Unmarshal(dAtA []byte) error

func (*HashtreeSpec) XXX_DiscardUnknown 

func (m *HashtreeSpec) XXX_DiscardUnknown()

func (*HashtreeSpec) XXX_Marshal 

func (m *HashtreeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HashtreeSpec) XXX_Merge 

func (dst *HashtreeSpec) XXX_Merge(src proto.Message)

func (*HashtreeSpec) XXX_Size 

func (m *HashtreeSpec) XXX_Size() int

func (*HashtreeSpec) XXX_Unmarshal 

func (m *HashtreeSpec) XXX_Unmarshal(b []byte) error

type Input 

type Input struct {
	Atom                 *AtomInput `protobuf:"bytes,1,opt,name=atom,proto3" json:"atom,omitempty"`
	Cross                []*Input   `protobuf:"bytes,2,rep,name=cross,proto3" json:"cross,omitempty"`
	Union                []*Input   `protobuf:"bytes,3,rep,name=union,proto3" json:"union,omitempty"`
	Cron                 *CronInput `protobuf:"bytes,4,opt,name=cron,proto3" json:"cron,omitempty"`
	Git                  *GitInput  `protobuf:"bytes,5,opt,name=git,proto3" json:"git,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Input) Descriptor 

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

func (*Input) GetAtom 

func (m *Input) GetAtom() *AtomInput

func (*Input) GetCron 

func (m *Input) GetCron() *CronInput

func (*Input) GetCross 

func (m *Input) GetCross() []*Input

func (*Input) GetGit 

func (m *Input) GetGit() *GitInput

func (*Input) GetUnion 

func (m *Input) GetUnion() []*Input

func (*Input) Marshal 

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

func (*Input) MarshalTo 

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

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) Size 

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

func (*Input) String 

func (m *Input) String() string

func (*Input) Unmarshal 

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

func (*Input) XXX_DiscardUnknown 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal 

func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Input) XXX_Merge 

func (dst *Input) XXX_Merge(src proto.Message)

func (*Input) XXX_Size 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal 

func (m *Input) XXX_Unmarshal(b []byte) error

type InputFile 

type InputFile struct {
	// This file's absolute path within its pfs repo.
	Path string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	// This file's hash
	Hash                 []byte   `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InputFile) Descriptor 

func (*InputFile) Descriptor() ([]byte, []int)

func (*InputFile) GetHash 

func (m *InputFile) GetHash() []byte

func (*InputFile) GetPath 

func (m *InputFile) GetPath() string

func (*InputFile) Marshal 

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

func (*InputFile) MarshalTo 

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

func (*InputFile) ProtoMessage 

func (*InputFile) ProtoMessage()

func (*InputFile) Reset 

func (m *InputFile) Reset()

func (*InputFile) Size 

func (m *InputFile) Size() (n int)

func (*InputFile) String 

func (m *InputFile) String() string

func (*InputFile) Unmarshal 

func (m *InputFile) Unmarshal(dAtA []byte) error

func (*InputFile) XXX_DiscardUnknown 

func (m *InputFile) XXX_DiscardUnknown()

func (*InputFile) XXX_Marshal 

func (m *InputFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InputFile) XXX_Merge 

func (dst *InputFile) XXX_Merge(src proto.Message)

func (*InputFile) XXX_Size 

func (m *InputFile) XXX_Size() int

func (*InputFile) XXX_Unmarshal 

func (m *InputFile) XXX_Unmarshal(b []byte) error

type InspectDatumRequest 

type InspectDatumRequest struct {
	Datum                *Datum   `protobuf:"bytes,1,opt,name=datum,proto3" json:"datum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InspectDatumRequest) Descriptor 

func (*InspectDatumRequest) Descriptor() ([]byte, []int)

func (*InspectDatumRequest) GetDatum 

func (m *InspectDatumRequest) GetDatum() *Datum

func (*InspectDatumRequest) Marshal 

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

func (*InspectDatumRequest) MarshalTo 

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

func (*InspectDatumRequest) ProtoMessage 

func (*InspectDatumRequest) ProtoMessage()

func (*InspectDatumRequest) Reset 

func (m *InspectDatumRequest) Reset()

func (*InspectDatumRequest) Size 

func (m *InspectDatumRequest) Size() (n int)

func (*InspectDatumRequest) String 

func (m *InspectDatumRequest) String() string

func (*InspectDatumRequest) Unmarshal 

func (m *InspectDatumRequest) Unmarshal(dAtA []byte) error

func (*InspectDatumRequest) XXX_DiscardUnknown 

func (m *InspectDatumRequest) XXX_DiscardUnknown()

func (*InspectDatumRequest) XXX_Marshal 

func (m *InspectDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectDatumRequest) XXX_Merge 

func (dst *InspectDatumRequest) XXX_Merge(src proto.Message)

func (*InspectDatumRequest) XXX_Size 

func (m *InspectDatumRequest) XXX_Size() int

func (*InspectDatumRequest) XXX_Unmarshal 

func (m *InspectDatumRequest) XXX_Unmarshal(b []byte) error

type InspectJobRequest 

type InspectJobRequest struct {
	// Callers should set either Job or OutputCommit, not both.
	Job                  *Job        `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	OutputCommit         *pfs.Commit `protobuf:"bytes,3,opt,name=output_commit,json=outputCommit,proto3" json:"output_commit,omitempty"`
	BlockState           bool        `protobuf:"varint,2,opt,name=block_state,json=blockState,proto3" json:"block_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*InspectJobRequest) Descriptor 

func (*InspectJobRequest) Descriptor() ([]byte, []int)

func (*InspectJobRequest) GetBlockState 

func (m *InspectJobRequest) GetBlockState() bool

func (*InspectJobRequest) GetJob 

func (m *InspectJobRequest) GetJob() *Job

func (*InspectJobRequest) GetOutputCommit 

func (m *InspectJobRequest) GetOutputCommit() *pfs.Commit

func (*InspectJobRequest) Marshal 

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

func (*InspectJobRequest) MarshalTo 

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

func (*InspectJobRequest) ProtoMessage 

func (*InspectJobRequest) ProtoMessage()

func (*InspectJobRequest) Reset 

func (m *InspectJobRequest) Reset()

func (*InspectJobRequest) Size 

func (m *InspectJobRequest) Size() (n int)

func (*InspectJobRequest) String 

func (m *InspectJobRequest) String() string

func (*InspectJobRequest) Unmarshal 

func (m *InspectJobRequest) Unmarshal(dAtA []byte) error

func (*InspectJobRequest) XXX_DiscardUnknown 

func (m *InspectJobRequest) XXX_DiscardUnknown()

func (*InspectJobRequest) XXX_Marshal 

func (m *InspectJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectJobRequest) XXX_Merge 

func (dst *InspectJobRequest) XXX_Merge(src proto.Message)

func (*InspectJobRequest) XXX_Size 

func (m *InspectJobRequest) XXX_Size() int

func (*InspectJobRequest) XXX_Unmarshal 

func (m *InspectJobRequest) XXX_Unmarshal(b []byte) error

type InspectPipelineRequest 

type InspectPipelineRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*InspectPipelineRequest) Descriptor 

func (*InspectPipelineRequest) Descriptor() ([]byte, []int)

func (*InspectPipelineRequest) GetPipeline 

func (m *InspectPipelineRequest) GetPipeline() *Pipeline

func (*InspectPipelineRequest) Marshal 

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

func (*InspectPipelineRequest) MarshalTo 

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

func (*InspectPipelineRequest) ProtoMessage 

func (*InspectPipelineRequest) ProtoMessage()

func (*InspectPipelineRequest) Reset 

func (m *InspectPipelineRequest) Reset()

func (*InspectPipelineRequest) Size 

func (m *InspectPipelineRequest) Size() (n int)

func (*InspectPipelineRequest) String 

func (m *InspectPipelineRequest) String() string

func (*InspectPipelineRequest) Unmarshal 

func (m *InspectPipelineRequest) Unmarshal(dAtA []byte) error

func (*InspectPipelineRequest) XXX_DiscardUnknown 

func (m *InspectPipelineRequest) XXX_DiscardUnknown()

func (*InspectPipelineRequest) XXX_Marshal 

func (m *InspectPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectPipelineRequest) XXX_Merge 

func (dst *InspectPipelineRequest) XXX_Merge(src proto.Message)

func (*InspectPipelineRequest) XXX_Size 

func (m *InspectPipelineRequest) XXX_Size() int

func (*InspectPipelineRequest) XXX_Unmarshal 

func (m *InspectPipelineRequest) XXX_Unmarshal(b []byte) error

type Job 

type Job struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Job) Descriptor 

func (*Job) Descriptor() ([]byte, []int)

func (*Job) GetID 

func (m *Job) GetID() string

func (*Job) Marshal 

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

func (*Job) MarshalTo 

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

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

func (m *Job) Size() (n int)

func (*Job) String 

func (m *Job) String() string

func (*Job) Unmarshal 

func (m *Job) Unmarshal(dAtA []byte) error

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge 

func (dst *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

func (m *Job) XXX_Unmarshal(b []byte) error

type JobInfo 

type JobInfo struct {
	Job                  *Job             `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Transform            *Transform       `protobuf:"bytes,2,opt,name=transform,proto3" json:"transform,omitempty"`
	Pipeline             *Pipeline        `protobuf:"bytes,3,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	PipelineVersion      uint64           `protobuf:"varint,13,opt,name=pipeline_version,json=pipelineVersion,proto3" json:"pipeline_version,omitempty"`
	ParallelismSpec      *ParallelismSpec `protobuf:"bytes,12,opt,name=parallelism_spec,json=parallelismSpec,proto3" json:"parallelism_spec,omitempty"`
	Egress               *Egress          `protobuf:"bytes,15,opt,name=egress,proto3" json:"egress,omitempty"`
	ParentJob            *Job             `protobuf:"bytes,6,opt,name=parent_job,json=parentJob,proto3" json:"parent_job,omitempty"`
	Started              *types.Timestamp `protobuf:"bytes,7,opt,name=started,proto3" json:"started,omitempty"`
	Finished             *types.Timestamp `protobuf:"bytes,8,opt,name=finished,proto3" json:"finished,omitempty"`
	OutputCommit         *pfs.Commit      `protobuf:"bytes,9,opt,name=output_commit,json=outputCommit,proto3" json:"output_commit,omitempty"`
	State                JobState         `protobuf:"varint,10,opt,name=state,proto3,enum=pps_1_7.JobState" json:"state,omitempty"`
	Reason               string           `protobuf:"bytes,35,opt,name=reason,proto3" json:"reason,omitempty"`
	Service              *Service         `protobuf:"bytes,14,opt,name=service,proto3" json:"service,omitempty"`
	OutputRepo           *pfs.Repo        `protobuf:"bytes,18,opt,name=output_repo,json=outputRepo,proto3" json:"output_repo,omitempty"`
	OutputBranch         string           `protobuf:"bytes,17,opt,name=output_branch,json=outputBranch,proto3" json:"output_branch,omitempty"`
	Restart              uint64           `protobuf:"varint,20,opt,name=restart,proto3" json:"restart,omitempty"`
	DataProcessed        int64            `protobuf:"varint,22,opt,name=data_processed,json=dataProcessed,proto3" json:"data_processed,omitempty"`
	DataSkipped          int64            `protobuf:"varint,30,opt,name=data_skipped,json=dataSkipped,proto3" json:"data_skipped,omitempty"`
	DataFailed           int64            `protobuf:"varint,40,opt,name=data_failed,json=dataFailed,proto3" json:"data_failed,omitempty"`
	DataTotal            int64            `protobuf:"varint,23,opt,name=data_total,json=dataTotal,proto3" json:"data_total,omitempty"`
	Stats                *ProcessStats    `protobuf:"bytes,31,opt,name=stats,proto3" json:"stats,omitempty"`
	WorkerStatus         []*WorkerStatus  `protobuf:"bytes,24,rep,name=worker_status,json=workerStatus,proto3" json:"worker_status,omitempty"`
	ResourceRequests     *ResourceSpec    `protobuf:"bytes,25,opt,name=resource_requests,json=resourceRequests,proto3" json:"resource_requests,omitempty"`
	ResourceLimits       *ResourceSpec    `protobuf:"bytes,36,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	Input                *Input           `protobuf:"bytes,26,opt,name=input,proto3" json:"input,omitempty"`
	NewBranch            *pfs.BranchInfo  `protobuf:"bytes,27,opt,name=new_branch,json=newBranch,proto3" json:"new_branch,omitempty"`
	Incremental          bool             `protobuf:"varint,28,opt,name=incremental,proto3" json:"incremental,omitempty"`
	StatsCommit          *pfs.Commit      `protobuf:"bytes,29,opt,name=stats_commit,json=statsCommit,proto3" json:"stats_commit,omitempty"`
	EnableStats          bool             `protobuf:"varint,32,opt,name=enable_stats,json=enableStats,proto3" json:"enable_stats,omitempty"`
	Salt                 string           `protobuf:"bytes,33,opt,name=salt,proto3" json:"salt,omitempty"`
	Batch                bool             `protobuf:"varint,34,opt,name=batch,proto3" json:"batch,omitempty"`
	ChunkSpec            *ChunkSpec       `protobuf:"bytes,37,opt,name=chunk_spec,json=chunkSpec,proto3" json:"chunk_spec,omitempty"`
	DatumTimeout         *types.Duration  `protobuf:"bytes,38,opt,name=datum_timeout,json=datumTimeout,proto3" json:"datum_timeout,omitempty"`
	JobTimeout           *types.Duration  `protobuf:"bytes,39,opt,name=job_timeout,json=jobTimeout,proto3" json:"job_timeout,omitempty"`
	DatumTries           int64            `protobuf:"varint,41,opt,name=datum_tries,json=datumTries,proto3" json:"datum_tries,omitempty"`
	SchedulingSpec       *SchedulingSpec  `protobuf:"bytes,42,opt,name=scheduling_spec,json=schedulingSpec,proto3" json:"scheduling_spec,omitempty"`
	PodSpec              string           `protobuf:"bytes,43,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*JobInfo) Descriptor 

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

func (*JobInfo) GetBatch 

func (m *JobInfo) GetBatch() bool

func (*JobInfo) GetChunkSpec 

func (m *JobInfo) GetChunkSpec() *ChunkSpec

func (*JobInfo) GetDataFailed 

func (m *JobInfo) GetDataFailed() int64

func (*JobInfo) GetDataProcessed 

func (m *JobInfo) GetDataProcessed() int64

func (*JobInfo) GetDataSkipped 

func (m *JobInfo) GetDataSkipped() int64

func (*JobInfo) GetDataTotal 

func (m *JobInfo) GetDataTotal() int64

func (*JobInfo) GetDatumTimeout 

func (m *JobInfo) GetDatumTimeout() *types.Duration

func (*JobInfo) GetDatumTries 

func (m *JobInfo) GetDatumTries() int64

func (*JobInfo) GetEgress 

func (m *JobInfo) GetEgress() *Egress

func (*JobInfo) GetEnableStats 

func (m *JobInfo) GetEnableStats() bool

func (*JobInfo) GetFinished 

func (m *JobInfo) GetFinished() *types.Timestamp

func (*JobInfo) GetIncremental 

func (m *JobInfo) GetIncremental() bool

func (*JobInfo) GetInput 

func (m *JobInfo) GetInput() *Input

func (*JobInfo) GetJob 

func (m *JobInfo) GetJob() *Job

func (*JobInfo) GetJobTimeout 

func (m *JobInfo) GetJobTimeout() *types.Duration

func (*JobInfo) GetNewBranch 

func (m *JobInfo) GetNewBranch() *pfs.BranchInfo

func (*JobInfo) GetOutputBranch 

func (m *JobInfo) GetOutputBranch() string

func (*JobInfo) GetOutputCommit 

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

func (*JobInfo) GetOutputRepo 

func (m *JobInfo) GetOutputRepo() *pfs.Repo

func (*JobInfo) GetParallelismSpec 

func (m *JobInfo) GetParallelismSpec() *ParallelismSpec

func (*JobInfo) GetParentJob 

func (m *JobInfo) GetParentJob() *Job

func (*JobInfo) GetPipeline 

func (m *JobInfo) GetPipeline() *Pipeline

func (*JobInfo) GetPipelineVersion 

func (m *JobInfo) GetPipelineVersion() uint64

func (*JobInfo) GetPodSpec 

func (m *JobInfo) GetPodSpec() string

func (*JobInfo) GetReason 

func (m *JobInfo) GetReason() string

func (*JobInfo) GetResourceLimits 

func (m *JobInfo) GetResourceLimits() *ResourceSpec

func (*JobInfo) GetResourceRequests 

func (m *JobInfo) GetResourceRequests() *ResourceSpec

func (*JobInfo) GetRestart 

func (m *JobInfo) GetRestart() uint64

func (*JobInfo) GetSalt 

func (m *JobInfo) GetSalt() string

func (*JobInfo) GetSchedulingSpec 

func (m *JobInfo) GetSchedulingSpec() *SchedulingSpec

func (*JobInfo) GetService 

func (m *JobInfo) GetService() *Service

func (*JobInfo) GetStarted 

func (m *JobInfo) GetStarted() *types.Timestamp

func (*JobInfo) GetState 

func (m *JobInfo) GetState() JobState

func (*JobInfo) GetStats 

func (m *JobInfo) GetStats() *ProcessStats

func (*JobInfo) GetStatsCommit 

func (m *JobInfo) GetStatsCommit() *pfs.Commit

func (*JobInfo) GetTransform 

func (m *JobInfo) GetTransform() *Transform

func (*JobInfo) GetWorkerStatus 

func (m *JobInfo) GetWorkerStatus() []*WorkerStatus

func (*JobInfo) Marshal 

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

func (*JobInfo) MarshalTo 

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

func (*JobInfo) ProtoMessage 

func (*JobInfo) ProtoMessage()

func (*JobInfo) Reset 

func (m *JobInfo) Reset()

func (*JobInfo) Size 

func (m *JobInfo) Size() (n int)

func (*JobInfo) String 

func (m *JobInfo) String() string

func (*JobInfo) Unmarshal 

func (m *JobInfo) Unmarshal(dAtA []byte) error

func (*JobInfo) XXX_DiscardUnknown 

func (m *JobInfo) XXX_DiscardUnknown()

func (*JobInfo) XXX_Marshal 

func (m *JobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfo) XXX_Merge 

func (dst *JobInfo) XXX_Merge(src proto.Message)

func (*JobInfo) XXX_Size 

func (m *JobInfo) XXX_Size() int

func (*JobInfo) XXX_Unmarshal 

func (m *JobInfo) XXX_Unmarshal(b []byte) error

type JobInfos 

type JobInfos struct {
	JobInfo              []*JobInfo `protobuf:"bytes,1,rep,name=job_info,json=jobInfo,proto3" json:"job_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*JobInfos) Descriptor 

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

func (*JobInfos) GetJobInfo 

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

func (*JobInfos) Marshal 

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

func (*JobInfos) MarshalTo 

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

func (*JobInfos) ProtoMessage 

func (*JobInfos) ProtoMessage()

func (*JobInfos) Reset 

func (m *JobInfos) Reset()

func (*JobInfos) Size 

func (m *JobInfos) Size() (n int)

func (*JobInfos) String 

func (m *JobInfos) String() string

func (*JobInfos) Unmarshal 

func (m *JobInfos) Unmarshal(dAtA []byte) error

func (*JobInfos) XXX_DiscardUnknown 

func (m *JobInfos) XXX_DiscardUnknown()

func (*JobInfos) XXX_Marshal 

func (m *JobInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfos) XXX_Merge 

func (dst *JobInfos) XXX_Merge(src proto.Message)

func (*JobInfos) XXX_Size 

func (m *JobInfos) XXX_Size() int

func (*JobInfos) XXX_Unmarshal 

func (m *JobInfos) XXX_Unmarshal(b []byte) error

type JobInput 

type JobInput struct {
	Name                 string      `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Commit               *pfs.Commit `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	Glob                 string      `protobuf:"bytes,2,opt,name=glob,proto3" json:"glob,omitempty"`
	Lazy                 bool        `protobuf:"varint,3,opt,name=lazy,proto3" json:"lazy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*JobInput) Descriptor 

func (*JobInput) Descriptor() ([]byte, []int)

func (*JobInput) GetCommit 

func (m *JobInput) GetCommit() *pfs.Commit

func (*JobInput) GetGlob 

func (m *JobInput) GetGlob() string

func (*JobInput) GetLazy 

func (m *JobInput) GetLazy() bool

func (*JobInput) GetName 

func (m *JobInput) GetName() string

func (*JobInput) Marshal 

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

func (*JobInput) MarshalTo 

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

func (*JobInput) ProtoMessage 

func (*JobInput) ProtoMessage()

func (*JobInput) Reset 

func (m *JobInput) Reset()

func (*JobInput) Size 

func (m *JobInput) Size() (n int)

func (*JobInput) String 

func (m *JobInput) String() string

func (*JobInput) Unmarshal 

func (m *JobInput) Unmarshal(dAtA []byte) error

func (*JobInput) XXX_DiscardUnknown 

func (m *JobInput) XXX_DiscardUnknown()

func (*JobInput) XXX_Marshal 

func (m *JobInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInput) XXX_Merge 

func (dst *JobInput) XXX_Merge(src proto.Message)

func (*JobInput) XXX_Size 

func (m *JobInput) XXX_Size() int

func (*JobInput) XXX_Unmarshal 

func (m *JobInput) XXX_Unmarshal(b []byte) error

type JobState 

type JobState int32
const (
	JobState_JOB_STARTING JobState = 0
	JobState_JOB_RUNNING  JobState = 1
	JobState_JOB_FAILURE  JobState = 2
	JobState_JOB_SUCCESS  JobState = 3
	JobState_JOB_KILLED   JobState = 4
)

func (JobState) EnumDescriptor 

func (JobState) EnumDescriptor() ([]byte, []int)

func (JobState) String 

func (x JobState) String() string

type ListDatumRequest 

type ListDatumRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	PageSize             int64    `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Page                 int64    `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDatumRequest) Descriptor 

func (*ListDatumRequest) Descriptor() ([]byte, []int)

func (*ListDatumRequest) GetJob 

func (m *ListDatumRequest) GetJob() *Job

func (*ListDatumRequest) GetPage 

func (m *ListDatumRequest) GetPage() int64

func (*ListDatumRequest) GetPageSize 

func (m *ListDatumRequest) GetPageSize() int64

func (*ListDatumRequest) Marshal 

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

func (*ListDatumRequest) MarshalTo 

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

func (*ListDatumRequest) ProtoMessage 

func (*ListDatumRequest) ProtoMessage()

func (*ListDatumRequest) Reset 

func (m *ListDatumRequest) Reset()

func (*ListDatumRequest) Size 

func (m *ListDatumRequest) Size() (n int)

func (*ListDatumRequest) String 

func (m *ListDatumRequest) String() string

func (*ListDatumRequest) Unmarshal 

func (m *ListDatumRequest) Unmarshal(dAtA []byte) error

func (*ListDatumRequest) XXX_DiscardUnknown 

func (m *ListDatumRequest) XXX_DiscardUnknown()

func (*ListDatumRequest) XXX_Marshal 

func (m *ListDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatumRequest) XXX_Merge 

func (dst *ListDatumRequest) XXX_Merge(src proto.Message)

func (*ListDatumRequest) XXX_Size 

func (m *ListDatumRequest) XXX_Size() int

func (*ListDatumRequest) XXX_Unmarshal 

func (m *ListDatumRequest) XXX_Unmarshal(b []byte) error

type ListDatumResponse 

type ListDatumResponse struct {
	DatumInfos           []*DatumInfo `protobuf:"bytes,1,rep,name=datum_infos,json=datumInfos,proto3" json:"datum_infos,omitempty"`
	TotalPages           int64        `protobuf:"varint,2,opt,name=total_pages,json=totalPages,proto3" json:"total_pages,omitempty"`
	Page                 int64        `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListDatumResponse) Descriptor 

func (*ListDatumResponse) Descriptor() ([]byte, []int)

func (*ListDatumResponse) GetDatumInfos 

func (m *ListDatumResponse) GetDatumInfos() []*DatumInfo

func (*ListDatumResponse) GetPage 

func (m *ListDatumResponse) GetPage() int64

func (*ListDatumResponse) GetTotalPages 

func (m *ListDatumResponse) GetTotalPages() int64

func (*ListDatumResponse) Marshal 

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

func (*ListDatumResponse) MarshalTo 

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

func (*ListDatumResponse) ProtoMessage 

func (*ListDatumResponse) ProtoMessage()

func (*ListDatumResponse) Reset 

func (m *ListDatumResponse) Reset()

func (*ListDatumResponse) Size 

func (m *ListDatumResponse) Size() (n int)

func (*ListDatumResponse) String 

func (m *ListDatumResponse) String() string

func (*ListDatumResponse) Unmarshal 

func (m *ListDatumResponse) Unmarshal(dAtA []byte) error

func (*ListDatumResponse) XXX_DiscardUnknown 

func (m *ListDatumResponse) XXX_DiscardUnknown()

func (*ListDatumResponse) XXX_Marshal 

func (m *ListDatumResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatumResponse) XXX_Merge 

func (dst *ListDatumResponse) XXX_Merge(src proto.Message)

func (*ListDatumResponse) XXX_Size 

func (m *ListDatumResponse) XXX_Size() int

func (*ListDatumResponse) XXX_Unmarshal 

func (m *ListDatumResponse) XXX_Unmarshal(b []byte) error

type ListDatumStreamResponse 

type ListDatumStreamResponse struct {
	DatumInfo *DatumInfo `protobuf:"bytes,1,opt,name=datum_info,json=datumInfo,proto3" json:"datum_info,omitempty"`
	// total_pages is only set in the first response (and set to 0 in all other
	// responses)
	TotalPages int64 `protobuf:"varint,2,opt,name=total_pages,json=totalPages,proto3" json:"total_pages,omitempty"`
	// page is only set in the first response (and set to 0 in all other
	// responses)
	Page                 int64    `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListDatumStreamResponse is identical to ListDatumResponse, except that only one DatumInfo is present (as these responses are streamed)

func (*ListDatumStreamResponse) Descriptor 

func (*ListDatumStreamResponse) Descriptor() ([]byte, []int)

func (*ListDatumStreamResponse) GetDatumInfo 

func (m *ListDatumStreamResponse) GetDatumInfo() *DatumInfo

func (*ListDatumStreamResponse) GetPage 

func (m *ListDatumStreamResponse) GetPage() int64

func (*ListDatumStreamResponse) GetTotalPages 

func (m *ListDatumStreamResponse) GetTotalPages() int64

func (*ListDatumStreamResponse) Marshal 

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

func (*ListDatumStreamResponse) MarshalTo 

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

func (*ListDatumStreamResponse) ProtoMessage 

func (*ListDatumStreamResponse) ProtoMessage()

func (*ListDatumStreamResponse) Reset 

func (m *ListDatumStreamResponse) Reset()

func (*ListDatumStreamResponse) Size 

func (m *ListDatumStreamResponse) Size() (n int)

func (*ListDatumStreamResponse) String 

func (m *ListDatumStreamResponse) String() string

func (*ListDatumStreamResponse) Unmarshal 

func (m *ListDatumStreamResponse) Unmarshal(dAtA []byte) error

func (*ListDatumStreamResponse) XXX_DiscardUnknown 

func (m *ListDatumStreamResponse) XXX_DiscardUnknown()

func (*ListDatumStreamResponse) XXX_Marshal 

func (m *ListDatumStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatumStreamResponse) XXX_Merge 

func (dst *ListDatumStreamResponse) XXX_Merge(src proto.Message)

func (*ListDatumStreamResponse) XXX_Size 

func (m *ListDatumStreamResponse) XXX_Size() int

func (*ListDatumStreamResponse) XXX_Unmarshal 

func (m *ListDatumStreamResponse) XXX_Unmarshal(b []byte) error

type ListJobRequest 

type ListJobRequest struct {
	Pipeline             *Pipeline     `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	InputCommit          []*pfs.Commit `protobuf:"bytes,2,rep,name=input_commit,json=inputCommit,proto3" json:"input_commit,omitempty"`
	OutputCommit         *pfs.Commit   `protobuf:"bytes,3,opt,name=output_commit,json=outputCommit,proto3" json:"output_commit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListJobRequest) Descriptor 

func (*ListJobRequest) Descriptor() ([]byte, []int)

func (*ListJobRequest) GetInputCommit 

func (m *ListJobRequest) GetInputCommit() []*pfs.Commit

func (*ListJobRequest) GetOutputCommit 

func (m *ListJobRequest) GetOutputCommit() *pfs.Commit

func (*ListJobRequest) GetPipeline 

func (m *ListJobRequest) GetPipeline() *Pipeline

func (*ListJobRequest) Marshal 

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

func (*ListJobRequest) MarshalTo 

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

func (*ListJobRequest) ProtoMessage 

func (*ListJobRequest) ProtoMessage()

func (*ListJobRequest) Reset 

func (m *ListJobRequest) Reset()

func (*ListJobRequest) Size 

func (m *ListJobRequest) Size() (n int)

func (*ListJobRequest) String 

func (m *ListJobRequest) String() string

func (*ListJobRequest) Unmarshal 

func (m *ListJobRequest) Unmarshal(dAtA []byte) error

func (*ListJobRequest) XXX_DiscardUnknown 

func (m *ListJobRequest) XXX_DiscardUnknown()

func (*ListJobRequest) XXX_Marshal 

func (m *ListJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobRequest) XXX_Merge 

func (dst *ListJobRequest) XXX_Merge(src proto.Message)

func (*ListJobRequest) XXX_Size 

func (m *ListJobRequest) XXX_Size() int

func (*ListJobRequest) XXX_Unmarshal 

func (m *ListJobRequest) XXX_Unmarshal(b []byte) error

type ListPipelineRequest 

type ListPipelineRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPipelineRequest) Descriptor 

func (*ListPipelineRequest) Descriptor() ([]byte, []int)

func (*ListPipelineRequest) Marshal 

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

func (*ListPipelineRequest) MarshalTo 

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

func (*ListPipelineRequest) ProtoMessage 

func (*ListPipelineRequest) ProtoMessage()

func (*ListPipelineRequest) Reset 

func (m *ListPipelineRequest) Reset()

func (*ListPipelineRequest) Size 

func (m *ListPipelineRequest) Size() (n int)

func (*ListPipelineRequest) String 

func (m *ListPipelineRequest) String() string

func (*ListPipelineRequest) Unmarshal 

func (m *ListPipelineRequest) Unmarshal(dAtA []byte) error

func (*ListPipelineRequest) XXX_DiscardUnknown 

func (m *ListPipelineRequest) XXX_DiscardUnknown()

func (*ListPipelineRequest) XXX_Marshal 

func (m *ListPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPipelineRequest) XXX_Merge 

func (dst *ListPipelineRequest) XXX_Merge(src proto.Message)

func (*ListPipelineRequest) XXX_Size 

func (m *ListPipelineRequest) XXX_Size() int

func (*ListPipelineRequest) XXX_Unmarshal 

func (m *ListPipelineRequest) XXX_Unmarshal(b []byte) error

type LogMessage 

type LogMessage struct {
	// The job and pipeline for which a PFS file is being processed (if the job
	// is an orphan job, pipeline name and ID will be unset)
	PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"`
	JobID        string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	WorkerID     string `protobuf:"bytes,7,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	DatumID      string `protobuf:"bytes,9,opt,name=datum_id,json=datumId,proto3" json:"datum_id,omitempty"`
	Master       bool   `protobuf:"varint,10,opt,name=master,proto3" json:"master,omitempty"`
	// The PFS files being processed (one per pipeline/job input)
	Data []*InputFile `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
	// User is true if log message comes from the users code.
	User bool `protobuf:"varint,8,opt,name=user,proto3" json:"user,omitempty"`
	// The message logged, and the time at which it was logged
	Ts                   *types.Timestamp `protobuf:"bytes,5,opt,name=ts,proto3" json:"ts,omitempty"`
	Message              string           `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

LogMessage is a log line from a PPS worker, annotated with metadata indicating when and why the line was logged.

func (*LogMessage) Descriptor 

func (*LogMessage) Descriptor() ([]byte, []int)

func (*LogMessage) GetData 

func (m *LogMessage) GetData() []*InputFile

func (*LogMessage) GetDatumID 

func (m *LogMessage) GetDatumID() string

func (*LogMessage) GetJobID 

func (m *LogMessage) GetJobID() string

func (*LogMessage) GetMaster 

func (m *LogMessage) GetMaster() bool

func (*LogMessage) GetMessage 

func (m *LogMessage) GetMessage() string

func (*LogMessage) GetPipelineName 

func (m *LogMessage) GetPipelineName() string

func (*LogMessage) GetTs 

func (m *LogMessage) GetTs() *types.Timestamp

func (*LogMessage) GetUser 

func (m *LogMessage) GetUser() bool

func (*LogMessage) GetWorkerID 

func (m *LogMessage) GetWorkerID() string

func (*LogMessage) Marshal 

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

func (*LogMessage) MarshalTo 

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

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) Reset 

func (m *LogMessage) Reset()

func (*LogMessage) Size 

func (m *LogMessage) Size() (n int)

func (*LogMessage) String 

func (m *LogMessage) String() string

func (*LogMessage) Unmarshal 

func (m *LogMessage) Unmarshal(dAtA []byte) error

func (*LogMessage) XXX_DiscardUnknown 

func (m *LogMessage) XXX_DiscardUnknown()

func (*LogMessage) XXX_Marshal 

func (m *LogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogMessage) XXX_Merge 

func (dst *LogMessage) XXX_Merge(src proto.Message)

func (*LogMessage) XXX_Size 

func (m *LogMessage) XXX_Size() int

func (*LogMessage) XXX_Unmarshal 

func (m *LogMessage) XXX_Unmarshal(b []byte) error

type ParallelismSpec 

type ParallelismSpec struct {
	// Starts the pipeline/job with a 'constant' workers, unless 'constant' is
	// zero. If 'constant' is zero (which is the zero value of ParallelismSpec),
	// then Pachyderm will choose the number of workers that is started,
	// (currently it chooses the number of workers in the cluster)
	Constant uint64 `protobuf:"varint,2,opt,name=constant,proto3" json:"constant,omitempty"`
	// Starts the pipeline/job with number of workers equal to 'coefficient' * N,
	// where N is the number of nodes in the kubernetes cluster.
	//
	// For example, if each Kubernetes node has four CPUs, you might set
	// 'coefficient' to four, so that there are four Pachyderm workers per
	// Kubernetes node, and each Pachyderm worker gets one CPU. If you want to
	// reserve half the nodes in your cluster for other tasks, you might set
	// 'coefficient' to 0.5.
	Coefficient          float64  `protobuf:"fixed64,3,opt,name=coefficient,proto3" json:"coefficient,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ParallelismSpec) Descriptor 

func (*ParallelismSpec) Descriptor() ([]byte, []int)

func (*ParallelismSpec) GetCoefficient 

func (m *ParallelismSpec) GetCoefficient() float64

func (*ParallelismSpec) GetConstant 

func (m *ParallelismSpec) GetConstant() uint64

func (*ParallelismSpec) Marshal 

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

func (*ParallelismSpec) MarshalTo 

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

func (*ParallelismSpec) ProtoMessage 

func (*ParallelismSpec) ProtoMessage()

func (*ParallelismSpec) Reset 

func (m *ParallelismSpec) Reset()

func (*ParallelismSpec) Size 

func (m *ParallelismSpec) Size() (n int)

func (*ParallelismSpec) String 

func (m *ParallelismSpec) String() string

func (*ParallelismSpec) Unmarshal 

func (m *ParallelismSpec) Unmarshal(dAtA []byte) error

func (*ParallelismSpec) XXX_DiscardUnknown 

func (m *ParallelismSpec) XXX_DiscardUnknown()

func (*ParallelismSpec) XXX_Marshal 

func (m *ParallelismSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParallelismSpec) XXX_Merge 

func (dst *ParallelismSpec) XXX_Merge(src proto.Message)

func (*ParallelismSpec) XXX_Size 

func (m *ParallelismSpec) XXX_Size() int

func (*ParallelismSpec) XXX_Unmarshal 

func (m *ParallelismSpec) XXX_Unmarshal(b []byte) error

type Pipeline 

type Pipeline struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pipeline) Descriptor 

func (*Pipeline) Descriptor() ([]byte, []int)

func (*Pipeline) GetName 

func (m *Pipeline) GetName() string

func (*Pipeline) Marshal 

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

func (*Pipeline) MarshalTo 

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

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) Reset 

func (m *Pipeline) Reset()

func (*Pipeline) Size 

func (m *Pipeline) Size() (n int)

func (*Pipeline) String 

func (m *Pipeline) String() string

func (*Pipeline) Unmarshal 

func (m *Pipeline) Unmarshal(dAtA []byte) error

func (*Pipeline) XXX_DiscardUnknown 

func (m *Pipeline) XXX_DiscardUnknown()

func (*Pipeline) XXX_Marshal 

func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pipeline) XXX_Merge 

func (dst *Pipeline) XXX_Merge(src proto.Message)

func (*Pipeline) XXX_Size 

func (m *Pipeline) XXX_Size() int

func (*Pipeline) XXX_Unmarshal 

func (m *Pipeline) XXX_Unmarshal(b []byte) error

type PipelineInfo 

type PipelineInfo struct {
	ID              string           `protobuf:"bytes,17,opt,name=id,proto3" json:"id,omitempty"`
	Pipeline        *Pipeline        `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Version         uint64           `protobuf:"varint,11,opt,name=version,proto3" json:"version,omitempty"`
	Transform       *Transform       `protobuf:"bytes,2,opt,name=transform,proto3" json:"transform,omitempty"`
	ParallelismSpec *ParallelismSpec `protobuf:"bytes,10,opt,name=parallelism_spec,json=parallelismSpec,proto3" json:"parallelism_spec,omitempty"`
	HashtreeSpec    *HashtreeSpec    `protobuf:"bytes,42,opt,name=hashtree_spec,json=hashtreeSpec,proto3" json:"hashtree_spec,omitempty"`
	Egress          *Egress          `protobuf:"bytes,15,opt,name=egress,proto3" json:"egress,omitempty"`
	CreatedAt       *types.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// state indicates the current state of the pipeline. This is not stored in
	// PFS along with the rest of this data structure--PPS.InspectPipeline fills
	// it in
	State PipelineState `protobuf:"varint,7,opt,name=state,proto3,enum=pps_1_7.PipelineState" json:"state,omitempty"`
	// same for stopped field
	Stopped     bool   `protobuf:"varint,38,opt,name=stopped,proto3" json:"stopped,omitempty"`
	RecentError string `protobuf:"bytes,8,opt,name=recent_error,json=recentError,proto3" json:"recent_error,omitempty"`
	// job_counts indicates the number of jobs within this pipeline in a given
	// state. This is not stored in PFS along with the rest of this data
	// structure--PPS.InspectPipeline fills it in
	JobCounts          map[int32]int32 `` /* 178-byte string literal not displayed */
	OutputBranch       string          `protobuf:"bytes,16,opt,name=output_branch,json=outputBranch,proto3" json:"output_branch,omitempty"`
	ScaleDownThreshold *types.Duration `protobuf:"bytes,18,opt,name=scale_down_threshold,json=scaleDownThreshold,proto3" json:"scale_down_threshold,omitempty"`
	ResourceRequests   *ResourceSpec   `protobuf:"bytes,19,opt,name=resource_requests,json=resourceRequests,proto3" json:"resource_requests,omitempty"`
	ResourceLimits     *ResourceSpec   `protobuf:"bytes,31,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	Input              *Input          `protobuf:"bytes,20,opt,name=input,proto3" json:"input,omitempty"`
	Description        string          `protobuf:"bytes,21,opt,name=description,proto3" json:"description,omitempty"`
	Incremental        bool            `protobuf:"varint,22,opt,name=incremental,proto3" json:"incremental,omitempty"`
	CacheSize          string          `protobuf:"bytes,23,opt,name=cache_size,json=cacheSize,proto3" json:"cache_size,omitempty"`
	EnableStats        bool            `protobuf:"varint,24,opt,name=enable_stats,json=enableStats,proto3" json:"enable_stats,omitempty"`
	Salt               string          `protobuf:"bytes,25,opt,name=salt,proto3" json:"salt,omitempty"`
	Batch              bool            `protobuf:"varint,27,opt,name=batch,proto3" json:"batch,omitempty"`
	// reason includes any error messages associated with a failed pipeline
	Reason               string          `protobuf:"bytes,28,opt,name=reason,proto3" json:"reason,omitempty"`
	MaxQueueSize         int64           `protobuf:"varint,29,opt,name=max_queue_size,json=maxQueueSize,proto3" json:"max_queue_size,omitempty"`
	Service              *Service        `protobuf:"bytes,30,opt,name=service,proto3" json:"service,omitempty"`
	ChunkSpec            *ChunkSpec      `protobuf:"bytes,32,opt,name=chunk_spec,json=chunkSpec,proto3" json:"chunk_spec,omitempty"`
	DatumTimeout         *types.Duration `protobuf:"bytes,33,opt,name=datum_timeout,json=datumTimeout,proto3" json:"datum_timeout,omitempty"`
	JobTimeout           *types.Duration `protobuf:"bytes,34,opt,name=job_timeout,json=jobTimeout,proto3" json:"job_timeout,omitempty"`
	GithookURL           string          `protobuf:"bytes,35,opt,name=githook_url,json=githookUrl,proto3" json:"githook_url,omitempty"`
	SpecCommit           *pfs.Commit     `protobuf:"bytes,36,opt,name=spec_commit,json=specCommit,proto3" json:"spec_commit,omitempty"`
	Standby              bool            `protobuf:"varint,37,opt,name=standby,proto3" json:"standby,omitempty"`
	DatumTries           int64           `protobuf:"varint,39,opt,name=datum_tries,json=datumTries,proto3" json:"datum_tries,omitempty"`
	SchedulingSpec       *SchedulingSpec `protobuf:"bytes,40,opt,name=scheduling_spec,json=schedulingSpec,proto3" json:"scheduling_spec,omitempty"`
	PodSpec              string          `protobuf:"bytes,41,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PipelineInfo) Descriptor 

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

func (*PipelineInfo) GetBatch 

func (m *PipelineInfo) GetBatch() bool

func (*PipelineInfo) GetCacheSize 

func (m *PipelineInfo) GetCacheSize() string

func (*PipelineInfo) GetChunkSpec 

func (m *PipelineInfo) GetChunkSpec() *ChunkSpec

func (*PipelineInfo) GetCreatedAt 

func (m *PipelineInfo) GetCreatedAt() *types.Timestamp

func (*PipelineInfo) GetDatumTimeout 

func (m *PipelineInfo) GetDatumTimeout() *types.Duration

func (*PipelineInfo) GetDatumTries 

func (m *PipelineInfo) GetDatumTries() int64

func (*PipelineInfo) GetDescription 

func (m *PipelineInfo) GetDescription() string

func (*PipelineInfo) GetEgress 

func (m *PipelineInfo) GetEgress() *Egress

func (*PipelineInfo) GetEnableStats 

func (m *PipelineInfo) GetEnableStats() bool

func (*PipelineInfo) GetGithookURL 

func (m *PipelineInfo) GetGithookURL() string

func (*PipelineInfo) GetHashtreeSpec 

func (m *PipelineInfo) GetHashtreeSpec() *HashtreeSpec

func (*PipelineInfo) GetID 

func (m *PipelineInfo) GetID() string

func (*PipelineInfo) GetIncremental 

func (m *PipelineInfo) GetIncremental() bool

func (*PipelineInfo) GetInput 

func (m *PipelineInfo) GetInput() *Input

func (*PipelineInfo) GetJobCounts 

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

func (*PipelineInfo) GetJobTimeout 

func (m *PipelineInfo) GetJobTimeout() *types.Duration

func (*PipelineInfo) GetMaxQueueSize 

func (m *PipelineInfo) GetMaxQueueSize() int64

func (*PipelineInfo) GetOutputBranch 

func (m *PipelineInfo) GetOutputBranch() string

func (*PipelineInfo) GetParallelismSpec 

func (m *PipelineInfo) GetParallelismSpec() *ParallelismSpec

func (*PipelineInfo) GetPipeline 

func (m *PipelineInfo) GetPipeline() *Pipeline

func (*PipelineInfo) GetPodSpec 

func (m *PipelineInfo) GetPodSpec() string

func (*PipelineInfo) GetReason 

func (m *PipelineInfo) GetReason() string

func (*PipelineInfo) GetRecentError 

func (m *PipelineInfo) GetRecentError() string

func (*PipelineInfo) GetResourceLimits 

func (m *PipelineInfo) GetResourceLimits() *ResourceSpec

func (*PipelineInfo) GetResourceRequests 

func (m *PipelineInfo) GetResourceRequests() *ResourceSpec

func (*PipelineInfo) GetSalt 

func (m *PipelineInfo) GetSalt() string

func (*PipelineInfo) GetScaleDownThreshold 

func (m *PipelineInfo) GetScaleDownThreshold() *types.Duration

func (*PipelineInfo) GetSchedulingSpec 

func (m *PipelineInfo) GetSchedulingSpec() *SchedulingSpec

func (*PipelineInfo) GetService 

func (m *PipelineInfo) GetService() *Service

func (*PipelineInfo) GetSpecCommit 

func (m *PipelineInfo) GetSpecCommit() *pfs.Commit

func (*PipelineInfo) GetStandby 

func (m *PipelineInfo) GetStandby() bool

func (*PipelineInfo) GetState 

func (m *PipelineInfo) GetState() PipelineState

func (*PipelineInfo) GetStopped 

func (m *PipelineInfo) GetStopped() bool

func (*PipelineInfo) GetTransform 

func (m *PipelineInfo) GetTransform() *Transform

func (*PipelineInfo) GetVersion 

func (m *PipelineInfo) GetVersion() uint64

func (*PipelineInfo) Marshal 

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

func (*PipelineInfo) MarshalTo 

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

func (*PipelineInfo) ProtoMessage 

func (*PipelineInfo) ProtoMessage()

func (*PipelineInfo) Reset 

func (m *PipelineInfo) Reset()

func (*PipelineInfo) Size 

func (m *PipelineInfo) Size() (n int)

func (*PipelineInfo) String 

func (m *PipelineInfo) String() string

func (*PipelineInfo) Unmarshal 

func (m *PipelineInfo) Unmarshal(dAtA []byte) error

func (*PipelineInfo) XXX_DiscardUnknown 

func (m *PipelineInfo) XXX_DiscardUnknown()

func (*PipelineInfo) XXX_Marshal 

func (m *PipelineInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineInfo) XXX_Merge 

func (dst *PipelineInfo) XXX_Merge(src proto.Message)

func (*PipelineInfo) XXX_Size 

func (m *PipelineInfo) XXX_Size() int

func (*PipelineInfo) XXX_Unmarshal 

func (m *PipelineInfo) XXX_Unmarshal(b []byte) error

type PipelineInfos 

type PipelineInfos struct {
	PipelineInfo         []*PipelineInfo `protobuf:"bytes,1,rep,name=pipeline_info,json=pipelineInfo,proto3" json:"pipeline_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PipelineInfos) Descriptor 

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

func (*PipelineInfos) GetPipelineInfo 

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

func (*PipelineInfos) Marshal 

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

func (*PipelineInfos) MarshalTo 

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

func (*PipelineInfos) ProtoMessage 

func (*PipelineInfos) ProtoMessage()

func (*PipelineInfos) Reset 

func (m *PipelineInfos) Reset()

func (*PipelineInfos) Size 

func (m *PipelineInfos) Size() (n int)

func (*PipelineInfos) String 

func (m *PipelineInfos) String() string

func (*PipelineInfos) Unmarshal 

func (m *PipelineInfos) Unmarshal(dAtA []byte) error

func (*PipelineInfos) XXX_DiscardUnknown 

func (m *PipelineInfos) XXX_DiscardUnknown()

func (*PipelineInfos) XXX_Marshal 

func (m *PipelineInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineInfos) XXX_Merge 

func (dst *PipelineInfos) XXX_Merge(src proto.Message)

func (*PipelineInfos) XXX_Size 

func (m *PipelineInfos) XXX_Size() int

func (*PipelineInfos) XXX_Unmarshal 

func (m *PipelineInfos) XXX_Unmarshal(b []byte) error

type PipelineInput 

type PipelineInput struct {
	Name                 string      `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Repo                 *pfs.Repo   `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Branch               string      `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	Glob                 string      `protobuf:"bytes,3,opt,name=glob,proto3" json:"glob,omitempty"`
	Lazy                 bool        `protobuf:"varint,4,opt,name=lazy,proto3" json:"lazy,omitempty"`
	From                 *pfs.Commit `protobuf:"bytes,6,opt,name=from,proto3" json:"from,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PipelineInput) Descriptor 

func (*PipelineInput) Descriptor() ([]byte, []int)

func (*PipelineInput) GetBranch 

func (m *PipelineInput) GetBranch() string

func (*PipelineInput) GetFrom 

func (m *PipelineInput) GetFrom() *pfs.Commit

func (*PipelineInput) GetGlob 

func (m *PipelineInput) GetGlob() string

func (*PipelineInput) GetLazy 

func (m *PipelineInput) GetLazy() bool

func (*PipelineInput) GetName 

func (m *PipelineInput) GetName() string

func (*PipelineInput) GetRepo 

func (m *PipelineInput) GetRepo() *pfs.Repo

func (*PipelineInput) Marshal 

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

func (*PipelineInput) MarshalTo 

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

func (*PipelineInput) ProtoMessage 

func (*PipelineInput) ProtoMessage()

func (*PipelineInput) Reset 

func (m *PipelineInput) Reset()

func (*PipelineInput) Size 

func (m *PipelineInput) Size() (n int)

func (*PipelineInput) String 

func (m *PipelineInput) String() string

func (*PipelineInput) Unmarshal 

func (m *PipelineInput) Unmarshal(dAtA []byte) error

func (*PipelineInput) XXX_DiscardUnknown 

func (m *PipelineInput) XXX_DiscardUnknown()

func (*PipelineInput) XXX_Marshal 

func (m *PipelineInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineInput) XXX_Merge 

func (dst *PipelineInput) XXX_Merge(src proto.Message)

func (*PipelineInput) XXX_Size 

func (m *PipelineInput) XXX_Size() int

func (*PipelineInput) XXX_Unmarshal 

func (m *PipelineInput) XXX_Unmarshal(b []byte) error

type PipelineState 

type PipelineState int32
const (
	// When the pipeline is not ready to be triggered by commits.
	// This happens when either 1) a pipeline has been created but not
	// yet picked up by a PPS server, or 2) the pipeline does not have
	// any inputs and is meant to be triggered manually
	PipelineState_PIPELINE_STARTING PipelineState = 0
	// After this pipeline is picked up by a pachd node.  This is the normal
	// state of a pipeline.
	PipelineState_PIPELINE_RUNNING PipelineState = 1
	// After some error caused runPipeline to exit, but before the
	// pipeline is re-run.  This is when the exponential backoff is
	// in effect.
	PipelineState_PIPELINE_RESTARTING PipelineState = 2
	// We have retried too many times and we have given up on this pipeline.
	PipelineState_PIPELINE_FAILURE PipelineState = 3
	// The pipeline has been explicitly paused by the user.
	PipelineState_PIPELINE_PAUSED PipelineState = 4
	// The pipeline is fully functional, but there are no commits to process.
	PipelineState_PIPELINE_STANDBY PipelineState = 5
)

func (PipelineState) EnumDescriptor 

func (PipelineState) EnumDescriptor() ([]byte, []int)

func (PipelineState) String 

func (x PipelineState) String() string

type ProcessStats 

type ProcessStats struct {
	DownloadTime         *types.Duration `protobuf:"bytes,1,opt,name=download_time,json=downloadTime,proto3" json:"download_time,omitempty"`
	ProcessTime          *types.Duration `protobuf:"bytes,2,opt,name=process_time,json=processTime,proto3" json:"process_time,omitempty"`
	UploadTime           *types.Duration `protobuf:"bytes,3,opt,name=upload_time,json=uploadTime,proto3" json:"upload_time,omitempty"`
	DownloadBytes        uint64          `protobuf:"varint,4,opt,name=download_bytes,json=downloadBytes,proto3" json:"download_bytes,omitempty"`
	UploadBytes          uint64          `protobuf:"varint,5,opt,name=upload_bytes,json=uploadBytes,proto3" json:"upload_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ProcessStats) Descriptor 

func (*ProcessStats) Descriptor() ([]byte, []int)

func (*ProcessStats) GetDownloadBytes 

func (m *ProcessStats) GetDownloadBytes() uint64

func (*ProcessStats) GetDownloadTime 

func (m *ProcessStats) GetDownloadTime() *types.Duration

func (*ProcessStats) GetProcessTime 

func (m *ProcessStats) GetProcessTime() *types.Duration

func (*ProcessStats) GetUploadBytes 

func (m *ProcessStats) GetUploadBytes() uint64

func (*ProcessStats) GetUploadTime 

func (m *ProcessStats) GetUploadTime() *types.Duration

func (*ProcessStats) Marshal 

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

func (*ProcessStats) MarshalTo 

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

func (*ProcessStats) ProtoMessage 

func (*ProcessStats) ProtoMessage()

func (*ProcessStats) Reset 

func (m *ProcessStats) Reset()

func (*ProcessStats) Size 

func (m *ProcessStats) Size() (n int)

func (*ProcessStats) String 

func (m *ProcessStats) String() string

func (*ProcessStats) Unmarshal 

func (m *ProcessStats) Unmarshal(dAtA []byte) error

func (*ProcessStats) XXX_DiscardUnknown 

func (m *ProcessStats) XXX_DiscardUnknown()

func (*ProcessStats) XXX_Marshal 

func (m *ProcessStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessStats) XXX_Merge 

func (dst *ProcessStats) XXX_Merge(src proto.Message)

func (*ProcessStats) XXX_Size 

func (m *ProcessStats) XXX_Size() int

func (*ProcessStats) XXX_Unmarshal 

func (m *ProcessStats) XXX_Unmarshal(b []byte) error

type RerunPipelineRequest 

type RerunPipelineRequest struct {
	Pipeline             *Pipeline     `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Exclude              []*pfs.Commit `protobuf:"bytes,2,rep,name=exclude,proto3" json:"exclude,omitempty"`
	Include              []*pfs.Commit `protobuf:"bytes,3,rep,name=include,proto3" json:"include,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RerunPipelineRequest) Descriptor 

func (*RerunPipelineRequest) Descriptor() ([]byte, []int)

func (*RerunPipelineRequest) GetExclude 

func (m *RerunPipelineRequest) GetExclude() []*pfs.Commit

func (*RerunPipelineRequest) GetInclude 

func (m *RerunPipelineRequest) GetInclude() []*pfs.Commit

func (*RerunPipelineRequest) GetPipeline 

func (m *RerunPipelineRequest) GetPipeline() *Pipeline

func (*RerunPipelineRequest) Marshal 

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

func (*RerunPipelineRequest) MarshalTo 

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

func (*RerunPipelineRequest) ProtoMessage 

func (*RerunPipelineRequest) ProtoMessage()

func (*RerunPipelineRequest) Reset 

func (m *RerunPipelineRequest) Reset()

func (*RerunPipelineRequest) Size 

func (m *RerunPipelineRequest) Size() (n int)

func (*RerunPipelineRequest) String 

func (m *RerunPipelineRequest) String() string

func (*RerunPipelineRequest) Unmarshal 

func (m *RerunPipelineRequest) Unmarshal(dAtA []byte) error

func (*RerunPipelineRequest) XXX_DiscardUnknown 

func (m *RerunPipelineRequest) XXX_DiscardUnknown()

func (*RerunPipelineRequest) XXX_Marshal 

func (m *RerunPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RerunPipelineRequest) XXX_Merge 

func (dst *RerunPipelineRequest) XXX_Merge(src proto.Message)

func (*RerunPipelineRequest) XXX_Size 

func (m *RerunPipelineRequest) XXX_Size() int

func (*RerunPipelineRequest) XXX_Unmarshal 

func (m *RerunPipelineRequest) XXX_Unmarshal(b []byte) error

type ResourceSpec 

type ResourceSpec struct {
	// The number of CPUs each worker needs (partial values are allowed, and
	// encouraged)
	Cpu float32 `protobuf:"fixed32,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// The amount of memory each worker needs (in bytes, with allowed
	// SI suffixes (M, K, G, Mi, Ki, Gi, etc).
	Memory string `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// The number of GPUs each worker needs.
	Gpu int64 `protobuf:"varint,3,opt,name=gpu,proto3" json:"gpu,omitempty"`
	// The amount of ephemeral storage each worker needs (in bytes, with allowed
	// SI suffixes (M, K, G, Mi, Ki, Gi, etc).
	Disk                 string   `protobuf:"bytes,4,opt,name=disk,proto3" json:"disk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceSpec describes the amount of resources that pipeline pods should request from kubernetes, for scheduling.

func (*ResourceSpec) Descriptor 

func (*ResourceSpec) Descriptor() ([]byte, []int)

func (*ResourceSpec) GetCpu 

func (m *ResourceSpec) GetCpu() float32

func (*ResourceSpec) GetDisk 

func (m *ResourceSpec) GetDisk() string

func (*ResourceSpec) GetGpu 

func (m *ResourceSpec) GetGpu() int64

func (*ResourceSpec) GetMemory 

func (m *ResourceSpec) GetMemory() string

func (*ResourceSpec) Marshal 

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

func (*ResourceSpec) MarshalTo 

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

func (*ResourceSpec) ProtoMessage 

func (*ResourceSpec) ProtoMessage()

func (*ResourceSpec) Reset 

func (m *ResourceSpec) Reset()

func (*ResourceSpec) Size 

func (m *ResourceSpec) Size() (n int)

func (*ResourceSpec) String 

func (m *ResourceSpec) String() string

func (*ResourceSpec) Unmarshal 

func (m *ResourceSpec) Unmarshal(dAtA []byte) error

func (*ResourceSpec) XXX_DiscardUnknown 

func (m *ResourceSpec) XXX_DiscardUnknown()

func (*ResourceSpec) XXX_Marshal 

func (m *ResourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceSpec) XXX_Merge 

func (dst *ResourceSpec) XXX_Merge(src proto.Message)

func (*ResourceSpec) XXX_Size 

func (m *ResourceSpec) XXX_Size() int

func (*ResourceSpec) XXX_Unmarshal 

func (m *ResourceSpec) XXX_Unmarshal(b []byte) error

type RestartDatumRequest 

type RestartDatumRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	DataFilters          []string `protobuf:"bytes,2,rep,name=data_filters,json=dataFilters,proto3" json:"data_filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestartDatumRequest) Descriptor 

func (*RestartDatumRequest) Descriptor() ([]byte, []int)

func (*RestartDatumRequest) GetDataFilters 

func (m *RestartDatumRequest) GetDataFilters() []string

func (*RestartDatumRequest) GetJob 

func (m *RestartDatumRequest) GetJob() *Job

func (*RestartDatumRequest) Marshal 

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

func (*RestartDatumRequest) MarshalTo 

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

func (*RestartDatumRequest) ProtoMessage 

func (*RestartDatumRequest) ProtoMessage()

func (*RestartDatumRequest) Reset 

func (m *RestartDatumRequest) Reset()

func (*RestartDatumRequest) Size 

func (m *RestartDatumRequest) Size() (n int)

func (*RestartDatumRequest) String 

func (m *RestartDatumRequest) String() string

func (*RestartDatumRequest) Unmarshal 

func (m *RestartDatumRequest) Unmarshal(dAtA []byte) error

func (*RestartDatumRequest) XXX_DiscardUnknown 

func (m *RestartDatumRequest) XXX_DiscardUnknown()

func (*RestartDatumRequest) XXX_Marshal 

func (m *RestartDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestartDatumRequest) XXX_Merge 

func (dst *RestartDatumRequest) XXX_Merge(src proto.Message)

func (*RestartDatumRequest) XXX_Size 

func (m *RestartDatumRequest) XXX_Size() int

func (*RestartDatumRequest) XXX_Unmarshal 

func (m *RestartDatumRequest) XXX_Unmarshal(b []byte) error

type SchedulingSpec 

type SchedulingSpec struct {
	NodeSelector         map[string]string `` /* 185-byte string literal not displayed */
	PriorityClassName    string            `protobuf:"bytes,2,opt,name=priority_class_name,json=priorityClassName,proto3" json:"priority_class_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SchedulingSpec) Descriptor 

func (*SchedulingSpec) Descriptor() ([]byte, []int)

func (*SchedulingSpec) GetNodeSelector 

func (m *SchedulingSpec) GetNodeSelector() map[string]string

func (*SchedulingSpec) GetPriorityClassName 

func (m *SchedulingSpec) GetPriorityClassName() string

func (*SchedulingSpec) Marshal 

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

func (*SchedulingSpec) MarshalTo 

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

func (*SchedulingSpec) ProtoMessage 

func (*SchedulingSpec) ProtoMessage()

func (*SchedulingSpec) Reset 

func (m *SchedulingSpec) Reset()

func (*SchedulingSpec) Size 

func (m *SchedulingSpec) Size() (n int)

func (*SchedulingSpec) String 

func (m *SchedulingSpec) String() string

func (*SchedulingSpec) Unmarshal 

func (m *SchedulingSpec) Unmarshal(dAtA []byte) error

func (*SchedulingSpec) XXX_DiscardUnknown 

func (m *SchedulingSpec) XXX_DiscardUnknown()

func (*SchedulingSpec) XXX_Marshal 

func (m *SchedulingSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulingSpec) XXX_Merge 

func (dst *SchedulingSpec) XXX_Merge(src proto.Message)

func (*SchedulingSpec) XXX_Size 

func (m *SchedulingSpec) XXX_Size() int

func (*SchedulingSpec) XXX_Unmarshal 

func (m *SchedulingSpec) XXX_Unmarshal(b []byte) error

type Secret 

type Secret struct {
	// Name must be the name of the secret in kubernetes.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Key of the secret to load into env_var, this field only has meaning if EnvVar != "".
	Key                  string   `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	MountPath            string   `protobuf:"bytes,2,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	EnvVar               string   `protobuf:"bytes,3,opt,name=env_var,json=envVar,proto3" json:"env_var,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Secret) Descriptor 

func (*Secret) Descriptor() ([]byte, []int)

func (*Secret) GetEnvVar 

func (m *Secret) GetEnvVar() string

func (*Secret) GetKey 

func (m *Secret) GetKey() string

func (*Secret) GetMountPath 

func (m *Secret) GetMountPath() string

func (*Secret) GetName 

func (m *Secret) GetName() string

func (*Secret) Marshal 

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

func (*Secret) MarshalTo 

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

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) Reset 

func (m *Secret) Reset()

func (*Secret) Size 

func (m *Secret) Size() (n int)

func (*Secret) String 

func (m *Secret) String() string

func (*Secret) Unmarshal 

func (m *Secret) Unmarshal(dAtA []byte) error

func (*Secret) XXX_DiscardUnknown 

func (m *Secret) XXX_DiscardUnknown()

func (*Secret) XXX_Marshal 

func (m *Secret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Secret) XXX_Merge 

func (dst *Secret) XXX_Merge(src proto.Message)

func (*Secret) XXX_Size 

func (m *Secret) XXX_Size() int

func (*Secret) XXX_Unmarshal 

func (m *Secret) XXX_Unmarshal(b []byte) error

type Service 

type Service struct {
	InternalPort         int32    `protobuf:"varint,1,opt,name=internal_port,json=internalPort,proto3" json:"internal_port,omitempty"`
	ExternalPort         int32    `protobuf:"varint,2,opt,name=external_port,json=externalPort,proto3" json:"external_port,omitempty"`
	IP                   string   `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Service) Descriptor 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) GetExternalPort 

func (m *Service) GetExternalPort() int32

func (*Service) GetIP 

func (m *Service) GetIP() string

func (*Service) GetInternalPort 

func (m *Service) GetInternalPort() int32

func (*Service) Marshal 

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

func (*Service) MarshalTo 

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

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) Size 

func (m *Service) Size() (n int)

func (*Service) String 

func (m *Service) String() string

func (*Service) Unmarshal 

func (m *Service) Unmarshal(dAtA []byte) error

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (dst *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type StartPipelineRequest 

type StartPipelineRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StartPipelineRequest) Descriptor 

func (*StartPipelineRequest) Descriptor() ([]byte, []int)

func (*StartPipelineRequest) GetPipeline 

func (m *StartPipelineRequest) GetPipeline() *Pipeline

func (*StartPipelineRequest) Marshal 

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

func (*StartPipelineRequest) MarshalTo 

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

func (*StartPipelineRequest) ProtoMessage 

func (*StartPipelineRequest) ProtoMessage()

func (*StartPipelineRequest) Reset 

func (m *StartPipelineRequest) Reset()

func (*StartPipelineRequest) Size 

func (m *StartPipelineRequest) Size() (n int)

func (*StartPipelineRequest) String 

func (m *StartPipelineRequest) String() string

func (*StartPipelineRequest) Unmarshal 

func (m *StartPipelineRequest) Unmarshal(dAtA []byte) error

func (*StartPipelineRequest) XXX_DiscardUnknown 

func (m *StartPipelineRequest) XXX_DiscardUnknown()

func (*StartPipelineRequest) XXX_Marshal 

func (m *StartPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartPipelineRequest) XXX_Merge 

func (dst *StartPipelineRequest) XXX_Merge(src proto.Message)

func (*StartPipelineRequest) XXX_Size 

func (m *StartPipelineRequest) XXX_Size() int

func (*StartPipelineRequest) XXX_Unmarshal 

func (m *StartPipelineRequest) XXX_Unmarshal(b []byte) error

type StopJobRequest 

type StopJobRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopJobRequest) Descriptor 

func (*StopJobRequest) Descriptor() ([]byte, []int)

func (*StopJobRequest) GetJob 

func (m *StopJobRequest) GetJob() *Job

func (*StopJobRequest) Marshal 

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

func (*StopJobRequest) MarshalTo 

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

func (*StopJobRequest) ProtoMessage 

func (*StopJobRequest) ProtoMessage()

func (*StopJobRequest) Reset 

func (m *StopJobRequest) Reset()

func (*StopJobRequest) Size 

func (m *StopJobRequest) Size() (n int)

func (*StopJobRequest) String 

func (m *StopJobRequest) String() string

func (*StopJobRequest) Unmarshal 

func (m *StopJobRequest) Unmarshal(dAtA []byte) error

func (*StopJobRequest) XXX_DiscardUnknown 

func (m *StopJobRequest) XXX_DiscardUnknown()

func (*StopJobRequest) XXX_Marshal 

func (m *StopJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopJobRequest) XXX_Merge 

func (dst *StopJobRequest) XXX_Merge(src proto.Message)

func (*StopJobRequest) XXX_Size 

func (m *StopJobRequest) XXX_Size() int

func (*StopJobRequest) XXX_Unmarshal 

func (m *StopJobRequest) XXX_Unmarshal(b []byte) error

type StopPipelineRequest 

type StopPipelineRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StopPipelineRequest) Descriptor 

func (*StopPipelineRequest) Descriptor() ([]byte, []int)

func (*StopPipelineRequest) GetPipeline 

func (m *StopPipelineRequest) GetPipeline() *Pipeline

func (*StopPipelineRequest) Marshal 

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

func (*StopPipelineRequest) MarshalTo 

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

func (*StopPipelineRequest) ProtoMessage 

func (*StopPipelineRequest) ProtoMessage()

func (*StopPipelineRequest) Reset 

func (m *StopPipelineRequest) Reset()

func (*StopPipelineRequest) Size 

func (m *StopPipelineRequest) Size() (n int)

func (*StopPipelineRequest) String 

func (m *StopPipelineRequest) String() string

func (*StopPipelineRequest) Unmarshal 

func (m *StopPipelineRequest) Unmarshal(dAtA []byte) error

func (*StopPipelineRequest) XXX_DiscardUnknown 

func (m *StopPipelineRequest) XXX_DiscardUnknown()

func (*StopPipelineRequest) XXX_Marshal 

func (m *StopPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopPipelineRequest) XXX_Merge 

func (dst *StopPipelineRequest) XXX_Merge(src proto.Message)

func (*StopPipelineRequest) XXX_Size 

func (m *StopPipelineRequest) XXX_Size() int

func (*StopPipelineRequest) XXX_Unmarshal 

func (m *StopPipelineRequest) XXX_Unmarshal(b []byte) error

type Transform 

type Transform struct {
	Image                string            `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Cmd                  []string          `protobuf:"bytes,2,rep,name=cmd,proto3" json:"cmd,omitempty"`
	Env                  map[string]string `` /* 147-byte string literal not displayed */
	Secrets              []*Secret         `protobuf:"bytes,4,rep,name=secrets,proto3" json:"secrets,omitempty"`
	ImagePullSecrets     []string          `protobuf:"bytes,9,rep,name=image_pull_secrets,json=imagePullSecrets,proto3" json:"image_pull_secrets,omitempty"`
	Stdin                []string          `protobuf:"bytes,5,rep,name=stdin,proto3" json:"stdin,omitempty"`
	AcceptReturnCode     []int64           `protobuf:"varint,6,rep,packed,name=accept_return_code,json=acceptReturnCode,proto3" json:"accept_return_code,omitempty"`
	Debug                bool              `protobuf:"varint,7,opt,name=debug,proto3" json:"debug,omitempty"`
	User                 string            `protobuf:"bytes,10,opt,name=user,proto3" json:"user,omitempty"`
	WorkingDir           string            `protobuf:"bytes,11,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Transform) Descriptor 

func (*Transform) Descriptor() ([]byte, []int)

func (*Transform) GetAcceptReturnCode 

func (m *Transform) GetAcceptReturnCode() []int64

func (*Transform) GetCmd 

func (m *Transform) GetCmd() []string

func (*Transform) GetDebug 

func (m *Transform) GetDebug() bool

func (*Transform) GetEnv 

func (m *Transform) GetEnv() map[string]string

func (*Transform) GetImage 

func (m *Transform) GetImage() string

func (*Transform) GetImagePullSecrets 

func (m *Transform) GetImagePullSecrets() []string

func (*Transform) GetSecrets 

func (m *Transform) GetSecrets() []*Secret

func (*Transform) GetStdin 

func (m *Transform) GetStdin() []string

func (*Transform) GetUser 

func (m *Transform) GetUser() string

func (*Transform) GetWorkingDir 

func (m *Transform) GetWorkingDir() string

func (*Transform) Marshal 

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

func (*Transform) MarshalTo 

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

func (*Transform) ProtoMessage 

func (*Transform) ProtoMessage()

func (*Transform) Reset 

func (m *Transform) Reset()

func (*Transform) Size 

func (m *Transform) Size() (n int)

func (*Transform) String 

func (m *Transform) String() string

func (*Transform) Unmarshal 

func (m *Transform) Unmarshal(dAtA []byte) error

func (*Transform) XXX_DiscardUnknown 

func (m *Transform) XXX_DiscardUnknown()

func (*Transform) XXX_Marshal 

func (m *Transform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Transform) XXX_Merge 

func (dst *Transform) XXX_Merge(src proto.Message)

func (*Transform) XXX_Size 

func (m *Transform) XXX_Size() int

func (*Transform) XXX_Unmarshal 

func (m *Transform) XXX_Unmarshal(b []byte) error

type Worker 

type Worker struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State                WorkerState `protobuf:"varint,2,opt,name=state,proto3,enum=pps_1_7.WorkerState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Worker) Descriptor 

func (*Worker) Descriptor() ([]byte, []int)

func (*Worker) GetName 

func (m *Worker) GetName() string

func (*Worker) GetState 

func (m *Worker) GetState() WorkerState

func (*Worker) Marshal 

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

func (*Worker) MarshalTo 

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

func (*Worker) ProtoMessage 

func (*Worker) ProtoMessage()

func (*Worker) Reset 

func (m *Worker) Reset()

func (*Worker) Size 

func (m *Worker) Size() (n int)

func (*Worker) String 

func (m *Worker) String() string

func (*Worker) Unmarshal 

func (m *Worker) Unmarshal(dAtA []byte) error

func (*Worker) XXX_DiscardUnknown 

func (m *Worker) XXX_DiscardUnknown()

func (*Worker) XXX_Marshal 

func (m *Worker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Worker) XXX_Merge 

func (dst *Worker) XXX_Merge(src proto.Message)

func (*Worker) XXX_Size 

func (m *Worker) XXX_Size() int

func (*Worker) XXX_Unmarshal 

func (m *Worker) XXX_Unmarshal(b []byte) error

type WorkerState 

type WorkerState int32
const (
	WorkerState_POD_RUNNING WorkerState = 0
	WorkerState_POD_SUCCESS WorkerState = 1
	WorkerState_POD_FAILED  WorkerState = 2
)

func (WorkerState) EnumDescriptor 

func (WorkerState) EnumDescriptor() ([]byte, []int)

func (WorkerState) String 

func (x WorkerState) String() string

type WorkerStatus 

type WorkerStatus struct {
	WorkerID string       `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	JobID    string       `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Data     []*InputFile `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	// Started is the time processing on the current datum began.
	Started              *types.Timestamp `protobuf:"bytes,4,opt,name=started,proto3" json:"started,omitempty"`
	Stats                *ProcessStats    `protobuf:"bytes,5,opt,name=stats,proto3" json:"stats,omitempty"`
	QueueSize            int64            `protobuf:"varint,6,opt,name=queue_size,json=queueSize,proto3" json:"queue_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*WorkerStatus) Descriptor 

func (*WorkerStatus) Descriptor() ([]byte, []int)

func (*WorkerStatus) GetData 

func (m *WorkerStatus) GetData() []*InputFile

func (*WorkerStatus) GetJobID 

func (m *WorkerStatus) GetJobID() string

func (*WorkerStatus) GetQueueSize 

func (m *WorkerStatus) GetQueueSize() int64

func (*WorkerStatus) GetStarted 

func (m *WorkerStatus) GetStarted() *types.Timestamp

func (*WorkerStatus) GetStats 

func (m *WorkerStatus) GetStats() *ProcessStats

func (*WorkerStatus) GetWorkerID 

func (m *WorkerStatus) GetWorkerID() string

func (*WorkerStatus) Marshal 

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

func (*WorkerStatus) MarshalTo 

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

func (*WorkerStatus) ProtoMessage 

func (*WorkerStatus) ProtoMessage()

func (*WorkerStatus) Reset 

func (m *WorkerStatus) Reset()

func (*WorkerStatus) Size 

func (m *WorkerStatus) Size() (n int)

func (*WorkerStatus) String 

func (m *WorkerStatus) String() string

func (*WorkerStatus) Unmarshal 

func (m *WorkerStatus) Unmarshal(dAtA []byte) error

func (*WorkerStatus) XXX_DiscardUnknown 

func (m *WorkerStatus) XXX_DiscardUnknown()

func (*WorkerStatus) XXX_Marshal 

func (m *WorkerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerStatus) XXX_Merge 

func (dst *WorkerStatus) XXX_Merge(src proto.Message)

func (*WorkerStatus) XXX_Size 

func (m *WorkerStatus) XXX_Size() int

func (*WorkerStatus) XXX_Unmarshal 

func (m *WorkerStatus) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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