func RegisterForwarderPlugins()

in plugins/forwarder/forwarder_repository.go [46:71]

• 25 lines of code
• 2 McCabe index (conditional complexity)

func RegisterForwarderPlugins() {
	plugin.RegisterPluginCategory(reflect.TypeOf((*api.Forwarder)(nil)).Elem())
	forwarders := []api.Forwarder{
		// Please register the forwarder plugins at here.
		new(kafka_nativelog.Forwarder),
		new(grpc_nativelog.Forwarder),
		new(grpc_meter.Forwarder),
		new(grpc_nativemanagement.Forwarder),
		new(grpc_nativetracing.Forwarder),
		new(grpc_nativeprofile.Forwarder),
		new(grpc_nativecds.Forwarder),
		new(grpc_nativeevent.Forwarder),
		new(grpc_nativejvm.Forwarder),
		new(grpc_nativeclr.Forwarder),
		new(grpc_nativeprocess.Forwarder),
		new(grpc_nativeebpfprofiling.Forwarder),
		new(envoyalsv2.Forwarder),
		new(envoyalsv3.Forwarder),
		new(envoymetricsv2.Forwarder),
		new(envoymetricsv3.Forwarder),
		new(otlpmetricsv1.Forwarder),
	}
	for _, forwarder := range forwarders {
		plugin.RegisterPlugin(forwarder)
	}
}