CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test(compilation): Fixing test compilation (#15978)

This commit is contained in:
Paweł Żak 2024-10-03 22:45:09 +02:00 committed by GitHub
parent b6e59aac59
commit 40d7961e31
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 27 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
plugins/inputs/cisco_telemetry_mdt/cisco_telemetry_mdt_test.go
View File

@ -830,52 +830,52 @@ func TestHandleNXDMESubtree(t *testing.T) {
// error is expected since we are passing in dummy transport // error is expected since we are passing in dummy transport
require.Error(t, err) require.Error(t, err)
telemetry := &telemetryBis.Telemetry{ tel := &telemetry.Telemetry{
MsgTimestamp: 1543236572000, MsgTimestamp: 1543236572000,
EncodingPath: "sys/dme", EncodingPath: "sys/dme",
NodeId: &telemetryBis.Telemetry_NodeIdStr{NodeIdStr: "hostname"}, NodeId: &telemetry.Telemetry_NodeIdStr{NodeIdStr: "hostname"},
Subscription: &telemetryBis.Telemetry_SubscriptionIdStr{SubscriptionIdStr: "subscription"}, Subscription: &telemetry.Telemetry_SubscriptionIdStr{SubscriptionIdStr: "subscription"},
DataGpbkv: []*telemetryBis.TelemetryField{ DataGpbkv: []*telemetry.TelemetryField{
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "keys", Name: "keys",
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "sys/dme", Name: "sys/dme",
ValueByType: &telemetryBis.TelemetryField_StringValue{StringValue: "sys/dme"}, ValueByType: &telemetry.TelemetryField_StringValue{StringValue: "sys/dme"},
}, },
}, },
}, },
{ {
Name: "content", Name: "content",
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "children", Name: "children",
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "fooEntity", Name: "fooEntity",
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "attributes", Name: "attributes",
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "foo", Name: "foo",
ValueByType: &telemetryBis.TelemetryField_StringValue{ ValueByType: &telemetry.TelemetryField_StringValue{
StringValue: "bar1", StringValue: "bar1",
}, },
}, },
{ {
Name: "dn", Name: "dn",
ValueByType: &telemetryBis.TelemetryField_StringValue{ ValueByType: &telemetry.TelemetryField_StringValue{
StringValue: "eth1/1", StringValue: "eth1/1",
}, },
}, },
@ -890,26 +890,26 @@ func TestHandleNXDMESubtree(t *testing.T) {
}, },
}, },
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "fooEntity", Name: "fooEntity",
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "attributes", Name: "attributes",
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Fields: []*telemetryBis.TelemetryField{ Fields: []*telemetry.TelemetryField{
{ {
Name: "foo", Name: "foo",
ValueByType: &telemetryBis.TelemetryField_StringValue{ ValueByType: &telemetry.TelemetryField_StringValue{
StringValue: "bar2", StringValue: "bar2",
}, },
}, },
{ {
Name: "dn", Name: "dn",
ValueByType: &telemetryBis.TelemetryField_StringValue{ ValueByType: &telemetry.TelemetryField_StringValue{
StringValue: "eth1/2", StringValue: "eth1/2",
}, },
}, },
@ -932,7 +932,7 @@ func TestHandleNXDMESubtree(t *testing.T) {
}, },
}, },
}} }}
data, err := proto.Marshal(telemetry) data, err := proto.Marshal(tel)
require.NoError(t, err) require.NoError(t, err)
c.handleTelemetry(data) c.handleTelemetry(data)

4
plugins/inputs/kafka_consumer/kafka_consumer_test.go
View File

@ -898,10 +898,10 @@ func TestStartupErrorBehaviorRetryIntegration(t *testing.T) {
// Setup a writer // Setup a writer
creator := outputs.Outputs["kafka"] creator := outputs.Outputs["kafka"]
output, ok := creator().(*kafkaOutput.Kafka) output, ok := creator().(*outputs_kafka.Kafka)
require.True(t, ok) require.True(t, ok)
s := &influxSerializer.Serializer{} s := &serializers_influx.Serializer{}
require.NoError(t, s.Init()) require.NoError(t, s.Init())
output.SetSerializer(s) output.SetSerializer(s)
output.Brokers = brokers output.Brokers = brokers