/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | udp_client_test.go | 35 assert.Nil(t, agentClient) 49 assert.NotNil(t, agentClient) 50 assert.Equal(t, 25000, agentClient.maxPacketSize) 56 assert.NoError(t, agentClient.Close()) 68 assert.NotNil(t, agentClient) 75 assert.NoError(t, agentClient.Close()) 85 assert.NotNil(t, agentClient) 92 assert.NoError(t, agentClient.Close()) 106 assert.NotNil(t, agentClient) 111 assert.NoError(t, agentClient.Close()) [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | udp_client_test.go | 36 assert.Nil(t, agentClient) 50 assert.NotNil(t, agentClient) 51 assert.Equal(t, 25000, agentClient.maxPacketSize) 57 assert.NoError(t, agentClient.Close()) 69 assert.NotNil(t, agentClient) 76 assert.NoError(t, agentClient.Close()) 86 assert.NotNil(t, agentClient) 93 assert.NoError(t, agentClient.Close()) 107 assert.NotNil(t, agentClient) 112 assert.NoError(t, agentClient.Close()) [all …]
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | udp_client_test.go | 35 assert.Nil(t, agentClient) 49 assert.NotNil(t, agentClient) 50 assert.Equal(t, 25000, agentClient.maxPacketSize) 56 assert.NoError(t, agentClient.Close()) 68 assert.NotNil(t, agentClient) 75 assert.NoError(t, agentClient.Close()) 85 assert.NotNil(t, agentClient) 92 assert.NoError(t, agentClient.Close()) 106 assert.NotNil(t, agentClient) 111 assert.NoError(t, agentClient.Close()) [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | udp_client_test.go | 36 assert.Nil(t, agentClient) 50 assert.NotNil(t, agentClient) 51 assert.Equal(t, 25000, agentClient.maxPacketSize) 57 assert.NoError(t, agentClient.Close()) 69 assert.NotNil(t, agentClient) 76 assert.NoError(t, agentClient.Close()) 86 assert.NotNil(t, agentClient) 93 assert.NoError(t, agentClient.Close()) 107 assert.NotNil(t, agentClient) 112 assert.NoError(t, agentClient.Close()) [all …]
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | udp_client_test.go | 35 assert.Nil(t, agentClient) 49 assert.NotNil(t, agentClient) 50 assert.Equal(t, 25000, agentClient.maxPacketSize) 56 assert.NoError(t, agentClient.Close()) 68 assert.NotNil(t, agentClient) 75 assert.NoError(t, agentClient.Close()) 85 assert.NotNil(t, agentClient) 92 assert.NoError(t, agentClient.Close()) 106 assert.NotNil(t, agentClient) 111 assert.NoError(t, agentClient.Close()) [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/uber/jaeger-client-go/utils/ |
H A D | udp_client_test.go | 36 assert.Nil(t, agentClient) 50 assert.NotNil(t, agentClient) 51 assert.Equal(t, 25000, agentClient.maxPacketSize) 57 assert.NoError(t, agentClient.Close()) 69 assert.NotNil(t, agentClient) 76 assert.NoError(t, agentClient.Close()) 86 assert.NotNil(t, agentClient) 93 assert.NoError(t, agentClient.Close()) 107 assert.NotNil(t, agentClient) 112 assert.NoError(t, agentClient.Close()) [all …]
|
/dports/security/vuls/vuls-0.13.7/vendor/go.opentelemetry.io/otel/exporters/trace/jaeger/ |
H A D | agent_test.go | 28 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 33 assert.Nil(t, agentClient) 41 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 47 assert.NotNil(t, agentClient) 48 assert.Equal(t, 25000, agentClient.maxPacketSize) 54 assert.NoError(t, agentClient.Close()) 67 assert.NotNil(t, agentClient) 74 assert.NoError(t, agentClient.Close()) 88 assert.NotNil(t, agentClient) 91 assert.IsType(t, &net.UDPConn{}, agentClient.connUDP) [all …]
|
/dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/go.opentelemetry.io/otel/exporters/trace/jaeger/ |
H A D | agent_test.go | 28 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 33 assert.Nil(t, agentClient) 41 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 47 assert.NotNil(t, agentClient) 48 assert.Equal(t, 25000, agentClient.maxPacketSize) 54 assert.NoError(t, agentClient.Close()) 67 assert.NotNil(t, agentClient) 74 assert.NoError(t, agentClient.Close()) 88 assert.NotNil(t, agentClient) 91 assert.IsType(t, &net.UDPConn{}, agentClient.connUDP) [all …]
|
/dports/games/automuteus/automuteus-6.15.2/vendor/go.opentelemetry.io/otel/exporters/trace/jaeger/ |
H A D | agent_test.go | 28 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 33 assert.Nil(t, agentClient) 41 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 47 assert.NotNil(t, agentClient) 48 assert.Equal(t, 25000, agentClient.maxPacketSize) 54 assert.NoError(t, agentClient.Close()) 67 assert.NotNil(t, agentClient) 74 assert.NoError(t, agentClient.Close()) 88 assert.NotNil(t, agentClient) 91 assert.IsType(t, &net.UDPConn{}, agentClient.connUDP) [all …]
|
/dports/net/storj/storj-1.45.3/vendor/go.opentelemetry.io/otel/exporters/trace/jaeger/ |
H A D | agent_test.go | 28 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 33 assert.Nil(t, agentClient) 41 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 47 assert.NotNil(t, agentClient) 48 assert.Equal(t, 25000, agentClient.maxPacketSize) 54 assert.NoError(t, agentClient.Close()) 67 assert.NotNil(t, agentClient) 74 assert.NoError(t, agentClient.Close()) 88 assert.NotNil(t, agentClient) 91 assert.IsType(t, &net.UDPConn{}, agentClient.connUDP) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/go.opentelemetry.io/otel/exporters/trace/jaeger/ |
H A D | agent_test.go | 26 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 31 assert.Nil(t, agentClient) 41 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 48 assert.NotNil(t, agentClient) 49 assert.Equal(t, 25000, agentClient.maxPacketSize) 55 assert.NoError(t, agentClient.Close()) 71 assert.NotNil(t, agentClient) 78 assert.NoError(t, agentClient.Close()) 95 assert.NotNil(t, agentClient) 98 assert.IsType(t, &net.UDPConn{}, agentClient.connUDP) [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/otel/exporters/jaeger/ |
H A D | agent_test.go | 30 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 35 assert.Nil(t, agentClient) 45 agentClient, err := newAgentClientUDP(agentClientUDPParams{ 52 assert.NotNil(t, agentClient) 53 assert.Equal(t, 25000, agentClient.maxPacketSize) 59 assert.NoError(t, agentClient.Close()) 75 assert.NotNil(t, agentClient) 82 assert.NoError(t, agentClient.Close()) 99 assert.NotNil(t, agentClient) 102 assert.IsType(t, &net.UDPConn{}, agentClient.connUDP) [all …]
|
/dports/net/bosh-cli/bosh-cli-5.5.0/deployment/vm/ |
H A D | vm.go | 54 agentClient biagentclient.AgentClient member 68 agentClient biagentclient.AgentClient, 79 agentClient: agentClient, 93 agentClient biagentclient.AgentClient, 105 agentClient: agentClient, 128 return vm.agentClient 139 err := vm.agentClient.Start() 168 err := vm.agentClient.Stop() 178 err := vm.agentClient.Apply(newState) 259 disks, err := vm.agentClient.ListDisk() [all …]
|
H A D | manager.go | 30 agentClient biagentclient.AgentClient member 44 agentClient biagentclient.AgentClient, 53 agentClient: agentClient, 80 m.agentClient, 142 m.agentClient,
|
H A D | manager_factory.go | 14 NewManager(cloud bicloud.Cloud, agentClient biagentclient.AgentClient) Manager 44 func (f *managerFactory) NewManager(cloud bicloud.Cloud, agentClient biagentclient.AgentClient) Man… 49 agentClient,
|
/dports/misc/concourse/vault-bdd38fca2cff/command/ |
H A D | agent_test.go | 581 req = agentClient.NewRequest("GET", "/v1/sys/health") 582 request(agentClient, req, 200) 587 req = agentClient.NewRequest("GET", "/v1/sys/health") 588 request(agentClient, req, 200) 593 req = agentClient.NewRequest("GET", "/v1/sys/health") 594 resp, err := agentClient.RawRequest(req) 605 h := agentClient.Headers() 607 agentClient.SetHeaders(h) 608 req = agentClient.NewRequest("GET", "/v1/sys/health") 609 resp, err = agentClient.RawRequest(req) [all …]
|
/dports/net/bosh-cli/bosh-cli-5.5.0/vendor/github.com/cloudfoundry/bosh-agent/agentclient/ |
H A D | get_state_retryable.go | 9 agentClient AgentClient member 12 func NewGetStateRetryable(agentClient AgentClient) boshretry.Retryable { 14 agentClient: agentClient, 19 stateResponse, err := r.agentClient.GetState()
|
H A D | ping_retryable.go | 11 agentClient AgentClient member 14 func NewPingRetryable(agentClient AgentClient) boshretry.Retryable { 16 agentClient: agentClient, 21 _, err := r.agentClient.Ping()
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/command/ |
H A D | agent_test.go | 555 req = agentClient.NewRequest("GET", "/v1/sys/health") 556 request(t, agentClient, req, 200) 561 req = agentClient.NewRequest("GET", "/v1/sys/health") 562 request(t, agentClient, req, 200) 567 req = agentClient.NewRequest("GET", "/v1/sys/health") 568 resp, err := agentClient.RawRequest(req) 579 h := agentClient.Headers() 581 agentClient.SetHeaders(h) 582 req = agentClient.NewRequest("GET", "/v1/sys/health") 583 resp, err = agentClient.RawRequest(req) [all …]
|
/dports/net/bosh-cli/bosh-cli-5.5.0/deployment/instance/state/ |
H A D | remote_package_compiler.go | 13 agentClient biagentclient.AgentClient member 19 agentClient biagentclient.AgentClient, 24 agentClient: agentClient, 80 compiledPackageRef, err := c.agentClient.CompilePackage(packageSource, packageDependencies)
|
/dports/net/traefik/traefik-2.6.1/vendor/github.com/instana/go-sensor/ |
H A D | sensor.go | 31 type agentClient interface { interface 57 agent agentClient 89 var agent agentClient 130 func (r *sensorS) setAgent(agent agentClient) { 139 func (r *sensorS) Agent() agentClient { 218 …rviceName, agentEndpoint, agentKey string, client *http.Client, logger LeveledLogger) agentClient {
|
/dports/sysutils/helmfile/vault-f6547fa8e820/command/ |
H A D | agent_test.go | 573 req = agentClient.NewRequest("GET", "/v1/sys/health") 574 request(t, agentClient, req, 200) 579 req = agentClient.NewRequest("GET", "/v1/sys/health") 580 request(t, agentClient, req, 200) 585 req = agentClient.NewRequest("GET", "/v1/sys/health") 586 resp, err := agentClient.RawRequest(req) 597 h := agentClient.Headers() 599 agentClient.SetHeaders(h) 600 req = agentClient.NewRequest("GET", "/v1/sys/health") 601 resp, err = agentClient.RawRequest(req) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/golang.org/x/crypto/ssh/agent/ |
H A D | server_test.go | 77 agentClient := NewClient(ch) 78 testAgentInterface(t, agentClient, testPrivateKeys["rsa"], nil, 0) 167 agentClient := NewClient(b) 168 if err := agentClient.Add(AddedKey{PrivateKey: key, Certificate: cert}); err != nil { 171 return verifyKey(agentClient)
|
H A D | example_test.go | 23 agentClient := agent.NewClient(conn) 30 ssh.PublicKeysCallback(agentClient.Signers),
|
/dports/net/grpcui/grpcui-1.1.0/vendor/golang.org/x/crypto/ssh/agent/ |
H A D | example_test.go | 23 agentClient := agent.NewClient(conn) 30 ssh.PublicKeysCallback(agentClient.Signers),
|