pps

package
v1.3.11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 2, 2017 License: Apache-2.0 Imports: 10 Imported by: 0

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

Constants

View Source 
const (
	// JobDataPath specifies ephemereal storage on the host for job data.
	JobDataPath = "/var/pachyderm/job-data"
)

Variables

This section is empty.

Functions

func JobRepo 

func JobRepo(job *ppsclient.Job) *pfs.Repo

JobRepo creates a pfs repo for a given job.

func PipelineRepo 

func PipelineRepo(pipeline *ppsclient.Pipeline) *pfs.Repo

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,proto3" json:"chunk_id,omitempty"`
	PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
}

func (*ContinuePodRequest) Descriptor added in v1.2.4 

func (*ContinuePodRequest) Descriptor() ([]byte, []int)

func (*ContinuePodRequest) GetChunkID added in v1.3.5 

func (m *ContinuePodRequest) GetChunkID() string

func (*ContinuePodRequest) GetPodName added in v1.3.5 

func (m *ContinuePodRequest) GetPodName() string

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 restart is true, the pod is expected to abandon its work and exit
	// with a non-zero code, so k8s knows to reschedule the pod.
	// This happens if the chunk that the pod is working on has been assigned
	// to another pod, or if the lease on this chunk has expired.
	Restart bool `protobuf:"varint,1,opt,name=restart,proto3" json:"restart,omitempty"`
}

func (*ContinuePodResponse) Descriptor added in v1.2.4 

func (*ContinuePodResponse) Descriptor() ([]byte, []int)

func (*ContinuePodResponse) GetRestart added in v1.3.5 

func (m *ContinuePodResponse) GetRestart() bool

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,proto3" json:"chunk_id,omitempty"`
	PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	Success bool   `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
}

func (*FinishPodRequest) Descriptor added in v1.2.4 

func (*FinishPodRequest) Descriptor() ([]byte, []int)

func (*FinishPodRequest) GetChunkID added in v1.3.5 

func (m *FinishPodRequest) GetChunkID() string

func (*FinishPodRequest) GetPodName added in v1.3.5 

func (m *FinishPodRequest) GetPodName() string

func (*FinishPodRequest) GetSuccess added in v1.3.5 

func (m *FinishPodRequest) GetSuccess() bool

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 restart is true, the pod is expected to exit with a non-zero code
	// so that k8s knows to reschedule the pod.
	Restart bool `protobuf:"varint,1,opt,name=restart,proto3" json:"restart,omitempty"`
}

func (*FinishPodResponse) Descriptor added in v1.2.4 

func (*FinishPodResponse) Descriptor() ([]byte, []int)

func (*FinishPodResponse) GetRestart added in v1.3.5 

func (m *FinishPodResponse) GetRestart() bool

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 

type Hasher struct {
	JobModulus      uint64
	PipelineModulus uint64
}

A Hasher represents a job/pipeline hasher.

func NewHasher 

func NewHasher(jobModulus uint64, pipelineModulus uint64) *Hasher

NewHasher creates a hasher.

func (*Hasher) HashJob 

func (s *Hasher) HashJob(job *ppsclient.Job) uint64

HashJob computes and returns a hash of a job.

func (*Hasher) HashPipeline 

func (s *Hasher) HashPipeline(pipeline *ppsclient.Pipeline) uint64

HashPipeline computes and returns a hash of a pipeline.

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,proto3" 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) GetPodName added in v1.3.5 

func (m *StartPodRequest) GetPodName() string

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,proto3" 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) GetChunkID added in v1.3.5 

func (m *StartPodResponse) GetChunkID() string

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

Source Files

View all Source files

Directories

Path Synopsis
Package persist is a generated protocol buffer package.
 Package persist is a generated protocol buffer package.
server
server/testing

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.