Documentation ¶
Overview ¶
Package persist is a generated protocol buffer package.
It is generated from these files:
server/pps/persist/persist.proto
It has these top-level messages:
JobInfo Pod Chunk Chunks JobInfos JobIDs JobOutput JobState AddOutputCommitRequest PipelineInfo PipelineInfoChange PipelineInfos SubscribePipelineInfosRequest SubscribeJobInfosRequest JobInfoChange ListPipelineInfosRequest Shard UpdatePipelineStateRequest UpdatePipelineStoppedRequest BlockPipelineStateRequest AddChunkRequest ClaimChunkRequest RenewChunkRequest FinishChunkRequest RevokeChunkRequest WaitJobResponse ChunkChange SubscribeChunksRequest ListGCJobsRequest
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type API_SubscribeChunksClient
- type API_SubscribeChunksServer
- type API_SubscribeJobInfosClient
- type API_SubscribeJobInfosServer
- type API_SubscribePipelineInfosClient
- type API_SubscribePipelineInfosServer
- type AddChunkRequest
- type AddOutputCommitRequest
- func (*AddOutputCommitRequest) Descriptor() ([]byte, []int)
- func (m *AddOutputCommitRequest) GetBranch() string
- func (m *AddOutputCommitRequest) GetCommit() *pfs.Commit
- func (m *AddOutputCommitRequest) GetJobID() string
- func (*AddOutputCommitRequest) ProtoMessage()
- func (m *AddOutputCommitRequest) Reset()
- func (m *AddOutputCommitRequest) String() string
- type BlockPipelineStateRequest
- func (*BlockPipelineStateRequest) Descriptor() ([]byte, []int)
- func (m *BlockPipelineStateRequest) GetPipelineName() string
- func (m *BlockPipelineStateRequest) GetState() pps.PipelineState
- func (*BlockPipelineStateRequest) ProtoMessage()
- func (m *BlockPipelineStateRequest) Reset()
- func (m *BlockPipelineStateRequest) String() string
- type ChangeType
- type Chunk
- func (*Chunk) Descriptor() ([]byte, []int)
- func (m *Chunk) GetID() string
- func (m *Chunk) GetIndex() uint64
- func (m *Chunk) GetJobID() string
- func (m *Chunk) GetLeaseTime() uint64
- func (m *Chunk) GetModuli() []uint64
- func (m *Chunk) GetOwner() string
- func (m *Chunk) GetPods() []*Pod
- func (m *Chunk) GetState() ChunkState
- func (*Chunk) ProtoMessage()
- func (m *Chunk) Reset()
- func (m *Chunk) String() string
- type ChunkChange
- type ChunkState
- type Chunks
- type ClaimChunkRequest
- type FinishChunkRequest
- type JobIDs
- type JobInfo
- func (*JobInfo) Descriptor() ([]byte, []int)
- func (m *JobInfo) GetBranch() string
- func (m *JobInfo) GetCommitIndex() string
- func (m *JobInfo) GetDefaultShardModuli() []uint64
- func (m *JobInfo) GetFinished() *google_protobuf1.Timestamp
- func (m *JobInfo) GetGc() bool
- func (m *JobInfo) GetInputs() []*pps.JobInput
- func (m *JobInfo) GetJobID() string
- func (m *JobInfo) GetOutput() *pps.Output
- func (m *JobInfo) GetOutputCommit() *pfs.Commit
- func (m *JobInfo) GetParallelismSpec() *pps.ParallelismSpec
- func (m *JobInfo) GetParentJob() *pps.Job
- func (m *JobInfo) GetPipelineName() string
- func (m *JobInfo) GetPipelineVersion() uint64
- func (m *JobInfo) GetResources() *pps.Resources
- func (m *JobInfo) GetService() *pps.Service
- func (m *JobInfo) GetShard() uint64
- func (m *JobInfo) GetStarted() *google_protobuf1.Timestamp
- func (m *JobInfo) GetState() pps.JobState
- func (m *JobInfo) GetTransform() *pps.Transform
- func (*JobInfo) ProtoMessage()
- func (m *JobInfo) Reset()
- func (m *JobInfo) String() string
- type JobInfoChange
- type JobInfos
- type JobOutput
- type JobState
- type ListGCJobsRequest
- type ListPipelineInfosRequest
- type PipelineInfo
- func (*PipelineInfo) Descriptor() ([]byte, []int)
- func (m *PipelineInfo) GetCreatedAt() *google_protobuf1.Timestamp
- func (m *PipelineInfo) GetGcPolicy() *pps.GCPolicy
- func (m *PipelineInfo) GetInputs() []*pps.PipelineInput
- func (m *PipelineInfo) GetJobCounts() map[int32]int32
- func (m *PipelineInfo) GetOutput() *pps.Output
- func (m *PipelineInfo) GetOutputRepo() *pfs.Repo
- func (m *PipelineInfo) GetParallelismSpec() *pps.ParallelismSpec
- func (m *PipelineInfo) GetPipelineName() string
- func (m *PipelineInfo) GetRecentError() string
- func (m *PipelineInfo) GetResources() *pps.Resources
- func (m *PipelineInfo) GetShard() uint64
- func (m *PipelineInfo) GetState() pps.PipelineState
- func (m *PipelineInfo) GetStopped() bool
- func (m *PipelineInfo) GetTransform() *pps.Transform
- func (m *PipelineInfo) GetVersion() uint64
- func (*PipelineInfo) ProtoMessage()
- func (m *PipelineInfo) Reset()
- func (m *PipelineInfo) String() string
- type PipelineInfoChange
- type PipelineInfos
- type Pod
- type RenewChunkRequest
- type RevokeChunkRequest
- func (*RevokeChunkRequest) Descriptor() ([]byte, []int)
- func (m *RevokeChunkRequest) GetChunkID() string
- func (m *RevokeChunkRequest) GetMaxPods() uint64
- func (m *RevokeChunkRequest) GetPodName() string
- func (*RevokeChunkRequest) ProtoMessage()
- func (m *RevokeChunkRequest) Reset()
- func (m *RevokeChunkRequest) String() string
- type Shard
- type SubscribeChunksRequest
- func (*SubscribeChunksRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeChunksRequest) GetIncludeInitial() bool
- func (m *SubscribeChunksRequest) GetJob() *pps.Job
- func (*SubscribeChunksRequest) ProtoMessage()
- func (m *SubscribeChunksRequest) Reset()
- func (m *SubscribeChunksRequest) String() string
- type SubscribeJobInfosRequest
- func (*SubscribeJobInfosRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeJobInfosRequest) GetIncludeChanges() bool
- func (m *SubscribeJobInfosRequest) GetIncludeInitial() bool
- func (m *SubscribeJobInfosRequest) GetShard() *Shard
- func (m *SubscribeJobInfosRequest) GetState() []pps.JobState
- func (*SubscribeJobInfosRequest) ProtoMessage()
- func (m *SubscribeJobInfosRequest) Reset()
- func (m *SubscribeJobInfosRequest) String() string
- type SubscribePipelineInfosRequest
- func (*SubscribePipelineInfosRequest) Descriptor() ([]byte, []int)
- func (m *SubscribePipelineInfosRequest) GetIncludeInitial() bool
- func (m *SubscribePipelineInfosRequest) GetShard() *Shard
- func (*SubscribePipelineInfosRequest) ProtoMessage()
- func (m *SubscribePipelineInfosRequest) Reset()
- func (m *SubscribePipelineInfosRequest) String() string
- type UpdatePipelineStateRequest
- func (*UpdatePipelineStateRequest) Descriptor() ([]byte, []int)
- func (m *UpdatePipelineStateRequest) GetPipelineName() string
- func (m *UpdatePipelineStateRequest) GetRecentError() string
- func (m *UpdatePipelineStateRequest) GetState() pps.PipelineState
- func (*UpdatePipelineStateRequest) ProtoMessage()
- func (m *UpdatePipelineStateRequest) Reset()
- func (m *UpdatePipelineStateRequest) String() string
- type UpdatePipelineStoppedRequest
- func (*UpdatePipelineStoppedRequest) Descriptor() ([]byte, []int)
- func (m *UpdatePipelineStoppedRequest) GetPipelineName() string
- func (m *UpdatePipelineStoppedRequest) GetStopped() bool
- func (*UpdatePipelineStoppedRequest) ProtoMessage()
- func (m *UpdatePipelineStoppedRequest) Reset()
- func (m *UpdatePipelineStoppedRequest) String() string
- type WaitJobResponse
Constants ¶
This section is empty.
Variables ¶
View Source
var ChangeType_name = map[int32]string{
0: "CREATE",
1: "UPDATE",
2: "DELETE",
}
View Source
var ChangeType_value = map[string]int32{
"CREATE": 0,
"UPDATE": 1,
"DELETE": 2,
}
View Source
var ChunkState_name = map[int32]string{
0: "UNASSIGNED",
1: "ASSIGNED",
2: "SUCCESS",
3: "FAILED",
4: "SPLITTED",
}
View Source
var ChunkState_value = map[string]int32{
"UNASSIGNED": 0,
"ASSIGNED": 1,
"SUCCESS": 2,
"FAILED": 3,
"SPLITTED": 4,
}
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface { // Job rpcs // job_id cannot be set // timestamp cannot be set CreateJobInfo(ctx context.Context, in *JobInfo, opts ...grpc.CallOption) (*JobInfo, error) InspectJob(ctx context.Context, in *pps.InspectJobRequest, opts ...grpc.CallOption) (*JobInfo, error) // ordered by time, latest to earliest ListJobInfos(ctx context.Context, in *pps.ListJobRequest, opts ...grpc.CallOption) (*JobInfos, error) // should only be called when rolling back if a Job does not start! DeleteJobInfo(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error) DeleteJobInfosForPipeline(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error) SubscribeJobInfos(ctx context.Context, in *SubscribeJobInfosRequest, opts ...grpc.CallOption) (API_SubscribeJobInfosClient, error) // JobOutput rpcs CreateJobOutput(ctx context.Context, in *JobOutput, opts ...grpc.CallOption) (*google_protobuf.Empty, error) // JobState rpcs CreateJobState(ctx context.Context, in *JobState, opts ...grpc.CallOption) (*google_protobuf.Empty, error) // StartJob sets the state of the job to "running" if the state // is currently "pulling". // This API updates the job state in a transactional manner. StartJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*JobInfo, error) // GC rpcs // List the IDs of jobs that should be GC-ed ListGCJobs(ctx context.Context, in *ListGCJobsRequest, opts ...grpc.CallOption) (*JobIDs, error) // Mark a job has having been GC-ed GCJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error) // Pipeline rpcs CreatePipelineInfo(ctx context.Context, in *PipelineInfo, opts ...grpc.CallOption) (*google_protobuf.Empty, error) UpdatePipelineInfo(ctx context.Context, in *PipelineInfo, opts ...grpc.CallOption) (*google_protobuf.Empty, error) TouchPipelineInfo(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error) GetPipelineInfo(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*PipelineInfo, error) // ordered by time, latest to earliest ListPipelineInfos(ctx context.Context, in *ListPipelineInfosRequest, opts ...grpc.CallOption) (*PipelineInfos, error) DeletePipelineInfo(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error) SubscribePipelineInfos(ctx context.Context, in *SubscribePipelineInfosRequest, opts ...grpc.CallOption) (API_SubscribePipelineInfosClient, error) UpdatePipelineState(ctx context.Context, in *UpdatePipelineStateRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) UpdatePipelineStopped(ctx context.Context, in *UpdatePipelineStoppedRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) BlockPipelineState(ctx context.Context, in *BlockPipelineStateRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) // DeleteAll deletes everything DeleteAll(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error) // Chunk rpcs AddChunk(ctx context.Context, in *AddChunkRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) ClaimChunk(ctx context.Context, in *ClaimChunkRequest, opts ...grpc.CallOption) (*Chunk, error) RenewChunk(ctx context.Context, in *RenewChunkRequest, opts ...grpc.CallOption) (*Chunk, error) FinishChunk(ctx context.Context, in *FinishChunkRequest, opts ...grpc.CallOption) (*Chunk, error) RevokeChunk(ctx context.Context, in *RevokeChunkRequest, opts ...grpc.CallOption) (*Chunk, error) SubscribeChunks(ctx context.Context, in *SubscribeChunksRequest, opts ...grpc.CallOption) (API_SubscribeChunksClient, error) GetChunksForJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*Chunks, error) DeleteChunksForJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error) }
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface { // Job rpcs // job_id cannot be set // timestamp cannot be set CreateJobInfo(context.Context, *JobInfo) (*JobInfo, error) InspectJob(context.Context, *pps.InspectJobRequest) (*JobInfo, error) // ordered by time, latest to earliest ListJobInfos(context.Context, *pps.ListJobRequest) (*JobInfos, error) // should only be called when rolling back if a Job does not start! DeleteJobInfo(context.Context, *pps.Job) (*google_protobuf.Empty, error) DeleteJobInfosForPipeline(context.Context, *pps.Pipeline) (*google_protobuf.Empty, error) SubscribeJobInfos(*SubscribeJobInfosRequest, API_SubscribeJobInfosServer) error // JobOutput rpcs CreateJobOutput(context.Context, *JobOutput) (*google_protobuf.Empty, error) // JobState rpcs CreateJobState(context.Context, *JobState) (*google_protobuf.Empty, error) // StartJob sets the state of the job to "running" if the state // is currently "pulling". // This API updates the job state in a transactional manner. StartJob(context.Context, *pps.Job) (*JobInfo, error) // GC rpcs // List the IDs of jobs that should be GC-ed ListGCJobs(context.Context, *ListGCJobsRequest) (*JobIDs, error) // Mark a job has having been GC-ed GCJob(context.Context, *pps.Job) (*google_protobuf.Empty, error) // Pipeline rpcs CreatePipelineInfo(context.Context, *PipelineInfo) (*google_protobuf.Empty, error) UpdatePipelineInfo(context.Context, *PipelineInfo) (*google_protobuf.Empty, error) TouchPipelineInfo(context.Context, *pps.Pipeline) (*google_protobuf.Empty, error) GetPipelineInfo(context.Context, *pps.Pipeline) (*PipelineInfo, error) // ordered by time, latest to earliest ListPipelineInfos(context.Context, *ListPipelineInfosRequest) (*PipelineInfos, error) DeletePipelineInfo(context.Context, *pps.Pipeline) (*google_protobuf.Empty, error) SubscribePipelineInfos(*SubscribePipelineInfosRequest, API_SubscribePipelineInfosServer) error UpdatePipelineState(context.Context, *UpdatePipelineStateRequest) (*google_protobuf.Empty, error) UpdatePipelineStopped(context.Context, *UpdatePipelineStoppedRequest) (*google_protobuf.Empty, error) BlockPipelineState(context.Context, *BlockPipelineStateRequest) (*google_protobuf.Empty, error) // DeleteAll deletes everything DeleteAll(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error) // Chunk rpcs AddChunk(context.Context, *AddChunkRequest) (*google_protobuf.Empty, error) ClaimChunk(context.Context, *ClaimChunkRequest) (*Chunk, error) RenewChunk(context.Context, *RenewChunkRequest) (*Chunk, error) FinishChunk(context.Context, *FinishChunkRequest) (*Chunk, error) RevokeChunk(context.Context, *RevokeChunkRequest) (*Chunk, error) SubscribeChunks(*SubscribeChunksRequest, API_SubscribeChunksServer) error GetChunksForJob(context.Context, *pps.Job) (*Chunks, error) DeleteChunksForJob(context.Context, *pps.Job) (*google_protobuf.Empty, error) }
type API_SubscribeChunksClient ¶ added in v1.2.4
type API_SubscribeChunksClient interface { Recv() (*ChunkChange, error) grpc.ClientStream }
type API_SubscribeChunksServer ¶ added in v1.2.4
type API_SubscribeChunksServer interface { Send(*ChunkChange) error grpc.ServerStream }
type API_SubscribeJobInfosClient ¶ added in v1.2.4
type API_SubscribeJobInfosClient interface { Recv() (*JobInfoChange, error) grpc.ClientStream }
type API_SubscribeJobInfosServer ¶ added in v1.2.4
type API_SubscribeJobInfosServer interface { Send(*JobInfoChange) error grpc.ServerStream }
type API_SubscribePipelineInfosClient ¶
type API_SubscribePipelineInfosClient interface { Recv() (*PipelineInfoChange, error) grpc.ClientStream }
type API_SubscribePipelineInfosServer ¶
type API_SubscribePipelineInfosServer interface { Send(*PipelineInfoChange) error grpc.ServerStream }
type AddChunkRequest ¶ added in v1.2.4
type AddChunkRequest struct {
Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks" json:"chunks,omitempty"`
}
func (*AddChunkRequest) Descriptor ¶ added in v1.2.4
func (*AddChunkRequest) Descriptor() ([]byte, []int)
func (*AddChunkRequest) GetChunks ¶ added in v1.2.4
func (m *AddChunkRequest) GetChunks() []*Chunk
func (*AddChunkRequest) ProtoMessage ¶ added in v1.2.4
func (*AddChunkRequest) ProtoMessage()
func (*AddChunkRequest) Reset ¶ added in v1.2.4
func (m *AddChunkRequest) Reset()
func (*AddChunkRequest) String ¶ added in v1.2.4
func (m *AddChunkRequest) String() string
type AddOutputCommitRequest ¶ added in v1.2.0
type AddOutputCommitRequest struct { JobID string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` Commit *pfs.Commit `protobuf:"bytes,2,opt,name=commit" json:"commit,omitempty"` Branch string `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"` }
func (*AddOutputCommitRequest) Descriptor ¶ added in v1.2.0
func (*AddOutputCommitRequest) Descriptor() ([]byte, []int)
func (*AddOutputCommitRequest) GetBranch ¶ added in v1.3.5
func (m *AddOutputCommitRequest) GetBranch() string
func (*AddOutputCommitRequest) GetCommit ¶ added in v1.2.0
func (m *AddOutputCommitRequest) GetCommit() *pfs.Commit
func (*AddOutputCommitRequest) GetJobID ¶ added in v1.3.5
func (m *AddOutputCommitRequest) GetJobID() string
func (*AddOutputCommitRequest) ProtoMessage ¶ added in v1.2.0
func (*AddOutputCommitRequest) ProtoMessage()
func (*AddOutputCommitRequest) Reset ¶ added in v1.2.0
func (m *AddOutputCommitRequest) Reset()
func (*AddOutputCommitRequest) String ¶ added in v1.2.0
func (m *AddOutputCommitRequest) String() string
type BlockPipelineStateRequest ¶ added in v1.2.0
type BlockPipelineStateRequest struct { PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"` State pps.PipelineState `protobuf:"varint,2,opt,name=state,proto3,enum=pps.PipelineState" json:"state,omitempty"` }
func (*BlockPipelineStateRequest) Descriptor ¶ added in v1.2.0
func (*BlockPipelineStateRequest) Descriptor() ([]byte, []int)
func (*BlockPipelineStateRequest) GetPipelineName ¶ added in v1.3.5
func (m *BlockPipelineStateRequest) GetPipelineName() string
func (*BlockPipelineStateRequest) GetState ¶ added in v1.3.5
func (m *BlockPipelineStateRequest) GetState() pps.PipelineState
func (*BlockPipelineStateRequest) ProtoMessage ¶ added in v1.2.0
func (*BlockPipelineStateRequest) ProtoMessage()
func (*BlockPipelineStateRequest) Reset ¶ added in v1.2.0
func (m *BlockPipelineStateRequest) Reset()
func (*BlockPipelineStateRequest) String ¶ added in v1.2.0
func (m *BlockPipelineStateRequest) String() string
type ChangeType ¶ added in v1.2.0
type ChangeType int32
const ( ChangeType_CREATE ChangeType = 0 ChangeType_UPDATE ChangeType = 1 ChangeType_DELETE ChangeType = 2 )
func (ChangeType) EnumDescriptor ¶ added in v1.2.0
func (ChangeType) EnumDescriptor() ([]byte, []int)
func (ChangeType) String ¶ added in v1.2.0
func (x ChangeType) String() string
type Chunk ¶ added in v1.2.4
type Chunk struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // the ID of the job that the Chunk belongs to JobID string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // moduli and index together specify the portion of inputs that the shard represents // For instance, if moduli is (2, 3, 4) and index is 15, then we have: // 15 = 1 * (3 * 4) + 0 * 4 + 3 * 1 // So the shard represents the second half of input 1, the first third of input 2, // and the fourth quarter of input 3. Moduli []uint64 `protobuf:"varint,3,rep,packed,name=moduli" json:"moduli,omitempty"` Index uint64 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"` // the pod that currently owns this shard Owner string `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"` // A series of pods, in chronological order, that have processed this shard Pods []*Pod `protobuf:"bytes,6,rep,name=pods" json:"pods,omitempty"` State ChunkState `protobuf:"varint,7,opt,name=state,proto3,enum=pps.persist.ChunkState" json:"state,omitempty"` // a unix timestamp representing the last time we received a ContinueJob // for this chunk LeaseTime uint64 `protobuf:"varint,8,opt,name=lease_time,json=leaseTime,proto3" json:"lease_time,omitempty"` }
Chunk is a unit of work that can be assigned to a pod
func (*Chunk) Descriptor ¶ added in v1.2.4
func (*Chunk) GetLeaseTime ¶ added in v1.3.5
func (*Chunk) GetState ¶ added in v1.3.5
func (m *Chunk) GetState() ChunkState
func (*Chunk) ProtoMessage ¶ added in v1.2.4
func (*Chunk) ProtoMessage()
type ChunkChange ¶ added in v1.2.4
type ChunkChange struct { Chunk *Chunk `protobuf:"bytes,1,opt,name=chunk" json:"chunk,omitempty"` Type ChangeType `protobuf:"varint,2,opt,name=type,proto3,enum=pps.persist.ChangeType" json:"type,omitempty"` // If ready is set to true, then all initial documents have been sent // See docs on `includeState` for rethinkdb's changefeed: // https://www.rethinkdb.com/api/javascript/changes/ Ready bool `protobuf:"varint,3,opt,name=ready,proto3" json:"ready,omitempty"` }
func (*ChunkChange) Descriptor ¶ added in v1.2.4
func (*ChunkChange) Descriptor() ([]byte, []int)
func (*ChunkChange) GetChunk ¶ added in v1.2.4
func (m *ChunkChange) GetChunk() *Chunk
func (*ChunkChange) GetReady ¶ added in v1.3.5
func (m *ChunkChange) GetReady() bool
func (*ChunkChange) GetType ¶ added in v1.3.5
func (m *ChunkChange) GetType() ChangeType
func (*ChunkChange) ProtoMessage ¶ added in v1.2.4
func (*ChunkChange) ProtoMessage()
func (*ChunkChange) Reset ¶ added in v1.2.4
func (m *ChunkChange) Reset()
func (*ChunkChange) String ¶ added in v1.2.4
func (m *ChunkChange) String() string
type ChunkState ¶ added in v1.2.4
type ChunkState int32
const ( // the chunk is available for a pod to work on ChunkState_UNASSIGNED ChunkState = 0 // the chunk has been assigned to a pod ChunkState_ASSIGNED ChunkState = 1 // the chunk has been processed successfully ChunkState_SUCCESS ChunkState = 2 // the chunk could not be processed ChunkState_FAILED ChunkState = 3 // the chunk has been splitted into smaller chunks, so this chunk no longer // needs to be processed. ChunkState_SPLITTED ChunkState = 4 )
func (ChunkState) EnumDescriptor ¶ added in v1.2.4
func (ChunkState) EnumDescriptor() ([]byte, []int)
func (ChunkState) String ¶ added in v1.2.4
func (x ChunkState) String() string
type Chunks ¶ added in v1.2.4
type Chunks struct {
Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks" json:"chunks,omitempty"`
}
func (*Chunks) Descriptor ¶ added in v1.2.4
func (*Chunks) ProtoMessage ¶ added in v1.2.4
func (*Chunks) ProtoMessage()
type ClaimChunkRequest ¶ added in v1.2.4
type ClaimChunkRequest struct { JobID string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` Pod *Pod `protobuf:"bytes,2,opt,name=pod" json:"pod,omitempty"` }
func (*ClaimChunkRequest) Descriptor ¶ added in v1.2.4
func (*ClaimChunkRequest) Descriptor() ([]byte, []int)
func (*ClaimChunkRequest) GetJobID ¶ added in v1.3.5
func (m *ClaimChunkRequest) GetJobID() string
func (*ClaimChunkRequest) GetPod ¶ added in v1.2.4
func (m *ClaimChunkRequest) GetPod() *Pod
func (*ClaimChunkRequest) ProtoMessage ¶ added in v1.2.4
func (*ClaimChunkRequest) ProtoMessage()
func (*ClaimChunkRequest) Reset ¶ added in v1.2.4
func (m *ClaimChunkRequest) Reset()
func (*ClaimChunkRequest) String ¶ added in v1.2.4
func (m *ClaimChunkRequest) String() string
type FinishChunkRequest ¶ added in v1.2.4
type FinishChunkRequest struct { ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"` PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` }
func (*FinishChunkRequest) Descriptor ¶ added in v1.2.4
func (*FinishChunkRequest) Descriptor() ([]byte, []int)
func (*FinishChunkRequest) GetChunkID ¶ added in v1.3.5
func (m *FinishChunkRequest) GetChunkID() string
func (*FinishChunkRequest) GetPodName ¶ added in v1.3.5
func (m *FinishChunkRequest) GetPodName() string
func (*FinishChunkRequest) ProtoMessage ¶ added in v1.2.4
func (*FinishChunkRequest) ProtoMessage()
func (*FinishChunkRequest) Reset ¶ added in v1.2.4
func (m *FinishChunkRequest) Reset()
func (*FinishChunkRequest) String ¶ added in v1.2.4
func (m *FinishChunkRequest) String() string
type JobIDs ¶ added in v1.3.0
type JobIDs struct {
Jobs []string `protobuf:"bytes,1,rep,name=jobs" json:"jobs,omitempty"`
}
func (*JobIDs) Descriptor ¶ added in v1.3.0
func (*JobIDs) ProtoMessage ¶ added in v1.3.0
func (*JobIDs) ProtoMessage()
type JobInfo ¶
type JobInfo struct { JobID string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` Transform *pps.Transform `protobuf:"bytes,2,opt,name=transform" json:"transform,omitempty"` PipelineName string `protobuf:"bytes,3,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"` PipelineVersion uint64 `protobuf:"varint,20,opt,name=pipeline_version,json=pipelineVersion,proto3" json:"pipeline_version,omitempty"` ParallelismSpec *pps.ParallelismSpec `protobuf:"bytes,18,opt,name=parallelism_spec,json=parallelismSpec" json:"parallelism_spec,omitempty"` Inputs []*pps.JobInput `protobuf:"bytes,5,rep,name=inputs" json:"inputs,omitempty"` ParentJob *pps.Job `protobuf:"bytes,6,opt,name=parent_job,json=parentJob" json:"parent_job,omitempty"` Started *google_protobuf1.Timestamp `protobuf:"bytes,7,opt,name=started" json:"started,omitempty"` Finished *google_protobuf1.Timestamp `protobuf:"bytes,8,opt,name=finished" json:"finished,omitempty"` OutputCommit *pfs.Commit `protobuf:"bytes,9,opt,name=output_commit,json=outputCommit" json:"output_commit,omitempty"` Branch string `protobuf:"bytes,17,opt,name=branch,proto3" json:"branch,omitempty"` State pps.JobState `protobuf:"varint,10,opt,name=state,proto3,enum=pps.JobState" json:"state,omitempty"` CommitIndex string `protobuf:"bytes,11,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"` DefaultShardModuli []uint64 `protobuf:"varint,15,rep,packed,name=default_shard_moduli,json=defaultShardModuli" json:"default_shard_moduli,omitempty"` Shard uint64 `protobuf:"varint,19,opt,name=shard,proto3" json:"shard,omitempty"` // if true, the underlying Kubernetes job has been deleted Gc bool `protobuf:"varint,21,opt,name=gc,proto3" json:"gc,omitempty"` Service *pps.Service `protobuf:"bytes,22,opt,name=service" json:"service,omitempty"` Output *pps.Output `protobuf:"bytes,23,opt,name=output" json:"output,omitempty"` Resources *pps.Resources `protobuf:"bytes,24,opt,name=resources" json:"resources,omitempty"` }
func (*JobInfo) Descriptor ¶
func (*JobInfo) GetCommitIndex ¶ added in v1.3.5
func (*JobInfo) GetDefaultShardModuli ¶ added in v1.3.5
func (*JobInfo) GetFinished ¶
func (m *JobInfo) GetFinished() *google_protobuf1.Timestamp
func (*JobInfo) GetOutputCommit ¶
func (*JobInfo) GetParallelismSpec ¶ added in v1.2.0
func (m *JobInfo) GetParallelismSpec() *pps.ParallelismSpec
func (*JobInfo) GetParentJob ¶
func (*JobInfo) GetPipelineName ¶ added in v1.3.5
func (*JobInfo) GetPipelineVersion ¶ added in v1.3.5
func (*JobInfo) GetResources ¶ added in v1.3.12
func (*JobInfo) GetService ¶ added in v1.3.0
func (*JobInfo) GetStarted ¶
func (m *JobInfo) GetStarted() *google_protobuf1.Timestamp
func (*JobInfo) GetTransform ¶
func (*JobInfo) ProtoMessage ¶
func (*JobInfo) ProtoMessage()
type JobInfoChange ¶ added in v1.2.4
type JobInfoChange struct { JobInfo *JobInfo `protobuf:"bytes,1,opt,name=jobInfo" json:"jobInfo,omitempty"` Type ChangeType `protobuf:"varint,2,opt,name=type,proto3,enum=pps.persist.ChangeType" json:"type,omitempty"` }
func (*JobInfoChange) Descriptor ¶ added in v1.2.4
func (*JobInfoChange) Descriptor() ([]byte, []int)
func (*JobInfoChange) GetJobInfo ¶ added in v1.2.4
func (m *JobInfoChange) GetJobInfo() *JobInfo
func (*JobInfoChange) GetType ¶ added in v1.3.5
func (m *JobInfoChange) GetType() ChangeType
func (*JobInfoChange) ProtoMessage ¶ added in v1.2.4
func (*JobInfoChange) ProtoMessage()
func (*JobInfoChange) Reset ¶ added in v1.2.4
func (m *JobInfoChange) Reset()
func (*JobInfoChange) String ¶ added in v1.2.4
func (m *JobInfoChange) String() string
type JobInfos ¶
type JobInfos struct {
JobInfo []*JobInfo `protobuf:"bytes,1,rep,name=job_info,json=jobInfo" json:"job_info,omitempty"`
}
func (*JobInfos) Descriptor ¶
func (*JobInfos) GetJobInfo ¶
func (*JobInfos) ProtoMessage ¶
func (*JobInfos) ProtoMessage()
type JobOutput ¶
type JobOutput struct { JobID string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` OutputCommit *pfs.Commit `protobuf:"bytes,2,opt,name=output_commit,json=outputCommit" json:"output_commit,omitempty"` }
func (*JobOutput) Descriptor ¶
func (*JobOutput) GetOutputCommit ¶
func (*JobOutput) ProtoMessage ¶
func (*JobOutput) ProtoMessage()
type JobState ¶
type JobState struct { JobID string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` State pps.JobState `protobuf:"varint,2,opt,name=state,proto3,enum=pps.JobState" json:"state,omitempty"` Finished *google_protobuf1.Timestamp `protobuf:"bytes,3,opt,name=finished" json:"finished,omitempty"` }
func (*JobState) Descriptor ¶
func (*JobState) GetFinished ¶
func (m *JobState) GetFinished() *google_protobuf1.Timestamp
func (*JobState) ProtoMessage ¶
func (*JobState) ProtoMessage()
type ListGCJobsRequest ¶ added in v1.3.0
type ListGCJobsRequest struct { PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"` GcPolicy *pps.GCPolicy `protobuf:"bytes,2,opt,name=gc_policy,json=gcPolicy" json:"gc_policy,omitempty"` }
func (*ListGCJobsRequest) Descriptor ¶ added in v1.3.0
func (*ListGCJobsRequest) Descriptor() ([]byte, []int)
func (*ListGCJobsRequest) GetGcPolicy ¶ added in v1.3.0
func (m *ListGCJobsRequest) GetGcPolicy() *pps.GCPolicy
func (*ListGCJobsRequest) GetPipelineName ¶ added in v1.3.5
func (m *ListGCJobsRequest) GetPipelineName() string
func (*ListGCJobsRequest) ProtoMessage ¶ added in v1.3.0
func (*ListGCJobsRequest) ProtoMessage()
func (*ListGCJobsRequest) Reset ¶ added in v1.3.0
func (m *ListGCJobsRequest) Reset()
func (*ListGCJobsRequest) String ¶ added in v1.3.0
func (m *ListGCJobsRequest) String() string
type ListPipelineInfosRequest ¶
type ListPipelineInfosRequest struct {
Shard *Shard `protobuf:"bytes,1,opt,name=shard" json:"shard,omitempty"`
}
func (*ListPipelineInfosRequest) Descriptor ¶
func (*ListPipelineInfosRequest) Descriptor() ([]byte, []int)
func (*ListPipelineInfosRequest) GetShard ¶
func (m *ListPipelineInfosRequest) GetShard() *Shard
func (*ListPipelineInfosRequest) ProtoMessage ¶
func (*ListPipelineInfosRequest) ProtoMessage()
func (*ListPipelineInfosRequest) Reset ¶
func (m *ListPipelineInfosRequest) Reset()
func (*ListPipelineInfosRequest) String ¶
func (m *ListPipelineInfosRequest) String() string
type PipelineInfo ¶
type PipelineInfo struct { PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"` Version uint64 `protobuf:"varint,13,opt,name=version,proto3" json:"version,omitempty"` Transform *pps.Transform `protobuf:"bytes,2,opt,name=transform" json:"transform,omitempty"` ParallelismSpec *pps.ParallelismSpec `protobuf:"bytes,12,opt,name=parallelism_spec,json=parallelismSpec" json:"parallelism_spec,omitempty"` Inputs []*pps.PipelineInput `protobuf:"bytes,4,rep,name=inputs" json:"inputs,omitempty"` OutputRepo *pfs.Repo `protobuf:"bytes,5,opt,name=output_repo,json=outputRepo" json:"output_repo,omitempty"` CreatedAt *google_protobuf1.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt" json:"created_at,omitempty"` Shard uint64 `protobuf:"varint,7,opt,name=shard,proto3" json:"shard,omitempty"` State pps.PipelineState `protobuf:"varint,8,opt,name=state,proto3,enum=pps.PipelineState" json:"state,omitempty"` RecentError string `protobuf:"bytes,9,opt,name=recent_error,json=recentError,proto3" json:"recent_error,omitempty"` JobCounts map[int32]int32 `` /* 172-byte string literal not displayed */ Stopped bool `protobuf:"varint,11,opt,name=stopped,proto3" json:"stopped,omitempty"` GcPolicy *pps.GCPolicy `protobuf:"bytes,14,opt,name=gc_policy,json=gcPolicy" json:"gc_policy,omitempty"` Output *pps.Output `protobuf:"bytes,15,opt,name=output" json:"output,omitempty"` Resources *pps.Resources `protobuf:"bytes,16,opt,name=resources" json:"resources,omitempty"` }
func (*PipelineInfo) Descriptor ¶
func (*PipelineInfo) Descriptor() ([]byte, []int)
func (*PipelineInfo) GetCreatedAt ¶
func (m *PipelineInfo) GetCreatedAt() *google_protobuf1.Timestamp
func (*PipelineInfo) GetGcPolicy ¶ added in v1.3.0
func (m *PipelineInfo) GetGcPolicy() *pps.GCPolicy
func (*PipelineInfo) GetInputs ¶
func (m *PipelineInfo) GetInputs() []*pps.PipelineInput
func (*PipelineInfo) GetJobCounts ¶
func (m *PipelineInfo) GetJobCounts() map[int32]int32
func (*PipelineInfo) GetOutput ¶ added in v1.3.2
func (m *PipelineInfo) GetOutput() *pps.Output
func (*PipelineInfo) GetOutputRepo ¶
func (m *PipelineInfo) GetOutputRepo() *pfs.Repo
func (*PipelineInfo) GetParallelismSpec ¶ added in v1.2.0
func (m *PipelineInfo) GetParallelismSpec() *pps.ParallelismSpec
func (*PipelineInfo) GetPipelineName ¶ added in v1.3.5
func (m *PipelineInfo) GetPipelineName() string
func (*PipelineInfo) GetRecentError ¶ added in v1.3.5
func (m *PipelineInfo) GetRecentError() string
func (*PipelineInfo) GetResources ¶ added in v1.3.13
func (m *PipelineInfo) GetResources() *pps.Resources
func (*PipelineInfo) GetShard ¶ added in v1.3.5
func (m *PipelineInfo) GetShard() uint64
func (*PipelineInfo) GetState ¶ added in v1.3.5
func (m *PipelineInfo) GetState() pps.PipelineState
func (*PipelineInfo) GetStopped ¶ added in v1.3.5
func (m *PipelineInfo) GetStopped() bool
func (*PipelineInfo) GetTransform ¶
func (m *PipelineInfo) GetTransform() *pps.Transform
func (*PipelineInfo) GetVersion ¶ added in v1.3.5
func (m *PipelineInfo) GetVersion() uint64
func (*PipelineInfo) ProtoMessage ¶
func (*PipelineInfo) ProtoMessage()
func (*PipelineInfo) Reset ¶
func (m *PipelineInfo) Reset()
func (*PipelineInfo) String ¶
func (m *PipelineInfo) String() string
type PipelineInfoChange ¶
type PipelineInfoChange struct { Pipeline *PipelineInfo `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"` Type ChangeType `protobuf:"varint,2,opt,name=type,proto3,enum=pps.persist.ChangeType" json:"type,omitempty"` }
func (*PipelineInfoChange) Descriptor ¶
func (*PipelineInfoChange) Descriptor() ([]byte, []int)
func (*PipelineInfoChange) GetPipeline ¶
func (m *PipelineInfoChange) GetPipeline() *PipelineInfo
func (*PipelineInfoChange) GetType ¶ added in v1.3.5
func (m *PipelineInfoChange) GetType() ChangeType
func (*PipelineInfoChange) ProtoMessage ¶
func (*PipelineInfoChange) ProtoMessage()
func (*PipelineInfoChange) Reset ¶
func (m *PipelineInfoChange) Reset()
func (*PipelineInfoChange) String ¶
func (m *PipelineInfoChange) String() string
type PipelineInfos ¶
type PipelineInfos struct {
PipelineInfo []*PipelineInfo `protobuf:"bytes,1,rep,name=pipeline_info,json=pipelineInfo" json:"pipeline_info,omitempty"`
}
func (*PipelineInfos) Descriptor ¶
func (*PipelineInfos) Descriptor() ([]byte, []int)
func (*PipelineInfos) GetPipelineInfo ¶
func (m *PipelineInfos) GetPipelineInfo() []*PipelineInfo
func (*PipelineInfos) ProtoMessage ¶
func (*PipelineInfos) ProtoMessage()
func (*PipelineInfos) Reset ¶
func (m *PipelineInfos) Reset()
func (*PipelineInfos) String ¶
func (m *PipelineInfos) String() string
type Pod ¶ added in v1.2.4
type Pod struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` OutputCommit *pfs.Commit `protobuf:"bytes,2,opt,name=output_commit,json=outputCommit" json:"output_commit,omitempty"` }
func (*Pod) Descriptor ¶ added in v1.2.4
func (*Pod) GetOutputCommit ¶ added in v1.2.4
func (*Pod) ProtoMessage ¶ added in v1.2.4
func (*Pod) ProtoMessage()
type RenewChunkRequest ¶ added in v1.2.4
type RenewChunkRequest struct { ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"` PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` }
func (*RenewChunkRequest) Descriptor ¶ added in v1.2.4
func (*RenewChunkRequest) Descriptor() ([]byte, []int)
func (*RenewChunkRequest) GetChunkID ¶ added in v1.3.5
func (m *RenewChunkRequest) GetChunkID() string
func (*RenewChunkRequest) GetPodName ¶ added in v1.3.5
func (m *RenewChunkRequest) GetPodName() string
func (*RenewChunkRequest) ProtoMessage ¶ added in v1.2.4
func (*RenewChunkRequest) ProtoMessage()
func (*RenewChunkRequest) Reset ¶ added in v1.2.4
func (m *RenewChunkRequest) Reset()
func (*RenewChunkRequest) String ¶ added in v1.2.4
func (m *RenewChunkRequest) String() string
type RevokeChunkRequest ¶ added in v1.2.4
type RevokeChunkRequest struct { ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"` PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` // if the number of pods that have processed this chunk exceeds maxPods, // then we switch the state of the chunk to FAILED instead of UNASSIGNED MaxPods uint64 `protobuf:"varint,3,opt,name=maxPods,proto3" json:"maxPods,omitempty"` }
func (*RevokeChunkRequest) Descriptor ¶ added in v1.2.4
func (*RevokeChunkRequest) Descriptor() ([]byte, []int)
func (*RevokeChunkRequest) GetChunkID ¶ added in v1.3.5
func (m *RevokeChunkRequest) GetChunkID() string
func (*RevokeChunkRequest) GetMaxPods ¶ added in v1.3.5
func (m *RevokeChunkRequest) GetMaxPods() uint64
func (*RevokeChunkRequest) GetPodName ¶ added in v1.3.5
func (m *RevokeChunkRequest) GetPodName() string
func (*RevokeChunkRequest) ProtoMessage ¶ added in v1.2.4
func (*RevokeChunkRequest) ProtoMessage()
func (*RevokeChunkRequest) Reset ¶ added in v1.2.4
func (m *RevokeChunkRequest) Reset()
func (*RevokeChunkRequest) String ¶ added in v1.2.4
func (m *RevokeChunkRequest) String() string
type Shard ¶
type Shard struct {
Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
}
func (*Shard) Descriptor ¶
func (*Shard) ProtoMessage ¶
func (*Shard) ProtoMessage()
type SubscribeChunksRequest ¶ added in v1.2.4
type SubscribeChunksRequest struct { Job *pps.Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"` IncludeInitial bool `protobuf:"varint,2,opt,name=include_initial,json=includeInitial,proto3" json:"include_initial,omitempty"` }
func (*SubscribeChunksRequest) Descriptor ¶ added in v1.2.4
func (*SubscribeChunksRequest) Descriptor() ([]byte, []int)
func (*SubscribeChunksRequest) GetIncludeInitial ¶ added in v1.3.5
func (m *SubscribeChunksRequest) GetIncludeInitial() bool
func (*SubscribeChunksRequest) GetJob ¶ added in v1.2.4
func (m *SubscribeChunksRequest) GetJob() *pps.Job
func (*SubscribeChunksRequest) ProtoMessage ¶ added in v1.2.4
func (*SubscribeChunksRequest) ProtoMessage()
func (*SubscribeChunksRequest) Reset ¶ added in v1.2.4
func (m *SubscribeChunksRequest) Reset()
func (*SubscribeChunksRequest) String ¶ added in v1.2.4
func (m *SubscribeChunksRequest) String() string
type SubscribeJobInfosRequest ¶ added in v1.2.4
type SubscribeJobInfosRequest struct { IncludeInitial bool `protobuf:"varint,1,opt,name=include_initial,json=includeInitial,proto3" json:"include_initial,omitempty"` IncludeChanges bool `protobuf:"varint,2,opt,name=include_changes,json=includeChanges,proto3" json:"include_changes,omitempty"` Shard *Shard `protobuf:"bytes,3,opt,name=shard" json:"shard,omitempty"` State []pps.JobState `protobuf:"varint,4,rep,packed,name=state,enum=pps.JobState" json:"state,omitempty"` }
func (*SubscribeJobInfosRequest) Descriptor ¶ added in v1.2.4
func (*SubscribeJobInfosRequest) Descriptor() ([]byte, []int)
func (*SubscribeJobInfosRequest) GetIncludeChanges ¶ added in v1.3.5
func (m *SubscribeJobInfosRequest) GetIncludeChanges() bool
func (*SubscribeJobInfosRequest) GetIncludeInitial ¶ added in v1.3.5
func (m *SubscribeJobInfosRequest) GetIncludeInitial() bool
func (*SubscribeJobInfosRequest) GetShard ¶ added in v1.2.4
func (m *SubscribeJobInfosRequest) GetShard() *Shard
func (*SubscribeJobInfosRequest) GetState ¶ added in v1.3.5
func (m *SubscribeJobInfosRequest) GetState() []pps.JobState
func (*SubscribeJobInfosRequest) ProtoMessage ¶ added in v1.2.4
func (*SubscribeJobInfosRequest) ProtoMessage()
func (*SubscribeJobInfosRequest) Reset ¶ added in v1.2.4
func (m *SubscribeJobInfosRequest) Reset()
func (*SubscribeJobInfosRequest) String ¶ added in v1.2.4
func (m *SubscribeJobInfosRequest) String() string
type SubscribePipelineInfosRequest ¶
type SubscribePipelineInfosRequest struct { IncludeInitial bool `protobuf:"varint,1,opt,name=include_initial,json=includeInitial,proto3" json:"include_initial,omitempty"` Shard *Shard `protobuf:"bytes,2,opt,name=shard" json:"shard,omitempty"` }
func (*SubscribePipelineInfosRequest) Descriptor ¶
func (*SubscribePipelineInfosRequest) Descriptor() ([]byte, []int)
func (*SubscribePipelineInfosRequest) GetIncludeInitial ¶ added in v1.3.5
func (m *SubscribePipelineInfosRequest) GetIncludeInitial() bool
func (*SubscribePipelineInfosRequest) GetShard ¶
func (m *SubscribePipelineInfosRequest) GetShard() *Shard
func (*SubscribePipelineInfosRequest) ProtoMessage ¶
func (*SubscribePipelineInfosRequest) ProtoMessage()
func (*SubscribePipelineInfosRequest) Reset ¶
func (m *SubscribePipelineInfosRequest) Reset()
func (*SubscribePipelineInfosRequest) String ¶
func (m *SubscribePipelineInfosRequest) String() string
type UpdatePipelineStateRequest ¶
type UpdatePipelineStateRequest struct { PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"` State pps.PipelineState `protobuf:"varint,2,opt,name=state,proto3,enum=pps.PipelineState" json:"state,omitempty"` RecentError string `protobuf:"bytes,3,opt,name=recent_error,json=recentError,proto3" json:"recent_error,omitempty"` }
func (*UpdatePipelineStateRequest) Descriptor ¶
func (*UpdatePipelineStateRequest) Descriptor() ([]byte, []int)
func (*UpdatePipelineStateRequest) GetPipelineName ¶ added in v1.3.5
func (m *UpdatePipelineStateRequest) GetPipelineName() string
func (*UpdatePipelineStateRequest) GetRecentError ¶ added in v1.3.5
func (m *UpdatePipelineStateRequest) GetRecentError() string
func (*UpdatePipelineStateRequest) GetState ¶ added in v1.3.5
func (m *UpdatePipelineStateRequest) GetState() pps.PipelineState
func (*UpdatePipelineStateRequest) ProtoMessage ¶
func (*UpdatePipelineStateRequest) ProtoMessage()
func (*UpdatePipelineStateRequest) Reset ¶
func (m *UpdatePipelineStateRequest) Reset()
func (*UpdatePipelineStateRequest) String ¶
func (m *UpdatePipelineStateRequest) String() string
type UpdatePipelineStoppedRequest ¶ added in v1.2.0
type UpdatePipelineStoppedRequest struct { PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"` Stopped bool `protobuf:"varint,2,opt,name=stopped,proto3" json:"stopped,omitempty"` }
func (*UpdatePipelineStoppedRequest) Descriptor ¶ added in v1.2.0
func (*UpdatePipelineStoppedRequest) Descriptor() ([]byte, []int)
func (*UpdatePipelineStoppedRequest) GetPipelineName ¶ added in v1.3.5
func (m *UpdatePipelineStoppedRequest) GetPipelineName() string
func (*UpdatePipelineStoppedRequest) GetStopped ¶ added in v1.3.5
func (m *UpdatePipelineStoppedRequest) GetStopped() bool
func (*UpdatePipelineStoppedRequest) ProtoMessage ¶ added in v1.2.0
func (*UpdatePipelineStoppedRequest) ProtoMessage()
func (*UpdatePipelineStoppedRequest) Reset ¶ added in v1.2.0
func (m *UpdatePipelineStoppedRequest) Reset()
func (*UpdatePipelineStoppedRequest) String ¶ added in v1.2.0
func (m *UpdatePipelineStoppedRequest) String() string
type WaitJobResponse ¶ added in v1.2.4
type WaitJobResponse struct {
State pps.JobState `protobuf:"varint,1,opt,name=state,proto3,enum=pps.JobState" json:"state,omitempty"`
}
func (*WaitJobResponse) Descriptor ¶ added in v1.2.4
func (*WaitJobResponse) Descriptor() ([]byte, []int)
func (*WaitJobResponse) GetState ¶ added in v1.3.5
func (m *WaitJobResponse) GetState() pps.JobState
func (*WaitJobResponse) ProtoMessage ¶ added in v1.2.4
func (*WaitJobResponse) ProtoMessage()
func (*WaitJobResponse) Reset ¶ added in v1.2.4
func (m *WaitJobResponse) Reset()
func (*WaitJobResponse) String ¶ added in v1.2.4
func (m *WaitJobResponse) String() string
Click to show internal directories.
Click to hide internal directories.