| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/streadway/amqp/ |
| H A D | client_test.go | 16 type server struct { struct
17 *testing.T anonMember
18 r reader // framer <- client
19 w writer // framer -> client
20 S io.ReadWriteCloser // Server IO
21 C io.ReadWriteCloser // Client IO
24 start connectionStartOk
25 tune connectionTuneOk
151 func (t *server) expectAMQP() {
166 func (t *server) connectionTune() {
[all …]
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/cloudflare/cfssl/api/client/ |
| H A D | client.go | 26 type server struct { struct
27 URL string
28 TLSConfig *tls.Config
29 reqModifier func(*http.Request, []byte)
30 RequestTimeout time.Duration
31 proxy func(*http.Request) (*url.URL, error)
80 func (srv *server) Hosts() []string {
88 func (srv *server) SetRequestTimeout(timeout time.Duration) {
104 func (srv *server) getURL(endpoint string) string {
108 func (srv *server) createTransport() *http.Transport {
[all …]
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/cloudflare/cfssl/cfssl-2001f384ec4f/api/client/ |
| H A D | client.go | 26 type server struct { struct
27 URL string
28 TLSConfig *tls.Config
29 reqModifier func(*http.Request, []byte)
30 RequestTimeout time.Duration
31 proxy func(*http.Request) (*url.URL, error)
80 func (srv *server) Hosts() []string {
88 func (srv *server) SetRequestTimeout(timeout time.Duration) {
104 func (srv *server) getURL(endpoint string) string {
108 func (srv *server) createTransport() *http.Transport {
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/http/ |
| H A D | TestHttpServerLifecycle.java | 30 private void assertAlive(HttpServer2 server) { in assertAlive()
35 private void assertNotLive(HttpServer2 server) { in assertNotLive()
46 HttpServer2 server = createTestServer(); in testCreatedServerIsNotAlive() local
51 HttpServer2 server = createTestServer(); in testStopUnstartedServer() local
62 HttpServer2 server = null; in testStartedServerIsAlive() local
82 HttpServer2 server = null; in testStartedServerWithRequestLog() local
96 private void assertToStringContains(HttpServer2 server, String text) { in assertToStringContains()
108 HttpServer2 server = createAndStartTestServer(); in testStoppedServerIsNotAlive() local
120 HttpServer2 server = createAndStartTestServer(); in testStoppingTwiceServerIsAllowed() local
136 HttpServer2 server = null; in testWepAppContextAfterServerStop() local
|
| /dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 89 type server struct { struct
90 logf Logger
92 db database
94 mu sync.Mutex
95 sessions map[string]*session
96 lros map[string]*lro
100 adminpb.DatabaseAdminServer
101 spannerpb.SpannerServer
102 lropb.OperationsServer
300 func (s *server) newSession() *spannerpb.Session {
[all …]
|
| /dports/security/lego/lego-4.5.3/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 89 type server struct { struct
90 logf Logger
92 db database
94 mu sync.Mutex
95 sessions map[string]*session
96 lros map[string]*lro
100 adminpb.DatabaseAdminServer
101 spannerpb.SpannerServer
102 lropb.OperationsServer
300 func (s *server) newSession() *spannerpb.Session {
[all …]
|
| /dports/security/vault/google-cloud-go-storage-v1.6.0/spanner/spannertest/ |
| H A D | inmem.go | 88 type server struct { struct
89 logf Logger
91 db database
93 mu sync.Mutex
94 sessions map[string]*session
95 lros map[string]*lro
99 adminpb.DatabaseAdminServer
100 spannerpb.SpannerServer
101 lropb.OperationsServer
299 func (s *server) newSession() *spannerpb.Session {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 89 type server struct { struct
90 logf Logger
92 db database
94 mu sync.Mutex
95 sessions map[string]*session
96 lros map[string]*lro
100 adminpb.DatabaseAdminServer
101 spannerpb.SpannerServer
102 lropb.OperationsServer
300 func (s *server) newSession() *spannerpb.Session {
[all …]
|
| /dports/sysutils/gomplate/google-cloud-go-storage-v1.12.0/spanner/spannertest/ |
| H A D | inmem.go | 91 type server struct { struct
92 logf Logger
94 db database
95 start time.Time
97 mu sync.Mutex
98 sessions map[string]*session
99 lros map[string]*lro
103 adminpb.DatabaseAdminServer
104 spannerpb.SpannerServer
105 lropb.OperationsServer
[all …]
|
| /dports/devel/gitlab-runner/google-cloud-go-storage-v1.12.0/spanner/spannertest/ |
| H A D | inmem.go | 91 type server struct { struct
92 logf Logger
94 db database
95 start time.Time
97 mu sync.Mutex
98 sessions map[string]*session
99 lros map[string]*lro
103 adminpb.DatabaseAdminServer
104 spannerpb.SpannerServer
105 lropb.OperationsServer
[all …]
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/ |
| H A D | server.go | 76 type server struct { struct
77 mutex sync.Mutex
79 tlsConf *tls.Config
80 config *Config
82 conn net.PacketConn
85 createdPacketConn bool
94 serverError error
95 errorChan chan struct{}
96 closed bool
101 sessionRunner sessionRunner
[all …]
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/github.com/envoyproxy/go-control-plane/pkg/server/ |
| H A D | server.go | 16 package server package
75 type server struct { struct
76 cache cache.Cache
77 callbacks Callbacks
80 streamCount int64
81 ctx context.Context
357 func (s *server) handler(stream stream, typeURL string) error {
396 func (s *server) StreamRoutes(stream v2grpc.RouteDiscoveryService_StreamRoutesServer) error {
482 func (s *server) DeltaEndpoints(_ v2grpc.EndpointDiscoveryService_DeltaEndpointsServer) error {
486 func (s *server) DeltaClusters(_ v2grpc.ClusterDiscoveryService_DeltaClustersServer) error {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/sysutils/restic/google-cloud-go-storage-v1.16.0/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/www/tusd/google-cloud-go-storage-v1.18.2/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|
| /dports/www/grafana8/google-cloud-go-storage-v1.14.0/spanner/spannertest/ |
| H A D | inmem.go | 92 type server struct { struct
93 logf Logger
95 db database
96 start time.Time
98 mu sync.Mutex
99 sessions map[string]*session
100 lros map[string]*lro
104 adminpb.DatabaseAdminServer
105 spannerpb.SpannerServer
106 lropb.OperationsServer
[all …]
|