[connector] deprecate CreateSettings -> Settings (#10338)
This deprecates CreateSettings in favour of Settings. NewNopCreateSettings is also being deprecated in favour of NewNopSettings Signed-off-by: Alex Boten <223565+codeboten@users.noreply.github.com>
This commit is contained in:
Alex Boten
GitHub
parent
9907ba50df
commit
3b3deb8dbe
|
|
@ -0,0 +1,28 @@
|
|||
# Use this changelog template to create an entry for release notes.
|
||||
|
||||
# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
|
||||
change_type: deprecation
|
||||
|
||||
# The name of the component, or a single word describing the area of concern, (e.g. otlpreceiver)
|
||||
component: connector
|
||||
|
||||
# A brief description of the change. Surround your text with quotes ("") if it needs to start with a backtick (`).
|
||||
note: Deprecate CreateSettings and NewNopCreateSettings
|
||||
|
||||
# One or more tracking issues or pull requests related to the change
|
||||
issues: [9428]
|
||||
|
||||
# (Optional) One or more lines of additional information to render under the primary note.
|
||||
# These lines will be padded with 2 spaces and then inserted directly into the document.
|
||||
# Use pipe (|) for multiline entries.
|
||||
subtext: |
|
||||
The following methods are being renamed:
|
||||
- connector.CreateSettings -> connector.Settings
|
||||
- connector.NewNopCreateSettings -> connector.NewNopSettings
|
||||
|
||||
# Optional: The change log or logs in which this entry should be included.
|
||||
# e.g. '[user]' or '[user, api]'
|
||||
# Include 'user' if the change is relevant to end users.
|
||||
# Include 'api' if there is a change to a library API.
|
||||
# Default: '[user]'
|
||||
change_logs: [api]
|
||||
|
|
@ -21,7 +21,7 @@ type componentTestTelemetry struct {
|
|||
meterProvider *sdkmetric.MeterProvider
|
||||
}
|
||||
|
||||
{{- if (or isExporter isReceiver isProcessor) }}
|
||||
{{- if (or isExporter isReceiver isProcessor isConnector) }}
|
||||
func (tt *componentTestTelemetry) NewSettings() {{ .Status.Class }}.Settings {
|
||||
settings := {{ .Status.Class }}test.NewNopSettings()
|
||||
settings.MeterProvider = tt.meterProvider
|
||||
|
|
|
|||
|
|
@ -366,12 +366,12 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
|
||||
tests := []struct{
|
||||
name string
|
||||
createFn func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error)
|
||||
createFn func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error)
|
||||
}{
|
||||
{{ if supportsLogsToLogs }}
|
||||
{
|
||||
name: "logs_to_logs",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewLogsRouter(map[component.ID]consumer.Logs{component.NewID(component.DataTypeLogs): consumertest.NewNop()})
|
||||
return factory.CreateLogsToLogs(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -380,7 +380,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsLogsToMetrics }}
|
||||
{
|
||||
name: "logs_to_metrics",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewMetricsRouter(map[component.ID]consumer.Metrics{component.NewID(component.DataTypeMetrics): consumertest.NewNop()})
|
||||
return factory.CreateLogsToMetrics(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -389,7 +389,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsLogsToTraces }}
|
||||
{
|
||||
name: "logs_to_traces",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewTracesRouter(map[component.ID]consumer.Traces{component.NewID(component.DataTypeTraces): consumertest.NewNop()})
|
||||
return factory.CreateLogsToTraces(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -398,7 +398,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsMetricsToLogs }}
|
||||
{
|
||||
name: "metrics_to_logs",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewLogsRouter(map[component.ID]consumer.Logs{component.NewID(component.DataTypeLogs): consumertest.NewNop()})
|
||||
return factory.CreateMetricsToLogs(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -407,7 +407,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsMetricsToMetrics }}
|
||||
{
|
||||
name: "metrics_to_metrics",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewMetricsRouter(map[component.ID]consumer.Metrics{component.NewID(component.DataTypeMetrics): consumertest.NewNop()})
|
||||
return factory.CreateMetricsToMetrics(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -416,7 +416,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsMetricsToTraces }}
|
||||
{
|
||||
name: "metrics_to_traces",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewTracesRouter(map[component.ID]consumer.Traces{component.NewID(component.DataTypeTraces): consumertest.NewNop()})
|
||||
return factory.CreateMetricsToTraces(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -425,7 +425,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsTracesToLogs }}
|
||||
{
|
||||
name: "traces_to_logs",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewLogsRouter(map[component.ID]consumer.Logs{component.NewID(component.DataTypeLogs): consumertest.NewNop()})
|
||||
return factory.CreateTracesToLogs(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -434,7 +434,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsTracesToMetrics }}
|
||||
{
|
||||
name: "traces_to_metrics",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewMetricsRouter(map[component.ID]consumer.Metrics{component.NewID(component.DataTypeMetrics): consumertest.NewNop()})
|
||||
return factory.CreateTracesToMetrics(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -443,7 +443,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
{{ if supportsTracesToTraces }}
|
||||
{
|
||||
name: "traces_to_traces",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewTracesRouter(map[component.ID]consumer.Traces{component.NewID(component.DataTypeTraces): consumertest.NewNop()})
|
||||
return factory.CreateTracesToTraces(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -461,7 +461,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
for _, test := range tests {
|
||||
{{- if not .Tests.SkipShutdown }}
|
||||
t.Run(test.name + "-shutdown", func(t *testing.T) {
|
||||
c, err := test.createFn(context.Background(), connectortest.NewNopCreateSettings(), cfg)
|
||||
c, err := test.createFn(context.Background(), connectortest.NewNopSettings(), cfg)
|
||||
require.NoError(t, err)
|
||||
err = c.Shutdown(context.Background())
|
||||
require.NoError(t, err)
|
||||
|
|
@ -470,13 +470,13 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
|
||||
{{- if not .Tests.SkipLifecycle }}
|
||||
t.Run(test.name + "-lifecycle", func(t *testing.T) {
|
||||
firstConnector, err := test.createFn(context.Background(), connectortest.NewNopCreateSettings(), cfg)
|
||||
firstConnector, err := test.createFn(context.Background(), connectortest.NewNopSettings(), cfg)
|
||||
require.NoError(t, err)
|
||||
host := componenttest.NewNopHost()
|
||||
require.NoError(t, err)
|
||||
require.NoError(t, firstConnector.Start(context.Background(), host))
|
||||
require.NoError(t, firstConnector.Shutdown(context.Background()))
|
||||
secondConnector, err := test.createFn(context.Background(), connectortest.NewNopCreateSettings(), cfg)
|
||||
secondConnector, err := test.createFn(context.Background(), connectortest.NewNopSettings(), cfg)
|
||||
require.NoError(t, err)
|
||||
require.NoError(t, secondConnector.Start(context.Background(), host))
|
||||
require.NoError(t, secondConnector.Shutdown(context.Background()))
|
||||
|
|
|
|||
|
|
@ -67,7 +67,12 @@ type Logs interface {
|
|||
}
|
||||
|
||||
// CreateSettings configures Connector creators.
|
||||
type CreateSettings struct {
|
||||
//
|
||||
// Deprecated: [v0.103.0] Use connector.Settings instead.
|
||||
type CreateSettings = Settings
|
||||
|
||||
// Settings configures Connector creators.
|
||||
type Settings struct {
|
||||
// ID returns the ID of the component that will be created.
|
||||
ID component.ID
|
||||
|
||||
|
|
@ -93,17 +98,17 @@ type Factory interface {
|
|||
// tests of any implementation of the Factory interface.
|
||||
CreateDefaultConfig() component.Config
|
||||
|
||||
CreateTracesToTraces(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Traces) (Traces, error)
|
||||
CreateTracesToMetrics(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Metrics) (Traces, error)
|
||||
CreateTracesToLogs(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Logs) (Traces, error)
|
||||
CreateTracesToTraces(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Traces) (Traces, error)
|
||||
CreateTracesToMetrics(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Metrics) (Traces, error)
|
||||
CreateTracesToLogs(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Logs) (Traces, error)
|
||||
|
||||
CreateMetricsToTraces(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Traces) (Metrics, error)
|
||||
CreateMetricsToMetrics(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Metrics) (Metrics, error)
|
||||
CreateMetricsToLogs(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Logs) (Metrics, error)
|
||||
CreateMetricsToTraces(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Traces) (Metrics, error)
|
||||
CreateMetricsToMetrics(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Metrics) (Metrics, error)
|
||||
CreateMetricsToLogs(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Logs) (Metrics, error)
|
||||
|
||||
CreateLogsToTraces(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Traces) (Logs, error)
|
||||
CreateLogsToMetrics(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Metrics) (Logs, error)
|
||||
CreateLogsToLogs(ctx context.Context, set CreateSettings, cfg component.Config, nextConsumer consumer.Logs) (Logs, error)
|
||||
CreateLogsToTraces(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Traces) (Logs, error)
|
||||
CreateLogsToMetrics(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Metrics) (Logs, error)
|
||||
CreateLogsToLogs(ctx context.Context, set Settings, cfg component.Config, nextConsumer consumer.Logs) (Logs, error)
|
||||
|
||||
TracesToTracesStability() component.StabilityLevel
|
||||
TracesToMetricsStability() component.StabilityLevel
|
||||
|
|
@ -136,12 +141,12 @@ func (f factoryOptionFunc) apply(o *factory) {
|
|||
}
|
||||
|
||||
// CreateTracesToTracesFunc is the equivalent of Factory.CreateTracesToTraces().
|
||||
type CreateTracesToTracesFunc func(context.Context, CreateSettings, component.Config, consumer.Traces) (Traces, error)
|
||||
type CreateTracesToTracesFunc func(context.Context, Settings, component.Config, consumer.Traces) (Traces, error)
|
||||
|
||||
// CreateTracesToTraces implements Factory.CreateTracesToTraces().
|
||||
func (f CreateTracesToTracesFunc) CreateTracesToTraces(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Traces) (Traces, error) {
|
||||
if f == nil {
|
||||
|
|
@ -151,12 +156,12 @@ func (f CreateTracesToTracesFunc) CreateTracesToTraces(
|
|||
}
|
||||
|
||||
// CreateTracesToMetricsFunc is the equivalent of Factory.CreateTracesToMetrics().
|
||||
type CreateTracesToMetricsFunc func(context.Context, CreateSettings, component.Config, consumer.Metrics) (Traces, error)
|
||||
type CreateTracesToMetricsFunc func(context.Context, Settings, component.Config, consumer.Metrics) (Traces, error)
|
||||
|
||||
// CreateTracesToMetrics implements Factory.CreateTracesToMetrics().
|
||||
func (f CreateTracesToMetricsFunc) CreateTracesToMetrics(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Metrics,
|
||||
) (Traces, error) {
|
||||
|
|
@ -167,12 +172,12 @@ func (f CreateTracesToMetricsFunc) CreateTracesToMetrics(
|
|||
}
|
||||
|
||||
// CreateTracesToLogsFunc is the equivalent of Factory.CreateTracesToLogs().
|
||||
type CreateTracesToLogsFunc func(context.Context, CreateSettings, component.Config, consumer.Logs) (Traces, error)
|
||||
type CreateTracesToLogsFunc func(context.Context, Settings, component.Config, consumer.Logs) (Traces, error)
|
||||
|
||||
// CreateTracesToLogs implements Factory.CreateTracesToLogs().
|
||||
func (f CreateTracesToLogsFunc) CreateTracesToLogs(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Logs,
|
||||
) (Traces, error) {
|
||||
|
|
@ -183,12 +188,12 @@ func (f CreateTracesToLogsFunc) CreateTracesToLogs(
|
|||
}
|
||||
|
||||
// CreateMetricsToTracesFunc is the equivalent of Factory.CreateMetricsToTraces().
|
||||
type CreateMetricsToTracesFunc func(context.Context, CreateSettings, component.Config, consumer.Traces) (Metrics, error)
|
||||
type CreateMetricsToTracesFunc func(context.Context, Settings, component.Config, consumer.Traces) (Metrics, error)
|
||||
|
||||
// CreateMetricsToTraces implements Factory.CreateMetricsToTraces().
|
||||
func (f CreateMetricsToTracesFunc) CreateMetricsToTraces(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Traces,
|
||||
) (Metrics, error) {
|
||||
|
|
@ -199,12 +204,12 @@ func (f CreateMetricsToTracesFunc) CreateMetricsToTraces(
|
|||
}
|
||||
|
||||
// CreateMetricsToMetricsFunc is the equivalent of Factory.CreateMetricsToTraces().
|
||||
type CreateMetricsToMetricsFunc func(context.Context, CreateSettings, component.Config, consumer.Metrics) (Metrics, error)
|
||||
type CreateMetricsToMetricsFunc func(context.Context, Settings, component.Config, consumer.Metrics) (Metrics, error)
|
||||
|
||||
// CreateMetricsToMetrics implements Factory.CreateMetricsToTraces().
|
||||
func (f CreateMetricsToMetricsFunc) CreateMetricsToMetrics(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Metrics,
|
||||
) (Metrics, error) {
|
||||
|
|
@ -215,12 +220,12 @@ func (f CreateMetricsToMetricsFunc) CreateMetricsToMetrics(
|
|||
}
|
||||
|
||||
// CreateMetricsToLogsFunc is the equivalent of Factory.CreateMetricsToLogs().
|
||||
type CreateMetricsToLogsFunc func(context.Context, CreateSettings, component.Config, consumer.Logs) (Metrics, error)
|
||||
type CreateMetricsToLogsFunc func(context.Context, Settings, component.Config, consumer.Logs) (Metrics, error)
|
||||
|
||||
// CreateMetricsToLogs implements Factory.CreateMetricsToLogs().
|
||||
func (f CreateMetricsToLogsFunc) CreateMetricsToLogs(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Logs,
|
||||
) (Metrics, error) {
|
||||
|
|
@ -231,12 +236,12 @@ func (f CreateMetricsToLogsFunc) CreateMetricsToLogs(
|
|||
}
|
||||
|
||||
// CreateLogsToTracesFunc is the equivalent of Factory.CreateLogsToTraces().
|
||||
type CreateLogsToTracesFunc func(context.Context, CreateSettings, component.Config, consumer.Traces) (Logs, error)
|
||||
type CreateLogsToTracesFunc func(context.Context, Settings, component.Config, consumer.Traces) (Logs, error)
|
||||
|
||||
// CreateLogsToTraces implements Factory.CreateLogsToTraces().
|
||||
func (f CreateLogsToTracesFunc) CreateLogsToTraces(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Traces,
|
||||
) (Logs, error) {
|
||||
|
|
@ -247,12 +252,12 @@ func (f CreateLogsToTracesFunc) CreateLogsToTraces(
|
|||
}
|
||||
|
||||
// CreateLogsToMetricsFunc is the equivalent of Factory.CreateLogsToMetrics().
|
||||
type CreateLogsToMetricsFunc func(context.Context, CreateSettings, component.Config, consumer.Metrics) (Logs, error)
|
||||
type CreateLogsToMetricsFunc func(context.Context, Settings, component.Config, consumer.Metrics) (Logs, error)
|
||||
|
||||
// CreateLogsToMetrics implements Factory.CreateLogsToMetrics().
|
||||
func (f CreateLogsToMetricsFunc) CreateLogsToMetrics(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Metrics,
|
||||
) (Logs, error) {
|
||||
|
|
@ -263,12 +268,12 @@ func (f CreateLogsToMetricsFunc) CreateLogsToMetrics(
|
|||
}
|
||||
|
||||
// CreateLogsToLogsFunc is the equivalent of Factory.CreateLogsToLogs().
|
||||
type CreateLogsToLogsFunc func(context.Context, CreateSettings, component.Config, consumer.Logs) (Logs, error)
|
||||
type CreateLogsToLogsFunc func(context.Context, Settings, component.Config, consumer.Logs) (Logs, error)
|
||||
|
||||
// CreateLogsToLogs implements Factory.CreateLogsToLogs().
|
||||
func (f CreateLogsToLogsFunc) CreateLogsToLogs(
|
||||
ctx context.Context,
|
||||
set CreateSettings,
|
||||
set Settings,
|
||||
cfg component.Config,
|
||||
nextConsumer consumer.Logs,
|
||||
) (Logs, error) {
|
||||
|
|
@ -460,7 +465,7 @@ func NewBuilder(cfgs map[component.ID]component.Config, factories map[component.
|
|||
}
|
||||
|
||||
// CreateTracesToTraces creates a Traces connector based on the settings and config.
|
||||
func (b *Builder) CreateTracesToTraces(ctx context.Context, set CreateSettings, next consumer.Traces) (Traces, error) {
|
||||
func (b *Builder) CreateTracesToTraces(ctx context.Context, set Settings, next consumer.Traces) (Traces, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -479,7 +484,7 @@ func (b *Builder) CreateTracesToTraces(ctx context.Context, set CreateSettings,
|
|||
}
|
||||
|
||||
// CreateTracesToMetrics creates a Traces connector based on the settings and config.
|
||||
func (b *Builder) CreateTracesToMetrics(ctx context.Context, set CreateSettings, next consumer.Metrics) (Traces, error) {
|
||||
func (b *Builder) CreateTracesToMetrics(ctx context.Context, set Settings, next consumer.Metrics) (Traces, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -498,7 +503,7 @@ func (b *Builder) CreateTracesToMetrics(ctx context.Context, set CreateSettings,
|
|||
}
|
||||
|
||||
// CreateTracesToLogs creates a Traces connector based on the settings and config.
|
||||
func (b *Builder) CreateTracesToLogs(ctx context.Context, set CreateSettings, next consumer.Logs) (Traces, error) {
|
||||
func (b *Builder) CreateTracesToLogs(ctx context.Context, set Settings, next consumer.Logs) (Traces, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -517,7 +522,7 @@ func (b *Builder) CreateTracesToLogs(ctx context.Context, set CreateSettings, ne
|
|||
}
|
||||
|
||||
// CreateMetricsToTraces creates a Metrics connector based on the settings and config.
|
||||
func (b *Builder) CreateMetricsToTraces(ctx context.Context, set CreateSettings, next consumer.Traces) (Metrics, error) {
|
||||
func (b *Builder) CreateMetricsToTraces(ctx context.Context, set Settings, next consumer.Traces) (Metrics, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -536,7 +541,7 @@ func (b *Builder) CreateMetricsToTraces(ctx context.Context, set CreateSettings,
|
|||
}
|
||||
|
||||
// CreateMetricsToMetrics creates a Metrics connector based on the settings and config.
|
||||
func (b *Builder) CreateMetricsToMetrics(ctx context.Context, set CreateSettings, next consumer.Metrics) (Metrics, error) {
|
||||
func (b *Builder) CreateMetricsToMetrics(ctx context.Context, set Settings, next consumer.Metrics) (Metrics, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -555,7 +560,7 @@ func (b *Builder) CreateMetricsToMetrics(ctx context.Context, set CreateSettings
|
|||
}
|
||||
|
||||
// CreateMetricsToLogs creates a Metrics connector based on the settings and config.
|
||||
func (b *Builder) CreateMetricsToLogs(ctx context.Context, set CreateSettings, next consumer.Logs) (Metrics, error) {
|
||||
func (b *Builder) CreateMetricsToLogs(ctx context.Context, set Settings, next consumer.Logs) (Metrics, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -574,7 +579,7 @@ func (b *Builder) CreateMetricsToLogs(ctx context.Context, set CreateSettings, n
|
|||
}
|
||||
|
||||
// CreateLogsToTraces creates a Logs connector based on the settings and config.
|
||||
func (b *Builder) CreateLogsToTraces(ctx context.Context, set CreateSettings, next consumer.Traces) (Logs, error) {
|
||||
func (b *Builder) CreateLogsToTraces(ctx context.Context, set Settings, next consumer.Traces) (Logs, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -593,7 +598,7 @@ func (b *Builder) CreateLogsToTraces(ctx context.Context, set CreateSettings, ne
|
|||
}
|
||||
|
||||
// CreateLogsToMetrics creates a Logs connector based on the settings and config.
|
||||
func (b *Builder) CreateLogsToMetrics(ctx context.Context, set CreateSettings, next consumer.Metrics) (Logs, error) {
|
||||
func (b *Builder) CreateLogsToMetrics(ctx context.Context, set Settings, next consumer.Metrics) (Logs, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
@ -612,7 +617,7 @@ func (b *Builder) CreateLogsToMetrics(ctx context.Context, set CreateSettings, n
|
|||
}
|
||||
|
||||
// CreateLogsToLogs creates a Logs connector based on the settings and config.
|
||||
func (b *Builder) CreateLogsToLogs(ctx context.Context, set CreateSettings, next consumer.Logs) (Logs, error) {
|
||||
func (b *Builder) CreateLogsToLogs(ctx context.Context, set Settings, next consumer.Logs) (Logs, error) {
|
||||
if next == nil {
|
||||
return nil, errNilNextConsumer
|
||||
}
|
||||
|
|
|
|||
|
|
@ -28,25 +28,25 @@ func TestNewFactoryNoOptions(t *testing.T) {
|
|||
assert.EqualValues(t, testType, factory.Type())
|
||||
assert.EqualValues(t, &defaultCfg, factory.CreateDefaultConfig())
|
||||
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeTraces, component.DataTypeTraces))
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeTraces, component.DataTypeMetrics))
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeTraces, component.DataTypeLogs))
|
||||
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeMetrics, component.DataTypeTraces))
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeMetrics, component.DataTypeMetrics))
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeMetrics, component.DataTypeLogs))
|
||||
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeLogs, component.DataTypeTraces))
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeLogs, component.DataTypeMetrics))
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeLogs, component.DataTypeLogs))
|
||||
}
|
||||
|
||||
|
|
@ -60,30 +60,30 @@ func TestNewFactoryWithSameTypes(t *testing.T) {
|
|||
assert.EqualValues(t, &defaultCfg, factory.CreateDefaultConfig())
|
||||
|
||||
assert.Equal(t, component.StabilityLevelAlpha, factory.TracesToTracesStability())
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelBeta, factory.MetricsToMetricsStability())
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelUnmaintained, factory.LogsToLogsStability())
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeTraces, component.DataTypeMetrics))
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeTraces, component.DataTypeLogs))
|
||||
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeMetrics, component.DataTypeTraces))
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeMetrics, component.DataTypeLogs))
|
||||
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeLogs, component.DataTypeTraces))
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeLogs, component.DataTypeMetrics))
|
||||
}
|
||||
|
||||
|
|
@ -99,35 +99,35 @@ func TestNewFactoryWithTranslateTypes(t *testing.T) {
|
|||
assert.EqualValues(t, testType, factory.Type())
|
||||
assert.EqualValues(t, &defaultCfg, factory.CreateDefaultConfig())
|
||||
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeTraces, component.DataTypeTraces))
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeMetrics, component.DataTypeMetrics))
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.Equal(t, err, errDataTypes(testID, component.DataTypeLogs, component.DataTypeLogs))
|
||||
|
||||
assert.Equal(t, component.StabilityLevelDevelopment, factory.TracesToMetricsStability())
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelAlpha, factory.TracesToLogsStability())
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelBeta, factory.MetricsToTracesStability())
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelStable, factory.MetricsToLogsStability())
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelDeprecated, factory.LogsToTracesStability())
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelUnmaintained, factory.LogsToMetricsStability())
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), CreateSettings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), Settings{ID: testID}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
}
|
||||
|
||||
|
|
@ -147,33 +147,33 @@ func TestNewFactoryWithAllTypes(t *testing.T) {
|
|||
assert.EqualValues(t, &defaultCfg, factory.CreateDefaultConfig())
|
||||
|
||||
assert.Equal(t, component.StabilityLevelAlpha, factory.TracesToTracesStability())
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err := factory.CreateTracesToTraces(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, component.StabilityLevelDevelopment, factory.TracesToMetricsStability())
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToMetrics(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, component.StabilityLevelAlpha, factory.TracesToLogsStability())
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateTracesToLogs(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelBeta, factory.MetricsToTracesStability())
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToTraces(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, component.StabilityLevelBeta, factory.MetricsToMetricsStability())
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToMetrics(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, component.StabilityLevelStable, factory.MetricsToLogsStability())
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateMetricsToLogs(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
|
||||
assert.Equal(t, component.StabilityLevelDeprecated, factory.LogsToTracesStability())
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToTraces(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, component.StabilityLevelUnmaintained, factory.LogsToMetricsStability())
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToMetrics(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, component.StabilityLevelUnmaintained, factory.LogsToLogsStability())
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), CreateSettings{}, &defaultCfg, consumertest.NewNop())
|
||||
_, err = factory.CreateLogsToLogs(context.Background(), Settings{}, &defaultCfg, consumertest.NewNop())
|
||||
assert.NoError(t, err)
|
||||
}
|
||||
|
||||
|
|
@ -467,38 +467,38 @@ type nopConnector struct {
|
|||
consumertest.Consumer
|
||||
}
|
||||
|
||||
func createTracesToTraces(context.Context, CreateSettings, component.Config, consumer.Traces) (Traces, error) {
|
||||
func createTracesToTraces(context.Context, Settings, component.Config, consumer.Traces) (Traces, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
func createTracesToMetrics(context.Context, CreateSettings, component.Config, consumer.Metrics) (Traces, error) {
|
||||
func createTracesToMetrics(context.Context, Settings, component.Config, consumer.Metrics) (Traces, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
func createTracesToLogs(context.Context, CreateSettings, component.Config, consumer.Logs) (Traces, error) {
|
||||
func createTracesToLogs(context.Context, Settings, component.Config, consumer.Logs) (Traces, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
|
||||
func createMetricsToTraces(context.Context, CreateSettings, component.Config, consumer.Traces) (Metrics, error) {
|
||||
func createMetricsToTraces(context.Context, Settings, component.Config, consumer.Traces) (Metrics, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
func createMetricsToMetrics(context.Context, CreateSettings, component.Config, consumer.Metrics) (Metrics, error) {
|
||||
func createMetricsToMetrics(context.Context, Settings, component.Config, consumer.Metrics) (Metrics, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
func createMetricsToLogs(context.Context, CreateSettings, component.Config, consumer.Logs) (Metrics, error) {
|
||||
func createMetricsToLogs(context.Context, Settings, component.Config, consumer.Logs) (Metrics, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
|
||||
func createLogsToTraces(context.Context, CreateSettings, component.Config, consumer.Traces) (Logs, error) {
|
||||
func createLogsToTraces(context.Context, Settings, component.Config, consumer.Traces) (Logs, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
func createLogsToMetrics(context.Context, CreateSettings, component.Config, consumer.Metrics) (Logs, error) {
|
||||
func createLogsToMetrics(context.Context, Settings, component.Config, consumer.Metrics) (Logs, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
func createLogsToLogs(context.Context, CreateSettings, component.Config, consumer.Logs) (Logs, error) {
|
||||
func createLogsToLogs(context.Context, Settings, component.Config, consumer.Logs) (Logs, error) {
|
||||
return nopInstance, nil
|
||||
}
|
||||
|
||||
func createSettings(id component.ID) CreateSettings {
|
||||
return CreateSettings{
|
||||
func createSettings(id component.ID) Settings {
|
||||
return Settings{
|
||||
ID: id,
|
||||
TelemetrySettings: componenttest.NewNopTelemetrySettings(),
|
||||
BuildInfo: component.NewDefaultBuildInfo(),
|
||||
|
|
|
|||
|
|
@ -18,8 +18,15 @@ import (
|
|||
var nopType = component.MustNewType("nop")
|
||||
|
||||
// NewNopCreateSettings returns a new nop settings for Create* functions.
|
||||
func NewNopCreateSettings() connector.CreateSettings {
|
||||
return connector.CreateSettings{
|
||||
//
|
||||
// Deprecated: [v0.103.0] Use connectortest.NewNopSettings instead.
|
||||
func NewNopCreateSettings() connector.Settings {
|
||||
return NewNopSettings()
|
||||
}
|
||||
|
||||
// NewNopSettings returns a new nop settings for Create* functions.
|
||||
func NewNopSettings() connector.Settings {
|
||||
return connector.Settings{
|
||||
ID: component.NewIDWithName(nopType, uuid.NewString()),
|
||||
TelemetrySettings: componenttest.NewNopTelemetrySettings(),
|
||||
BuildInfo: component.NewDefaultBuildInfo(),
|
||||
|
|
@ -47,39 +54,39 @@ func NewNopFactory() connector.Factory {
|
|||
)
|
||||
}
|
||||
|
||||
func createTracesToTracesConnector(context.Context, connector.CreateSettings, component.Config, consumer.Traces) (connector.Traces, error) {
|
||||
func createTracesToTracesConnector(context.Context, connector.Settings, component.Config, consumer.Traces) (connector.Traces, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createTracesToMetricsConnector(context.Context, connector.CreateSettings, component.Config, consumer.Metrics) (connector.Traces, error) {
|
||||
func createTracesToMetricsConnector(context.Context, connector.Settings, component.Config, consumer.Metrics) (connector.Traces, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createTracesToLogsConnector(context.Context, connector.CreateSettings, component.Config, consumer.Logs) (connector.Traces, error) {
|
||||
func createTracesToLogsConnector(context.Context, connector.Settings, component.Config, consumer.Logs) (connector.Traces, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createMetricsToTracesConnector(context.Context, connector.CreateSettings, component.Config, consumer.Traces) (connector.Metrics, error) {
|
||||
func createMetricsToTracesConnector(context.Context, connector.Settings, component.Config, consumer.Traces) (connector.Metrics, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createMetricsToMetricsConnector(context.Context, connector.CreateSettings, component.Config, consumer.Metrics) (connector.Metrics, error) {
|
||||
func createMetricsToMetricsConnector(context.Context, connector.Settings, component.Config, consumer.Metrics) (connector.Metrics, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createMetricsToLogsConnector(context.Context, connector.CreateSettings, component.Config, consumer.Logs) (connector.Metrics, error) {
|
||||
func createMetricsToLogsConnector(context.Context, connector.Settings, component.Config, consumer.Logs) (connector.Metrics, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createLogsToTracesConnector(context.Context, connector.CreateSettings, component.Config, consumer.Traces) (connector.Logs, error) {
|
||||
func createLogsToTracesConnector(context.Context, connector.Settings, component.Config, consumer.Traces) (connector.Logs, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createLogsToMetricsConnector(context.Context, connector.CreateSettings, component.Config, consumer.Metrics) (connector.Logs, error) {
|
||||
func createLogsToMetricsConnector(context.Context, connector.Settings, component.Config, consumer.Metrics) (connector.Logs, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
func createLogsToLogsConnector(context.Context, connector.CreateSettings, component.Config, consumer.Logs) (connector.Logs, error) {
|
||||
func createLogsToLogsConnector(context.Context, connector.Settings, component.Config, consumer.Logs) (connector.Logs, error) {
|
||||
return &nopConnector{Consumer: consumertest.NewNop()}, nil
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -25,55 +25,55 @@ func TestNewNopConnectorFactory(t *testing.T) {
|
|||
cfg := factory.CreateDefaultConfig()
|
||||
assert.Equal(t, &nopConfig{}, cfg)
|
||||
|
||||
tracesToTraces, err := factory.CreateTracesToTraces(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
tracesToTraces, err := factory.CreateTracesToTraces(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, tracesToTraces.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, tracesToTraces.ConsumeTraces(context.Background(), ptrace.NewTraces()))
|
||||
assert.NoError(t, tracesToTraces.Shutdown(context.Background()))
|
||||
|
||||
tracesToMetrics, err := factory.CreateTracesToMetrics(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
tracesToMetrics, err := factory.CreateTracesToMetrics(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, tracesToMetrics.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, tracesToMetrics.ConsumeTraces(context.Background(), ptrace.NewTraces()))
|
||||
assert.NoError(t, tracesToMetrics.Shutdown(context.Background()))
|
||||
|
||||
tracesToLogs, err := factory.CreateTracesToLogs(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
tracesToLogs, err := factory.CreateTracesToLogs(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, tracesToLogs.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, tracesToLogs.ConsumeTraces(context.Background(), ptrace.NewTraces()))
|
||||
assert.NoError(t, tracesToLogs.Shutdown(context.Background()))
|
||||
|
||||
metricsToTraces, err := factory.CreateMetricsToTraces(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
metricsToTraces, err := factory.CreateMetricsToTraces(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, metricsToTraces.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, metricsToTraces.ConsumeMetrics(context.Background(), pmetric.NewMetrics()))
|
||||
assert.NoError(t, metricsToTraces.Shutdown(context.Background()))
|
||||
|
||||
metricsToMetrics, err := factory.CreateMetricsToMetrics(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
metricsToMetrics, err := factory.CreateMetricsToMetrics(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, metricsToMetrics.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, metricsToMetrics.ConsumeMetrics(context.Background(), pmetric.NewMetrics()))
|
||||
assert.NoError(t, metricsToMetrics.Shutdown(context.Background()))
|
||||
|
||||
metricsToLogs, err := factory.CreateMetricsToLogs(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
metricsToLogs, err := factory.CreateMetricsToLogs(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, metricsToLogs.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, metricsToLogs.ConsumeMetrics(context.Background(), pmetric.NewMetrics()))
|
||||
assert.NoError(t, metricsToLogs.Shutdown(context.Background()))
|
||||
|
||||
logsToTraces, err := factory.CreateLogsToTraces(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
logsToTraces, err := factory.CreateLogsToTraces(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, logsToTraces.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, logsToTraces.ConsumeLogs(context.Background(), plog.NewLogs()))
|
||||
assert.NoError(t, logsToTraces.Shutdown(context.Background()))
|
||||
|
||||
logsToMetrics, err := factory.CreateLogsToMetrics(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
logsToMetrics, err := factory.CreateLogsToMetrics(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, logsToMetrics.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, logsToMetrics.ConsumeLogs(context.Background(), plog.NewLogs()))
|
||||
assert.NoError(t, logsToMetrics.Shutdown(context.Background()))
|
||||
|
||||
logsToLogs, err := factory.CreateLogsToLogs(context.Background(), NewNopCreateSettings(), cfg, consumertest.NewNop())
|
||||
logsToLogs, err := factory.CreateLogsToLogs(context.Background(), NewNopSettings(), cfg, consumertest.NewNop())
|
||||
require.NoError(t, err)
|
||||
assert.NoError(t, logsToLogs.Start(context.Background(), componenttest.NewNopHost()))
|
||||
assert.NoError(t, logsToLogs.ConsumeLogs(context.Background(), plog.NewLogs()))
|
||||
|
|
@ -86,7 +86,7 @@ func TestNewNopBuilder(t *testing.T) {
|
|||
|
||||
factory := NewNopFactory()
|
||||
cfg := factory.CreateDefaultConfig()
|
||||
set := NewNopCreateSettings()
|
||||
set := NewNopSettings()
|
||||
set.ID = component.NewIDWithName(nopType, "conn")
|
||||
|
||||
tracesToTraces, err := factory.CreateTracesToTraces(context.Background(), set, cfg, consumertest.NewNop())
|
||||
|
|
|
|||
|
|
@ -33,7 +33,7 @@ func createDefaultConfig() component.Config {
|
|||
// createTracesToTraces creates a trace receiver based on provided config.
|
||||
func createTracesToTraces(
|
||||
_ context.Context,
|
||||
_ connector.CreateSettings,
|
||||
_ connector.Settings,
|
||||
_ component.Config,
|
||||
nextConsumer consumer.Traces,
|
||||
) (connector.Traces, error) {
|
||||
|
|
@ -43,7 +43,7 @@ func createTracesToTraces(
|
|||
// createMetricsToMetrics creates a metrics receiver based on provided config.
|
||||
func createMetricsToMetrics(
|
||||
_ context.Context,
|
||||
_ connector.CreateSettings,
|
||||
_ connector.Settings,
|
||||
_ component.Config,
|
||||
nextConsumer consumer.Metrics,
|
||||
) (connector.Metrics, error) {
|
||||
|
|
@ -53,7 +53,7 @@ func createMetricsToMetrics(
|
|||
// createLogsToLogs creates a log receiver based on provided config.
|
||||
func createLogsToLogs(
|
||||
_ context.Context,
|
||||
_ connector.CreateSettings,
|
||||
_ connector.Settings,
|
||||
_ component.Config,
|
||||
nextConsumer consumer.Logs,
|
||||
) (connector.Logs, error) {
|
||||
|
|
|
|||
|
|
@ -22,7 +22,7 @@ func TestForward(t *testing.T) {
|
|||
assert.Equal(t, &Config{}, cfg)
|
||||
|
||||
ctx := context.Background()
|
||||
set := connectortest.NewNopCreateSettings()
|
||||
set := connectortest.NewNopSettings()
|
||||
host := componenttest.NewNopHost()
|
||||
|
||||
tracesSink := new(consumertest.TracesSink)
|
||||
|
|
|
|||
|
|
@ -30,12 +30,12 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
|
||||
tests := []struct {
|
||||
name string
|
||||
createFn func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error)
|
||||
createFn func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error)
|
||||
}{
|
||||
|
||||
{
|
||||
name: "logs_to_logs",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewLogsRouter(map[component.ID]consumer.Logs{component.NewID(component.DataTypeLogs): consumertest.NewNop()})
|
||||
return factory.CreateLogsToLogs(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -43,7 +43,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
|
||||
{
|
||||
name: "metrics_to_metrics",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewMetricsRouter(map[component.ID]consumer.Metrics{component.NewID(component.DataTypeMetrics): consumertest.NewNop()})
|
||||
return factory.CreateMetricsToMetrics(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -51,7 +51,7 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
|
||||
{
|
||||
name: "traces_to_traces",
|
||||
createFn: func(ctx context.Context, set connector.CreateSettings, cfg component.Config) (component.Component, error) {
|
||||
createFn: func(ctx context.Context, set connector.Settings, cfg component.Config) (component.Component, error) {
|
||||
router := connector.NewTracesRouter(map[component.ID]consumer.Traces{component.NewID(component.DataTypeTraces): consumertest.NewNop()})
|
||||
return factory.CreateTracesToTraces(ctx, set, cfg, router)
|
||||
},
|
||||
|
|
@ -67,19 +67,19 @@ func TestComponentLifecycle(t *testing.T) {
|
|||
|
||||
for _, test := range tests {
|
||||
t.Run(test.name+"-shutdown", func(t *testing.T) {
|
||||
c, err := test.createFn(context.Background(), connectortest.NewNopCreateSettings(), cfg)
|
||||
c, err := test.createFn(context.Background(), connectortest.NewNopSettings(), cfg)
|
||||
require.NoError(t, err)
|
||||
err = c.Shutdown(context.Background())
|
||||
require.NoError(t, err)
|
||||
})
|
||||
t.Run(test.name+"-lifecycle", func(t *testing.T) {
|
||||
firstConnector, err := test.createFn(context.Background(), connectortest.NewNopCreateSettings(), cfg)
|
||||
firstConnector, err := test.createFn(context.Background(), connectortest.NewNopSettings(), cfg)
|
||||
require.NoError(t, err)
|
||||
host := componenttest.NewNopHost()
|
||||
require.NoError(t, err)
|
||||
require.NoError(t, firstConnector.Start(context.Background(), host))
|
||||
require.NoError(t, firstConnector.Shutdown(context.Background()))
|
||||
secondConnector, err := test.createFn(context.Background(), connectortest.NewNopCreateSettings(), cfg)
|
||||
secondConnector, err := test.createFn(context.Background(), connectortest.NewNopSettings(), cfg)
|
||||
require.NoError(t, err)
|
||||
require.NoError(t, secondConnector.Start(context.Background(), host))
|
||||
require.NoError(t, secondConnector.Shutdown(context.Background()))
|
||||
|
|
|
|||
|
|
@ -2502,33 +2502,33 @@ func newErrConnectorFactory() connector.Factory {
|
|||
return connector.NewFactory(component.MustNewType("err"), func() component.Config {
|
||||
return &struct{}{}
|
||||
},
|
||||
connector.WithTracesToTraces(func(context.Context, connector.CreateSettings, component.Config, consumer.Traces) (connector.Traces, error) {
|
||||
connector.WithTracesToTraces(func(context.Context, connector.Settings, component.Config, consumer.Traces) (connector.Traces, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
connector.WithTracesToMetrics(func(context.Context, connector.CreateSettings, component.Config, consumer.Metrics) (connector.Traces, error) {
|
||||
connector.WithTracesToMetrics(func(context.Context, connector.Settings, component.Config, consumer.Metrics) (connector.Traces, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
connector.WithTracesToLogs(func(context.Context, connector.CreateSettings, component.Config, consumer.Logs) (connector.Traces, error) {
|
||||
connector.WithTracesToLogs(func(context.Context, connector.Settings, component.Config, consumer.Logs) (connector.Traces, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
|
||||
connector.WithMetricsToTraces(func(context.Context, connector.CreateSettings, component.Config, consumer.Traces) (connector.Metrics, error) {
|
||||
connector.WithMetricsToTraces(func(context.Context, connector.Settings, component.Config, consumer.Traces) (connector.Metrics, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
connector.WithMetricsToMetrics(func(context.Context, connector.CreateSettings, component.Config, consumer.Metrics) (connector.Metrics, error) {
|
||||
connector.WithMetricsToMetrics(func(context.Context, connector.Settings, component.Config, consumer.Metrics) (connector.Metrics, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
connector.WithMetricsToLogs(func(context.Context, connector.CreateSettings, component.Config, consumer.Logs) (connector.Metrics, error) {
|
||||
connector.WithMetricsToLogs(func(context.Context, connector.Settings, component.Config, consumer.Logs) (connector.Metrics, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
|
||||
connector.WithLogsToTraces(func(context.Context, connector.CreateSettings, component.Config, consumer.Traces) (connector.Logs, error) {
|
||||
connector.WithLogsToTraces(func(context.Context, connector.Settings, component.Config, consumer.Traces) (connector.Logs, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
connector.WithLogsToMetrics(func(context.Context, connector.CreateSettings, component.Config, consumer.Metrics) (connector.Logs, error) {
|
||||
connector.WithLogsToMetrics(func(context.Context, connector.Settings, component.Config, consumer.Metrics) (connector.Logs, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
connector.WithLogsToLogs(func(context.Context, connector.CreateSettings, component.Config, consumer.Logs) (connector.Logs, error) {
|
||||
connector.WithLogsToLogs(func(context.Context, connector.Settings, component.Config, consumer.Logs) (connector.Logs, error) {
|
||||
return &errComponent{}, nil
|
||||
}, component.StabilityLevelUnmaintained),
|
||||
)
|
||||
|
|
|
|||
|
|
@ -233,7 +233,7 @@ func (n *connectorNode) buildComponent(
|
|||
builder *connector.Builder,
|
||||
nexts []baseConsumer,
|
||||
) error {
|
||||
set := connector.CreateSettings{ID: n.componentID, TelemetrySettings: tel, BuildInfo: info}
|
||||
set := connector.Settings{ID: n.componentID, TelemetrySettings: tel, BuildInfo: info}
|
||||
set.TelemetrySettings.Logger = components.ConnectorLogger(set.TelemetrySettings.Logger, n.componentID, n.exprPipelineType, n.rcvrPipelineType)
|
||||
|
||||
switch n.rcvrPipelineType {
|
||||
|
|
|
|||
|
|
@ -47,14 +47,14 @@ func createExampleConnectorDefaultConfig() component.Config {
|
|||
return &struct{}{}
|
||||
}
|
||||
|
||||
func createExampleTracesToTraces(_ context.Context, set connector.CreateSettings, _ component.Config, traces consumer.Traces) (connector.Traces, error) {
|
||||
func createExampleTracesToTraces(_ context.Context, set connector.Settings, _ component.Config, traces consumer.Traces) (connector.Traces, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeTracesFunc: traces.ConsumeTraces,
|
||||
mutatesData: set.ID.Name() == "mutate",
|
||||
}, nil
|
||||
}
|
||||
|
||||
func createExampleTracesToMetrics(_ context.Context, set connector.CreateSettings, _ component.Config, metrics consumer.Metrics) (connector.Traces, error) {
|
||||
func createExampleTracesToMetrics(_ context.Context, set connector.Settings, _ component.Config, metrics consumer.Metrics) (connector.Traces, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeTracesFunc: func(ctx context.Context, td ptrace.Traces) error {
|
||||
return metrics.ConsumeMetrics(ctx, testdata.GenerateMetrics(td.SpanCount()))
|
||||
|
|
@ -63,7 +63,7 @@ func createExampleTracesToMetrics(_ context.Context, set connector.CreateSetting
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleTracesToLogs(_ context.Context, set connector.CreateSettings, _ component.Config, logs consumer.Logs) (connector.Traces, error) {
|
||||
func createExampleTracesToLogs(_ context.Context, set connector.Settings, _ component.Config, logs consumer.Logs) (connector.Traces, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeTracesFunc: func(ctx context.Context, td ptrace.Traces) error {
|
||||
return logs.ConsumeLogs(ctx, testdata.GenerateLogs(td.SpanCount()))
|
||||
|
|
@ -72,7 +72,7 @@ func createExampleTracesToLogs(_ context.Context, set connector.CreateSettings,
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleMetricsToTraces(_ context.Context, set connector.CreateSettings, _ component.Config, traces consumer.Traces) (connector.Metrics, error) {
|
||||
func createExampleMetricsToTraces(_ context.Context, set connector.Settings, _ component.Config, traces consumer.Traces) (connector.Metrics, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeMetricsFunc: func(ctx context.Context, md pmetric.Metrics) error {
|
||||
return traces.ConsumeTraces(ctx, testdata.GenerateTraces(md.MetricCount()))
|
||||
|
|
@ -81,14 +81,14 @@ func createExampleMetricsToTraces(_ context.Context, set connector.CreateSetting
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleMetricsToMetrics(_ context.Context, set connector.CreateSettings, _ component.Config, metrics consumer.Metrics) (connector.Metrics, error) {
|
||||
func createExampleMetricsToMetrics(_ context.Context, set connector.Settings, _ component.Config, metrics consumer.Metrics) (connector.Metrics, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeMetricsFunc: metrics.ConsumeMetrics,
|
||||
mutatesData: set.ID.Name() == "mutate",
|
||||
}, nil
|
||||
}
|
||||
|
||||
func createExampleMetricsToLogs(_ context.Context, set connector.CreateSettings, _ component.Config, logs consumer.Logs) (connector.Metrics, error) {
|
||||
func createExampleMetricsToLogs(_ context.Context, set connector.Settings, _ component.Config, logs consumer.Logs) (connector.Metrics, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeMetricsFunc: func(ctx context.Context, md pmetric.Metrics) error {
|
||||
return logs.ConsumeLogs(ctx, testdata.GenerateLogs(md.MetricCount()))
|
||||
|
|
@ -97,7 +97,7 @@ func createExampleMetricsToLogs(_ context.Context, set connector.CreateSettings,
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleLogsToTraces(_ context.Context, set connector.CreateSettings, _ component.Config, traces consumer.Traces) (connector.Logs, error) {
|
||||
func createExampleLogsToTraces(_ context.Context, set connector.Settings, _ component.Config, traces consumer.Traces) (connector.Logs, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeLogsFunc: func(ctx context.Context, ld plog.Logs) error {
|
||||
return traces.ConsumeTraces(ctx, testdata.GenerateTraces(ld.LogRecordCount()))
|
||||
|
|
@ -106,7 +106,7 @@ func createExampleLogsToTraces(_ context.Context, set connector.CreateSettings,
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleLogsToMetrics(_ context.Context, set connector.CreateSettings, _ component.Config, metrics consumer.Metrics) (connector.Logs, error) {
|
||||
func createExampleLogsToMetrics(_ context.Context, set connector.Settings, _ component.Config, metrics consumer.Metrics) (connector.Logs, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeLogsFunc: func(ctx context.Context, ld plog.Logs) error {
|
||||
return metrics.ConsumeMetrics(ctx, testdata.GenerateMetrics(ld.LogRecordCount()))
|
||||
|
|
@ -115,7 +115,7 @@ func createExampleLogsToMetrics(_ context.Context, set connector.CreateSettings,
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleLogsToLogs(_ context.Context, set connector.CreateSettings, _ component.Config, logs consumer.Logs) (connector.Logs, error) {
|
||||
func createExampleLogsToLogs(_ context.Context, set connector.Settings, _ component.Config, logs consumer.Logs) (connector.Logs, error) {
|
||||
return &ExampleConnector{
|
||||
ConsumeLogsFunc: logs.ConsumeLogs,
|
||||
mutatesData: set.ID.Name() == "mutate",
|
||||
|
|
|
|||
|
|
@ -40,7 +40,7 @@ func createExampleRouterDefaultConfig() component.Config {
|
|||
return &ExampleRouterConfig{}
|
||||
}
|
||||
|
||||
func createExampleTracesRouter(_ context.Context, _ connector.CreateSettings, cfg component.Config, traces consumer.Traces) (connector.Traces, error) {
|
||||
func createExampleTracesRouter(_ context.Context, _ connector.Settings, cfg component.Config, traces consumer.Traces) (connector.Traces, error) {
|
||||
c := cfg.(ExampleRouterConfig)
|
||||
r := traces.(connector.TracesRouterAndConsumer)
|
||||
left, _ := r.Consumer(c.Traces.Left)
|
||||
|
|
@ -51,7 +51,7 @@ func createExampleTracesRouter(_ context.Context, _ connector.CreateSettings, cf
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleMetricsRouter(_ context.Context, _ connector.CreateSettings, cfg component.Config, metrics consumer.Metrics) (connector.Metrics, error) {
|
||||
func createExampleMetricsRouter(_ context.Context, _ connector.Settings, cfg component.Config, metrics consumer.Metrics) (connector.Metrics, error) {
|
||||
c := cfg.(ExampleRouterConfig)
|
||||
r := metrics.(connector.MetricsRouterAndConsumer)
|
||||
left, _ := r.Consumer(c.Metrics.Left)
|
||||
|
|
@ -62,7 +62,7 @@ func createExampleMetricsRouter(_ context.Context, _ connector.CreateSettings, c
|
|||
}, nil
|
||||
}
|
||||
|
||||
func createExampleLogsRouter(_ context.Context, _ connector.CreateSettings, cfg component.Config, logs consumer.Logs) (connector.Logs, error) {
|
||||
func createExampleLogsRouter(_ context.Context, _ connector.Settings, cfg component.Config, logs consumer.Logs) (connector.Logs, error) {
|
||||
c := cfg.(ExampleRouterConfig)
|
||||
r := logs.(connector.LogsRouterAndConsumer)
|
||||
left, _ := r.Consumer(c.Logs.Left)
|
||||
|
|
|
|||
|
|
@ -48,7 +48,7 @@ func TestTracesRouter(t *testing.T) {
|
|||
|
||||
cfg := ExampleRouterConfig{Traces: &LeftRightConfig{Left: leftID, Right: rightID}}
|
||||
tr, err := ExampleRouterFactory.CreateTracesToTraces(
|
||||
context.Background(), connectortest.NewNopCreateSettings(), cfg, router)
|
||||
context.Background(), connectortest.NewNopSettings(), cfg, router)
|
||||
assert.NoError(t, err)
|
||||
assert.False(t, tr.Capabilities().MutatesData)
|
||||
|
||||
|
|
@ -87,7 +87,7 @@ func TestMetricsRouter(t *testing.T) {
|
|||
|
||||
cfg := ExampleRouterConfig{Metrics: &LeftRightConfig{Left: leftID, Right: rightID}}
|
||||
mr, err := ExampleRouterFactory.CreateMetricsToMetrics(
|
||||
context.Background(), connectortest.NewNopCreateSettings(), cfg, router)
|
||||
context.Background(), connectortest.NewNopSettings(), cfg, router)
|
||||
assert.NoError(t, err)
|
||||
assert.False(t, mr.Capabilities().MutatesData)
|
||||
|
||||
|
|
@ -126,7 +126,7 @@ func TestLogsRouter(t *testing.T) {
|
|||
|
||||
cfg := ExampleRouterConfig{Logs: &LeftRightConfig{Left: leftID, Right: rightID}}
|
||||
lr, err := ExampleRouterFactory.CreateLogsToLogs(
|
||||
context.Background(), connectortest.NewNopCreateSettings(), cfg, router)
|
||||
context.Background(), connectortest.NewNopSettings(), cfg, router)
|
||||
assert.NoError(t, err)
|
||||
assert.False(t, lr.Capabilities().MutatesData)
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue