mirror of
https://github.com/outbackdingo/matchbox.git
synced 2026-01-27 02:19:28 +00:00
Use a container image for protobuf code generation
* Use `quay.io/dghubble/protoc` as the standard codegen environment across projects. Pin a version (v3.10.1) * Generated code is now automatically ignored by golint based on the comment header, which will simplify linting * Upgrade protobuf from 2bba0603135d to v1.3.2 * Upgrade grpc from v1.2.1 to v1.25.1 * Remove `get-protoc` and `codegen` scripts
This commit is contained in:
Dalton Hubble
22
Makefile
22
Makefile
@@ -2,6 +2,7 @@ export CGO_ENABLED:=0
|
||||
export GO111MODULE=on
|
||||
export GOFLAGS=-mod=vendor
|
||||
|
||||
DIR := $(abspath $(dir $(lastword $(MAKEFILE_LIST))))
|
||||
VERSION=$(shell git describe --tags --match=v* --always --dirty)
|
||||
LD_FLAGS="-w -X github.com/poseidon/matchbox/matchbox/version.Version=$(VERSION)"
|
||||
|
||||
@@ -55,18 +56,17 @@ update:
|
||||
vendor:
|
||||
@go mod vendor
|
||||
|
||||
.PHONY: codegen
|
||||
codegen: tools
|
||||
@./scripts/dev/codegen
|
||||
protoc/%:
|
||||
podman run --security-opt label=disable \
|
||||
-u root \
|
||||
--mount type=bind,src=$(DIR),target=/mnt/code \
|
||||
quay.io/dghubble/protoc:v3.10.1 \
|
||||
--go_out=plugins=grpc,paths=source_relative:. $*
|
||||
|
||||
.PHONY: tools
|
||||
tools: bin/protoc bin/protoc-gen-go
|
||||
|
||||
bin/protoc:
|
||||
@./scripts/dev/get-protoc
|
||||
|
||||
bin/protoc-gen-go:
|
||||
@go build -o bin/protoc-gen-go $(REPO)/vendor/github.com/golang/protobuf/protoc-gen-go
|
||||
codegen: \
|
||||
protoc/matchbox/storage/storagepb/*.proto \
|
||||
protoc/matchbox/server/serverpb/*.proto \
|
||||
protoc/matchbox/rpc/rpcpb/*.proto
|
||||
|
||||
clean:
|
||||
@rm -rf bin
|
||||
|
||||
13
go.mod
13
go.mod
@@ -11,7 +11,7 @@ require (
|
||||
github.com/coreos/ignition v0.31.0
|
||||
github.com/coreos/pkg v0.0.0-20160221035341-66fe44ad037c
|
||||
github.com/coreos/yaml v0.0.0-20141224210557-6b16a5714269 // indirect
|
||||
github.com/golang/protobuf v0.0.0-20170331031902-2bba0603135d
|
||||
github.com/golang/protobuf v1.3.2
|
||||
github.com/inconshreveable/mousetrap v1.0.0 // indirect
|
||||
github.com/kr/pretty v0.1.0 // indirect
|
||||
github.com/sirupsen/logrus v1.3.0
|
||||
@@ -20,11 +20,12 @@ require (
|
||||
github.com/stretchr/testify v1.3.0
|
||||
github.com/vincent-petithory/dataurl v0.0.0-20160330182126-9a301d65acbb // indirect
|
||||
go4.org v0.0.0-20160314031811-03efcb870d84 // indirect
|
||||
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793
|
||||
golang.org/x/net v0.0.0-20160412225635-fb93926129b8
|
||||
golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6 // indirect
|
||||
golang.org/x/sys v0.0.0-20190209173611-3b5209105503 // indirect
|
||||
google.golang.org/grpc v1.2.1
|
||||
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2
|
||||
golang.org/x/net v0.0.0-20191119073136-fc4aabc6c914
|
||||
golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e // indirect
|
||||
golang.org/x/text v0.3.2 // indirect
|
||||
google.golang.org/genproto v0.0.0-20191115221424-83cc0476cb11 // indirect
|
||||
google.golang.org/grpc v1.25.1
|
||||
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 // indirect
|
||||
gopkg.in/yaml.v2 v2.0.0-20151201162745-f7716cbe52ba // indirect
|
||||
)
|
||||
|
||||
58
go.sum
58
go.sum
@@ -1,9 +1,13 @@
|
||||
cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
|
||||
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
|
||||
github.com/ajeddeloh/go-json v0.0.0-20160803184958-73d058cf8437 h1:gZCtZ+Hh/e3CGEX8q/yAcp8wWu5ZS6NMk6VGzpQhI3s=
|
||||
github.com/ajeddeloh/go-json v0.0.0-20160803184958-73d058cf8437/go.mod h1:otnto4/Icqn88WCcM4bhIJNSgsh9VLBuspyyCfvof9c=
|
||||
github.com/ajeddeloh/yaml v0.0.0-20170912190910-6b94386aeefd h1:NlKlOv3aVJ5ODMC0JWPvddw05KENkL3cZttIuu8kJRo=
|
||||
github.com/ajeddeloh/yaml v0.0.0-20170912190910-6b94386aeefd/go.mod h1:idhzw68Q7v4j+rQ2AGyq3OlZW2Jij9mdmGA4/Sk6J0E=
|
||||
github.com/alecthomas/units v0.0.0-20150109002421-6b4e7dc5e314 h1:NWdGjCRUTTqEqDwJRojRLiwXDW1ZJM2DSiyGfBWx874=
|
||||
github.com/alecthomas/units v0.0.0-20150109002421-6b4e7dc5e314/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
|
||||
github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
|
||||
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
|
||||
github.com/coreos/container-linux-config-transpiler v0.9.0 h1:UBGpT8qWqzi48hNLrzMAgAUNJsR0LW8Gk5/dR/caI8U=
|
||||
github.com/coreos/container-linux-config-transpiler v0.9.0/go.mod h1:SlcxXZQ2c42knj8pezMiQsM1f+ADxFMjGetuMKR/YSQ=
|
||||
github.com/coreos/coreos-cloudinit v1.13.0 h1:NAJMy7cdj722Nm6+THzKx9fH/vCb39Z1JndsKS4TS6c=
|
||||
@@ -21,8 +25,17 @@ github.com/coreos/yaml v0.0.0-20141224210557-6b16a5714269/go.mod h1:Bl1D/T9QJhVd
|
||||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
|
||||
github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
|
||||
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b h1:VKtxabqXZkF25pY9ekfRL6a582T4P37/31XEstQ5p58=
|
||||
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
|
||||
github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
|
||||
github.com/golang/protobuf v0.0.0-20170331031902-2bba0603135d h1:KmiEmEGA5sqizMpKnexwioxj8zEUSBc7p9UTQu36lpQ=
|
||||
github.com/golang/protobuf v0.0.0-20170331031902-2bba0603135d/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/golang/protobuf v1.3.2 h1:6nsPYzhq5kReh6QImI3k5qWzO4PEbvbIW2cwSfR/6xs=
|
||||
github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
|
||||
github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
|
||||
github.com/inconshreveable/mousetrap v1.0.0 h1:Z8tu5sraLXCXIcARxBp/8cbvlwVa7Z1NHg9XEKhtSvM=
|
||||
github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
|
||||
github.com/konsorten/go-windows-terminal-sequences v1.0.1 h1:mweAR1A6xJ3oS2pRaGiHgQ4OO8tzTaLawm8vnODuwDk=
|
||||
@@ -34,6 +47,7 @@ github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
|
||||
github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
|
||||
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
|
||||
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
|
||||
github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
|
||||
github.com/sirupsen/logrus v1.3.0 h1:hI/7Q+DtNZ2kINb6qt/lS+IyXnHQe9e90POfeewL/ME=
|
||||
github.com/sirupsen/logrus v1.3.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
|
||||
github.com/spf13/cobra v0.0.0-20160208220627-65a708cee0a4 h1:YWnu4r9zC05ic4XVJR+X7zxHI/lv5Ha9QPYx3gZvQHw=
|
||||
@@ -53,16 +67,60 @@ go4.org v0.0.0-20160314031811-03efcb870d84 h1:WZkGC1qzoax/QSt84wmvIxk+ZOmGIChsTz
|
||||
go4.org v0.0.0-20160314031811-03efcb870d84/go.mod h1:MkTOUMDaeVYJUOUsaDXIhWPZYa1yOyC1qaOBpL57BhE=
|
||||
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793 h1:u+LnwYTOOW7Ukr/fppxEb1Nwz0AtPflrblfvUudpo+I=
|
||||
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
|
||||
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2 h1:VklqNMn3ovrHsnt90PveolxSbWFaJdECFbxSq0Mqo2M=
|
||||
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
|
||||
golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
|
||||
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
|
||||
golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
|
||||
golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
|
||||
golang.org/x/net v0.0.0-20160412225635-fb93926129b8 h1:5Lew4KHjm6QAzkboL0Sdg03Nc3VtVcno+Mdcvclquco=
|
||||
golang.org/x/net v0.0.0-20160412225635-fb93926129b8/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
|
||||
golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
|
||||
golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
|
||||
golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
|
||||
golang.org/x/net v0.0.0-20190311183353-d8887717615a h1:oWX7TPOiFAMXLq8o0ikBYfCJVlRHBcsciT5bXOrH628=
|
||||
golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
|
||||
golang.org/x/net v0.0.0-20191119073136-fc4aabc6c914 h1:MlY3mEfbnWGmUi4rtHOtNnnnN4UJRGSyLPx+DXA5Sq4=
|
||||
golang.org/x/net v0.0.0-20191119073136-fc4aabc6c914/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
|
||||
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
|
||||
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6 h1:bjcUS9ztw9kFmmIxJInhon/0Is3p+EHBKNgquIzo1OI=
|
||||
golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20190209173611-3b5209105503 h1:5SvYFrOM3W8Mexn9/oA44Ji7vhXAZQ9hiP+1Q/DMrWg=
|
||||
golang.org/x/sys v0.0.0-20190209173611-3b5209105503/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a h1:1BGLXjeY4akVXGgbC9HugT3Jv3hCI0z56oJR5vAMgBU=
|
||||
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||
golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e h1:N7DeIrjYszNmSW409R3frPPwglRwMkXSBzwVbkOjLLA=
|
||||
golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||
golang.org/x/text v0.3.0 h1:g61tztE5qeGQ89tm6NTjjM9VPIm088od1l6aSorWRWg=
|
||||
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||
golang.org/x/text v0.3.2 h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs=
|
||||
golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
|
||||
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
|
||||
golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
|
||||
golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
|
||||
golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
|
||||
golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
|
||||
google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
|
||||
google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
|
||||
google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
|
||||
google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55 h1:gSJIx1SDwno+2ElGhA4+qG2zF97qiUzTM+rQ0klBOcE=
|
||||
google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
|
||||
google.golang.org/genproto v0.0.0-20191115221424-83cc0476cb11 h1:51D++eCgOHufw5VfDE9Uzqyyc+OyQIjb9hkYy9LN5Fk=
|
||||
google.golang.org/genproto v0.0.0-20191115221424-83cc0476cb11/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
|
||||
google.golang.org/grpc v1.2.1 h1:uXbsPclX7+aYIzPCched4e5D5dguzKH7wW8cyJ9r2Pk=
|
||||
google.golang.org/grpc v1.2.1/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw=
|
||||
google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
|
||||
google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg=
|
||||
google.golang.org/grpc v1.25.1 h1:wdKvqQk7IttEw92GoRyKG2IDrUIpgpj6H6m81yfeMW0=
|
||||
google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY=
|
||||
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
|
||||
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/yaml.v2 v2.0.0-20151201162745-f7716cbe52ba h1:zs5kJPNmBQxScpRIdp+2eZySRHFWheLSbXfME4zAxgw=
|
||||
gopkg.in/yaml.v2 v2.0.0-20151201162745-f7716cbe52ba/go.mod h1:JAlM8MvJe8wmxCU4Bli9HhUf9+ttbYbLASfIpnQbh74=
|
||||
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
|
||||
honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
|
||||
|
||||
@@ -1,25 +1,17 @@
|
||||
// Code generated by protoc-gen-go.
|
||||
// source: rpc.proto
|
||||
// DO NOT EDIT!
|
||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// source: matchbox/rpc/rpcpb/rpc.proto
|
||||
|
||||
/*
|
||||
Package rpcpb is a generated protocol buffer package.
|
||||
|
||||
It is generated from these files:
|
||||
rpc.proto
|
||||
|
||||
It has these top-level messages:
|
||||
*/
|
||||
package rpcpb
|
||||
|
||||
import proto "github.com/golang/protobuf/proto"
|
||||
import fmt "fmt"
|
||||
import math "math"
|
||||
import serverpb "github.com/poseidon/matchbox/matchbox/server/serverpb"
|
||||
|
||||
import (
|
||||
context "golang.org/x/net/context"
|
||||
context "context"
|
||||
fmt "fmt"
|
||||
proto "github.com/golang/protobuf/proto"
|
||||
serverpb "github.com/poseidon/matchbox/matchbox/server/serverpb"
|
||||
grpc "google.golang.org/grpc"
|
||||
codes "google.golang.org/grpc/codes"
|
||||
status "google.golang.org/grpc/status"
|
||||
math "math"
|
||||
)
|
||||
|
||||
// Reference imports to suppress errors if they are not otherwise used.
|
||||
@@ -31,7 +23,40 @@ var _ = math.Inf
|
||||
// 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.ProtoPackageIsVersion2 // please upgrade the proto package
|
||||
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
|
||||
|
||||
func init() { proto.RegisterFile("matchbox/rpc/rpcpb/rpc.proto", fileDescriptor_16cc910f0e1e5aa8) }
|
||||
|
||||
var fileDescriptor_16cc910f0e1e5aa8 = []byte{
|
||||
// 430 bytes of a gzipped FileDescriptorProto
|
||||
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x94, 0xc1, 0x4e, 0xe3, 0x30,
|
||||
0x10, 0x86, 0xb7, 0x95, 0xb6, 0xdb, 0xf5, 0x6a, 0x39, 0xe4, 0x46, 0x49, 0x29, 0xe2, 0xc2, 0x2d,
|
||||
0x11, 0xe5, 0x0d, 0x00, 0x11, 0x55, 0xea, 0xa1, 0x2a, 0xe2, 0xc2, 0xad, 0x09, 0x43, 0x1b, 0xa9,
|
||||
0x8d, 0x43, 0xec, 0x20, 0x1e, 0x09, 0xf1, 0x18, 0xbc, 0x12, 0x67, 0x24, 0x64, 0xc7, 0x76, 0x26,
|
||||
0xb1, 0x7d, 0x68, 0x6b, 0xfd, 0x9f, 0xfd, 0x77, 0xf2, 0xcf, 0xc4, 0x24, 0x3c, 0x6c, 0x78, 0xb6,
|
||||
0x4b, 0xe9, 0x5b, 0x5c, 0x95, 0x99, 0xf8, 0x94, 0xa9, 0xf8, 0x8e, 0xca, 0x8a, 0x72, 0x1a, 0xfc,
|
||||
0x96, 0xc2, 0xe4, 0xc2, 0x6c, 0x62, 0x50, 0xbd, 0x42, 0xa5, 0x7e, 0xca, 0x34, 0x3e, 0x00, 0x63,
|
||||
0x9b, 0x2d, 0xb0, 0x66, 0xff, 0xfc, 0x7d, 0x48, 0x46, 0x49, 0x45, 0xeb, 0x92, 0x05, 0x37, 0x64,
|
||||
0x2c, 0x57, 0xab, 0x9a, 0x07, 0xc7, 0x91, 0x3e, 0x10, 0x69, 0x6d, 0x0d, 0x2f, 0x35, 0x30, 0x3e,
|
||||
0x99, 0xb8, 0x10, 0x2b, 0x69, 0xc1, 0xe0, 0xfc, 0x97, 0x31, 0x49, 0xc0, 0x36, 0x49, 0xc0, 0x6b,
|
||||
0x22, 0x91, 0x31, 0x59, 0x92, 0x7f, 0x52, 0xbd, 0x85, 0x3d, 0x70, 0x08, 0xc2, 0xde, 0xe6, 0x46,
|
||||
0xd6, 0x56, 0x53, 0x0f, 0x35, 0x6e, 0x77, 0xe4, 0xaf, 0x04, 0xcb, 0x9c, 0xf1, 0xa0, 0xff, 0xc7,
|
||||
0x42, 0xd4, 0x4e, 0x27, 0x4e, 0xa6, 0x7d, 0xe6, 0x9f, 0x43, 0x32, 0x5e, 0x55, 0xf4, 0x39, 0xdf,
|
||||
0x03, 0x0b, 0x16, 0x84, 0xa8, 0xb5, 0x88, 0x0b, 0x9d, 0x6c, 0x55, 0x6d, 0x1b, 0xba, 0xa1, 0xa9,
|
||||
0xaf, 0xb5, 0x12, 0xa1, 0xd9, 0x56, 0x28, 0xb6, 0xd0, 0x0d, 0x8d, 0xd5, 0x9a, 0xfc, 0x57, 0xba,
|
||||
0x8a, 0xee, 0xd4, 0x3a, 0xd0, 0x0d, 0x6f, 0xe6, 0xe5, 0xb8, 0x19, 0x0a, 0xc9, 0x00, 0xed, 0x12,
|
||||
0x70, 0x84, 0x53, 0x0f, 0x35, 0x21, 0x7e, 0x0f, 0xc8, 0x78, 0xb1, 0x2d, 0x72, 0x9e, 0xd3, 0x42,
|
||||
0x58, 0xeb, 0xb5, 0x48, 0x11, 0x59, 0x23, 0xd9, 0x61, 0xdd, 0xa1, 0xb8, 0x50, 0x0d, 0x44, 0x90,
|
||||
0x0e, 0x37, 0x94, 0xe4, 0xd4, 0x43, 0x8d, 0xdb, 0x03, 0x39, 0xd2, 0x40, 0x65, 0x39, 0xb3, 0x8f,
|
||||
0x74, 0xc3, 0x3c, 0xf3, 0x6f, 0x30, 0xcf, 0xff, 0x35, 0x20, 0x7f, 0x12, 0x28, 0xa0, 0xca, 0x33,
|
||||
0xd1, 0x78, 0xb5, 0xec, 0xcd, 0x50, 0xab, 0x3a, 0x1a, 0x8f, 0x21, 0x9e, 0x21, 0xa5, 0xf7, 0x66,
|
||||
0xa8, 0x55, 0xfd, 0x56, 0xd6, 0x0c, 0x29, 0xdd, 0x9e, 0xa1, 0x0e, 0x70, 0xcc, 0x50, 0x8f, 0x9b,
|
||||
0xa7, 0xfe, 0x18, 0x90, 0xd1, 0x3d, 0xec, 0x21, 0xe3, 0xa2, 0x4b, 0xcd, 0x4a, 0xbe, 0x62, 0xb8,
|
||||
0x4b, 0x48, 0x76, 0x74, 0xa9, 0x43, 0x71, 0xb1, 0x0d, 0x50, 0xd3, 0x86, 0x8b, 0xed, 0x00, 0x47,
|
||||
0xb1, 0x3d, 0xae, 0x3d, 0xaf, 0x2f, 0x1f, 0xe3, 0x6d, 0xce, 0x77, 0x75, 0x1a, 0x65, 0xf4, 0x10,
|
||||
0x97, 0x94, 0x41, 0xfe, 0x44, 0x8b, 0xd8, 0xdc, 0xa8, 0xf6, 0xfd, 0x9b, 0x8e, 0xe4, 0x65, 0x7a,
|
||||
0xf5, 0x13, 0x00, 0x00, 0xff, 0xff, 0x3e, 0x95, 0x02, 0xe5, 0x9c, 0x05, 0x00, 0x00,
|
||||
}
|
||||
|
||||
// Reference imports to suppress errors if they are not otherwise used.
|
||||
var _ context.Context
|
||||
@@ -41,8 +66,9 @@ var _ grpc.ClientConn
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
const _ = grpc.SupportPackageIsVersion4
|
||||
|
||||
// Client API for Groups service
|
||||
|
||||
// GroupsClient is the client API for Groups service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
|
||||
type GroupsClient interface {
|
||||
// Create a Group.
|
||||
GroupPut(ctx context.Context, in *serverpb.GroupPutRequest, opts ...grpc.CallOption) (*serverpb.GroupPutResponse, error)
|
||||
@@ -64,7 +90,7 @@ func NewGroupsClient(cc *grpc.ClientConn) GroupsClient {
|
||||
|
||||
func (c *groupsClient) GroupPut(ctx context.Context, in *serverpb.GroupPutRequest, opts ...grpc.CallOption) (*serverpb.GroupPutResponse, error) {
|
||||
out := new(serverpb.GroupPutResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Groups/GroupPut", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Groups/GroupPut", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -73,7 +99,7 @@ func (c *groupsClient) GroupPut(ctx context.Context, in *serverpb.GroupPutReques
|
||||
|
||||
func (c *groupsClient) GroupGet(ctx context.Context, in *serverpb.GroupGetRequest, opts ...grpc.CallOption) (*serverpb.GroupGetResponse, error) {
|
||||
out := new(serverpb.GroupGetResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Groups/GroupGet", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Groups/GroupGet", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -82,7 +108,7 @@ func (c *groupsClient) GroupGet(ctx context.Context, in *serverpb.GroupGetReques
|
||||
|
||||
func (c *groupsClient) GroupDelete(ctx context.Context, in *serverpb.GroupDeleteRequest, opts ...grpc.CallOption) (*serverpb.GroupDeleteResponse, error) {
|
||||
out := new(serverpb.GroupDeleteResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Groups/GroupDelete", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Groups/GroupDelete", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -91,15 +117,14 @@ func (c *groupsClient) GroupDelete(ctx context.Context, in *serverpb.GroupDelete
|
||||
|
||||
func (c *groupsClient) GroupList(ctx context.Context, in *serverpb.GroupListRequest, opts ...grpc.CallOption) (*serverpb.GroupListResponse, error) {
|
||||
out := new(serverpb.GroupListResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Groups/GroupList", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Groups/GroupList", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
// Server API for Groups service
|
||||
|
||||
// GroupsServer is the server API for Groups service.
|
||||
type GroupsServer interface {
|
||||
// Create a Group.
|
||||
GroupPut(context.Context, *serverpb.GroupPutRequest) (*serverpb.GroupPutResponse, error)
|
||||
@@ -111,6 +136,23 @@ type GroupsServer interface {
|
||||
GroupList(context.Context, *serverpb.GroupListRequest) (*serverpb.GroupListResponse, error)
|
||||
}
|
||||
|
||||
// UnimplementedGroupsServer can be embedded to have forward compatible implementations.
|
||||
type UnimplementedGroupsServer struct {
|
||||
}
|
||||
|
||||
func (*UnimplementedGroupsServer) GroupPut(ctx context.Context, req *serverpb.GroupPutRequest) (*serverpb.GroupPutResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GroupPut not implemented")
|
||||
}
|
||||
func (*UnimplementedGroupsServer) GroupGet(ctx context.Context, req *serverpb.GroupGetRequest) (*serverpb.GroupGetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GroupGet not implemented")
|
||||
}
|
||||
func (*UnimplementedGroupsServer) GroupDelete(ctx context.Context, req *serverpb.GroupDeleteRequest) (*serverpb.GroupDeleteResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GroupDelete not implemented")
|
||||
}
|
||||
func (*UnimplementedGroupsServer) GroupList(ctx context.Context, req *serverpb.GroupListRequest) (*serverpb.GroupListResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GroupList not implemented")
|
||||
}
|
||||
|
||||
func RegisterGroupsServer(s *grpc.Server, srv GroupsServer) {
|
||||
s.RegisterService(&_Groups_serviceDesc, srv)
|
||||
}
|
||||
@@ -209,11 +251,12 @@ var _Groups_serviceDesc = grpc.ServiceDesc{
|
||||
},
|
||||
},
|
||||
Streams: []grpc.StreamDesc{},
|
||||
Metadata: "rpc.proto",
|
||||
Metadata: "matchbox/rpc/rpcpb/rpc.proto",
|
||||
}
|
||||
|
||||
// Client API for Profiles service
|
||||
|
||||
// ProfilesClient is the client API for Profiles service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
|
||||
type ProfilesClient interface {
|
||||
// Create a Profile.
|
||||
ProfilePut(ctx context.Context, in *serverpb.ProfilePutRequest, opts ...grpc.CallOption) (*serverpb.ProfilePutResponse, error)
|
||||
@@ -235,7 +278,7 @@ func NewProfilesClient(cc *grpc.ClientConn) ProfilesClient {
|
||||
|
||||
func (c *profilesClient) ProfilePut(ctx context.Context, in *serverpb.ProfilePutRequest, opts ...grpc.CallOption) (*serverpb.ProfilePutResponse, error) {
|
||||
out := new(serverpb.ProfilePutResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Profiles/ProfilePut", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Profiles/ProfilePut", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -244,7 +287,7 @@ func (c *profilesClient) ProfilePut(ctx context.Context, in *serverpb.ProfilePut
|
||||
|
||||
func (c *profilesClient) ProfileGet(ctx context.Context, in *serverpb.ProfileGetRequest, opts ...grpc.CallOption) (*serverpb.ProfileGetResponse, error) {
|
||||
out := new(serverpb.ProfileGetResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Profiles/ProfileGet", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Profiles/ProfileGet", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -253,7 +296,7 @@ func (c *profilesClient) ProfileGet(ctx context.Context, in *serverpb.ProfileGet
|
||||
|
||||
func (c *profilesClient) ProfileDelete(ctx context.Context, in *serverpb.ProfileDeleteRequest, opts ...grpc.CallOption) (*serverpb.ProfileDeleteResponse, error) {
|
||||
out := new(serverpb.ProfileDeleteResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Profiles/ProfileDelete", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Profiles/ProfileDelete", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -262,15 +305,14 @@ func (c *profilesClient) ProfileDelete(ctx context.Context, in *serverpb.Profile
|
||||
|
||||
func (c *profilesClient) ProfileList(ctx context.Context, in *serverpb.ProfileListRequest, opts ...grpc.CallOption) (*serverpb.ProfileListResponse, error) {
|
||||
out := new(serverpb.ProfileListResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Profiles/ProfileList", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Profiles/ProfileList", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
// Server API for Profiles service
|
||||
|
||||
// ProfilesServer is the server API for Profiles service.
|
||||
type ProfilesServer interface {
|
||||
// Create a Profile.
|
||||
ProfilePut(context.Context, *serverpb.ProfilePutRequest) (*serverpb.ProfilePutResponse, error)
|
||||
@@ -282,6 +324,23 @@ type ProfilesServer interface {
|
||||
ProfileList(context.Context, *serverpb.ProfileListRequest) (*serverpb.ProfileListResponse, error)
|
||||
}
|
||||
|
||||
// UnimplementedProfilesServer can be embedded to have forward compatible implementations.
|
||||
type UnimplementedProfilesServer struct {
|
||||
}
|
||||
|
||||
func (*UnimplementedProfilesServer) ProfilePut(ctx context.Context, req *serverpb.ProfilePutRequest) (*serverpb.ProfilePutResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ProfilePut not implemented")
|
||||
}
|
||||
func (*UnimplementedProfilesServer) ProfileGet(ctx context.Context, req *serverpb.ProfileGetRequest) (*serverpb.ProfileGetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ProfileGet not implemented")
|
||||
}
|
||||
func (*UnimplementedProfilesServer) ProfileDelete(ctx context.Context, req *serverpb.ProfileDeleteRequest) (*serverpb.ProfileDeleteResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ProfileDelete not implemented")
|
||||
}
|
||||
func (*UnimplementedProfilesServer) ProfileList(ctx context.Context, req *serverpb.ProfileListRequest) (*serverpb.ProfileListResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ProfileList not implemented")
|
||||
}
|
||||
|
||||
func RegisterProfilesServer(s *grpc.Server, srv ProfilesServer) {
|
||||
s.RegisterService(&_Profiles_serviceDesc, srv)
|
||||
}
|
||||
@@ -380,11 +439,12 @@ var _Profiles_serviceDesc = grpc.ServiceDesc{
|
||||
},
|
||||
},
|
||||
Streams: []grpc.StreamDesc{},
|
||||
Metadata: "rpc.proto",
|
||||
Metadata: "matchbox/rpc/rpcpb/rpc.proto",
|
||||
}
|
||||
|
||||
// Client API for Ignition service
|
||||
|
||||
// IgnitionClient is the client API for Ignition service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
|
||||
type IgnitionClient interface {
|
||||
// Create or update a Container Linux Config template.
|
||||
IgnitionPut(ctx context.Context, in *serverpb.IgnitionPutRequest, opts ...grpc.CallOption) (*serverpb.IgnitionPutResponse, error)
|
||||
@@ -404,7 +464,7 @@ func NewIgnitionClient(cc *grpc.ClientConn) IgnitionClient {
|
||||
|
||||
func (c *ignitionClient) IgnitionPut(ctx context.Context, in *serverpb.IgnitionPutRequest, opts ...grpc.CallOption) (*serverpb.IgnitionPutResponse, error) {
|
||||
out := new(serverpb.IgnitionPutResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Ignition/IgnitionPut", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Ignition/IgnitionPut", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -413,7 +473,7 @@ func (c *ignitionClient) IgnitionPut(ctx context.Context, in *serverpb.IgnitionP
|
||||
|
||||
func (c *ignitionClient) IgnitionGet(ctx context.Context, in *serverpb.IgnitionGetRequest, opts ...grpc.CallOption) (*serverpb.IgnitionGetResponse, error) {
|
||||
out := new(serverpb.IgnitionGetResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Ignition/IgnitionGet", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Ignition/IgnitionGet", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -422,15 +482,14 @@ func (c *ignitionClient) IgnitionGet(ctx context.Context, in *serverpb.IgnitionG
|
||||
|
||||
func (c *ignitionClient) IgnitionDelete(ctx context.Context, in *serverpb.IgnitionDeleteRequest, opts ...grpc.CallOption) (*serverpb.IgnitionDeleteResponse, error) {
|
||||
out := new(serverpb.IgnitionDeleteResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Ignition/IgnitionDelete", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Ignition/IgnitionDelete", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
// Server API for Ignition service
|
||||
|
||||
// IgnitionServer is the server API for Ignition service.
|
||||
type IgnitionServer interface {
|
||||
// Create or update a Container Linux Config template.
|
||||
IgnitionPut(context.Context, *serverpb.IgnitionPutRequest) (*serverpb.IgnitionPutResponse, error)
|
||||
@@ -440,6 +499,20 @@ type IgnitionServer interface {
|
||||
IgnitionDelete(context.Context, *serverpb.IgnitionDeleteRequest) (*serverpb.IgnitionDeleteResponse, error)
|
||||
}
|
||||
|
||||
// UnimplementedIgnitionServer can be embedded to have forward compatible implementations.
|
||||
type UnimplementedIgnitionServer struct {
|
||||
}
|
||||
|
||||
func (*UnimplementedIgnitionServer) IgnitionPut(ctx context.Context, req *serverpb.IgnitionPutRequest) (*serverpb.IgnitionPutResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method IgnitionPut not implemented")
|
||||
}
|
||||
func (*UnimplementedIgnitionServer) IgnitionGet(ctx context.Context, req *serverpb.IgnitionGetRequest) (*serverpb.IgnitionGetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method IgnitionGet not implemented")
|
||||
}
|
||||
func (*UnimplementedIgnitionServer) IgnitionDelete(ctx context.Context, req *serverpb.IgnitionDeleteRequest) (*serverpb.IgnitionDeleteResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method IgnitionDelete not implemented")
|
||||
}
|
||||
|
||||
func RegisterIgnitionServer(s *grpc.Server, srv IgnitionServer) {
|
||||
s.RegisterService(&_Ignition_serviceDesc, srv)
|
||||
}
|
||||
@@ -516,11 +589,12 @@ var _Ignition_serviceDesc = grpc.ServiceDesc{
|
||||
},
|
||||
},
|
||||
Streams: []grpc.StreamDesc{},
|
||||
Metadata: "rpc.proto",
|
||||
Metadata: "matchbox/rpc/rpcpb/rpc.proto",
|
||||
}
|
||||
|
||||
// Client API for Generic service
|
||||
|
||||
// GenericClient is the client API for Generic service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
|
||||
type GenericClient interface {
|
||||
// Create or update a Generic template.
|
||||
GenericPut(ctx context.Context, in *serverpb.GenericPutRequest, opts ...grpc.CallOption) (*serverpb.GenericPutResponse, error)
|
||||
@@ -540,7 +614,7 @@ func NewGenericClient(cc *grpc.ClientConn) GenericClient {
|
||||
|
||||
func (c *genericClient) GenericPut(ctx context.Context, in *serverpb.GenericPutRequest, opts ...grpc.CallOption) (*serverpb.GenericPutResponse, error) {
|
||||
out := new(serverpb.GenericPutResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Generic/GenericPut", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Generic/GenericPut", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -549,7 +623,7 @@ func (c *genericClient) GenericPut(ctx context.Context, in *serverpb.GenericPutR
|
||||
|
||||
func (c *genericClient) GenericGet(ctx context.Context, in *serverpb.GenericGetRequest, opts ...grpc.CallOption) (*serverpb.GenericGetResponse, error) {
|
||||
out := new(serverpb.GenericGetResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Generic/GenericGet", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Generic/GenericGet", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -558,15 +632,14 @@ func (c *genericClient) GenericGet(ctx context.Context, in *serverpb.GenericGetR
|
||||
|
||||
func (c *genericClient) GenericDelete(ctx context.Context, in *serverpb.GenericDeleteRequest, opts ...grpc.CallOption) (*serverpb.GenericDeleteResponse, error) {
|
||||
out := new(serverpb.GenericDeleteResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Generic/GenericDelete", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Generic/GenericDelete", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
// Server API for Generic service
|
||||
|
||||
// GenericServer is the server API for Generic service.
|
||||
type GenericServer interface {
|
||||
// Create or update a Generic template.
|
||||
GenericPut(context.Context, *serverpb.GenericPutRequest) (*serverpb.GenericPutResponse, error)
|
||||
@@ -576,6 +649,20 @@ type GenericServer interface {
|
||||
GenericDelete(context.Context, *serverpb.GenericDeleteRequest) (*serverpb.GenericDeleteResponse, error)
|
||||
}
|
||||
|
||||
// UnimplementedGenericServer can be embedded to have forward compatible implementations.
|
||||
type UnimplementedGenericServer struct {
|
||||
}
|
||||
|
||||
func (*UnimplementedGenericServer) GenericPut(ctx context.Context, req *serverpb.GenericPutRequest) (*serverpb.GenericPutResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GenericPut not implemented")
|
||||
}
|
||||
func (*UnimplementedGenericServer) GenericGet(ctx context.Context, req *serverpb.GenericGetRequest) (*serverpb.GenericGetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GenericGet not implemented")
|
||||
}
|
||||
func (*UnimplementedGenericServer) GenericDelete(ctx context.Context, req *serverpb.GenericDeleteRequest) (*serverpb.GenericDeleteResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GenericDelete not implemented")
|
||||
}
|
||||
|
||||
func RegisterGenericServer(s *grpc.Server, srv GenericServer) {
|
||||
s.RegisterService(&_Generic_serviceDesc, srv)
|
||||
}
|
||||
@@ -652,11 +739,12 @@ var _Generic_serviceDesc = grpc.ServiceDesc{
|
||||
},
|
||||
},
|
||||
Streams: []grpc.StreamDesc{},
|
||||
Metadata: "rpc.proto",
|
||||
Metadata: "matchbox/rpc/rpcpb/rpc.proto",
|
||||
}
|
||||
|
||||
// Client API for Select service
|
||||
|
||||
// SelectClient is the client API for Select service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
|
||||
type SelectClient interface {
|
||||
// SelectGroup returns the Group matching the given labels.
|
||||
SelectGroup(ctx context.Context, in *serverpb.SelectGroupRequest, opts ...grpc.CallOption) (*serverpb.SelectGroupResponse, error)
|
||||
@@ -674,7 +762,7 @@ func NewSelectClient(cc *grpc.ClientConn) SelectClient {
|
||||
|
||||
func (c *selectClient) SelectGroup(ctx context.Context, in *serverpb.SelectGroupRequest, opts ...grpc.CallOption) (*serverpb.SelectGroupResponse, error) {
|
||||
out := new(serverpb.SelectGroupResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Select/SelectGroup", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Select/SelectGroup", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -683,15 +771,14 @@ func (c *selectClient) SelectGroup(ctx context.Context, in *serverpb.SelectGroup
|
||||
|
||||
func (c *selectClient) SelectProfile(ctx context.Context, in *serverpb.SelectProfileRequest, opts ...grpc.CallOption) (*serverpb.SelectProfileResponse, error) {
|
||||
out := new(serverpb.SelectProfileResponse)
|
||||
err := grpc.Invoke(ctx, "/rpcpb.Select/SelectProfile", in, out, c.cc, opts...)
|
||||
err := c.cc.Invoke(ctx, "/rpcpb.Select/SelectProfile", in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
// Server API for Select service
|
||||
|
||||
// SelectServer is the server API for Select service.
|
||||
type SelectServer interface {
|
||||
// SelectGroup returns the Group matching the given labels.
|
||||
SelectGroup(context.Context, *serverpb.SelectGroupRequest) (*serverpb.SelectGroupResponse, error)
|
||||
@@ -699,6 +786,17 @@ type SelectServer interface {
|
||||
SelectProfile(context.Context, *serverpb.SelectProfileRequest) (*serverpb.SelectProfileResponse, error)
|
||||
}
|
||||
|
||||
// UnimplementedSelectServer can be embedded to have forward compatible implementations.
|
||||
type UnimplementedSelectServer struct {
|
||||
}
|
||||
|
||||
func (*UnimplementedSelectServer) SelectGroup(ctx context.Context, req *serverpb.SelectGroupRequest) (*serverpb.SelectGroupResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method SelectGroup not implemented")
|
||||
}
|
||||
func (*UnimplementedSelectServer) SelectProfile(ctx context.Context, req *serverpb.SelectProfileRequest) (*serverpb.SelectProfileResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method SelectProfile not implemented")
|
||||
}
|
||||
|
||||
func RegisterSelectServer(s *grpc.Server, srv SelectServer) {
|
||||
s.RegisterService(&_Select_serviceDesc, srv)
|
||||
}
|
||||
@@ -753,37 +851,5 @@ var _Select_serviceDesc = grpc.ServiceDesc{
|
||||
},
|
||||
},
|
||||
Streams: []grpc.StreamDesc{},
|
||||
Metadata: "rpc.proto",
|
||||
}
|
||||
|
||||
func init() { proto.RegisterFile("rpc.proto", fileDescriptor0) }
|
||||
|
||||
var fileDescriptor0 = []byte{
|
||||
// 411 bytes of a gzipped FileDescriptorProto
|
||||
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x74, 0x94, 0xd1, 0x4e, 0xc2, 0x30,
|
||||
0x14, 0x86, 0x85, 0x44, 0x84, 0x1a, 0xbd, 0xd8, 0x9d, 0x08, 0x62, 0x7c, 0x80, 0x91, 0xe0, 0x1b,
|
||||
0xa8, 0x71, 0x21, 0xe1, 0x82, 0x60, 0x7c, 0x00, 0xb6, 0x1c, 0x61, 0x09, 0xac, 0xb3, 0xed, 0x8c,
|
||||
0x8f, 0x64, 0x7c, 0x0c, 0x5f, 0xc9, 0x6b, 0x13, 0xd3, 0xae, 0xed, 0xce, 0xd6, 0xf6, 0x8a, 0x93,
|
||||
0xff, 0xdb, 0xf9, 0x39, 0xfb, 0xcf, 0x01, 0x32, 0x62, 0x65, 0x16, 0x97, 0x8c, 0x0a, 0x1a, 0x9d,
|
||||
0xb2, 0x32, 0x2b, 0xd3, 0xf1, 0xc3, 0x2e, 0x17, 0xfb, 0x2a, 0x8d, 0x33, 0x7a, 0x9c, 0x67, 0x94,
|
||||
0x01, 0xe5, 0xf3, 0xe3, 0x56, 0x64, 0xfb, 0x94, 0x7e, 0x36, 0x05, 0x07, 0xf6, 0x01, 0x4c, 0x7f,
|
||||
0x94, 0xe9, 0xfc, 0x08, 0x9c, 0x6f, 0x77, 0xc0, 0x6b, 0xab, 0xc5, 0x57, 0x9f, 0x0c, 0x12, 0x46,
|
||||
0xab, 0x92, 0x47, 0x8f, 0x64, 0xa8, 0xaa, 0x75, 0x25, 0xa2, 0xab, 0xd8, 0x34, 0xc4, 0x46, 0xdb,
|
||||
0xc0, 0x7b, 0x05, 0x5c, 0x8c, 0xc7, 0x3e, 0xc4, 0x4b, 0x5a, 0x70, 0xb8, 0x3b, 0xb1, 0x26, 0x09,
|
||||
0xb8, 0x26, 0x09, 0x04, 0x4d, 0x14, 0xb2, 0x26, 0x2b, 0x72, 0xae, 0xd4, 0x27, 0x38, 0x80, 0x80,
|
||||
0x68, 0xd2, 0x79, 0xb8, 0x96, 0x8d, 0xd5, 0x34, 0x40, 0xad, 0xdb, 0x33, 0x19, 0x29, 0xb0, 0xca,
|
||||
0xb9, 0x88, 0xba, 0x5f, 0x2c, 0x45, 0xe3, 0x74, 0xed, 0x65, 0xc6, 0x67, 0xf1, 0xd3, 0x27, 0xc3,
|
||||
0x35, 0xa3, 0x6f, 0xf9, 0x01, 0x78, 0xb4, 0x24, 0x44, 0xd7, 0x32, 0x2e, 0xd4, 0xd9, 0xa8, 0xc6,
|
||||
0x76, 0xe2, 0x87, 0x76, 0xbe, 0xc6, 0x4a, 0x86, 0xe6, 0x5a, 0xa1, 0xd8, 0x26, 0x7e, 0x68, 0xad,
|
||||
0x36, 0xe4, 0x42, 0xeb, 0x3a, 0xba, 0x1b, 0xa7, 0xa1, 0x1d, 0xde, 0x2c, 0xc8, 0xf1, 0x32, 0x34,
|
||||
0x52, 0x01, 0xba, 0x23, 0xe0, 0x08, 0xa7, 0x01, 0x6a, 0x43, 0xfc, 0xeb, 0x91, 0xe1, 0x72, 0x57,
|
||||
0xe4, 0x22, 0xa7, 0x85, 0xb4, 0x36, 0xb5, 0x4c, 0x11, 0x59, 0x23, 0xd9, 0x63, 0xdd, 0xa2, 0x78,
|
||||
0x50, 0x03, 0x64, 0x90, 0x1e, 0x37, 0x94, 0xe4, 0x34, 0x40, 0xad, 0xdb, 0x2b, 0xb9, 0x34, 0x40,
|
||||
0x67, 0x39, 0x73, 0x5b, 0xda, 0x61, 0xde, 0x86, 0x1f, 0xb0, 0xef, 0xff, 0xdb, 0x23, 0x67, 0x09,
|
||||
0x14, 0xc0, 0xf2, 0x4c, 0x2e, 0x5e, 0x97, 0x9d, 0x1b, 0x6a, 0x54, 0xcf, 0xe2, 0x31, 0xc4, 0x37,
|
||||
0xa4, 0xf5, 0xce, 0x0d, 0x35, 0x6a, 0xd8, 0xca, 0xb9, 0x21, 0xad, 0xbb, 0x37, 0xd4, 0x02, 0x9e,
|
||||
0x1b, 0xea, 0x70, 0xfb, 0xd6, 0xdf, 0x3d, 0x32, 0x78, 0x81, 0x03, 0x64, 0x42, 0x6e, 0xa9, 0xae,
|
||||
0xd4, 0x4f, 0x0c, 0x6f, 0x09, 0xc9, 0x9e, 0x2d, 0xb5, 0x28, 0x1e, 0xb6, 0x06, 0xfa, 0xda, 0xf0,
|
||||
0xb0, 0x2d, 0xe0, 0x19, 0xb6, 0xc3, 0x8d, 0x67, 0x3a, 0x50, 0xff, 0x8c, 0xf7, 0xff, 0x01, 0x00,
|
||||
0x00, 0xff, 0xff, 0xf6, 0x7f, 0x75, 0x65, 0x71, 0x05, 0x00, 0x00,
|
||||
Metadata: "matchbox/rpc/rpcpb/rpc.proto",
|
||||
}
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
syntax = "proto3";
|
||||
package rpcpb;
|
||||
|
||||
import "github.com/coreos/matchbox/matchbox/server/serverpb/messages.proto";
|
||||
import "matchbox/server/serverpb/messages.proto";
|
||||
|
||||
option go_package = "github.com/poseidon/matchbox/matchbox/rpc/rpcpb";
|
||||
|
||||
service Groups {
|
||||
// Create a Group.
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@@ -1,7 +1,9 @@
|
||||
syntax = "proto3";
|
||||
package serverpb;
|
||||
|
||||
import "github.com/coreos/matchbox/matchbox/storage/storagepb/storage.proto";
|
||||
import "matchbox/storage/storagepb/storage.proto";
|
||||
|
||||
option go_package = "github.com/poseidon/matchbox/matchbox/server/serverpb";
|
||||
|
||||
// Selects
|
||||
|
||||
|
||||
@@ -1,23 +1,13 @@
|
||||
// Code generated by protoc-gen-go.
|
||||
// source: storage.proto
|
||||
// DO NOT EDIT!
|
||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||
// source: matchbox/storage/storagepb/storage.proto
|
||||
|
||||
/*
|
||||
Package storagepb is a generated protocol buffer package.
|
||||
|
||||
It is generated from these files:
|
||||
storage.proto
|
||||
|
||||
It has these top-level messages:
|
||||
Group
|
||||
Profile
|
||||
NetBoot
|
||||
*/
|
||||
package storagepb
|
||||
|
||||
import proto "github.com/golang/protobuf/proto"
|
||||
import fmt "fmt"
|
||||
import math "math"
|
||||
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
|
||||
@@ -28,26 +18,49 @@ var _ = math.Inf
|
||||
// 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.ProtoPackageIsVersion2 // please upgrade the proto package
|
||||
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
|
||||
|
||||
// Group selects one or more machines and matches them to a Profile.
|
||||
type Group struct {
|
||||
// machine readable Id
|
||||
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
|
||||
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
|
||||
// human readable name
|
||||
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
|
||||
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
|
||||
// Profile id
|
||||
Profile string `protobuf:"bytes,3,opt,name=profile" json:"profile,omitempty"`
|
||||
Profile string `protobuf:"bytes,3,opt,name=profile,proto3" json:"profile,omitempty"`
|
||||
// Selectors to match machines
|
||||
Selector map[string]string `protobuf:"bytes,4,rep,name=selector" json:"selector,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
||||
Selector map[string]string `protobuf:"bytes,4,rep,name=selector,proto3" json:"selector,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
|
||||
// JSON encoded metadata
|
||||
Metadata []byte `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
||||
Metadata []byte `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
||||
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
||||
XXX_unrecognized []byte `json:"-"`
|
||||
XXX_sizecache int32 `json:"-"`
|
||||
}
|
||||
|
||||
func (m *Group) Reset() { *m = Group{} }
|
||||
func (m *Group) String() string { return proto.CompactTextString(m) }
|
||||
func (*Group) ProtoMessage() {}
|
||||
func (*Group) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
|
||||
func (m *Group) Reset() { *m = Group{} }
|
||||
func (m *Group) String() string { return proto.CompactTextString(m) }
|
||||
func (*Group) ProtoMessage() {}
|
||||
func (*Group) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_5ed97bf224c67cd0, []int{0}
|
||||
}
|
||||
|
||||
func (m *Group) XXX_Unmarshal(b []byte) error {
|
||||
return xxx_messageInfo_Group.Unmarshal(m, b)
|
||||
}
|
||||
func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return xxx_messageInfo_Group.Marshal(b, m, deterministic)
|
||||
}
|
||||
func (m *Group) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_Group.Merge(m, src)
|
||||
}
|
||||
func (m *Group) XXX_Size() int {
|
||||
return xxx_messageInfo_Group.Size(m)
|
||||
}
|
||||
func (m *Group) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_Group.DiscardUnknown(m)
|
||||
}
|
||||
|
||||
var xxx_messageInfo_Group proto.InternalMessageInfo
|
||||
|
||||
func (m *Group) GetId() string {
|
||||
if m != nil {
|
||||
@@ -87,23 +100,46 @@ func (m *Group) GetMetadata() []byte {
|
||||
// Profile defines the boot and provisioning behavior of a group of machines.
|
||||
type Profile struct {
|
||||
// profile id
|
||||
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
|
||||
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
|
||||
// human readable name
|
||||
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
|
||||
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
|
||||
// ignition id
|
||||
IgnitionId string `protobuf:"bytes,3,opt,name=ignition_id,json=ignitionId" json:"ignition_id,omitempty"`
|
||||
IgnitionId string `protobuf:"bytes,3,opt,name=ignition_id,json=ignitionId,proto3" json:"ignition_id,omitempty"`
|
||||
// cloud config id
|
||||
CloudId string `protobuf:"bytes,4,opt,name=cloud_id,json=cloudId" json:"cloud_id,omitempty"`
|
||||
CloudId string `protobuf:"bytes,4,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
|
||||
// support network boot / PXE
|
||||
Boot *NetBoot `protobuf:"bytes,5,opt,name=boot" json:"boot,omitempty"`
|
||||
Boot *NetBoot `protobuf:"bytes,5,opt,name=boot,proto3" json:"boot,omitempty"`
|
||||
// generic config id
|
||||
GenericId string `protobuf:"bytes,6,opt,name=generic_id,json=genericId" json:"generic_id,omitempty"`
|
||||
GenericId string `protobuf:"bytes,6,opt,name=generic_id,json=genericId,proto3" json:"generic_id,omitempty"`
|
||||
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
||||
XXX_unrecognized []byte `json:"-"`
|
||||
XXX_sizecache int32 `json:"-"`
|
||||
}
|
||||
|
||||
func (m *Profile) Reset() { *m = Profile{} }
|
||||
func (m *Profile) String() string { return proto.CompactTextString(m) }
|
||||
func (*Profile) ProtoMessage() {}
|
||||
func (*Profile) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
|
||||
func (m *Profile) Reset() { *m = Profile{} }
|
||||
func (m *Profile) String() string { return proto.CompactTextString(m) }
|
||||
func (*Profile) ProtoMessage() {}
|
||||
func (*Profile) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_5ed97bf224c67cd0, []int{1}
|
||||
}
|
||||
|
||||
func (m *Profile) XXX_Unmarshal(b []byte) error {
|
||||
return xxx_messageInfo_Profile.Unmarshal(m, b)
|
||||
}
|
||||
func (m *Profile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return xxx_messageInfo_Profile.Marshal(b, m, deterministic)
|
||||
}
|
||||
func (m *Profile) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_Profile.Merge(m, src)
|
||||
}
|
||||
func (m *Profile) XXX_Size() int {
|
||||
return xxx_messageInfo_Profile.Size(m)
|
||||
}
|
||||
func (m *Profile) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_Profile.DiscardUnknown(m)
|
||||
}
|
||||
|
||||
var xxx_messageInfo_Profile proto.InternalMessageInfo
|
||||
|
||||
func (m *Profile) GetId() string {
|
||||
if m != nil {
|
||||
@@ -150,17 +186,40 @@ func (m *Profile) GetGenericId() string {
|
||||
// NetBoot describes network or PXE boot settings for a machine.
|
||||
type NetBoot struct {
|
||||
// the URL of the kernel image
|
||||
Kernel string `protobuf:"bytes,1,opt,name=kernel" json:"kernel,omitempty"`
|
||||
Kernel string `protobuf:"bytes,1,opt,name=kernel,proto3" json:"kernel,omitempty"`
|
||||
// the init RAM filesystem URLs
|
||||
Initrd []string `protobuf:"bytes,2,rep,name=initrd" json:"initrd,omitempty"`
|
||||
Initrd []string `protobuf:"bytes,2,rep,name=initrd,proto3" json:"initrd,omitempty"`
|
||||
// kernel args
|
||||
Args []string `protobuf:"bytes,4,rep,name=args" json:"args,omitempty"`
|
||||
Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
|
||||
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
||||
XXX_unrecognized []byte `json:"-"`
|
||||
XXX_sizecache int32 `json:"-"`
|
||||
}
|
||||
|
||||
func (m *NetBoot) Reset() { *m = NetBoot{} }
|
||||
func (m *NetBoot) String() string { return proto.CompactTextString(m) }
|
||||
func (*NetBoot) ProtoMessage() {}
|
||||
func (*NetBoot) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
|
||||
func (m *NetBoot) Reset() { *m = NetBoot{} }
|
||||
func (m *NetBoot) String() string { return proto.CompactTextString(m) }
|
||||
func (*NetBoot) ProtoMessage() {}
|
||||
func (*NetBoot) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_5ed97bf224c67cd0, []int{2}
|
||||
}
|
||||
|
||||
func (m *NetBoot) XXX_Unmarshal(b []byte) error {
|
||||
return xxx_messageInfo_NetBoot.Unmarshal(m, b)
|
||||
}
|
||||
func (m *NetBoot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return xxx_messageInfo_NetBoot.Marshal(b, m, deterministic)
|
||||
}
|
||||
func (m *NetBoot) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_NetBoot.Merge(m, src)
|
||||
}
|
||||
func (m *NetBoot) XXX_Size() int {
|
||||
return xxx_messageInfo_NetBoot.Size(m)
|
||||
}
|
||||
func (m *NetBoot) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_NetBoot.DiscardUnknown(m)
|
||||
}
|
||||
|
||||
var xxx_messageInfo_NetBoot proto.InternalMessageInfo
|
||||
|
||||
func (m *NetBoot) GetKernel() string {
|
||||
if m != nil {
|
||||
@@ -185,33 +244,39 @@ func (m *NetBoot) GetArgs() []string {
|
||||
|
||||
func init() {
|
||||
proto.RegisterType((*Group)(nil), "storagepb.Group")
|
||||
proto.RegisterMapType((map[string]string)(nil), "storagepb.Group.SelectorEntry")
|
||||
proto.RegisterType((*Profile)(nil), "storagepb.Profile")
|
||||
proto.RegisterType((*NetBoot)(nil), "storagepb.NetBoot")
|
||||
}
|
||||
|
||||
func init() { proto.RegisterFile("storage.proto", fileDescriptor0) }
|
||||
|
||||
var fileDescriptor0 = []byte{
|
||||
// 334 bytes of a gzipped FileDescriptorProto
|
||||
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x8c, 0x91, 0x4f, 0x4b, 0xf3, 0x40,
|
||||
0x10, 0xc6, 0xc9, 0x9f, 0x36, 0xc9, 0xf4, 0xed, 0x4b, 0x19, 0x44, 0xd6, 0x82, 0x1a, 0x7a, 0x90,
|
||||
0x9e, 0x72, 0xa8, 0x17, 0xa9, 0x37, 0x41, 0xa4, 0x1e, 0x44, 0xe2, 0x55, 0x90, 0x6d, 0x76, 0x0c,
|
||||
0x4b, 0xd3, 0xdd, 0xb0, 0xdd, 0x0a, 0xfd, 0x56, 0x7e, 0x1e, 0x3f, 0x8d, 0x64, 0xbb, 0x2d, 0x7a,
|
||||
0xf3, 0x36, 0xbf, 0x67, 0x27, 0x33, 0xcf, 0x33, 0x81, 0xe1, 0xc6, 0x6a, 0xc3, 0x6b, 0x2a, 0x5a,
|
||||
0xa3, 0xad, 0xc6, 0xcc, 0x63, 0xbb, 0x9c, 0x7c, 0x05, 0xd0, 0x7b, 0x30, 0x7a, 0xdb, 0xe2, 0x7f,
|
||||
0x08, 0xa5, 0x60, 0x41, 0x1e, 0x4c, 0xb3, 0x32, 0x94, 0x02, 0x11, 0x62, 0xc5, 0xd7, 0xc4, 0x42,
|
||||
0xa7, 0xb8, 0x1a, 0x19, 0x24, 0xad, 0xd1, 0xef, 0xb2, 0x21, 0x16, 0x39, 0xf9, 0x80, 0x38, 0x87,
|
||||
0x74, 0x43, 0x0d, 0x55, 0x56, 0x1b, 0x16, 0xe7, 0xd1, 0x74, 0x30, 0xbb, 0x28, 0x8e, 0x5b, 0x0a,
|
||||
0xb7, 0xa1, 0x78, 0xf1, 0x0d, 0xf7, 0xca, 0x9a, 0x5d, 0x79, 0xec, 0xc7, 0x31, 0xa4, 0x6b, 0xb2,
|
||||
0x5c, 0x70, 0xcb, 0x59, 0x2f, 0x0f, 0xa6, 0xff, 0xca, 0x23, 0x8f, 0x6f, 0x61, 0xf8, 0xeb, 0x33,
|
||||
0x1c, 0x41, 0xb4, 0xa2, 0x9d, 0xf7, 0xd9, 0x95, 0x78, 0x02, 0xbd, 0x0f, 0xde, 0x6c, 0x0f, 0x4e,
|
||||
0xf7, 0x30, 0x0f, 0x6f, 0x82, 0xc9, 0x67, 0x00, 0xc9, 0xb3, 0x37, 0xf8, 0x97, 0x78, 0x97, 0x30,
|
||||
0x90, 0xb5, 0x92, 0x56, 0x6a, 0xf5, 0x26, 0x85, 0x8f, 0x08, 0x07, 0x69, 0x21, 0xf0, 0x0c, 0xd2,
|
||||
0xaa, 0xd1, 0x5b, 0xd1, 0xbd, 0xc6, 0xfb, 0x03, 0x38, 0x5e, 0x08, 0xbc, 0x82, 0x78, 0xa9, 0xb5,
|
||||
0x75, 0x01, 0x06, 0x33, 0xfc, 0x11, 0xfe, 0x89, 0xec, 0x9d, 0xd6, 0xb6, 0x74, 0xef, 0x78, 0x0e,
|
||||
0x50, 0x93, 0x22, 0x23, 0xab, 0x6e, 0x48, 0xdf, 0x0d, 0xc9, 0xbc, 0xb2, 0x10, 0x93, 0x57, 0x48,
|
||||
0x7c, 0x3f, 0x9e, 0x42, 0x7f, 0x45, 0x46, 0x51, 0xe3, 0x5d, 0x7b, 0xea, 0x74, 0xa9, 0xa4, 0x35,
|
||||
0x82, 0x85, 0x79, 0xd4, 0xe9, 0x7b, 0xea, 0x12, 0x71, 0x53, 0x6f, 0xdc, 0xf9, 0xb3, 0xd2, 0xd5,
|
||||
0x8f, 0x71, 0x1a, 0x8d, 0xe2, 0x32, 0xa9, 0xd6, 0xa2, 0x91, 0x8a, 0x96, 0x7d, 0xf7, 0xff, 0xaf,
|
||||
0xbf, 0x03, 0x00, 0x00, 0xff, 0xff, 0x10, 0x74, 0x65, 0xd8, 0x10, 0x02, 0x00, 0x00,
|
||||
func init() {
|
||||
proto.RegisterFile("matchbox/storage/storagepb/storage.proto", fileDescriptor_5ed97bf224c67cd0)
|
||||
}
|
||||
|
||||
var fileDescriptor_5ed97bf224c67cd0 = []byte{
|
||||
// 374 bytes of a gzipped FileDescriptorProto
|
||||
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x52, 0x4d, 0x8b, 0xdb, 0x30,
|
||||
0x10, 0xc5, 0x1f, 0x89, 0xed, 0x49, 0x5b, 0x82, 0x28, 0xc5, 0x0d, 0xb4, 0x35, 0x39, 0x14, 0x9f,
|
||||
0x1c, 0x48, 0x0f, 0x6d, 0xd3, 0x5b, 0xa0, 0x94, 0xf4, 0x50, 0x8a, 0x7b, 0x2b, 0x85, 0x22, 0x5b,
|
||||
0x5a, 0x47, 0xc4, 0xd6, 0x18, 0x59, 0x5e, 0x36, 0xff, 0x6a, 0x7f, 0xcf, 0xfe, 0x9a, 0xc5, 0x8a,
|
||||
0x6c, 0x76, 0x0f, 0x0b, 0x7b, 0xf2, 0x7b, 0x6f, 0xc6, 0x9a, 0xf7, 0x86, 0x81, 0xb4, 0xa1, 0xba,
|
||||
0x3c, 0x16, 0x78, 0xb3, 0xe9, 0x34, 0x2a, 0x5a, 0xf1, 0xf1, 0xdb, 0x16, 0x23, 0xca, 0x5a, 0x85,
|
||||
0x1a, 0x49, 0x34, 0x15, 0xd6, 0x77, 0x0e, 0xcc, 0x7e, 0x28, 0xec, 0x5b, 0xf2, 0x0a, 0x5c, 0xc1,
|
||||
0x62, 0x27, 0x71, 0xd2, 0x28, 0x77, 0x05, 0x23, 0x04, 0x7c, 0x49, 0x1b, 0x1e, 0xbb, 0x46, 0x31,
|
||||
0x98, 0xc4, 0x10, 0xb4, 0x0a, 0xaf, 0x44, 0xcd, 0x63, 0xcf, 0xc8, 0x23, 0x25, 0x3b, 0x08, 0x3b,
|
||||
0x5e, 0xf3, 0x52, 0xa3, 0x8a, 0xfd, 0xc4, 0x4b, 0x17, 0xdb, 0xf7, 0xd9, 0x34, 0x25, 0x33, 0x13,
|
||||
0xb2, 0x3f, 0xb6, 0xe1, 0xbb, 0xd4, 0xea, 0x9c, 0x4f, 0xfd, 0x64, 0x05, 0x61, 0xc3, 0x35, 0x65,
|
||||
0x54, 0xd3, 0x78, 0x96, 0x38, 0xe9, 0x8b, 0x7c, 0xe2, 0xab, 0x6f, 0xf0, 0xf2, 0xd1, 0x6f, 0x64,
|
||||
0x09, 0xde, 0x89, 0x9f, 0xad, 0xcf, 0x01, 0x92, 0xd7, 0x30, 0xbb, 0xa6, 0x75, 0x3f, 0x3a, 0xbd,
|
||||
0x90, 0x9d, 0xfb, 0xc5, 0x59, 0xdf, 0x3a, 0x10, 0xfc, 0xb6, 0x06, 0x9f, 0x13, 0xef, 0x03, 0x2c,
|
||||
0x44, 0x25, 0x85, 0x16, 0x28, 0xff, 0x0b, 0x66, 0x23, 0xc2, 0x28, 0x1d, 0x18, 0x79, 0x0b, 0x61,
|
||||
0x59, 0x63, 0xcf, 0x86, 0xaa, 0x7f, 0x59, 0x80, 0xe1, 0x07, 0x46, 0x3e, 0x82, 0x5f, 0x20, 0x6a,
|
||||
0x13, 0x60, 0xb1, 0x25, 0x0f, 0xc2, 0xff, 0xe2, 0x7a, 0x8f, 0xa8, 0x73, 0x53, 0x27, 0xef, 0x00,
|
||||
0x2a, 0x2e, 0xb9, 0x12, 0xe5, 0xf0, 0xc8, 0xdc, 0x3c, 0x12, 0x59, 0xe5, 0xc0, 0xd6, 0xff, 0x20,
|
||||
0xb0, 0xfd, 0xe4, 0x0d, 0xcc, 0x4f, 0x5c, 0x49, 0x5e, 0x5b, 0xd7, 0x96, 0x0d, 0xba, 0x90, 0x42,
|
||||
0x2b, 0x16, 0xbb, 0x89, 0x37, 0xe8, 0x17, 0x36, 0x24, 0xa2, 0xaa, 0xea, 0xcc, 0xfa, 0xa3, 0xdc,
|
||||
0xe0, 0x9f, 0x7e, 0xe8, 0x2d, 0xfd, 0x3c, 0x28, 0x1b, 0x56, 0x0b, 0xc9, 0xf7, 0x5f, 0xff, 0x7e,
|
||||
0xae, 0x84, 0x3e, 0xf6, 0x45, 0x56, 0x62, 0xb3, 0x69, 0xb1, 0xe3, 0x82, 0xa1, 0xdc, 0x4c, 0x87,
|
||||
0xf3, 0xf4, 0x05, 0x15, 0x73, 0x73, 0x3a, 0x9f, 0xee, 0x03, 0x00, 0x00, 0xff, 0xff, 0x37, 0x8a,
|
||||
0x89, 0x62, 0x66, 0x02, 0x00, 0x00,
|
||||
}
|
||||
|
||||
@@ -1,6 +1,8 @@
|
||||
syntax = "proto3";
|
||||
package storagepb;
|
||||
|
||||
option go_package = "github.com/poseidon/matchbox/matchbox/storage/storagepb";
|
||||
|
||||
// Group selects one or more machines and matches them to a Profile.
|
||||
message Group {
|
||||
// machine readable Id
|
||||
|
||||
@@ -1,22 +0,0 @@
|
||||
#!/usr/bin/env bash
|
||||
# USAGE ./scripts/codegen
|
||||
# Generate Go protocol buffer code from proto definitions
|
||||
|
||||
set -eu
|
||||
|
||||
# Add protoc and protoc-gen-go tools to PATH
|
||||
export PATH=$PWD/bin:$PATH
|
||||
|
||||
# protobuf subpackages end in "pb"
|
||||
PBUFS=$(go list ./... | grep -v /vendor | grep 'pb$')
|
||||
|
||||
# change into each protobuf directory
|
||||
for pkg in $PBUFS ; do
|
||||
abs_path=${GOPATH}/src/${pkg}
|
||||
echo Generating $abs_path
|
||||
pushd ${abs_path} > /dev/null
|
||||
# generate protocol buffers, make other .proto files available to import
|
||||
protoc --go_out=plugins=grpc:. -I=.:"${GOPATH}/src/" *.proto
|
||||
popd > /dev/null
|
||||
done
|
||||
|
||||
@@ -1,21 +0,0 @@
|
||||
#!/usr/bin/env bash
|
||||
# USAGE: ./get-protoc bin/protoc
|
||||
# Get the 'protoc' protocol buffer compiler
|
||||
set -eu
|
||||
|
||||
DEST=${1:-"bin"}
|
||||
VERSION="3.2.0"
|
||||
|
||||
OS=$(uname | tr A-Z a-z)
|
||||
if [[ $OS == 'darwin' ]]; then
|
||||
OS=osx # protoc names downloads with OSX, not darwin
|
||||
fi
|
||||
|
||||
FILE="protoc-${VERSION}-${OS}-x86_64.zip"
|
||||
URL="https://github.com/google/protobuf/releases/download/v${VERSION}/${FILE}"
|
||||
|
||||
mkdir -p $DEST
|
||||
curl -L -# -o protoc.zip ${URL}
|
||||
unzip -p protoc.zip bin/protoc > ${DEST}/protoc
|
||||
chmod +x ${DEST}/protoc
|
||||
rm -f protoc.zip
|
||||
Reference in New Issue
Block a user