pps.pb.go

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

/*
Package pps is a generated protocol buffer package.

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

It has these top-level messages:
	StartPodRequest
	StartPodResponse
	FinishPodRequest
	FinishPodResponse
	ContinuePodRequest
	ContinuePodResponse
*/
package pps

import proto "github.com/gogo/protobuf/proto"
import fmt "fmt"
import math "math"
import _ "github.com/gogo/protobuf/gogoproto"
import fuse "github.com/pachyderm/pachyderm/src/server/pfs/fuse"
import pps1 "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 StartPodRequest struct {
	Job     *pps1.Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"`
	PodName string    `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
}

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

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

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

type StartPodResponse struct {
	ChunkID      string              `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	Transform    *pps1.Transform     `protobuf:"bytes,2,opt,name=transform" json:"transform,omitempty"`
	CommitMounts []*fuse.CommitMount `protobuf:"bytes,3,rep,name=commit_mounts,json=commitMounts" json:"commit_mounts,omitempty"`
}

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

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

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

func (m *StartPodResponse) GetCommitMounts() []*fuse.CommitMount {
	if m != nil {
		return m.CommitMounts
	}
	return nil
}

type FinishPodRequest struct {
	ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	Success bool   `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
}

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

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

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

func (m *FinishPodRequest) GetSuccess() bool {
	if m != nil {
		return m.Success
	}
	return false
}

type FinishPodResponse struct {
	// If restart is true, the pod is expected to exit with a non-zero code
	// so that k8s knows to reschedule the pod.
	Restart bool `protobuf:"varint,1,opt,name=restart,proto3" json:"restart,omitempty"`
}

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

func (m *FinishPodResponse) GetRestart() bool {
	if m != nil {
		return m.Restart
	}
	return false
}

type ContinuePodRequest struct {
	ChunkID string `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	PodName string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
}

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

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

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

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

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

func (m *ContinuePodResponse) GetRestart() bool {
	if m != nil {
		return m.Restart
	}
	return false
}

func init() {
	proto.RegisterType((*StartPodRequest)(nil), "pps.StartPodRequest")
	proto.RegisterType((*StartPodResponse)(nil), "pps.StartPodResponse")
	proto.RegisterType((*FinishPodRequest)(nil), "pps.FinishPodRequest")
	proto.RegisterType((*FinishPodResponse)(nil), "pps.FinishPodResponse")
	proto.RegisterType((*ContinuePodRequest)(nil), "pps.ContinuePodRequest")
	proto.RegisterType((*ContinuePodResponse)(nil), "pps.ContinuePodResponse")
}

// 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 InternalPodAPI service

type InternalPodAPIClient interface {
	StartPod(ctx context.Context, in *StartPodRequest, opts ...grpc.CallOption) (*StartPodResponse, error)
	ContinuePod(ctx context.Context, in *ContinuePodRequest, opts ...grpc.CallOption) (*ContinuePodResponse, error)
	FinishPod(ctx context.Context, in *FinishPodRequest, opts ...grpc.CallOption) (*FinishPodResponse, error)
}

type internalPodAPIClient struct {
	cc *grpc.ClientConn
}

func NewInternalPodAPIClient(cc *grpc.ClientConn) InternalPodAPIClient {
	return &internalPodAPIClient{cc}
}

func (c *internalPodAPIClient) StartPod(ctx context.Context, in *StartPodRequest, opts ...grpc.CallOption) (*StartPodResponse, error) {
	out := new(StartPodResponse)
	err := grpc.Invoke(ctx, "/pps.InternalPodAPI/StartPod", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *internalPodAPIClient) ContinuePod(ctx context.Context, in *ContinuePodRequest, opts ...grpc.CallOption) (*ContinuePodResponse, error) {
	out := new(ContinuePodResponse)
	err := grpc.Invoke(ctx, "/pps.InternalPodAPI/ContinuePod", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *internalPodAPIClient) FinishPod(ctx context.Context, in *FinishPodRequest, opts ...grpc.CallOption) (*FinishPodResponse, error) {
	out := new(FinishPodResponse)
	err := grpc.Invoke(ctx, "/pps.InternalPodAPI/FinishPod", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for InternalPodAPI service

type InternalPodAPIServer interface {
	StartPod(context.Context, *StartPodRequest) (*StartPodResponse, error)
	ContinuePod(context.Context, *ContinuePodRequest) (*ContinuePodResponse, error)
	FinishPod(context.Context, *FinishPodRequest) (*FinishPodResponse, error)
}

func RegisterInternalPodAPIServer(s *grpc.Server, srv InternalPodAPIServer) {
	s.RegisterService(&_InternalPodAPI_serviceDesc, srv)
}

func _InternalPodAPI_StartPod_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StartPodRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(InternalPodAPIServer).StartPod(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.InternalPodAPI/StartPod",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(InternalPodAPIServer).StartPod(ctx, req.(*StartPodRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _InternalPodAPI_ContinuePod_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ContinuePodRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(InternalPodAPIServer).ContinuePod(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.InternalPodAPI/ContinuePod",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(InternalPodAPIServer).ContinuePod(ctx, req.(*ContinuePodRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _InternalPodAPI_FinishPod_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FinishPodRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(InternalPodAPIServer).FinishPod(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pps.InternalPodAPI/FinishPod",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(InternalPodAPIServer).FinishPod(ctx, req.(*FinishPodRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _InternalPodAPI_serviceDesc = grpc.ServiceDesc{
	ServiceName: "pps.InternalPodAPI",
	HandlerType: (*InternalPodAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartPod",
			Handler:    _InternalPodAPI_StartPod_Handler,
		},
		{
			MethodName: "ContinuePod",
			Handler:    _InternalPodAPI_ContinuePod_Handler,
		},
		{
			MethodName: "FinishPod",
			Handler:    _InternalPodAPI_FinishPod_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "server/pps/pps.proto",
}

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

var fileDescriptorPps = []byte{
	// 419 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xac, 0x53, 0xcd, 0xae, 0x93, 0x40,
	0x14, 0x16, 0x89, 0x02, 0x07, 0xbd, 0xde, 0x3b, 0xa2, 0x22, 0x1b, 0x1b, 0x16, 0x86, 0x85, 0x96,
	0x04, 0x13, 0x13, 0x13, 0x37, 0xb6, 0xc6, 0x88, 0x89, 0xa6, 0x19, 0x4d, 0x4c, 0xdc, 0x34, 0x14,
	0xa6, 0xf7, 0xa2, 0x97, 0x39, 0xe3, 0xcc, 0xe0, 0xf3, 0xf8, 0x42, 0xbe, 0x82, 0x0b, 0x9f, 0xc4,
	0xcc, 0xf4, 0x72, 0xdb, 0xd2, 0x18, 0x5d, 0xb8, 0x80, 0x70, 0xbe, 0xef, 0xcc, 0xf7, 0x9d, 0x9f,
	0x01, 0x22, 0xc5, 0xe4, 0x37, 0x26, 0x73, 0x21, 0x94, 0x79, 0xa6, 0x42, 0xa2, 0x46, 0xe2, 0x0a,
	0xa1, 0x92, 0xe8, 0x14, 0x4f, 0xd1, 0xc6, 0xb9, 0xf9, 0xda, 0x50, 0x49, 0x32, 0x1c, 0x58, 0xab,
	0x7c, 0xdd, 0x2b, 0x66, 0x5f, 0x17, 0x5c, 0x54, 0x9f, 0xb7, 0x8c, 0xeb, 0x7d, 0xb1, 0xf4, 0x35,
	0xdc, 0x7a, 0xaf, 0x2b, 0xa9, 0x17, 0xd8, 0x50, 0xf6, 0xb5, 0x67, 0x4a, 0x93, 0x04, 0xdc, 0xcf,
	0xb8, 0x8a, 0x9d, 0x89, 0x93, 0x85, 0x85, 0x3f, 0x35, 0xb9, 0x6f, 0x70, 0x45, 0x0d, 0x48, 0xee,
	0x83, 0x2f, 0xb0, 0x59, 0xf2, 0xaa, 0x63, 0xf1, 0xd5, 0x89, 0x93, 0x05, 0xd4, 0x13, 0xd8, 0xbc,
	0xab, 0x3a, 0x96, 0x7e, 0x77, 0xe0, 0x78, 0x2b, 0xa5, 0x04, 0x72, 0xc5, 0xc8, 0x43, 0xf0, 0xeb,
	0xb3, 0x9e, 0x7f, 0x59, 0xb6, 0x8d, 0x15, 0x0c, 0x66, 0xe1, 0xaf, 0x9f, 0x0f, 0xbc, 0xb9, 0xc1,
	0xca, 0x97, 0xd4, 0xb3, 0x64, 0xd9, 0x90, 0x47, 0x10, 0x68, 0x59, 0x71, 0xb5, 0x46, 0xd9, 0x59,
	0xe1, 0xb0, 0x38, 0xb2, 0xce, 0x1f, 0x06, 0x94, 0x6e, 0x13, 0xc8, 0x53, 0xb8, 0x59, 0x63, 0xd7,
	0xb5, 0x7a, 0xd9, 0x61, 0xcf, 0xb5, 0x8a, 0xdd, 0x89, 0x9b, 0x85, 0xc5, 0xc9, 0xd4, 0xb6, 0x3b,
	0xb7, 0xd4, 0x5b, 0xc3, 0xd0, 0x1b, 0xf5, 0x36, 0x50, 0x29, 0xc2, 0xf1, 0xab, 0x96, 0xb7, 0xea,
	0x6c, 0xa7, 0xdb, 0x7f, 0xad, 0xf0, 0xcf, 0x9d, 0x93, 0x18, 0x3c, 0xd5, 0xd7, 0x35, 0x53, 0xa6,
	0x10, 0x27, 0xf3, 0xe9, 0x10, 0xa6, 0x8f, 0xe1, 0x64, 0xc7, 0xf0, 0x62, 0x26, 0x31, 0x78, 0x92,
	0x29, 0x33, 0x29, 0x6b, 0xe8, 0xd3, 0x21, 0x4c, 0x3f, 0x02, 0x99, 0x23, 0xd7, 0x2d, 0xef, 0xd9,
	0x7f, 0xad, 0x30, 0xcd, 0xe1, 0xf6, 0x9e, 0xf0, 0xdf, 0x2a, 0x29, 0x7e, 0x38, 0x70, 0x54, 0x72,
	0xcd, 0x24, 0xaf, 0xce, 0x17, 0xd8, 0xbc, 0x58, 0x94, 0xe4, 0x19, 0xf8, 0xc3, 0x7a, 0x49, 0x64,
	0x77, 0x33, 0xba, 0x38, 0xc9, 0x9d, 0x11, 0xba, 0x71, 0x49, 0xaf, 0x90, 0x19, 0x84, 0x3b, 0xf6,
	0xe4, 0x9e, 0xcd, 0x3b, 0xec, 0x34, 0x89, 0x0f, 0x89, 0x4b, 0x8d, 0xe7, 0x10, 0x5c, 0x8e, 0x92,
	0x6c, 0x9c, 0xc6, 0xbb, 0x4c, 0xee, 0x8e, 0xe1, 0xe1, 0xf4, 0xec, 0xda, 0x27, 0xf3, 0xd7, 0xac,
	0xae, 0xdb, 0x4b, 0xff, 0xe4, 0x77, 0x00, 0x00, 0x00, 0xff, 0xff, 0xcd, 0xe9, 0x5e, 0x05, 0x59,
	0x03, 0x00, 0x00,
}