refactor: modify tooling to take advantage of go run

The generate commands have been modified to take advantage of the new
functionality in Go 1.11 that allows `go run` to execute a package
instead of individual files.

This functionality combined with Go modules allows us to execute a
package directly out of our pinned dependencies rather than accidentally
picking up another binary outside of the build environment.

This also simplifies the Makefile because they no longer have to be
responsible for installing the correct tooling since the Go command
takes care of that logic. It also makes it so that the Makefiles with
file generation can now be invoked from their appropriate subdirectories
so they are contained within the directory itself rather than relying on
values in the top level Makefile.

It is now possible to generate all files within this project by using:

    go generate ./...

Or the Makefile can continue to be used.

This commit also copies over the special copy of `tmpl` that the storage
engine uses within the influxdb repository. It was never copied over so
using `go generate` on these packages did not work.
pull/10616/head
Jonathan A. Sternberg 2018-10-15 09:39:01 -05:00
parent fe0d2c43f0
commit e9600b1f0b
No known key found for this signature in database
GPG Key ID: 4A0C1200CB8B9D2E
27 changed files with 1597 additions and 616 deletions

View File

@ -43,19 +43,12 @@ CMDS := \
bin/$(GOOS)/influx \
bin/$(GOOS)/influxd
# List of utilities to build as part of the build process
UTILS := \
bin/$(GOOS)/pigeon \
bin/$(GOOS)/protoc-gen-gogofaster \
bin/$(GOOS)/goreleaser \
bin/$(GOOS)/go-bindata
# Default target to build all go commands.
#
# This target sets up the dependencies to correctly build all go commands.
# Other targets must depend on this target to correctly builds CMDS.
all: GO_ARGS=-tags 'assets $(GO_TAGS)'
all: node_modules $(UTILS) subdirs chronograf/ui generate $(CMDS)
all: node_modules subdirs chronograf/ui generate $(CMDS)
# Target to build subdirs.
# Each subdirs must support the `all` target.
@ -73,22 +66,9 @@ $(CMDS): $(SOURCES)
$(GO_BUILD) -o $@ ./cmd/$(shell basename "$@")
#
# Define targets for utilities
# Define targets for the web ui
#
bin/$(GOOS)/pigeon: go.mod go.sum
$(GO_BUILD) -o $@ github.com/mna/pigeon
bin/$(GOOS)/protoc-gen-gogofaster: go.mod go.sum
$(GO_BUILD) -o $@ github.com/gogo/protobuf/protoc-gen-gogofaster
bin/$(GOOS)/goreleaser: go.mod go.sum
$(GO_BUILD) -o $@ github.com/goreleaser/goreleaser
bin/$(GOOS)/go-bindata: go.mod go.sum
$(GO_BUILD) -o $@ github.com/kevinburke/go-bindata/go-bindata
node_modules: chronograf/ui/node_modules
chronograf_lint:
@ -144,8 +124,8 @@ vet:
bench:
$(GO_TEST) -bench=. -run=^$$ ./...
nightly: bin/$(GOOS)/goreleaser all
PATH=./bin/$(GOOS):${PATH} goreleaser --snapshot --rm-dist --publish-snapshots
nightly: all
env GO111MODULE=on go run github.com/goreleaser/goreleaser --snapshot --rm-dist --publish-snapshots
# Recursively clean all subdirs
clean: $(SUBDIRS)
@ -165,7 +145,7 @@ define CHRONOGIRAFFE
," ## /
endef
export CHRONOGIRAFFE
chronogiraffe: $(UTILS) subdirs generate $(CMDS)
chronogiraffe: subdirs generate $(CMDS)
@echo "$$CHRONOGIRAFFE"
run: chronogiraffe

View File

@ -8,7 +8,7 @@ import (
"github.com/influxdata/platform/chronograf"
)
//go:generate protoc --gogo_out=. internal.proto
//go:generate protoc --plugin ../../../scripts/protoc-gen-gogo --gogo_out=. internal.proto
// MarshalBuild encodes a build to binary protobuf format.
func MarshalBuild(b chronograf.BuildInfo) ([]byte, error) {

File diff suppressed because it is too large Load Diff

View File

@ -8,7 +8,7 @@ import (
"github.com/influxdata/platform/chronograf"
)
//go:generate go-bindata -o bin_gen.go -tags assets -ignore README|apps|.sh|go -pkg canned .
//go:generate env GO111MODULE=on go run github.com/kevinburke/go-bindata/go-bindata -o bin_gen.go -tags assets -ignore README|apps|.sh|go -pkg canned .
// BinLayoutsStore represents a layout store using data generated by go-bindata
type BinLayoutsStore struct {

View File

@ -1,6 +1,6 @@
package dist
//go:generate go-bindata -o dist_gen.go -ignore 'map|go' -tags assets -pkg dist ../ui/build/...
//go:generate env GO111MODULE=on go run github.com/kevinburke/go-bindata/go-bindata -o dist_gen.go -ignore 'map|go' -tags assets -pkg dist ../ui/build/...
import (
"fmt"

View File

@ -1,6 +1,6 @@
package server
//go:generate go-bindata -o swagger_gen.go -tags assets -ignore go -nocompress -pkg server .
//go:generate env GO111MODULE=on go run github.com/kevinburke/go-bindata/go-bindata -o swagger_gen.go -tags assets -ignore go -nocompress -pkg server .
import "net/http"

View File

@ -1,7 +1,9 @@
all: promql.go
promql.go: promql.peg gen.go ../../bin/$(GOOS)/pigeon
PATH="../../bin/${GOOS}:${PATH}" go generate -x ./...
GO_GENERATE := go generate
promql.go: promql.peg gen.go
$(GO_GENERATE) -x
clean:
rm -f promql.go

View File

@ -1,3 +1,3 @@
package promql
//go:generate pigeon -o promql.go promql.peg
//go:generate env GO111MODULE=on go run github.com/mna/pigeon -o promql.go promql.peg

2
scripts/protoc-gen-gogo Executable file
View File

@ -0,0 +1,2 @@
#!/bin/bash
env GO111MODULE=on go run github.com/gogo/protobuf/protoc-gen-gogo "$@"

2
scripts/protoc-gen-gogofaster Executable file
View File

@ -0,0 +1,2 @@
#!/bin/bash
env GO111MODULE=on go run github.com/gogo/protobuf/protoc-gen-gogofaster "$@"

View File

@ -1,3 +1,3 @@
package datatypes
//go:generate protoc -I$GOPATH/src/github.com/influxdata/influxdb/vendor -I. --gogofaster_out=Mgoogle/protobuf/empty.proto=github.com/gogo/protobuf/types,Mgoogle/protobuf/any.proto=github.com/gogo/protobuf/types,plugins=grpc:. storage_common.proto predicate.proto
//go:generate protoc -I ../../../internal -I . --plugin ../../../scripts/protoc-gen-gogofaster --gogofaster_out=Mgoogle/protobuf/empty.proto=github.com/gogo/protobuf/types,Mgoogle/protobuf/any.proto=github.com/gogo/protobuf/types,plugins=grpc:. storage_common.proto predicate.proto

View File

@ -55,7 +55,7 @@ func (x Node_Type) String() string {
return proto.EnumName(Node_Type_name, int32(x))
}
func (Node_Type) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_predicate_bed59cc00b8d7f05, []int{0, 0}
return fileDescriptor_predicate_dbcd4976a789e072, []int{0, 0}
}
type Node_Comparison int32
@ -99,7 +99,7 @@ func (x Node_Comparison) String() string {
return proto.EnumName(Node_Comparison_name, int32(x))
}
func (Node_Comparison) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_predicate_bed59cc00b8d7f05, []int{0, 1}
return fileDescriptor_predicate_dbcd4976a789e072, []int{0, 1}
}
// Logical operators apply to boolean values and combine to produce a single boolean result.
@ -123,7 +123,7 @@ func (x Node_Logical) String() string {
return proto.EnumName(Node_Logical_name, int32(x))
}
func (Node_Logical) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_predicate_bed59cc00b8d7f05, []int{0, 2}
return fileDescriptor_predicate_dbcd4976a789e072, []int{0, 2}
}
type Node struct {
@ -149,7 +149,7 @@ func (m *Node) Reset() { *m = Node{} }
func (m *Node) String() string { return proto.CompactTextString(m) }
func (*Node) ProtoMessage() {}
func (*Node) Descriptor() ([]byte, []int) {
return fileDescriptor_predicate_bed59cc00b8d7f05, []int{0}
return fileDescriptor_predicate_dbcd4976a789e072, []int{0}
}
func (m *Node) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -511,7 +511,7 @@ func (m *Predicate) Reset() { *m = Predicate{} }
func (m *Predicate) String() string { return proto.CompactTextString(m) }
func (*Predicate) ProtoMessage() {}
func (*Predicate) Descriptor() ([]byte, []int) {
return fileDescriptor_predicate_bed59cc00b8d7f05, []int{1}
return fileDescriptor_predicate_dbcd4976a789e072, []int{1}
}
func (m *Predicate) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1334,63 +1334,62 @@ var (
ErrIntOverflowPredicate = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("predicate.proto", fileDescriptor_predicate_bed59cc00b8d7f05) }
func init() { proto.RegisterFile("predicate.proto", fileDescriptor_predicate_dbcd4976a789e072) }
var fileDescriptor_predicate_bed59cc00b8d7f05 = []byte{
// 876 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x95, 0xdd, 0x6e, 0xe3, 0x44,
0x14, 0xc7, 0xe3, 0x24, 0x6d, 0xe2, 0x93, 0x7e, 0x78, 0x67, 0xb7, 0xdb, 0xe0, 0xb2, 0xc9, 0xd0,
0x15, 0x28, 0x2b, 0x41, 0xaa, 0x16, 0x7a, 0xb5, 0x42, 0x28, 0xe9, 0xba, 0x69, 0x24, 0x93, 0x04,
0xc7, 0xcb, 0xae, 0x90, 0x50, 0xe4, 0x26, 0x13, 0xd7, 0x92, 0xeb, 0x09, 0xe3, 0x09, 0xea, 0xbe,
0x01, 0xf2, 0x15, 0xf7, 0x2b, 0x5f, 0xf1, 0x32, 0xdc, 0x20, 0xf1, 0x04, 0x11, 0x0a, 0x77, 0x3c,
0x05, 0xf2, 0xf8, 0x2b, 0x0b, 0x88, 0xee, 0xdd, 0x9c, 0x33, 0xff, 0xdf, 0xff, 0xcc, 0x1c, 0x9f,
0x4c, 0x60, 0x7f, 0xc1, 0xc8, 0xcc, 0x99, 0x5a, 0x9c, 0xb4, 0x17, 0x8c, 0x72, 0x8a, 0x8e, 0x1c,
0x6f, 0xee, 0x2e, 0xef, 0x66, 0x16, 0xb7, 0xda, 0x0b, 0xd7, 0xe2, 0x73, 0xca, 0x6e, 0xdb, 0x3e,
0xa7, 0xcc, 0xb2, 0x89, 0xfa, 0x99, 0xed, 0xf0, 0x9b, 0xe5, 0x75, 0x7b, 0x4a, 0x6f, 0x4f, 0x6c,
0x6a, 0xd3, 0x13, 0xc1, 0x5c, 0x2f, 0xe7, 0x22, 0x12, 0x81, 0x58, 0xc5, 0x5e, 0xc7, 0x6f, 0x6b,
0x50, 0x1e, 0xd0, 0x19, 0x41, 0xdf, 0x83, 0xec, 0xd1, 0x19, 0x99, 0xf0, 0x37, 0x0b, 0x52, 0x97,
0xb0, 0xd4, 0xda, 0x3b, 0xfb, 0xa4, 0xfd, 0x3f, 0x85, 0xda, 0x11, 0xd5, 0x36, 0xdf, 0x2c, 0x48,
0xb7, 0xbe, 0x5e, 0x35, 0xab, 0x51, 0x18, 0x45, 0x7f, 0xad, 0x9a, 0x55, 0x2f, 0x59, 0x1b, 0xd9,
0x0a, 0x7d, 0x09, 0xd5, 0xe9, 0x8d, 0xe3, 0xce, 0x18, 0xf1, 0xea, 0x45, 0x5c, 0x6a, 0xd5, 0xce,
0x3e, 0xba, 0xd7, 0xdd, 0xc8, 0x10, 0xf4, 0x05, 0xec, 0xf8, 0x9c, 0x39, 0x9e, 0x3d, 0xf9, 0xd1,
0x72, 0x97, 0xa4, 0x5e, 0xc2, 0x52, 0x4b, 0xee, 0xee, 0xaf, 0x57, 0xcd, 0xda, 0x58, 0xe4, 0xbf,
0x8d, 0xd2, 0x57, 0x05, 0xa3, 0xe6, 0xe7, 0x21, 0x3a, 0x05, 0xb8, 0xa6, 0xd4, 0x4d, 0x98, 0x32,
0x96, 0x5a, 0xd5, 0xae, 0xb2, 0x5e, 0x35, 0x77, 0xba, 0x94, 0xba, 0xc4, 0xf2, 0x52, 0x48, 0x8e,
0x54, 0x31, 0x72, 0x02, 0xb2, 0xe3, 0xf1, 0x84, 0xd8, 0xc2, 0x52, 0xab, 0x14, 0x13, 0x7d, 0x8f,
0x13, 0x9b, 0xb0, 0x94, 0xa8, 0x3a, 0x1e, 0x8f, 0x81, 0x33, 0x80, 0x65, 0x4e, 0x6c, 0x63, 0xa9,
0x55, 0xee, 0x3e, 0x58, 0xaf, 0x9a, 0xbb, 0x2f, 0x3d, 0xdf, 0xb1, 0x3d, 0x32, 0xcb, 0x8a, 0x2c,
0x33, 0xe6, 0x14, 0x6a, 0x73, 0x97, 0x5a, 0x29, 0x54, 0xc1, 0x52, 0x4b, 0xea, 0xee, 0xad, 0x57,
0x4d, 0xb8, 0x8c, 0xd2, 0x29, 0x01, 0xf3, 0x2c, 0x8a, 0x10, 0x46, 0x6c, 0x72, 0x97, 0x20, 0x55,
0x71, 0x7f, 0x81, 0x18, 0x51, 0x3a, 0x43, 0x58, 0x16, 0xa1, 0x73, 0xd8, 0xe5, 0x96, 0x3d, 0x61,
0x64, 0x9e, 0x40, 0x72, 0xde, 0x34, 0xd3, 0xb2, 0x0d, 0x32, 0xcf, 0x9a, 0xc6, 0xf3, 0x10, 0x3d,
0x87, 0xfd, 0xb9, 0x43, 0xdc, 0xd9, 0x06, 0x08, 0x02, 0x14, 0xb7, 0xba, 0x8c, 0xb6, 0x36, 0xd0,
0xdd, 0xf9, 0x66, 0x02, 0x69, 0x50, 0x71, 0xa9, 0xed, 0x4c, 0x2d, 0xb7, 0x5e, 0x13, 0x33, 0xf4,
0xec, 0xfe, 0x19, 0xd2, 0x63, 0xe0, 0xaa, 0x60, 0xa4, 0x2c, 0x1a, 0x00, 0x4c, 0xe9, 0xed, 0xc2,
0x62, 0x8e, 0x4f, 0xbd, 0xfa, 0x8e, 0x70, 0xfa, 0xf4, 0x7e, 0xa7, 0x8b, 0x8c, 0x89, 0x5a, 0x91,
0x3b, 0x1c, 0xbf, 0x2d, 0x42, 0x59, 0x8c, 0xe1, 0x39, 0x20, 0x7d, 0xd8, 0xeb, 0x5f, 0x74, 0xf4,
0x89, 0xf6, 0x7a, 0x64, 0x68, 0xe3, 0x71, 0x7f, 0x38, 0x50, 0x0a, 0xea, 0x93, 0x20, 0xc4, 0x1f,
0xa4, 0x23, 0x9c, 0x1c, 0x48, 0xbb, 0x5b, 0x30, 0xe2, 0xfb, 0x0e, 0xf5, 0xd0, 0x73, 0x38, 0xb8,
0x18, 0x7e, 0x3d, 0xea, 0x18, 0xfd, 0xf1, 0x70, 0xb0, 0x49, 0x4a, 0x2a, 0x0e, 0x42, 0xfc, 0x61,
0x4a, 0xe6, 0x07, 0xd8, 0x80, 0x4f, 0x41, 0x19, 0x75, 0x0c, 0xed, 0x1d, 0xae, 0xa8, 0x1e, 0x05,
0x21, 0x3e, 0x4c, 0xb9, 0x91, 0xc5, 0xc8, 0x26, 0xd2, 0x84, 0x8a, 0xd9, 0xe9, 0x4d, 0x0c, 0xed,
0x52, 0x29, 0xa9, 0x28, 0x08, 0xf1, 0x5e, 0xaa, 0x8c, 0x3f, 0x1c, 0xc2, 0x50, 0xd1, 0xfb, 0xa6,
0x66, 0x74, 0x74, 0xa5, 0xac, 0x3e, 0x0c, 0x42, 0xbc, 0x9f, 0x1d, 0xde, 0xe1, 0x84, 0x59, 0x2e,
0x7a, 0x0a, 0xf2, 0x65, 0x5f, 0xd3, 0x5f, 0x08, 0x93, 0x2d, 0xf5, 0x51, 0x10, 0x62, 0x25, 0xd5,
0xa4, 0x1f, 0x51, 0x2d, 0xff, 0xf4, 0x4b, 0xa3, 0x70, 0xfc, 0x5b, 0x11, 0x20, 0x3f, 0x39, 0x6a,
0xc0, 0x96, 0xf6, 0xcd, 0xcb, 0x8e, 0xae, 0x14, 0x62, 0xe7, 0x8d, 0x4b, 0xfd, 0xb0, 0xb4, 0x5c,
0xf4, 0x31, 0xc8, 0x83, 0xa1, 0x39, 0x89, 0x35, 0x92, 0xfa, 0x38, 0x08, 0x31, 0xca, 0x35, 0x03,
0xca, 0x63, 0xd9, 0x33, 0xa8, 0x8d, 0xcd, 0x8e, 0x61, 0x8e, 0x27, 0xaf, 0xfa, 0xe6, 0x95, 0x52,
0x54, 0xeb, 0x41, 0x88, 0x1f, 0xe5, 0xc2, 0x31, 0xb7, 0x18, 0xf7, 0x5f, 0x39, 0xfc, 0x26, 0xaa,
0x68, 0x68, 0x3d, 0xed, 0xb5, 0x52, 0xfa, 0x67, 0x45, 0x31, 0xdc, 0x69, 0xc5, 0x58, 0x53, 0xfe,
0x8f, 0x8a, 0xb1, 0x4c, 0x85, 0xa2, 0x6e, 0x2a, 0x5b, 0x71, 0xc3, 0xf2, 0x7d, 0x9d, 0xf8, 0x3e,
0xc2, 0x50, 0xd2, 0x4d, 0x4d, 0xd9, 0x56, 0x0f, 0x83, 0x10, 0x3f, 0x7c, 0x77, 0x33, 0x3e, 0xef,
0x13, 0x28, 0xf6, 0x4c, 0xa5, 0xa2, 0x1e, 0x04, 0x21, 0x7e, 0x90, 0x0b, 0x7a, 0x8c, 0x58, 0x9c,
0x30, 0xf4, 0x14, 0x4a, 0x3d, 0x53, 0x53, 0xaa, 0xaa, 0x1a, 0x84, 0xf8, 0xf1, 0xbf, 0xf6, 0x85,
0x47, 0xd2, 0xcf, 0xaf, 0xa0, 0x92, 0x8c, 0x10, 0x3a, 0x84, 0x52, 0x67, 0xf0, 0x42, 0x29, 0xa8,
0x7b, 0x41, 0x88, 0x21, 0xc9, 0x76, 0xbc, 0x19, 0x3a, 0x80, 0xe2, 0xd0, 0x50, 0x24, 0x75, 0x37,
0x08, 0xb1, 0x9c, 0xe4, 0x87, 0x2c, 0x36, 0xe8, 0x56, 0x60, 0x4b, 0xfc, 0xf0, 0x8e, 0xbb, 0x20,
0x8f, 0xd2, 0xc7, 0x1f, 0x9d, 0x43, 0x99, 0x51, 0xca, 0xc5, 0xe3, 0xfc, 0x5e, 0xcf, 0xa7, 0x90,
0x77, 0x8f, 0x7e, 0x5d, 0x37, 0xa4, 0xdf, 0xd7, 0x0d, 0xe9, 0x8f, 0x75, 0x43, 0xfa, 0xf9, 0xcf,
0x46, 0xe1, 0x3b, 0x39, 0x62, 0xa2, 0x77, 0xde, 0xbf, 0xde, 0x16, 0xff, 0x02, 0x9f, 0xff, 0x1d,
0x00, 0x00, 0xff, 0xff, 0x83, 0xfd, 0x6f, 0x70, 0x64, 0x06, 0x00, 0x00,
var fileDescriptor_predicate_dbcd4976a789e072 = []byte{
// 860 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x95, 0xdd, 0x8e, 0xdb, 0x44,
0x14, 0xc7, 0xe3, 0x7c, 0x6c, 0xe2, 0x93, 0xfd, 0x70, 0xa7, 0xbb, 0xdd, 0xe0, 0xa5, 0xc9, 0xb0,
0x15, 0x28, 0x95, 0x50, 0xaa, 0x5d, 0xd8, 0xab, 0x0a, 0xa1, 0x78, 0xeb, 0xcd, 0x46, 0x32, 0x49,
0x70, 0x5c, 0x5a, 0x21, 0xa1, 0x68, 0xba, 0x99, 0xb8, 0x96, 0x5c, 0x4f, 0x18, 0x4f, 0xd0, 0xf6,
0x0d, 0x90, 0xaf, 0xb8, 0xaf, 0x7c, 0xc5, 0xcb, 0x70, 0x83, 0xc4, 0x13, 0x44, 0x28, 0xdc, 0xf1,
0x14, 0xc8, 0xdf, 0x29, 0x20, 0x96, 0xbb, 0x39, 0x67, 0xfe, 0xbf, 0xff, 0x9c, 0x39, 0x3e, 0x99,
0xc0, 0xc1, 0x92, 0xd3, 0xb9, 0x73, 0x43, 0x04, 0xed, 0x2d, 0x39, 0x13, 0x0c, 0x9d, 0x38, 0xde,
0xc2, 0x5d, 0xdd, 0xce, 0x89, 0x20, 0xbd, 0xa5, 0x4b, 0xc4, 0x82, 0xf1, 0x37, 0x3d, 0x5f, 0x30,
0x4e, 0x6c, 0xaa, 0x1e, 0xda, 0xcc, 0x66, 0xb1, 0xee, 0x49, 0xb4, 0x4a, 0x90, 0xd3, 0x77, 0x4d,
0xa8, 0x8e, 0xd8, 0x9c, 0xa2, 0xef, 0x40, 0xf6, 0xd8, 0x9c, 0xce, 0xc4, 0xdb, 0x25, 0x6d, 0x49,
0x58, 0xea, 0xee, 0x9f, 0x7f, 0xd2, 0xfb, 0x0f, 0xbf, 0x5e, 0x44, 0xf5, 0xac, 0xb7, 0x4b, 0xaa,
0xb5, 0x36, 0xeb, 0x4e, 0x23, 0x0a, 0xa3, 0xe8, 0xcf, 0x75, 0xa7, 0xe1, 0xa5, 0x6b, 0x33, 0x5f,
0xa1, 0x2f, 0xa0, 0x71, 0xf3, 0xda, 0x71, 0xe7, 0x9c, 0x7a, 0xad, 0x32, 0xae, 0x74, 0x9b, 0xe7,
0x1f, 0xdd, 0xe9, 0x6e, 0xe6, 0x08, 0xfa, 0x1c, 0x76, 0x7d, 0xc1, 0x1d, 0xcf, 0x9e, 0xfd, 0x40,
0xdc, 0x15, 0x6d, 0x55, 0xb0, 0xd4, 0x95, 0xb5, 0x83, 0xcd, 0xba, 0xd3, 0x9c, 0xc6, 0xf9, 0x6f,
0xa2, 0xf4, 0x75, 0xc9, 0x6c, 0xfa, 0x45, 0x88, 0xce, 0x00, 0x5e, 0x31, 0xe6, 0xa6, 0x4c, 0x15,
0x4b, 0xdd, 0x86, 0xa6, 0x6c, 0xd6, 0x9d, 0x5d, 0x8d, 0x31, 0x97, 0x12, 0x2f, 0x83, 0xe4, 0x48,
0x95, 0x20, 0x4f, 0x40, 0x76, 0x3c, 0x91, 0x12, 0x35, 0x2c, 0x75, 0x2b, 0x09, 0x31, 0xf4, 0x04,
0xb5, 0x29, 0xcf, 0x88, 0x86, 0xe3, 0x89, 0x04, 0x38, 0x07, 0x58, 0x15, 0xc4, 0x0e, 0x96, 0xba,
0x55, 0xed, 0xde, 0x66, 0xdd, 0xd9, 0x7b, 0xee, 0xf9, 0x8e, 0xed, 0xd1, 0x79, 0x7e, 0xc8, 0x2a,
0x67, 0xce, 0xa0, 0xb9, 0x70, 0x19, 0xc9, 0xa0, 0x3a, 0x96, 0xba, 0x92, 0xb6, 0xbf, 0x59, 0x77,
0xe0, 0x2a, 0x4a, 0x67, 0x04, 0x2c, 0xf2, 0x28, 0x42, 0x38, 0xb5, 0xe9, 0x6d, 0x8a, 0x34, 0xe2,
0xfb, 0xc7, 0x88, 0x19, 0xa5, 0x73, 0x84, 0xe7, 0x11, 0xba, 0x80, 0x3d, 0x41, 0xec, 0x19, 0xa7,
0x8b, 0x14, 0x92, 0x8b, 0xa6, 0x59, 0xc4, 0x36, 0xe9, 0x22, 0x6f, 0x9a, 0x28, 0x42, 0xf4, 0x14,
0x0e, 0x16, 0x0e, 0x75, 0xe7, 0x5b, 0x20, 0xc4, 0x60, 0x7c, 0xab, 0xab, 0x68, 0x6b, 0x0b, 0xdd,
0x5b, 0x6c, 0x27, 0x90, 0x0e, 0x75, 0x97, 0xd9, 0xce, 0x0d, 0x71, 0x5b, 0xcd, 0x78, 0x86, 0x1e,
0xdf, 0x3d, 0x43, 0x46, 0x02, 0x5c, 0x97, 0xcc, 0x8c, 0x45, 0x23, 0x80, 0x1b, 0xf6, 0x66, 0x49,
0xb8, 0xe3, 0x33, 0xaf, 0xb5, 0x1b, 0x3b, 0x7d, 0x7a, 0xb7, 0xd3, 0x65, 0xce, 0x44, 0xad, 0x28,
0x1c, 0x4e, 0xdf, 0x95, 0xa1, 0x1a, 0x8f, 0xe1, 0x05, 0x20, 0x63, 0x3c, 0x18, 0x5e, 0xf6, 0x8d,
0x99, 0xfe, 0x72, 0x62, 0xea, 0xd3, 0xe9, 0x70, 0x3c, 0x52, 0x4a, 0xea, 0xc3, 0x20, 0xc4, 0x1f,
0x64, 0x23, 0x9c, 0x16, 0xa4, 0xdf, 0x2e, 0x39, 0xf5, 0x7d, 0x87, 0x79, 0xe8, 0x29, 0x1c, 0x5d,
0x8e, 0xbf, 0x9a, 0xf4, 0xcd, 0xe1, 0x74, 0x3c, 0xda, 0x26, 0x25, 0x15, 0x07, 0x21, 0xfe, 0x30,
0x23, 0x8b, 0x02, 0xb6, 0xe0, 0x33, 0x50, 0x26, 0x7d, 0x53, 0x7f, 0x8f, 0x2b, 0xab, 0x27, 0x41,
0x88, 0x8f, 0x33, 0x6e, 0x42, 0x38, 0xdd, 0x46, 0x3a, 0x50, 0xb7, 0xfa, 0x83, 0x99, 0xa9, 0x5f,
0x29, 0x15, 0x15, 0x05, 0x21, 0xde, 0xcf, 0x94, 0xc9, 0x87, 0x43, 0x18, 0xea, 0xc6, 0xd0, 0xd2,
0xcd, 0xbe, 0xa1, 0x54, 0xd5, 0xfb, 0x41, 0x88, 0x0f, 0xf2, 0xe2, 0x1d, 0x41, 0x39, 0x71, 0xd1,
0x23, 0x90, 0xaf, 0x86, 0xba, 0xf1, 0x2c, 0x36, 0xa9, 0xa9, 0x87, 0x41, 0x88, 0x95, 0x4c, 0x93,
0x7d, 0x44, 0xb5, 0xfa, 0xe3, 0xcf, 0xed, 0xd2, 0xe9, 0xaf, 0x65, 0x80, 0xa2, 0x72, 0xd4, 0x86,
0x9a, 0xfe, 0xf5, 0xf3, 0xbe, 0xa1, 0x94, 0x12, 0xe7, 0xad, 0x4b, 0x7d, 0xbf, 0x22, 0x2e, 0xfa,
0x18, 0xe4, 0xd1, 0xd8, 0x9a, 0x25, 0x1a, 0x49, 0x7d, 0x10, 0x84, 0x18, 0x15, 0x9a, 0x11, 0x13,
0x89, 0xec, 0x31, 0x34, 0xa7, 0x56, 0xdf, 0xb4, 0xa6, 0xb3, 0x17, 0x43, 0xeb, 0x5a, 0x29, 0xab,
0xad, 0x20, 0xc4, 0x87, 0x85, 0x70, 0x2a, 0x08, 0x17, 0xfe, 0x0b, 0x47, 0xbc, 0x8e, 0x4e, 0x34,
0xf5, 0x81, 0xfe, 0x52, 0xa9, 0xfc, 0xfd, 0xc4, 0x78, 0xb8, 0xb3, 0x13, 0x13, 0x4d, 0xf5, 0x5f,
0x4e, 0x4c, 0x64, 0x2a, 0x94, 0x0d, 0x4b, 0xa9, 0x25, 0x0d, 0x2b, 0xf6, 0x0d, 0xea, 0xfb, 0x08,
0x43, 0xc5, 0xb0, 0x74, 0x65, 0x47, 0x3d, 0x0e, 0x42, 0x7c, 0xff, 0xfd, 0xcd, 0xa4, 0xde, 0x87,
0x50, 0x1e, 0x58, 0x4a, 0x5d, 0x3d, 0x0a, 0x42, 0x7c, 0xaf, 0x10, 0x0c, 0x38, 0x25, 0x82, 0x72,
0xf4, 0x08, 0x2a, 0x03, 0x4b, 0x57, 0x1a, 0xaa, 0x1a, 0x84, 0xf8, 0xc1, 0x3f, 0xf6, 0x63, 0x8f,
0xb4, 0x9f, 0x5f, 0x42, 0x3d, 0x1d, 0x21, 0x74, 0x0c, 0x95, 0xfe, 0xe8, 0x99, 0x52, 0x52, 0xf7,
0x83, 0x10, 0x43, 0x9a, 0xed, 0x7b, 0x73, 0x74, 0x04, 0xe5, 0xb1, 0xa9, 0x48, 0xea, 0x5e, 0x10,
0x62, 0x39, 0xcd, 0x8f, 0x79, 0x62, 0xa0, 0xd5, 0xa1, 0x16, 0xff, 0xf0, 0x4e, 0x35, 0x90, 0x27,
0xd9, 0x1b, 0x8f, 0x2e, 0xa0, 0xca, 0x19, 0x13, 0xf1, 0xe3, 0xfc, 0xbf, 0x9e, 0xcf, 0x58, 0xae,
0x9d, 0xfc, 0xb2, 0x69, 0x4b, 0xbf, 0x6d, 0xda, 0xd2, 0xef, 0x9b, 0xb6, 0xf4, 0xd3, 0x1f, 0xed,
0xd2, 0xb7, 0x72, 0xc4, 0x44, 0xef, 0xbc, 0xff, 0x6a, 0x27, 0xfe, 0x17, 0xf8, 0xec, 0xaf, 0x00,
0x00, 0x00, 0xff, 0xff, 0xef, 0xb8, 0x31, 0xd8, 0x4b, 0x06, 0x00, 0x00,
}

View File

@ -2,7 +2,7 @@ syntax = "proto3";
package influxdata.platform.storage;
option go_package = "datatypes";
import "github.com/gogo/protobuf/gogoproto/gogo.proto";
import "gogoproto/gogo.proto";
message Node {
enum Type {

View File

@ -59,7 +59,7 @@ func (x ReadRequest_Group) String() string {
return proto.EnumName(ReadRequest_Group_name, int32(x))
}
func (ReadRequest_Group) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{0, 0}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{0, 0}
}
type ReadRequest_HintFlags int32
@ -89,7 +89,7 @@ func (x ReadRequest_HintFlags) String() string {
return proto.EnumName(ReadRequest_HintFlags_name, int32(x))
}
func (ReadRequest_HintFlags) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{0, 1}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{0, 1}
}
type Aggregate_AggregateType int32
@ -115,7 +115,7 @@ func (x Aggregate_AggregateType) String() string {
return proto.EnumName(Aggregate_AggregateType_name, int32(x))
}
func (Aggregate_AggregateType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{1, 0}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{1, 0}
}
type ReadResponse_FrameType int32
@ -138,7 +138,7 @@ func (x ReadResponse_FrameType) String() string {
return proto.EnumName(ReadResponse_FrameType_name, int32(x))
}
func (ReadResponse_FrameType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 0}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 0}
}
type ReadResponse_DataType int32
@ -170,7 +170,7 @@ func (x ReadResponse_DataType) String() string {
return proto.EnumName(ReadResponse_DataType_name, int32(x))
}
func (ReadResponse_DataType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 1}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 1}
}
// Request message for Storage.Read.
@ -208,7 +208,7 @@ func (m *ReadRequest) Reset() { *m = ReadRequest{} }
func (m *ReadRequest) String() string { return proto.CompactTextString(m) }
func (*ReadRequest) ProtoMessage() {}
func (*ReadRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{0}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{0}
}
func (m *ReadRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -247,7 +247,7 @@ func (m *Aggregate) Reset() { *m = Aggregate{} }
func (m *Aggregate) String() string { return proto.CompactTextString(m) }
func (*Aggregate) ProtoMessage() {}
func (*Aggregate) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{1}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{1}
}
func (m *Aggregate) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -287,7 +287,7 @@ func (m *Tag) Reset() { *m = Tag{} }
func (m *Tag) String() string { return proto.CompactTextString(m) }
func (*Tag) ProtoMessage() {}
func (*Tag) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{2}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{2}
}
func (m *Tag) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -327,7 +327,7 @@ func (m *ReadResponse) Reset() { *m = ReadResponse{} }
func (m *ReadResponse) String() string { return proto.CompactTextString(m) }
func (*ReadResponse) ProtoMessage() {}
func (*ReadResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3}
}
func (m *ReadResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -374,7 +374,7 @@ func (m *ReadResponse_Frame) Reset() { *m = ReadResponse_Frame{} }
func (m *ReadResponse_Frame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_Frame) ProtoMessage() {}
func (*ReadResponse_Frame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 0}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 0}
}
func (m *ReadResponse_Frame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -677,7 +677,7 @@ func (m *ReadResponse_GroupFrame) Reset() { *m = ReadResponse_GroupFrame
func (m *ReadResponse_GroupFrame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_GroupFrame) ProtoMessage() {}
func (*ReadResponse_GroupFrame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 1}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 1}
}
func (m *ReadResponse_GroupFrame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -717,7 +717,7 @@ func (m *ReadResponse_SeriesFrame) Reset() { *m = ReadResponse_SeriesFra
func (m *ReadResponse_SeriesFrame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_SeriesFrame) ProtoMessage() {}
func (*ReadResponse_SeriesFrame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 2}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 2}
}
func (m *ReadResponse_SeriesFrame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -757,7 +757,7 @@ func (m *ReadResponse_FloatPointsFrame) Reset() { *m = ReadResponse_Floa
func (m *ReadResponse_FloatPointsFrame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_FloatPointsFrame) ProtoMessage() {}
func (*ReadResponse_FloatPointsFrame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 3}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 3}
}
func (m *ReadResponse_FloatPointsFrame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -797,7 +797,7 @@ func (m *ReadResponse_IntegerPointsFrame) Reset() { *m = ReadResponse_In
func (m *ReadResponse_IntegerPointsFrame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_IntegerPointsFrame) ProtoMessage() {}
func (*ReadResponse_IntegerPointsFrame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 4}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 4}
}
func (m *ReadResponse_IntegerPointsFrame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -837,7 +837,7 @@ func (m *ReadResponse_UnsignedPointsFrame) Reset() { *m = ReadResponse_U
func (m *ReadResponse_UnsignedPointsFrame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_UnsignedPointsFrame) ProtoMessage() {}
func (*ReadResponse_UnsignedPointsFrame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 5}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 5}
}
func (m *ReadResponse_UnsignedPointsFrame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -877,7 +877,7 @@ func (m *ReadResponse_BooleanPointsFrame) Reset() { *m = ReadResponse_Bo
func (m *ReadResponse_BooleanPointsFrame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_BooleanPointsFrame) ProtoMessage() {}
func (*ReadResponse_BooleanPointsFrame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 6}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 6}
}
func (m *ReadResponse_BooleanPointsFrame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -917,7 +917,7 @@ func (m *ReadResponse_StringPointsFrame) Reset() { *m = ReadResponse_Str
func (m *ReadResponse_StringPointsFrame) String() string { return proto.CompactTextString(m) }
func (*ReadResponse_StringPointsFrame) ProtoMessage() {}
func (*ReadResponse_StringPointsFrame) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{3, 7}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{3, 7}
}
func (m *ReadResponse_StringPointsFrame) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -956,7 +956,7 @@ func (m *CapabilitiesResponse) Reset() { *m = CapabilitiesResponse{} }
func (m *CapabilitiesResponse) String() string { return proto.CompactTextString(m) }
func (*CapabilitiesResponse) ProtoMessage() {}
func (*CapabilitiesResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{4}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{4}
}
func (m *CapabilitiesResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -994,7 +994,7 @@ func (m *HintsResponse) Reset() { *m = HintsResponse{} }
func (m *HintsResponse) String() string { return proto.CompactTextString(m) }
func (*HintsResponse) ProtoMessage() {}
func (*HintsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{5}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{5}
}
func (m *HintsResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1037,7 +1037,7 @@ func (m *TimestampRange) Reset() { *m = TimestampRange{} }
func (m *TimestampRange) String() string { return proto.CompactTextString(m) }
func (*TimestampRange) ProtoMessage() {}
func (*TimestampRange) Descriptor() ([]byte, []int) {
return fileDescriptor_storage_common_34a13332d204354f, []int{6}
return fileDescriptor_storage_common_01b6ac29b3fb8162, []int{6}
}
func (m *TimestampRange) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -4585,106 +4585,106 @@ var (
)
func init() {
proto.RegisterFile("storage_common.proto", fileDescriptor_storage_common_34a13332d204354f)
proto.RegisterFile("storage_common.proto", fileDescriptor_storage_common_01b6ac29b3fb8162)
}
var fileDescriptor_storage_common_34a13332d204354f = []byte{
// 1551 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x57, 0x5f, 0x6f, 0xea, 0xc8,
0x15, 0xc7, 0xfc, 0xe7, 0xf0, 0x27, 0xce, 0x6c, 0x1a, 0xb1, 0xbe, 0x5d, 0xf0, 0xa2, 0x6a, 0x45,
0xdb, 0x5d, 0xd2, 0xb2, 0xbb, 0xea, 0xd5, 0x6d, 0xfb, 0x00, 0x09, 0x37, 0xd0, 0x24, 0x10, 0x0d,
0xa4, 0xea, 0x56, 0xaa, 0xd0, 0x04, 0x06, 0x5f, 0x6b, 0x8d, 0xed, 0xda, 0x66, 0x15, 0xa4, 0xbe,
0x77, 0xc5, 0xd3, 0xed, 0x6b, 0x25, 0xa4, 0x4a, 0x7d, 0xec, 0x7b, 0x3f, 0xc3, 0x7d, 0x6b, 0x3f,
0x01, 0x6a, 0xe9, 0x87, 0xa8, 0xd4, 0xa7, 0x6a, 0x66, 0x6c, 0x30, 0xc9, 0xdd, 0x08, 0xde, 0x66,
0xce, 0x9f, 0xdf, 0xef, 0xcc, 0xf1, 0x39, 0x67, 0xc6, 0x70, 0xe2, 0x7a, 0x96, 0x43, 0x34, 0x3a,
0x1c, 0x59, 0xd3, 0xa9, 0x65, 0xd6, 0x6c, 0xc7, 0xf2, 0x2c, 0xf4, 0x42, 0x37, 0x27, 0xc6, 0xec,
0x61, 0x4c, 0x3c, 0x52, 0xb3, 0x0d, 0xe2, 0x4d, 0x2c, 0x67, 0x5a, 0xf3, 0x2d, 0x95, 0xcf, 0x34,
0xdd, 0x7b, 0x33, 0xbb, 0xaf, 0x8d, 0xac, 0xe9, 0x99, 0x66, 0x69, 0xd6, 0x19, 0xf7, 0xb9, 0x9f,
0x4d, 0xf8, 0x8e, 0x6f, 0xf8, 0x4a, 0x60, 0x29, 0x2f, 0x34, 0xcb, 0xd2, 0x0c, 0xba, 0xb5, 0xa2,
0x53, 0xdb, 0x9b, 0xfb, 0xca, 0x0f, 0x1f, 0x2b, 0x89, 0x19, 0xa8, 0x8e, 0x6c, 0x87, 0x8e, 0xf5,
0x11, 0xf1, 0xa8, 0x10, 0x54, 0xfe, 0x9b, 0x86, 0x2c, 0xa6, 0x64, 0x8c, 0xe9, 0xef, 0x67, 0xd4,
0xf5, 0x90, 0x01, 0x47, 0x9e, 0x3e, 0xa5, 0xae, 0x47, 0xa6, 0xf6, 0xd0, 0x21, 0xa6, 0x46, 0x8b,
0x51, 0x55, 0xaa, 0x66, 0xeb, 0x3f, 0xae, 0x3d, 0x13, 0x7e, 0x6d, 0x10, 0xf8, 0x60, 0xe6, 0xd2,
0x3c, 0x7d, 0xb7, 0x2a, 0x47, 0xd6, 0xab, 0x72, 0x61, 0x57, 0x8e, 0x0b, 0xde, 0xce, 0x1e, 0x95,
0x00, 0xc6, 0xd4, 0x1d, 0x51, 0x73, 0xac, 0x9b, 0x5a, 0x31, 0xa6, 0x4a, 0xd5, 0x34, 0x0e, 0x49,
0xd0, 0xa7, 0x00, 0x9a, 0x63, 0xcd, 0xec, 0xe1, 0xd7, 0x74, 0xee, 0x16, 0xe3, 0x6a, 0xac, 0x9a,
0x69, 0xe6, 0xd7, 0xab, 0x72, 0xe6, 0x92, 0x49, 0xaf, 0xe8, 0xdc, 0xc5, 0x19, 0x2d, 0x58, 0xa2,
0x0b, 0xc8, 0x6c, 0x8e, 0x57, 0x4c, 0xf0, 0xa8, 0x3f, 0x79, 0x36, 0xea, 0xdb, 0xc0, 0x1a, 0x6f,
0x1d, 0x51, 0x1d, 0x72, 0x2e, 0x75, 0x74, 0xea, 0x0e, 0x0d, 0x7d, 0xaa, 0x7b, 0xc5, 0xa4, 0x2a,
0x55, 0x63, 0xcd, 0xa3, 0xf5, 0xaa, 0x9c, 0xed, 0x73, 0xf9, 0x35, 0x13, 0xe3, 0xac, 0xbb, 0xdd,
0xa0, 0x2f, 0x21, 0xef, 0xfb, 0x58, 0x93, 0x89, 0x4b, 0xbd, 0x62, 0x8a, 0x3b, 0xc9, 0xeb, 0x55,
0x39, 0x27, 0x9c, 0x7a, 0x5c, 0x8e, 0x7d, 0x68, 0xb1, 0x63, 0x54, 0xb6, 0xa5, 0x9b, 0x5e, 0x40,
0x95, 0xde, 0x52, 0xdd, 0x72, 0xb9, 0x4f, 0x65, 0x6f, 0x37, 0xec, 0x90, 0x44, 0xd3, 0x1c, 0xaa,
0xb1, 0x43, 0x66, 0xf6, 0x38, 0x64, 0x23, 0xb0, 0xc6, 0x5b, 0x47, 0x34, 0x80, 0x84, 0xe7, 0x90,
0x11, 0x2d, 0x82, 0x1a, 0xab, 0x66, 0xeb, 0x9f, 0x3f, 0x8b, 0x10, 0xaa, 0x8f, 0xda, 0x80, 0x79,
0xb5, 0x4c, 0xcf, 0x99, 0x37, 0x33, 0xeb, 0x55, 0x39, 0xc1, 0xf7, 0x58, 0x80, 0xa1, 0x0b, 0x48,
0xf0, 0xaf, 0x51, 0xcc, 0xaa, 0x52, 0xb5, 0x50, 0xaf, 0xed, 0x8d, 0xca, 0x3f, 0x27, 0x16, 0xce,
0xe8, 0x53, 0x48, 0xbc, 0x61, 0xe7, 0x2d, 0xe6, 0x54, 0xa9, 0x9a, 0x6a, 0x9e, 0x32, 0x9a, 0x36,
0x13, 0xfc, 0x6f, 0x55, 0xce, 0xb0, 0xc5, 0x6b, 0x83, 0x68, 0x2e, 0x16, 0x46, 0xa8, 0x05, 0x59,
0x87, 0x92, 0xf1, 0xd0, 0xb5, 0x66, 0xce, 0x88, 0x16, 0xf3, 0x3c, 0x23, 0x27, 0x35, 0xd1, 0x02,
0xb5, 0xa0, 0x05, 0x6a, 0x0d, 0x73, 0xde, 0x2c, 0xac, 0x57, 0x65, 0x60, 0xb4, 0x7d, 0x6e, 0x8b,
0xc1, 0xd9, 0xac, 0x95, 0x97, 0x00, 0xdb, 0xa3, 0x21, 0x19, 0x62, 0x5f, 0xd3, 0x79, 0x51, 0x52,
0xa5, 0x6a, 0x06, 0xb3, 0x25, 0x3a, 0x81, 0xc4, 0x37, 0xc4, 0x98, 0x89, 0x6e, 0xc8, 0x60, 0xb1,
0x79, 0x15, 0x7d, 0x29, 0x55, 0xfe, 0x28, 0x41, 0x82, 0xc7, 0x8f, 0x3e, 0x02, 0xb8, 0xc4, 0xbd,
0xbb, 0xdb, 0x61, 0xb7, 0xd7, 0x6d, 0xc9, 0x11, 0x25, 0xbf, 0x58, 0xaa, 0xa2, 0x52, 0xbb, 0x96,
0x49, 0xd1, 0x0b, 0xc8, 0x08, 0x75, 0xe3, 0xfa, 0x5a, 0x96, 0x94, 0xdc, 0x62, 0xa9, 0xa6, 0xb9,
0xb6, 0x61, 0x18, 0xe8, 0x43, 0x48, 0x0b, 0x65, 0xf3, 0x2b, 0x39, 0xaa, 0x64, 0x17, 0x4b, 0x35,
0xc5, 0x75, 0xcd, 0x39, 0xfa, 0x18, 0x72, 0x42, 0xd5, 0xfa, 0xcd, 0x79, 0xeb, 0x76, 0x20, 0xc7,
0x94, 0xa3, 0xc5, 0x52, 0xcd, 0x72, 0x75, 0xeb, 0x61, 0x44, 0x6d, 0x4f, 0x89, 0x7f, 0xfb, 0xd7,
0x52, 0xa4, 0xf2, 0x37, 0x09, 0xb6, 0xf9, 0x61, 0x74, 0xed, 0x4e, 0x77, 0x10, 0x04, 0xc3, 0xe9,
0x98, 0x96, 0xc7, 0xf2, 0x03, 0x28, 0xf8, 0xca, 0xe1, 0x6d, 0xaf, 0xd3, 0x1d, 0xf4, 0x65, 0x49,
0x91, 0x17, 0x4b, 0x35, 0x27, 0x2c, 0x44, 0xf5, 0x85, 0xad, 0xfa, 0x2d, 0xdc, 0x69, 0xf5, 0xe5,
0x68, 0xd8, 0x4a, 0x54, 0x36, 0x3a, 0x83, 0x13, 0x6e, 0xd5, 0x3f, 0x6f, 0xb7, 0x6e, 0x1a, 0xec,
0x74, 0xc3, 0x41, 0xe7, 0xa6, 0x25, 0xc7, 0x95, 0xef, 0x2d, 0x96, 0xea, 0x31, 0xb3, 0xed, 0x8f,
0xde, 0xd0, 0x29, 0x69, 0x18, 0x06, 0x9b, 0x07, 0x7e, 0xb4, 0xff, 0x90, 0x20, 0xb3, 0xa9, 0x4d,
0xd4, 0x86, 0xb8, 0x37, 0xb7, 0x29, 0x4f, 0x79, 0xa1, 0xfe, 0xc5, 0x7e, 0x15, 0xbd, 0x5d, 0x0d,
0xe6, 0x36, 0xc5, 0x1c, 0xa1, 0xf2, 0x00, 0xf9, 0x1d, 0x31, 0x2a, 0x43, 0xdc, 0xcf, 0x01, 0x8f,
0x67, 0x47, 0xc9, 0x93, 0xf1, 0x11, 0xc4, 0xfa, 0x77, 0x37, 0xb2, 0xa4, 0x9c, 0x2c, 0x96, 0xaa,
0xbc, 0xa3, 0xef, 0xcf, 0xa6, 0xe8, 0x63, 0x48, 0x9c, 0xf7, 0xee, 0xba, 0x03, 0x39, 0xaa, 0x9c,
0x2e, 0x96, 0x2a, 0xda, 0x31, 0x38, 0xb7, 0x66, 0x66, 0x90, 0xff, 0xcf, 0x20, 0x36, 0x20, 0x5a,
0xb8, 0x78, 0x72, 0xef, 0x29, 0x9e, 0x9c, 0x5f, 0x3c, 0x95, 0x3f, 0x15, 0x20, 0x27, 0x9a, 0xc0,
0xb5, 0x2d, 0xd3, 0xa5, 0xe8, 0x06, 0x92, 0x13, 0x87, 0x4c, 0xa9, 0x5b, 0x94, 0x78, 0x57, 0x9e,
0xed, 0xd1, 0x3f, 0xc2, 0xb5, 0xf6, 0x9a, 0xf9, 0x35, 0xe3, 0x6c, 0xec, 0x62, 0x1f, 0x44, 0xf9,
0x36, 0x09, 0x09, 0x2e, 0x47, 0x3d, 0x48, 0x8a, 0xb9, 0xc3, 0x83, 0xca, 0xd6, 0xbf, 0xdc, 0x1f,
0x58, 0x7c, 0x63, 0x0e, 0xd3, 0x8e, 0x60, 0x1f, 0x06, 0xd9, 0x90, 0x9b, 0x18, 0x16, 0xf1, 0x86,
0x62, 0x32, 0xf9, 0x57, 0xc4, 0xab, 0x03, 0xe2, 0x65, 0xde, 0xa2, 0xca, 0x44, 0xe8, 0x7c, 0xe8,
0x85, 0xa4, 0xed, 0x08, 0xce, 0x4e, 0xb6, 0x5b, 0xf4, 0x00, 0x05, 0xdd, 0xf4, 0xa8, 0x46, 0x9d,
0x80, 0x33, 0xc6, 0x39, 0x7f, 0xb1, 0x3f, 0x67, 0x47, 0xf8, 0x87, 0x59, 0x8f, 0xd7, 0xab, 0x72,
0x7e, 0x47, 0xde, 0x8e, 0xe0, 0xbc, 0x1e, 0x16, 0xa0, 0x3f, 0xc0, 0xd1, 0xcc, 0x74, 0x75, 0xcd,
0xa4, 0xe3, 0x80, 0x3a, 0xce, 0xa9, 0x7f, 0xb9, 0x3f, 0xf5, 0x9d, 0x0f, 0x10, 0xe6, 0x46, 0xec,
0x7e, 0xdc, 0x55, 0xb4, 0x23, 0xb8, 0x30, 0xdb, 0x91, 0xb0, 0x73, 0xdf, 0x5b, 0x96, 0x41, 0x89,
0x19, 0x90, 0x27, 0x0e, 0x3d, 0x77, 0x53, 0xf8, 0x3f, 0x39, 0xf7, 0x8e, 0x9c, 0x9d, 0xfb, 0x3e,
0x2c, 0x40, 0x1e, 0xe4, 0x5d, 0xcf, 0xd1, 0x4d, 0x2d, 0x20, 0x4e, 0x72, 0xe2, 0x9f, 0x1f, 0x50,
0x3b, 0xdc, 0x3d, 0xcc, 0x2b, 0x2e, 0xc4, 0x90, 0xb8, 0x1d, 0xc1, 0x39, 0x37, 0xb4, 0x47, 0xd7,
0xc1, 0x15, 0x92, 0xe2, 0x6c, 0x5f, 0xec, 0xcf, 0xc6, 0xe7, 0x61, 0x50, 0xa8, 0x02, 0xa4, 0x99,
0x84, 0x38, 0xf3, 0x54, 0x1e, 0x00, 0xb6, 0x6a, 0xf4, 0x09, 0xa4, 0x3d, 0xa2, 0x89, 0x37, 0x05,
0xeb, 0xb4, 0x5c, 0x33, 0xbb, 0x5e, 0x95, 0x53, 0x03, 0xa2, 0xf1, 0x17, 0x45, 0xca, 0x13, 0x0b,
0xd4, 0x04, 0x64, 0x13, 0xc7, 0xd3, 0x3d, 0xdd, 0x32, 0x99, 0xf5, 0xf0, 0x1b, 0x62, 0xb0, 0x5a,
0x67, 0x1e, 0x27, 0xeb, 0x55, 0x59, 0xbe, 0x0d, 0xb4, 0x57, 0x74, 0xfe, 0x6b, 0x62, 0xb8, 0x58,
0xb6, 0x1f, 0x49, 0x94, 0x3f, 0x4b, 0x90, 0x0d, 0xf5, 0x10, 0x7a, 0x05, 0x71, 0x8f, 0x68, 0x41,
0x87, 0xab, 0xcf, 0x3f, 0xaa, 0x88, 0xe6, 0xb7, 0x34, 0xf7, 0x41, 0x3d, 0xc8, 0x30, 0xc3, 0x21,
0x1f, 0x94, 0x51, 0x3e, 0x28, 0xeb, 0xfb, 0xe7, 0xe7, 0x82, 0x78, 0x84, 0x8f, 0xc9, 0xf4, 0xd8,
0x5f, 0x29, 0xbf, 0x02, 0xf9, 0x71, 0x23, 0xb2, 0x27, 0xd9, 0xe6, 0x91, 0x26, 0xc2, 0x94, 0x71,
0x48, 0x82, 0x4e, 0x21, 0xc9, 0xc7, 0x97, 0x48, 0x84, 0x84, 0xfd, 0x9d, 0x72, 0x0d, 0xe8, 0x69,
0x83, 0x1d, 0x88, 0x16, 0xdb, 0xa0, 0xdd, 0xc0, 0x07, 0xef, 0xe9, 0x99, 0x03, 0xe1, 0xe2, 0xe1,
0xe0, 0x9e, 0x76, 0xc1, 0x81, 0x68, 0xe9, 0x0d, 0xda, 0x15, 0x1c, 0x3f, 0x29, 0xed, 0x03, 0xc1,
0x32, 0x01, 0x58, 0xa5, 0x0f, 0x19, 0x0e, 0xe0, 0x5f, 0x55, 0x49, 0xff, 0xa2, 0x8d, 0x28, 0x1f,
0x2c, 0x96, 0xea, 0xd1, 0x46, 0xe5, 0xdf, 0xb5, 0x65, 0x48, 0x6e, 0xee, 0xeb, 0x5d, 0x03, 0x11,
0x8b, 0x7f, 0x13, 0xfd, 0x5d, 0x82, 0x74, 0xf0, 0xbd, 0xd1, 0xf7, 0x21, 0xf1, 0xfa, 0xba, 0xd7,
0x18, 0xc8, 0x11, 0xe5, 0x78, 0xb1, 0x54, 0xf3, 0x81, 0x82, 0x7f, 0x7a, 0xa4, 0x42, 0xaa, 0xd3,
0x1d, 0xb4, 0x2e, 0x5b, 0x38, 0x80, 0x0c, 0xf4, 0xfe, 0xe7, 0x44, 0x15, 0x48, 0xdf, 0x75, 0xfb,
0x9d, 0xcb, 0x6e, 0xeb, 0x42, 0x8e, 0x8a, 0x3b, 0x32, 0x30, 0x09, 0xbe, 0x11, 0x43, 0x69, 0xf6,
0x7a, 0xd7, 0xad, 0x46, 0x57, 0x8e, 0xed, 0xa2, 0xf8, 0x79, 0x47, 0x25, 0x48, 0xf6, 0x07, 0xb8,
0xd3, 0xbd, 0x94, 0xe3, 0x0a, 0x5a, 0x2c, 0xd5, 0x42, 0x60, 0x20, 0x52, 0xe9, 0x07, 0xfe, 0x17,
0x09, 0x4e, 0xce, 0x89, 0x4d, 0xee, 0x75, 0x43, 0xf7, 0x74, 0xea, 0x6e, 0xee, 0xc6, 0x1e, 0xc4,
0x47, 0xc4, 0x0e, 0xfa, 0xe6, 0xf9, 0x21, 0xf4, 0x3e, 0x00, 0x26, 0x74, 0xf9, 0xe3, 0x0e, 0x73,
0x20, 0xe5, 0x67, 0x90, 0xd9, 0x88, 0x0e, 0x7a, 0xef, 0x1d, 0x41, 0x9e, 0xbf, 0x46, 0x03, 0xe4,
0xca, 0x4b, 0x78, 0xf4, 0x9b, 0xc3, 0x9c, 0x5d, 0x8f, 0x38, 0x1e, 0x07, 0x8c, 0x61, 0xb1, 0x61,
0x24, 0xd4, 0x1c, 0x73, 0xc0, 0x18, 0x66, 0xcb, 0xfa, 0xdb, 0x28, 0xa4, 0xfa, 0x22, 0x68, 0xf4,
0x3b, 0x88, 0xb3, 0x76, 0x45, 0xd5, 0x7d, 0x1f, 0xcd, 0xca, 0x0f, 0xf7, 0xee, 0xfd, 0x9f, 0x48,
0xe8, 0x2b, 0xc8, 0x85, 0xd3, 0x82, 0x4e, 0x9f, 0xbc, 0x90, 0x5b, 0xec, 0x0f, 0x52, 0xf9, 0xe9,
0xc1, 0x99, 0x45, 0x57, 0x20, 0x9e, 0xe7, 0xdf, 0x89, 0xf9, 0xa3, 0x67, 0x31, 0x77, 0x92, 0xd9,
0x2c, 0xbf, 0xfb, 0x77, 0x29, 0xf2, 0x6e, 0x5d, 0x92, 0xfe, 0xb9, 0x2e, 0x49, 0xff, 0x5a, 0x97,
0xa4, 0xb7, 0xff, 0x29, 0x45, 0x7e, 0xcb, 0xe7, 0x1e, 0x1b, 0x7b, 0xee, 0x7d, 0x92, 0x83, 0x7f,
0xfe, 0xff, 0x00, 0x00, 0x00, 0xff, 0xff, 0x86, 0x7c, 0x8a, 0x06, 0x64, 0x0f, 0x00, 0x00,
var fileDescriptor_storage_common_01b6ac29b3fb8162 = []byte{
// 1539 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x57, 0x5f, 0x8f, 0x2a, 0x49,
0x15, 0xa7, 0xf9, 0xcf, 0xe1, 0xcf, 0xf4, 0xad, 0xc5, 0x09, 0xdb, 0xd7, 0x85, 0x5e, 0x62, 0x36,
0xa8, 0x2b, 0xa3, 0xec, 0x6e, 0xbc, 0xb9, 0xea, 0x03, 0xcc, 0x70, 0x07, 0x9c, 0x19, 0x98, 0x14,
0x8c, 0x71, 0x4d, 0x0c, 0xa9, 0x81, 0xa2, 0xb7, 0xb3, 0x4d, 0x77, 0xdb, 0xdd, 0x6c, 0x86, 0xc4,
0x77, 0x37, 0x3c, 0x5d, 0x5f, 0x4d, 0x48, 0x4c, 0x7c, 0xf4, 0xdd, 0xcf, 0x70, 0xdf, 0xf4, 0x13,
0x10, 0xc5, 0x0f, 0x61, 0xe2, 0x93, 0xa9, 0xaa, 0x6e, 0x68, 0x66, 0xae, 0x13, 0x78, 0xab, 0x3a,
0x7f, 0x7e, 0xbf, 0x53, 0xa7, 0xcf, 0x39, 0x55, 0x0d, 0x45, 0xd7, 0xb3, 0x1c, 0xa2, 0xd1, 0xd1,
0xd8, 0x9a, 0xcd, 0x2c, 0xb3, 0x6e, 0x3b, 0x96, 0x67, 0xa1, 0x97, 0xba, 0x39, 0x35, 0xe6, 0x0f,
0x13, 0xe2, 0x91, 0xba, 0x6d, 0x10, 0x6f, 0x6a, 0x39, 0xb3, 0xba, 0x6f, 0xa9, 0x14, 0x35, 0x4b,
0xb3, 0xb8, 0xdd, 0x19, 0x5b, 0x09, 0x17, 0xe5, 0xa5, 0x66, 0x59, 0x9a, 0x41, 0xcf, 0xf8, 0xee,
0x7e, 0x3e, 0x3d, 0xa3, 0x33, 0xdb, 0x5b, 0xf8, 0xca, 0x0f, 0x1f, 0x2b, 0x89, 0x19, 0xa8, 0x4e,
0x6c, 0x87, 0x4e, 0xf4, 0x31, 0xf1, 0xa8, 0x10, 0x54, 0xff, 0x93, 0x86, 0x2c, 0xa6, 0x64, 0x82,
0xe9, 0xef, 0xe6, 0xd4, 0xf5, 0x90, 0x01, 0x27, 0x9e, 0x3e, 0xa3, 0xae, 0x47, 0x66, 0xf6, 0xc8,
0x21, 0xa6, 0x46, 0x4b, 0x51, 0x55, 0xaa, 0x65, 0x1b, 0x3f, 0xac, 0x3f, 0x13, 0x65, 0x7d, 0x18,
0xf8, 0x60, 0xe6, 0xd2, 0x3a, 0x7d, 0xb7, 0xae, 0x44, 0x36, 0xeb, 0x4a, 0x61, 0x5f, 0x8e, 0x0b,
0xde, 0xde, 0x1e, 0x95, 0x01, 0x26, 0xd4, 0x1d, 0x53, 0x73, 0xa2, 0x9b, 0x5a, 0x29, 0xa6, 0x4a,
0xb5, 0x34, 0x0e, 0x49, 0xd0, 0xa7, 0x00, 0x9a, 0x63, 0xcd, 0xed, 0xd1, 0xd7, 0x74, 0xe1, 0x96,
0xe2, 0x6a, 0xac, 0x96, 0x69, 0xe5, 0x37, 0xeb, 0x4a, 0xe6, 0x92, 0x49, 0xaf, 0xe8, 0xc2, 0xc5,
0x19, 0x2d, 0x58, 0xa2, 0x0b, 0xc8, 0x6c, 0x8f, 0x57, 0x4a, 0xf0, 0xa8, 0x3f, 0x79, 0x36, 0xea,
0xdb, 0xc0, 0x1a, 0xef, 0x1c, 0x51, 0x03, 0x72, 0x2e, 0x75, 0x74, 0xea, 0x8e, 0x0c, 0x7d, 0xa6,
0x7b, 0xa5, 0xa4, 0x2a, 0xd5, 0x62, 0xad, 0x93, 0xcd, 0xba, 0x92, 0x1d, 0x70, 0xf9, 0x35, 0x13,
0xe3, 0xac, 0xbb, 0xdb, 0xa0, 0x2f, 0x20, 0xef, 0xfb, 0x58, 0xd3, 0xa9, 0x4b, 0xbd, 0x52, 0x8a,
0x3b, 0xc9, 0x9b, 0x75, 0x25, 0x27, 0x9c, 0xfa, 0x5c, 0x8e, 0x7d, 0x68, 0xb1, 0x63, 0x54, 0xb6,
0xa5, 0x9b, 0x5e, 0x40, 0x95, 0xde, 0x51, 0xdd, 0x72, 0xb9, 0x4f, 0x65, 0xef, 0x36, 0xec, 0x90,
0x44, 0xd3, 0x1c, 0xaa, 0xb1, 0x43, 0x66, 0x0e, 0x38, 0x64, 0x33, 0xb0, 0xc6, 0x3b, 0x47, 0x34,
0x84, 0x84, 0xe7, 0x90, 0x31, 0x2d, 0x81, 0x1a, 0xab, 0x65, 0x1b, 0x9f, 0x3d, 0x8b, 0x10, 0xaa,
0x8f, 0xfa, 0x90, 0x79, 0xb5, 0x4d, 0xcf, 0x59, 0xb4, 0x32, 0x9b, 0x75, 0x25, 0xc1, 0xf7, 0x58,
0x80, 0xa1, 0x0b, 0x48, 0xf0, 0xaf, 0x51, 0xca, 0xaa, 0x52, 0xad, 0xd0, 0xa8, 0x1f, 0x8c, 0xca,
0x3f, 0x27, 0x16, 0xce, 0xe8, 0x53, 0x48, 0x7c, 0xc5, 0xce, 0x5b, 0xca, 0xa9, 0x52, 0x2d, 0xd5,
0x3a, 0x65, 0x34, 0x1d, 0x26, 0xf8, 0xef, 0xba, 0x92, 0x61, 0x8b, 0x37, 0x06, 0xd1, 0x5c, 0x2c,
0x8c, 0x50, 0x1b, 0xb2, 0x0e, 0x25, 0x93, 0x91, 0x6b, 0xcd, 0x9d, 0x31, 0x2d, 0xe5, 0x79, 0x46,
0x8a, 0x75, 0xd1, 0x02, 0xf5, 0xa0, 0x05, 0xea, 0x4d, 0x73, 0xd1, 0x2a, 0x6c, 0xd6, 0x15, 0x60,
0xb4, 0x03, 0x6e, 0x8b, 0xc1, 0xd9, 0xae, 0x95, 0x57, 0x00, 0xbb, 0xa3, 0x21, 0x19, 0x62, 0x5f,
0xd3, 0x45, 0x49, 0x52, 0xa5, 0x5a, 0x06, 0xb3, 0x25, 0x2a, 0x42, 0xe2, 0x1b, 0x62, 0xcc, 0x45,
0x37, 0x64, 0xb0, 0xd8, 0xbc, 0x8e, 0xbe, 0x92, 0xaa, 0x7f, 0x90, 0x20, 0xc1, 0xe3, 0x47, 0x1f,
0x01, 0x5c, 0xe2, 0xfe, 0xdd, 0xed, 0xa8, 0xd7, 0xef, 0xb5, 0xe5, 0x88, 0x92, 0x5f, 0xae, 0x54,
0x51, 0xa9, 0x3d, 0xcb, 0xa4, 0xe8, 0x25, 0x64, 0x84, 0xba, 0x79, 0x7d, 0x2d, 0x4b, 0x4a, 0x6e,
0xb9, 0x52, 0xd3, 0x5c, 0xdb, 0x34, 0x0c, 0xf4, 0x21, 0xa4, 0x85, 0xb2, 0xf5, 0xa5, 0x1c, 0x55,
0xb2, 0xcb, 0x95, 0x9a, 0xe2, 0xba, 0xd6, 0x02, 0x7d, 0x0c, 0x39, 0xa1, 0x6a, 0xff, 0xfa, 0xbc,
0x7d, 0x3b, 0x94, 0x63, 0xca, 0xc9, 0x72, 0xa5, 0x66, 0xb9, 0xba, 0xfd, 0x30, 0xa6, 0xb6, 0xa7,
0xc4, 0xbf, 0xfd, 0x4b, 0x39, 0x52, 0xfd, 0xab, 0x04, 0xbb, 0xfc, 0x30, 0xba, 0x4e, 0xb7, 0x37,
0x0c, 0x82, 0xe1, 0x74, 0x4c, 0xcb, 0x63, 0xf9, 0x1e, 0x14, 0x7c, 0xe5, 0xe8, 0xb6, 0xdf, 0xed,
0x0d, 0x07, 0xb2, 0xa4, 0xc8, 0xcb, 0x95, 0x9a, 0x13, 0x16, 0xa2, 0xfa, 0xc2, 0x56, 0x83, 0x36,
0xee, 0xb6, 0x07, 0x72, 0x34, 0x6c, 0x25, 0x2a, 0x1b, 0x9d, 0x41, 0x91, 0x5b, 0x0d, 0xce, 0x3b,
0xed, 0x9b, 0x26, 0x3b, 0xdd, 0x68, 0xd8, 0xbd, 0x69, 0xcb, 0x71, 0xe5, 0x3b, 0xcb, 0x95, 0xfa,
0x82, 0xd9, 0x0e, 0xc6, 0x5f, 0xd1, 0x19, 0x69, 0x1a, 0x06, 0x9b, 0x07, 0x7e, 0xb4, 0x7f, 0x97,
0x20, 0xb3, 0xad, 0x4d, 0xd4, 0x81, 0xb8, 0xb7, 0xb0, 0x29, 0x4f, 0x79, 0xa1, 0xf1, 0xf9, 0x61,
0x15, 0xbd, 0x5b, 0x0d, 0x17, 0x36, 0xc5, 0x1c, 0xa1, 0xfa, 0x00, 0xf9, 0x3d, 0x31, 0xaa, 0x40,
0xdc, 0xcf, 0x01, 0x8f, 0x67, 0x4f, 0xc9, 0x93, 0xf1, 0x11, 0xc4, 0x06, 0x77, 0x37, 0xb2, 0xa4,
0x14, 0x97, 0x2b, 0x55, 0xde, 0xd3, 0x0f, 0xe6, 0x33, 0xf4, 0x31, 0x24, 0xce, 0xfb, 0x77, 0xbd,
0xa1, 0x1c, 0x55, 0x4e, 0x97, 0x2b, 0x15, 0xed, 0x19, 0x9c, 0x5b, 0x73, 0x33, 0xc8, 0xff, 0x8f,
0x20, 0x36, 0x24, 0x5a, 0xb8, 0x78, 0x72, 0xef, 0x29, 0x9e, 0x9c, 0x5f, 0x3c, 0xd5, 0x3f, 0x16,
0x20, 0x27, 0x9a, 0xc0, 0xb5, 0x2d, 0xd3, 0xa5, 0xe8, 0x06, 0x92, 0x53, 0x87, 0xcc, 0xa8, 0x5b,
0x92, 0x78, 0x57, 0x9e, 0x1d, 0xd0, 0x3f, 0xc2, 0xb5, 0xfe, 0x86, 0xf9, 0xb5, 0xe2, 0x6c, 0xec,
0x62, 0x1f, 0x44, 0xf9, 0x36, 0x09, 0x09, 0x2e, 0x47, 0x7d, 0x48, 0x8a, 0xb9, 0xc3, 0x83, 0xca,
0x36, 0xbe, 0x38, 0x1c, 0x58, 0x7c, 0x63, 0x0e, 0xd3, 0x89, 0x60, 0x1f, 0x06, 0xd9, 0x90, 0x9b,
0x1a, 0x16, 0xf1, 0x46, 0x62, 0x32, 0xf9, 0x57, 0xc4, 0xeb, 0x23, 0xe2, 0x65, 0xde, 0xa2, 0xca,
0x44, 0xe8, 0x7c, 0xe8, 0x85, 0xa4, 0x9d, 0x08, 0xce, 0x4e, 0x77, 0x5b, 0xf4, 0x00, 0x05, 0xdd,
0xf4, 0xa8, 0x46, 0x9d, 0x80, 0x33, 0xc6, 0x39, 0x7f, 0x7e, 0x38, 0x67, 0x57, 0xf8, 0x87, 0x59,
0x5f, 0x6c, 0xd6, 0x95, 0xfc, 0x9e, 0xbc, 0x13, 0xc1, 0x79, 0x3d, 0x2c, 0x40, 0xbf, 0x87, 0x93,
0xb9, 0xe9, 0xea, 0x9a, 0x49, 0x27, 0x01, 0x75, 0x9c, 0x53, 0xff, 0xe2, 0x70, 0xea, 0x3b, 0x1f,
0x20, 0xcc, 0x8d, 0xd8, 0xfd, 0xb8, 0xaf, 0xe8, 0x44, 0x70, 0x61, 0xbe, 0x27, 0x61, 0xe7, 0xbe,
0xb7, 0x2c, 0x83, 0x12, 0x33, 0x20, 0x4f, 0x1c, 0x7b, 0xee, 0x96, 0xf0, 0x7f, 0x72, 0xee, 0x3d,
0x39, 0x3b, 0xf7, 0x7d, 0x58, 0x80, 0x3c, 0xc8, 0xbb, 0x9e, 0xa3, 0x9b, 0x5a, 0x40, 0x9c, 0xe4,
0xc4, 0x3f, 0x3b, 0xa2, 0x76, 0xb8, 0x7b, 0x98, 0x57, 0x5c, 0x88, 0x21, 0x71, 0x27, 0x82, 0x73,
0x6e, 0x68, 0x8f, 0xae, 0x83, 0x2b, 0x24, 0xc5, 0xd9, 0x3e, 0x3f, 0x9c, 0x8d, 0xcf, 0xc3, 0xa0,
0x50, 0x05, 0x48, 0x2b, 0x09, 0x71, 0xe6, 0xa9, 0x3c, 0x00, 0xec, 0xd4, 0xe8, 0x13, 0x48, 0x7b,
0x44, 0x13, 0x6f, 0x0a, 0xd6, 0x69, 0xb9, 0x56, 0x76, 0xb3, 0xae, 0xa4, 0x86, 0x44, 0xe3, 0x2f,
0x8a, 0x94, 0x27, 0x16, 0xa8, 0x05, 0xc8, 0x26, 0x8e, 0xa7, 0x7b, 0xba, 0x65, 0x32, 0xeb, 0xd1,
0x37, 0xc4, 0x60, 0xb5, 0xce, 0x3c, 0x8a, 0x9b, 0x75, 0x45, 0xbe, 0x0d, 0xb4, 0x57, 0x74, 0xf1,
0x2b, 0x62, 0xb8, 0x58, 0xb6, 0x1f, 0x49, 0x94, 0x3f, 0x49, 0x90, 0x0d, 0xf5, 0x10, 0x7a, 0x0d,
0x71, 0x8f, 0x68, 0x41, 0x87, 0xab, 0xcf, 0x3f, 0xaa, 0x88, 0xe6, 0xb7, 0x34, 0xf7, 0x41, 0x7d,
0xc8, 0x30, 0xc3, 0x11, 0x1f, 0x94, 0x51, 0x3e, 0x28, 0x1b, 0x87, 0xe7, 0xe7, 0x82, 0x78, 0x84,
0x8f, 0xc9, 0xf4, 0xc4, 0x5f, 0x29, 0xbf, 0x04, 0xf9, 0x71, 0x23, 0xb2, 0x27, 0xd9, 0xf6, 0x91,
0x26, 0xc2, 0x94, 0x71, 0x48, 0x82, 0x4e, 0x21, 0xc9, 0xc7, 0x97, 0x48, 0x84, 0x84, 0xfd, 0x9d,
0x72, 0x0d, 0xe8, 0x69, 0x83, 0x1d, 0x89, 0x16, 0xdb, 0xa2, 0xdd, 0xc0, 0x07, 0xef, 0xe9, 0x99,
0x23, 0xe1, 0xe2, 0xe1, 0xe0, 0x9e, 0x76, 0xc1, 0x91, 0x68, 0xe9, 0x2d, 0xda, 0x15, 0xbc, 0x78,
0x52, 0xda, 0x47, 0x82, 0x65, 0x02, 0xb0, 0xea, 0x00, 0x32, 0x1c, 0xc0, 0xbf, 0xaa, 0x92, 0xfe,
0x45, 0x1b, 0x51, 0x3e, 0x58, 0xae, 0xd4, 0x93, 0xad, 0xca, 0xbf, 0x6b, 0x2b, 0x90, 0xdc, 0xde,
0xd7, 0xfb, 0x06, 0x22, 0x16, 0xff, 0x26, 0xfa, 0x9b, 0x04, 0xe9, 0xe0, 0x7b, 0xa3, 0xef, 0x42,
0xe2, 0xcd, 0x75, 0xbf, 0x39, 0x94, 0x23, 0xca, 0x8b, 0xe5, 0x4a, 0xcd, 0x07, 0x0a, 0xfe, 0xe9,
0x91, 0x0a, 0xa9, 0x6e, 0x6f, 0xd8, 0xbe, 0x6c, 0xe3, 0x00, 0x32, 0xd0, 0xfb, 0x9f, 0x13, 0x55,
0x21, 0x7d, 0xd7, 0x1b, 0x74, 0x2f, 0x7b, 0xed, 0x0b, 0x39, 0x2a, 0xee, 0xc8, 0xc0, 0x24, 0xf8,
0x46, 0x0c, 0xa5, 0xd5, 0xef, 0x5f, 0xb7, 0x9b, 0x3d, 0x39, 0xb6, 0x8f, 0xe2, 0xe7, 0x1d, 0x95,
0x21, 0x39, 0x18, 0xe2, 0x6e, 0xef, 0x52, 0x8e, 0x2b, 0x68, 0xb9, 0x52, 0x0b, 0x81, 0x81, 0x48,
0xa5, 0x1f, 0xf8, 0x9f, 0x25, 0x28, 0x9e, 0x13, 0x9b, 0xdc, 0xeb, 0x86, 0xee, 0xe9, 0xd4, 0xdd,
0xde, 0x8d, 0x7d, 0x88, 0x8f, 0x89, 0x1d, 0xf4, 0xcd, 0xf3, 0x43, 0xe8, 0x7d, 0x00, 0x4c, 0xe8,
0xf2, 0xc7, 0x1d, 0xe6, 0x40, 0xca, 0x4f, 0x21, 0xb3, 0x15, 0x1d, 0xf5, 0xde, 0x3b, 0x81, 0x3c,
0x7f, 0x8d, 0x06, 0xc8, 0xd5, 0x57, 0xf0, 0xe8, 0x37, 0x87, 0x39, 0xbb, 0x1e, 0x71, 0x3c, 0x0e,
0x18, 0xc3, 0x62, 0xc3, 0x48, 0xa8, 0x39, 0xe1, 0x80, 0x31, 0xcc, 0x96, 0x8d, 0xb7, 0x51, 0x48,
0x0d, 0x44, 0xd0, 0xe8, 0xb7, 0x10, 0x67, 0xed, 0x8a, 0x6a, 0x87, 0x3e, 0x9a, 0x95, 0xef, 0x1f,
0xdc, 0xfb, 0x3f, 0x96, 0xd0, 0x97, 0x90, 0x0b, 0xa7, 0x05, 0x9d, 0x3e, 0x79, 0x21, 0xb7, 0xd9,
0x1f, 0xa4, 0xf2, 0x93, 0xa3, 0x33, 0x8b, 0xae, 0x40, 0x3c, 0xcf, 0xff, 0x2f, 0xe6, 0x0f, 0x9e,
0xc5, 0xdc, 0x4b, 0x66, 0xab, 0xf2, 0xee, 0x5f, 0xe5, 0xc8, 0xbb, 0x4d, 0x59, 0xfa, 0xc7, 0xa6,
0x2c, 0xfd, 0x73, 0x53, 0x96, 0xde, 0xfe, 0xbb, 0x1c, 0xf9, 0x0d, 0x9f, 0x7b, 0x6c, 0xec, 0xb9,
0xf7, 0x49, 0x0e, 0xfe, 0xd9, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x62, 0x34, 0xad, 0x1c, 0x4b,
0x0f, 0x00, 0x00,
}

View File

@ -2,7 +2,7 @@ syntax = "proto3";
package influxdata.platform.storage;
option go_package = "datatypes";
import "github.com/gogo/protobuf/gogoproto/gogo.proto";
import "gogoproto/gogo.proto";
import "google/protobuf/empty.proto";
import "google/protobuf/any.proto";
import "predicate.proto";

View File

@ -1,4 +1,4 @@
package reads
//go:generate tmpl -data=@array_cursor.gen.go.tmpldata array_cursor.gen.go.tmpl
//go:generate tmpl -data=@array_cursor.gen.go.tmpldata response_writer.gen.go.tmpl
//go:generate env GO111MODULE=on go run github.com/benbjohnson/tmpl -data=@array_cursor.gen.go.tmpldata array_cursor.gen.go.tmpl
//go:generate env GO111MODULE=on go run github.com/benbjohnson/tmpl -data=@array_cursor.gen.go.tmpldata response_writer.gen.go.tmpl

View File

@ -1,6 +1,6 @@
package reads
//go:generate tmpl -data=@types.tmpldata table.gen.go.tmpl
//go:generate env GO111MODULE=on go run github.com/benbjohnson/tmpl -data=@types.tmpldata table.gen.go.tmpl
import (
"fmt"

View File

@ -1,9 +1,11 @@
targets := meta.pb.go
GO_GENERATE := go generate
all: $(targets)
$(targets): meta.proto
PATH="../../../../../bin/${GOOS}:${PATH}" $(GO_GENERATE) -x ./
$(GO_GENERATE) -x
clean:
rm -f $(targets)

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_9d9298f22bde0681, []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_9d9298f22bde0681, []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_9d9298f22bde0681, []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 {
@ -373,24 +452,6 @@ func (m *StoreTaskMetaManualRun) MarshalTo(dAtA []byte) (int, error) {
return i, nil
}
func encodeFixed64Meta(dAtA []byte, offset int, v uint64) int {
dAtA[offset] = uint8(v)
dAtA[offset+1] = uint8(v >> 8)
dAtA[offset+2] = uint8(v >> 16)
dAtA[offset+3] = uint8(v >> 24)
dAtA[offset+4] = uint8(v >> 32)
dAtA[offset+5] = uint8(v >> 40)
dAtA[offset+6] = uint8(v >> 48)
dAtA[offset+7] = uint8(v >> 56)
return offset + 8
}
func encodeFixed32Meta(dAtA []byte, offset int, v uint32) int {
dAtA[offset] = uint8(v)
dAtA[offset+1] = uint8(v >> 8)
dAtA[offset+2] = uint8(v >> 16)
dAtA[offset+3] = uint8(v >> 24)
return offset + 4
}
func encodeVarintMeta(dAtA []byte, offset int, v uint64) int {
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
@ -1112,38 +1173,38 @@ var (
ErrIntOverflowMeta = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("meta.proto", fileDescriptorMeta) }
func init() { proto.RegisterFile("meta.proto", fileDescriptor_meta_9d9298f22bde0681) }
var fileDescriptorMeta = []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, 0x9d, 0x04, 0x32, 0x21, 0xad, 0x59, 0x50, 0x65, 0x40, 0x4a, 0x4d, 0x04, 0x22,
0x5c, 0x8c, 0x04, 0x12, 0x27, 0x2e, 0x34, 0x70, 0xe8, 0xa1, 0x97, 0x2d, 0x27, 0x24, 0x64, 0x6d,
0xed, 0x4d, 0x64, 0xc5, 0x9e, 0x2d, 0xbb, 0xb3, 0x90, 0xbc, 0x04, 0xe2, 0x75, 0x78, 0x03, 0x8e,
0x3c, 0x01, 0x42, 0xe1, 0x35, 0x38, 0xa0, 0xdd, 0x6d, 0x83, 0x28, 0x39, 0x20, 0x6e, 0x33, 0x9f,
0x92, 0x7f, 0xff, 0xff, 0xf7, 0x00, 0xb4, 0x92, 0x44, 0x7e, 0xa6, 0x15, 0x29, 0x76, 0xbf, 0x54,
0x6d, 0x5e, 0xe3, 0xac, 0xb1, 0xcb, 0x4a, 0x38, 0xda, 0x08, 0x9a, 0x29, 0xdd, 0xe6, 0x24, 0xcc,
0x22, 0x3f, 0x15, 0xe5, 0x42, 0x62, 0x75, 0xe7, 0x66, 0x8d, 0x24, 0x35, 0x8a, 0xe6, 0xf1, 0x5c,
0xcd, 0x55, 0xf8, 0xeb, 0xf8, 0xe7, 0x0e, 0x0c, 0x4f, 0x48, 0x69, 0xf9, 0x5a, 0x98, 0xc5, 0xb1,
0x24, 0xc1, 0x1e, 0xc2, 0x5e, 0x2b, 0x96, 0x45, 0xa9, 0xb0, 0xb4, 0x5a, 0x4b, 0x2c, 0x57, 0x69,
0x94, 0x45, 0x93, 0x2e, 0xdf, 0x6d, 0xc5, 0x72, 0xfa, 0x9b, 0xb2, 0x47, 0x90, 0x34, 0x82, 0xa4,
0xa1, 0xa2, 0x54, 0xed, 0x59, 0x23, 0x49, 0x56, 0xe9, 0x4e, 0x16, 0x4d, 0x62, 0xbe, 0x17, 0xf8,
0xf4, 0x02, 0xb3, 0x7d, 0xe8, 0x19, 0x12, 0x64, 0x4d, 0x1a, 0x67, 0xd1, 0xa4, 0xcf, 0xcf, 0x37,
0x56, 0xc2, 0x8d, 0x20, 0x47, 0xcd, 0xaa, 0xd0, 0x16, 0xb1, 0xc6, 0x79, 0xda, 0xc9, 0xe2, 0xc9,
0xe0, 0xc9, 0xb3, 0xfc, 0x5f, 0x42, 0xe5, 0x7f, 0x78, 0xe7, 0x16, 0x79, 0xb2, 0x11, 0xe4, 0x41,
0x8f, 0x3d, 0x80, 0x5d, 0x39, 0x9b, 0xc9, 0x92, 0xea, 0xf7, 0xb2, 0x28, 0xb5, 0xc2, 0xb4, 0xeb,
0x4d, 0x0c, 0x37, 0x74, 0xaa, 0x15, 0xb2, 0x5b, 0xd0, 0xad, 0x64, 0x23, 0x56, 0x69, 0xcf, 0xa7,
0x0d, 0x0b, 0x7b, 0x0b, 0x83, 0x56, 0xa0, 0x15, 0x8d, 0xb3, 0x67, 0xd2, 0xc4, 0x7b, 0x7b, 0xfe,
0x1f, 0xde, 0x8e, 0xbd, 0x8a, 0x73, 0x08, 0xed, 0xc5, 0x68, 0xc6, 0x9f, 0x23, 0x48, 0x2e, 0x47,
0x60, 0x09, 0xc4, 0xa8, 0x3e, 0xf8, 0xd6, 0x63, 0xee, 0x46, 0x47, 0x48, 0xaf, 0x7c, 0xbb, 0x43,
0xee, 0x46, 0x96, 0x41, 0x4f, 0x5b, 0x2c, 0xea, 0xca, 0x37, 0xda, 0x39, 0xec, 0xaf, 0xbf, 0x1d,
0x74, 0xb9, 0xc5, 0xa3, 0x97, 0xbc, 0xab, 0x2d, 0x1e, 0x55, 0xec, 0x00, 0x06, 0x5a, 0xe0, 0x5c,
0x16, 0x86, 0x84, 0xa6, 0xb4, 0xe3, 0xd5, 0xc0, 0xa3, 0x13, 0x47, 0xd8, 0x5d, 0xe8, 0x87, 0x1f,
0x48, 0xac, 0x7c, 0x25, 0x31, 0xbf, 0xe6, 0xc1, 0x2b, 0xac, 0xd8, 0x3d, 0xb8, 0xae, 0xe5, 0x3b,
0x2b, 0x0d, 0xc9, 0xaa, 0x10, 0xe4, 0x4b, 0x89, 0xf9, 0x60, 0xc3, 0x5e, 0xd0, 0xf8, 0x63, 0x04,
0xfb, 0xdb, 0x23, 0xba, 0x2e, 0xc3, 0xab, 0x21, 0x43, 0x58, 0x5c, 0x0a, 0xf7, 0x54, 0xb8, 0x11,
0x37, 0x6e, 0x3d, 0xa1, 0x78, 0xfb, 0x09, 0x5d, 0x36, 0xd4, 0xf9, 0xcb, 0xd0, 0xe1, 0xed, 0x2f,
0xeb, 0x51, 0xf4, 0x75, 0x3d, 0x8a, 0xbe, 0xaf, 0x47, 0xd1, 0xa7, 0x1f, 0xa3, 0x2b, 0x6f, 0xae,
0x9e, 0x7f, 0x8a, 0xd3, 0x9e, 0xbf, 0xf6, 0xa7, 0xbf, 0x02, 0x00, 0x00, 0xff, 0xff, 0x32, 0x47,
0xe7, 0x4b, 0x36, 0x03, 0x00, 0x00,
var fileDescriptor_meta_9d9298f22bde0681 = []byte{
// 468 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x92, 0x41, 0x6e, 0xd3, 0x40,
0x14, 0x86, 0x71, 0x1d, 0x07, 0xf2, 0x42, 0x5a, 0x33, 0xaa, 0x2a, 0x03, 0x52, 0x6a, 0x22, 0x10,
0x61, 0x63, 0x24, 0x90, 0x58, 0xb1, 0xa1, 0x81, 0x45, 0x17, 0xdd, 0x4c, 0x59, 0x21, 0x21, 0x6b,
0x6a, 0x4f, 0xa2, 0x28, 0xf6, 0x9b, 0x32, 0xf3, 0x06, 0x92, 0x4b, 0x20, 0xae, 0xc3, 0x0d, 0x58,
0x72, 0x02, 0x84, 0xc2, 0x35, 0x58, 0xa0, 0x99, 0x69, 0x83, 0x28, 0x59, 0x20, 0x76, 0x6f, 0x3e,
0x79, 0xfe, 0xf9, 0xff, 0xdf, 0x0f, 0xa0, 0x95, 0x24, 0x8a, 0x73, 0xad, 0x48, 0xb1, 0xfb, 0x95,
0x6a, 0x8b, 0x39, 0x4e, 0x1b, 0xbb, 0xac, 0x85, 0xa3, 0x8d, 0xa0, 0xa9, 0xd2, 0x6d, 0x41, 0xc2,
0x2c, 0x8a, 0x33, 0x51, 0x2d, 0x24, 0xd6, 0x77, 0xf6, 0x67, 0x6a, 0xa6, 0xfc, 0x85, 0xc7, 0x6e,
0x0a, 0x77, 0x47, 0x3f, 0x77, 0x60, 0x70, 0x4a, 0x4a, 0xcb, 0xd7, 0xc2, 0x2c, 0x4e, 0x24, 0x09,
0xf6, 0x10, 0xf6, 0x5a, 0xb1, 0x2c, 0x2b, 0x85, 0x95, 0xd5, 0x5a, 0x62, 0xb5, 0xca, 0xa2, 0x3c,
0x1a, 0x27, 0x7c, 0xb7, 0x15, 0xcb, 0xc9, 0x6f, 0xca, 0x1e, 0x41, 0xda, 0x08, 0x92, 0x86, 0xca,
0x4a, 0xb5, 0xe7, 0x8d, 0x24, 0x59, 0x67, 0x3b, 0x79, 0x34, 0x8e, 0xf9, 0x5e, 0xe0, 0x93, 0x4b,
0xcc, 0x0e, 0xa0, 0x6b, 0x48, 0x90, 0x35, 0x59, 0x9c, 0x47, 0xe3, 0x1e, 0xbf, 0x38, 0xb1, 0x0a,
0x6e, 0x05, 0x39, 0x6a, 0x56, 0xa5, 0xb6, 0x88, 0x73, 0x9c, 0x65, 0x9d, 0x3c, 0x1e, 0xf7, 0x9f,
0x3c, 0x2b, 0xfe, 0x25, 0x55, 0xf1, 0x87, 0x77, 0x6e, 0x91, 0xa7, 0x1b, 0x41, 0x1e, 0xf4, 0xd8,
0x03, 0xd8, 0x95, 0xd3, 0xa9, 0xac, 0x68, 0xfe, 0x5e, 0x96, 0x95, 0x56, 0x98, 0x25, 0xde, 0xc4,
0x60, 0x43, 0x27, 0x5a, 0x21, 0xdb, 0x87, 0xa4, 0x96, 0x8d, 0x58, 0x65, 0x5d, 0x9f, 0x36, 0x1c,
0xd8, 0x5b, 0xe8, 0xb7, 0x02, 0xad, 0x68, 0x9c, 0x3d, 0x93, 0xa5, 0xde, 0xdb, 0xf3, 0xff, 0xf0,
0x76, 0xe2, 0x55, 0x9c, 0x43, 0x68, 0x2f, 0x47, 0x33, 0xfa, 0x1c, 0x41, 0x7a, 0x35, 0x02, 0x4b,
0x21, 0x46, 0xf5, 0xc1, 0xb7, 0x1e, 0x73, 0x37, 0x3a, 0x42, 0x7a, 0xe5, 0xdb, 0x1d, 0x70, 0x37,
0xb2, 0x1c, 0xba, 0xda, 0x62, 0x39, 0xaf, 0x7d, 0xa3, 0x9d, 0xa3, 0xde, 0xfa, 0xdb, 0x61, 0xc2,
0x2d, 0x1e, 0xbf, 0xe4, 0x89, 0xb6, 0x78, 0x5c, 0xb3, 0x43, 0xe8, 0x6b, 0x81, 0x33, 0x59, 0x1a,
0x12, 0x9a, 0xb2, 0x8e, 0x57, 0x03, 0x8f, 0x4e, 0x1d, 0x61, 0x77, 0xa1, 0x17, 0x3e, 0x90, 0x58,
0xfb, 0x4a, 0x62, 0x7e, 0xc3, 0x83, 0x57, 0x58, 0xb3, 0x7b, 0x70, 0x53, 0xcb, 0x77, 0x56, 0x1a,
0x92, 0x75, 0x29, 0xc8, 0x97, 0x12, 0xf3, 0xfe, 0x86, 0xbd, 0xa0, 0xd1, 0xc7, 0x08, 0x0e, 0xb6,
0x47, 0x74, 0x5d, 0x86, 0x57, 0x43, 0x86, 0x70, 0x70, 0x29, 0xdc, 0x53, 0x61, 0x47, 0xdc, 0xb8,
0x75, 0x85, 0xe2, 0xed, 0x2b, 0x74, 0xd5, 0x50, 0xe7, 0x2f, 0x43, 0x47, 0xb7, 0xbf, 0xac, 0x87,
0xd1, 0xd7, 0xf5, 0x30, 0xfa, 0xbe, 0x1e, 0x46, 0x9f, 0x7e, 0x0c, 0xaf, 0xbd, 0xb9, 0x7e, 0xf1,
0x2b, 0xce, 0xba, 0x7e, 0xdb, 0x9f, 0xfe, 0x0a, 0x00, 0x00, 0xff, 0xff, 0x88, 0x78, 0xfd, 0xdc,
0x37, 0x03, 0x00, 0x00,
}

View File

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

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 . --plugin ../../bin/${GOOS}/protoc-gen-gogofaster --gogofaster_out=plugins=grpc:. ./meta.proto
//go:generate protoc -I ../../internal -I . --plugin ../../scripts/protoc-gen-gogofaster --gogofaster_out=plugins=grpc:. ./meta.proto
import (
"context"

View File

@ -3,6 +3,7 @@
package platform
import (
_ "github.com/gogo/protobuf/protoc-gen-gogo"
_ "github.com/gogo/protobuf/protoc-gen-gogofaster"
_ "github.com/goreleaser/goreleaser"
_ "github.com/kevinburke/go-bindata/go-bindata"

251
tools/tmpl/main.go Normal file
View File

@ -0,0 +1,251 @@
package main
import (
"bytes"
"encoding/json"
"flag"
"fmt"
"go/format"
"io/ioutil"
"os"
"os/exec"
"path/filepath"
"strings"
"text/template"
)
const Ext = ".tmpl"
type pathSpec struct {
in, out string
}
func (p *pathSpec) String() string { return p.in + " → " + p.out }
func (p *pathSpec) IsGoFile() bool { return filepath.Ext(p.out) == ".go" }
func parsePath(path string) (string, string) {
p := strings.IndexByte(path, '=')
if p == -1 {
if filepath.Ext(path) != Ext {
errExit("template file '%s' must have .tmpl extension", path)
}
return path, path[:len(path)-len(Ext)]
}
return path[:p], path[p+1:]
}
type data struct {
In interface{}
D listValue
}
func errExit(format string, a ...interface{}) {
fmt.Fprintf(os.Stderr, format, a...)
fmt.Fprintln(os.Stderr)
os.Exit(1)
}
type listValue map[string]string
func (l listValue) String() string {
res := make([]string, 0, len(l))
for k, v := range l {
res = append(res, fmt.Sprintf("%s=%s", k, v))
}
return strings.Join(res, ", ")
}
func (l listValue) Set(v string) error {
nv := strings.Split(v, "=")
if len(nv) != 2 {
return fmt.Errorf("expected NAME=VALUE, got %s", v)
}
l[nv[0]] = nv[1]
return nil
}
func main() {
var (
dataArg = flag.String("data", "", "input JSON data")
gi = flag.Bool("i", false, "run goimports")
in = &data{D: make(listValue)}
)
flag.Var(&in.D, "d", "-d NAME=VALUE")
flag.Parse()
if *dataArg == "" {
errExit("data option is required")
}
if *gi {
if _, err := exec.LookPath("goimports"); err != nil {
errExit("failed to find goimports: %s", err.Error())
}
formatter = formatSource
} else {
formatter = format.Source
}
paths := flag.Args()
if len(paths) == 0 {
errExit("no tmpl files specified")
}
specs := make([]pathSpec, len(paths))
for i, p := range paths {
in, out := parsePath(p)
specs[i] = pathSpec{in: in, out: out}
}
in.In = readData(*dataArg)
process(in, specs)
}
func mustReadAll(path string) []byte {
data, err := ioutil.ReadFile(path)
if err != nil {
errExit(err.Error())
}
return data
}
func readData(path string) interface{} {
data := mustReadAll(path)
var v interface{}
if err := json.Unmarshal(StripComments(data), &v); err != nil {
errExit("invalid JSON data: %s", err.Error())
}
return v
}
func fileMode(path string) os.FileMode {
stat, err := os.Stat(path)
if err != nil {
errExit(err.Error())
}
return stat.Mode()
}
var funcs = template.FuncMap{
"lower": strings.ToLower,
"upper": strings.ToUpper,
}
func process(data interface{}, specs []pathSpec) {
for _, spec := range specs {
var (
t *template.Template
err error
)
t, err = template.New("gen").Funcs(funcs).Parse(string(mustReadAll(spec.in)))
if err != nil {
errExit("error processing template '%s': %s", spec.in, err.Error())
}
var buf bytes.Buffer
if spec.IsGoFile() {
// preamble
fmt.Fprintf(&buf, "// Code generated by %s. DO NOT EDIT.\n", spec.in)
fmt.Fprintln(&buf)
}
err = t.Execute(&buf, data)
if err != nil {
errExit("error executing template '%s': %s", spec.in, err.Error())
}
generated := buf.Bytes()
if spec.IsGoFile() {
generated, err = formatter(generated)
if err != nil {
errExit("error formatting '%s': %s", spec.in, err.Error())
}
}
ioutil.WriteFile(spec.out, generated, fileMode(spec.in))
}
}
var (
formatter func([]byte) ([]byte, error)
)
func formatSource(in []byte) ([]byte, error) {
r := bytes.NewReader(in)
cmd := exec.Command("goimports")
cmd.Stdin = r
out, err := cmd.Output()
if err != nil {
if ee, ok := err.(*exec.ExitError); ok {
return nil, fmt.Errorf("error running goimports: %s", string(ee.Stderr))
}
return nil, fmt.Errorf("error running goimports: %s", string(out))
}
return out, nil
}
func StripComments(raw []byte) []byte {
var (
quoted, esc bool
comment bool
)
buf := bytes.Buffer{}
for i := 0; i < len(raw); i++ {
b := raw[i]
if comment {
switch b {
case '/':
comment = false
j := bytes.IndexByte(raw[i+1:], '\n')
if j == -1 {
i = len(raw)
} else {
i += j // keep new line
}
case '*':
j := bytes.Index(raw[i+1:], []byte("*/"))
if j == -1 {
i = len(raw)
} else {
i += j + 2
comment = false
}
}
continue
}
if esc {
esc = false
continue
}
if b == '\\' && quoted {
esc = true
continue
}
if b == '"' || b == '\'' {
quoted = !quoted
}
if b == '/' && !quoted {
comment = true
continue
}
buf.WriteByte(b)
}
if quoted || esc || comment {
// unexpected state, so return raw bytes
return raw
}
return buf.Bytes()
}

57
tools/tmpl/main_test.go Normal file
View File

@ -0,0 +1,57 @@
package main
import (
"testing"
)
func TestStripComments(t *testing.T) {
tests := []struct {
name string
in string
exp string
}{
{name: "none", in: `[1,2,3]`, exp: `[1,2,3]`},
{name: "single-line, line comment at end", in: `[1,2,3] // foo bar`, exp: `[1,2,3] `},
{name: "single-line, block comment at end", in: `[1,2,3] /* foo bar */ `, exp: `[1,2,3] `},
{name: "single-line, block comment at end", in: `[1,2,3] /* /* // */`, exp: `[1,2,3] `},
{name: "single-line, block comment in middle", in: `[1,/* foo bar */2,3]`, exp: `[1,2,3]`},
{name: "single-line, block comment in string", in: `[1,"/* foo bar */"]`, exp: `[1,"/* foo bar */"]`},
{name: "single-line, malformed block comment", in: `[1,2,/*]`, exp: `[1,2,/*]`},
{name: "single-line, malformed JSON", in: `[1,2,/]`, exp: `[1,2,/]`},
{
name: "multi-line",
in: `[
1,
2,
3
]`,
exp: `[
1,
2,
3
]`,
},
{
name: "multi-line, multiple line comments",
in: `[ // foo
1, // bar
2,
3
] // fit`,
exp: `[
1,
2,
3
] `,
},
}
for _, test := range tests {
t.Run(test.name, func(t *testing.T) {
got := string(StripComments([]byte(test.in)))
if got != test.exp {
t.Errorf("got:\n%s\nexp:\n%s", got, test.exp)
}
})
}
}

View File

@ -1,6 +1,6 @@
package tsdb
//go:generate protoc --gogo_out=. internal/meta.proto
//go:generate protoc --plugin ../scripts/protoc-gen-gogo --gogo_out=. internal/meta.proto
import (
"sort"

View File

@ -36,12 +36,12 @@ import (
"go.uber.org/zap"
)
//go:generate tmpl -data=@iterator.gen.go.tmpldata iterator.gen.go.tmpl engine.gen.go.tmpl array_cursor.gen.go.tmpl array_cursor_iterator.gen.go.tmpl
//go:generate go run ../../../_tools/tmpl/main.go -i -data=file_store.gen.go.tmpldata file_store.gen.go.tmpl=file_store.gen.go
//go:generate go run ../../../_tools/tmpl/main.go -i -d isArray=y -data=file_store.gen.go.tmpldata file_store.gen.go.tmpl=file_store_array.gen.go
//go:generate tmpl -data=@encoding.gen.go.tmpldata encoding.gen.go.tmpl
//go:generate tmpl -data=@compact.gen.go.tmpldata compact.gen.go.tmpl
//go:generate tmpl -data=@reader.gen.go.tmpldata reader.gen.go.tmpl
//go:generate env GO111MODULE=on go run github.com/benbjohnson/tmpl -data=@iterator.gen.go.tmpldata iterator.gen.go.tmpl engine.gen.go.tmpl array_cursor.gen.go.tmpl array_cursor_iterator.gen.go.tmpl
//go:generate env GO111MODULE=on go run github.com/influxdata/platform/tools/tmpl -i -data=file_store.gen.go.tmpldata file_store.gen.go.tmpl=file_store.gen.go
//go:generate env GO111MODULE=on go run github.com/influxdata/platform/tools/tmpl -i -d isArray=y -data=file_store.gen.go.tmpldata file_store.gen.go.tmpl=file_store_array.gen.go
//go:generate env GO111MODULE=on go run github.com/benbjohnson/tmpl -data=@encoding.gen.go.tmpldata encoding.gen.go.tmpl
//go:generate env GO111MODULE=on go run github.com/benbjohnson/tmpl -data=@compact.gen.go.tmpldata compact.gen.go.tmpl
//go:generate env GO111MODULE=on go run github.com/benbjohnson/tmpl -data=@reader.gen.go.tmpldata reader.gen.go.tmpl
func init() {
tsdb.RegisterEngine("tsm1", NewEngine)