persist.pb.go

// Code generated by protoc-gen-gogo.
// source: server/pps/persist/persist.proto
// DO NOT EDIT!

/*
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
*/
package persist

import proto "github.com/gogo/protobuf/proto"
import fmt "fmt"
import math "math"
import google_protobuf "github.com/gogo/protobuf/types"
import google_protobuf1 "github.com/gogo/protobuf/types"
import _ "github.com/gogo/protobuf/gogoproto"
import pfs "github.com/pachyderm/pachyderm/src/client/pfs"
import pps "github.com/pachyderm/pachyderm/src/client/pps"

import (
	context "golang.org/x/net/context"
	grpc "google.golang.org/grpc"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package

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
)

var ChunkState_name = map[int32]string{
	0: "UNASSIGNED",
	1: "ASSIGNED",
	2: "SUCCESS",
	3: "FAILED",
	4: "SPLITTED",
}
var ChunkState_value = map[string]int32{
	"UNASSIGNED": 0,
	"ASSIGNED":   1,
	"SUCCESS":    2,
	"FAILED":     3,
	"SPLITTED":   4,
}

func (x ChunkState) String() string {
	return proto.EnumName(ChunkState_name, int32(x))
}
func (ChunkState) EnumDescriptor() ([]byte, []int) { return fileDescriptorPersist, []int{0} }

type ChangeType int32

const (
	ChangeType_CREATE ChangeType = 0
	ChangeType_UPDATE ChangeType = 1
	ChangeType_DELETE ChangeType = 2
)

var ChangeType_name = map[int32]string{
	0: "CREATE",
	1: "UPDATE",
	2: "DELETE",
}
var ChangeType_value = map[string]int32{
	"CREATE": 0,
	"UPDATE": 1,
	"DELETE": 2,
}

func (x ChangeType) String() string {
	return proto.EnumName(ChangeType_name, int32(x))
}
func (ChangeType) EnumDescriptor() ([]byte, []int) { return fileDescriptorPersist, []int{1} }

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 (m *JobInfo) Reset()                    { *m = JobInfo{} }
func (m *JobInfo) String() string            { return proto.CompactTextString(m) }
func (*JobInfo) ProtoMessage()               {}
func (*JobInfo) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{0} }

func (m *JobInfo) GetJobID() string {
	if m != nil {
		return m.JobID
	}
	return ""
}

func (m *JobInfo) GetTransform() *pps.Transform {
	if m != nil {
		return m.Transform
	}
	return nil
}

func (m *JobInfo) GetPipelineName() string {
	if m != nil {
		return m.PipelineName
	}
	return ""
}

func (m *JobInfo) GetPipelineVersion() uint64 {
	if m != nil {
		return m.PipelineVersion
	}
	return 0
}

func (m *JobInfo) GetParallelismSpec() *pps.ParallelismSpec {
	if m != nil {
		return m.ParallelismSpec
	}
	return nil
}

func (m *JobInfo) GetInputs() []*pps.JobInput {
	if m != nil {
		return m.Inputs
	}
	return nil
}

func (m *JobInfo) GetParentJob() *pps.Job {
	if m != nil {
		return m.ParentJob
	}
	return nil
}

func (m *JobInfo) GetStarted() *google_protobuf1.Timestamp {
	if m != nil {
		return m.Started
	}
	return nil
}

func (m *JobInfo) GetFinished() *google_protobuf1.Timestamp {
	if m != nil {
		return m.Finished
	}
	return nil
}

func (m *JobInfo) GetOutputCommit() *pfs.Commit {
	if m != nil {
		return m.OutputCommit
	}
	return nil
}

func (m *JobInfo) GetBranch() string {
	if m != nil {
		return m.Branch
	}
	return ""
}

func (m *JobInfo) GetState() pps.JobState {
	if m != nil {
		return m.State
	}
	return pps.JobState_JOB_CREATING
}

func (m *JobInfo) GetCommitIndex() string {
	if m != nil {
		return m.CommitIndex
	}
	return ""
}

func (m *JobInfo) GetDefaultShardModuli() []uint64 {
	if m != nil {
		return m.DefaultShardModuli
	}
	return nil
}

func (m *JobInfo) GetShard() uint64 {
	if m != nil {
		return m.Shard
	}
	return 0
}

func (m *JobInfo) GetGc() bool {
	if m != nil {
		return m.Gc
	}
	return false
}

func (m *JobInfo) GetService() *pps.Service {
	if m != nil {
		return m.Service
	}
	return nil
}

func (m *JobInfo) GetOutput() *pps.Output {
	if m != nil {
		return m.Output
	}
	return nil
}

func (m *JobInfo) GetResources() *pps.Resources {
	if m != nil {
		return m.Resources
	}
	return nil
}

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 (m *Pod) Reset()                    { *m = Pod{} }
func (m *Pod) String() string            { return proto.CompactTextString(m) }
func (*Pod) ProtoMessage()               {}
func (*Pod) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{1} }

func (m *Pod) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *Pod) GetOutputCommit() *pfs.Commit {
	if m != nil {
		return m.OutputCommit
	}
	return nil
}

// Chunk is a unit of work that can be assigned to a pod
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"`
}

func (m *Chunk) Reset()                    { *m = Chunk{} }
func (m *Chunk) String() string            { return proto.CompactTextString(m) }
func (*Chunk) ProtoMessage()               {}
func (*Chunk) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{2} }

func (m *Chunk) GetID() string {
	if m != nil {
		return m.ID
	}
	return ""
}

func (m *Chunk) GetJobID() string {
	if m != nil {
		return m.JobID
	}
	return ""
}

func (m *Chunk) GetModuli() []uint64 {
	if m != nil {
		return m.Moduli
	}
	return nil
}

func (m *Chunk) GetIndex() uint64 {
	if m != nil {
		return m.Index
	}
	return 0
}

func (m *Chunk) GetOwner() string {
	if m != nil {
		return m.Owner
	}
	return ""
}

func (m *Chunk) GetPods() []*Pod {
	if m != nil {
		return m.Pods
	}
	return nil
}

func (m *Chunk) GetState() ChunkState {
	if m != nil {
		return m.State
	}
	return ChunkState_UNASSIGNED
}

func (m *Chunk) GetLeaseTime() uint64 {
	if m != nil {
		return m.LeaseTime
	}
	return 0
}

type Chunks struct {
	Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks" json:"chunks,omitempty"`
}

func (m *Chunks) Reset()                    { *m = Chunks{} }
func (m *Chunks) String() string            { return proto.CompactTextString(m) }
func (*Chunks) ProtoMessage()               {}
func (*Chunks) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{3} }

func (m *Chunks) GetChunks() []*Chunk {
	if m != nil {
		return m.Chunks
	}
	return nil
}

type JobInfos struct {
	JobInfo []*JobInfo `protobuf:"bytes,1,rep,name=job_info,json=jobInfo" json:"job_info,omitempty"`
}

func (m *JobInfos) Reset()                    { *m = JobInfos{} }
func (m *JobInfos) String() string            { return proto.CompactTextString(m) }
func (*JobInfos) ProtoMessage()               {}
func (*JobInfos) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{4} }

func (m *JobInfos) GetJobInfo() []*JobInfo {
	if m != nil {
		return m.JobInfo
	}
	return nil
}

type JobIDs struct {
	Jobs []string `protobuf:"bytes,1,rep,name=jobs" json:"jobs,omitempty"`
}

func (m *JobIDs) Reset()                    { *m = JobIDs{} }
func (m *JobIDs) String() string            { return proto.CompactTextString(m) }
func (*JobIDs) ProtoMessage()               {}
func (*JobIDs) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{5} }

func (m *JobIDs) GetJobs() []string {
	if m != nil {
		return m.Jobs
	}
	return nil
}

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 (m *JobOutput) Reset()                    { *m = JobOutput{} }
func (m *JobOutput) String() string            { return proto.CompactTextString(m) }
func (*JobOutput) ProtoMessage()               {}
func (*JobOutput) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{6} }

func (m *JobOutput) GetJobID() string {
	if m != nil {
		return m.JobID
	}
	return ""
}

func (m *JobOutput) GetOutputCommit() *pfs.Commit {
	if m != nil {
		return m.OutputCommit
	}
	return nil
}

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 (m *JobState) Reset()                    { *m = JobState{} }
func (m *JobState) String() string            { return proto.CompactTextString(m) }
func (*JobState) ProtoMessage()               {}
func (*JobState) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{7} }

func (m *JobState) GetJobID() string {
	if m != nil {
		return m.JobID
	}
	return ""
}

func (m *JobState) GetState() pps.JobState {
	if m != nil {
		return m.State
	}
	return pps.JobState_JOB_CREATING
}

func (m *JobState) GetFinished() *google_protobuf1.Timestamp {
	if m != nil {
		return m.Finished
	}
	return nil
}

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 (m *AddOutputCommitRequest) Reset()                    { *m = AddOutputCommitRequest{} }
func (m *AddOutputCommitRequest) String() string            { return proto.CompactTextString(m) }
func (*AddOutputCommitRequest) ProtoMessage()               {}
func (*AddOutputCommitRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{8} }

func (m *AddOutputCommitRequest) GetJobID() string {
	if m != nil {
		return m.JobID
	}
	return ""
}

func (m *AddOutputCommitRequest) GetCommit() *pfs.Commit {
	if m != nil {
		return m.Commit
	}
	return nil
}

func (m *AddOutputCommitRequest) GetBranch() string {
	if m != nil {
		return m.Branch
	}
	return ""
}

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             `protobuf:"bytes,10,rep,name=job_counts,json=jobCounts" json:"job_counts,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
	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 (m *PipelineInfo) Reset()                    { *m = PipelineInfo{} }
func (m *PipelineInfo) String() string            { return proto.CompactTextString(m) }
func (*PipelineInfo) ProtoMessage()               {}
func (*PipelineInfo) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{9} }

func (m *PipelineInfo) GetPipelineName() string {
	if m != nil {
		return m.PipelineName
	}
	return ""
}

func (m *PipelineInfo) GetVersion() uint64 {
	if m != nil {
		return m.Version
	}
	return 0
}

func (m *PipelineInfo) GetTransform() *pps.Transform {
	if m != nil {
		return m.Transform
	}
	return nil
}

func (m *PipelineInfo) GetParallelismSpec() *pps.ParallelismSpec {
	if m != nil {
		return m.ParallelismSpec
	}
	return nil
}

func (m *PipelineInfo) GetInputs() []*pps.PipelineInput {
	if m != nil {
		return m.Inputs
	}
	return nil
}

func (m *PipelineInfo) GetOutputRepo() *pfs.Repo {
	if m != nil {
		return m.OutputRepo
	}
	return nil
}

func (m *PipelineInfo) GetCreatedAt() *google_protobuf1.Timestamp {
	if m != nil {
		return m.CreatedAt
	}
	return nil
}

func (m *PipelineInfo) GetShard() uint64 {
	if m != nil {
		return m.Shard
	}
	return 0
}

func (m *PipelineInfo) GetState() pps.PipelineState {
	if m != nil {
		return m.State
	}
	return pps.PipelineState_PIPELINE_IDLE
}

func (m *PipelineInfo) GetRecentError() string {
	if m != nil {
		return m.RecentError
	}
	return ""
}

func (m *PipelineInfo) GetJobCounts() map[int32]int32 {
	if m != nil {
		return m.JobCounts
	}
	return nil
}

func (m *PipelineInfo) GetStopped() bool {
	if m != nil {
		return m.Stopped
	}
	return false
}

func (m *PipelineInfo) GetGcPolicy() *pps.GCPolicy {
	if m != nil {
		return m.GcPolicy
	}
	return nil
}

func (m *PipelineInfo) GetOutput() *pps.Output {
	if m != nil {
		return m.Output
	}
	return nil
}

func (m *PipelineInfo) GetResources() *pps.Resources {
	if m != nil {
		return m.Resources
	}
	return nil
}

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 (m *PipelineInfoChange) Reset()                    { *m = PipelineInfoChange{} }
func (m *PipelineInfoChange) String() string            { return proto.CompactTextString(m) }
func (*PipelineInfoChange) ProtoMessage()               {}
func (*PipelineInfoChange) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{10} }

func (m *PipelineInfoChange) GetPipeline() *PipelineInfo {
	if m != nil {
		return m.Pipeline
	}
	return nil
}

func (m *PipelineInfoChange) GetType() ChangeType {
	if m != nil {
		return m.Type
	}
	return ChangeType_CREATE
}

type PipelineInfos struct {
	PipelineInfo []*PipelineInfo `protobuf:"bytes,1,rep,name=pipeline_info,json=pipelineInfo" json:"pipeline_info,omitempty"`
}

func (m *PipelineInfos) Reset()                    { *m = PipelineInfos{} }
func (m *PipelineInfos) String() string            { return proto.CompactTextString(m) }
func (*PipelineInfos) ProtoMessage()               {}
func (*PipelineInfos) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{11} }

func (m *PipelineInfos) GetPipelineInfo() []*PipelineInfo {
	if m != nil {
		return m.PipelineInfo
	}
	return nil
}

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 (m *SubscribePipelineInfosRequest) Reset()         { *m = SubscribePipelineInfosRequest{} }
func (m *SubscribePipelineInfosRequest) String() string { return proto.CompactTextString(m) }
func (*SubscribePipelineInfosRequest) ProtoMessage()    {}
func (*SubscribePipelineInfosRequest) Descriptor() ([]byte, []int) {
	return fileDescriptorPersist, []int{12}
}

func (m *SubscribePipelineInfosRequest) GetIncludeInitial() bool {
	if m != nil {
		return m.IncludeInitial
	}
	return false
}

func (m *SubscribePipelineInfosRequest) GetShard() *Shard {
	if m != nil {
		return m.Shard
	}
	return nil
}

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 (m *SubscribeJobInfosRequest) Reset()                    { *m = SubscribeJobInfosRequest{} }
func (m *SubscribeJobInfosRequest) String() string            { return proto.CompactTextString(m) }
func (*SubscribeJobInfosRequest) ProtoMessage()               {}
func (*SubscribeJobInfosRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{13} }

func (m *SubscribeJobInfosRequest) GetIncludeInitial() bool {
	if m != nil {
		return m.IncludeInitial
	}
	return false
}

func (m *SubscribeJobInfosRequest) GetIncludeChanges() bool {
	if m != nil {
		return m.IncludeChanges
	}
	return false
}

func (m *SubscribeJobInfosRequest) GetShard() *Shard {
	if m != nil {
		return m.Shard
	}
	return nil
}

func (m *SubscribeJobInfosRequest) GetState() []pps.JobState {
	if m != nil {
		return m.State
	}
	return nil
}

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 (m *JobInfoChange) Reset()                    { *m = JobInfoChange{} }
func (m *JobInfoChange) String() string            { return proto.CompactTextString(m) }
func (*JobInfoChange) ProtoMessage()               {}
func (*JobInfoChange) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{14} }

func (m *JobInfoChange) GetJobInfo() *JobInfo {
	if m != nil {
		return m.JobInfo
	}
	return nil
}

func (m *JobInfoChange) GetType() ChangeType {
	if m != nil {
		return m.Type
	}
	return ChangeType_CREATE
}

type ListPipelineInfosRequest struct {
	Shard *Shard `protobuf:"bytes,1,opt,name=shard" json:"shard,omitempty"`
}

func (m *ListPipelineInfosRequest) Reset()                    { *m = ListPipelineInfosRequest{} }
func (m *ListPipelineInfosRequest) String() string            { return proto.CompactTextString(m) }
func (*ListPipelineInfosRequest) ProtoMessage()               {}
func (*ListPipelineInfosRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{15} }

func (m *ListPipelineInfosRequest) GetShard() *Shard {
	if m != nil {
		return m.Shard
	}
	return nil
}

type Shard struct {
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
}

func (m *Shard) Reset()                    { *m = Shard{} }
func (m *Shard) String() string            { return proto.CompactTextString(m) }
func (*Shard) ProtoMessage()               {}
func (*Shard) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{16} }

func (m *Shard) GetNumber() uint64 {
	if m != nil {
		return m.Number
	}
	return 0
}

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 (m *UpdatePipelineStateRequest) Reset()         { *m = UpdatePipelineStateRequest{} }
func (m *UpdatePipelineStateRequest) String() string { return proto.CompactTextString(m) }
func (*UpdatePipelineStateRequest) ProtoMessage()    {}
func (*UpdatePipelineStateRequest) Descriptor() ([]byte, []int) {
	return fileDescriptorPersist, []int{17}
}

func (m *UpdatePipelineStateRequest) GetPipelineName() string {
	if m != nil {
		return m.PipelineName
	}
	return ""
}

func (m *UpdatePipelineStateRequest) GetState() pps.PipelineState {
	if m != nil {
		return m.State
	}
	return pps.PipelineState_PIPELINE_IDLE
}

func (m *UpdatePipelineStateRequest) GetRecentError() string {
	if m != nil {
		return m.RecentError
	}
	return ""
}

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 (m *UpdatePipelineStoppedRequest) Reset()         { *m = UpdatePipelineStoppedRequest{} }
func (m *UpdatePipelineStoppedRequest) String() string { return proto.CompactTextString(m) }
func (*UpdatePipelineStoppedRequest) ProtoMessage()    {}
func (*UpdatePipelineStoppedRequest) Descriptor() ([]byte, []int) {
	return fileDescriptorPersist, []int{18}
}

func (m *UpdatePipelineStoppedRequest) GetPipelineName() string {
	if m != nil {
		return m.PipelineName
	}
	return ""
}

func (m *UpdatePipelineStoppedRequest) GetStopped() bool {
	if m != nil {
		return m.Stopped
	}
	return false
}

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 (m *BlockPipelineStateRequest) Reset()         { *m = BlockPipelineStateRequest{} }
func (m *BlockPipelineStateRequest) String() string { return proto.CompactTextString(m) }
func (*BlockPipelineStateRequest) ProtoMessage()    {}
func (*BlockPipelineStateRequest) Descriptor() ([]byte, []int) {
	return fileDescriptorPersist, []int{19}
}

func (m *BlockPipelineStateRequest) GetPipelineName() string {
	if m != nil {
		return m.PipelineName
	}
	return ""
}

func (m *BlockPipelineStateRequest) GetState() pps.PipelineState {
	if m != nil {
		return m.State
	}
	return pps.PipelineState_PIPELINE_IDLE
}

type AddChunkRequest struct {
	Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks" json:"chunks,omitempty"`
}

func (m *AddChunkRequest) Reset()                    { *m = AddChunkRequest{} }
func (m *AddChunkRequest) String() string            { return proto.CompactTextString(m) }
func (*AddChunkRequest) ProtoMessage()               {}
func (*AddChunkRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{20} }

func (m *AddChunkRequest) GetChunks() []*Chunk {
	if m != nil {
		return m.Chunks
	}
	return nil
}

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 (m *ClaimChunkRequest) Reset()                    { *m = ClaimChunkRequest{} }
func (m *ClaimChunkRequest) String() string            { return proto.CompactTextString(m) }
func (*ClaimChunkRequest) ProtoMessage()               {}
func (*ClaimChunkRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{21} }

func (m *ClaimChunkRequest) GetJobID() string {
	if m != nil {
		return m.JobID
	}
	return ""
}

func (m *ClaimChunkRequest) GetPod() *Pod {
	if m != nil {
		return m.Pod
	}
	return nil
}

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 (m *RenewChunkRequest) Reset()                    { *m = RenewChunkRequest{} }
func (m *RenewChunkRequest) String() string            { return proto.CompactTextString(m) }
func (*RenewChunkRequest) ProtoMessage()               {}
func (*RenewChunkRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{22} }

func (m *RenewChunkRequest) GetChunkID() string {
	if m != nil {
		return m.ChunkID
	}
	return ""
}

func (m *RenewChunkRequest) GetPodName() string {
	if m != nil {
		return m.PodName
	}
	return ""
}

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 (m *FinishChunkRequest) Reset()                    { *m = FinishChunkRequest{} }
func (m *FinishChunkRequest) String() string            { return proto.CompactTextString(m) }
func (*FinishChunkRequest) ProtoMessage()               {}
func (*FinishChunkRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{23} }

func (m *FinishChunkRequest) GetChunkID() string {
	if m != nil {
		return m.ChunkID
	}
	return ""
}

func (m *FinishChunkRequest) GetPodName() string {
	if m != nil {
		return m.PodName
	}
	return ""
}

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 (m *RevokeChunkRequest) Reset()                    { *m = RevokeChunkRequest{} }
func (m *RevokeChunkRequest) String() string            { return proto.CompactTextString(m) }
func (*RevokeChunkRequest) ProtoMessage()               {}
func (*RevokeChunkRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{24} }

func (m *RevokeChunkRequest) GetChunkID() string {
	if m != nil {
		return m.ChunkID
	}
	return ""
}

func (m *RevokeChunkRequest) GetPodName() string {
	if m != nil {
		return m.PodName
	}
	return ""
}

func (m *RevokeChunkRequest) GetMaxPods() uint64 {
	if m != nil {
		return m.MaxPods
	}
	return 0
}

type WaitJobResponse struct {
	State pps.JobState `protobuf:"varint,1,opt,name=state,proto3,enum=pps.JobState" json:"state,omitempty"`
}

func (m *WaitJobResponse) Reset()                    { *m = WaitJobResponse{} }
func (m *WaitJobResponse) String() string            { return proto.CompactTextString(m) }
func (*WaitJobResponse) ProtoMessage()               {}
func (*WaitJobResponse) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{25} }

func (m *WaitJobResponse) GetState() pps.JobState {
	if m != nil {
		return m.State
	}
	return pps.JobState_JOB_CREATING
}

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 (m *ChunkChange) Reset()                    { *m = ChunkChange{} }
func (m *ChunkChange) String() string            { return proto.CompactTextString(m) }
func (*ChunkChange) ProtoMessage()               {}
func (*ChunkChange) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{26} }

func (m *ChunkChange) GetChunk() *Chunk {
	if m != nil {
		return m.Chunk
	}
	return nil
}

func (m *ChunkChange) GetType() ChangeType {
	if m != nil {
		return m.Type
	}
	return ChangeType_CREATE
}

func (m *ChunkChange) GetReady() bool {
	if m != nil {
		return m.Ready
	}
	return false
}

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 (m *SubscribeChunksRequest) Reset()                    { *m = SubscribeChunksRequest{} }
func (m *SubscribeChunksRequest) String() string            { return proto.CompactTextString(m) }
func (*SubscribeChunksRequest) ProtoMessage()               {}
func (*SubscribeChunksRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{27} }

func (m *SubscribeChunksRequest) GetJob() *pps.Job {
	if m != nil {
		return m.Job
	}
	return nil
}

func (m *SubscribeChunksRequest) GetIncludeInitial() bool {
	if m != nil {
		return m.IncludeInitial
	}
	return false
}

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 (m *ListGCJobsRequest) Reset()                    { *m = ListGCJobsRequest{} }
func (m *ListGCJobsRequest) String() string            { return proto.CompactTextString(m) }
func (*ListGCJobsRequest) ProtoMessage()               {}
func (*ListGCJobsRequest) Descriptor() ([]byte, []int) { return fileDescriptorPersist, []int{28} }

func (m *ListGCJobsRequest) GetPipelineName() string {
	if m != nil {
		return m.PipelineName
	}
	return ""
}

func (m *ListGCJobsRequest) GetGcPolicy() *pps.GCPolicy {
	if m != nil {
		return m.GcPolicy
	}
	return nil
}

func init() {
	proto.RegisterType((*JobInfo)(nil), "pps.persist.JobInfo")
	proto.RegisterType((*Pod)(nil), "pps.persist.Pod")
	proto.RegisterType((*Chunk)(nil), "pps.persist.Chunk")
	proto.RegisterType((*Chunks)(nil), "pps.persist.Chunks")
	proto.RegisterType((*JobInfos)(nil), "pps.persist.JobInfos")
	proto.RegisterType((*JobIDs)(nil), "pps.persist.JobIDs")
	proto.RegisterType((*JobOutput)(nil), "pps.persist.JobOutput")
	proto.RegisterType((*JobState)(nil), "pps.persist.JobState")
	proto.RegisterType((*AddOutputCommitRequest)(nil), "pps.persist.AddOutputCommitRequest")
	proto.RegisterType((*PipelineInfo)(nil), "pps.persist.PipelineInfo")
	proto.RegisterType((*PipelineInfoChange)(nil), "pps.persist.PipelineInfoChange")
	proto.RegisterType((*PipelineInfos)(nil), "pps.persist.PipelineInfos")
	proto.RegisterType((*SubscribePipelineInfosRequest)(nil), "pps.persist.SubscribePipelineInfosRequest")
	proto.RegisterType((*SubscribeJobInfosRequest)(nil), "pps.persist.SubscribeJobInfosRequest")
	proto.RegisterType((*JobInfoChange)(nil), "pps.persist.JobInfoChange")
	proto.RegisterType((*ListPipelineInfosRequest)(nil), "pps.persist.ListPipelineInfosRequest")
	proto.RegisterType((*Shard)(nil), "pps.persist.Shard")
	proto.RegisterType((*UpdatePipelineStateRequest)(nil), "pps.persist.UpdatePipelineStateRequest")
	proto.RegisterType((*UpdatePipelineStoppedRequest)(nil), "pps.persist.UpdatePipelineStoppedRequest")
	proto.RegisterType((*BlockPipelineStateRequest)(nil), "pps.persist.BlockPipelineStateRequest")
	proto.RegisterType((*AddChunkRequest)(nil), "pps.persist.AddChunkRequest")
	proto.RegisterType((*ClaimChunkRequest)(nil), "pps.persist.ClaimChunkRequest")
	proto.RegisterType((*RenewChunkRequest)(nil), "pps.persist.RenewChunkRequest")
	proto.RegisterType((*FinishChunkRequest)(nil), "pps.persist.FinishChunkRequest")
	proto.RegisterType((*RevokeChunkRequest)(nil), "pps.persist.RevokeChunkRequest")
	proto.RegisterType((*WaitJobResponse)(nil), "pps.persist.WaitJobResponse")
	proto.RegisterType((*ChunkChange)(nil), "pps.persist.ChunkChange")
	proto.RegisterType((*SubscribeChunksRequest)(nil), "pps.persist.SubscribeChunksRequest")
	proto.RegisterType((*ListGCJobsRequest)(nil), "pps.persist.ListGCJobsRequest")
	proto.RegisterEnum("pps.persist.ChunkState", ChunkState_name, ChunkState_value)
	proto.RegisterEnum("pps.persist.ChangeType", ChangeType_name, ChangeType_value)
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// Client API for API service

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)
}

type aPIClient struct {
	cc *grpc.ClientConn
}

func NewAPIClient(cc *grpc.ClientConn) APIClient {
	return &aPIClient{cc}
}

func (c *aPIClient) CreateJobInfo(ctx context.Context, in *JobInfo, opts ...grpc.CallOption) (*JobInfo, error) {
	out := new(JobInfo)
	err := grpc.Invoke(ctx, "/pps.persist.API/CreateJobInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) InspectJob(ctx context.Context, in *pps.InspectJobRequest, opts ...grpc.CallOption) (*JobInfo, error) {
	out := new(JobInfo)
	err := grpc.Invoke(ctx, "/pps.persist.API/InspectJob", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) ListJobInfos(ctx context.Context, in *pps.ListJobRequest, opts ...grpc.CallOption) (*JobInfos, error) {
	out := new(JobInfos)
	err := grpc.Invoke(ctx, "/pps.persist.API/ListJobInfos", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) DeleteJobInfo(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/DeleteJobInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) DeleteJobInfosForPipeline(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/DeleteJobInfosForPipeline", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) SubscribeJobInfos(ctx context.Context, in *SubscribeJobInfosRequest, opts ...grpc.CallOption) (API_SubscribeJobInfosClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_API_serviceDesc.Streams[0], c.cc, "/pps.persist.API/SubscribeJobInfos", opts...)
	if err != nil {
		return nil, err
	}
	x := &aPISubscribeJobInfosClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type API_SubscribeJobInfosClient interface {
	Recv() (*JobInfoChange, error)
	grpc.ClientStream
}

type aPISubscribeJobInfosClient struct {
	grpc.ClientStream
}

func (x *aPISubscribeJobInfosClient) Recv() (*JobInfoChange, error) {
	m := new(JobInfoChange)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *aPIClient) CreateJobOutput(ctx context.Context, in *JobOutput, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/CreateJobOutput", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) CreateJobState(ctx context.Context, in *JobState, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/CreateJobState", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) StartJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*JobInfo, error) {
	out := new(JobInfo)
	err := grpc.Invoke(ctx, "/pps.persist.API/StartJob", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) ListGCJobs(ctx context.Context, in *ListGCJobsRequest, opts ...grpc.CallOption) (*JobIDs, error) {
	out := new(JobIDs)
	err := grpc.Invoke(ctx, "/pps.persist.API/ListGCJobs", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) GCJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/GCJob", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) CreatePipelineInfo(ctx context.Context, in *PipelineInfo, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/CreatePipelineInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) UpdatePipelineInfo(ctx context.Context, in *PipelineInfo, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/UpdatePipelineInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) TouchPipelineInfo(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/TouchPipelineInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) GetPipelineInfo(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*PipelineInfo, error) {
	out := new(PipelineInfo)
	err := grpc.Invoke(ctx, "/pps.persist.API/GetPipelineInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) ListPipelineInfos(ctx context.Context, in *ListPipelineInfosRequest, opts ...grpc.CallOption) (*PipelineInfos, error) {
	out := new(PipelineInfos)
	err := grpc.Invoke(ctx, "/pps.persist.API/ListPipelineInfos", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) DeletePipelineInfo(ctx context.Context, in *pps.Pipeline, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/DeletePipelineInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) SubscribePipelineInfos(ctx context.Context, in *SubscribePipelineInfosRequest, opts ...grpc.CallOption) (API_SubscribePipelineInfosClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_API_serviceDesc.Streams[1], c.cc, "/pps.persist.API/SubscribePipelineInfos", opts...)
	if err != nil {
		return nil, err
	}
	x := &aPISubscribePipelineInfosClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type API_SubscribePipelineInfosClient interface {
	Recv() (*PipelineInfoChange, error)
	grpc.ClientStream
}

type aPISubscribePipelineInfosClient struct {
	grpc.ClientStream
}

func (x *aPISubscribePipelineInfosClient) Recv() (*PipelineInfoChange, error) {
	m := new(PipelineInfoChange)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *aPIClient) UpdatePipelineState(ctx context.Context, in *UpdatePipelineStateRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/UpdatePipelineState", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) UpdatePipelineStopped(ctx context.Context, in *UpdatePipelineStoppedRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/UpdatePipelineStopped", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) BlockPipelineState(ctx context.Context, in *BlockPipelineStateRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/BlockPipelineState", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) DeleteAll(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/DeleteAll", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) AddChunk(ctx context.Context, in *AddChunkRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/AddChunk", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) ClaimChunk(ctx context.Context, in *ClaimChunkRequest, opts ...grpc.CallOption) (*Chunk, error) {
	out := new(Chunk)
	err := grpc.Invoke(ctx, "/pps.persist.API/ClaimChunk", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) RenewChunk(ctx context.Context, in *RenewChunkRequest, opts ...grpc.CallOption) (*Chunk, error) {
	out := new(Chunk)
	err := grpc.Invoke(ctx, "/pps.persist.API/RenewChunk", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) FinishChunk(ctx context.Context, in *FinishChunkRequest, opts ...grpc.CallOption) (*Chunk, error) {
	out := new(Chunk)
	err := grpc.Invoke(ctx, "/pps.persist.API/FinishChunk", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) RevokeChunk(ctx context.Context, in *RevokeChunkRequest, opts ...grpc.CallOption) (*Chunk, error) {
	out := new(Chunk)
	err := grpc.Invoke(ctx, "/pps.persist.API/RevokeChunk", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) SubscribeChunks(ctx context.Context, in *SubscribeChunksRequest, opts ...grpc.CallOption) (API_SubscribeChunksClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_API_serviceDesc.Streams[2], c.cc, "/pps.persist.API/SubscribeChunks", opts...)
	if err != nil {
		return nil, err
	}
	x := &aPISubscribeChunksClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type API_SubscribeChunksClient interface {
	Recv() (*ChunkChange, error)
	grpc.ClientStream
}

type aPISubscribeChunksClient struct {
	grpc.ClientStream
}

func (x *aPISubscribeChunksClient) Recv() (*ChunkChange, error) {
	m := new(ChunkChange)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *aPIClient) GetChunksForJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*Chunks, error) {
	out := new(Chunks)
	err := grpc.Invoke(ctx, "/pps.persist.API/GetChunksForJob", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *aPIClient) DeleteChunksForJob(ctx context.Context, in *pps.Job, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.persist.API/DeleteChunksForJob", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for API service

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)
}

func RegisterAPIServer(s *grpc.Server, srv APIServer) {
	s.RegisterService(&_API_serviceDesc, srv)
}

func _API_CreateJobInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(JobInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).CreateJobInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/CreateJobInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).CreateJobInfo(ctx, req.(*JobInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_InspectJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.InspectJobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).InspectJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/InspectJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).InspectJob(ctx, req.(*pps.InspectJobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_ListJobInfos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.ListJobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).ListJobInfos(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/ListJobInfos",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).ListJobInfos(ctx, req.(*pps.ListJobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_DeleteJobInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Job)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).DeleteJobInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/DeleteJobInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).DeleteJobInfo(ctx, req.(*pps.Job))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_DeleteJobInfosForPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Pipeline)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).DeleteJobInfosForPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/DeleteJobInfosForPipeline",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).DeleteJobInfosForPipeline(ctx, req.(*pps.Pipeline))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_SubscribeJobInfos_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(SubscribeJobInfosRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(APIServer).SubscribeJobInfos(m, &aPISubscribeJobInfosServer{stream})
}

type API_SubscribeJobInfosServer interface {
	Send(*JobInfoChange) error
	grpc.ServerStream
}

type aPISubscribeJobInfosServer struct {
	grpc.ServerStream
}

func (x *aPISubscribeJobInfosServer) Send(m *JobInfoChange) error {
	return x.ServerStream.SendMsg(m)
}

func _API_CreateJobOutput_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(JobOutput)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).CreateJobOutput(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/CreateJobOutput",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).CreateJobOutput(ctx, req.(*JobOutput))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_CreateJobState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(JobState)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).CreateJobState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/CreateJobState",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).CreateJobState(ctx, req.(*JobState))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_StartJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Job)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).StartJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/StartJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).StartJob(ctx, req.(*pps.Job))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_ListGCJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListGCJobsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).ListGCJobs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/ListGCJobs",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).ListGCJobs(ctx, req.(*ListGCJobsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_GCJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Job)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).GCJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/GCJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).GCJob(ctx, req.(*pps.Job))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_CreatePipelineInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PipelineInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).CreatePipelineInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/CreatePipelineInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).CreatePipelineInfo(ctx, req.(*PipelineInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_UpdatePipelineInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PipelineInfo)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).UpdatePipelineInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/UpdatePipelineInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).UpdatePipelineInfo(ctx, req.(*PipelineInfo))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_TouchPipelineInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Pipeline)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).TouchPipelineInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/TouchPipelineInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).TouchPipelineInfo(ctx, req.(*pps.Pipeline))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_GetPipelineInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Pipeline)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).GetPipelineInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/GetPipelineInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).GetPipelineInfo(ctx, req.(*pps.Pipeline))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_ListPipelineInfos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListPipelineInfosRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).ListPipelineInfos(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/ListPipelineInfos",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).ListPipelineInfos(ctx, req.(*ListPipelineInfosRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_DeletePipelineInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Pipeline)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).DeletePipelineInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/DeletePipelineInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).DeletePipelineInfo(ctx, req.(*pps.Pipeline))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_SubscribePipelineInfos_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(SubscribePipelineInfosRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(APIServer).SubscribePipelineInfos(m, &aPISubscribePipelineInfosServer{stream})
}

type API_SubscribePipelineInfosServer interface {
	Send(*PipelineInfoChange) error
	grpc.ServerStream
}

type aPISubscribePipelineInfosServer struct {
	grpc.ServerStream
}

func (x *aPISubscribePipelineInfosServer) Send(m *PipelineInfoChange) error {
	return x.ServerStream.SendMsg(m)
}

func _API_UpdatePipelineState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdatePipelineStateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).UpdatePipelineState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/UpdatePipelineState",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).UpdatePipelineState(ctx, req.(*UpdatePipelineStateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_UpdatePipelineStopped_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdatePipelineStoppedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).UpdatePipelineStopped(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/UpdatePipelineStopped",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).UpdatePipelineStopped(ctx, req.(*UpdatePipelineStoppedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_BlockPipelineState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BlockPipelineStateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).BlockPipelineState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/BlockPipelineState",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).BlockPipelineState(ctx, req.(*BlockPipelineStateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_DeleteAll_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(google_protobuf.Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).DeleteAll(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/DeleteAll",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).DeleteAll(ctx, req.(*google_protobuf.Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_AddChunk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AddChunkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).AddChunk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/AddChunk",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).AddChunk(ctx, req.(*AddChunkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_ClaimChunk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClaimChunkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).ClaimChunk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/ClaimChunk",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).ClaimChunk(ctx, req.(*ClaimChunkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_RenewChunk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RenewChunkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).RenewChunk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/RenewChunk",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).RenewChunk(ctx, req.(*RenewChunkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_FinishChunk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FinishChunkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).FinishChunk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/FinishChunk",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).FinishChunk(ctx, req.(*FinishChunkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_RevokeChunk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RevokeChunkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).RevokeChunk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/RevokeChunk",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).RevokeChunk(ctx, req.(*RevokeChunkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_SubscribeChunks_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(SubscribeChunksRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(APIServer).SubscribeChunks(m, &aPISubscribeChunksServer{stream})
}

type API_SubscribeChunksServer interface {
	Send(*ChunkChange) error
	grpc.ServerStream
}

type aPISubscribeChunksServer struct {
	grpc.ServerStream
}

func (x *aPISubscribeChunksServer) Send(m *ChunkChange) error {
	return x.ServerStream.SendMsg(m)
}

func _API_GetChunksForJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Job)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).GetChunksForJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/GetChunksForJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).GetChunksForJob(ctx, req.(*pps.Job))
	}
	return interceptor(ctx, in, info, handler)
}

func _API_DeleteChunksForJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(pps.Job)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).DeleteChunksForJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.persist.API/DeleteChunksForJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).DeleteChunksForJob(ctx, req.(*pps.Job))
	}
	return interceptor(ctx, in, info, handler)
}

var _API_serviceDesc = grpc.ServiceDesc{
	ServiceName: "pps.persist.API",
	HandlerType: (*APIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateJobInfo",
			Handler:    _API_CreateJobInfo_Handler,
		},
		{
			MethodName: "InspectJob",
			Handler:    _API_InspectJob_Handler,
		},
		{
			MethodName: "ListJobInfos",
			Handler:    _API_ListJobInfos_Handler,
		},
		{
			MethodName: "DeleteJobInfo",
			Handler:    _API_DeleteJobInfo_Handler,
		},
		{
			MethodName: "DeleteJobInfosForPipeline",
			Handler:    _API_DeleteJobInfosForPipeline_Handler,
		},
		{
			MethodName: "CreateJobOutput",
			Handler:    _API_CreateJobOutput_Handler,
		},
		{
			MethodName: "CreateJobState",
			Handler:    _API_CreateJobState_Handler,
		},
		{
			MethodName: "StartJob",
			Handler:    _API_StartJob_Handler,
		},
		{
			MethodName: "ListGCJobs",
			Handler:    _API_ListGCJobs_Handler,
		},
		{
			MethodName: "GCJob",
			Handler:    _API_GCJob_Handler,
		},
		{
			MethodName: "CreatePipelineInfo",
			Handler:    _API_CreatePipelineInfo_Handler,
		},
		{
			MethodName: "UpdatePipelineInfo",
			Handler:    _API_UpdatePipelineInfo_Handler,
		},
		{
			MethodName: "TouchPipelineInfo",
			Handler:    _API_TouchPipelineInfo_Handler,
		},
		{
			MethodName: "GetPipelineInfo",
			Handler:    _API_GetPipelineInfo_Handler,
		},
		{
			MethodName: "ListPipelineInfos",
			Handler:    _API_ListPipelineInfos_Handler,
		},
		{
			MethodName: "DeletePipelineInfo",
			Handler:    _API_DeletePipelineInfo_Handler,
		},
		{
			MethodName: "UpdatePipelineState",
			Handler:    _API_UpdatePipelineState_Handler,
		},
		{
			MethodName: "UpdatePipelineStopped",
			Handler:    _API_UpdatePipelineStopped_Handler,
		},
		{
			MethodName: "BlockPipelineState",
			Handler:    _API_BlockPipelineState_Handler,
		},
		{
			MethodName: "DeleteAll",
			Handler:    _API_DeleteAll_Handler,
		},
		{
			MethodName: "AddChunk",
			Handler:    _API_AddChunk_Handler,
		},
		{
			MethodName: "ClaimChunk",
			Handler:    _API_ClaimChunk_Handler,
		},
		{
			MethodName: "RenewChunk",
			Handler:    _API_RenewChunk_Handler,
		},
		{
			MethodName: "FinishChunk",
			Handler:    _API_FinishChunk_Handler,
		},
		{
			MethodName: "RevokeChunk",
			Handler:    _API_RevokeChunk_Handler,
		},
		{
			MethodName: "GetChunksForJob",
			Handler:    _API_GetChunksForJob_Handler,
		},
		{
			MethodName: "DeleteChunksForJob",
			Handler:    _API_DeleteChunksForJob_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeJobInfos",
			Handler:       _API_SubscribeJobInfos_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribePipelineInfos",
			Handler:       _API_SubscribePipelineInfos_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeChunks",
			Handler:       _API_SubscribeChunks_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "server/pps/persist/persist.proto",
}

func init() { proto.RegisterFile("server/pps/persist/persist.proto", fileDescriptorPersist) }

var fileDescriptorPersist = []byte{
	// 2087 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xbc, 0x58, 0x5f, 0x73, 0xdb, 0xc6,
	0x11, 0x17, 0xff, 0x83, 0x4b, 0xf1, 0x8f, 0xce, 0x8a, 0x02, 0xb3, 0x4e, 0xa5, 0xc2, 0xb5, 0xcd,
	0x28, 0x29, 0xe5, 0x51, 0xd2, 0x4c, 0xda, 0xda, 0xed, 0xc8, 0x24, 0xad, 0x21, 0xeb, 0xda, 0xea,
	0x51, 0x76, 0xd2, 0x4c, 0x33, 0x1c, 0x10, 0x38, 0x49, 0x90, 0x41, 0x1c, 0x02, 0x80, 0xb6, 0xd5,
	0x6f, 0xd0, 0x97, 0x7e, 0x91, 0x7e, 0x84, 0x3e, 0xf5, 0x5b, 0xf4, 0xc9, 0x0f, 0xfe, 0x16, 0x7d,
	0xeb, 0xdc, 0x1e, 0x40, 0x02, 0xfc, 0x27, 0x31, 0x93, 0xe9, 0x83, 0x46, 0x77, 0x7b, 0xbb, 0x7b,
	0x7b, 0xfb, 0xe7, 0xb7, 0x0b, 0xc2, 0x9e, 0xcf, 0xbc, 0x37, 0xcc, 0x3b, 0x70, 0x5d, 0xff, 0xc0,
	0x65, 0x9e, 0x6f, 0xf9, 0x41, 0xf4, 0xbf, 0xe9, 0x7a, 0x3c, 0xe0, 0xa4, 0xe4, 0xba, 0x7e, 0x33,
	0x24, 0xd5, 0x7f, 0x76, 0xce, 0xf9, 0xb9, 0xcd, 0x0e, 0xf0, 0x68, 0x38, 0x3e, 0x3b, 0x60, 0x23,
	0x37, 0xb8, 0x92, 0x9c, 0xf5, 0xdd, 0xd9, 0xc3, 0xc0, 0x1a, 0x31, 0x3f, 0xd0, 0x47, 0x6e, 0xc8,
	0xb0, 0x7d, 0xce, 0xcf, 0x39, 0x2e, 0x0f, 0xc4, 0x2a, 0xa2, 0x1a, 0xb6, 0xc5, 0x9c, 0xe0, 0xc0,
	0x3d, 0xf3, 0xc5, 0xdf, 0x2c, 0x55, 0x18, 0xe6, 0x86, 0x54, 0xed, 0x9f, 0x79, 0x28, 0xf4, 0xf8,
	0xb0, 0xeb, 0x9c, 0x71, 0xb2, 0x07, 0xf9, 0x4b, 0x3e, 0x1c, 0x58, 0xa6, 0x9a, 0xda, 0x4b, 0x35,
	0x8a, 0x4f, 0x8a, 0x1f, 0xde, 0xef, 0xe6, 0xc4, 0x61, 0x9b, 0xe6, 0x2e, 0xf9, 0xb0, 0x6b, 0x92,
	0xcf, 0xa1, 0x18, 0x78, 0xba, 0xe3, 0x9f, 0x71, 0x6f, 0xa4, 0xa6, 0xf7, 0x52, 0x8d, 0xd2, 0x61,
	0xa5, 0x29, 0x94, 0x9d, 0x46, 0x54, 0x3a, 0x65, 0x20, 0x77, 0xa1, 0xec, 0x5a, 0x2e, 0xb3, 0x2d,
	0x87, 0x0d, 0x1c, 0x7d, 0xc4, 0xd4, 0x8c, 0x50, 0x4b, 0x37, 0x23, 0xe2, 0x73, 0x7d, 0xc4, 0xc8,
	0xa7, 0x50, 0x9b, 0x30, 0xbd, 0x11, 0x4e, 0xe1, 0x8e, 0xba, 0xbd, 0x97, 0x6a, 0x64, 0x69, 0x35,
	0xa2, 0xbf, 0x92, 0x64, 0xf2, 0x07, 0xa8, 0xb9, 0xba, 0xa7, 0xdb, 0x36, 0xb3, 0x2d, 0x7f, 0x34,
	0xf0, 0x5d, 0x66, 0xa8, 0x04, 0x8d, 0xd8, 0x46, 0x23, 0x4e, 0xa6, 0x87, 0x7d, 0x97, 0x19, 0xb4,
	0xea, 0x26, 0x09, 0xe4, 0x1e, 0xe4, 0x2d, 0xc7, 0x1d, 0x07, 0xbe, 0x9a, 0xdb, 0xcb, 0x34, 0x4a,
	0x87, 0x65, 0x14, 0xc3, 0xe7, 0xbb, 0xe3, 0x80, 0x86, 0x87, 0xe4, 0x01, 0x80, 0xab, 0x7b, 0xcc,
	0x09, 0x06, 0x97, 0x7c, 0xa8, 0xe6, 0xf1, 0x06, 0x25, 0x62, 0xa5, 0x45, 0x79, 0xd6, 0xe3, 0x43,
	0xf2, 0x25, 0x14, 0xfc, 0x40, 0xf7, 0x02, 0x66, 0xaa, 0x05, 0xe4, 0xaa, 0x37, 0x65, 0xc4, 0x9a,
	0x51, 0xc4, 0x9a, 0xa7, 0x51, 0xc4, 0x68, 0xc4, 0x4a, 0xbe, 0x02, 0xe5, 0xcc, 0x72, 0x2c, 0xff,
	0x82, 0x99, 0xaa, 0x72, 0xad, 0xd8, 0x84, 0x97, 0x3c, 0x84, 0x32, 0x1f, 0x07, 0xee, 0x38, 0x18,
	0x18, 0x7c, 0x34, 0xb2, 0x02, 0xb5, 0x88, 0xc2, 0xa5, 0xa6, 0x88, 0x71, 0x0b, 0x49, 0x74, 0x53,
	0x72, 0xc8, 0x1d, 0xd9, 0x81, 0xfc, 0xd0, 0xd3, 0x1d, 0xe3, 0x42, 0xdd, 0x42, 0xcf, 0x87, 0x3b,
	0x72, 0x17, 0x72, 0x7e, 0xa0, 0x07, 0x4c, 0x85, 0xbd, 0x54, 0xa3, 0x32, 0x75, 0x43, 0x5f, 0x10,
	0xa9, 0x3c, 0x23, 0xbf, 0x80, 0x4d, 0x79, 0xcf, 0xc0, 0x72, 0x4c, 0xf6, 0x4e, 0x2d, 0xa1, 0x8a,
	0x92, 0xa4, 0x75, 0x05, 0x89, 0x3c, 0x84, 0x6d, 0x93, 0x9d, 0xe9, 0x63, 0x3b, 0x18, 0xf8, 0x17,
	0xba, 0x67, 0x0e, 0x46, 0xdc, 0x1c, 0xdb, 0x96, 0x5a, 0xdd, 0xcb, 0x34, 0xb2, 0x94, 0x84, 0x67,
	0x7d, 0x71, 0xf4, 0x27, 0x3c, 0x21, 0xdb, 0x90, 0x43, 0x4e, 0xf5, 0x16, 0x86, 0x58, 0x6e, 0x48,
	0x05, 0xd2, 0xe7, 0x86, 0xfa, 0xd1, 0x5e, 0xaa, 0xa1, 0xd0, 0xf4, 0xb9, 0x41, 0xee, 0x43, 0x41,
	0x54, 0x91, 0x65, 0x30, 0x75, 0x07, 0xdf, 0xb8, 0x89, 0x16, 0xf6, 0x25, 0x8d, 0x46, 0x87, 0xe4,
	0x2e, 0xe4, 0xe5, 0x7b, 0xd5, 0x8f, 0x23, 0x57, 0xb8, 0x7e, 0xf3, 0x05, 0x92, 0x68, 0x78, 0x24,
	0x72, 0xd6, 0x63, 0x3e, 0x1f, 0x7b, 0x06, 0xf3, 0x55, 0x35, 0x96, 0xb3, 0x34, 0xa2, 0xd2, 0x29,
	0x43, 0x2f, 0xab, 0x64, 0x6b, 0xb9, 0x5e, 0x56, 0xd9, 0xac, 0x95, 0x7b, 0x59, 0xa5, 0x5c, 0xab,
	0xf4, 0xb2, 0x4a, 0xa5, 0x56, 0xed, 0x65, 0x95, 0x5a, 0x6d, 0x4b, 0xfb, 0x23, 0x64, 0x4e, 0xb8,
	0x49, 0x08, 0x64, 0x31, 0x9f, 0xb1, 0x4c, 0x28, 0xae, 0xe7, 0xa3, 0x93, 0xbe, 0x26, 0x3a, 0xda,
	0x7f, 0x53, 0x90, 0x6b, 0x5d, 0x8c, 0x9d, 0xd7, 0x64, 0x07, 0xd2, 0x93, 0xa2, 0xcb, 0x7f, 0x78,
	0xbf, 0x9b, 0xee, 0xb6, 0x69, 0xda, 0x32, 0x63, 0x05, 0x99, 0x5e, 0x52, 0x90, 0x3b, 0x90, 0x0f,
	0x7d, 0x9e, 0x41, 0x9f, 0x87, 0x3b, 0xe1, 0x67, 0x19, 0xb5, 0xac, 0xf4, 0x33, 0x6e, 0x04, 0x95,
	0xbf, 0x75, 0x98, 0xa7, 0xe6, 0xd0, 0x70, 0xb9, 0x21, 0xbf, 0x84, 0xac, 0xcb, 0x4d, 0x5f, 0xcd,
	0x63, 0x4d, 0xd4, 0x9a, 0x31, 0x78, 0x6a, 0x9e, 0x70, 0x93, 0xe2, 0x29, 0xf9, 0x55, 0x94, 0x33,
	0x05, 0xcc, 0x99, 0x8f, 0x13, 0x6c, 0xf8, 0x8c, 0x44, 0xf6, 0x7c, 0x02, 0x60, 0x33, 0xdd, 0x67,
	0x03, 0x01, 0x59, 0x98, 0xe6, 0x59, 0x5a, 0x44, 0x8a, 0x48, 0x6d, 0xed, 0x4b, 0xc8, 0xa3, 0x8c,
	0x4f, 0xf6, 0x21, 0x6f, 0xe0, 0x4a, 0x4d, 0xe1, 0xfd, 0x64, 0x5e, 0x31, 0x0d, 0x39, 0xb4, 0xdf,
	0x81, 0x12, 0x62, 0x95, 0x4f, 0x0e, 0x40, 0x41, 0xdf, 0x38, 0x67, 0x3c, 0x94, 0xdc, 0x4e, 0x48,
	0x86, 0x8c, 0xb4, 0x70, 0x29, 0x17, 0xda, 0x1d, 0xc8, 0xa3, 0xeb, 0x7c, 0x11, 0xbe, 0x4b, 0x3e,
	0x94, 0x17, 0x16, 0x29, 0xae, 0xb5, 0x01, 0x14, 0x7b, 0x7c, 0x28, 0x53, 0xe7, 0x06, 0x40, 0xb8,
	0x7e, 0xb4, 0xff, 0x9e, 0x42, 0xe3, 0xd1, 0x49, 0x37, 0xb8, 0x60, 0x52, 0xa2, 0xe9, 0x15, 0x25,
	0x1a, 0x47, 0x92, 0xcc, 0xcd, 0x91, 0x44, 0x7b, 0x0b, 0x3b, 0x47, 0xa6, 0xf9, 0x22, 0x66, 0x1e,
	0x65, 0x3f, 0x8c, 0x99, 0x1f, 0xdc, 0xc8, 0xb0, 0xfc, 0xf2, 0x27, 0x87, 0x47, 0x31, 0xe0, 0xc9,
	0xc4, 0x81, 0x47, 0xfb, 0x4f, 0x0e, 0x36, 0x4f, 0x42, 0x54, 0xc7, 0x96, 0x33, 0xd7, 0x22, 0x52,
	0x0b, 0x5a, 0x84, 0x0a, 0x85, 0xa8, 0x33, 0x94, 0x31, 0x91, 0xa2, 0xed, 0x9a, 0xfd, 0x68, 0x51,
	0xff, 0xd8, 0x5c, 0xa7, 0x7f, 0xec, 0x4f, 0xfa, 0x47, 0x36, 0x96, 0xab, 0xd3, 0x07, 0xc5, 0x9b,
	0xc8, 0x3e, 0x94, 0xc2, 0x0c, 0xf1, 0x98, 0xcb, 0xb1, 0xe2, 0x4a, 0x87, 0x45, 0x74, 0x16, 0x65,
	0x2e, 0xa7, 0x20, 0x4f, 0xc5, 0x9a, 0xfc, 0x06, 0xc0, 0xf0, 0x98, 0x1e, 0x30, 0x73, 0xa0, 0x07,
	0x61, 0xc3, 0x59, 0x15, 0xc9, 0x62, 0xc8, 0x7d, 0x14, 0x4c, 0x01, 0xb5, 0x10, 0x07, 0xd4, 0x46,
	0x94, 0x3d, 0x0a, 0x66, 0x4f, 0xd2, 0xce, 0x59, 0x94, 0xf7, 0x98, 0x21, 0x7a, 0x1d, 0xf3, 0x3c,
	0xee, 0x61, 0x4f, 0x29, 0xd2, 0x92, 0xa4, 0x75, 0x04, 0x89, 0x1c, 0x03, 0x88, 0x9c, 0x30, 0xf8,
	0xd8, 0x09, 0x7c, 0x15, 0xf0, 0xe5, 0x8d, 0x24, 0x4a, 0xc4, 0x42, 0x2a, 0x92, 0xb4, 0x85, 0xac,
	0x1d, 0x27, 0xf0, 0xae, 0x68, 0xf1, 0x32, 0xda, 0x8b, 0x38, 0xfa, 0x01, 0x77, 0x5d, 0x66, 0x62,
	0x33, 0x51, 0x68, 0xb4, 0x25, 0xfb, 0x50, 0x3c, 0x37, 0x06, 0x2e, 0xb7, 0x2d, 0xe3, 0x4a, 0xad,
	0xe0, 0xfb, 0x65, 0xc6, 0x1f, 0xb7, 0x4e, 0x90, 0x48, 0x95, 0x73, 0x43, 0xae, 0x62, 0xa0, 0x5f,
	0xbd, 0x21, 0xe8, 0xd7, 0xae, 0x01, 0xfd, 0xfa, 0x23, 0xa8, 0x24, 0xad, 0x26, 0x35, 0xc8, 0xbc,
	0x66, 0x57, 0x98, 0x8d, 0x39, 0x2a, 0x96, 0xc2, 0xd1, 0x6f, 0x74, 0x7b, 0x2c, 0x0b, 0x32, 0x47,
	0xe5, 0xe6, 0xb7, 0xe9, 0xaf, 0x53, 0xbd, 0xac, 0x92, 0xa9, 0x65, 0xb5, 0x77, 0x40, 0xe2, 0x6e,
	0x68, 0x5d, 0xe8, 0xce, 0x39, 0x23, 0xbf, 0x06, 0x25, 0x4a, 0x65, 0x54, 0x56, 0x3a, 0xbc, 0xbd,
	0xd4, 0x73, 0x74, 0xc2, 0x4a, 0x3e, 0x83, 0x6c, 0x70, 0xe5, 0x46, 0xc5, 0x3f, 0x8b, 0xb5, 0x42,
	0xf3, 0xe9, 0x95, 0xcb, 0x28, 0x32, 0x69, 0x2f, 0xa0, 0x1c, 0x57, 0xe3, 0x93, 0xdf, 0xc7, 0x8a,
	0x2a, 0x86, 0x8f, 0x2b, 0x6e, 0x9e, 0xd4, 0x1b, 0x22, 0xa5, 0x07, 0x9f, 0xf4, 0xc7, 0x43, 0xdf,
	0xf0, 0xac, 0x21, 0x4b, 0x68, 0x8e, 0x50, 0xe2, 0x01, 0x54, 0x2d, 0xc7, 0xb0, 0xc7, 0xa6, 0xd0,
	0x6f, 0x05, 0x96, 0x6e, 0xe3, 0xe3, 0x14, 0x5a, 0x09, 0xc9, 0x5d, 0x49, 0xc5, 0x3c, 0xc4, 0xec,
	0x94, 0xb5, 0x99, 0xc4, 0x76, 0x9c, 0x0b, 0xc2, 0x8c, 0xd5, 0xfe, 0x95, 0x02, 0x75, 0x72, 0x69,
	0x04, 0xf2, 0x6b, 0xdf, 0x17, 0x63, 0x34, 0xd0, 0x4d, 0x3e, 0xde, 0x3c, 0x65, 0x94, 0xce, 0xf3,
	0xa7, 0x86, 0x65, 0xae, 0x31, 0x6c, 0x0a, 0xc4, 0xa2, 0xe4, 0x97, 0x00, 0xb1, 0x66, 0x43, 0x39,
	0xb4, 0x39, 0x8c, 0x7b, 0x13, 0xa2, 0xbe, 0x13, 0x86, 0x7d, 0x75, 0x73, 0x5a, 0x2f, 0xe0, 0x6d,
	0x50, 0x9f, 0x59, 0x7e, 0xb0, 0x30, 0x34, 0x93, 0x87, 0xa5, 0xae, 0xf3, 0xf8, 0x2e, 0xe4, 0x70,
	0x2f, 0xc0, 0xda, 0x19, 0x8f, 0x86, 0xcc, 0x43, 0x99, 0x2c, 0x0d, 0x77, 0xda, 0x3f, 0x52, 0x50,
	0x7f, 0xe9, 0x9a, 0x7a, 0xc0, 0x92, 0xc8, 0x11, 0xde, 0x74, 0x23, 0xe8, 0x6e, 0x24, 0xdb, 0xd8,
	0x1a, 0x40, 0x94, 0x99, 0x03, 0x22, 0xed, 0x7b, 0xb8, 0x33, 0x6b, 0x0f, 0xc2, 0xc7, 0x5a, 0x16,
	0xc5, 0x40, 0x28, 0x9d, 0x00, 0x21, 0xed, 0x12, 0x6e, 0x3f, 0xb1, 0xb9, 0xf1, 0xfa, 0xff, 0xf0,
	0x5a, 0xed, 0x31, 0x54, 0x8f, 0x4c, 0x53, 0x4e, 0x37, 0xe1, 0x0d, 0xeb, 0x0c, 0x42, 0x7f, 0x81,
	0xad, 0x96, 0xad, 0x5b, 0xa3, 0x84, 0x82, 0xeb, 0x7b, 0xb7, 0x06, 0x19, 0x97, 0x47, 0xc5, 0x38,
	0x3f, 0xe8, 0x89, 0x43, 0xed, 0x15, 0x6c, 0x51, 0xe6, 0xb0, 0xb7, 0x09, 0xd5, 0xf7, 0x41, 0xc1,
	0x9b, 0xa7, 0xca, 0x4b, 0x1f, 0xde, 0xef, 0x16, 0x90, 0xa7, 0xdb, 0xa6, 0x05, 0x3c, 0xec, 0x9a,
	0xe4, 0x36, 0x28, 0x2e, 0x37, 0xa5, 0x83, 0x70, 0x64, 0xa5, 0x05, 0x97, 0x9b, 0xc2, 0x37, 0xda,
	0x37, 0x40, 0x9e, 0xe2, 0xfc, 0xf1, 0x53, 0x2b, 0xfe, 0x01, 0x08, 0x65, 0x6f, 0xf8, 0x6b, 0xf6,
	0x13, 0x2b, 0x16, 0x99, 0x32, 0xd2, 0xdf, 0x9d, 0x88, 0xd1, 0x38, 0x23, 0xc7, 0x8e, 0x70, 0xab,
	0x7d, 0x05, 0xd5, 0x6f, 0x74, 0x4b, 0x7c, 0x02, 0x52, 0xe6, 0xbb, 0xdc, 0xf1, 0xd9, 0x14, 0x26,
	0x52, 0xcb, 0xe7, 0x35, 0xed, 0x6f, 0x50, 0x42, 0x03, 0x42, 0x90, 0x68, 0x40, 0x0e, 0xcd, 0x58,
	0x58, 0xab, 0xf2, 0x35, 0x92, 0x61, 0x2d, 0x78, 0x10, 0x9d, 0xca, 0x63, 0xba, 0x79, 0x85, 0x56,
	0x2b, 0x54, 0x6e, 0xb4, 0xef, 0x61, 0x67, 0x82, 0xaf, 0x72, 0xf4, 0x8e, 0x5c, 0x55, 0x87, 0x8c,
	0xf8, 0xce, 0x4d, 0xcd, 0x7c, 0xe7, 0x0a, 0xe2, 0x22, 0xe4, 0x4d, 0x2f, 0x42, 0x5e, 0xcd, 0x84,
	0x2d, 0x81, 0x49, 0xc7, 0xad, 0x1e, 0x1f, 0xfa, 0x6b, 0x15, 0x4d, 0xa2, 0xf7, 0xa7, 0x57, 0xf6,
	0xfe, 0xfd, 0x3f, 0x03, 0x4c, 0x3f, 0x35, 0x48, 0x05, 0xe0, 0xe5, 0xf3, 0xa3, 0x7e, 0xbf, 0x7b,
	0xfc, 0xbc, 0xd3, 0xae, 0x6d, 0x90, 0x4d, 0x50, 0x26, 0xbb, 0x14, 0x29, 0x41, 0xa1, 0xff, 0xb2,
	0xd5, 0xea, 0xf4, 0xfb, 0xb5, 0x34, 0x01, 0xc8, 0x3f, 0x3d, 0xea, 0x3e, 0xeb, 0xb4, 0x6b, 0x19,
	0xc1, 0xd6, 0x3f, 0x79, 0xd6, 0x3d, 0x3d, 0xed, 0xb4, 0x6b, 0xd9, 0xfd, 0x87, 0x42, 0x65, 0xe4,
	0x41, 0xc1, 0xd7, 0xa2, 0x9d, 0xa3, 0xd3, 0x4e, 0x6d, 0x43, 0xac, 0x5f, 0x9e, 0xb4, 0xc5, 0x3a,
	0x25, 0xd6, 0xed, 0xce, 0xb3, 0xce, 0x69, 0xa7, 0x96, 0x3e, 0xfc, 0x77, 0x0d, 0x32, 0x47, 0x27,
	0x5d, 0xf2, 0x18, 0xca, 0x2d, 0x9c, 0xc3, 0xa2, 0xdf, 0x4f, 0x16, 0x62, 0x7c, 0x7d, 0x21, 0x55,
	0xdb, 0x20, 0x8f, 0x00, 0xba, 0x8e, 0x98, 0x41, 0xf1, 0xa7, 0x84, 0x1d, 0xe4, 0x9a, 0x12, 0x42,
	0x17, 0xae, 0x90, 0xde, 0x14, 0xfe, 0x9e, 0x7c, 0x0e, 0xdd, 0x42, 0xbe, 0x90, 0x14, 0x09, 0x7f,
	0xb4, 0x48, 0xd8, 0xd7, 0x36, 0xc8, 0x17, 0x50, 0x6e, 0x33, 0x9b, 0x4d, 0x4d, 0x9f, 0x84, 0xbd,
	0xbe, 0x33, 0x37, 0x77, 0x76, 0x46, 0x6e, 0x70, 0xa5, 0x6d, 0x90, 0x36, 0xdc, 0x4e, 0x08, 0xf9,
	0x4f, 0xb9, 0x17, 0x81, 0x1b, 0x29, 0x27, 0xb0, 0x6e, 0x85, 0x96, 0xef, 0x60, 0x6b, 0xae, 0xcf,
	0x93, 0x7b, 0xc9, 0x36, 0xb5, 0x64, 0x0e, 0xa8, 0xd7, 0x17, 0xbd, 0x47, 0x46, 0x4f, 0xdb, 0x78,
	0x98, 0x22, 0x2d, 0xa8, 0x4e, 0x22, 0x12, 0x7e, 0xca, 0xed, 0xcc, 0x8a, 0x48, 0xfa, 0x0a, 0x03,
	0x8f, 0xa0, 0x32, 0x51, 0x22, 0xf3, 0x6c, 0xce, 0x8d, 0x48, 0x5e, 0xa1, 0xe2, 0x73, 0x50, 0xfa,
	0x81, 0xee, 0x61, 0x60, 0xa7, 0x9e, 0x5d, 0x16, 0xca, 0x16, 0xc0, 0xb4, 0x74, 0xc8, 0xcf, 0x13,
	0x5c, 0x73, 0x35, 0x55, 0xbf, 0x35, 0xa7, 0xa5, 0x2d, 0x22, 0xfa, 0x19, 0xe4, 0x90, 0xef, 0x46,
	0x91, 0xec, 0x02, 0x91, 0x4f, 0x4c, 0x7c, 0x8b, 0x2d, 0x9f, 0x0f, 0x57, 0xab, 0x4a, 0xf6, 0xe4,
	0x1f, 0xaf, 0xea, 0x11, 0x6c, 0x9d, 0xf2, 0xb1, 0x71, 0x91, 0xd0, 0x74, 0xe3, 0xbc, 0x7a, 0x0c,
	0xd5, 0x63, 0x16, 0xac, 0x92, 0x5d, 0x6e, 0x94, 0xb6, 0x41, 0xbe, 0x95, 0xf8, 0x95, 0x1c, 0xa4,
	0xef, 0xcd, 0xc5, 0x62, 0xd1, 0xcc, 0x35, 0x93, 0x96, 0x09, 0x16, 0x34, 0x8c, 0xc8, 0xb2, 0xf9,
	0x71, 0xef, 0xb2, 0x62, 0xb8, 0x9d, 0xb4, 0x6e, 0x7f, 0x71, 0xd1, 0x2c, 0x34, 0x71, 0x77, 0xa9,
	0x89, 0xb1, 0xf2, 0xf9, 0x16, 0x6e, 0x2d, 0x98, 0xf7, 0xc8, 0x83, 0x84, 0xec, 0xf2, 0x89, 0x70,
	0xc5, 0x23, 0xfe, 0x0a, 0x1f, 0x2d, 0x9c, 0xdc, 0xc8, 0xa7, 0x2b, 0x75, 0xc7, 0xa7, 0xbb, 0x15,
	0xda, 0x5f, 0x01, 0x99, 0x1f, 0xdc, 0xc8, 0xfd, 0x84, 0xea, 0xa5, 0x93, 0xdd, 0xca, 0x94, 0x2a,
	0xca, 0xc8, 0x1d, 0xd9, 0x36, 0x59, 0xc2, 0xb6, 0x42, 0xfc, 0x09, 0x28, 0xd1, 0x8c, 0x47, 0xee,
	0x24, 0x8c, 0x99, 0x19, 0xfd, 0x56, 0xea, 0x80, 0xe9, 0xa0, 0x37, 0x83, 0x0d, 0x73, 0x13, 0x60,
	0x7d, 0xc1, 0x04, 0x21, 0x75, 0x4c, 0x27, 0xba, 0x19, 0x1d, 0x73, 0xa3, 0xde, 0x12, 0x1d, 0x6d,
	0x28, 0xc5, 0xa6, 0x37, 0x92, 0x4c, 0xa7, 0xf9, 0xb9, 0x6e, 0xb9, 0x96, 0xd8, 0xa8, 0x36, 0xa3,
	0x65, 0x7e, 0x88, 0x5b, 0xa2, 0xe5, 0x14, 0xaa, 0x33, 0x93, 0x0c, 0xb9, 0xbb, 0xb8, 0x14, 0x12,
	0x73, 0x4e, 0x5d, 0x9d, 0xd7, 0x16, 0x4b, 0xfe, 0x43, 0xc4, 0x0f, 0x29, 0xf1, 0x94, 0x7b, 0x49,
	0x28, 0xbd, 0x35, 0x2f, 0x2a, 0x4a, 0xfb, 0xeb, 0xa8, 0xb4, 0x97, 0x88, 0x2d, 0x8d, 0xeb, 0x93,
	0xe2, 0x77, 0x85, 0x50, 0xdb, 0x30, 0x8f, 0x87, 0x5f, 0xfc, 0x2f, 0x00, 0x00, 0xff, 0xff, 0xe1,
	0x60, 0x2e, 0x43, 0x39, 0x1a, 0x00, 0x00,
}