Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #878 from influxdata/fix/protoc-gomod 

fix(task/backend): copy gogo.proto into repo
pull/10616/head
Chris Goller 2018-09-26 00:35:29 -05:00 committed by GitHub
parent c6821e3f71 a64b86399f
commit 0cae0deb2f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 277 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

136
task/backend/internal/gogo.proto Normal file
View File

@ -0,0 +1,136 @@
// Protocol Buffers for Go with Gadgets
//
// Copyright (c) 2013, The GoGo Authors. All rights reserved.
// http://github.com/gogo/protobuf
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are
// met:
//
// * Redistributions of source code must retain the above copyright
// notice, this list of conditions and the following disclaimer.
// * Redistributions in binary form must reproduce the above
// copyright notice, this list of conditions and the following disclaimer
// in the documentation and/or other materials provided with the
// distribution.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
syntax = "proto2";
package gogoproto;
import "google/protobuf/descriptor.proto";
option java_package = "com.google.protobuf";
option java_outer_classname = "GoGoProtos";
option go_package = "github.com/gogo/protobuf/gogoproto";
extend google.protobuf.EnumOptions {
optional bool goproto_enum_prefix = 62001;
optional bool goproto_enum_stringer = 62021;
optional bool enum_stringer = 62022;
optional string enum_customname = 62023;
optional bool enumdecl = 62024;
}
extend google.protobuf.EnumValueOptions {
optional string enumvalue_customname = 66001;
}
extend google.protobuf.FileOptions {
optional bool goproto_getters_all = 63001;
optional bool goproto_enum_prefix_all = 63002;
optional bool goproto_stringer_all = 63003;
optional bool verbose_equal_all = 63004;
optional bool face_all = 63005;
optional bool gostring_all = 63006;
optional bool populate_all = 63007;
optional bool stringer_all = 63008;
optional bool onlyone_all = 63009;
optional bool equal_all = 63013;
optional bool description_all = 63014;
optional bool testgen_all = 63015;
optional bool benchgen_all = 63016;
optional bool marshaler_all = 63017;
optional bool unmarshaler_all = 63018;
optional bool stable_marshaler_all = 63019;
optional bool sizer_all = 63020;
optional bool goproto_enum_stringer_all = 63021;
optional bool enum_stringer_all = 63022;
optional bool unsafe_marshaler_all = 63023;
optional bool unsafe_unmarshaler_all = 63024;
optional bool goproto_extensions_map_all = 63025;
optional bool goproto_unrecognized_all = 63026;
optional bool gogoproto_import = 63027;
optional bool protosizer_all = 63028;
optional bool compare_all = 63029;
optional bool typedecl_all = 63030;
optional bool enumdecl_all = 63031;
optional bool goproto_registration = 63032;
optional bool messagename_all = 63033;
}
extend google.protobuf.MessageOptions {
optional bool goproto_getters = 64001;
optional bool goproto_stringer = 64003;
optional bool verbose_equal = 64004;
optional bool face = 64005;
optional bool gostring = 64006;
optional bool populate = 64007;
optional bool stringer = 67008;
optional bool onlyone = 64009;
optional bool equal = 64013;
optional bool description = 64014;
optional bool testgen = 64015;
optional bool benchgen = 64016;
optional bool marshaler = 64017;
optional bool unmarshaler = 64018;
optional bool stable_marshaler = 64019;
optional bool sizer = 64020;
optional bool unsafe_marshaler = 64023;
optional bool unsafe_unmarshaler = 64024;
optional bool goproto_extensions_map = 64025;
optional bool goproto_unrecognized = 64026;
optional bool protosizer = 64028;
optional bool compare = 64029;
optional bool typedecl = 64030;
optional bool messagename = 64033;
}
extend google.protobuf.FieldOptions {
optional bool nullable = 65001;
optional bool embed = 65002;
optional string customtype = 65003;
optional string customname = 65004;
optional string jsontag = 65005;
optional string moretags = 65006;
optional string casttype = 65007;
optional string castkey = 65008;
optional string castvalue = 65009;
optional bool stdtime = 65010;
optional bool stdduration = 65011;
}

200
task/backend/meta.pb.go
View File

@ -1,17 +1,6 @@
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: meta.proto
/*
Package backend is a generated protocol buffer package.
It is generated from these files:
meta.proto
It has these top-level messages:
StoreTaskMeta
StoreTaskMetaRun
StoreTaskMetaManualRun
*/
package backend
import proto "github.com/gogo/protobuf/proto"
@ -46,14 +35,44 @@ type StoreTaskMeta struct {
// effective_cron is the effective cron string as reported by the task's options.
EffectiveCron string `protobuf:"bytes,5,opt,name=effective_cron,json=effectiveCron,proto3" json:"effective_cron,omitempty"`
// Task's configured delay, in seconds.
Delay int32 `protobuf:"varint,6,opt,name=delay,proto3" json:"delay,omitempty"`
ManualRuns []*StoreTaskMetaManualRun `protobuf:"bytes,16,rep,name=manual_runs,json=manualRuns" json:"manual_runs,omitempty"`
Delay int32 `protobuf:"varint,6,opt,name=delay,proto3" json:"delay,omitempty"`
ManualRuns []*StoreTaskMetaManualRun `protobuf:"bytes,16,rep,name=manual_runs,json=manualRuns" json:"manual_runs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StoreTaskMeta) Reset() { *m = StoreTaskMeta{} }
func (m *StoreTaskMeta) String() string { return proto.CompactTextString(m) }
func (*StoreTaskMeta) ProtoMessage() {}
func (*StoreTaskMeta) Descriptor() ([]byte, []int) { return fileDescriptorMeta, []int{0} }
func (m *StoreTaskMeta) Reset() { *m = StoreTaskMeta{} }
func (m *StoreTaskMeta) String() string { return proto.CompactTextString(m) }
func (*StoreTaskMeta) ProtoMessage() {}
func (*StoreTaskMeta) Descriptor() ([]byte, []int) {
return fileDescriptor_meta_2b44cf76b296d0c3, []int{0}
}
func (m *StoreTaskMeta) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *StoreTaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_StoreTaskMeta.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *StoreTaskMeta) XXX_Merge(src proto.Message) {
xxx_messageInfo_StoreTaskMeta.Merge(dst, src)
}
func (m *StoreTaskMeta) XXX_Size() int {
return m.Size()
}
func (m *StoreTaskMeta) XXX_DiscardUnknown() {
xxx_messageInfo_StoreTaskMeta.DiscardUnknown(m)
}
var xxx_messageInfo_StoreTaskMeta proto.InternalMessageInfo
func (m *StoreTaskMeta) GetMaxConcurrency() int32 {
if m != nil {
@ -115,13 +134,43 @@ type StoreTaskMetaRun struct {
RangeEnd int64 `protobuf:"varint,5,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
// requested_at is the unix timestamp indicating when this run was requested.
// It is the same value as the "parent" StoreTaskMetaManualRun, if this run was the result of a manual request.
RequestedAt int64 `protobuf:"varint,6,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
RequestedAt int64 `protobuf:"varint,6,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StoreTaskMetaRun) Reset() { *m = StoreTaskMetaRun{} }
func (m *StoreTaskMetaRun) String() string { return proto.CompactTextString(m) }
func (*StoreTaskMetaRun) ProtoMessage() {}
func (*StoreTaskMetaRun) Descriptor() ([]byte, []int) { return fileDescriptorMeta, []int{1} }
func (m *StoreTaskMetaRun) Reset() { *m = StoreTaskMetaRun{} }
func (m *StoreTaskMetaRun) String() string { return proto.CompactTextString(m) }
func (*StoreTaskMetaRun) ProtoMessage() {}
func (*StoreTaskMetaRun) Descriptor() ([]byte, []int) {
return fileDescriptor_meta_2b44cf76b296d0c3, []int{1}
}
func (m *StoreTaskMetaRun) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *StoreTaskMetaRun) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_StoreTaskMetaRun.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *StoreTaskMetaRun) XXX_Merge(src proto.Message) {
xxx_messageInfo_StoreTaskMetaRun.Merge(dst, src)
}
func (m *StoreTaskMetaRun) XXX_Size() int {
return m.Size()
}
func (m *StoreTaskMetaRun) XXX_DiscardUnknown() {
xxx_messageInfo_StoreTaskMetaRun.DiscardUnknown(m)
}
var xxx_messageInfo_StoreTaskMetaRun proto.InternalMessageInfo
func (m *StoreTaskMetaRun) GetNow() int64 {
if m != nil {
@ -175,13 +224,43 @@ type StoreTaskMetaManualRun struct {
// latest_completed is the timestamp of the latest completed run from this queue.
LatestCompleted int64 `protobuf:"varint,3,opt,name=latest_completed,json=latestCompleted,proto3" json:"latest_completed,omitempty"`
// requested_at is the unix timestamp indicating when this run was requested.
RequestedAt int64 `protobuf:"varint,4,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
RequestedAt int64 `protobuf:"varint,4,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StoreTaskMetaManualRun) Reset() { *m = StoreTaskMetaManualRun{} }
func (m *StoreTaskMetaManualRun) String() string { return proto.CompactTextString(m) }
func (*StoreTaskMetaManualRun) ProtoMessage() {}
func (*StoreTaskMetaManualRun) Descriptor() ([]byte, []int) { return fileDescriptorMeta, []int{2} }
func (m *StoreTaskMetaManualRun) Reset() { *m = StoreTaskMetaManualRun{} }
func (m *StoreTaskMetaManualRun) String() string { return proto.CompactTextString(m) }
func (*StoreTaskMetaManualRun) ProtoMessage() {}
func (*StoreTaskMetaManualRun) Descriptor() ([]byte, []int) {
return fileDescriptor_meta_2b44cf76b296d0c3, []int{2}
}
func (m *StoreTaskMetaManualRun) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *StoreTaskMetaManualRun) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_StoreTaskMetaManualRun.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *StoreTaskMetaManualRun) XXX_Merge(src proto.Message) {
xxx_messageInfo_StoreTaskMetaManualRun.Merge(dst, src)
}
func (m *StoreTaskMetaManualRun) XXX_Size() int {
return m.Size()
}
func (m *StoreTaskMetaManualRun) XXX_DiscardUnknown() {
xxx_messageInfo_StoreTaskMetaManualRun.DiscardUnknown(m)
}
var xxx_messageInfo_StoreTaskMetaManualRun proto.InternalMessageInfo
func (m *StoreTaskMetaManualRun) GetStart() int64 {
if m != nil {
@ -1108,39 +1187,38 @@ var (
ErrIntOverflowMeta = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("meta.proto", fileDescriptorMeta) }
func init() { proto.RegisterFile("meta.proto", fileDescriptor_meta_2b44cf76b296d0c3) }
var fileDescriptorMeta = []byte{
// 484 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x92, 0xc1, 0x6e, 0xd3, 0x4c,
0x14, 0x85, 0x7f, 0xd7, 0x71, 0x7e, 0x72, 0xd3, 0xb4, 0x66, 0x84, 0x2a, 0x03, 0x52, 0x6a, 0x22,
0x10, 0x61, 0x81, 0x2b, 0x81, 0xc4, 0x8a, 0x0d, 0x0d, 0x2c, 0xba, 0xe8, 0x66, 0xca, 0x0a, 0x09,
0x59, 0x93, 0xf1, 0xd8, 0x58, 0xb1, 0x67, 0xca, 0xf8, 0x0e, 0x24, 0x2f, 0x81, 0x78, 0x1d, 0xde,
0x80, 0x25, 0x4f, 0x80, 0x50, 0x78, 0x0d, 0x16, 0x68, 0x66, 0xda, 0x20, 0x4a, 0x16, 0x88, 0xdd,
0xbd, 0x9f, 0x92, 0x33, 0xe7, 0x1c, 0x5f, 0x80, 0x56, 0x20, 0xcb, 0xce, 0xb5, 0x42, 0x45, 0xee,
0x72, 0xd5, 0x66, 0xb5, 0x2c, 0x1b, 0xb3, 0x2c, 0x98, 0xa5, 0x0d, 0xc3, 0x52, 0xe9, 0x36, 0x43,
0xd6, 0x2d, 0xb2, 0x39, 0xe3, 0x0b, 0x21, 0x8b, 0x5b, 0x0f, 0xab, 0x1a, 0xdf, 0x98, 0x79, 0xc6,
0x55, 0x7b, 0x54, 0xa9, 0x4a, 0x1d, 0xb9, 0x3f, 0xcf, 0x4d, 0xe9, 0x36, 0xb7, 0xb8, 0xc9, 0x8b,
0x4e, 0x7e, 0xec, 0xc0, 0xe8, 0x0c, 0x95, 0x16, 0x2f, 0x59, 0xb7, 0x38, 0x15, 0xc8, 0xc8, 0x7d,
0xd8, 0x6f, 0xd9, 0x32, 0xe7, 0x4a, 0x72, 0xa3, 0xb5, 0x90, 0x7c, 0x95, 0x04, 0x69, 0x30, 0x8d,
0xe8, 0x5e, 0xcb, 0x96, 0xb3, 0x5f, 0x94, 0x3c, 0x80, 0xb8, 0x61, 0x28, 0x3a, 0xcc, 0xb9, 0x6a,
0xcf, 0x1b, 0x81, 0xa2, 0x48, 0x76, 0xd2, 0x60, 0x1a, 0xd2, 0x7d, 0xcf, 0x67, 0x97, 0x98, 0x1c,
0x40, 0xbf, 0x43, 0x86, 0xa6, 0x4b, 0xc2, 0x34, 0x98, 0x0e, 0xe8, 0xc5, 0x46, 0x38, 0x5c, 0xf7,
0x72, 0xd8, 0xac, 0x72, 0x6d, 0xa4, 0xac, 0x65, 0x95, 0xf4, 0xd2, 0x70, 0x3a, 0x7c, 0xf4, 0x24,
0xfb, 0x9b, 0xb8, 0xd9, 0x6f, 0xde, 0xa9, 0x91, 0x34, 0xde, 0x08, 0x52, 0xaf, 0x47, 0xee, 0xc1,
0x9e, 0x28, 0x4b, 0xc1, 0xb1, 0x7e, 0x27, 0x72, 0xae, 0x95, 0x4c, 0x22, 0x67, 0x62, 0xb4, 0xa1,
0x33, 0xad, 0x24, 0xb9, 0x01, 0x51, 0x21, 0x1a, 0xb6, 0x4a, 0xfa, 0x2e, 0xad, 0x5f, 0xc8, 0x6b,
0x18, 0xb6, 0x4c, 0x1a, 0xd6, 0x58, 0x7b, 0x5d, 0x12, 0x3b, 0x6f, 0x4f, 0xff, 0xc1, 0xdb, 0xa9,
0x53, 0xb1, 0x0e, 0xa1, 0xbd, 0x1c, 0xbb, 0xc9, 0xa7, 0x00, 0xe2, 0xab, 0x11, 0x48, 0x0c, 0xa1,
0x54, 0xef, 0x5d, 0xeb, 0x21, 0xb5, 0xa3, 0x25, 0xa8, 0x57, 0xae, 0xdd, 0x11, 0xb5, 0x23, 0x49,
0xa1, 0xaf, 0x8d, 0xcc, 0xeb, 0xc2, 0x35, 0xba, 0x7b, 0x3c, 0x58, 0x7f, 0x3d, 0x8c, 0xa8, 0x91,
0x27, 0xcf, 0x69, 0xa4, 0x8d, 0x3c, 0x29, 0xc8, 0x21, 0x0c, 0x35, 0x93, 0x95, 0xc8, 0x3b, 0x64,
0x1a, 0x93, 0x9e, 0x53, 0x03, 0x87, 0xce, 0x2c, 0x21, 0xb7, 0x61, 0xe0, 0x7f, 0x20, 0x64, 0xe1,
0x2a, 0x09, 0xe9, 0x35, 0x07, 0x5e, 0xc8, 0x82, 0xdc, 0x81, 0x5d, 0x2d, 0xde, 0x1a, 0xd1, 0xa1,
0x28, 0x72, 0x86, 0xae, 0x94, 0x90, 0x0e, 0x37, 0xec, 0x19, 0x4e, 0x3e, 0x04, 0x70, 0xb0, 0x3d,
0xa2, 0xed, 0xd2, 0xbf, 0xea, 0x33, 0xf8, 0xc5, 0xa6, 0xb0, 0x4f, 0xf9, 0x1b, 0xb1, 0xe3, 0xd6,
0x13, 0x0a, 0xb7, 0x9f, 0xd0, 0x55, 0x43, 0xbd, 0x3f, 0x0c, 0x1d, 0xdf, 0xfc, 0xbc, 0x1e, 0x07,
0x5f, 0xd6, 0xe3, 0xe0, 0xdb, 0x7a, 0x1c, 0x7c, 0xfc, 0x3e, 0xfe, 0xef, 0xd5, 0xff, 0x17, 0x9f,
0x62, 0xde, 0x77, 0xd7, 0xfe, 0xf8, 0x67, 0x00, 0x00, 0x00, 0xff, 0xff, 0x4e, 0x34, 0xd2, 0x89,
0x50, 0x03, 0x00, 0x00,
var fileDescriptor_meta_2b44cf76b296d0c3 = []byte{
// 470 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x92, 0xc1, 0x6e, 0xd3, 0x40,
0x10, 0x86, 0x71, 0x1d, 0x07, 0x32, 0x69, 0x5a, 0xb3, 0xa0, 0xca, 0x80, 0x94, 0x9a, 0x08, 0x44,
0xb8, 0x18, 0x09, 0x24, 0x4e, 0x5c, 0x68, 0xe0, 0xd0, 0x43, 0x2f, 0x5b, 0x4e, 0x48, 0xc8, 0xda,
0xda, 0x9b, 0xc8, 0x8a, 0x3d, 0x5b, 0xd6, 0xb3, 0x90, 0xbc, 0x04, 0xe2, 0x75, 0x78, 0x03, 0x8e,
0x3c, 0x01, 0x42, 0xe1, 0x35, 0x38, 0xa0, 0xdd, 0x6d, 0x83, 0x08, 0x39, 0xa0, 0xde, 0x66, 0x3e,
0x25, 0xff, 0xfe, 0xff, 0xef, 0x01, 0x68, 0x24, 0x89, 0xec, 0x5c, 0x2b, 0x52, 0xec, 0x41, 0xa1,
0x9a, 0xac, 0xc2, 0x69, 0x6d, 0x16, 0xa5, 0xb0, 0xb4, 0x16, 0x34, 0x55, 0xba, 0xc9, 0x48, 0xb4,
0xf3, 0xec, 0x4c, 0x14, 0x73, 0x89, 0xe5, 0xdd, 0x5b, 0x15, 0x92, 0xd4, 0x28, 0xea, 0x27, 0x33,
0x35, 0x53, 0xfe, 0xaf, 0xa3, 0x5f, 0x3b, 0x30, 0x38, 0x25, 0xa5, 0xe5, 0x1b, 0xd1, 0xce, 0x4f,
0x24, 0x09, 0xf6, 0x08, 0xf6, 0x1b, 0xb1, 0xc8, 0x0b, 0x85, 0x85, 0xd1, 0x5a, 0x62, 0xb1, 0x4c,
0x82, 0x34, 0x18, 0x47, 0x7c, 0xaf, 0x11, 0x8b, 0xc9, 0x1f, 0xca, 0x1e, 0x43, 0x5c, 0x0b, 0x92,
0x2d, 0xe5, 0x85, 0x6a, 0xce, 0x6b, 0x49, 0xb2, 0x4c, 0x76, 0xd2, 0x60, 0x1c, 0xf2, 0x7d, 0xcf,
0x27, 0x97, 0x98, 0x1d, 0x40, 0xb7, 0x25, 0x41, 0xa6, 0x4d, 0xc2, 0x34, 0x18, 0xf7, 0xf8, 0xc5,
0xc6, 0x0a, 0xb8, 0xe9, 0xe5, 0xa8, 0x5e, 0xe6, 0xda, 0x20, 0x56, 0x38, 0x4b, 0x3a, 0x69, 0x38,
0xee, 0x3f, 0x7d, 0x9e, 0xfd, 0x4f, 0xa8, 0xec, 0x2f, 0xef, 0xdc, 0x20, 0x8f, 0xd7, 0x82, 0xdc,
0xeb, 0xb1, 0x87, 0xb0, 0x27, 0xa7, 0x53, 0x59, 0x50, 0xf5, 0x41, 0xe6, 0x85, 0x56, 0x98, 0x44,
0xce, 0xc4, 0x60, 0x4d, 0x27, 0x5a, 0x21, 0xbb, 0x0d, 0x51, 0x29, 0x6b, 0xb1, 0x4c, 0xba, 0x2e,
0xad, 0x5f, 0xd8, 0x3b, 0xe8, 0x37, 0x02, 0x8d, 0xa8, 0xad, 0xbd, 0x36, 0x89, 0x9d, 0xb7, 0x17,
0x57, 0xf0, 0x76, 0xe2, 0x54, 0xac, 0x43, 0x68, 0x2e, 0xc7, 0x76, 0xf4, 0x25, 0x80, 0x78, 0x33,
0x02, 0x8b, 0x21, 0x44, 0xf5, 0xd1, 0xb5, 0x1e, 0x72, 0x3b, 0x5a, 0x42, 0x7a, 0xe9, 0xda, 0x1d,
0x70, 0x3b, 0xb2, 0x14, 0xba, 0xda, 0x60, 0x5e, 0x95, 0xae, 0xd1, 0xdd, 0xa3, 0xde, 0xea, 0xfb,
0x61, 0xc4, 0x0d, 0x1e, 0xbf, 0xe2, 0x91, 0x36, 0x78, 0x5c, 0xb2, 0x43, 0xe8, 0x6b, 0x81, 0x33,
0x99, 0xb7, 0x24, 0x34, 0x25, 0x1d, 0xa7, 0x06, 0x0e, 0x9d, 0x5a, 0xc2, 0xee, 0x41, 0xcf, 0xff,
0x40, 0x62, 0xe9, 0x2a, 0x09, 0xf9, 0x0d, 0x07, 0x5e, 0x63, 0xc9, 0xee, 0xc3, 0xae, 0x96, 0xef,
0x8d, 0x6c, 0x49, 0x96, 0xb9, 0x20, 0x57, 0x4a, 0xc8, 0xfb, 0x6b, 0xf6, 0x92, 0x46, 0x9f, 0x02,
0x38, 0xd8, 0x1e, 0xd1, 0x76, 0xe9, 0x5f, 0xf5, 0x19, 0xfc, 0x62, 0x53, 0xd8, 0xa7, 0xfc, 0x8d,
0xd8, 0x71, 0xeb, 0x09, 0x85, 0xdb, 0x4f, 0x68, 0xd3, 0x50, 0xe7, 0x1f, 0x43, 0x47, 0x77, 0xbe,
0xae, 0x86, 0xc1, 0xb7, 0xd5, 0x30, 0xf8, 0xb1, 0x1a, 0x06, 0x9f, 0x7f, 0x0e, 0xaf, 0xbd, 0xbd,
0x7e, 0xf1, 0x29, 0xce, 0xba, 0xee, 0xda, 0x9f, 0xfd, 0x0e, 0x00, 0x00, 0xff, 0xff, 0x26, 0x20,
0x5a, 0xdd, 0x36, 0x03, 0x00, 0x00,
}

2
task/backend/meta.proto
View File

@ -1,6 +1,6 @@
syntax = "proto3";
import "github.com/gogo/protobuf/gogoproto/gogo.proto";
import "internal/gogo.proto";
package com.influxdata.platform.task.backend;

2
task/backend/store.go
View File

@ -2,7 +2,7 @@ package backend
// The tooling needed to correctly run go generate is managed by the Makefile.
// Run `make` from the project root to ensure these generate commands execute correctly.
//go:generate protoc -I ../../vendor -I . --plugin ../../bin/${GOOS}/protoc-gen-gogofaster --gogofaster_out=plugins=grpc:. ./meta.proto
//go:generate protoc -I . --plugin ../../bin/${GOOS}/protoc-gen-gogofaster --gogofaster_out=plugins=grpc:. ./meta.proto
import (
"context"