pps

Apr 8, 2017

Changes in this version

+ type Datum struct

+ Hash []byte

+ Path string

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

+ func (*Datum) ProtoMessage()

+ func (m *Datum) GetHash() []byte

+ func (m *Datum) GetPath() string

+ func (m *Datum) Reset()

+ func (m *Datum) String() string

type DeletePipelineRequest

+ DeleteJobs bool

+ func (m *DeletePipelineRequest) GetDeleteJobs() bool

type JobInfo

+ DataProcessed int64

+ DataTotal int64

+ func (m *JobInfo) GetDataProcessed() int64

+ func (m *JobInfo) GetDataTotal() int64

type JobState

+ const JobState_JOB_STOPPED

Apr 7, 2017

Changes in this version

type JobInfo

+ Restart uint64

+ func (m *JobInfo) GetRestart() uint64

Apr 5, 2017

Changes in this version

type LogMessage

+ User bool

+ WorkerID string

+ func (m *LogMessage) GetUser() bool

+ func (m *LogMessage) GetWorkerID() string

Mar 29, 2017

Changes in this version

+ var WorkerState_name = map[int32]string

+ var WorkerState_value = map[string]int32

type CreateJobRequest

+ Egress *Egress

+ OutputBranch string

+ OutputRepo *pfs.Repo

+ func (m *CreateJobRequest) GetEgress() *Egress

+ func (m *CreateJobRequest) GetOutputBranch() string

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

type CreatePipelineRequest

+ Egress *Egress

+ OutputBranch string

+ func (m *CreatePipelineRequest) GetEgress() *Egress

+ func (m *CreatePipelineRequest) GetOutputBranch() string

+ type Egress struct

+ URL string

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

+ func (*Egress) ProtoMessage()

+ func (m *Egress) GetURL() string

+ func (m *Egress) Reset()

+ func (m *Egress) String() string

type GetLogsRequest

+ DataFilters []string

+ Pipeline *Pipeline

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

+ func (m *GetLogsRequest) GetPipeline() *Pipeline

type JobInfo

+ Egress *Egress

+ Error string

+ OutputBranch string

+ OutputRepo *pfs.Repo

+ PipelineID string

+ Stopped bool

+ func (m *JobInfo) GetEgress() *Egress

+ func (m *JobInfo) GetError() string

+ func (m *JobInfo) GetOutputBranch() string

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

+ func (m *JobInfo) GetPipelineID() string

+ func (m *JobInfo) GetStopped() bool

type JobInput

+ Glob string

+ Name string

+ func (m *JobInput) GetGlob() string

+ func (m *JobInput) GetName() string

type JobState

+ const JobState_JOB_STARTING

+ type LogMessage struct

+ Data []*LogMessage_Datum

+ JobID string

+ Message string

+ PipelineID string

+ PipelineName string

+ Ts *google_protobuf1.Timestamp

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

+ func (*LogMessage) ProtoMessage()

+ func (m *LogMessage) GetData() []*LogMessage_Datum

+ func (m *LogMessage) GetJobID() string

+ func (m *LogMessage) GetMessage() string

+ func (m *LogMessage) GetPipelineID() string

+ func (m *LogMessage) GetPipelineName() string

+ func (m *LogMessage) GetTs() *google_protobuf1.Timestamp

+ func (m *LogMessage) Reset()

+ func (m *LogMessage) String() string

+ type LogMessage_Datum struct

+ Hash []byte

+ Path string

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

+ func (*LogMessage_Datum) ProtoMessage()

+ func (m *LogMessage_Datum) GetHash() []byte

+ func (m *LogMessage_Datum) GetPath() string

+ func (m *LogMessage_Datum) Reset()

+ func (m *LogMessage_Datum) String() string

type PipelineInfo

+ Egress *Egress

+ ID string

+ OutputBranch string

+ Stopped bool

+ func (m *PipelineInfo) GetEgress() *Egress

+ func (m *PipelineInfo) GetID() string

+ func (m *PipelineInfo) GetOutputBranch() string

+ func (m *PipelineInfo) GetStopped() bool

type PipelineInput

+ Branch string

+ From *pfs.Commit

+ Glob string

+ Name string

+ func (m *PipelineInput) GetBranch() string

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

+ func (m *PipelineInput) GetGlob() string

+ func (m *PipelineInput) GetName() string

type PipelineState

+ const PipelineState_PIPELINE_STARTING

+ type Worker struct

+ Name string

+ State WorkerState

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

+ func (*Worker) ProtoMessage()

+ func (m *Worker) GetName() string

+ func (m *Worker) GetState() WorkerState

+ func (m *Worker) Reset()

+ func (m *Worker) String() string

+ type WorkerState int32

+ const WorkerState_POD_FAILED

+ const WorkerState_POD_RUNNING

+ const WorkerState_POD_SUCCESS

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

+ func (x WorkerState) String() string

Mar 7, 2017

Changes in this version

type PipelineInfo

+ Resources *Resources

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

Mar 7, 2017

Changes in this version

type CreateJobRequest

+ Resources *Resources

+ func (m *CreateJobRequest) GetResources() *Resources

type CreatePipelineRequest

+ Resources *Resources

+ func (m *CreatePipelineRequest) GetResources() *Resources

type JobInfo

+ Resources *Resources

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

+ type Resources struct

+ Cpu float32

+ Memory string

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

+ func (*Resources) ProtoMessage()

+ func (m *Resources) GetCpu() float32

+ func (m *Resources) GetMemory() string

+ func (m *Resources) Reset()

+ func (m *Resources) String() string

Feb 16, 2017

Changes in this version

type APIClient

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

type APIServer

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

type CreateJobRequest

+ PipelineVersion uint64

+ func (m *CreateJobRequest) GetPipelineVersion() uint64

+ type RerunPipelineRequest struct

+ Exclude []*pfs.Commit

+ Include []*pfs.Commit

+ Pipeline *Pipeline

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

+ func (*RerunPipelineRequest) ProtoMessage()

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

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

+ func (m *RerunPipelineRequest) GetPipeline() *Pipeline

+ func (m *RerunPipelineRequest) Reset()

+ func (m *RerunPipelineRequest) String() string

Feb 9, 2017

Changes in this version

type Chunk

+ func (m *Chunk) GetID() string

+ func (m *Chunk) GetState() ChunkState

type CreateJobRequest

+ func (m *CreateJobRequest) GetForce() bool

type CreatePipelineRequest

+ func (m *CreatePipelineRequest) GetNoArchive() bool

+ func (m *CreatePipelineRequest) GetUpdate() bool

type InspectJobRequest

+ func (m *InspectJobRequest) GetBlockState() bool

type Job

+ func (m *Job) GetID() string

type JobInfo

+ func (m *JobInfo) GetPipelineVersion() uint64

+ func (m *JobInfo) GetState() JobState

type JobInput

+ func (m *JobInput) GetLazy() bool

+ func (m *JobInput) GetRunEmpty() bool

type Method

+ func (m *Method) GetIncremental() Incremental

+ func (m *Method) GetPartition() Partition

type Output

+ func (m *Output) GetURL() string

type ParallelismSpec

+ func (m *ParallelismSpec) GetCoefficient() float64

+ func (m *ParallelismSpec) GetConstant() uint64

+ func (m *ParallelismSpec) GetStrategy() ParallelismSpec_Strategy

type Pipeline

+ func (m *Pipeline) GetName() string

type PipelineInfo

+ func (m *PipelineInfo) GetRecentError() string

+ func (m *PipelineInfo) GetState() PipelineState

+ func (m *PipelineInfo) GetVersion() uint64

type PipelineInput

+ func (m *PipelineInput) GetLazy() bool

+ func (m *PipelineInput) GetRunEmpty() bool

type Pod

+ func (m *Pod) GetName() string

+ func (m *Pod) GetState() PodState

type Secret

+ func (m *Secret) GetMountPath() string

+ func (m *Secret) GetName() string

type Service

+ func (m *Service) GetExternalPort() int32

+ func (m *Service) GetInternalPort() int32

type Transform

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

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

+ func (m *Transform) GetDebug() bool

+ func (m *Transform) GetImage() string

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

+ func (m *Transform) GetOverwrite() bool

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

Dec 21, 2016

Changes in this version

type CreateJobRequest

+ Output *Output

+ func (m *CreateJobRequest) GetOutput() *Output

type CreatePipelineRequest

+ Output *Output

+ func (m *CreatePipelineRequest) GetOutput() *Output

type JobInfo

+ Output *Output

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

type JobState

+ const JobState_JOB_OUTPUTTING

+ type Output struct

+ URL string

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

+ func (*Output) ProtoMessage()

+ func (m *Output) Reset()

+ func (m *Output) String() string

type PipelineInfo

+ Output *Output

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

type Transform

+ ImagePullSecrets []string

Dec 7, 2016

Changes in this version

type APIClient

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

type APIServer

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

type CreateJobRequest

+ Service *Service

+ func (m *CreateJobRequest) GetService() *Service

type CreatePipelineRequest

+ GcPolicy *GCPolicy

+ func (m *CreatePipelineRequest) GetGcPolicy() *GCPolicy

+ type DeleteJobRequest struct

+ Job *Job

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

+ func (*DeleteJobRequest) ProtoMessage()

+ func (m *DeleteJobRequest) GetJob() *Job

+ func (m *DeleteJobRequest) Reset()

+ func (m *DeleteJobRequest) String() string

+ type GCPolicy struct

+ Failure *google_protobuf2.Duration

+ Success *google_protobuf2.Duration

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

+ func (*GCPolicy) ProtoMessage()

+ func (m *GCPolicy) GetFailure() *google_protobuf2.Duration

+ func (m *GCPolicy) GetSuccess() *google_protobuf2.Duration

+ func (m *GCPolicy) Reset()

+ func (m *GCPolicy) String() string

type JobInfo

+ Service *Service

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

type JobInput

+ Lazy bool

type PipelineInfo

+ GcPolicy *GCPolicy

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

type PipelineInput

+ Lazy bool

+ type Service struct

+ ExternalPort int32

+ InternalPort int32

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

+ func (*Service) ProtoMessage()

+ func (m *Service) Reset()

+ func (m *Service) String() string

Dec 1, 2016

Changes in this version

type Transform

+ Overwrite bool

Nov 23, 2016

Changes in this version

+ var ChunkState_name = map[int32]string

+ var ChunkState_value = map[string]int32

+ var PodState_name = map[int32]string

+ var PodState_value = map[string]int32

+ type Chunk struct

+ ID string

+ Pods []*Pod

+ State ChunkState

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

+ func (*Chunk) ProtoMessage()

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

+ func (m *Chunk) Reset()

+ func (m *Chunk) String() string

+ type ChunkState int32

+ const ChunkState_CHUNK_ASSIGNED

+ const ChunkState_CHUNK_FAILURE

+ const ChunkState_CHUNK_SUCCESS

+ const ChunkState_CHUNK_UNASSIGNED

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

+ func (x ChunkState) String() string

type JobInfo

+ Chunks []*Chunk

+ PipelineVersion uint64

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

type JobState

+ const JobState_JOB_CREATING

type PipelineInfo

+ Version uint64

+ type Pod struct

+ Name string

+ OutputCommit *pfs.Commit

+ State PodState

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

+ func (*Pod) ProtoMessage()

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

+ func (m *Pod) Reset()

+ func (m *Pod) String() string

+ type PodState int32

+ const PodState_POD_FAILED

+ const PodState_POD_RUNNING

+ const PodState_POD_SUCCESS

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

+ func (x PodState) String() string

Sep 23, 2016

Changes in this version

+ var Incremental_name = map[int32]string

+ var Incremental_value = map[string]int32

+ var ParallelismSpec_Strategy_name = map[int32]string

+ var ParallelismSpec_Strategy_value = map[string]int32

type APIClient

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

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

type APIServer

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

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

type CreateJobRequest

+ ParallelismSpec *ParallelismSpec

+ func (m *CreateJobRequest) GetParallelismSpec() *ParallelismSpec

type CreatePipelineRequest

+ NoArchive bool

+ ParallelismSpec *ParallelismSpec

+ Update bool

+ func (m *CreatePipelineRequest) GetParallelismSpec() *ParallelismSpec

+ type Incremental int32

+ const Incremental_DIFF

+ const Incremental_FULL

+ const Incremental_NONE

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

+ func (x Incremental) String() string

type JobInfo

+ ParallelismSpec *ParallelismSpec

+ PodCommits map[uint64]string

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

+ func (m *JobInfo) GetPodCommits() map[uint64]string

type JobInput

+ RunEmpty bool

type JobState

+ const JobState_JOB_EMPTY

+ type ParallelismSpec struct

+ Coefficient float64

+ Constant uint64

+ Strategy ParallelismSpec_Strategy

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

+ func (*ParallelismSpec) ProtoMessage()

+ func (m *ParallelismSpec) Reset()

+ func (m *ParallelismSpec) String() string

+ type ParallelismSpec_Strategy int32

+ const ParallelismSpec_COEFFICIENT

+ const ParallelismSpec_CONSTANT

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

+ func (x ParallelismSpec_Strategy) String() string

type PipelineInfo

+ ParallelismSpec *ParallelismSpec

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

type PipelineInput

+ RunEmpty bool

type PipelineState

+ const PipelineState_PIPELINE_STOPPED

+ type Secret struct

+ MountPath string

+ Name string

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

+ func (*Secret) ProtoMessage()

+ func (m *Secret) Reset()

+ func (m *Secret) String() string

+ type StartPipelineRequest struct

+ Pipeline *Pipeline

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

+ func (*StartPipelineRequest) ProtoMessage()

+ func (m *StartPipelineRequest) GetPipeline() *Pipeline

+ func (m *StartPipelineRequest) Reset()

+ func (m *StartPipelineRequest) String() string

+ type StopPipelineRequest struct

+ Pipeline *Pipeline

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

+ func (*StopPipelineRequest) ProtoMessage()

+ func (m *StopPipelineRequest) GetPipeline() *Pipeline

+ func (m *StopPipelineRequest) Reset()

+ func (m *StopPipelineRequest) String() string

type Transform

+ Env map[string]string

+ Secrets []*Secret

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

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

Apr 14, 2016

Changes in this version

+ func DeletePipeline(client APIClient, name string) error

Apr 11, 2016

Changes in this version

+ func GetLogs(client APIClient, jobID string, writer io.Writer) error

Apr 11, 2016

Changes in this version

+ func CreatePipeline(client APIClient, name string, image string, cmd []string, stdin []string, ...) error

+ func RegisterJobAPIServer(s *grpc.Server, srv JobAPIServer)

+ func RegisterPipelineAPIServer(s *grpc.Server, srv PipelineAPIServer)

type CreateJobRequest

+ Shards uint64

type CreatePipelineRequest

+ Shards uint64

type InspectJobRequest

+ BlockOutput bool

type Job

+ func CreateJob(client APIClient, image string, cmd []string, stdin []string, shards uint64, ...) (*Job, error)

+ func NewJob(jobID string) *Job

+ type JobAPIClient interface

+ CreateJob func(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)

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

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

+ func NewJobAPIClient(cc *grpc.ClientConn) JobAPIClient

+ type JobAPIServer interface

+ CreateJob func(context.Context, *CreateJobRequest) (*Job, error)

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

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

type JobInfo

+ CreatedAt *google_protobuf1.Timestamp

+ Shards uint64

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

type JobInput

+ Reduce bool

type JobState

+ const JobState_JOB_STATE_FAILURE

+ const JobState_JOB_STATE_RUNNING

+ const JobState_JOB_STATE_SUCCESS

type Pipeline

+ func NewPipeline(pipelineName string) *Pipeline

+ type PipelineAPIClient interface

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

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

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

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

+ func NewPipelineAPIClient(cc *grpc.ClientConn) PipelineAPIClient

+ type PipelineAPIServer interface

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

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

+ InspectPipeline func(context.Context, *InspectPipelineRequest) (*PipelineInfo, error)

+ ListPipeline func(context.Context, *ListPipelineRequest) (*PipelineInfos, error)

type PipelineInfo

+ Shards uint64

type PipelineInput

+ Reduce bool

Jun 28, 2016

Changes in this version

+ var JobState_name = map[int32]string

+ var JobState_value = map[string]int32

+ var Partition_name = map[int32]string

+ var Partition_value = map[string]int32

+ var PipelineState_name = map[int32]string

+ var PipelineState_value = map[string]int32

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

+ type APIClient interface

+ CreateJob func(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)

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

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

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

+ GetLogs func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error)

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

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

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

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

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

+ CreateJob func(context.Context, *CreateJobRequest) (*Job, error)

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

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

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

+ GetLogs func(*GetLogsRequest, API_GetLogsServer) error

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

+ InspectPipeline func(context.Context, *InspectPipelineRequest) (*PipelineInfo, error)

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

+ ListPipeline func(context.Context, *ListPipelineRequest) (*PipelineInfos, error)

+ type API_GetLogsClient interface

+ Recv func() (*google_protobuf2.BytesValue, error)

+ type API_GetLogsServer interface

+ Send func(*google_protobuf2.BytesValue) error

+ type CreateJobRequest struct

+ Force bool

+ Inputs []*JobInput

+ Parallelism uint64

+ ParentJob *Job

+ Pipeline *Pipeline

+ Transform *Transform

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

+ func (*CreateJobRequest) ProtoMessage()

+ func (m *CreateJobRequest) GetInputs() []*JobInput

+ func (m *CreateJobRequest) GetParentJob() *Job

+ func (m *CreateJobRequest) GetPipeline() *Pipeline

+ func (m *CreateJobRequest) GetTransform() *Transform

+ func (m *CreateJobRequest) Reset()

+ func (m *CreateJobRequest) String() string

+ type CreatePipelineRequest struct

+ Inputs []*PipelineInput

+ Parallelism uint64

+ Pipeline *Pipeline

+ Transform *Transform

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

+ func (*CreatePipelineRequest) ProtoMessage()

+ func (m *CreatePipelineRequest) GetInputs() []*PipelineInput

+ func (m *CreatePipelineRequest) GetPipeline() *Pipeline

+ func (m *CreatePipelineRequest) GetTransform() *Transform

+ func (m *CreatePipelineRequest) Reset()

+ func (m *CreatePipelineRequest) String() string

+ type DeletePipelineRequest struct

+ Pipeline *Pipeline

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

+ func (*DeletePipelineRequest) ProtoMessage()

+ func (m *DeletePipelineRequest) GetPipeline() *Pipeline

+ func (m *DeletePipelineRequest) Reset()

+ func (m *DeletePipelineRequest) String() string

+ type GetLogsRequest struct

+ Job *Job

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

+ func (*GetLogsRequest) ProtoMessage()

+ func (m *GetLogsRequest) GetJob() *Job

+ func (m *GetLogsRequest) Reset()

+ func (m *GetLogsRequest) String() string

+ type InspectJobRequest struct

+ BlockState bool

+ Job *Job

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

+ func (*InspectJobRequest) ProtoMessage()

+ func (m *InspectJobRequest) GetJob() *Job

+ func (m *InspectJobRequest) Reset()

+ func (m *InspectJobRequest) String() string

+ type InspectPipelineRequest struct

+ Pipeline *Pipeline

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

+ func (*InspectPipelineRequest) ProtoMessage()

+ func (m *InspectPipelineRequest) GetPipeline() *Pipeline

+ func (m *InspectPipelineRequest) Reset()

+ func (m *InspectPipelineRequest) String() string

+ type Job struct

+ ID string

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

+ func (*Job) ProtoMessage()

+ func (m *Job) Reset()

+ func (m *Job) String() string

+ type JobInfo struct

+ Finished *google_protobuf1.Timestamp

+ Inputs []*JobInput

+ Job *Job

+ OutputCommit *pfs.Commit

+ Parallelism uint64

+ ParentJob *Job

+ Pipeline *Pipeline

+ Started *google_protobuf1.Timestamp

+ State JobState

+ Transform *Transform

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

+ func (*JobInfo) ProtoMessage()

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

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

+ func (m *JobInfo) GetJob() *Job

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

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

+ func (m *JobInfo) GetPipeline() *Pipeline

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

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

+ func (m *JobInfo) Reset()

+ func (m *JobInfo) String() string

+ type JobInfos struct

+ JobInfo []*JobInfo

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

+ func (*JobInfos) ProtoMessage()

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

+ func (m *JobInfos) Reset()

+ func (m *JobInfos) String() string

+ type JobInput struct

+ Commit *pfs.Commit

+ Method *Method

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

+ func (*JobInput) ProtoMessage()

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

+ func (m *JobInput) GetMethod() *Method

+ func (m *JobInput) Reset()

+ func (m *JobInput) String() string

+ type JobState int32

+ const JobState_JOB_FAILURE

+ const JobState_JOB_PULLING

+ const JobState_JOB_RUNNING

+ const JobState_JOB_SUCCESS

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

+ func (x JobState) String() string

+ type ListJobRequest struct

+ InputCommit []*pfs.Commit

+ Pipeline *Pipeline

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

+ func (*ListJobRequest) ProtoMessage()

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

+ func (m *ListJobRequest) GetPipeline() *Pipeline

+ func (m *ListJobRequest) Reset()

+ func (m *ListJobRequest) String() string

+ type ListPipelineRequest struct

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

+ func (*ListPipelineRequest) ProtoMessage()

+ func (m *ListPipelineRequest) Reset()

+ func (m *ListPipelineRequest) String() string

+ type Method struct

+ Incremental bool

+ Partition Partition

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

+ func (*Method) ProtoMessage()

+ func (m *Method) Reset()

+ func (m *Method) String() string

+ type Partition int32

+ const Partition_BLOCK

+ const Partition_FILE

+ const Partition_REPO

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

+ func (x Partition) String() string

+ type Pipeline struct

+ Name string

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

+ func (*Pipeline) ProtoMessage()

+ func (m *Pipeline) Reset()

+ func (m *Pipeline) String() string

+ type PipelineInfo struct

+ CreatedAt *google_protobuf1.Timestamp

+ Inputs []*PipelineInput

+ JobCounts map[int32]int32

+ OutputRepo *pfs.Repo

+ Parallelism uint64

+ Pipeline *Pipeline

+ RecentError string

+ State PipelineState

+ Transform *Transform

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

+ func (*PipelineInfo) ProtoMessage()

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

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

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

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

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

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

+ func (m *PipelineInfo) Reset()

+ func (m *PipelineInfo) String() string

+ type PipelineInfos struct

+ PipelineInfo []*PipelineInfo

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

+ func (*PipelineInfos) ProtoMessage()

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

+ func (m *PipelineInfos) Reset()

+ func (m *PipelineInfos) String() string

+ type PipelineInput struct

+ Method *Method

+ Repo *pfs.Repo

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

+ func (*PipelineInput) ProtoMessage()

+ func (m *PipelineInput) GetMethod() *Method

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

+ func (m *PipelineInput) Reset()

+ func (m *PipelineInput) String() string

+ type PipelineState int32

+ const PipelineState_PIPELINE_FAILURE

+ const PipelineState_PIPELINE_IDLE

+ const PipelineState_PIPELINE_RESTARTING

+ const PipelineState_PIPELINE_RUNNING

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

+ func (x PipelineState) String() string

+ type Transform struct

+ AcceptReturnCode []int64

+ Cmd []string

+ Debug bool

+ Image string

+ Stdin []string

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

+ func (*Transform) ProtoMessage()

+ func (m *Transform) Reset()

+ func (m *Transform) String() string