Documentation ¶
Overview ¶
Package pps is a generated protocol buffer package.
It is generated from these files:
server/pps/pps.proto
It has these top-level messages:
StartPodRequest StartPodResponse FinishPodRequest FinishPodResponse ContinuePodRequest ContinuePodResponse
Index ¶
- func JobRepo(job *ppsclient.Job) *pfs.Repo
- func PipelineRepo(pipeline *ppsclient.Pipeline) *pfs.Repo
- func RegisterInternalPodAPIServer(s *grpc.Server, srv InternalPodAPIServer)
- type ContinuePodRequest
- type ContinuePodResponse
- type FinishPodRequest
- type FinishPodResponse
- type Hasher
- type InternalPodAPIClient
- type InternalPodAPIServer
- type StartPodRequest
- type StartPodResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PipelineRepo ¶
PipelineRepo creates a pfs repo for a given pipeline.
func RegisterInternalPodAPIServer ¶ added in v1.2.4
func RegisterInternalPodAPIServer(s *grpc.Server, srv InternalPodAPIServer)
Types ¶
type ContinuePodRequest ¶ added in v1.2.4
type ContinuePodRequest struct { ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId" json:"chunk_id,omitempty"` PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName" json:"pod_name,omitempty"` }
func (*ContinuePodRequest) Descriptor ¶ added in v1.2.4
func (*ContinuePodRequest) Descriptor() ([]byte, []int)
func (*ContinuePodRequest) ProtoMessage ¶ added in v1.2.4
func (*ContinuePodRequest) ProtoMessage()
func (*ContinuePodRequest) Reset ¶ added in v1.2.4
func (m *ContinuePodRequest) Reset()
func (*ContinuePodRequest) String ¶ added in v1.2.4
func (m *ContinuePodRequest) String() string
type ContinuePodResponse ¶ added in v1.2.4
type ContinuePodResponse struct { // if exit is true, the pod is expected to abandon its work and exit. // this happens if the chunk that the pod is working on has been assigned // to another pod. Exit bool `protobuf:"varint,1,opt,name=exit" json:"exit,omitempty"` }
func (*ContinuePodResponse) Descriptor ¶ added in v1.2.4
func (*ContinuePodResponse) Descriptor() ([]byte, []int)
func (*ContinuePodResponse) ProtoMessage ¶ added in v1.2.4
func (*ContinuePodResponse) ProtoMessage()
func (*ContinuePodResponse) Reset ¶ added in v1.2.4
func (m *ContinuePodResponse) Reset()
func (*ContinuePodResponse) String ¶ added in v1.2.4
func (m *ContinuePodResponse) String() string
type FinishPodRequest ¶ added in v1.2.4
type FinishPodRequest struct { ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId" json:"chunk_id,omitempty"` PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName" json:"pod_name,omitempty"` Success bool `protobuf:"varint,3,opt,name=success" json:"success,omitempty"` }
func (*FinishPodRequest) Descriptor ¶ added in v1.2.4
func (*FinishPodRequest) Descriptor() ([]byte, []int)
func (*FinishPodRequest) ProtoMessage ¶ added in v1.2.4
func (*FinishPodRequest) ProtoMessage()
func (*FinishPodRequest) Reset ¶ added in v1.2.4
func (m *FinishPodRequest) Reset()
func (*FinishPodRequest) String ¶ added in v1.2.4
func (m *FinishPodRequest) String() string
type FinishPodResponse ¶ added in v1.2.4
type FinishPodResponse struct { // If fail is true, the pod is expected to exit with a non-zero code // so that k8s knows to reschedule the pod. Fail bool `protobuf:"varint,1,opt,name=fail" json:"fail,omitempty"` }
func (*FinishPodResponse) Descriptor ¶ added in v1.2.4
func (*FinishPodResponse) Descriptor() ([]byte, []int)
func (*FinishPodResponse) ProtoMessage ¶ added in v1.2.4
func (*FinishPodResponse) ProtoMessage()
func (*FinishPodResponse) Reset ¶ added in v1.2.4
func (m *FinishPodResponse) Reset()
func (*FinishPodResponse) String ¶ added in v1.2.4
func (m *FinishPodResponse) String() string
type Hasher ¶
A Hasher represents a job/pipeline hasher.
type InternalPodAPIClient ¶ added in v1.2.4
type InternalPodAPIClient interface { StartPod(ctx context.Context, in *StartPodRequest, opts ...grpc.CallOption) (*StartPodResponse, error) ContinuePod(ctx context.Context, in *ContinuePodRequest, opts ...grpc.CallOption) (*ContinuePodResponse, error) FinishPod(ctx context.Context, in *FinishPodRequest, opts ...grpc.CallOption) (*FinishPodResponse, error) }
func NewInternalPodAPIClient ¶ added in v1.2.4
func NewInternalPodAPIClient(cc *grpc.ClientConn) InternalPodAPIClient
func NewInternalPodAPIClientFromAddress ¶ added in v1.2.4
func NewInternalPodAPIClientFromAddress(pachAddr string) (InternalPodAPIClient, error)
NewInternalPodAPIClientFromAddress creates an InternalPodAPIClient connecting to pachd at pachAddr.
type InternalPodAPIServer ¶ added in v1.2.4
type InternalPodAPIServer interface { StartPod(context.Context, *StartPodRequest) (*StartPodResponse, error) ContinuePod(context.Context, *ContinuePodRequest) (*ContinuePodResponse, error) FinishPod(context.Context, *FinishPodRequest) (*FinishPodResponse, error) }
type StartPodRequest ¶ added in v1.2.4
type StartPodRequest struct { Job *pps1.Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"` PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName" json:"pod_name,omitempty"` }
func (*StartPodRequest) Descriptor ¶ added in v1.2.4
func (*StartPodRequest) Descriptor() ([]byte, []int)
func (*StartPodRequest) GetJob ¶ added in v1.2.4
func (m *StartPodRequest) GetJob() *pps1.Job
func (*StartPodRequest) ProtoMessage ¶ added in v1.2.4
func (*StartPodRequest) ProtoMessage()
func (*StartPodRequest) Reset ¶ added in v1.2.4
func (m *StartPodRequest) Reset()
func (*StartPodRequest) String ¶ added in v1.2.4
func (m *StartPodRequest) String() string
type StartPodResponse ¶ added in v1.2.4
type StartPodResponse struct { ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId" json:"chunk_id,omitempty"` Transform *pps1.Transform `protobuf:"bytes,2,opt,name=transform" json:"transform,omitempty"` CommitMounts []*fuse.CommitMount `protobuf:"bytes,3,rep,name=commit_mounts,json=commitMounts" json:"commit_mounts,omitempty"` }
func (*StartPodResponse) Descriptor ¶ added in v1.2.4
func (*StartPodResponse) Descriptor() ([]byte, []int)
func (*StartPodResponse) GetCommitMounts ¶ added in v1.2.4
func (m *StartPodResponse) GetCommitMounts() []*fuse.CommitMount
func (*StartPodResponse) GetTransform ¶ added in v1.2.4
func (m *StartPodResponse) GetTransform() *pps1.Transform
func (*StartPodResponse) ProtoMessage ¶ added in v1.2.4
func (*StartPodResponse) ProtoMessage()
func (*StartPodResponse) Reset ¶ added in v1.2.4
func (m *StartPodResponse) Reset()
func (*StartPodResponse) String ¶ added in v1.2.4
func (m *StartPodResponse) String() string
Click to show internal directories.
Click to hide internal directories.