pps.pb.go

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

/*
Package pps is a generated protocol buffer package.

It is generated from these files:
	client/pps/pps.proto

It has these top-level messages:
	Secret
	Transform
	Output
	Job
	Service
	Method
	JobInput
	ParallelismSpec
	JobInfo
	Chunk
	Pod
	JobInfos
	Pipeline
	PipelineInput
	GCPolicy
	PipelineInfo
	PipelineInfos
	CreateJobRequest
	InspectJobRequest
	ListJobRequest
	DeleteJobRequest
	GetLogsRequest
	CreatePipelineRequest
	InspectPipelineRequest
	ListPipelineRequest
	DeletePipelineRequest
	StartPipelineRequest
	StopPipelineRequest
	RerunPipelineRequest
*/
package pps

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 google_protobuf2 "github.com/gogo/protobuf/types"
import google_protobuf3 "github.com/gogo/protobuf/types"
import _ "github.com/gogo/protobuf/gogoproto"
import pfs "github.com/pachyderm/pachyderm/src/client/pfs"

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 JobState int32

const (
	JobState_JOB_CREATING JobState = 0
	JobState_JOB_RUNNING  JobState = 1
	JobState_JOB_FAILURE  JobState = 2
	JobState_JOB_SUCCESS  JobState = 3
	// An empty job is a job that hasn't actually been run.
	// It's a result of empty input commits.
	JobState_JOB_EMPTY      JobState = 4
	JobState_JOB_OUTPUTTING JobState = 5
)

var JobState_name = map[int32]string{
	0: "JOB_CREATING",
	1: "JOB_RUNNING",
	2: "JOB_FAILURE",
	3: "JOB_SUCCESS",
	4: "JOB_EMPTY",
	5: "JOB_OUTPUTTING",
}
var JobState_value = map[string]int32{
	"JOB_CREATING":   0,
	"JOB_RUNNING":    1,
	"JOB_FAILURE":    2,
	"JOB_SUCCESS":    3,
	"JOB_EMPTY":      4,
	"JOB_OUTPUTTING": 5,
}

func (x JobState) String() string {
	return proto.EnumName(JobState_name, int32(x))
}
func (JobState) EnumDescriptor() ([]byte, []int) { return fileDescriptorPps, []int{0} }

type Partition int32

const (
	Partition_BLOCK Partition = 0
	Partition_FILE  Partition = 1
	Partition_REPO  Partition = 2
)

var Partition_name = map[int32]string{
	0: "BLOCK",
	1: "FILE",
	2: "REPO",
}
var Partition_value = map[string]int32{
	"BLOCK": 0,
	"FILE":  1,
	"REPO":  2,
}

func (x Partition) String() string {
	return proto.EnumName(Partition_name, int32(x))
}
func (Partition) EnumDescriptor() ([]byte, []int) { return fileDescriptorPps, []int{1} }

type Incremental int32

const (
	Incremental_NONE Incremental = 0
	Incremental_DIFF Incremental = 1
	Incremental_FULL Incremental = 2
)

var Incremental_name = map[int32]string{
	0: "NONE",
	1: "DIFF",
	2: "FULL",
}
var Incremental_value = map[string]int32{
	"NONE": 0,
	"DIFF": 1,
	"FULL": 2,
}

func (x Incremental) String() string {
	return proto.EnumName(Incremental_name, int32(x))
}
func (Incremental) EnumDescriptor() ([]byte, []int) { return fileDescriptorPps, []int{2} }

type ChunkState int32

const (
	ChunkState_CHUNK_UNASSIGNED ChunkState = 0
	ChunkState_CHUNK_ASSIGNED   ChunkState = 1
	ChunkState_CHUNK_SUCCESS    ChunkState = 2
	ChunkState_CHUNK_FAILURE    ChunkState = 3
)

var ChunkState_name = map[int32]string{
	0: "CHUNK_UNASSIGNED",
	1: "CHUNK_ASSIGNED",
	2: "CHUNK_SUCCESS",
	3: "CHUNK_FAILURE",
}
var ChunkState_value = map[string]int32{
	"CHUNK_UNASSIGNED": 0,
	"CHUNK_ASSIGNED":   1,
	"CHUNK_SUCCESS":    2,
	"CHUNK_FAILURE":    3,
}

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

type PodState int32

const (
	PodState_POD_RUNNING PodState = 0
	PodState_POD_SUCCESS PodState = 1
	PodState_POD_FAILED  PodState = 2
)

var PodState_name = map[int32]string{
	0: "POD_RUNNING",
	1: "POD_SUCCESS",
	2: "POD_FAILED",
}
var PodState_value = map[string]int32{
	"POD_RUNNING": 0,
	"POD_SUCCESS": 1,
	"POD_FAILED":  2,
}

func (x PodState) String() string {
	return proto.EnumName(PodState_name, int32(x))
}
func (PodState) EnumDescriptor() ([]byte, []int) { return fileDescriptorPps, []int{4} }

type PipelineState int32

const (
	// When the pipeline is not ready to be triggered by commits.
	// This happens when either 1) a pipeline has been created but not yet picked
	// up by a PPS server, or 2) the pipeline does not have any inputs and is meant
	// to be triggered manually
	PipelineState_PIPELINE_IDLE PipelineState = 0
	// After this pipeline is picked up by a pachd node.  This is the normal
	// state of a pipeline.
	PipelineState_PIPELINE_RUNNING PipelineState = 1
	// After some error caused runPipeline to exit, but before the pipeline is
	// re-run.  This is when the exponential backoff is in effect.
	PipelineState_PIPELINE_RESTARTING PipelineState = 2
	// We have retried too many times and we have given up on this pipeline.
	PipelineState_PIPELINE_FAILURE PipelineState = 3
	// The pipeline has been explicitly stopped by the user.
	PipelineState_PIPELINE_STOPPED PipelineState = 4
)

var PipelineState_name = map[int32]string{
	0: "PIPELINE_IDLE",
	1: "PIPELINE_RUNNING",
	2: "PIPELINE_RESTARTING",
	3: "PIPELINE_FAILURE",
	4: "PIPELINE_STOPPED",
}
var PipelineState_value = map[string]int32{
	"PIPELINE_IDLE":       0,
	"PIPELINE_RUNNING":    1,
	"PIPELINE_RESTARTING": 2,
	"PIPELINE_FAILURE":    3,
	"PIPELINE_STOPPED":    4,
}

func (x PipelineState) String() string {
	return proto.EnumName(PipelineState_name, int32(x))
}
func (PipelineState) EnumDescriptor() ([]byte, []int) { return fileDescriptorPps, []int{5} }

// Which Parallelism strategy to use. Depending on the value of
// 'strategy', other messages in the spec will or will not be set.
type ParallelismSpec_Strategy int32

const (
	ParallelismSpec_CONSTANT    ParallelismSpec_Strategy = 0
	ParallelismSpec_COEFFICIENT ParallelismSpec_Strategy = 1
)

var ParallelismSpec_Strategy_name = map[int32]string{
	0: "CONSTANT",
	1: "COEFFICIENT",
}
var ParallelismSpec_Strategy_value = map[string]int32{
	"CONSTANT":    0,
	"COEFFICIENT": 1,
}

func (x ParallelismSpec_Strategy) String() string {
	return proto.EnumName(ParallelismSpec_Strategy_name, int32(x))
}
func (ParallelismSpec_Strategy) EnumDescriptor() ([]byte, []int) {
	return fileDescriptorPps, []int{7, 0}
}

type Secret struct {
	// Name must be the name of the secret in kubernetes.
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MountPath string `protobuf:"bytes,2,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
}

func (m *Secret) Reset()                    { *m = Secret{} }
func (m *Secret) String() string            { return proto.CompactTextString(m) }
func (*Secret) ProtoMessage()               {}
func (*Secret) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{0} }

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

func (m *Secret) GetMountPath() string {
	if m != nil {
		return m.MountPath
	}
	return ""
}

type Transform struct {
	Image            string            `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Cmd              []string          `protobuf:"bytes,2,rep,name=cmd" json:"cmd,omitempty"`
	Env              map[string]string `protobuf:"bytes,3,rep,name=env" json:"env,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	Secrets          []*Secret         `protobuf:"bytes,4,rep,name=secrets" json:"secrets,omitempty"`
	ImagePullSecrets []string          `protobuf:"bytes,9,rep,name=image_pull_secrets,json=imagePullSecrets" json:"image_pull_secrets,omitempty"`
	Stdin            []string          `protobuf:"bytes,5,rep,name=stdin" json:"stdin,omitempty"`
	AcceptReturnCode []int64           `protobuf:"varint,6,rep,packed,name=accept_return_code,json=acceptReturnCode" json:"accept_return_code,omitempty"`
	Debug            bool              `protobuf:"varint,7,opt,name=debug,proto3" json:"debug,omitempty"`
	// If set to true, writing to a file overwrites the original file, as opposed to
	// appending to it.
	Overwrite bool `protobuf:"varint,8,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
}

func (m *Transform) Reset()                    { *m = Transform{} }
func (m *Transform) String() string            { return proto.CompactTextString(m) }
func (*Transform) ProtoMessage()               {}
func (*Transform) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{1} }

func (m *Transform) GetImage() string {
	if m != nil {
		return m.Image
	}
	return ""
}

func (m *Transform) GetCmd() []string {
	if m != nil {
		return m.Cmd
	}
	return nil
}

func (m *Transform) GetEnv() map[string]string {
	if m != nil {
		return m.Env
	}
	return nil
}

func (m *Transform) GetSecrets() []*Secret {
	if m != nil {
		return m.Secrets
	}
	return nil
}

func (m *Transform) GetImagePullSecrets() []string {
	if m != nil {
		return m.ImagePullSecrets
	}
	return nil
}

func (m *Transform) GetStdin() []string {
	if m != nil {
		return m.Stdin
	}
	return nil
}

func (m *Transform) GetAcceptReturnCode() []int64 {
	if m != nil {
		return m.AcceptReturnCode
	}
	return nil
}

func (m *Transform) GetDebug() bool {
	if m != nil {
		return m.Debug
	}
	return false
}

func (m *Transform) GetOverwrite() bool {
	if m != nil {
		return m.Overwrite
	}
	return false
}

type Output struct {
	URL string `protobuf:"bytes,1,opt,name=URL,json=uRL,proto3" json:"URL,omitempty"`
}

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

func (m *Output) GetURL() string {
	if m != nil {
		return m.URL
	}
	return ""
}

type Job struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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

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

type Service struct {
	InternalPort int32 `protobuf:"varint,1,opt,name=internal_port,json=internalPort,proto3" json:"internal_port,omitempty"`
	ExternalPort int32 `protobuf:"varint,2,opt,name=external_port,json=externalPort,proto3" json:"external_port,omitempty"`
}

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

func (m *Service) GetInternalPort() int32 {
	if m != nil {
		return m.InternalPort
	}
	return 0
}

func (m *Service) GetExternalPort() int32 {
	if m != nil {
		return m.ExternalPort
	}
	return 0
}

type Method struct {
	Partition   Partition   `protobuf:"varint,1,opt,name=partition,proto3,enum=pps.Partition" json:"partition,omitempty"`
	Incremental Incremental `protobuf:"varint,2,opt,name=incremental,proto3,enum=pps.Incremental" json:"incremental,omitempty"`
}

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

func (m *Method) GetPartition() Partition {
	if m != nil {
		return m.Partition
	}
	return Partition_BLOCK
}

func (m *Method) GetIncremental() Incremental {
	if m != nil {
		return m.Incremental
	}
	return Incremental_NONE
}

type JobInput struct {
	Commit *pfs.Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Method *Method     `protobuf:"bytes,2,opt,name=method" json:"method,omitempty"`
	// This flag specifies whether the pipeline should be triggered
	// when this input gets an empty commit.
	RunEmpty bool `protobuf:"varint,3,opt,name=run_empty,json=runEmpty,proto3" json:"run_empty,omitempty"`
	Lazy     bool `protobuf:"varint,4,opt,name=lazy,proto3" json:"lazy,omitempty"`
}

func (m *JobInput) Reset()                    { *m = JobInput{} }
func (m *JobInput) String() string            { return proto.CompactTextString(m) }
func (*JobInput) ProtoMessage()               {}
func (*JobInput) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{6} }

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

func (m *JobInput) GetMethod() *Method {
	if m != nil {
		return m.Method
	}
	return nil
}

func (m *JobInput) GetRunEmpty() bool {
	if m != nil {
		return m.RunEmpty
	}
	return false
}

func (m *JobInput) GetLazy() bool {
	if m != nil {
		return m.Lazy
	}
	return false
}

type ParallelismSpec struct {
	Strategy ParallelismSpec_Strategy `protobuf:"varint,1,opt,name=strategy,proto3,enum=pps.ParallelismSpec_Strategy" json:"strategy,omitempty"`
	// If 'strategy' is set to CONSTANT, then the field 'constant' is used.
	//
	// Starts the pipeline/job with a 'constant' workers, unless 'constant' is
	// zero. If 'constant' is zero (which is the zero value of ParallelismSpec),
	// then Pachyderm will choose the number of workers that is started,
	// (currently it chooses the number of workers in the cluster)
	Constant uint64 `protobuf:"varint,2,opt,name=constant,proto3" json:"constant,omitempty"`
	// If 'strategy' is set to COEFFICIENT, then the field 'coefficient' is used.
	//
	// Starts the pipeline/job with number of workers equal to 'coefficient' * N,
	// where N is the number of nodes in the kubernetes cluster.
	//
	// For example, if each Kubernetes node has four CPUs, you might set
	// 'coefficient' to four, so that there are four Pachyderm workers per
	// Kubernetes node, and each Pachyderm worker gets one CPU. If you want to
	// reserve half the nodes in your cluster for other tasks, you might set
	// 'coefficient' to 0.5.
	Coefficient float64 `protobuf:"fixed64,3,opt,name=coefficient,proto3" json:"coefficient,omitempty"`
}

func (m *ParallelismSpec) Reset()                    { *m = ParallelismSpec{} }
func (m *ParallelismSpec) String() string            { return proto.CompactTextString(m) }
func (*ParallelismSpec) ProtoMessage()               {}
func (*ParallelismSpec) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{7} }

func (m *ParallelismSpec) GetStrategy() ParallelismSpec_Strategy {
	if m != nil {
		return m.Strategy
	}
	return ParallelismSpec_CONSTANT
}

func (m *ParallelismSpec) GetConstant() uint64 {
	if m != nil {
		return m.Constant
	}
	return 0
}

func (m *ParallelismSpec) GetCoefficient() float64 {
	if m != nil {
		return m.Coefficient
	}
	return 0
}

type JobInfo struct {
	Job             *Job                        `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"`
	Transform       *Transform                  `protobuf:"bytes,2,opt,name=transform" json:"transform,omitempty"`
	Pipeline        *Pipeline                   `protobuf:"bytes,3,opt,name=pipeline" json:"pipeline,omitempty"`
	PipelineVersion uint64                      `protobuf:"varint,13,opt,name=pipeline_version,json=pipelineVersion,proto3" json:"pipeline_version,omitempty"`
	ParallelismSpec *ParallelismSpec            `protobuf:"bytes,12,opt,name=parallelism_spec,json=parallelismSpec" json:"parallelism_spec,omitempty"`
	Inputs          []*JobInput                 `protobuf:"bytes,5,rep,name=inputs" json:"inputs,omitempty"`
	Output          *Output                     `protobuf:"bytes,15,opt,name=output" json:"output,omitempty"`
	ParentJob       *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"`
	State           JobState                    `protobuf:"varint,10,opt,name=state,proto3,enum=pps.JobState" json:"state,omitempty"`
	Chunks          []*Chunk                    `protobuf:"bytes,11,rep,name=chunks" json:"chunks,omitempty"`
	Service         *Service                    `protobuf:"bytes,14,opt,name=service" json:"service,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 fileDescriptorPps, []int{8} }

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

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

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

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

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

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

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

func (m *JobInfo) GetParentJob() *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) GetState() JobState {
	if m != nil {
		return m.State
	}
	return JobState_JOB_CREATING
}

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

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

type Chunk struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A series of pods, in chronological order, that have processed this shard
	Pods  []*Pod     `protobuf:"bytes,2,rep,name=pods" json:"pods,omitempty"`
	State ChunkState `protobuf:"varint,3,opt,name=state,proto3,enum=pps.ChunkState" json:"state,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 fileDescriptorPps, []int{9} }

func (m *Chunk) GetID() string {
	if m != nil {
		return m.ID
	}
	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_CHUNK_UNASSIGNED
}

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"`
	State        PodState    `protobuf:"varint,3,opt,name=state,proto3,enum=pps.PodState" json:"state,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 fileDescriptorPps, []int{10} }

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
}

func (m *Pod) GetState() PodState {
	if m != nil {
		return m.State
	}
	return PodState_POD_RUNNING
}

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 fileDescriptorPps, []int{11} }

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

type Pipeline struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (m *Pipeline) Reset()                    { *m = Pipeline{} }
func (m *Pipeline) String() string            { return proto.CompactTextString(m) }
func (*Pipeline) ProtoMessage()               {}
func (*Pipeline) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{12} }

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

type PipelineInput struct {
	Repo   *pfs.Repo `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Method *Method   `protobuf:"bytes,2,opt,name=method" json:"method,omitempty"`
	// This flag specifies whether the pipeline should be triggered
	// when this input gets an empty commit.
	RunEmpty bool `protobuf:"varint,3,opt,name=run_empty,json=runEmpty,proto3" json:"run_empty,omitempty"`
	Lazy     bool `protobuf:"varint,4,opt,name=lazy,proto3" json:"lazy,omitempty"`
}

func (m *PipelineInput) Reset()                    { *m = PipelineInput{} }
func (m *PipelineInput) String() string            { return proto.CompactTextString(m) }
func (*PipelineInput) ProtoMessage()               {}
func (*PipelineInput) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{13} }

func (m *PipelineInput) GetRepo() *pfs.Repo {
	if m != nil {
		return m.Repo
	}
	return nil
}

func (m *PipelineInput) GetMethod() *Method {
	if m != nil {
		return m.Method
	}
	return nil
}

func (m *PipelineInput) GetRunEmpty() bool {
	if m != nil {
		return m.RunEmpty
	}
	return false
}

func (m *PipelineInput) GetLazy() bool {
	if m != nil {
		return m.Lazy
	}
	return false
}

// GCPolicy describes when jobs can be garbage-collected.
type GCPolicy struct {
	// The amount of time that needs to pass before a successful job
	// can be GC-ed.
	Success *google_protobuf2.Duration `protobuf:"bytes,1,opt,name=success" json:"success,omitempty"`
	// The amount of time that needs to pass before a failed job
	// can be GC-ed.
	Failure *google_protobuf2.Duration `protobuf:"bytes,2,opt,name=failure" json:"failure,omitempty"`
}

func (m *GCPolicy) Reset()                    { *m = GCPolicy{} }
func (m *GCPolicy) String() string            { return proto.CompactTextString(m) }
func (*GCPolicy) ProtoMessage()               {}
func (*GCPolicy) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{14} }

func (m *GCPolicy) GetSuccess() *google_protobuf2.Duration {
	if m != nil {
		return m.Success
	}
	return nil
}

func (m *GCPolicy) GetFailure() *google_protobuf2.Duration {
	if m != nil {
		return m.Failure
	}
	return nil
}

type PipelineInfo struct {
	Pipeline        *Pipeline                   `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
	Version         uint64                      `protobuf:"varint,11,opt,name=version,proto3" json:"version,omitempty"`
	Transform       *Transform                  `protobuf:"bytes,2,opt,name=transform" json:"transform,omitempty"`
	ParallelismSpec *ParallelismSpec            `protobuf:"bytes,10,opt,name=parallelism_spec,json=parallelismSpec" json:"parallelism_spec,omitempty"`
	Inputs          []*PipelineInput            `protobuf:"bytes,4,rep,name=inputs" json:"inputs,omitempty"`
	Output          *Output                     `protobuf:"bytes,15,opt,name=output" json:"output,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"`
	State           PipelineState               `protobuf:"varint,7,opt,name=state,proto3,enum=pps.PipelineState" json:"state,omitempty"`
	RecentError     string                      `protobuf:"bytes,8,opt,name=recent_error,json=recentError,proto3" json:"recent_error,omitempty"`
	JobCounts       map[int32]int32             `protobuf:"bytes,9,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"`
	GcPolicy        *GCPolicy                   `protobuf:"bytes,12,opt,name=gc_policy,json=gcPolicy" json:"gc_policy,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 fileDescriptorPps, []int{15} }

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

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

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

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

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

func (m *PipelineInfo) GetOutput() *Output {
	if m != nil {
		return m.Output
	}
	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) GetState() PipelineState {
	if m != nil {
		return m.State
	}
	return 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) GetGcPolicy() *GCPolicy {
	if m != nil {
		return m.GcPolicy
	}
	return nil
}

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 fileDescriptorPps, []int{16} }

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

type CreateJobRequest struct {
	Transform       *Transform       `protobuf:"bytes,1,opt,name=transform" json:"transform,omitempty"`
	Pipeline        *Pipeline        `protobuf:"bytes,2,opt,name=pipeline" json:"pipeline,omitempty"`
	PipelineVersion uint64           `protobuf:"varint,10,opt,name=pipeline_version,json=pipelineVersion,proto3" json:"pipeline_version,omitempty"`
	ParallelismSpec *ParallelismSpec `protobuf:"bytes,7,opt,name=parallelism_spec,json=parallelismSpec" json:"parallelism_spec,omitempty"`
	Inputs          []*JobInput      `protobuf:"bytes,4,rep,name=inputs" json:"inputs,omitempty"`
	Output          *Output          `protobuf:"bytes,9,opt,name=output" json:"output,omitempty"`
	ParentJob       *Job             `protobuf:"bytes,5,opt,name=parent_job,json=parentJob" json:"parent_job,omitempty"`
	Force           bool             `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
	// When service is defined, we create a long running job
	// by using a k8s RC and Service instead of a k8s Job
	Service *Service `protobuf:"bytes,8,opt,name=service" json:"service,omitempty"`
}

func (m *CreateJobRequest) Reset()                    { *m = CreateJobRequest{} }
func (m *CreateJobRequest) String() string            { return proto.CompactTextString(m) }
func (*CreateJobRequest) ProtoMessage()               {}
func (*CreateJobRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{17} }

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

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

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

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

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

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

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

func (m *CreateJobRequest) GetForce() bool {
	if m != nil {
		return m.Force
	}
	return false
}

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

type InspectJobRequest struct {
	Job        *Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"`
	BlockState bool `protobuf:"varint,2,opt,name=block_state,json=blockState,proto3" json:"block_state,omitempty"`
}

func (m *InspectJobRequest) Reset()                    { *m = InspectJobRequest{} }
func (m *InspectJobRequest) String() string            { return proto.CompactTextString(m) }
func (*InspectJobRequest) ProtoMessage()               {}
func (*InspectJobRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{18} }

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

func (m *InspectJobRequest) GetBlockState() bool {
	if m != nil {
		return m.BlockState
	}
	return false
}

type ListJobRequest struct {
	Pipeline    *Pipeline     `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
	InputCommit []*pfs.Commit `protobuf:"bytes,2,rep,name=input_commit,json=inputCommit" json:"input_commit,omitempty"`
}

func (m *ListJobRequest) Reset()                    { *m = ListJobRequest{} }
func (m *ListJobRequest) String() string            { return proto.CompactTextString(m) }
func (*ListJobRequest) ProtoMessage()               {}
func (*ListJobRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{19} }

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

func (m *ListJobRequest) GetInputCommit() []*pfs.Commit {
	if m != nil {
		return m.InputCommit
	}
	return nil
}

type DeleteJobRequest struct {
	Job *Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"`
}

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

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

type GetLogsRequest struct {
	Job *Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"`
}

func (m *GetLogsRequest) Reset()                    { *m = GetLogsRequest{} }
func (m *GetLogsRequest) String() string            { return proto.CompactTextString(m) }
func (*GetLogsRequest) ProtoMessage()               {}
func (*GetLogsRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{21} }

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

type CreatePipelineRequest struct {
	Pipeline        *Pipeline        `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
	Transform       *Transform       `protobuf:"bytes,2,opt,name=transform" json:"transform,omitempty"`
	ParallelismSpec *ParallelismSpec `protobuf:"bytes,7,opt,name=parallelism_spec,json=parallelismSpec" json:"parallelism_spec,omitempty"`
	Inputs          []*PipelineInput `protobuf:"bytes,4,rep,name=inputs" json:"inputs,omitempty"`
	Output          *Output          `protobuf:"bytes,9,opt,name=output" json:"output,omitempty"`
	Update          bool             `protobuf:"varint,5,opt,name=update,proto3" json:"update,omitempty"`
	NoArchive       bool             `protobuf:"varint,6,opt,name=no_archive,json=noArchive,proto3" json:"no_archive,omitempty"`
	GcPolicy        *GCPolicy        `protobuf:"bytes,8,opt,name=gc_policy,json=gcPolicy" json:"gc_policy,omitempty"`
}

func (m *CreatePipelineRequest) Reset()                    { *m = CreatePipelineRequest{} }
func (m *CreatePipelineRequest) String() string            { return proto.CompactTextString(m) }
func (*CreatePipelineRequest) ProtoMessage()               {}
func (*CreatePipelineRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{22} }

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

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

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

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

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

func (m *CreatePipelineRequest) GetUpdate() bool {
	if m != nil {
		return m.Update
	}
	return false
}

func (m *CreatePipelineRequest) GetNoArchive() bool {
	if m != nil {
		return m.NoArchive
	}
	return false
}

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

type InspectPipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
}

func (m *InspectPipelineRequest) Reset()                    { *m = InspectPipelineRequest{} }
func (m *InspectPipelineRequest) String() string            { return proto.CompactTextString(m) }
func (*InspectPipelineRequest) ProtoMessage()               {}
func (*InspectPipelineRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{23} }

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

type ListPipelineRequest struct {
}

func (m *ListPipelineRequest) Reset()                    { *m = ListPipelineRequest{} }
func (m *ListPipelineRequest) String() string            { return proto.CompactTextString(m) }
func (*ListPipelineRequest) ProtoMessage()               {}
func (*ListPipelineRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{24} }

type DeletePipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
}

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

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

type StartPipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
}

func (m *StartPipelineRequest) Reset()                    { *m = StartPipelineRequest{} }
func (m *StartPipelineRequest) String() string            { return proto.CompactTextString(m) }
func (*StartPipelineRequest) ProtoMessage()               {}
func (*StartPipelineRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{26} }

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

type StopPipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
}

func (m *StopPipelineRequest) Reset()                    { *m = StopPipelineRequest{} }
func (m *StopPipelineRequest) String() string            { return proto.CompactTextString(m) }
func (*StopPipelineRequest) ProtoMessage()               {}
func (*StopPipelineRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{27} }

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

type RerunPipelineRequest struct {
	Pipeline *Pipeline     `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
	Exclude  []*pfs.Commit `protobuf:"bytes,2,rep,name=exclude" json:"exclude,omitempty"`
	Include  []*pfs.Commit `protobuf:"bytes,3,rep,name=include" json:"include,omitempty"`
}

func (m *RerunPipelineRequest) Reset()                    { *m = RerunPipelineRequest{} }
func (m *RerunPipelineRequest) String() string            { return proto.CompactTextString(m) }
func (*RerunPipelineRequest) ProtoMessage()               {}
func (*RerunPipelineRequest) Descriptor() ([]byte, []int) { return fileDescriptorPps, []int{28} }

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

func (m *RerunPipelineRequest) GetExclude() []*pfs.Commit {
	if m != nil {
		return m.Exclude
	}
	return nil
}

func (m *RerunPipelineRequest) GetInclude() []*pfs.Commit {
	if m != nil {
		return m.Include
	}
	return nil
}

func init() {
	proto.RegisterType((*Secret)(nil), "pps.Secret")
	proto.RegisterType((*Transform)(nil), "pps.Transform")
	proto.RegisterType((*Output)(nil), "pps.Output")
	proto.RegisterType((*Job)(nil), "pps.Job")
	proto.RegisterType((*Service)(nil), "pps.Service")
	proto.RegisterType((*Method)(nil), "pps.Method")
	proto.RegisterType((*JobInput)(nil), "pps.JobInput")
	proto.RegisterType((*ParallelismSpec)(nil), "pps.ParallelismSpec")
	proto.RegisterType((*JobInfo)(nil), "pps.JobInfo")
	proto.RegisterType((*Chunk)(nil), "pps.Chunk")
	proto.RegisterType((*Pod)(nil), "pps.Pod")
	proto.RegisterType((*JobInfos)(nil), "pps.JobInfos")
	proto.RegisterType((*Pipeline)(nil), "pps.Pipeline")
	proto.RegisterType((*PipelineInput)(nil), "pps.PipelineInput")
	proto.RegisterType((*GCPolicy)(nil), "pps.GCPolicy")
	proto.RegisterType((*PipelineInfo)(nil), "pps.PipelineInfo")
	proto.RegisterType((*PipelineInfos)(nil), "pps.PipelineInfos")
	proto.RegisterType((*CreateJobRequest)(nil), "pps.CreateJobRequest")
	proto.RegisterType((*InspectJobRequest)(nil), "pps.InspectJobRequest")
	proto.RegisterType((*ListJobRequest)(nil), "pps.ListJobRequest")
	proto.RegisterType((*DeleteJobRequest)(nil), "pps.DeleteJobRequest")
	proto.RegisterType((*GetLogsRequest)(nil), "pps.GetLogsRequest")
	proto.RegisterType((*CreatePipelineRequest)(nil), "pps.CreatePipelineRequest")
	proto.RegisterType((*InspectPipelineRequest)(nil), "pps.InspectPipelineRequest")
	proto.RegisterType((*ListPipelineRequest)(nil), "pps.ListPipelineRequest")
	proto.RegisterType((*DeletePipelineRequest)(nil), "pps.DeletePipelineRequest")
	proto.RegisterType((*StartPipelineRequest)(nil), "pps.StartPipelineRequest")
	proto.RegisterType((*StopPipelineRequest)(nil), "pps.StopPipelineRequest")
	proto.RegisterType((*RerunPipelineRequest)(nil), "pps.RerunPipelineRequest")
	proto.RegisterEnum("pps.JobState", JobState_name, JobState_value)
	proto.RegisterEnum("pps.Partition", Partition_name, Partition_value)
	proto.RegisterEnum("pps.Incremental", Incremental_name, Incremental_value)
	proto.RegisterEnum("pps.ChunkState", ChunkState_name, ChunkState_value)
	proto.RegisterEnum("pps.PodState", PodState_name, PodState_value)
	proto.RegisterEnum("pps.PipelineState", PipelineState_name, PipelineState_value)
	proto.RegisterEnum("pps.ParallelismSpec_Strategy", ParallelismSpec_Strategy_name, ParallelismSpec_Strategy_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 {
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
	InspectJob(ctx context.Context, in *InspectJobRequest, opts ...grpc.CallOption) (*JobInfo, error)
	ListJob(ctx context.Context, in *ListJobRequest, opts ...grpc.CallOption) (*JobInfos, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error)
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	InspectPipeline(ctx context.Context, in *InspectPipelineRequest, opts ...grpc.CallOption) (*PipelineInfo, error)
	ListPipeline(ctx context.Context, in *ListPipelineRequest, opts ...grpc.CallOption) (*PipelineInfos, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	StartPipeline(ctx context.Context, in *StartPipelineRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	StopPipeline(ctx context.Context, in *StopPipelineRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	RerunPipeline(ctx context.Context, in *RerunPipelineRequest, 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)
}

type aPIClient struct {
	cc *grpc.ClientConn
}

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

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

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

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

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

func (c *aPIClient) GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_API_serviceDesc.Streams[0], c.cc, "/pps.API/GetLogs", opts...)
	if err != nil {
		return nil, err
	}
	x := &aPIGetLogsClient{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_GetLogsClient interface {
	Recv() (*google_protobuf3.BytesValue, error)
	grpc.ClientStream
}

type aPIGetLogsClient struct {
	grpc.ClientStream
}

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

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

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

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

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

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

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

func (c *aPIClient) RerunPipeline(ctx context.Context, in *RerunPipelineRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) {
	out := new(google_protobuf.Empty)
	err := grpc.Invoke(ctx, "/pps.API/RerunPipeline", 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.API/DeleteAll", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for API service

type APIServer interface {
	CreateJob(context.Context, *CreateJobRequest) (*Job, error)
	InspectJob(context.Context, *InspectJobRequest) (*JobInfo, error)
	ListJob(context.Context, *ListJobRequest) (*JobInfos, error)
	DeleteJob(context.Context, *DeleteJobRequest) (*google_protobuf.Empty, error)
	GetLogs(*GetLogsRequest, API_GetLogsServer) error
	CreatePipeline(context.Context, *CreatePipelineRequest) (*google_protobuf.Empty, error)
	InspectPipeline(context.Context, *InspectPipelineRequest) (*PipelineInfo, error)
	ListPipeline(context.Context, *ListPipelineRequest) (*PipelineInfos, error)
	DeletePipeline(context.Context, *DeletePipelineRequest) (*google_protobuf.Empty, error)
	StartPipeline(context.Context, *StartPipelineRequest) (*google_protobuf.Empty, error)
	StopPipeline(context.Context, *StopPipelineRequest) (*google_protobuf.Empty, error)
	RerunPipeline(context.Context, *RerunPipelineRequest) (*google_protobuf.Empty, error)
	// DeleteAll deletes everything
	DeleteAll(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error)
}

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

func _API_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateJobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).CreateJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.API/CreateJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).CreateJob(ctx, req.(*CreateJobRequest))
	}
	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(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.API/InspectJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).InspectJob(ctx, req.(*InspectJobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

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

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

func _API_GetLogs_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetLogsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(APIServer).GetLogs(m, &aPIGetLogsServer{stream})
}

type API_GetLogsServer interface {
	Send(*google_protobuf3.BytesValue) error
	grpc.ServerStream
}

type aPIGetLogsServer struct {
	grpc.ServerStream
}

func (x *aPIGetLogsServer) Send(m *google_protobuf3.BytesValue) error {
	return x.ServerStream.SendMsg(m)
}

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

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

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

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

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

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

func _API_RerunPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RerunPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(APIServer).RerunPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.API/RerunPipeline",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(APIServer).RerunPipeline(ctx, req.(*RerunPipelineRequest))
	}
	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.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)
}

var _API_serviceDesc = grpc.ServiceDesc{
	ServiceName: "pps.API",
	HandlerType: (*APIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateJob",
			Handler:    _API_CreateJob_Handler,
		},
		{
			MethodName: "InspectJob",
			Handler:    _API_InspectJob_Handler,
		},
		{
			MethodName: "ListJob",
			Handler:    _API_ListJob_Handler,
		},
		{
			MethodName: "DeleteJob",
			Handler:    _API_DeleteJob_Handler,
		},
		{
			MethodName: "CreatePipeline",
			Handler:    _API_CreatePipeline_Handler,
		},
		{
			MethodName: "InspectPipeline",
			Handler:    _API_InspectPipeline_Handler,
		},
		{
			MethodName: "ListPipeline",
			Handler:    _API_ListPipeline_Handler,
		},
		{
			MethodName: "DeletePipeline",
			Handler:    _API_DeletePipeline_Handler,
		},
		{
			MethodName: "StartPipeline",
			Handler:    _API_StartPipeline_Handler,
		},
		{
			MethodName: "StopPipeline",
			Handler:    _API_StopPipeline_Handler,
		},
		{
			MethodName: "RerunPipeline",
			Handler:    _API_RerunPipeline_Handler,
		},
		{
			MethodName: "DeleteAll",
			Handler:    _API_DeleteAll_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetLogs",
			Handler:       _API_GetLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "client/pps/pps.proto",
}

func init() { proto.RegisterFile("client/pps/pps.proto", fileDescriptorPps) }

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