pps

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