pps

Apr 19, 2018

Changes in this version

type CreatePipelineRequest

+ Standby bool

+ func (m *CreatePipelineRequest) GetStandby() bool

type InspectJobRequest

+ OutputCommit *pfs.Commit

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

type PipelineInfo

+ Standby bool

+ func (m *PipelineInfo) GetStandby() bool

type PipelineState

+ const PipelineState_PIPELINE_STANDBY

type Transform

+ User string

+ WorkingDir string

+ func (m *Transform) GetUser() string

+ func (m *Transform) GetWorkingDir() string

Mar 27, 2018

Changes in this version

+ func InputBranches(input *Input) []*pfs.Branch

type APIClient

+ ActivateAuth func(ctx context.Context, in *ActivateAuthRequest, opts ...grpc.CallOption) (*ActivateAuthResponse, error)

+ FlushJob func(ctx context.Context, in *FlushJobRequest, opts ...grpc.CallOption) (API_FlushJobClient, error)

type APIServer

+ ActivateAuth func(context.Context, *ActivateAuthRequest) (*ActivateAuthResponse, error)

+ FlushJob func(*FlushJobRequest, API_FlushJobServer) error

+ type API_FlushJobClient interface

+ Recv func() (*JobInfo, error)

+ type API_FlushJobServer interface

+ Send func(*JobInfo) error

+ type ActivateAuthRequest struct

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

+ func (*ActivateAuthRequest) ProtoMessage()

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

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

+ func (m *ActivateAuthRequest) Reset()

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

+ func (m *ActivateAuthRequest) String() string

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

+ type ActivateAuthResponse struct

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

+ func (*ActivateAuthResponse) ProtoMessage()

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

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

+ func (m *ActivateAuthResponse) Reset()

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

+ func (m *ActivateAuthResponse) String() string

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

type CreateJobRequest

+ OutputCommit *pfs.Commit

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

+ type EtcdJobInfo struct

+ DataFailed int64

+ DataProcessed int64

+ DataSkipped int64

+ DataTotal int64

+ Job *Job

+ OutputCommit *pfs.Commit

+ Pipeline *Pipeline

+ Reason string

+ Restart uint64

+ State JobState

+ Stats *ProcessStats

+ StatsCommit *pfs.Commit

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

+ func (*EtcdJobInfo) ProtoMessage()

+ func (m *EtcdJobInfo) GetDataFailed() int64

+ func (m *EtcdJobInfo) GetDataProcessed() int64

+ func (m *EtcdJobInfo) GetDataSkipped() int64

+ func (m *EtcdJobInfo) GetDataTotal() int64

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

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

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

+ func (m *EtcdJobInfo) GetReason() string

+ func (m *EtcdJobInfo) GetRestart() uint64

+ func (m *EtcdJobInfo) GetState() JobState

+ func (m *EtcdJobInfo) GetStats() *ProcessStats

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

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

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

+ func (m *EtcdJobInfo) Reset()

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

+ func (m *EtcdJobInfo) String() string

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

+ type EtcdPipelineInfo struct

+ AuthToken string

+ JobCounts map[int32]int32

+ Reason string

+ SpecCommit *pfs.Commit

+ State PipelineState

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

+ func (*EtcdPipelineInfo) ProtoMessage()

+ func (m *EtcdPipelineInfo) GetAuthToken() string

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

+ func (m *EtcdPipelineInfo) GetReason() string

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

+ func (m *EtcdPipelineInfo) GetState() PipelineState

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

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

+ func (m *EtcdPipelineInfo) Reset()

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

+ func (m *EtcdPipelineInfo) String() string

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

+ type FlushJobRequest struct

+ Commits []*pfs.Commit

+ ToPipelines []*Pipeline

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

+ func (*FlushJobRequest) ProtoMessage()

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

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

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

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

+ func (m *FlushJobRequest) Reset()

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

+ func (m *FlushJobRequest) String() string

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

type PipelineInfo

+ SpecCommit *pfs.Commit

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

type Service

+ IP string

+ func (m *Service) GetIP() string

Feb 27, 2018

Changes in this version

type CreatePipelineRequest

+ Salt string

+ func (m *CreatePipelineRequest) GetSalt() string

Jan 29, 2018

Changes in this version

type AtomInput

+ EmptyFiles bool

+ func (m *AtomInput) GetEmptyFiles() bool

Jan 11, 2018

Changes in this version

type GetLogsRequest

+ Follow bool

+ Tail int64

+ func (m *GetLogsRequest) GetFollow() bool

+ func (m *GetLogsRequest) GetTail() int64

type JobInfo

+ DataFailed int64

+ func (m *JobInfo) GetDataFailed() int64

type PipelineInfo

+ GithookURL string

+ func (m *PipelineInfo) GetGithookURL() string

Dec 11, 2017

Changes in this version

+ type ChunkSpec struct

+ Number int64

+ SizeBytes int64

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

+ func (*ChunkSpec) ProtoMessage()

+ func (m *ChunkSpec) GetNumber() int64

+ func (m *ChunkSpec) GetSizeBytes() int64

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

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

+ func (m *ChunkSpec) Reset()

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

+ func (m *ChunkSpec) String() string

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

type CreateJobRequest

+ ChunkSpec *ChunkSpec

+ DatumTimeout *google_protobuf2.Duration

+ JobTimeout *google_protobuf2.Duration

+ func (m *CreateJobRequest) GetChunkSpec() *ChunkSpec

+ func (m *CreateJobRequest) GetDatumTimeout() *google_protobuf2.Duration

+ func (m *CreateJobRequest) GetJobTimeout() *google_protobuf2.Duration

type CreatePipelineRequest

+ ChunkSpec *ChunkSpec

+ DatumTimeout *google_protobuf2.Duration

+ JobTimeout *google_protobuf2.Duration

+ func (m *CreatePipelineRequest) GetChunkSpec() *ChunkSpec

+ func (m *CreatePipelineRequest) GetDatumTimeout() *google_protobuf2.Duration

+ func (m *CreatePipelineRequest) GetJobTimeout() *google_protobuf2.Duration

type JobInfo

+ ChunkSpec *ChunkSpec

+ DatumTimeout *google_protobuf2.Duration

+ JobTimeout *google_protobuf2.Duration

+ func (m *JobInfo) GetChunkSpec() *ChunkSpec

+ func (m *JobInfo) GetDatumTimeout() *google_protobuf2.Duration

+ func (m *JobInfo) GetJobTimeout() *google_protobuf2.Duration

type PipelineInfo

+ ChunkSpec *ChunkSpec

+ DatumTimeout *google_protobuf2.Duration

+ JobTimeout *google_protobuf2.Duration

+ func (m *PipelineInfo) GetChunkSpec() *ChunkSpec

+ func (m *PipelineInfo) GetDatumTimeout() *google_protobuf2.Duration

+ func (m *PipelineInfo) GetJobTimeout() *google_protobuf2.Duration

Nov 17, 2017

Changes in this version

type CreateJobRequest

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ func (m *CreateJobRequest) GetResourceLimits() *ResourceSpec

+ func (m *CreateJobRequest) GetResourceRequests() *ResourceSpec

type CreatePipelineRequest

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ func (m *CreatePipelineRequest) GetResourceLimits() *ResourceSpec

+ func (m *CreatePipelineRequest) GetResourceRequests() *ResourceSpec

type JobInfo

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ func (m *JobInfo) GetResourceLimits() *ResourceSpec

+ func (m *JobInfo) GetResourceRequests() *ResourceSpec

type PipelineInfo

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ func (m *PipelineInfo) GetResourceLimits() *ResourceSpec

+ func (m *PipelineInfo) GetResourceRequests() *ResourceSpec

Nov 15, 2017

Changes in this version

+ func ValidateGitCloneURL(url string) error

type APIClient

+ ListDatumStream func(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (API_ListDatumStreamClient, error)

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

type APIServer

+ ListDatumStream func(*ListDatumRequest, API_ListDatumStreamServer) error

+ ListJobStream func(*ListJobRequest, API_ListJobStreamServer) error

+ type API_ListDatumStreamClient interface

+ Recv func() (*ListDatumStreamResponse, error)

+ type API_ListDatumStreamServer interface

+ Send func(*ListDatumStreamResponse) error

+ type API_ListJobStreamClient interface

+ Recv func() (*JobInfo, error)

+ type API_ListJobStreamServer interface

+ Send func(*JobInfo) error

+ type GitInput struct

+ Branch string

+ Commit string

+ Name string

+ URL string

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

+ func (*GitInput) ProtoMessage()

+ func (m *GitInput) GetBranch() string

+ func (m *GitInput) GetCommit() string

+ func (m *GitInput) GetName() string

+ func (m *GitInput) GetURL() string

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

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

+ func (m *GitInput) Reset()

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

+ func (m *GitInput) String() string

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

type Input

+ Git *GitInput

+ func (m *Input) GetGit() *GitInput

+ type ListDatumStreamResponse struct

+ DatumInfo *DatumInfo

+ Page int64

+ TotalPages int64

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

+ func (*ListDatumStreamResponse) ProtoMessage()

+ func (m *ListDatumStreamResponse) GetDatumInfo() *DatumInfo

+ func (m *ListDatumStreamResponse) GetPage() int64

+ func (m *ListDatumStreamResponse) GetTotalPages() int64

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

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

+ func (m *ListDatumStreamResponse) Reset()

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

+ func (m *ListDatumStreamResponse) String() string

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

Oct 4, 2017

Changes in this version

type CreatePipelineRequest

+ MaxQueueSize int64

+ Service *Service

+ func (m *CreatePipelineRequest) GetMaxQueueSize() int64

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

type GetLogsRequest

+ Datum *Datum

+ func (m *GetLogsRequest) GetDatum() *Datum

type JobInfo

+ Reason string

+ func (m *JobInfo) GetReason() string

type ListDatumRequest

+ Page int64

+ PageSize int64

+ func (m *ListDatumRequest) GetPage() int64

+ func (m *ListDatumRequest) GetPageSize() int64

+ type ListDatumResponse struct

+ DatumInfos []*DatumInfo

+ Page int64

+ TotalPages int64

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

+ func (*ListDatumResponse) ProtoMessage()

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

+ func (m *ListDatumResponse) GetPage() int64

+ func (m *ListDatumResponse) GetTotalPages() int64

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

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

+ func (m *ListDatumResponse) Reset()

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

+ func (m *ListDatumResponse) String() string

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

type ListJobRequest

+ OutputCommit *pfs.Commit

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

type PipelineInfo

+ MaxQueueSize int64

+ Reason string

+ Service *Service

+ func (m *PipelineInfo) GetMaxQueueSize() int64

+ func (m *PipelineInfo) GetReason() string

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

type Secret

+ EnvVar string

+ Key string

+ func (m *Secret) GetEnvVar() string

+ func (m *Secret) GetKey() string

Aug 17, 2017

Changes in this version

+ type CronInput struct

+ Commit string

+ Name string

+ Repo string

+ Spec string

+ Start *google_protobuf1.Timestamp

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

+ func (*CronInput) ProtoMessage()

+ func (m *CronInput) GetCommit() string

+ func (m *CronInput) GetName() string

+ func (m *CronInput) GetRepo() string

+ func (m *CronInput) GetSpec() string

+ func (m *CronInput) GetStart() *google_protobuf1.Timestamp

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

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

+ func (m *CronInput) Reset()

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

+ func (m *CronInput) String() string

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

type DatumInfo

+ Data []*InputFile

+ func (m *DatumInfo) GetData() []*InputFile

type DatumState

+ const DatumState_STARTING

type Input

+ Cron *CronInput

+ func (m *Input) GetCron() *CronInput

Aug 5, 2017

Changes in this version

+ var DatumState_name = map[int32]string

+ var DatumState_value = map[string]int32

type APIClient

+ InspectDatum func(ctx context.Context, in *InspectDatumRequest, opts ...grpc.CallOption) (*DatumInfo, error)

+ ListDatum func(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (*DatumInfos, error)

type APIServer

+ InspectDatum func(context.Context, *InspectDatumRequest) (*DatumInfo, error)

+ ListDatum func(context.Context, *ListDatumRequest) (*DatumInfos, error)

type Datum

+ ID string

+ Job *Job

+ func (m *Datum) GetID() string

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

+ type DatumInfo struct

+ Datum *Datum

+ PfsState *pfs.File

+ State DatumState

+ Stats *ProcessStats

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

+ func (*DatumInfo) ProtoMessage()

+ func (m *DatumInfo) GetDatum() *Datum

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

+ func (m *DatumInfo) GetState() DatumState

+ func (m *DatumInfo) GetStats() *ProcessStats

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

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

+ func (m *DatumInfo) Reset()

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

+ func (m *DatumInfo) String() string

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

+ type DatumInfos struct

+ DatumInfo []*DatumInfo

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

+ func (*DatumInfos) ProtoMessage()

+ func (m *DatumInfos) GetDatumInfo() []*DatumInfo

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

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

+ func (m *DatumInfos) Reset()

+ func (m *DatumInfos) Size() (n int)

+ func (m *DatumInfos) String() string

+ func (m *DatumInfos) Unmarshal(dAtA []byte) error

+ type DatumState int32

+ const DatumState_FAILED

+ const DatumState_SKIPPED

+ const DatumState_SUCCESS

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

+ func (x DatumState) String() string

type GetLogsRequest

+ InputFileID string

+ func (m *GetLogsRequest) GetInputFileID() string

+ type InputFile struct

+ Hash []byte

+ Path string

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

+ func (*InputFile) ProtoMessage()

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

+ func (m *InputFile) GetPath() string

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

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

+ func (m *InputFile) Reset()

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

+ func (m *InputFile) String() string

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

+ type InspectDatumRequest struct

+ Datum *Datum

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

+ func (*InspectDatumRequest) ProtoMessage()

+ func (m *InspectDatumRequest) GetDatum() *Datum

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

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

+ func (m *InspectDatumRequest) Reset()

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

+ func (m *InspectDatumRequest) String() string

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

+ type ListDatumRequest struct

+ Job *Job

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

+ func (*ListDatumRequest) ProtoMessage()

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

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

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

+ func (m *ListDatumRequest) Reset()

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

+ func (m *ListDatumRequest) String() string

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

type LogMessage

+ InputFileID string

+ func (m *LogMessage) GetInputFileID() string

Aug 2, 2017

Changes in this version

+ type Aggregate struct

+ Count int64

+ FifthPercentile float64

+ Mean float64

+ NinetyFifthPercentile float64

+ Stddev float64

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

+ func (*Aggregate) ProtoMessage()

+ func (m *Aggregate) GetCount() int64

+ func (m *Aggregate) GetFifthPercentile() float64

+ func (m *Aggregate) GetMean() float64

+ func (m *Aggregate) GetNinetyFifthPercentile() float64

+ func (m *Aggregate) GetStddev() float64

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

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

+ func (m *Aggregate) Reset()

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

+ func (m *Aggregate) String() string

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

+ type AggregateProcessStats struct

+ DownloadBytes *Aggregate

+ DownloadTime *Aggregate

+ ProcessTime *Aggregate

+ UploadBytes *Aggregate

+ UploadTime *Aggregate

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

+ func (*AggregateProcessStats) ProtoMessage()

+ func (m *AggregateProcessStats) GetDownloadBytes() *Aggregate

+ func (m *AggregateProcessStats) GetDownloadTime() *Aggregate

+ func (m *AggregateProcessStats) GetProcessTime() *Aggregate

+ func (m *AggregateProcessStats) GetUploadBytes() *Aggregate

+ func (m *AggregateProcessStats) GetUploadTime() *Aggregate

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

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

+ func (m *AggregateProcessStats) Reset()

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

+ func (m *AggregateProcessStats) String() string

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

type CreateJobRequest

+ Batch bool

+ EnableStats bool

+ Salt string

+ func (m *CreateJobRequest) GetBatch() bool

+ func (m *CreateJobRequest) GetEnableStats() bool

+ func (m *CreateJobRequest) GetSalt() string

type CreatePipelineRequest

+ Batch bool

+ CacheSize string

+ EnableStats bool

+ Reprocess bool

+ func (m *CreatePipelineRequest) GetBatch() bool

+ func (m *CreatePipelineRequest) GetCacheSize() string

+ func (m *CreatePipelineRequest) GetEnableStats() bool

+ func (m *CreatePipelineRequest) GetReprocess() bool

type GetLogsRequest

+ DatumID string

+ Master bool

+ func (m *GetLogsRequest) GetDatumID() string

+ func (m *GetLogsRequest) GetMaster() bool

type JobInfo

+ Batch bool

+ DataSkipped int64

+ EnableStats bool

+ Salt string

+ Stats *ProcessStats

+ StatsCommit *pfs.Commit

+ func (m *JobInfo) GetBatch() bool

+ func (m *JobInfo) GetDataSkipped() int64

+ func (m *JobInfo) GetEnableStats() bool

+ func (m *JobInfo) GetSalt() string

+ func (m *JobInfo) GetStats() *ProcessStats

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

type LogMessage

+ DatumID string

+ Master bool

+ func (m *LogMessage) GetDatumID() string

+ func (m *LogMessage) GetMaster() bool

type PipelineInfo

+ Batch bool

+ CacheSize string

+ Capability string

+ EnableStats bool

+ Salt string

+ func (m *PipelineInfo) GetBatch() bool

+ func (m *PipelineInfo) GetCacheSize() string

+ func (m *PipelineInfo) GetCapability() string

+ func (m *PipelineInfo) GetEnableStats() bool

+ func (m *PipelineInfo) GetSalt() string

+ type ProcessStats struct

+ DownloadBytes uint64

+ DownloadTime *google_protobuf2.Duration

+ ProcessTime *google_protobuf2.Duration

+ UploadBytes uint64

+ UploadTime *google_protobuf2.Duration

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

+ func (*ProcessStats) ProtoMessage()

+ func (m *ProcessStats) GetDownloadBytes() uint64

+ func (m *ProcessStats) GetDownloadTime() *google_protobuf2.Duration

+ func (m *ProcessStats) GetProcessTime() *google_protobuf2.Duration

+ func (m *ProcessStats) GetUploadBytes() uint64

+ func (m *ProcessStats) GetUploadTime() *google_protobuf2.Duration

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

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

+ func (m *ProcessStats) Reset()

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

+ func (m *ProcessStats) String() string

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

type WorkerStatus

+ QueueSize int64

+ Stats *ProcessStats

+ func (m *WorkerStatus) GetQueueSize() int64

+ func (m *WorkerStatus) GetStats() *ProcessStats

Jul 7, 2017

Changes in this version

+ var ErrIntOverflowPps = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPps = fmt.Errorf("proto: negative length found during unmarshaling")

+ func InputCommits(input *Input) []*pfs.Commit

+ func InputName(input *Input) string

+ func SortInput(input *Input)

+ func VisitInput(input *Input, f func(*Input))

type AtomInput

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

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

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

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

type CreateJobRequest

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

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

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

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

type CreatePipelineRequest

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

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

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

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

type Datum

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

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

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

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

type DeleteJobRequest

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

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

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

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

type DeletePipelineRequest

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

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

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

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

type Egress

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

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

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

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

type GarbageCollectRequest

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

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

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

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

type GarbageCollectResponse

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

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

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

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

type GetLogsRequest

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

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

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

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

type Input

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

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

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

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

type InspectJobRequest

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

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

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

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

type InspectPipelineRequest

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

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

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

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

type Job

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

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

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

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

type JobInfo

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

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

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

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

type JobInfos

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

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

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

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

type JobInput

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

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

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

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

type JobState

+ const JobState_JOB_KILLED

type ListJobRequest

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

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

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

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

type ListPipelineRequest

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

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

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

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

type LogMessage

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

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

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

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

type ParallelismSpec

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

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

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

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

type Pipeline

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

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

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

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

type PipelineInfo

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

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

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

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

type PipelineInfos

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

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

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

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

type PipelineInput

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

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

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

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

type PipelineState

+ const PipelineState_PIPELINE_PAUSED

type RerunPipelineRequest

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

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

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

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

type ResourceSpec

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

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

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

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

type RestartDatumRequest

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

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

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

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

type Secret

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

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

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

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

type Service

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

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

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

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

type StartPipelineRequest

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

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

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

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

type StopJobRequest

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

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

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

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

type StopPipelineRequest

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

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

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

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

type Transform

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

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

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

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

type Worker

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

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

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

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

type WorkerStatus

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

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

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

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

Jun 14, 2017

Changes in this version

type CreateJobRequest

+ Incremental bool

+ NewBranch *pfs.Branch

+ func (m *CreateJobRequest) GetIncremental() bool

+ func (m *CreateJobRequest) GetNewBranch() *pfs.Branch

type CreatePipelineRequest

+ Incremental bool

+ func (m *CreatePipelineRequest) GetIncremental() bool

type DeletePipelineRequest

+ All bool

+ DeleteRepo bool

+ func (m *DeletePipelineRequest) GetAll() bool

+ func (m *DeletePipelineRequest) GetDeleteRepo() bool

type JobInfo

+ Incremental bool

+ NewBranch *pfs.Branch

+ func (m *JobInfo) GetIncremental() bool

+ func (m *JobInfo) GetNewBranch() *pfs.Branch

type PipelineInfo

+ Incremental bool

+ func (m *PipelineInfo) GetIncremental() bool

Jun 1, 2017

Changes in this version

type APIClient

+ GarbageCollect func(ctx context.Context, in *GarbageCollectRequest, opts ...grpc.CallOption) (*GarbageCollectResponse, error)

type APIServer

+ GarbageCollect func(context.Context, *GarbageCollectRequest) (*GarbageCollectResponse, error)

type CreatePipelineRequest

+ Description string

+ func (m *CreatePipelineRequest) GetDescription() string

+ type GarbageCollectRequest struct

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

+ func (*GarbageCollectRequest) ProtoMessage()

+ func (m *GarbageCollectRequest) Reset()

+ func (m *GarbageCollectRequest) String() string

+ type GarbageCollectResponse struct

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

+ func (*GarbageCollectResponse) ProtoMessage()

+ func (m *GarbageCollectResponse) Reset()

+ func (m *GarbageCollectResponse) String() string

type PipelineInfo

+ Description string

+ func (m *PipelineInfo) GetDescription() string

May 5, 2017

Changes in this version

+ type AtomInput struct

+ Branch string

+ Commit string

+ FromCommit string

+ Glob string

+ Lazy bool

+ Name string

+ Repo string

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

+ func (*AtomInput) ProtoMessage()

+ func (m *AtomInput) GetBranch() string

+ func (m *AtomInput) GetCommit() string

+ func (m *AtomInput) GetFromCommit() string

+ func (m *AtomInput) GetGlob() string

+ func (m *AtomInput) GetLazy() bool

+ func (m *AtomInput) GetName() string

+ func (m *AtomInput) GetRepo() string

+ func (m *AtomInput) Reset()

+ func (m *AtomInput) String() string

type CreateJobRequest

+ Input *Input

+ func (m *CreateJobRequest) GetInput() *Input

type CreatePipelineRequest

+ Input *Input

+ func (m *CreatePipelineRequest) GetInput() *Input

+ type Input struct

+ Atom *AtomInput

+ Cross []*Input

+ Union []*Input

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

+ func (*Input) ProtoMessage()

+ func (m *Input) GetAtom() *AtomInput

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

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

+ func (m *Input) Reset()

+ func (m *Input) String() string

type JobInfo

+ Input *Input

+ func (m *JobInfo) GetInput() *Input

type PipelineInfo

+ Input *Input

+ func (m *PipelineInfo) GetInput() *Input

type ResourceSpec

+ Gpu int64

+ func (m *ResourceSpec) GetGpu() int64

Apr 22, 2017

Changes in this version

type CreateJobRequest

+ ResourceSpec *ResourceSpec

+ func (m *CreateJobRequest) GetResourceSpec() *ResourceSpec

type CreatePipelineRequest

+ ResourceSpec *ResourceSpec

+ func (m *CreatePipelineRequest) GetResourceSpec() *ResourceSpec

type JobInfo

+ ResourceSpec *ResourceSpec

+ func (m *JobInfo) GetResourceSpec() *ResourceSpec

type PipelineInfo

+ ResourceSpec *ResourceSpec

+ func (m *PipelineInfo) GetResourceSpec() *ResourceSpec

+ type ResourceSpec struct

+ Cpu float32

+ Memory string

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

+ func (*ResourceSpec) ProtoMessage()

+ func (m *ResourceSpec) GetCpu() float32

+ func (m *ResourceSpec) GetMemory() string

+ func (m *ResourceSpec) Reset()

+ func (m *ResourceSpec) String() string

Apr 15, 2017

Changes in this version

type APIClient

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

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

type APIServer

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

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

type CreatePipelineRequest

+ ScaleDownThreshold *google_protobuf2.Duration

+ func (m *CreatePipelineRequest) GetScaleDownThreshold() *google_protobuf2.Duration

type JobInfo

+ WorkerStatus []*WorkerStatus

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

type PipelineInfo

+ ScaleDownThreshold *google_protobuf2.Duration

+ func (m *PipelineInfo) GetScaleDownThreshold() *google_protobuf2.Duration

+ type RestartDatumRequest struct

+ DataFilters []string

+ Job *Job

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

+ func (*RestartDatumRequest) ProtoMessage()

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

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

+ func (m *RestartDatumRequest) Reset()

+ func (m *RestartDatumRequest) String() string

+ type StopJobRequest struct

+ Job *Job

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

+ func (*StopJobRequest) ProtoMessage()

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

+ func (m *StopJobRequest) Reset()

+ func (m *StopJobRequest) String() string

+ type WorkerStatus struct

+ Data []*Datum

+ JobID string

+ Started *google_protobuf1.Timestamp

+ WorkerID string

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

+ func (*WorkerStatus) ProtoMessage()

+ func (m *WorkerStatus) GetData() []*Datum

+ func (m *WorkerStatus) GetJobID() string

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

+ func (m *WorkerStatus) GetWorkerID() string

+ func (m *WorkerStatus) Reset()

+ func (m *WorkerStatus) String() string

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