| /dports/audio/sayonara/sayonara-player-5bbf1399332d5d59362ad03bf625f9132be72206/src/Components/Broadcasting/ |
| H A D | StreamServerHandler.cpp | 29 StreamServer* streamServer=nullptr; member
32 streamServer(new StreamServer{playManager, audioDataProvider}) in Private()
37 if(streamServer){ in ~Private()
38 delete streamServer; in ~Private()
54 m->streamServer->restart(); in portChanged()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/collector/config/configauth/ |
| H A D | serverauth_test.go | 106 streamServer := &mockServerStream{
111 …err := DefaultGRPCStreamServerInterceptor(nil, streamServer, &grpc.StreamServerInfo{}, handler, au…
132 streamServer := &mockServerStream{
137 …err := DefaultGRPCStreamServerInterceptor(nil, streamServer, &grpc.StreamServerInfo{}, handler, au…
154 streamServer := &mockServerStream{
159 …err := DefaultGRPCStreamServerInterceptor(nil, streamServer, &grpc.StreamServerInfo{}, handler, au…
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gitlab.com/gitlab-org/gitlab-terminal/gitlab-terminal-2a71b03b44621289b28493d8bf3eaa9f64dbb6c9/ |
| H A D | terminal_test.go | 20 srv := streamServer{
44 type streamServer struct { struct
48 func (d *streamServer) ServeHTTP(w http.ResponseWriter, r *http.Request) { argument
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/vendor/github.com/containerd/cri/pkg/server/ |
| H A D | service.go | 96 streamServer streaming.Server member
161 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
214 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
270 if err := c.streamServer.Stop(); err != nil {
|
| H A D | container_exec.go | 35 return c.streamServer.GetExec(r)
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/containerd/containerd/vendor/github.com/containerd/cri/pkg/server/ |
| H A D | service.go | 96 streamServer streaming.Server member
161 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
214 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
270 if err := c.streamServer.Stop(); err != nil {
|
| H A D | container_exec.go | 35 return c.streamServer.GetExec(r)
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/vendor/github.com/containerd/cri/pkg/server/ |
| H A D | service.go | 93 streamServer streaming.Server member
135 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
207 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
270 if err := c.streamServer.Stop(); err != nil {
|
| H A D | sandbox_portforward.go | 37 return c.streamServer.GetPortForward(r)
|
| H A D | container_exec.go | 35 return c.streamServer.GetExec(r)
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/pkg/cri/server/ |
| H A D | service.go | 93 streamServer streaming.Server member
138 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
210 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
273 if err := c.streamServer.Stop(); err != nil {
|
| H A D | sandbox_portforward.go | 37 return c.streamServer.GetPortForward(r)
|
| H A D | container_exec.go | 35 return c.streamServer.GetExec(r)
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/pkg/cri/server/ |
| H A D | service.go | 93 streamServer streaming.Server member
135 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
207 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
270 if err := c.streamServer.Stop(); err != nil {
|
| H A D | sandbox_portforward.go | 37 return c.streamServer.GetPortForward(r)
|
| H A D | container_exec.go | 35 return c.streamServer.GetExec(r)
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/pkg/cri/server/ |
| H A D | service.go | 93 streamServer streaming.Server member
138 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
210 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
273 if err := c.streamServer.Stop(); err != nil {
|
| H A D | sandbox_portforward.go | 37 return c.streamServer.GetPortForward(r)
|
| H A D | container_exec.go | 35 return c.streamServer.GetExec(r)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/vendor/github.com/containerd/cri/pkg/server/ |
| H A D | service.go | 93 streamServer streaming.Server member
135 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
207 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
270 if err := c.streamServer.Stop(); err != nil {
|
| H A D | sandbox_portforward.go | 37 return c.streamServer.GetPortForward(r)
|
| H A D | container_exec.go | 35 return c.streamServer.GetExec(r)
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/vendor/github.com/containerd/cri/pkg/server/ |
| H A D | service.go | 93 streamServer streaming.Server member
135 …c.streamServer, err = newStreamServer(c, config.StreamServerAddress, config.StreamServerPort, conf…
207 if err := c.streamServer.Start(true); err != nil && err != http.ErrServerClosed {
270 if err := c.streamServer.Stop(); err != nil {
|
| H A D | sandbox_portforward.go | 37 return c.streamServer.GetPortForward(r)
|
| /dports/www/nginx-prometheus-exporter/nginx-prometheus-exporter-0.10.0/vendor/github.com/nginxinc/nginx-plus-go-client/tests/ |
| H A D | client_test.go | 40 streamServer := client.StreamUpstreamServer{
46 err = c.AddStreamServer(streamUpstream, streamServer)
52 err = c.AddStreamServer(streamUpstream, streamServer)
60 err = c.DeleteStreamServer(streamUpstream, streamServer.Server)
65 err = c.DeleteStreamServer(streamUpstream, streamServer.Server)
266 streamServer := client.StreamUpstreamServer{
276 err = c.AddStreamServer(streamUpstream, streamServer)
290 if !reflect.DeepEqual(streamServer, servers[0]) {
291 t.Errorf("Expected: %v Got: %v", streamServer, servers[0])
823 streamServer := client.StreamUpstreamServer{
[all …]
|