From 5d908eda1d67dc1ea4c97b11a0c0edee94d38c7d Mon Sep 17 00:00:00 2001 From: Sascha Steinbiss Date: Sun, 15 Aug 2021 21:37:02 +0200 Subject: [PATCH 1/2] depend on less recent versions of gRPC tooling --- go.mod | 13 +- go.sum | 59 +-- mgmt/mgmt.pb.go | 839 +++++++++++++++++++++++++++++++++---------- mgmt/mgmt_grpc.pb.go | 281 --------------- protomgmtc.sh | 4 +- 5 files changed, 663 insertions(+), 533 deletions(-) delete mode 100644 mgmt/mgmt_grpc.pb.go diff --git a/go.mod b/go.mod index 28ca0c3..49e88f4 100644 --- a/go.mod +++ b/go.mod @@ -8,14 +8,15 @@ require ( github.com/NeowayLabs/wabbit v0.0.0-20201021105516-ded4a9ef19d2 github.com/Showmax/go-fqdn v1.0.0 // indirect github.com/buger/jsonparser v1.1.1 + github.com/fsnotify/fsnotify v1.4.9 // indirect github.com/fsouza/go-dockerclient v1.7.1 // indirect github.com/garyburd/redigo v1.6.2 - github.com/golang/protobuf v1.4.3 + github.com/golang/protobuf v1.5.0 github.com/gomodule/redigo v1.8.3 // indirect github.com/jinzhu/inflection v1.0.0 // indirect github.com/mitchellh/go-homedir v1.1.0 - github.com/onsi/ginkgo v1.15.0 // indirect - github.com/onsi/gomega v1.10.5 // indirect + github.com/onsi/ginkgo v1.12.1 // indirect + github.com/onsi/gomega v1.10.0 // indirect github.com/patrickmn/go-cache v2.1.0+incompatible github.com/pborman/uuid v1.2.1 // indirect github.com/sirupsen/logrus v1.8.0 @@ -25,10 +26,10 @@ require ( github.com/stvp/tempredis v0.0.0-20181119212430-b82af8480203 github.com/tiago4orion/conjure v0.0.0-20150908101743-93cb30b9d218 // indirect github.com/yl2chen/cidranger v1.0.2 + golang.org/x/net v0.0.0-20201202161906-c7110b5ffcbb // indirect golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9 - google.golang.org/grpc v1.35.0 - google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0 // indirect - google.golang.org/protobuf v1.25.0 + google.golang.org/grpc v1.27.0 + google.golang.org/protobuf v1.26.0 gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22 gopkg.in/pg.v5 v5.3.3 ) diff --git a/go.sum b/go.sum index 58d02ff..a02825d 100644 --- a/go.sum +++ b/go.sum @@ -46,7 +46,6 @@ github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc= github.com/cilium/ebpf v0.0.0-20200110133405-4032b1d8aae3/go.mod h1:MA5e5Lr8slmEg9bt0VpxxWqJlO4iwu3FBdHUzV7wQVg= github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw= -github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk= github.com/containerd/cgroups v0.0.0-20200531161412-0dbf7f05ba59 h1:qWj4qVYZ95vLWwqyNJCQg7rDsG5wPdze0UaPolH7DUk= github.com/containerd/cgroups v0.0.0-20200531161412-0dbf7f05ba59/go.mod h1:pA0z1pT8KYB3TCXK/ocprsh7MAkoW8bZVzPdih9snmM= github.com/containerd/console v0.0.0-20180822173158-c12b1e7919c1/go.mod h1:Tj/on1eG8kiEhd0+fhSDzsPAFESxzBBvdyEgyryXffw= @@ -83,9 +82,7 @@ github.com/docker/go-connections v0.4.0/go.mod h1:Gbd7IOopHjR8Iph03tsViu4nIes5Xh github.com/docker/go-units v0.4.0 h1:3uh0PgVws3nIA0Q+MwDC8yjEPf9zjRfZZWXZYDct3Tw= github.com/docker/go-units v0.4.0/go.mod h1:fgPhTUdO+D/Jk86RDLlptpiXQzgHJF7gydDDbaIK4Dk= github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk= -github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= -github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk= github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c= github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4= github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo= @@ -107,6 +104,7 @@ github.com/gogo/protobuf v1.2.1/go.mod h1:hp+jE20tsWTFYpLwKvXlhS1hjn+gTNwPg2I6zV github.com/gogo/protobuf v1.3.1/go.mod h1:SlYgWuQ5SjCEi6WLHjHCa1yvBfUnHcTbrrZtXPKa29o= github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q= github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q= +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/groupcache v0.0.0-20190129154638-5b532d6fd5ef/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A= @@ -115,33 +113,25 @@ github.com/golang/mock v1.3.1/go.mod h1:sBzyDLLjw3U8JLTeZvSv8jJB+tU5PVekmnlKIyFU github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= -github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8= -github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA= -github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs= -github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w= -github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0= -github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8= -github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= -github.com/golang/protobuf v1.4.3 h1:JjCZWpVbqXDqFVmTfYWEVTMIYrL/NPdPSCHPJ0T/raM= -github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= +github.com/golang/protobuf v1.5.0 h1:LUVKkCeviFUMKqHa4tXIIij/lbhnMbP7Fn5wKdKkRh4= +github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= github.com/gomodule/redigo v1.8.3 h1:HR0kYDX2RJZvAup8CsiJwxB4dTCSC0AaUq6S4SiLwUc= github.com/gomodule/redigo v1.8.3/go.mod h1:P9dn9mFrCBvWhGE1wpxx6fgq7BAeLBk+UUUzlpkBYO0= github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ= github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ= github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M= github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= -github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.4 h1:L8R9j+yAqZuZjsqh/z+F1NCffTKKLShY6zXTItVIZ8M= github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU= +github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/martian v2.1.0+incompatible/go.mod h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs= github.com/google/pprof v0.0.0-20181206194817-3ea8567a2e57/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc= github.com/google/pprof v0.0.0-20190515194954-54271f7e092f/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc= github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI= +github.com/google/uuid v1.0.0 h1:b4Gk+7WdP/d3HZH8EJsZpvV7EtDOgaZLtnaNGIu1adA= github.com/google/uuid v1.0.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= -github.com/google/uuid v1.1.2 h1:EVhdT+1Kseyi1/pUmXKaFxYsDNy9RQYkMWRH68J/W7Y= -github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/googleapis/gax-go/v2 v2.0.4/go.mod h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+vpHVxEJEs9eg= github.com/googleapis/gax-go/v2 v2.0.5/go.mod h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk= github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1 h1:EGx4pi6eqNxGaHF6qqu48+N2wcFQ5qg5FXgOdqsJ5d8= @@ -229,13 +219,11 @@ github.com/nxadm/tail v1.4.4 h1:DQuhQpB1tVlglWS2hLQ5OV6B5r8aGxSrPc5Qo6uTN78= github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A= github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U= github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE= +github.com/onsi/ginkgo v1.12.1 h1:mFwc4LvZ0xpSvDZ3E+k8Yte0hLOMxXUlP+yXtJqkYfQ= github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk= -github.com/onsi/ginkgo v1.15.0 h1:1V1NfVQR87RtWAgp1lv9JZJ5Jap+XFGKPi00andXGi4= -github.com/onsi/ginkgo v1.15.0/go.mod h1:hF8qUzuuC8DJGygJH3726JnCZX4MYbRB8yFfISqnKUg= github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY= -github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo= -github.com/onsi/gomega v1.10.5 h1:7n6FEkpFmfCoo2t+YYqXH0evK+a9ICQz0xcAy9dYcaQ= -github.com/onsi/gomega v1.10.5/go.mod h1:gza4q3jKQJijlu05nKWRCW/GavJumGt8aNRxWg7mt48= +github.com/onsi/gomega v1.10.0 h1:Gwkk+PTu/nfOwNMtUB/mRUv0X7ewW5dO4AERT1ThVKo= +github.com/onsi/gomega v1.10.0/go.mod h1:Ho0h+IUsWyvy1OpqCwxlQ/21gkhVunqlU8fDGcoTdcA= github.com/opencontainers/go-digest v0.0.0-20180430190053-c9281466c8b2/go.mod h1:cMLVZDEM3+U2I4VmLI6N8jQYUd2OVphdqWwCJHrFt2s= github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U= github.com/opencontainers/go-digest v1.0.0/go.mod h1:0JzlMkj0TRzQZfJkVvzbP0HBR3IKzErnv2BNG4W4MAM= @@ -379,7 +367,6 @@ golang.org/x/net v0.0.0-20190603091049-60506f45cf65/go.mod h1:HSz+uSET+XFnRR8LxR golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20191004110552-13f9640d40b9/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= -golang.org/x/net v0.0.0-20200520004742-59133d7f0dd7/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A= golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= golang.org/x/net v0.0.0-20201202161906-c7110b5ffcbb h1:eBmm0M9fYhWpKZLjQUUKka/LtIxf46G4fxeEz5KJr9U= golang.org/x/net v0.0.0-20201202161906-c7110b5ffcbb/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= @@ -416,13 +403,11 @@ golang.org/x/sys v0.0.0-20191022100944-742c48ecaeb7/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200120151820-655fe14d7479/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200831180312-196b9ba8737a/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200909081042-eff7692f9009/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200922070232-aee5d888a860/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20201201145000-ef89a241ccb3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210112080510-489259a85091/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210216224549-f992740a1bac h1:9glrpwtNjBYgRpb67AZJKHfzj1stG/8BL5H7In2oTC4= golang.org/x/sys v0.0.0-20210216224549-f992740a1bac/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/term v0.0.0-20201113234701-d7a72108b828 h1:htWEtQEuEVJ4tU/Ngx7Cd/4Q7e3A5Up1owgyBtVsTwk= @@ -456,7 +441,6 @@ golang.org/x/tools v0.0.0-20191012152004-8de300cfc20a/go.mod h1:b+2E5dAYhXwXZwtn golang.org/x/tools v0.0.0-20191112195655-aa38f8e97acc/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20200619180055-7c47624df98f/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE= -golang.org/x/tools v0.0.0-20201224043029-2b0845dc783e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= @@ -480,31 +464,19 @@ google.golang.org/genproto v0.0.0-20190502173448-54afdca5d873/go.mod h1:VzzqZJRn google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= google.golang.org/genproto v0.0.0-20190911173649-1774047e7e51/go.mod h1:IbNlFCBrqXvoKpeg0TB2l7cyZUmoaFKYIwrEpbDKLA8= +google.golang.org/genproto v0.0.0-20191108220845-16a3f7862a1a h1:Ob5/580gVHBJZgXnff1cZDbG+xLtMVE5mDRTe+nIsX4= google.golang.org/genproto v0.0.0-20191108220845-16a3f7862a1a/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc= -google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 h1:+kGHl1aib/qcwaRi1CbqBZ1rk19r85MNUf8HaBghugY= -google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM= google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg= google.golang.org/grpc v1.23.1/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg= -google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY= +google.golang.org/grpc v1.27.0 h1:rRYRFMVgRv6E0D70Skyfsr28tDXIuuPZyWGMPdMcnXg= google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk= -google.golang.org/grpc v1.35.0 h1:TwIQcH3es+MojMVojxxfQ3l3OF2KzlRxML2xZq0kRo8= -google.golang.org/grpc v1.35.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= -google.golang.org/grpc v1.40.0 h1:AGJ0Ih4mHjSeibYkFGh1dD9KJ/eOtZ93I6hoHhukQ5Q= -google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0 h1:M1YKkFIboKNieVO5DLUEVzQfGwJD30Nv2jfUgzb5UcE= -google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0/go.mod h1:6Kw0yEErY5E/yWrBtf03jp27GLLJujG4z/JK95pnjjw= -google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= -google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0= -google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM= -google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE= -google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo= -google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= -google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= -google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= -google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c= -google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= +google.golang.org/protobuf v1.26.0-rc.1 h1:7QnIQpGRHE5RnLKnESfDoxm2dTapTZua5a0kS0A+VXQ= +google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= +google.golang.org/protobuf v1.26.0 h1:bxAC2xTBsZGibn2RTntX0oH50xLsqy1OxA9tTL3p/lk= +google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY= @@ -525,7 +497,6 @@ gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= -gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= gotest.tools v2.2.0+incompatible h1:VsBPFP1AI068pPrMxtb/S8Zkgf9xEmTLJjfM+P5UIEo= diff --git a/mgmt/mgmt.pb.go b/mgmt/mgmt.pb.go index cfaa2c7..4d1d0e6 100644 --- a/mgmt/mgmt.pb.go +++ b/mgmt/mgmt.pb.go @@ -1,299 +1,740 @@ // Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.26.0 +// protoc v3.12.4 // source: mgmt.proto package mgmt import ( - fmt "fmt" - proto "github.com/golang/protobuf/proto" - _ "google.golang.org/protobuf/types/known/emptypb" - math "math" + context "context" + grpc "google.golang.org/grpc" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + emptypb "google.golang.org/protobuf/types/known/emptypb" + reflect "reflect" + sync "sync" ) -// Reference imports to suppress errors if they are not otherwise used. -var _ = proto.Marshal -var _ = fmt.Errorf -var _ = math.Inf - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the proto package it is being compiled against. -// A compilation error at this line likely means your copy of the -// proto package needs to be updated. -const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) type MgmtBloomInfoResponse struct { - HasBloom bool `protobuf:"varint,1,opt,name=has_bloom,json=hasBloom,proto3" json:"has_bloom,omitempty"` - Capacity uint64 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"` - Elements uint64 `protobuf:"varint,3,opt,name=elements,proto3" json:"elements,omitempty"` - Bits uint64 `protobuf:"varint,4,opt,name=bits,proto3" json:"bits,omitempty"` - Hashfuncs uint64 `protobuf:"varint,5,opt,name=hashfuncs,proto3" json:"hashfuncs,omitempty"` - Fpprob float64 `protobuf:"fixed64,6,opt,name=fpprob,proto3" json:"fpprob,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` -} - -func (m *MgmtBloomInfoResponse) Reset() { *m = MgmtBloomInfoResponse{} } -func (m *MgmtBloomInfoResponse) String() string { return proto.CompactTextString(m) } -func (*MgmtBloomInfoResponse) ProtoMessage() {} -func (*MgmtBloomInfoResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_24cf82780fd24e73, []int{0} + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + HasBloom bool `protobuf:"varint,1,opt,name=has_bloom,json=hasBloom,proto3" json:"has_bloom,omitempty"` + Capacity uint64 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"` + Elements uint64 `protobuf:"varint,3,opt,name=elements,proto3" json:"elements,omitempty"` + Bits uint64 `protobuf:"varint,4,opt,name=bits,proto3" json:"bits,omitempty"` + Hashfuncs uint64 `protobuf:"varint,5,opt,name=hashfuncs,proto3" json:"hashfuncs,omitempty"` + Fpprob float64 `protobuf:"fixed64,6,opt,name=fpprob,proto3" json:"fpprob,omitempty"` +} + +func (x *MgmtBloomInfoResponse) Reset() { + *x = MgmtBloomInfoResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_mgmt_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *MgmtBloomInfoResponse) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_MgmtBloomInfoResponse.Unmarshal(m, b) -} -func (m *MgmtBloomInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_MgmtBloomInfoResponse.Marshal(b, m, deterministic) -} -func (m *MgmtBloomInfoResponse) XXX_Merge(src proto.Message) { - xxx_messageInfo_MgmtBloomInfoResponse.Merge(m, src) -} -func (m *MgmtBloomInfoResponse) XXX_Size() int { - return xxx_messageInfo_MgmtBloomInfoResponse.Size(m) +func (x *MgmtBloomInfoResponse) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *MgmtBloomInfoResponse) XXX_DiscardUnknown() { - xxx_messageInfo_MgmtBloomInfoResponse.DiscardUnknown(m) + +func (*MgmtBloomInfoResponse) ProtoMessage() {} + +func (x *MgmtBloomInfoResponse) ProtoReflect() protoreflect.Message { + mi := &file_mgmt_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_MgmtBloomInfoResponse proto.InternalMessageInfo +// Deprecated: Use MgmtBloomInfoResponse.ProtoReflect.Descriptor instead. +func (*MgmtBloomInfoResponse) Descriptor() ([]byte, []int) { + return file_mgmt_proto_rawDescGZIP(), []int{0} +} -func (m *MgmtBloomInfoResponse) GetHasBloom() bool { - if m != nil { - return m.HasBloom +func (x *MgmtBloomInfoResponse) GetHasBloom() bool { + if x != nil { + return x.HasBloom } return false } -func (m *MgmtBloomInfoResponse) GetCapacity() uint64 { - if m != nil { - return m.Capacity +func (x *MgmtBloomInfoResponse) GetCapacity() uint64 { + if x != nil { + return x.Capacity } return 0 } -func (m *MgmtBloomInfoResponse) GetElements() uint64 { - if m != nil { - return m.Elements +func (x *MgmtBloomInfoResponse) GetElements() uint64 { + if x != nil { + return x.Elements } return 0 } -func (m *MgmtBloomInfoResponse) GetBits() uint64 { - if m != nil { - return m.Bits +func (x *MgmtBloomInfoResponse) GetBits() uint64 { + if x != nil { + return x.Bits } return 0 } -func (m *MgmtBloomInfoResponse) GetHashfuncs() uint64 { - if m != nil { - return m.Hashfuncs +func (x *MgmtBloomInfoResponse) GetHashfuncs() uint64 { + if x != nil { + return x.Hashfuncs } return 0 } -func (m *MgmtBloomInfoResponse) GetFpprob() float64 { - if m != nil { - return m.Fpprob +func (x *MgmtBloomInfoResponse) GetFpprob() float64 { + if x != nil { + return x.Fpprob } return 0 } type MgmtAliveRequest struct { - Alive string `protobuf:"bytes,1,opt,name=alive,proto3" json:"alive,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Alive string `protobuf:"bytes,1,opt,name=alive,proto3" json:"alive,omitempty"` } -func (m *MgmtAliveRequest) Reset() { *m = MgmtAliveRequest{} } -func (m *MgmtAliveRequest) String() string { return proto.CompactTextString(m) } -func (*MgmtAliveRequest) ProtoMessage() {} +func (x *MgmtAliveRequest) Reset() { + *x = MgmtAliveRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_mgmt_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MgmtAliveRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MgmtAliveRequest) ProtoMessage() {} + +func (x *MgmtAliveRequest) ProtoReflect() protoreflect.Message { + mi := &file_mgmt_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use MgmtAliveRequest.ProtoReflect.Descriptor instead. func (*MgmtAliveRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_24cf82780fd24e73, []int{1} + return file_mgmt_proto_rawDescGZIP(), []int{1} } -func (m *MgmtAliveRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_MgmtAliveRequest.Unmarshal(m, b) +func (x *MgmtAliveRequest) GetAlive() string { + if x != nil { + return x.Alive + } + return "" } -func (m *MgmtAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_MgmtAliveRequest.Marshal(b, m, deterministic) + +type MgmtAliveResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Echo string `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"` } -func (m *MgmtAliveRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_MgmtAliveRequest.Merge(m, src) + +func (x *MgmtAliveResponse) Reset() { + *x = MgmtAliveResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_mgmt_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *MgmtAliveRequest) XXX_Size() int { - return xxx_messageInfo_MgmtAliveRequest.Size(m) + +func (x *MgmtAliveResponse) String() string { + return protoimpl.X.MessageStringOf(x) } -func (m *MgmtAliveRequest) XXX_DiscardUnknown() { - xxx_messageInfo_MgmtAliveRequest.DiscardUnknown(m) + +func (*MgmtAliveResponse) ProtoMessage() {} + +func (x *MgmtAliveResponse) ProtoReflect() protoreflect.Message { + mi := &file_mgmt_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -var xxx_messageInfo_MgmtAliveRequest proto.InternalMessageInfo +// Deprecated: Use MgmtAliveResponse.ProtoReflect.Descriptor instead. +func (*MgmtAliveResponse) Descriptor() ([]byte, []int) { + return file_mgmt_proto_rawDescGZIP(), []int{2} +} -func (m *MgmtAliveRequest) GetAlive() string { - if m != nil { - return m.Alive +func (x *MgmtAliveResponse) GetEcho() string { + if x != nil { + return x.Echo } return "" } -type MgmtAliveResponse struct { - Echo string `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` +type MgmtBloomAddRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Ioc string `protobuf:"bytes,1,opt,name=ioc,proto3" json:"ioc,omitempty"` } -func (m *MgmtAliveResponse) Reset() { *m = MgmtAliveResponse{} } -func (m *MgmtAliveResponse) String() string { return proto.CompactTextString(m) } -func (*MgmtAliveResponse) ProtoMessage() {} -func (*MgmtAliveResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_24cf82780fd24e73, []int{2} +func (x *MgmtBloomAddRequest) Reset() { + *x = MgmtBloomAddRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_mgmt_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MgmtBloomAddRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MgmtBloomAddRequest) ProtoMessage() {} + +func (x *MgmtBloomAddRequest) ProtoReflect() protoreflect.Message { + mi := &file_mgmt_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) } -func (m *MgmtAliveResponse) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_MgmtAliveResponse.Unmarshal(m, b) +// Deprecated: Use MgmtBloomAddRequest.ProtoReflect.Descriptor instead. +func (*MgmtBloomAddRequest) Descriptor() ([]byte, []int) { + return file_mgmt_proto_rawDescGZIP(), []int{3} } -func (m *MgmtAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_MgmtAliveResponse.Marshal(b, m, deterministic) + +func (x *MgmtBloomAddRequest) GetIoc() string { + if x != nil { + return x.Ioc + } + return "" } -func (m *MgmtAliveResponse) XXX_Merge(src proto.Message) { - xxx_messageInfo_MgmtAliveResponse.Merge(m, src) + +type MgmtBloomAddResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Added uint64 `protobuf:"varint,1,opt,name=added,proto3" json:"added,omitempty"` } -func (m *MgmtAliveResponse) XXX_Size() int { - return xxx_messageInfo_MgmtAliveResponse.Size(m) + +func (x *MgmtBloomAddResponse) Reset() { + *x = MgmtBloomAddResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_mgmt_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } } -func (m *MgmtAliveResponse) XXX_DiscardUnknown() { - xxx_messageInfo_MgmtAliveResponse.DiscardUnknown(m) + +func (x *MgmtBloomAddResponse) String() string { + return protoimpl.X.MessageStringOf(x) } -var xxx_messageInfo_MgmtAliveResponse proto.InternalMessageInfo +func (*MgmtBloomAddResponse) ProtoMessage() {} -func (m *MgmtAliveResponse) GetEcho() string { - if m != nil { - return m.Echo +func (x *MgmtBloomAddResponse) ProtoReflect() protoreflect.Message { + mi := &file_mgmt_proto_msgTypes[4] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms } - return "" + return mi.MessageOf(x) } -type MgmtBloomAddRequest struct { - Ioc string `protobuf:"bytes,1,opt,name=ioc,proto3" json:"ioc,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` +// Deprecated: Use MgmtBloomAddResponse.ProtoReflect.Descriptor instead. +func (*MgmtBloomAddResponse) Descriptor() ([]byte, []int) { + return file_mgmt_proto_rawDescGZIP(), []int{4} } -func (m *MgmtBloomAddRequest) Reset() { *m = MgmtBloomAddRequest{} } -func (m *MgmtBloomAddRequest) String() string { return proto.CompactTextString(m) } -func (*MgmtBloomAddRequest) ProtoMessage() {} -func (*MgmtBloomAddRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_24cf82780fd24e73, []int{3} +func (x *MgmtBloomAddResponse) GetAdded() uint64 { + if x != nil { + return x.Added + } + return 0 +} + +var File_mgmt_proto protoreflect.FileDescriptor + +var file_mgmt_proto_rawDesc = []byte{ + 0x0a, 0x0a, 0x6d, 0x67, 0x6d, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x04, 0x6d, 0x67, + 0x6d, 0x74, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, + 0xb6, 0x01, 0x0a, 0x15, 0x4d, 0x67, 0x6d, 0x74, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x49, 0x6e, 0x66, + 0x6f, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x68, 0x61, 0x73, + 0x5f, 0x62, 0x6c, 0x6f, 0x6f, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x68, 0x61, + 0x73, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x12, 0x1a, 0x0a, 0x08, 0x63, 0x61, 0x70, 0x61, 0x63, 0x69, + 0x74, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x63, 0x61, 0x70, 0x61, 0x63, 0x69, + 0x74, 0x79, 0x12, 0x1a, 0x0a, 0x08, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x03, + 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x65, 0x6c, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x12, + 0x0a, 0x04, 0x62, 0x69, 0x74, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x04, 0x62, 0x69, + 0x74, 0x73, 0x12, 0x1c, 0x0a, 0x09, 0x68, 0x61, 0x73, 0x68, 0x66, 0x75, 0x6e, 0x63, 0x73, 0x18, + 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x09, 0x68, 0x61, 0x73, 0x68, 0x66, 0x75, 0x6e, 0x63, 0x73, + 0x12, 0x16, 0x0a, 0x06, 0x66, 0x70, 0x70, 0x72, 0x6f, 0x62, 0x18, 0x06, 0x20, 0x01, 0x28, 0x01, + 0x52, 0x06, 0x66, 0x70, 0x70, 0x72, 0x6f, 0x62, 0x22, 0x28, 0x0a, 0x10, 0x4d, 0x67, 0x6d, 0x74, + 0x41, 0x6c, 0x69, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, + 0x61, 0x6c, 0x69, 0x76, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x6c, 0x69, + 0x76, 0x65, 0x22, 0x27, 0x0a, 0x11, 0x4d, 0x67, 0x6d, 0x74, 0x41, 0x6c, 0x69, 0x76, 0x65, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x65, 0x63, 0x68, 0x6f, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x65, 0x63, 0x68, 0x6f, 0x22, 0x27, 0x0a, 0x13, 0x4d, + 0x67, 0x6d, 0x74, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x69, 0x6f, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x03, 0x69, 0x6f, 0x63, 0x22, 0x2c, 0x0a, 0x14, 0x4d, 0x67, 0x6d, 0x74, 0x42, 0x6c, 0x6f, 0x6f, + 0x6d, 0x41, 0x64, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x14, 0x0a, 0x05, + 0x61, 0x64, 0x64, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x61, 0x64, 0x64, + 0x65, 0x64, 0x32, 0xca, 0x02, 0x0a, 0x0b, 0x4d, 0x67, 0x6d, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, + 0x63, 0x65, 0x12, 0x38, 0x0a, 0x05, 0x41, 0x6c, 0x69, 0x76, 0x65, 0x12, 0x16, 0x2e, 0x6d, 0x67, + 0x6d, 0x74, 0x2e, 0x4d, 0x67, 0x6d, 0x74, 0x41, 0x6c, 0x69, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x6d, 0x67, 0x6d, 0x74, 0x2e, 0x4d, 0x67, 0x6d, 0x74, 0x41, + 0x6c, 0x69, 0x76, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x40, 0x0a, 0x09, + 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, + 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, + 0x79, 0x1a, 0x1b, 0x2e, 0x6d, 0x67, 0x6d, 0x74, 0x2e, 0x4d, 0x67, 0x6d, 0x74, 0x42, 0x6c, 0x6f, + 0x6f, 0x6d, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x43, + 0x0a, 0x08, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x12, 0x19, 0x2e, 0x6d, 0x67, 0x6d, + 0x74, 0x2e, 0x4d, 0x67, 0x6d, 0x74, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x6d, 0x67, 0x6d, 0x74, 0x2e, 0x4d, 0x67, 0x6d, + 0x74, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x41, 0x64, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x28, 0x01, 0x12, 0x3b, 0x0a, 0x09, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x53, 0x61, 0x76, 0x65, + 0x12, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, + 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, + 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, + 0x12, 0x3d, 0x0a, 0x0b, 0x42, 0x6c, 0x6f, 0x6f, 0x6d, 0x52, 0x65, 0x6c, 0x6f, 0x61, 0x64, 0x12, + 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, + 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, + 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x42, + 0x1c, 0x5a, 0x1a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x44, 0x43, + 0x53, 0x4f, 0x2f, 0x66, 0x65, 0x76, 0x65, 0x72, 0x2f, 0x6d, 0x67, 0x6d, 0x74, 0x62, 0x06, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_mgmt_proto_rawDescOnce sync.Once + file_mgmt_proto_rawDescData = file_mgmt_proto_rawDesc +) + +func file_mgmt_proto_rawDescGZIP() []byte { + file_mgmt_proto_rawDescOnce.Do(func() { + file_mgmt_proto_rawDescData = protoimpl.X.CompressGZIP(file_mgmt_proto_rawDescData) + }) + return file_mgmt_proto_rawDescData +} + +var file_mgmt_proto_msgTypes = make([]protoimpl.MessageInfo, 5) +var file_mgmt_proto_goTypes = []interface{}{ + (*MgmtBloomInfoResponse)(nil), // 0: mgmt.MgmtBloomInfoResponse + (*MgmtAliveRequest)(nil), // 1: mgmt.MgmtAliveRequest + (*MgmtAliveResponse)(nil), // 2: mgmt.MgmtAliveResponse + (*MgmtBloomAddRequest)(nil), // 3: mgmt.MgmtBloomAddRequest + (*MgmtBloomAddResponse)(nil), // 4: mgmt.MgmtBloomAddResponse + (*emptypb.Empty)(nil), // 5: google.protobuf.Empty +} +var file_mgmt_proto_depIdxs = []int32{ + 1, // 0: mgmt.MgmtService.Alive:input_type -> mgmt.MgmtAliveRequest + 5, // 1: mgmt.MgmtService.BloomInfo:input_type -> google.protobuf.Empty + 3, // 2: mgmt.MgmtService.BloomAdd:input_type -> mgmt.MgmtBloomAddRequest + 5, // 3: mgmt.MgmtService.BloomSave:input_type -> google.protobuf.Empty + 5, // 4: mgmt.MgmtService.BloomReload:input_type -> google.protobuf.Empty + 2, // 5: mgmt.MgmtService.Alive:output_type -> mgmt.MgmtAliveResponse + 0, // 6: mgmt.MgmtService.BloomInfo:output_type -> mgmt.MgmtBloomInfoResponse + 4, // 7: mgmt.MgmtService.BloomAdd:output_type -> mgmt.MgmtBloomAddResponse + 5, // 8: mgmt.MgmtService.BloomSave:output_type -> google.protobuf.Empty + 5, // 9: mgmt.MgmtService.BloomReload:output_type -> google.protobuf.Empty + 5, // [5:10] is the sub-list for method output_type + 0, // [0:5] is the sub-list for method input_type + 0, // [0:0] is the sub-list for extension type_name + 0, // [0:0] is the sub-list for extension extendee + 0, // [0:0] is the sub-list for field type_name +} + +func init() { file_mgmt_proto_init() } +func file_mgmt_proto_init() { + if File_mgmt_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_mgmt_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MgmtBloomInfoResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_mgmt_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MgmtAliveRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_mgmt_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MgmtAliveResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_mgmt_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MgmtBloomAddRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_mgmt_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MgmtBloomAddResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_mgmt_proto_rawDesc, + NumEnums: 0, + NumMessages: 5, + NumExtensions: 0, + NumServices: 1, + }, + GoTypes: file_mgmt_proto_goTypes, + DependencyIndexes: file_mgmt_proto_depIdxs, + MessageInfos: file_mgmt_proto_msgTypes, + }.Build() + File_mgmt_proto = out.File + file_mgmt_proto_rawDesc = nil + file_mgmt_proto_goTypes = nil + file_mgmt_proto_depIdxs = nil } -func (m *MgmtBloomAddRequest) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_MgmtBloomAddRequest.Unmarshal(m, b) +// Reference imports to suppress errors if they are not otherwise used. +var _ context.Context +var _ grpc.ClientConnInterface + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the grpc package it is being compiled against. +const _ = grpc.SupportPackageIsVersion6 + +// MgmtServiceClient is the client API for MgmtService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. +type MgmtServiceClient interface { + Alive(ctx context.Context, in *MgmtAliveRequest, opts ...grpc.CallOption) (*MgmtAliveResponse, error) + BloomInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MgmtBloomInfoResponse, error) + BloomAdd(ctx context.Context, opts ...grpc.CallOption) (MgmtService_BloomAddClient, error) + BloomSave(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) + BloomReload(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) } -func (m *MgmtBloomAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_MgmtBloomAddRequest.Marshal(b, m, deterministic) + +type mgmtServiceClient struct { + cc grpc.ClientConnInterface } -func (m *MgmtBloomAddRequest) XXX_Merge(src proto.Message) { - xxx_messageInfo_MgmtBloomAddRequest.Merge(m, src) + +func NewMgmtServiceClient(cc grpc.ClientConnInterface) MgmtServiceClient { + return &mgmtServiceClient{cc} } -func (m *MgmtBloomAddRequest) XXX_Size() int { - return xxx_messageInfo_MgmtBloomAddRequest.Size(m) + +func (c *mgmtServiceClient) Alive(ctx context.Context, in *MgmtAliveRequest, opts ...grpc.CallOption) (*MgmtAliveResponse, error) { + out := new(MgmtAliveResponse) + err := c.cc.Invoke(ctx, "/mgmt.MgmtService/Alive", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil } -func (m *MgmtBloomAddRequest) XXX_DiscardUnknown() { - xxx_messageInfo_MgmtBloomAddRequest.DiscardUnknown(m) + +func (c *mgmtServiceClient) BloomInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MgmtBloomInfoResponse, error) { + out := new(MgmtBloomInfoResponse) + err := c.cc.Invoke(ctx, "/mgmt.MgmtService/BloomInfo", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil } -var xxx_messageInfo_MgmtBloomAddRequest proto.InternalMessageInfo +func (c *mgmtServiceClient) BloomAdd(ctx context.Context, opts ...grpc.CallOption) (MgmtService_BloomAddClient, error) { + stream, err := c.cc.NewStream(ctx, &_MgmtService_serviceDesc.Streams[0], "/mgmt.MgmtService/BloomAdd", opts...) + if err != nil { + return nil, err + } + x := &mgmtServiceBloomAddClient{stream} + return x, nil +} -func (m *MgmtBloomAddRequest) GetIoc() string { - if m != nil { - return m.Ioc +type MgmtService_BloomAddClient interface { + Send(*MgmtBloomAddRequest) error + CloseAndRecv() (*MgmtBloomAddResponse, error) + grpc.ClientStream +} + +type mgmtServiceBloomAddClient struct { + grpc.ClientStream +} + +func (x *mgmtServiceBloomAddClient) Send(m *MgmtBloomAddRequest) error { + return x.ClientStream.SendMsg(m) +} + +func (x *mgmtServiceBloomAddClient) CloseAndRecv() (*MgmtBloomAddResponse, error) { + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err } - return "" + m := new(MgmtBloomAddResponse) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil } -type MgmtBloomAddResponse struct { - Added uint64 `protobuf:"varint,1,opt,name=added,proto3" json:"added,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` +func (c *mgmtServiceClient) BloomSave(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { + out := new(emptypb.Empty) + err := c.cc.Invoke(ctx, "/mgmt.MgmtService/BloomSave", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil } -func (m *MgmtBloomAddResponse) Reset() { *m = MgmtBloomAddResponse{} } -func (m *MgmtBloomAddResponse) String() string { return proto.CompactTextString(m) } -func (*MgmtBloomAddResponse) ProtoMessage() {} -func (*MgmtBloomAddResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_24cf82780fd24e73, []int{4} +func (c *mgmtServiceClient) BloomReload(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { + out := new(emptypb.Empty) + err := c.cc.Invoke(ctx, "/mgmt.MgmtService/BloomReload", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// MgmtServiceServer is the server API for MgmtService service. +type MgmtServiceServer interface { + Alive(context.Context, *MgmtAliveRequest) (*MgmtAliveResponse, error) + BloomInfo(context.Context, *emptypb.Empty) (*MgmtBloomInfoResponse, error) + BloomAdd(MgmtService_BloomAddServer) error + BloomSave(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + BloomReload(context.Context, *emptypb.Empty) (*emptypb.Empty, error) +} + +// UnimplementedMgmtServiceServer can be embedded to have forward compatible implementations. +type UnimplementedMgmtServiceServer struct { } -func (m *MgmtBloomAddResponse) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_MgmtBloomAddResponse.Unmarshal(m, b) +func (*UnimplementedMgmtServiceServer) Alive(context.Context, *MgmtAliveRequest) (*MgmtAliveResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Alive not implemented") } -func (m *MgmtBloomAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_MgmtBloomAddResponse.Marshal(b, m, deterministic) +func (*UnimplementedMgmtServiceServer) BloomInfo(context.Context, *emptypb.Empty) (*MgmtBloomInfoResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method BloomInfo not implemented") } -func (m *MgmtBloomAddResponse) XXX_Merge(src proto.Message) { - xxx_messageInfo_MgmtBloomAddResponse.Merge(m, src) +func (*UnimplementedMgmtServiceServer) BloomAdd(MgmtService_BloomAddServer) error { + return status.Errorf(codes.Unimplemented, "method BloomAdd not implemented") } -func (m *MgmtBloomAddResponse) XXX_Size() int { - return xxx_messageInfo_MgmtBloomAddResponse.Size(m) +func (*UnimplementedMgmtServiceServer) BloomSave(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { + return nil, status.Errorf(codes.Unimplemented, "method BloomSave not implemented") } -func (m *MgmtBloomAddResponse) XXX_DiscardUnknown() { - xxx_messageInfo_MgmtBloomAddResponse.DiscardUnknown(m) +func (*UnimplementedMgmtServiceServer) BloomReload(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { + return nil, status.Errorf(codes.Unimplemented, "method BloomReload not implemented") } -var xxx_messageInfo_MgmtBloomAddResponse proto.InternalMessageInfo +func RegisterMgmtServiceServer(s *grpc.Server, srv MgmtServiceServer) { + s.RegisterService(&_MgmtService_serviceDesc, srv) +} -func (m *MgmtBloomAddResponse) GetAdded() uint64 { - if m != nil { - return m.Added +func _MgmtService_Alive_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(MgmtAliveRequest) + if err := dec(in); err != nil { + return nil, err } - return 0 + if interceptor == nil { + return srv.(MgmtServiceServer).Alive(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/mgmt.MgmtService/Alive", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(MgmtServiceServer).Alive(ctx, req.(*MgmtAliveRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _MgmtService_BloomInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(emptypb.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(MgmtServiceServer).BloomInfo(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/mgmt.MgmtService/BloomInfo", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(MgmtServiceServer).BloomInfo(ctx, req.(*emptypb.Empty)) + } + return interceptor(ctx, in, info, handler) +} + +func _MgmtService_BloomAdd_Handler(srv interface{}, stream grpc.ServerStream) error { + return srv.(MgmtServiceServer).BloomAdd(&mgmtServiceBloomAddServer{stream}) +} + +type MgmtService_BloomAddServer interface { + SendAndClose(*MgmtBloomAddResponse) error + Recv() (*MgmtBloomAddRequest, error) + grpc.ServerStream +} + +type mgmtServiceBloomAddServer struct { + grpc.ServerStream +} + +func (x *mgmtServiceBloomAddServer) SendAndClose(m *MgmtBloomAddResponse) error { + return x.ServerStream.SendMsg(m) +} + +func (x *mgmtServiceBloomAddServer) Recv() (*MgmtBloomAddRequest, error) { + m := new(MgmtBloomAddRequest) + if err := x.ServerStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + +func _MgmtService_BloomSave_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(emptypb.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(MgmtServiceServer).BloomSave(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/mgmt.MgmtService/BloomSave", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(MgmtServiceServer).BloomSave(ctx, req.(*emptypb.Empty)) + } + return interceptor(ctx, in, info, handler) } -func init() { - proto.RegisterType((*MgmtBloomInfoResponse)(nil), "mgmt.MgmtBloomInfoResponse") - proto.RegisterType((*MgmtAliveRequest)(nil), "mgmt.MgmtAliveRequest") - proto.RegisterType((*MgmtAliveResponse)(nil), "mgmt.MgmtAliveResponse") - proto.RegisterType((*MgmtBloomAddRequest)(nil), "mgmt.MgmtBloomAddRequest") - proto.RegisterType((*MgmtBloomAddResponse)(nil), "mgmt.MgmtBloomAddResponse") -} - -func init() { - proto.RegisterFile("mgmt.proto", fileDescriptor_24cf82780fd24e73) -} - -var fileDescriptor_24cf82780fd24e73 = []byte{ - // 401 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x51, 0x3d, 0x8f, 0xda, 0x40, - 0x10, 0x95, 0xc1, 0x20, 0x33, 0x34, 0x64, 0x43, 0x88, 0x63, 0x28, 0x90, 0x1b, 0x5c, 0x44, 0xb6, - 0x94, 0x34, 0x91, 0xa2, 0x48, 0x01, 0x92, 0x22, 0x45, 0x14, 0x69, 0xe9, 0xd2, 0x44, 0xfe, 0x18, - 0x7f, 0x48, 0xb6, 0xd7, 0xf1, 0xae, 0x91, 0xf8, 0x63, 0xf9, 0x11, 0xf9, 0x55, 0xa7, 0x5d, 0xdb, - 0x70, 0x07, 0x5c, 0x71, 0xdd, 0xbc, 0x79, 0x6f, 0x66, 0xdf, 0xec, 0x03, 0x28, 0x92, 0x42, 0xb8, - 0x55, 0xcd, 0x04, 0x23, 0xba, 0xac, 0xad, 0x65, 0xc2, 0x58, 0x92, 0xa3, 0xa7, 0x7a, 0x41, 0x13, - 0x7b, 0x58, 0x54, 0xe2, 0xd4, 0x4a, 0xec, 0x7f, 0x1a, 0xbc, 0xf9, 0x99, 0x14, 0x62, 0x97, 0x33, - 0x56, 0xfc, 0x28, 0x63, 0x46, 0x91, 0x57, 0xac, 0xe4, 0x48, 0x96, 0x30, 0x49, 0x7d, 0xfe, 0x27, - 0x90, 0x84, 0xa9, 0xad, 0x35, 0xc7, 0xa0, 0x46, 0xea, 0x73, 0x25, 0x24, 0x16, 0x18, 0xa1, 0x5f, - 0xf9, 0x61, 0x26, 0x4e, 0xe6, 0x60, 0xad, 0x39, 0x3a, 0x3d, 0x63, 0xc9, 0x61, 0x8e, 0x05, 0x96, - 0x82, 0x9b, 0xc3, 0x96, 0xeb, 0x31, 0x21, 0xa0, 0x07, 0x99, 0xe0, 0xa6, 0xae, 0xfa, 0xaa, 0x26, - 0x2b, 0xf5, 0x50, 0x1a, 0x37, 0x65, 0xc8, 0xcd, 0x91, 0x22, 0x2e, 0x0d, 0xb2, 0x80, 0x71, 0x5c, - 0x55, 0x35, 0x0b, 0xcc, 0xf1, 0x5a, 0x73, 0x34, 0xda, 0x21, 0xdb, 0x81, 0x99, 0xf4, 0xbd, 0xcd, - 0xb3, 0x23, 0x52, 0xfc, 0xdb, 0x20, 0x17, 0x64, 0x0e, 0x23, 0x5f, 0x62, 0x65, 0x77, 0x42, 0x5b, - 0x60, 0x6f, 0xe0, 0xd5, 0x23, 0x65, 0x77, 0x1d, 0x01, 0x1d, 0xc3, 0x94, 0x75, 0x4a, 0x55, 0xdb, - 0x1b, 0x78, 0x7d, 0xfe, 0x8a, 0x6d, 0x14, 0xf5, 0x5b, 0x67, 0x30, 0xcc, 0x58, 0xd8, 0x29, 0x65, - 0x69, 0xbf, 0x87, 0xf9, 0x53, 0x61, 0xb7, 0x54, 0xbe, 0x1f, 0x45, 0x18, 0x29, 0xad, 0x4e, 0x5b, - 0xf0, 0xe1, 0xff, 0x00, 0xa6, 0x52, 0x7e, 0xc0, 0xfa, 0x98, 0x85, 0x48, 0x3e, 0xc1, 0x48, 0x79, - 0x21, 0x0b, 0x57, 0x65, 0x75, 0x7d, 0x86, 0xf5, 0xf6, 0xa6, 0xdf, 0xed, 0xff, 0x0a, 0x93, 0x73, - 0x4e, 0x64, 0xe1, 0xb6, 0xb9, 0xba, 0x7d, 0xae, 0xee, 0x77, 0x99, 0xab, 0xb5, 0xbc, 0x4c, 0xdf, - 0x86, 0xba, 0x07, 0xa3, 0x77, 0x4d, 0xde, 0x5d, 0x09, 0x2f, 0x27, 0x5b, 0xd6, 0x3d, 0xaa, 0x5d, - 0xe1, 0x68, 0xe4, 0x73, 0x67, 0xe3, 0xe0, 0xab, 0x23, 0xee, 0xdb, 0x78, 0xa6, 0x4f, 0xbe, 0xc0, - 0x54, 0x0d, 0x53, 0xcc, 0x99, 0x1f, 0xbd, 0x74, 0x7c, 0xb7, 0xfa, 0x6d, 0x25, 0x99, 0x48, 0x9b, - 0xc0, 0x0d, 0x59, 0xe1, 0x7d, 0xdb, 0x1f, 0x7e, 0x79, 0x31, 0x1e, 0xb1, 0xf6, 0xa4, 0xe1, 0x60, - 0xac, 0xd4, 0x1f, 0x1f, 0x02, 0x00, 0x00, 0xff, 0xff, 0x5e, 0xbf, 0x67, 0x4d, 0x05, 0x03, 0x00, - 0x00, +func _MgmtService_BloomReload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(emptypb.Empty) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(MgmtServiceServer).BloomReload(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/mgmt.MgmtService/BloomReload", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(MgmtServiceServer).BloomReload(ctx, req.(*emptypb.Empty)) + } + return interceptor(ctx, in, info, handler) +} + +var _MgmtService_serviceDesc = grpc.ServiceDesc{ + ServiceName: "mgmt.MgmtService", + HandlerType: (*MgmtServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "Alive", + Handler: _MgmtService_Alive_Handler, + }, + { + MethodName: "BloomInfo", + Handler: _MgmtService_BloomInfo_Handler, + }, + { + MethodName: "BloomSave", + Handler: _MgmtService_BloomSave_Handler, + }, + { + MethodName: "BloomReload", + Handler: _MgmtService_BloomReload_Handler, + }, + }, + Streams: []grpc.StreamDesc{ + { + StreamName: "BloomAdd", + Handler: _MgmtService_BloomAdd_Handler, + ClientStreams: true, + }, + }, + Metadata: "mgmt.proto", } diff --git a/mgmt/mgmt_grpc.pb.go b/mgmt/mgmt_grpc.pb.go deleted file mode 100644 index ba3de39..0000000 --- a/mgmt/mgmt_grpc.pb.go +++ /dev/null @@ -1,281 +0,0 @@ -// Code generated by protoc-gen-go-grpc. DO NOT EDIT. - -package mgmt - -import ( - context "context" - grpc "google.golang.org/grpc" - codes "google.golang.org/grpc/codes" - status "google.golang.org/grpc/status" - emptypb "google.golang.org/protobuf/types/known/emptypb" -) - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.32.0 or later. -const _ = grpc.SupportPackageIsVersion7 - -// MgmtServiceClient is the client API for MgmtService service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. -type MgmtServiceClient interface { - Alive(ctx context.Context, in *MgmtAliveRequest, opts ...grpc.CallOption) (*MgmtAliveResponse, error) - BloomInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MgmtBloomInfoResponse, error) - BloomAdd(ctx context.Context, opts ...grpc.CallOption) (MgmtService_BloomAddClient, error) - BloomSave(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) - BloomReload(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) -} - -type mgmtServiceClient struct { - cc grpc.ClientConnInterface -} - -func NewMgmtServiceClient(cc grpc.ClientConnInterface) MgmtServiceClient { - return &mgmtServiceClient{cc} -} - -func (c *mgmtServiceClient) Alive(ctx context.Context, in *MgmtAliveRequest, opts ...grpc.CallOption) (*MgmtAliveResponse, error) { - out := new(MgmtAliveResponse) - err := c.cc.Invoke(ctx, "/mgmt.MgmtService/Alive", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *mgmtServiceClient) BloomInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MgmtBloomInfoResponse, error) { - out := new(MgmtBloomInfoResponse) - err := c.cc.Invoke(ctx, "/mgmt.MgmtService/BloomInfo", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *mgmtServiceClient) BloomAdd(ctx context.Context, opts ...grpc.CallOption) (MgmtService_BloomAddClient, error) { - stream, err := c.cc.NewStream(ctx, &MgmtService_ServiceDesc.Streams[0], "/mgmt.MgmtService/BloomAdd", opts...) - if err != nil { - return nil, err - } - x := &mgmtServiceBloomAddClient{stream} - return x, nil -} - -type MgmtService_BloomAddClient interface { - Send(*MgmtBloomAddRequest) error - CloseAndRecv() (*MgmtBloomAddResponse, error) - grpc.ClientStream -} - -type mgmtServiceBloomAddClient struct { - grpc.ClientStream -} - -func (x *mgmtServiceBloomAddClient) Send(m *MgmtBloomAddRequest) error { - return x.ClientStream.SendMsg(m) -} - -func (x *mgmtServiceBloomAddClient) CloseAndRecv() (*MgmtBloomAddResponse, error) { - if err := x.ClientStream.CloseSend(); err != nil { - return nil, err - } - m := new(MgmtBloomAddResponse) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} - -func (c *mgmtServiceClient) BloomSave(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { - out := new(emptypb.Empty) - err := c.cc.Invoke(ctx, "/mgmt.MgmtService/BloomSave", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *mgmtServiceClient) BloomReload(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { - out := new(emptypb.Empty) - err := c.cc.Invoke(ctx, "/mgmt.MgmtService/BloomReload", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -// MgmtServiceServer is the server API for MgmtService service. -// All implementations must embed UnimplementedMgmtServiceServer -// for forward compatibility -type MgmtServiceServer interface { - Alive(context.Context, *MgmtAliveRequest) (*MgmtAliveResponse, error) - BloomInfo(context.Context, *emptypb.Empty) (*MgmtBloomInfoResponse, error) - BloomAdd(MgmtService_BloomAddServer) error - BloomSave(context.Context, *emptypb.Empty) (*emptypb.Empty, error) - BloomReload(context.Context, *emptypb.Empty) (*emptypb.Empty, error) - mustEmbedUnimplementedMgmtServiceServer() -} - -// UnimplementedMgmtServiceServer must be embedded to have forward compatible implementations. -type UnimplementedMgmtServiceServer struct { -} - -func (UnimplementedMgmtServiceServer) Alive(context.Context, *MgmtAliveRequest) (*MgmtAliveResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method Alive not implemented") -} -func (UnimplementedMgmtServiceServer) BloomInfo(context.Context, *emptypb.Empty) (*MgmtBloomInfoResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method BloomInfo not implemented") -} -func (UnimplementedMgmtServiceServer) BloomAdd(MgmtService_BloomAddServer) error { - return status.Errorf(codes.Unimplemented, "method BloomAdd not implemented") -} -func (UnimplementedMgmtServiceServer) BloomSave(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { - return nil, status.Errorf(codes.Unimplemented, "method BloomSave not implemented") -} -func (UnimplementedMgmtServiceServer) BloomReload(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { - return nil, status.Errorf(codes.Unimplemented, "method BloomReload not implemented") -} -func (UnimplementedMgmtServiceServer) mustEmbedUnimplementedMgmtServiceServer() {} - -// UnsafeMgmtServiceServer may be embedded to opt out of forward compatibility for this service. -// Use of this interface is not recommended, as added methods to MgmtServiceServer will -// result in compilation errors. -type UnsafeMgmtServiceServer interface { - mustEmbedUnimplementedMgmtServiceServer() -} - -func RegisterMgmtServiceServer(s grpc.ServiceRegistrar, srv MgmtServiceServer) { - s.RegisterService(&MgmtService_ServiceDesc, srv) -} - -func _MgmtService_Alive_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(MgmtAliveRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(MgmtServiceServer).Alive(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/mgmt.MgmtService/Alive", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(MgmtServiceServer).Alive(ctx, req.(*MgmtAliveRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _MgmtService_BloomInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(emptypb.Empty) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(MgmtServiceServer).BloomInfo(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/mgmt.MgmtService/BloomInfo", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(MgmtServiceServer).BloomInfo(ctx, req.(*emptypb.Empty)) - } - return interceptor(ctx, in, info, handler) -} - -func _MgmtService_BloomAdd_Handler(srv interface{}, stream grpc.ServerStream) error { - return srv.(MgmtServiceServer).BloomAdd(&mgmtServiceBloomAddServer{stream}) -} - -type MgmtService_BloomAddServer interface { - SendAndClose(*MgmtBloomAddResponse) error - Recv() (*MgmtBloomAddRequest, error) - grpc.ServerStream -} - -type mgmtServiceBloomAddServer struct { - grpc.ServerStream -} - -func (x *mgmtServiceBloomAddServer) SendAndClose(m *MgmtBloomAddResponse) error { - return x.ServerStream.SendMsg(m) -} - -func (x *mgmtServiceBloomAddServer) Recv() (*MgmtBloomAddRequest, error) { - m := new(MgmtBloomAddRequest) - if err := x.ServerStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} - -func _MgmtService_BloomSave_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(emptypb.Empty) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(MgmtServiceServer).BloomSave(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/mgmt.MgmtService/BloomSave", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(MgmtServiceServer).BloomSave(ctx, req.(*emptypb.Empty)) - } - return interceptor(ctx, in, info, handler) -} - -func _MgmtService_BloomReload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(emptypb.Empty) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(MgmtServiceServer).BloomReload(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/mgmt.MgmtService/BloomReload", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(MgmtServiceServer).BloomReload(ctx, req.(*emptypb.Empty)) - } - return interceptor(ctx, in, info, handler) -} - -// MgmtService_ServiceDesc is the grpc.ServiceDesc for MgmtService service. -// It's only intended for direct use with grpc.RegisterService, -// and not to be introspected or modified (even as a copy) -var MgmtService_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "mgmt.MgmtService", - HandlerType: (*MgmtServiceServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "Alive", - Handler: _MgmtService_Alive_Handler, - }, - { - MethodName: "BloomInfo", - Handler: _MgmtService_BloomInfo_Handler, - }, - { - MethodName: "BloomSave", - Handler: _MgmtService_BloomSave_Handler, - }, - { - MethodName: "BloomReload", - Handler: _MgmtService_BloomReload_Handler, - }, - }, - Streams: []grpc.StreamDesc{ - { - StreamName: "BloomAdd", - Handler: _MgmtService_BloomAdd_Handler, - ClientStreams: true, - }, - }, - Metadata: "mgmt.proto", -} diff --git a/protomgmtc.sh b/protomgmtc.sh index 4d71246..a0325eb 100755 --- a/protomgmtc.sh +++ b/protomgmtc.sh @@ -10,7 +10,5 @@ find ${MGMT_PATH} -name "*.pb.go" -delete protoc \ --proto_path="${WELL_KNOWN_TYPES}" \ --proto_path="${MGMT_PATH}" \ - --proto_path="${GOPATH}/src" \ - --go_out=paths=source_relative:"${MGMT_PATH}" \ - --go-grpc_out=paths=source_relative:"${MGMT_PATH}" \ + --go_out=plugins=grpc:${GOPATH}/src \ ${MGMT_PATH}/mgmt.proto From cf985464d1c754ebbfa457f36370ca7a59d5e9d9 Mon Sep 17 00:00:00 2001 From: Sascha Steinbiss Date: Sun, 15 Aug 2021 21:37:14 +0200 Subject: [PATCH 2/2] update CHANGELOG --- CHANGELOG.md | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index b5ddb35..1b94f48 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -2,10 +2,19 @@ All notable changes to FEVER will be documented in this file. +## [1.3.0] - 2021-08-15 + +### Added +- gRPC based infrastructure for remote runtime communication with FEVER process. +- Runtime control tool for Bloom filter matcher `fever bloom` (#86, #85) + +### Changed +- CI now uses GitHub Actions (#87, #81) + ## [1.2.0] - 2021-06-25 ### Added -- Support for multiple output sockets with ecent type filtering and +- Support for multiple output sockets with event type filtering and buffers (#84) ### Changed