blob: 9569f704345074596f4f7c063430af7378a3025e [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: go.chromium.org/luci/appengine/mapper/messages.proto
package mapper
import (
fmt "fmt"
proto "github.com/golang/protobuf/proto"
timestamp "github.com/golang/protobuf/ptypes/timestamp"
math "math"
)
// 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.ProtoPackageIsVersion3 // please upgrade the proto package
// State of a job or one of its shards.
type State int32
const (
State_STATE_UNSPECIFIED State = 0
State_STARTING State = 1
State_RUNNING State = 2
State_ABORTING State = 3
State_SUCCESS State = 4
State_FAIL State = 5
State_ABORTED State = 6
)
var State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "STARTING",
2: "RUNNING",
3: "ABORTING",
4: "SUCCESS",
5: "FAIL",
6: "ABORTED",
}
var State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"STARTING": 1,
"RUNNING": 2,
"ABORTING": 3,
"SUCCESS": 4,
"FAIL": 5,
"ABORTED": 6,
}
func (x State) String() string {
return proto.EnumName(State_name, int32(x))
}
func (State) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_009da4539d0ef669, []int{0}
}
// Information about some single shard of a job.
type ShardInfo struct {
Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
State State `protobuf:"varint,2,opt,name=state,proto3,enum=appengine.mapper.messages.State" json:"state,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
Created *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
Updated *timestamp.Timestamp `protobuf:"bytes,5,opt,name=updated,proto3" json:"updated,omitempty"`
Eta *timestamp.Timestamp `protobuf:"bytes,6,opt,name=eta,proto3" json:"eta,omitempty"`
ProcessedEntities int64 `protobuf:"varint,7,opt,name=processed_entities,json=processedEntities,proto3" json:"processed_entities,omitempty"`
TotalEntities int64 `protobuf:"varint,8,opt,name=total_entities,json=totalEntities,proto3" json:"total_entities,omitempty"`
EntitiesPerSec float32 `protobuf:"fixed32,9,opt,name=entities_per_sec,json=entitiesPerSec,proto3" json:"entities_per_sec,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ShardInfo) Reset() { *m = ShardInfo{} }
func (m *ShardInfo) String() string { return proto.CompactTextString(m) }
func (*ShardInfo) ProtoMessage() {}
func (*ShardInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_009da4539d0ef669, []int{0}
}
func (m *ShardInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ShardInfo.Unmarshal(m, b)
}
func (m *ShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ShardInfo.Marshal(b, m, deterministic)
}
func (m *ShardInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_ShardInfo.Merge(m, src)
}
func (m *ShardInfo) XXX_Size() int {
return xxx_messageInfo_ShardInfo.Size(m)
}
func (m *ShardInfo) XXX_DiscardUnknown() {
xxx_messageInfo_ShardInfo.DiscardUnknown(m)
}
var xxx_messageInfo_ShardInfo proto.InternalMessageInfo
func (m *ShardInfo) GetIndex() int32 {
if m != nil {
return m.Index
}
return 0
}
func (m *ShardInfo) GetState() State {
if m != nil {
return m.State
}
return State_STATE_UNSPECIFIED
}
func (m *ShardInfo) GetError() string {
if m != nil {
return m.Error
}
return ""
}
func (m *ShardInfo) GetCreated() *timestamp.Timestamp {
if m != nil {
return m.Created
}
return nil
}
func (m *ShardInfo) GetUpdated() *timestamp.Timestamp {
if m != nil {
return m.Updated
}
return nil
}
func (m *ShardInfo) GetEta() *timestamp.Timestamp {
if m != nil {
return m.Eta
}
return nil
}
func (m *ShardInfo) GetProcessedEntities() int64 {
if m != nil {
return m.ProcessedEntities
}
return 0
}
func (m *ShardInfo) GetTotalEntities() int64 {
if m != nil {
return m.TotalEntities
}
return 0
}
func (m *ShardInfo) GetEntitiesPerSec() float32 {
if m != nil {
return m.EntitiesPerSec
}
return 0
}
// Information about a job.
type JobInfo struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
State State `protobuf:"varint,2,opt,name=state,proto3,enum=appengine.mapper.messages.State" json:"state,omitempty"`
Created *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"`
Updated *timestamp.Timestamp `protobuf:"bytes,4,opt,name=updated,proto3" json:"updated,omitempty"`
Eta *timestamp.Timestamp `protobuf:"bytes,5,opt,name=eta,proto3" json:"eta,omitempty"`
ProcessedEntities int64 `protobuf:"varint,6,opt,name=processed_entities,json=processedEntities,proto3" json:"processed_entities,omitempty"`
TotalEntities int64 `protobuf:"varint,7,opt,name=total_entities,json=totalEntities,proto3" json:"total_entities,omitempty"`
EntitiesPerSec float32 `protobuf:"fixed32,8,opt,name=entities_per_sec,json=entitiesPerSec,proto3" json:"entities_per_sec,omitempty"`
Shards []*ShardInfo `protobuf:"bytes,20,rep,name=shards,proto3" json:"shards,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *JobInfo) Reset() { *m = JobInfo{} }
func (m *JobInfo) String() string { return proto.CompactTextString(m) }
func (*JobInfo) ProtoMessage() {}
func (*JobInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_009da4539d0ef669, []int{1}
}
func (m *JobInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_JobInfo.Unmarshal(m, b)
}
func (m *JobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_JobInfo.Marshal(b, m, deterministic)
}
func (m *JobInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_JobInfo.Merge(m, src)
}
func (m *JobInfo) XXX_Size() int {
return xxx_messageInfo_JobInfo.Size(m)
}
func (m *JobInfo) XXX_DiscardUnknown() {
xxx_messageInfo_JobInfo.DiscardUnknown(m)
}
var xxx_messageInfo_JobInfo proto.InternalMessageInfo
func (m *JobInfo) GetId() int64 {
if m != nil {
return m.Id
}
return 0
}
func (m *JobInfo) GetState() State {
if m != nil {
return m.State
}
return State_STATE_UNSPECIFIED
}
func (m *JobInfo) GetCreated() *timestamp.Timestamp {
if m != nil {
return m.Created
}
return nil
}
func (m *JobInfo) GetUpdated() *timestamp.Timestamp {
if m != nil {
return m.Updated
}
return nil
}
func (m *JobInfo) GetEta() *timestamp.Timestamp {
if m != nil {
return m.Eta
}
return nil
}
func (m *JobInfo) GetProcessedEntities() int64 {
if m != nil {
return m.ProcessedEntities
}
return 0
}
func (m *JobInfo) GetTotalEntities() int64 {
if m != nil {
return m.TotalEntities
}
return 0
}
func (m *JobInfo) GetEntitiesPerSec() float32 {
if m != nil {
return m.EntitiesPerSec
}
return 0
}
func (m *JobInfo) GetShards() []*ShardInfo {
if m != nil {
return m.Shards
}
return nil
}
func init() {
proto.RegisterEnum("appengine.mapper.messages.State", State_name, State_value)
proto.RegisterType((*ShardInfo)(nil), "appengine.mapper.messages.ShardInfo")
proto.RegisterType((*JobInfo)(nil), "appengine.mapper.messages.JobInfo")
}
func init() {
proto.RegisterFile("go.chromium.org/luci/appengine/mapper/messages.proto", fileDescriptor_009da4539d0ef669)
}
var fileDescriptor_009da4539d0ef669 = []byte{
// 469 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x93, 0xcf, 0x6e, 0xd3, 0x40,
0x10, 0x87, 0xb1, 0x1d, 0xff, 0xc9, 0x06, 0x22, 0x77, 0x55, 0x24, 0xd3, 0x0b, 0x56, 0x05, 0x92,
0x85, 0x60, 0x2d, 0x85, 0x8a, 0x13, 0x97, 0x34, 0x75, 0x91, 0x11, 0x0a, 0xd5, 0xda, 0xb9, 0x70,
0x89, 0x1c, 0x7b, 0xea, 0x5a, 0xc4, 0x5e, 0x6b, 0x77, 0x23, 0xf1, 0x0a, 0x3c, 0x0a, 0x6f, 0x89,
0xd6, 0x8e, 0x03, 0x07, 0xa0, 0xa5, 0xbd, 0x65, 0x66, 0xbe, 0x5f, 0x3c, 0xfa, 0xc6, 0x46, 0x67,
0x25, 0x23, 0xf9, 0x0d, 0x67, 0x75, 0xb5, 0xab, 0x09, 0xe3, 0x65, 0xb8, 0xdd, 0xe5, 0x55, 0x98,
0xb5, 0x2d, 0x34, 0x65, 0xd5, 0x40, 0x58, 0xab, 0x9f, 0x3c, 0xac, 0x41, 0x88, 0xac, 0x04, 0x41,
0x5a, 0xce, 0x24, 0xc3, 0xcf, 0x0e, 0x00, 0xe9, 0x01, 0x32, 0x00, 0x27, 0xcf, 0x4b, 0xc6, 0xca,
0x2d, 0x84, 0x1d, 0xb8, 0xd9, 0x5d, 0x87, 0xb2, 0xaa, 0x41, 0xc8, 0xac, 0x6e, 0xfb, 0xec, 0xe9,
0x77, 0x03, 0x8d, 0x93, 0x9b, 0x8c, 0x17, 0x71, 0x73, 0xcd, 0xf0, 0x31, 0x32, 0xab, 0xa6, 0x80,
0x6f, 0x9e, 0xe6, 0x6b, 0x81, 0x49, 0xfb, 0x02, 0xbf, 0x43, 0xa6, 0x90, 0x99, 0x04, 0x4f, 0xf7,
0xb5, 0x60, 0x3a, 0xf3, 0xc9, 0x5f, 0x9f, 0x47, 0x12, 0xc5, 0xd1, 0x1e, 0x57, 0xff, 0x06, 0x9c,
0x33, 0xee, 0x19, 0xbe, 0x16, 0x8c, 0x69, 0x5f, 0xe0, 0x33, 0x64, 0xe7, 0x1c, 0x32, 0x09, 0x85,
0x37, 0xf2, 0xb5, 0x60, 0x32, 0x3b, 0x21, 0xfd, 0x92, 0x64, 0x58, 0x92, 0xa4, 0xc3, 0x92, 0x74,
0x40, 0x55, 0x6a, 0xd7, 0x16, 0x5d, 0xca, 0xbc, 0x3d, 0xb5, 0x47, 0xf1, 0x6b, 0x64, 0x80, 0xcc,
0x3c, 0xeb, 0xd6, 0x84, 0xc2, 0xf0, 0x1b, 0x84, 0x5b, 0xce, 0x72, 0x10, 0x02, 0x8a, 0x35, 0x34,
0xb2, 0x92, 0x15, 0x08, 0xcf, 0xf6, 0xb5, 0xc0, 0xa0, 0x47, 0x87, 0x49, 0xb4, 0x1f, 0xe0, 0x97,
0x68, 0x2a, 0x99, 0xcc, 0xb6, 0xbf, 0x50, 0xa7, 0x43, 0x9f, 0x74, 0xdd, 0x03, 0x16, 0x20, 0x77,
0x00, 0xd6, 0x2d, 0xf0, 0xb5, 0x80, 0xdc, 0x1b, 0xfb, 0x5a, 0xa0, 0xd3, 0xe9, 0xd0, 0xbf, 0x02,
0x9e, 0x40, 0x7e, 0xfa, 0xc3, 0x40, 0xf6, 0x47, 0xb6, 0xe9, 0x2e, 0x31, 0x45, 0x7a, 0x55, 0x74,
0x67, 0x30, 0xa8, 0x5e, 0x15, 0xf7, 0xbe, 0xc1, 0x6f, 0xb6, 0x8d, 0x7b, 0xd9, 0x1e, 0xfd, 0xb7,
0x6d, 0xf3, 0x21, 0xb6, 0xad, 0xbb, 0xdb, 0xb6, 0xef, 0x6a, 0xdb, 0xf9, 0x93, 0x6d, 0xfc, 0x1e,
0x59, 0x42, 0xbd, 0xf8, 0xc2, 0x3b, 0xf6, 0x8d, 0x60, 0x32, 0x7b, 0xf1, 0x2f, 0xa5, 0xc3, 0x17,
0x42, 0xf7, 0x99, 0x57, 0x5f, 0x91, 0xd9, 0x79, 0xc6, 0x4f, 0xd1, 0x51, 0x92, 0xce, 0xd3, 0x68,
0xbd, 0x5a, 0x26, 0x57, 0xd1, 0x22, 0xbe, 0x8c, 0xa3, 0x0b, 0xf7, 0x11, 0x7e, 0x8c, 0x9c, 0x24,
0x9d, 0xd3, 0x34, 0x5e, 0x7e, 0x70, 0x35, 0x3c, 0x41, 0x36, 0x5d, 0x2d, 0x97, 0xaa, 0xd0, 0xd5,
0x68, 0x7e, 0xfe, 0xb9, 0x1f, 0x19, 0x6a, 0x94, 0xac, 0x16, 0x8b, 0x28, 0x49, 0xdc, 0x11, 0x76,
0xd0, 0xe8, 0x72, 0x1e, 0x7f, 0x72, 0x4d, 0xd5, 0xee, 0xa0, 0xe8, 0xc2, 0xb5, 0xce, 0x9d, 0x2f,
0x56, 0xbf, 0xd1, 0xc6, 0xea, 0x6c, 0xbe, 0xfd, 0x19, 0x00, 0x00, 0xff, 0xff, 0xe6, 0x19, 0xff,
0x57, 0x29, 0x04, 0x00, 0x00,
}