blob: ede0de2b0230e01d7263f84204b9da531cb46ddc [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: go.chromium.org/luci/appengine/mapper/internal/tasks/tasks.proto
package tasks
import (
fmt "fmt"
proto "github.com/golang/protobuf/proto"
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
// SplitAndLaunch task splits the key range into shards and kicks off processing
// of each individual shard.
//
// Enqueued transactionally when creating a new mapping job.
type SplitAndLaunch struct {
JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SplitAndLaunch) Reset() { *m = SplitAndLaunch{} }
func (m *SplitAndLaunch) String() string { return proto.CompactTextString(m) }
func (*SplitAndLaunch) ProtoMessage() {}
func (*SplitAndLaunch) Descriptor() ([]byte, []int) {
return fileDescriptor_7c79c318740f2dbc, []int{0}
}
func (m *SplitAndLaunch) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SplitAndLaunch.Unmarshal(m, b)
}
func (m *SplitAndLaunch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SplitAndLaunch.Marshal(b, m, deterministic)
}
func (m *SplitAndLaunch) XXX_Merge(src proto.Message) {
xxx_messageInfo_SplitAndLaunch.Merge(m, src)
}
func (m *SplitAndLaunch) XXX_Size() int {
return xxx_messageInfo_SplitAndLaunch.Size(m)
}
func (m *SplitAndLaunch) XXX_DiscardUnknown() {
xxx_messageInfo_SplitAndLaunch.DiscardUnknown(m)
}
var xxx_messageInfo_SplitAndLaunch proto.InternalMessageInfo
func (m *SplitAndLaunch) GetJobId() int64 {
if m != nil {
return m.JobId
}
return 0
}
// FanOutShards enqueues a bunch of ProcessShard named tasks (one per shard).
//
// Enqueued transactionally by SplitAndLaunch after it has constructed shards.
type FanOutShards struct {
JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *FanOutShards) Reset() { *m = FanOutShards{} }
func (m *FanOutShards) String() string { return proto.CompactTextString(m) }
func (*FanOutShards) ProtoMessage() {}
func (*FanOutShards) Descriptor() ([]byte, []int) {
return fileDescriptor_7c79c318740f2dbc, []int{1}
}
func (m *FanOutShards) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FanOutShards.Unmarshal(m, b)
}
func (m *FanOutShards) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FanOutShards.Marshal(b, m, deterministic)
}
func (m *FanOutShards) XXX_Merge(src proto.Message) {
xxx_messageInfo_FanOutShards.Merge(m, src)
}
func (m *FanOutShards) XXX_Size() int {
return xxx_messageInfo_FanOutShards.Size(m)
}
func (m *FanOutShards) XXX_DiscardUnknown() {
xxx_messageInfo_FanOutShards.DiscardUnknown(m)
}
var xxx_messageInfo_FanOutShards proto.InternalMessageInfo
func (m *FanOutShards) GetJobId() int64 {
if m != nil {
return m.JobId
}
return 0
}
// ProcessShard sequentially reads the entities belonging to a key range
// assigned to a shard and applies the mapper to them.
//
// Upon reaching 1 min mark, relaunches itself, increasing task_num. Thus
// ProcessShard is actually a chain of tasks that runs as long as needed to
// completely process the shard.
type ProcessShard struct {
JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
ShardId int64 `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
TaskNum int64 `protobuf:"varint,3,opt,name=task_num,json=taskNum,proto3" json:"task_num,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ProcessShard) Reset() { *m = ProcessShard{} }
func (m *ProcessShard) String() string { return proto.CompactTextString(m) }
func (*ProcessShard) ProtoMessage() {}
func (*ProcessShard) Descriptor() ([]byte, []int) {
return fileDescriptor_7c79c318740f2dbc, []int{2}
}
func (m *ProcessShard) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProcessShard.Unmarshal(m, b)
}
func (m *ProcessShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ProcessShard.Marshal(b, m, deterministic)
}
func (m *ProcessShard) XXX_Merge(src proto.Message) {
xxx_messageInfo_ProcessShard.Merge(m, src)
}
func (m *ProcessShard) XXX_Size() int {
return xxx_messageInfo_ProcessShard.Size(m)
}
func (m *ProcessShard) XXX_DiscardUnknown() {
xxx_messageInfo_ProcessShard.DiscardUnknown(m)
}
var xxx_messageInfo_ProcessShard proto.InternalMessageInfo
func (m *ProcessShard) GetJobId() int64 {
if m != nil {
return m.JobId
}
return 0
}
func (m *ProcessShard) GetShardId() int64 {
if m != nil {
return m.ShardId
}
return 0
}
func (m *ProcessShard) GetTaskNum() int64 {
if m != nil {
return m.TaskNum
}
return 0
}
// RequestJobStateUpdate is transactionally emitted by ProcessShard when shard's
// state changes.
//
// It eventually (with some throttling) causes UpdateJobState to be emitted,
// which updates the job state based on states of the shards.
type RequestJobStateUpdate struct {
JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
ShardId int64 `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RequestJobStateUpdate) Reset() { *m = RequestJobStateUpdate{} }
func (m *RequestJobStateUpdate) String() string { return proto.CompactTextString(m) }
func (*RequestJobStateUpdate) ProtoMessage() {}
func (*RequestJobStateUpdate) Descriptor() ([]byte, []int) {
return fileDescriptor_7c79c318740f2dbc, []int{3}
}
func (m *RequestJobStateUpdate) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RequestJobStateUpdate.Unmarshal(m, b)
}
func (m *RequestJobStateUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RequestJobStateUpdate.Marshal(b, m, deterministic)
}
func (m *RequestJobStateUpdate) XXX_Merge(src proto.Message) {
xxx_messageInfo_RequestJobStateUpdate.Merge(m, src)
}
func (m *RequestJobStateUpdate) XXX_Size() int {
return xxx_messageInfo_RequestJobStateUpdate.Size(m)
}
func (m *RequestJobStateUpdate) XXX_DiscardUnknown() {
xxx_messageInfo_RequestJobStateUpdate.DiscardUnknown(m)
}
var xxx_messageInfo_RequestJobStateUpdate proto.InternalMessageInfo
func (m *RequestJobStateUpdate) GetJobId() int64 {
if m != nil {
return m.JobId
}
return 0
}
func (m *RequestJobStateUpdate) GetShardId() int64 {
if m != nil {
return m.ShardId
}
return 0
}
// UpdateJobState is emitted after one or more shards have changed their state.
//
// It recalculates the job's state based on state of all its shards. Throttled
// to 0.5 QPS.
type UpdateJobState struct {
JobId int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *UpdateJobState) Reset() { *m = UpdateJobState{} }
func (m *UpdateJobState) String() string { return proto.CompactTextString(m) }
func (*UpdateJobState) ProtoMessage() {}
func (*UpdateJobState) Descriptor() ([]byte, []int) {
return fileDescriptor_7c79c318740f2dbc, []int{4}
}
func (m *UpdateJobState) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateJobState.Unmarshal(m, b)
}
func (m *UpdateJobState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UpdateJobState.Marshal(b, m, deterministic)
}
func (m *UpdateJobState) XXX_Merge(src proto.Message) {
xxx_messageInfo_UpdateJobState.Merge(m, src)
}
func (m *UpdateJobState) XXX_Size() int {
return xxx_messageInfo_UpdateJobState.Size(m)
}
func (m *UpdateJobState) XXX_DiscardUnknown() {
xxx_messageInfo_UpdateJobState.DiscardUnknown(m)
}
var xxx_messageInfo_UpdateJobState proto.InternalMessageInfo
func (m *UpdateJobState) GetJobId() int64 {
if m != nil {
return m.JobId
}
return 0
}
func init() {
proto.RegisterType((*SplitAndLaunch)(nil), "appengine.mapper.internal.tasks.SplitAndLaunch")
proto.RegisterType((*FanOutShards)(nil), "appengine.mapper.internal.tasks.FanOutShards")
proto.RegisterType((*ProcessShard)(nil), "appengine.mapper.internal.tasks.ProcessShard")
proto.RegisterType((*RequestJobStateUpdate)(nil), "appengine.mapper.internal.tasks.RequestJobStateUpdate")
proto.RegisterType((*UpdateJobState)(nil), "appengine.mapper.internal.tasks.UpdateJobState")
}
func init() {
proto.RegisterFile("go.chromium.org/luci/appengine/mapper/internal/tasks/tasks.proto", fileDescriptor_7c79c318740f2dbc)
}
var fileDescriptor_7c79c318740f2dbc = []byte{
// 243 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x90, 0x41, 0x4b, 0x04, 0x21,
0x18, 0x86, 0xd9, 0x96, 0xdd, 0x0d, 0x59, 0x3a, 0x0c, 0x2c, 0x6c, 0xa7, 0x62, 0x20, 0xea, 0xa4,
0x87, 0xfe, 0x40, 0x75, 0x08, 0x36, 0xa2, 0x62, 0x87, 0x2e, 0x75, 0x58, 0x1c, 0x95, 0x19, 0xb7,
0xd1, 0xcf, 0xf4, 0xf3, 0xff, 0x87, 0xca, 0x74, 0x9b, 0xc3, 0x5e, 0xc4, 0x8f, 0xe7, 0xf1, 0x55,
0x5f, 0xf2, 0xd0, 0x01, 0x15, 0xbd, 0x07, 0xa3, 0xa3, 0xa1, 0xe0, 0x3b, 0x36, 0x44, 0xa1, 0x19,
0x77, 0x4e, 0xd9, 0x4e, 0x5b, 0xc5, 0x4c, 0xda, 0x7a, 0xa6, 0x2d, 0x2a, 0x6f, 0xf9, 0xc0, 0x90,
0x87, 0x9f, 0x50, 0x56, 0xea, 0x3c, 0x20, 0x54, 0x57, 0xff, 0x32, 0x2d, 0x32, 0x1d, 0x65, 0x9a,
0xb5, 0xfa, 0x96, 0x5c, 0x34, 0x6e, 0xd0, 0xf8, 0x68, 0xe5, 0x2b, 0x8f, 0x56, 0xf4, 0xd5, 0x86,
0x2c, 0x8f, 0xd0, 0x1e, 0xb4, 0xdc, 0xce, 0xae, 0x67, 0x77, 0xf3, 0xfd, 0xe2, 0x08, 0xed, 0x4e,
0xd6, 0x37, 0x64, 0xfd, 0xcc, 0xed, 0x7b, 0xc4, 0xa6, 0xe7, 0x5e, 0x86, 0x29, 0xed, 0x9b, 0xac,
0x3f, 0x3c, 0x08, 0x15, 0x42, 0xf6, 0x26, 0xb4, 0xea, 0x92, 0x9c, 0x87, 0xc4, 0x13, 0x38, 0xcb,
0x60, 0x95, 0xe7, 0x82, 0xd2, 0xd3, 0x0e, 0x36, 0x9a, 0xed, 0xbc, 0xa0, 0x34, 0xbf, 0x45, 0x53,
0xef, 0xc8, 0x66, 0xaf, 0x7e, 0xa3, 0x0a, 0xf8, 0x02, 0x6d, 0x83, 0x1c, 0xd5, 0xa7, 0x93, 0x1c,
0xd5, 0xe9, 0xb7, 0xa4, 0x7f, 0x97, 0xb3, 0x63, 0xd2, 0x44, 0xc6, 0xd3, 0xea, 0x6b, 0x91, 0x9b,
0x6a, 0x97, 0xb9, 0xd1, 0xfb, 0xbf, 0x00, 0x00, 0x00, 0xff, 0xff, 0xbf, 0xed, 0xd7, 0xd8, 0x95,
0x01, 0x00, 0x00,
}