Home
last modified time | relevance | path

Searched refs:StreamInterceptor (Results 1 – 25 of 680) sorted by relevance

12345678910>>...28

/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/server/
H A Dserver.go98 grpc.StreamInterceptor(grpc_middleware.ChainStreamServer(
101 metadatahandler.StreamInterceptor,
103 commandstatshandler.StreamInterceptor,
110 …lh.StreamInterceptor(), // Should be below auth handler to prevent v2 hmac tokens from timing out …
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/server/
H A Dserver.go108 grpc.StreamInterceptor(grpcmw.ChainStreamServer(
111 metadatahandler.StreamInterceptor,
113 commandstatshandler.StreamInterceptor,
120 …lh.StreamInterceptor(), // Should be below auth handler to prevent v2 hmac tokens from timing out …
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/server/
H A Dserver.go108 grpc.StreamInterceptor(grpcmw.ChainStreamServer(
111 metadatahandler.StreamInterceptor,
113 commandstatshandler.StreamInterceptor,
120 …lh.StreamInterceptor(), // Should be below auth handler to prevent v2 hmac tokens from timing out …
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/grpc-ecosystem/go-grpc-middleware/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grpc-ecosystem/go-grpc-middleware/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/grpc-ecosystem/go-grpc-middleware/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/grpc-ecosystem/go-grpc-middleware/go-grpc-middleware-1.0.0/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/www/tusd/tusd-1.8.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/github.com/grpc-ecosystem/go-grpc-middleware/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/grpc-ecosystem/go-grpc-middleware/tags/
H A Dexamples_test.go14 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
25 grpc.StreamInterceptor(grpc_ctxtags.StreamServerInterceptor(opts...)),
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/grpc-ecosystem/go-grpc-middleware/auth/
H A Dexamples_test.go47 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
71 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grpc-ecosystem/go-grpc-middleware/auth/
H A Dexamples_test.go47 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
71 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/grpc-ecosystem/go-grpc-middleware/auth/
H A Dexamples_test.go47 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
71 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
/dports/www/tusd/tusd-1.8.0/vendor/github.com/grpc-ecosystem/go-grpc-middleware/auth/
H A Dexamples_test.go47 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
71 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/github.com/grpc-ecosystem/go-grpc-middleware/auth/
H A Dexamples_test.go47 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
71 grpc.StreamInterceptor(grpc_auth.StreamServerInterceptor(exampleAuthFunc)),
/dports/devel/spark/spark-2.1.1/common/network-common/src/main/java/org/apache/spark/network/client/
H A DStreamInterceptor.java31 class StreamInterceptor implements TransportFrameDecoder.Interceptor { class
39 StreamInterceptor( in StreamInterceptor() method in StreamInterceptor
/dports/net/grpcurl/grpcurl-1.8.5/vendor/cloud.google.com/go/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
/dports/net/storj/storj-1.45.3/vendor/cloud.google.com/go/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
/dports/sysutils/istio/istio-1.6.7/vendor/cloud.google.com/go/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
/dports/sysutils/helm/helm-3.5.2/vendor/cloud.google.com/go/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/bigtable/
H A Dretry_test.go155 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
212 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
260 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
308 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))
384 tbl, cleanup, err := setupFakeServer(grpc.StreamInterceptor(errInjector))

12345678910>>...28