pps

package

Go to main page

Versions in this module

v1

v1.9.4

Sep 6, 2019

v1.9.4-6277238fa1e72d2adcbab36c2a829b0eb6309533

Sep 10, 2019

v1.9.3

Aug 7, 2019

v1.9.3-6221e9ed57a10b39d363e0e97cdd6e4e41796af2

Aug 13, 2019

v1.9.2

Jul 25, 2019

v1.9.1

Jul 18, 2019

v1.9.0

Jun 12, 2019

v1.9.0-1ff617394086e2ac29d786b2c19a63288572383a

Jun 6, 2019

v1.8.8

Sep 11, 2019

Changes in this version

type ActivateAuthRequest

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

type ActivateAuthResponse

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

type Aggregate

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

type AggregateProcessStats

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

type AtomInput

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

type ChunkSpec

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

type CreateJobRequest

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

type CreatePipelineRequest

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

type CronInput

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

type Datum

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

type DatumInfo

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

type DeleteJobRequest

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

type DeletePipelineRequest

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

type Egress

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

type EtcdJobInfo

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

type EtcdPipelineInfo

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

type FlushJobRequest

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

type GarbageCollectRequest

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

type GarbageCollectResponse

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

type GetLogsRequest

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

type GitInput

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

type HashtreeSpec

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

type Input

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

type InputFile

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

type InspectDatumRequest

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

type InspectJobRequest

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

type InspectPipelineRequest

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

type Job

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

type JobInfo

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

type JobInfos

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

type JobInput

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

type ListDatumRequest

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

type ListDatumResponse

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

type ListDatumStreamResponse

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

type ListJobRequest

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

type ListPipelineRequest

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

type LogMessage

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

type ParallelismSpec

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

type Pipeline

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

type PipelineInfo

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

type PipelineInfos

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

type PipelineInput

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

type ProcessStats

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

type RerunPipelineRequest

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

type ResourceSpec

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

type RestartDatumRequest

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

type SchedulingSpec

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

type Secret

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

type Service

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

type StartPipelineRequest

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

type StopJobRequest

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

type StopPipelineRequest

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

type Transform

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

type Worker

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

type WorkerStatus

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

v1.8.7

May 28, 2019

Changes in this version

+ type UnimplementedAPIServer struct

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

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

+ func (*UnimplementedAPIServer) CreatePipeline(ctx context.Context, req *CreatePipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *types.Empty) (*types.Empty, error)

+ func (*UnimplementedAPIServer) DeleteJob(ctx context.Context, req *DeleteJobRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) DeletePipeline(ctx context.Context, req *DeletePipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) FlushJob(req *FlushJobRequest, srv API_FlushJobServer) error

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

+ func (*UnimplementedAPIServer) GetLogs(req *GetLogsRequest, srv API_GetLogsServer) error

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

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

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

+ func (*UnimplementedAPIServer) ListDatum(ctx context.Context, req *ListDatumRequest) (*ListDatumResponse, error)

+ func (*UnimplementedAPIServer) ListDatumStream(req *ListDatumRequest, srv API_ListDatumStreamServer) error

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

+ func (*UnimplementedAPIServer) ListJobStream(req *ListJobRequest, srv API_ListJobStreamServer) error

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

+ func (*UnimplementedAPIServer) RerunPipeline(ctx context.Context, req *RerunPipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) RestartDatum(ctx context.Context, req *RestartDatumRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) StartPipeline(ctx context.Context, req *StartPipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) StopJob(ctx context.Context, req *StopJobRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) StopPipeline(ctx context.Context, req *StopPipelineRequest) (*types.Empty, error)

v1.8.6

Mar 8, 2019

v1.8.5

Feb 18, 2019

v1.8.5-e20ac1978f01a451a1ce59ea524113eb9cd6734d

Feb 19, 2019

v1.8.5-3b15373481111ab338f03c171679c591965b3f3b

Feb 19, 2019

v1.8.4

Feb 12, 2019

v1.8.3

Feb 7, 2019

Changes in this version

+ var DatumState_name = map[int32]string

+ var DatumState_value = map[string]int32

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

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

+ var JobState_name = map[int32]string

+ var JobState_value = map[string]int32

+ var PipelineState_name = map[int32]string

+ var PipelineState_value = map[string]int32

+ var WorkerState_name = map[int32]string

+ var WorkerState_value = map[string]int32

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

+ type APIClient interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

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

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

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

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

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

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

+ FlushJob func(*FlushJobRequest, API_FlushJobServer) error

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

+ GetLogs func(*GetLogsRequest, API_GetLogsServer) error

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

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

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

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

+ ListDatumStream func(*ListDatumRequest, API_ListDatumStreamServer) error

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

+ ListJobStream func(*ListJobRequest, API_ListJobStreamServer) error

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

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

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

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

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

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

+ type API_FlushJobClient interface

+ Recv func() (*JobInfo, error)

+ type API_FlushJobServer interface

+ Send func(*JobInfo) error

+ type API_GetLogsClient interface

+ Recv func() (*LogMessage, error)

+ type API_GetLogsServer interface

+ Send func(*LogMessage) error

+ type API_ListDatumStreamClient interface

+ Recv func() (*ListDatumStreamResponse, error)

+ type API_ListDatumStreamServer interface

+ Send func(*ListDatumStreamResponse) error

+ type API_ListJobStreamClient interface

+ Recv func() (*JobInfo, error)

+ type API_ListJobStreamServer interface

+ Send func(*JobInfo) error

+ type ActivateAuthRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActivateAuthRequest) ProtoMessage()

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

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

+ func (m *ActivateAuthRequest) Reset()

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

+ func (m *ActivateAuthRequest) String() string

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

+ func (m *ActivateAuthRequest) XXX_DiscardUnknown()

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

+ func (m *ActivateAuthRequest) XXX_Merge(src proto.Message)

+ func (m *ActivateAuthRequest) XXX_Size() int

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

+ type ActivateAuthResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActivateAuthResponse) ProtoMessage()

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

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

+ func (m *ActivateAuthResponse) Reset()

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

+ func (m *ActivateAuthResponse) String() string

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

+ func (m *ActivateAuthResponse) XXX_DiscardUnknown()

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

+ func (m *ActivateAuthResponse) XXX_Merge(src proto.Message)

+ func (m *ActivateAuthResponse) XXX_Size() int

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

+ type Aggregate struct

+ Count int64

+ FifthPercentile float64

+ Mean float64

+ NinetyFifthPercentile float64

+ Stddev float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Aggregate) ProtoMessage()

+ func (m *Aggregate) GetCount() int64

+ func (m *Aggregate) GetFifthPercentile() float64

+ func (m *Aggregate) GetMean() float64

+ func (m *Aggregate) GetNinetyFifthPercentile() float64

+ func (m *Aggregate) GetStddev() float64

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

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

+ func (m *Aggregate) Reset()

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

+ func (m *Aggregate) String() string

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

+ func (m *Aggregate) XXX_DiscardUnknown()

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

+ func (m *Aggregate) XXX_Merge(src proto.Message)

+ func (m *Aggregate) XXX_Size() int

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

+ type AggregateProcessStats struct

+ DownloadBytes *Aggregate

+ DownloadTime *Aggregate

+ ProcessTime *Aggregate

+ UploadBytes *Aggregate

+ UploadTime *Aggregate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AggregateProcessStats) ProtoMessage()

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

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

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

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

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

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

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

+ func (m *AggregateProcessStats) Reset()

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

+ func (m *AggregateProcessStats) String() string

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

+ func (m *AggregateProcessStats) XXX_DiscardUnknown()

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

+ func (m *AggregateProcessStats) XXX_Merge(src proto.Message)

+ func (m *AggregateProcessStats) XXX_Size() int

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

+ type AtomInput struct

+ Branch string

+ Commit string

+ EmptyFiles bool

+ Glob string

+ Lazy bool

+ Name string

+ Repo string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AtomInput) ProtoMessage()

+ func (m *AtomInput) GetBranch() string

+ func (m *AtomInput) GetCommit() string

+ func (m *AtomInput) GetEmptyFiles() bool

+ func (m *AtomInput) GetGlob() string

+ func (m *AtomInput) GetLazy() bool

+ func (m *AtomInput) GetName() string

+ func (m *AtomInput) GetRepo() string

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

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

+ func (m *AtomInput) Reset()

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

+ func (m *AtomInput) String() string

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

+ func (m *AtomInput) XXX_DiscardUnknown()

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

+ func (m *AtomInput) XXX_Merge(src proto.Message)

+ func (m *AtomInput) XXX_Size() int

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

+ type ChunkSpec struct

+ Number int64

+ SizeBytes int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ChunkSpec) ProtoMessage()

+ func (m *ChunkSpec) GetNumber() int64

+ func (m *ChunkSpec) GetSizeBytes() int64

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

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

+ func (m *ChunkSpec) Reset()

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

+ func (m *ChunkSpec) String() string

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

+ func (m *ChunkSpec) XXX_DiscardUnknown()

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

+ func (m *ChunkSpec) XXX_Merge(src proto.Message)

+ func (m *ChunkSpec) XXX_Size() int

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

+ type CreateJobRequest struct

+ OutputCommit *pfs.Commit

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateJobRequest) ProtoMessage()

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

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

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

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

+ func (m *CreateJobRequest) Reset()

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

+ func (m *CreateJobRequest) String() string

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

+ func (m *CreateJobRequest) XXX_DiscardUnknown()

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

+ func (m *CreateJobRequest) XXX_Merge(src proto.Message)

+ func (m *CreateJobRequest) XXX_Size() int

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

+ type CreatePipelineRequest struct

+ Batch bool

+ CacheSize string

+ ChunkSpec *ChunkSpec

+ DatumTimeout *types.Duration

+ DatumTries int64

+ Description string

+ Egress *Egress

+ EnableStats bool

+ HashtreeSpec *HashtreeSpec

+ Incremental bool

+ Input *Input

+ JobTimeout *types.Duration

+ MaxQueueSize int64

+ OutputBranch string

+ ParallelismSpec *ParallelismSpec

+ Pipeline *Pipeline

+ PodSpec string

+ Reprocess bool

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ Salt string

+ ScaleDownThreshold *types.Duration

+ SchedulingSpec *SchedulingSpec

+ Service *Service

+ Standby bool

+ Transform *Transform

+ Update bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreatePipelineRequest) ProtoMessage()

+ func (m *CreatePipelineRequest) GetBatch() bool

+ func (m *CreatePipelineRequest) GetCacheSize() string

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

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

+ func (m *CreatePipelineRequest) GetDatumTries() int64

+ func (m *CreatePipelineRequest) GetDescription() string

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

+ func (m *CreatePipelineRequest) GetEnableStats() bool

+ func (m *CreatePipelineRequest) GetHashtreeSpec() *HashtreeSpec

+ func (m *CreatePipelineRequest) GetIncremental() bool

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

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

+ func (m *CreatePipelineRequest) GetMaxQueueSize() int64

+ func (m *CreatePipelineRequest) GetOutputBranch() string

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

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

+ func (m *CreatePipelineRequest) GetPodSpec() string

+ func (m *CreatePipelineRequest) GetReprocess() bool

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

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

+ func (m *CreatePipelineRequest) GetSalt() string

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

+ func (m *CreatePipelineRequest) GetSchedulingSpec() *SchedulingSpec

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

+ func (m *CreatePipelineRequest) GetStandby() bool

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

+ func (m *CreatePipelineRequest) GetUpdate() bool

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

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

+ func (m *CreatePipelineRequest) Reset()

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

+ func (m *CreatePipelineRequest) String() string

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

+ func (m *CreatePipelineRequest) XXX_DiscardUnknown()

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

+ func (m *CreatePipelineRequest) XXX_Merge(src proto.Message)

+ func (m *CreatePipelineRequest) XXX_Size() int

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

+ type CronInput struct

+ Commit string

+ Name string

+ Repo string

+ Spec string

+ Start *types.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CronInput) ProtoMessage()

+ func (m *CronInput) GetCommit() string

+ func (m *CronInput) GetName() string

+ func (m *CronInput) GetRepo() string

+ func (m *CronInput) GetSpec() string

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

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

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

+ func (m *CronInput) Reset()

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

+ func (m *CronInput) String() string

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

+ func (m *CronInput) XXX_DiscardUnknown()

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

+ func (m *CronInput) XXX_Merge(src proto.Message)

+ func (m *CronInput) XXX_Size() int

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

+ type Datum struct

+ ID string

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Datum) ProtoMessage()

+ func (m *Datum) GetID() string

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

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

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

+ func (m *Datum) Reset()

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

+ func (m *Datum) String() string

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

+ func (m *Datum) XXX_DiscardUnknown()

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

+ func (m *Datum) XXX_Merge(src proto.Message)

+ func (m *Datum) XXX_Size() int

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

+ type DatumInfo struct

+ Data []*pfs.FileInfo

+ Datum *Datum

+ PfsState *pfs.File

+ State DatumState

+ Stats *ProcessStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DatumInfo) ProtoMessage()

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

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

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

+ func (m *DatumInfo) GetState() DatumState

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

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

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

+ func (m *DatumInfo) Reset()

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

+ func (m *DatumInfo) String() string

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

+ func (m *DatumInfo) XXX_DiscardUnknown()

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

+ func (m *DatumInfo) XXX_Merge(src proto.Message)

+ func (m *DatumInfo) XXX_Size() int

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

+ type DatumState int32

+ const DatumState_FAILED

+ const DatumState_SKIPPED

+ const DatumState_STARTING

+ const DatumState_SUCCESS

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

+ func (x DatumState) String() string

+ type DeleteJobRequest struct

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteJobRequest) ProtoMessage()

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

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

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

+ func (m *DeleteJobRequest) Reset()

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

+ func (m *DeleteJobRequest) String() string

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

+ func (m *DeleteJobRequest) XXX_DiscardUnknown()

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

+ func (m *DeleteJobRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteJobRequest) XXX_Size() int

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

+ type DeletePipelineRequest struct

+ All bool

+ Force bool

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeletePipelineRequest) ProtoMessage()

+ func (m *DeletePipelineRequest) GetAll() bool

+ func (m *DeletePipelineRequest) GetForce() bool

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

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

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

+ func (m *DeletePipelineRequest) Reset()

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

+ func (m *DeletePipelineRequest) String() string

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

+ func (m *DeletePipelineRequest) XXX_DiscardUnknown()

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

+ func (m *DeletePipelineRequest) XXX_Merge(src proto.Message)

+ func (m *DeletePipelineRequest) XXX_Size() int

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

+ type Egress struct

+ URL string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Egress) ProtoMessage()

+ func (m *Egress) GetURL() string

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

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

+ func (m *Egress) Reset()

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

+ func (m *Egress) String() string

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

+ func (m *Egress) XXX_DiscardUnknown()

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

+ func (m *Egress) XXX_Merge(src proto.Message)

+ func (m *Egress) XXX_Size() int

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

+ type EtcdJobInfo struct

+ DataFailed int64

+ DataProcessed int64

+ DataSkipped int64

+ DataTotal int64

+ Finished *types.Timestamp

+ Job *Job

+ OutputCommit *pfs.Commit

+ Pipeline *Pipeline

+ Reason string

+ Restart uint64

+ Started *types.Timestamp

+ State JobState

+ Stats *ProcessStats

+ StatsCommit *pfs.Commit

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EtcdJobInfo) ProtoMessage()

+ func (m *EtcdJobInfo) GetDataFailed() int64

+ func (m *EtcdJobInfo) GetDataProcessed() int64

+ func (m *EtcdJobInfo) GetDataSkipped() int64

+ func (m *EtcdJobInfo) GetDataTotal() int64

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

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

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

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

+ func (m *EtcdJobInfo) GetReason() string

+ func (m *EtcdJobInfo) GetRestart() uint64

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

+ func (m *EtcdJobInfo) GetState() JobState

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

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

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

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

+ func (m *EtcdJobInfo) Reset()

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

+ func (m *EtcdJobInfo) String() string

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

+ func (m *EtcdJobInfo) XXX_DiscardUnknown()

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

+ func (m *EtcdJobInfo) XXX_Merge(src proto.Message)

+ func (m *EtcdJobInfo) XXX_Size() int

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

+ type EtcdPipelineInfo struct

+ AuthToken string

+ JobCounts map[int32]int32

+ Reason string

+ SpecCommit *pfs.Commit

+ State PipelineState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EtcdPipelineInfo) ProtoMessage()

+ func (m *EtcdPipelineInfo) GetAuthToken() string

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

+ func (m *EtcdPipelineInfo) 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

+ func (m *EtcdPipelineInfo) XXX_DiscardUnknown()

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

+ func (m *EtcdPipelineInfo) XXX_Merge(src proto.Message)

+ func (m *EtcdPipelineInfo) XXX_Size() int

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

+ type FlushJobRequest struct

+ Commits []*pfs.Commit

+ ToPipelines []*Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*FlushJobRequest) ProtoMessage()

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

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

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

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

+ func (m *FlushJobRequest) Reset()

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

+ func (m *FlushJobRequest) String() string

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

+ func (m *FlushJobRequest) XXX_DiscardUnknown()

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

+ func (m *FlushJobRequest) XXX_Merge(src proto.Message)

+ func (m *FlushJobRequest) XXX_Size() int

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

+ type GarbageCollectRequest struct

+ MemoryBytes int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GarbageCollectRequest) ProtoMessage()

+ func (m *GarbageCollectRequest) GetMemoryBytes() int64

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

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

+ func (m *GarbageCollectRequest) Reset()

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

+ func (m *GarbageCollectRequest) String() string

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

+ func (m *GarbageCollectRequest) XXX_DiscardUnknown()

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

+ func (m *GarbageCollectRequest) XXX_Merge(src proto.Message)

+ func (m *GarbageCollectRequest) XXX_Size() int

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

+ type GarbageCollectResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GarbageCollectResponse) ProtoMessage()

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

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

+ func (m *GarbageCollectResponse) Reset()

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

+ func (m *GarbageCollectResponse) String() string

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

+ func (m *GarbageCollectResponse) XXX_DiscardUnknown()

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

+ func (m *GarbageCollectResponse) XXX_Merge(src proto.Message)

+ func (m *GarbageCollectResponse) XXX_Size() int

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

+ type GetLogsRequest struct

+ DataFilters []string

+ Datum *Datum

+ Follow bool

+ Job *Job

+ Master bool

+ Pipeline *Pipeline

+ Tail int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetLogsRequest) ProtoMessage()

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

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

+ func (m *GetLogsRequest) GetFollow() bool

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

+ func (m *GetLogsRequest) GetMaster() bool

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

+ func (m *GetLogsRequest) GetTail() int64

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

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

+ func (m *GetLogsRequest) Reset()

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

+ func (m *GetLogsRequest) String() string

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

+ func (m *GetLogsRequest) XXX_DiscardUnknown()

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

+ func (m *GetLogsRequest) XXX_Merge(src proto.Message)

+ func (m *GetLogsRequest) XXX_Size() int

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

+ type GitInput struct

+ Branch string

+ Commit string

+ Name string

+ URL string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GitInput) ProtoMessage()

+ func (m *GitInput) GetBranch() string

+ func (m *GitInput) GetCommit() string

+ func (m *GitInput) GetName() string

+ func (m *GitInput) GetURL() string

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

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

+ func (m *GitInput) Reset()

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

+ func (m *GitInput) String() string

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

+ func (m *GitInput) XXX_DiscardUnknown()

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

+ func (m *GitInput) XXX_Merge(src proto.Message)

+ func (m *GitInput) XXX_Size() int

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

+ type HashtreeSpec struct

+ Constant uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HashtreeSpec) ProtoMessage()

+ func (m *HashtreeSpec) GetConstant() uint64

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

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

+ func (m *HashtreeSpec) Reset()

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

+ func (m *HashtreeSpec) String() string

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

+ func (m *HashtreeSpec) XXX_DiscardUnknown()

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

+ func (m *HashtreeSpec) XXX_Merge(src proto.Message)

+ func (m *HashtreeSpec) XXX_Size() int

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

+ type Input struct

+ Atom *AtomInput

+ Cron *CronInput

+ Cross []*Input

+ Git *GitInput

+ Union []*Input

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Input) ProtoMessage()

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

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

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

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

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

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

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

+ func (m *Input) Reset()

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

+ func (m *Input) String() string

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

+ func (m *Input) XXX_DiscardUnknown()

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

+ func (m *Input) XXX_Merge(src proto.Message)

+ func (m *Input) XXX_Size() int

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

+ type InputFile struct

+ Hash []byte

+ Path string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InputFile) ProtoMessage()

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

+ func (m *InputFile) GetPath() string

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

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

+ func (m *InputFile) Reset()

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

+ func (m *InputFile) String() string

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

+ func (m *InputFile) XXX_DiscardUnknown()

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

+ func (m *InputFile) XXX_Merge(src proto.Message)

+ func (m *InputFile) XXX_Size() int

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

+ type InspectDatumRequest struct

+ Datum *Datum

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectDatumRequest) ProtoMessage()

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

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

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

+ func (m *InspectDatumRequest) Reset()

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

+ func (m *InspectDatumRequest) String() string

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

+ func (m *InspectDatumRequest) XXX_DiscardUnknown()

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

+ func (m *InspectDatumRequest) XXX_Merge(src proto.Message)

+ func (m *InspectDatumRequest) XXX_Size() int

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

+ type InspectJobRequest struct

+ BlockState bool

+ Job *Job

+ OutputCommit *pfs.Commit

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectJobRequest) ProtoMessage()

+ func (m *InspectJobRequest) GetBlockState() bool

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

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

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

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

+ func (m *InspectJobRequest) Reset()

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

+ func (m *InspectJobRequest) String() string

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

+ func (m *InspectJobRequest) XXX_DiscardUnknown()

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

+ func (m *InspectJobRequest) XXX_Merge(src proto.Message)

+ func (m *InspectJobRequest) XXX_Size() int

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

+ type InspectPipelineRequest struct

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectPipelineRequest) ProtoMessage()

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

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

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

+ func (m *InspectPipelineRequest) Reset()

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

+ func (m *InspectPipelineRequest) String() string

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

+ func (m *InspectPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *InspectPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *InspectPipelineRequest) XXX_Size() int

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

+ type Job struct

+ ID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Job) ProtoMessage()

+ func (m *Job) GetID() string

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

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

+ func (m *Job) Reset()

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

+ func (m *Job) String() string

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

+ func (m *Job) XXX_DiscardUnknown()

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

+ func (m *Job) XXX_Merge(src proto.Message)

+ func (m *Job) XXX_Size() int

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

+ type JobInfo struct

+ Batch bool

+ ChunkSpec *ChunkSpec

+ DataFailed int64

+ DataProcessed int64

+ DataSkipped int64

+ DataTotal int64

+ DatumTimeout *types.Duration

+ DatumTries int64

+ Egress *Egress

+ EnableStats bool

+ Finished *types.Timestamp

+ Incremental bool

+ Input *Input

+ Job *Job

+ JobTimeout *types.Duration

+ NewBranch *pfs.BranchInfo

+ OutputBranch string

+ OutputCommit *pfs.Commit

+ OutputRepo *pfs.Repo

+ ParallelismSpec *ParallelismSpec

+ ParentJob *Job

+ Pipeline *Pipeline

+ PipelineVersion uint64

+ PodSpec string

+ Reason string

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ Restart uint64

+ Salt string

+ SchedulingSpec *SchedulingSpec

+ Service *Service

+ Started *types.Timestamp

+ State JobState

+ Stats *ProcessStats

+ StatsCommit *pfs.Commit

+ Transform *Transform

+ WorkerStatus []*WorkerStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobInfo) ProtoMessage()

+ func (m *JobInfo) GetBatch() bool

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

+ func (m *JobInfo) GetDataFailed() int64

+ func (m *JobInfo) GetDataProcessed() int64

+ func (m *JobInfo) GetDataSkipped() int64

+ func (m *JobInfo) GetDataTotal() int64

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

+ func (m *JobInfo) GetDatumTries() int64

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

+ func (m *JobInfo) GetEnableStats() bool

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

+ func (m *JobInfo) GetIncremental() bool

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

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

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

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

+ func (m *JobInfo) GetOutputBranch() string

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

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

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

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

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

+ func (m *JobInfo) GetPipelineVersion() uint64

+ func (m *JobInfo) GetPodSpec() string

+ func (m *JobInfo) GetReason() string

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

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

+ func (m *JobInfo) GetRestart() uint64

+ func (m *JobInfo) GetSalt() string

+ func (m *JobInfo) GetSchedulingSpec() *SchedulingSpec

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

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

+ func (m *JobInfo) GetState() JobState

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

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

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

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

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

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

+ func (m *JobInfo) Reset()

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

+ func (m *JobInfo) String() string

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

+ func (m *JobInfo) XXX_DiscardUnknown()

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

+ func (m *JobInfo) XXX_Merge(src proto.Message)

+ func (m *JobInfo) XXX_Size() int

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

+ type JobInfos struct

+ JobInfo []*JobInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobInfos) ProtoMessage()

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

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

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

+ func (m *JobInfos) Reset()

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

+ func (m *JobInfos) String() string

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

+ func (m *JobInfos) XXX_DiscardUnknown()

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

+ func (m *JobInfos) XXX_Merge(src proto.Message)

+ func (m *JobInfos) XXX_Size() int

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

+ type JobInput struct

+ Commit *pfs.Commit

+ Glob string

+ Lazy bool

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobInput) ProtoMessage()

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

+ func (m *JobInput) GetGlob() string

+ func (m *JobInput) GetLazy() bool

+ func (m *JobInput) GetName() string

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

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

+ func (m *JobInput) Reset()

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

+ func (m *JobInput) String() string

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

+ func (m *JobInput) XXX_DiscardUnknown()

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

+ func (m *JobInput) XXX_Merge(src proto.Message)

+ func (m *JobInput) XXX_Size() int

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

+ type JobState int32

+ const JobState_JOB_FAILURE

+ const JobState_JOB_KILLED

+ const JobState_JOB_RUNNING

+ const JobState_JOB_STARTING

+ const JobState_JOB_SUCCESS

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

+ func (x JobState) String() string

+ type ListDatumRequest struct

+ Job *Job

+ Page int64

+ PageSize int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListDatumRequest) ProtoMessage()

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

+ func (m *ListDatumRequest) GetPage() int64

+ func (m *ListDatumRequest) GetPageSize() int64

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

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

+ func (m *ListDatumRequest) Reset()

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

+ func (m *ListDatumRequest) String() string

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

+ func (m *ListDatumRequest) XXX_DiscardUnknown()

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

+ func (m *ListDatumRequest) XXX_Merge(src proto.Message)

+ func (m *ListDatumRequest) XXX_Size() int

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

+ type ListDatumResponse struct

+ DatumInfos []*DatumInfo

+ Page int64

+ TotalPages int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListDatumResponse) ProtoMessage()

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

+ func (m *ListDatumResponse) GetPage() int64

+ func (m *ListDatumResponse) GetTotalPages() int64

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

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

+ func (m *ListDatumResponse) Reset()

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

+ func (m *ListDatumResponse) String() string

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

+ func (m *ListDatumResponse) XXX_DiscardUnknown()

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

+ func (m *ListDatumResponse) XXX_Merge(src proto.Message)

+ func (m *ListDatumResponse) XXX_Size() int

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

+ type ListDatumStreamResponse struct

+ DatumInfo *DatumInfo

+ Page int64

+ TotalPages int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListDatumStreamResponse) ProtoMessage()

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

+ func (m *ListDatumStreamResponse) GetPage() int64

+ func (m *ListDatumStreamResponse) GetTotalPages() int64

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

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

+ func (m *ListDatumStreamResponse) Reset()

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

+ func (m *ListDatumStreamResponse) String() string

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

+ func (m *ListDatumStreamResponse) XXX_DiscardUnknown()

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

+ func (m *ListDatumStreamResponse) XXX_Merge(src proto.Message)

+ func (m *ListDatumStreamResponse) XXX_Size() int

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

+ type ListJobRequest struct

+ InputCommit []*pfs.Commit

+ OutputCommit *pfs.Commit

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListJobRequest) ProtoMessage()

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

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

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

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

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

+ func (m *ListJobRequest) Reset()

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

+ func (m *ListJobRequest) String() string

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

+ func (m *ListJobRequest) XXX_DiscardUnknown()

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

+ func (m *ListJobRequest) XXX_Merge(src proto.Message)

+ func (m *ListJobRequest) XXX_Size() int

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

+ type ListPipelineRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListPipelineRequest) ProtoMessage()

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

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

+ func (m *ListPipelineRequest) Reset()

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

+ func (m *ListPipelineRequest) String() string

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

+ func (m *ListPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *ListPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *ListPipelineRequest) XXX_Size() int

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

+ type LogMessage struct

+ Data []*InputFile

+ DatumID string

+ JobID string

+ Master bool

+ Message string

+ PipelineName string

+ Ts *types.Timestamp

+ User bool

+ WorkerID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LogMessage) ProtoMessage()

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

+ func (m *LogMessage) GetDatumID() string

+ func (m *LogMessage) GetJobID() string

+ func (m *LogMessage) GetMaster() bool

+ func (m *LogMessage) GetMessage() string

+ func (m *LogMessage) GetPipelineName() string

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

+ func (m *LogMessage) GetUser() bool

+ func (m *LogMessage) GetWorkerID() string

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

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

+ func (m *LogMessage) Reset()

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

+ func (m *LogMessage) String() string

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

+ func (m *LogMessage) XXX_DiscardUnknown()

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

+ func (m *LogMessage) XXX_Merge(src proto.Message)

+ func (m *LogMessage) XXX_Size() int

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

+ type ParallelismSpec struct

+ Coefficient float64

+ Constant uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ParallelismSpec) ProtoMessage()

+ func (m *ParallelismSpec) GetCoefficient() float64

+ func (m *ParallelismSpec) GetConstant() uint64

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

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

+ func (m *ParallelismSpec) Reset()

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

+ func (m *ParallelismSpec) String() string

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

+ func (m *ParallelismSpec) XXX_DiscardUnknown()

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

+ func (m *ParallelismSpec) XXX_Merge(src proto.Message)

+ func (m *ParallelismSpec) XXX_Size() int

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

+ type Pipeline struct

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Pipeline) ProtoMessage()

+ func (m *Pipeline) GetName() string

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

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

+ func (m *Pipeline) Reset()

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

+ func (m *Pipeline) String() string

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

+ func (m *Pipeline) XXX_DiscardUnknown()

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

+ func (m *Pipeline) XXX_Merge(src proto.Message)

+ func (m *Pipeline) XXX_Size() int

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

+ type PipelineInfo struct

+ Batch bool

+ CacheSize string

+ ChunkSpec *ChunkSpec

+ CreatedAt *types.Timestamp

+ DatumTimeout *types.Duration

+ DatumTries int64

+ Description string

+ Egress *Egress

+ EnableStats bool

+ GithookURL string

+ HashtreeSpec *HashtreeSpec

+ ID string

+ Incremental bool

+ Input *Input

+ JobCounts map[int32]int32

+ JobTimeout *types.Duration

+ MaxQueueSize int64

+ OutputBranch string

+ ParallelismSpec *ParallelismSpec

+ Pipeline *Pipeline

+ PodSpec string

+ Reason string

+ RecentError string

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ Salt string

+ ScaleDownThreshold *types.Duration

+ SchedulingSpec *SchedulingSpec

+ Service *Service

+ SpecCommit *pfs.Commit

+ Standby bool

+ State PipelineState

+ Stopped bool

+ Transform *Transform

+ Version uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PipelineInfo) ProtoMessage()

+ func (m *PipelineInfo) GetBatch() bool

+ func (m *PipelineInfo) GetCacheSize() string

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

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

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

+ func (m *PipelineInfo) GetDatumTries() int64

+ func (m *PipelineInfo) GetDescription() string

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

+ func (m *PipelineInfo) GetEnableStats() bool

+ func (m *PipelineInfo) GetGithookURL() string

+ func (m *PipelineInfo) GetHashtreeSpec() *HashtreeSpec

+ func (m *PipelineInfo) GetID() string

+ func (m *PipelineInfo) GetIncremental() bool

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

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

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

+ func (m *PipelineInfo) GetMaxQueueSize() int64

+ func (m *PipelineInfo) GetOutputBranch() string

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

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

+ func (m *PipelineInfo) GetPodSpec() string

+ func (m *PipelineInfo) GetReason() string

+ func (m *PipelineInfo) GetRecentError() string

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

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

+ func (m *PipelineInfo) GetSalt() string

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

+ func (m *PipelineInfo) GetSchedulingSpec() *SchedulingSpec

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

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

+ func (m *PipelineInfo) GetStandby() bool

+ func (m *PipelineInfo) GetState() PipelineState

+ func (m *PipelineInfo) GetStopped() bool

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

+ func (m *PipelineInfo) GetVersion() uint64

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

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

+ func (m *PipelineInfo) Reset()

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

+ func (m *PipelineInfo) String() string

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

+ func (m *PipelineInfo) XXX_DiscardUnknown()

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

+ func (m *PipelineInfo) XXX_Merge(src proto.Message)

+ func (m *PipelineInfo) XXX_Size() int

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

+ type PipelineInfos struct

+ PipelineInfo []*PipelineInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PipelineInfos) ProtoMessage()

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

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

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

+ func (m *PipelineInfos) Reset()

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

+ func (m *PipelineInfos) String() string

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

+ func (m *PipelineInfos) XXX_DiscardUnknown()

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

+ func (m *PipelineInfos) XXX_Merge(src proto.Message)

+ func (m *PipelineInfos) XXX_Size() int

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

+ type PipelineInput struct

+ Branch string

+ From *pfs.Commit

+ Glob string

+ Lazy bool

+ Name string

+ Repo *pfs.Repo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PipelineInput) ProtoMessage()

+ func (m *PipelineInput) GetBranch() string

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

+ func (m *PipelineInput) GetGlob() string

+ func (m *PipelineInput) GetLazy() bool

+ func (m *PipelineInput) GetName() string

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

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

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

+ func (m *PipelineInput) Reset()

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

+ func (m *PipelineInput) String() string

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

+ func (m *PipelineInput) XXX_DiscardUnknown()

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

+ func (m *PipelineInput) XXX_Merge(src proto.Message)

+ func (m *PipelineInput) XXX_Size() int

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

+ type PipelineState int32

+ const PipelineState_PIPELINE_FAILURE

+ const PipelineState_PIPELINE_PAUSED

+ const PipelineState_PIPELINE_RESTARTING

+ const PipelineState_PIPELINE_RUNNING

+ const PipelineState_PIPELINE_STANDBY

+ const PipelineState_PIPELINE_STARTING

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

+ func (x PipelineState) String() string

+ type ProcessStats struct

+ DownloadBytes uint64

+ DownloadTime *types.Duration

+ ProcessTime *types.Duration

+ UploadBytes uint64

+ UploadTime *types.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ProcessStats) ProtoMessage()

+ func (m *ProcessStats) GetDownloadBytes() uint64

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

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

+ func (m *ProcessStats) GetUploadBytes() uint64

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

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

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

+ func (m *ProcessStats) Reset()

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

+ func (m *ProcessStats) String() string

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

+ func (m *ProcessStats) XXX_DiscardUnknown()

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

+ func (m *ProcessStats) XXX_Merge(src proto.Message)

+ func (m *ProcessStats) XXX_Size() int

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

+ type RerunPipelineRequest struct

+ Exclude []*pfs.Commit

+ Include []*pfs.Commit

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RerunPipelineRequest) ProtoMessage()

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

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

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

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

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

+ func (m *RerunPipelineRequest) Reset()

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

+ func (m *RerunPipelineRequest) String() string

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

+ func (m *RerunPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *RerunPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *RerunPipelineRequest) XXX_Size() int

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

+ type ResourceSpec struct

+ Cpu float32

+ Disk string

+ Gpu int64

+ Memory string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResourceSpec) ProtoMessage()

+ func (m *ResourceSpec) GetCpu() float32

+ func (m *ResourceSpec) GetDisk() string

+ func (m *ResourceSpec) GetGpu() int64

+ func (m *ResourceSpec) GetMemory() string

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

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

+ func (m *ResourceSpec) Reset()

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

+ func (m *ResourceSpec) String() string

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

+ func (m *ResourceSpec) XXX_DiscardUnknown()

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

+ func (m *ResourceSpec) XXX_Merge(src proto.Message)

+ func (m *ResourceSpec) XXX_Size() int

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

+ type RestartDatumRequest struct

+ DataFilters []string

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RestartDatumRequest) ProtoMessage()

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

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

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

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

+ func (m *RestartDatumRequest) Reset()

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

+ func (m *RestartDatumRequest) String() string

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

+ func (m *RestartDatumRequest) XXX_DiscardUnknown()

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

+ func (m *RestartDatumRequest) XXX_Merge(src proto.Message)

+ func (m *RestartDatumRequest) XXX_Size() int

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

+ type SchedulingSpec struct

+ NodeSelector map[string]string

+ PriorityClassName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SchedulingSpec) ProtoMessage()

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

+ func (m *SchedulingSpec) GetPriorityClassName() string

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

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

+ func (m *SchedulingSpec) Reset()

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

+ func (m *SchedulingSpec) String() string

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

+ func (m *SchedulingSpec) XXX_DiscardUnknown()

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

+ func (m *SchedulingSpec) XXX_Merge(src proto.Message)

+ func (m *SchedulingSpec) XXX_Size() int

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

+ type Secret struct

+ EnvVar string

+ Key string

+ MountPath string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Secret) ProtoMessage()

+ func (m *Secret) GetEnvVar() string

+ func (m *Secret) GetKey() string

+ func (m *Secret) GetMountPath() string

+ func (m *Secret) GetName() string

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

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

+ func (m *Secret) Reset()

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

+ func (m *Secret) String() string

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

+ func (m *Secret) XXX_DiscardUnknown()

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

+ func (m *Secret) XXX_Merge(src proto.Message)

+ func (m *Secret) XXX_Size() int

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

+ type Service struct

+ ExternalPort int32

+ IP string

+ InternalPort int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Service) ProtoMessage()

+ func (m *Service) GetExternalPort() int32

+ func (m *Service) GetIP() string

+ func (m *Service) GetInternalPort() int32

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

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

+ func (m *Service) Reset()

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

+ func (m *Service) String() string

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

+ func (m *Service) XXX_DiscardUnknown()

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

+ func (m *Service) XXX_Merge(src proto.Message)

+ func (m *Service) XXX_Size() int

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

+ type StartPipelineRequest struct

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StartPipelineRequest) ProtoMessage()

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

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

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

+ func (m *StartPipelineRequest) Reset()

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

+ func (m *StartPipelineRequest) String() string

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

+ func (m *StartPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *StartPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *StartPipelineRequest) XXX_Size() int

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

+ type StopJobRequest struct

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StopJobRequest) ProtoMessage()

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

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

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

+ func (m *StopJobRequest) Reset()

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

+ func (m *StopJobRequest) String() string

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

+ func (m *StopJobRequest) XXX_DiscardUnknown()

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

+ func (m *StopJobRequest) XXX_Merge(src proto.Message)

+ func (m *StopJobRequest) XXX_Size() int

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

+ type StopPipelineRequest struct

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StopPipelineRequest) ProtoMessage()

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

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

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

+ func (m *StopPipelineRequest) Reset()

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

+ func (m *StopPipelineRequest) String() string

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

+ func (m *StopPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *StopPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *StopPipelineRequest) XXX_Size() int

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

+ type Transform struct

+ AcceptReturnCode []int64

+ Cmd []string

+ Debug bool

+ Env map[string]string

+ Image string

+ ImagePullSecrets []string

+ Secrets []*Secret

+ Stdin []string

+ User string

+ WorkingDir string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Transform) ProtoMessage()

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

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

+ func (m *Transform) GetDebug() bool

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

+ func (m *Transform) GetImage() string

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

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

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

+ func (m *Transform) GetUser() string

+ func (m *Transform) GetWorkingDir() string

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

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

+ func (m *Transform) Reset()

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

+ func (m *Transform) String() string

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

+ func (m *Transform) XXX_DiscardUnknown()

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

+ func (m *Transform) XXX_Merge(src proto.Message)

+ func (m *Transform) XXX_Size() int

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

+ type Worker struct

+ Name string

+ State WorkerState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Worker) ProtoMessage()

+ func (m *Worker) GetName() string

+ func (m *Worker) GetState() WorkerState

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

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

+ func (m *Worker) Reset()

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

+ func (m *Worker) String() string

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

+ func (m *Worker) XXX_DiscardUnknown()

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

+ func (m *Worker) XXX_Merge(src proto.Message)

+ func (m *Worker) XXX_Size() int

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

+ type WorkerState int32

+ const WorkerState_POD_FAILED

+ const WorkerState_POD_RUNNING

+ const WorkerState_POD_SUCCESS

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

+ func (x WorkerState) String() string

+ type WorkerStatus struct

+ Data []*InputFile

+ JobID string

+ QueueSize int64

+ Started *types.Timestamp

+ Stats *ProcessStats

+ WorkerID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WorkerStatus) ProtoMessage()

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

+ func (m *WorkerStatus) GetJobID() string

+ func (m *WorkerStatus) GetQueueSize() int64

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

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

+ func (m *WorkerStatus) GetWorkerID() string

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

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

+ func (m *WorkerStatus) Reset()

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

+ func (m *WorkerStatus) String() string

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

+ func (m *WorkerStatus) XXX_DiscardUnknown()

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

+ func (m *WorkerStatus) XXX_Merge(src proto.Message)

+ func (m *WorkerStatus) XXX_Size() int

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

v1.8.2-c94af25b6a6a45ab38980e2b29010bef8869ee85

Jan 24, 2019

v1.8.2-c5c9defc1862febc0f633b4a211692fa5c84c69f

Jan 24, 2019

v1.8.2-c2dc1d719856f44183c6be9e6404fa24704b9726

Jan 23, 2019

v1.8.2-b01811d728f42bedb77d95f95bceeabffbf7afeb

Jan 21, 2019

v1.8.2-3d440134bca6a690643f64911242930cca174a48

Jan 25, 2019

v1.8.2-267bb46df4269caf48ff5ffdd247c5bcbffc0cd9

Jan 30, 2019

v1.8.2-0dd2ae297eab6fb635d3278410566458707d728f

Jan 24, 2019

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL