Lines Matching refs:agentClient

31 	agentClient, err := NewAgentClientUDPWithParams(AgentClientUDPParams{
36 	assert.Nil(t, agentClient)
44 	agentClient, err := NewAgentClientUDPWithParams(AgentClientUDPParams{
50 	assert.NotNil(t, agentClient)
51 	assert.Equal(t, 25000, agentClient.maxPacketSize)
53 	if assert.IsType(t, &reconnectingUDPConn{}, agentClient.connUDP) {
54 		assert.Equal(t, log.NullLogger, agentClient.connUDP.(*reconnectingUDPConn).logger)
57 	assert.NoError(t, agentClient.Close())
65 	agentClient, err := NewAgentClientUDPWithParams(AgentClientUDPParams{
69 	assert.NotNil(t, agentClient)
70 	assert.Equal(t, UDPPacketMaxLength, agentClient.maxPacketSize)
72 	if assert.IsType(t, &reconnectingUDPConn{}, agentClient.connUDP) {
73 		assert.Equal(t, agentClient.connUDP.(*reconnectingUDPConn).logger, log.StdLogger)
76 	assert.NoError(t, agentClient.Close())
84 	agentClient, err := NewAgentClientUDP("localhost:6831", 0)
86 	assert.NotNil(t, agentClient)
87 	assert.Equal(t, UDPPacketMaxLength, agentClient.maxPacketSize)
89 	if assert.IsType(t, &reconnectingUDPConn{}, agentClient.connUDP) {
90 		assert.Equal(t, agentClient.connUDP.(*reconnectingUDPConn).logger, log.StdLogger)
93 	assert.NoError(t, agentClient.Close())
101 	agentClient, err := NewAgentClientUDPWithParams(AgentClientUDPParams{
107 	assert.NotNil(t, agentClient)
108 	assert.Equal(t, UDPPacketMaxLength, agentClient.maxPacketSize)
110 	assert.IsType(t, &net.UDPConn{}, agentClient.connUDP)
112 	assert.NoError(t, agentClient.Close())
116 	agentClient := AgentClientUDP{}
118 …assert.Error(t, agentClient.EmitZipkinBatch(context.Background(), []*zipkincore.Span{{Name: "fakes…