Home
last modified time | relevance | path

Searched refs:agentClient (Results 1 – 25 of 285) sorted by relevance

12345678910>>...12

/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/uber/jaeger-client-go/utils/
H A Dudp_client_test.go35 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 Dudp_client_test.go36 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 Dudp_client_test.go35 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 Dudp_client_test.go36 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 Dudp_client_test.go35 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 Dudp_client_test.go36 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 Dagent_test.go28 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 Dagent_test.go28 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 Dagent_test.go28 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 Dagent_test.go28 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 Dagent_test.go26 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 Dagent_test.go30 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 Dvm.go54 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 Dmanager.go30 agentClient biagentclient.AgentClient member
44 agentClient biagentclient.AgentClient,
53 agentClient: agentClient,
80 m.agentClient,
142 m.agentClient,
H A Dmanager_factory.go14 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 Dagent_test.go581 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 Dget_state_retryable.go9 agentClient AgentClient member
12 func NewGetStateRetryable(agentClient AgentClient) boshretry.Retryable {
14 agentClient: agentClient,
19 stateResponse, err := r.agentClient.GetState()
H A Dping_retryable.go11 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 Dagent_test.go555 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 Dremote_package_compiler.go13 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 Dsensor.go31 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 Dagent_test.go573 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 Dserver_test.go77 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 Dexample_test.go23 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 Dexample_test.go23 agentClient := agent.NewClient(conn)
30 ssh.PublicKeysCallback(agentClient.Signers),

12345678910>>...12