Skip to content

Commit 73e1f46

Browse files
aphralGaphralG
committed
Merge branch 'main' into fix-failing-to-find-master-process-in-debug
2 parents 1e58331 + a4918b3 commit 73e1f46

File tree

62 files changed

+1066
-1368
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

62 files changed

+1066
-1368
lines changed

‎.golangci.yml‎

Lines changed: 578 additions & 814 deletions
Large diffs are not rendered by default.

‎Makefile.packaging‎

Lines changed: 11 additions & 90 deletions
Original file line numberDiff line numberDiff line change
@@ -9,23 +9,18 @@ AZURE_PACKAGES_DIR := ./build/azure/packages
99
BINARY_PATH := $(BUILD_DIR)/$(BINARY_NAME)
1010
GPG_PUBLIC_KEY := .key
1111
PACKAGE_BUILD ?= 1
12-
PACKAGE_VERSION := $(shell echo ${VERSION} | tr -d 'v')
12+
PACKAGE_VERSION := $(shell git describe --match "v[0-9]*" --abbrev=0 --tags)
1313
TARBALL_NAME := $(PACKAGE_PREFIX).tar.gz
1414

15-
DEB_DISTROS ?= ubuntu-noble-24.04 ubuntu-jammy-22.04 ubuntu-focal-20.04 debian-bookworm-12 debian-bullseye-11
15+
DEB_DISTROS ?= ubuntu-plucky-25.04 ubuntu-noble-24.04 ubuntu-jammy-22.04 ubuntu-focal-20.04 debian-bookworm-12 debian-bullseye-11
1616
DEB_ARCHS ?= arm64 amd64
17-
RPM_DISTROS ?= oraclelinux-8-x86_64 oraclelinux-9-x86_64 suse-15-x86_64
17+
RPM_DISTROS ?= suse-15-x86_64
1818
RPM_ARCH := x86_64
19-
REDHAT_VERSIONS ?= redhatenterprise-8 redhatenterprise-9
19+
REDHAT_VERSIONS ?= redhatenterprise-8 redhatenterprise-9 redhatenterprise-10
2020
REDHAT_ARCHS ?= aarch64 x86_64
21-
ROCKY_VERSIONS ?= rocky-8 rocky-9
22-
ROCKY_ARCHS ?= aarch64 x86_64
23-
FREEBSD_DISTROS ?= "FreeBSD:13:amd64" "FreeBSD:14:amd64"
2421
APK_VERSIONS ?= 3.18 3.19 3.20 3.21 3.22
2522
APK_ARCHS ?= aarch64 x86_64
2623
APK_REVISION ?= 1
27-
ALMA_VERSIONS ?= almalinux-8 almalinux-9
28-
ALMA_ARCHS ?= aarch64 x86_64
2924
AMAZON_VERSIONS ?= amazon-2 amazon-2023
3025
AMAZON_ARCHS ?= aarch64 x86_64
3126

@@ -35,55 +30,38 @@ AMAZON_ARCHS ?= aarch64 x86_64
3530
.PHONY: clean-packages
3631
clean-packages:
3732
rm -rf $(PACKAGES_DIR)
38-
rm -rf $(GITHUB_PACKAGES_DIR)
39-
rm -rf $(AZURE_PACKAGES_DIR)
4033

4134
$(PACKAGES_DIR):
42-
@mkdir -p $(PACKAGES_DIR)/deb && mkdir -p $(PACKAGES_DIR)/rpm && mkdir -p $(PACKAGES_DIR)/apk && mkdir -p $(PACKAGES_DIR)/txz
43-
44-
$(GITHUB_PACKAGES_DIR):
45-
@mkdir -p $(GITHUB_PACKAGES_DIR)
46-
47-
$(AZURE_PACKAGES_DIR):
48-
@mkdir -p $(AZURE_PACKAGES_DIR)
35+
@mkdir -p $(PACKAGES_DIR)/deb && mkdir -p $(PACKAGES_DIR)/rpm && mkdir -p $(PACKAGES_DIR)/apk
4936

5037
.PHONY: package
51-
package: gpg-key $(PACKAGES_DIR) $(GITHUB_PACKAGES_DIR) $(AZURE_PACKAGES_DIR) #### Create final packages for all supported distros
38+
package: $(PACKAGES_DIR) #### Create final packages for all supported distros
5239
# Create deb packages
53-
5440
@for arch in $(DEB_ARCHS); do \
5541
GOWORK=off CGO_ENABLED=0 GOARCH=$${arch} GOOS=linux go build -pgo=auto -ldflags=${LDFLAGS} -o $(BINARY_PATH) $(PROJECT_DIR)/$(PROJECT_FILE); \
5642
for distro in $(DEB_DISTROS); do \
5743
deb_codename=`echo $$distro | cut -d- -f 2`; \
5844
VERSION=$(PACKAGE_VERSION)~$${deb_codename} ARCH=$${arch} nfpm pkg --config .nfpm.yaml --packager deb --target ${PACKAGES_DIR}/deb/${PACKAGE_PREFIX}_$(PACKAGE_VERSION)~$${deb_codename}_$${arch}.deb; \
59-
cp ${PACKAGES_DIR}/deb/${PACKAGE_PREFIX}_$(PACKAGE_VERSION)~$${deb_codename}_$${arch}.deb ${GITHUB_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION)~$${deb_codename}_$${arch}.deb; \
60-
cp ${PACKAGES_DIR}/deb/${PACKAGE_PREFIX}_$(PACKAGE_VERSION)~$${deb_codename}_$${arch}.deb ${AZURE_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION)~$${deb_codename}_$${arch}.deb; \
6145
done; \
6246
rm -rf $(BINARY_PATH); \
6347
done; \
6448

6549
# Create rpm packages
66-
6750
@GOWORK=off CGO_ENABLED=0 GOARCH=amd64 GOOS=linux go build -pgo=auto -ldflags=${LDFLAGS} -o $(BINARY_PATH) $(PROJECT_DIR)/$(PROJECT_FILE)
6851
@for distro in $(RPM_DISTROS); do \
6952
rpm_distro=`echo $$distro | cut -d- -f 1`; \
7053
rpm_major=`echo $$distro | cut -d- -f 2`; \
7154
rpm_codename='na'; \
72-
if [ "$$rpm_distro" = "centos" ] || [ "$$rpm_distro" = "redhatenterprise" ]; then rpm_codename="el$$rpm_major"; \
73-
elif [ "$$rpm_distro" = "oraclelinux" ]; then rpm_codename="oraclelinux$$rpm_major"; \
74-
elif [ "$$rpm_distro" = "suse" ]; then rpm_codename="sles$$rpm_major"; \
55+
if [ "$$rpm_distro" = "suse" ]; then rpm_codename="sles$$rpm_major"; \
7556
fi; \
7657
if [ "$$rpm_codename" != "na" ]; then \
7758
VERSION=$(PACKAGE_VERSION) ARCH=amd64 nfpm pkg --config .nfpm.yaml --packager rpm --target $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.${RPM_ARCH}.rpm; \
78-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$(RPM_ARCH).rpm ${GITHUB_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.${RPM_ARCH}.rpm; \
79-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$(RPM_ARCH).rpm ${AZURE_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.${RPM_ARCH}.rpm; \
8059
fi; \
8160
done; \
8261
rm -rf $(BINARY_PATH)
8362

8463

8564
# Create redhat rpm packages
86-
8765
@for arch in $(REDHAT_ARCHS); do \
8866
goarch=amd64; \
8967
if [ "$$arch" = "aarch64" ]; then goarch="arm64"; fi; \
@@ -93,49 +71,12 @@ package: gpg-key $(PACKAGES_DIR) $(GITHUB_PACKAGES_DIR) $(AZURE_PACKAGES_DIR) ##
9371
rpm_major=`echo $$distro | cut -d- -f 2`; \
9472
rpm_codename="el$$rpm_major"; \
9573
VERSION=$(PACKAGE_VERSION) ARCH=$${arch} nfpm pkg --config .nfpm.yaml --packager rpm --target $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
96-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${GITHUB_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
97-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${AZURE_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
9874
done; \
9975
rm -rf $(BINARY_PATH); \
10076
done; \
10177

102-
# Create almalinux rpm packages
103-
104-
@for arch in $(ALMA_ARCHS); do \
105-
goarch=amd64; \
106-
if [ "$$arch" = "aarch64" ]; then goarch="arm64"; fi; \
107-
GOWORK=off CGO_ENABLED=0 GOARCH=$${goarch} GOOS=linux go build -pgo=auto -ldflags=${LDFLAGS} -o $(BINARY_PATH) $(PROJECT_DIR)/$(PROJECT_FILE); \
108-
for distro in $(ALMA_VERSIONS); do \
109-
rpm_distro=`echo $$distro | cut -d- -f 1`; \
110-
rpm_major=`echo $$distro | cut -d- -f 2`; \
111-
rpm_codename="almalinux$$rpm_major"; \
112-
VERSION=$(PACKAGE_VERSION) ARCH=$${arch} nfpm pkg --config .nfpm.yaml --packager rpm --target $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
113-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${GITHUB_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
114-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${AZURE_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
115-
done; \
116-
rm -rf $(BINARY_PATH); \
117-
done; \
118-
119-
# Create rocky rpm packages
120-
121-
@for arch in $(ROCKY_ARCHS); do \
122-
goarch=amd64; \
123-
if [ "$$arch" = "aarch64" ]; then goarch="arm64"; fi; \
124-
GOWORK=off CGO_ENABLED=0 GOARCH=$${goarch} GOOS=linux go build -pgo=auto -ldflags=${LDFLAGS} -o $(BINARY_PATH) $(PROJECT_DIR)/$(PROJECT_FILE); \
125-
for distro in $(ROCKY_VERSIONS); do \
126-
rpm_distro=`echo $$distro | cut -d- -f 1`; \
127-
rpm_major=`echo $$distro | cut -d- -f 2`; \
128-
rpm_codename='na'; \
129-
if [ "$$rpm_distro" = "rocky" ]; then rpm_codename="rocky$$rpm_major"; fi; \
130-
if [ "$$rpm_codename" != "na" ]; then \
131-
VERSION=$(PACKAGE_VERSION) ARCH=$${arch} nfpm pkg --config .nfpm.yaml --packager rpm --target $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
132-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${GITHUB_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
133-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${AZURE_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
134-
fi; \
135-
done; \
136-
rm -rf $(BINARY_PATH); \
137-
done; \
13878

79+
# Create amazon rpm packages
13980
@for arch in $(AMAZON_ARCHS); do \
14081
goarch=amd64; \
14182
if [ "$$arch" = "aarch64" ]; then goarch="arm64"; fi; \
@@ -144,34 +85,22 @@ package: gpg-key $(PACKAGES_DIR) $(GITHUB_PACKAGES_DIR) $(AZURE_PACKAGES_DIR) ##
14485
rpm_major=`echo $$version | cut -d- -f 2`; \
14586
rpm_codename="amzn$$rpm_major";\
14687
VERSION=$(PACKAGE_VERSION) ARCH=$${arch} nfpm pkg --config .nfpm.yaml --packager rpm --target $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
147-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${GITHUB_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
148-
cp $(PACKAGES_DIR)/rpm/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm ${AZURE_PACKAGES_DIR}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).$${rpm_codename}.ngx.$${arch}.rpm; \
14988
done; \
15089
rm -rf $(BINARY_PATH); \
15190
done; \
15291

15392
# Create apk packages
154-
15593
@for arch in $(APK_ARCHS); do \
15694
goarch=amd64; \
15795
if [ "$$arch" = "aarch64" ]; then goarch="arm64"; fi; \
15896
GOWORK=off CGO_ENABLED=0 GOARCH=$${goarch} GOOS=linux go build -pgo=auto -ldflags=${LDFLAGS} -o $(BINARY_PATH) $(PROJECT_DIR)/$(PROJECT_FILE); \
15997
for version in $(APK_VERSIONS); do \
16098
if [ ! -d "$(PACKAGES_DIR)/apk/v$${version}/$${arch}" ]; then mkdir -p $(PACKAGES_DIR)/apk/v$${version}/$${arch}; fi; \
16199
VERSION=$(PACKAGE_VERSION) ARCH=$${arch} nfpm pkg --config .nfpm.yaml --packager apk --target $(PACKAGES_DIR)/apk/v$${version}/$${arch}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).apk; \
162-
cp $(PACKAGES_DIR)/apk/v$${version}/$${arch}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).apk ${GITHUB_PACKAGES_DIR}/${PACKAGE_PREFIX}-v$(PACKAGE_VERSION)-r$(APK_REVISION).apk; \
163-
cp $(PACKAGES_DIR)/apk/v$${version}/$${arch}/${PACKAGE_PREFIX}-$(PACKAGE_VERSION).apk ${AZURE_PACKAGES_DIR}/${PACKAGE_PREFIX}-v$(PACKAGE_VERSION)-r$(APK_REVISION).apk; \
164100
done; \
165101
rm -rf $(BINARY_PATH); \
166102
done; \
167-
168-
# Create txz packages
169-
170-
rm -rf $(BINARY_PATH)
171-
@GOWORK=off CGO_ENABLED=0 GOOS=freebsd GOARCH=amd64 go build -pgo=auto -ldflags=${LDFLAGS} -o $(BINARY_PATH) $(PROJECT_DIR)/$(PROJECT_FILE)
172-
173-
docker run -v ${PWD}:/nginx-agent/ -e VERSION=$(PACKAGE_VERSION) build-signed-packager:1.0.0
174-
103+
175104
# Package build complete
176105

177106
echo "DEB packages:"; \
@@ -180,17 +109,9 @@ package: gpg-key $(PACKAGES_DIR) $(GITHUB_PACKAGES_DIR) $(AZURE_PACKAGES_DIR) ##
180109
find $(PACKAGES_DIR)/rpm ;\
181110
echo "APK packages:"; \
182111
find $(PACKAGES_DIR)/apk ;\
183-
echo "TXZ packages:"; \
184-
find $(PACKAGES_DIR)/txz ;\
185-
echo "Github packages:"; \
186-
find $(GITHUB_PACKAGES_DIR) ;\
187-
cd $(PACKAGES_DIR) && tar -czvf "./$(TARBALL_NAME)" * && cd ../.. && cp "${PACKAGES_DIR}/$(TARBALL_NAME)" "${AZURE_PACKAGES_DIR}/$(TARBALL_NAME)"; \
188-
echo "Azure packages:"; \
189-
find $(AZURE_PACKAGES_DIR) ;
190112

191-
.PHONY: build-signed-packager
192-
build-signed-packager:
193-
docker build -f scripts/packages/packager/Dockerfile --build-arg package_type=signed-package -t build-signed-packager:1.0.0 .
113+
# Create tarball containing all packages
114+
cd $(PACKAGES_DIR) && tar -czvf "./$(TARBALL_NAME)" * && cd ../.. && cp "${PACKAGES_DIR}/$(TARBALL_NAME)"; \
194115

195116
.PHONY: gpg-key
196117
gpg-key: ## Generate GPG public key

‎Makefile.tools‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
OAPICODEGEN = github.com/deepmap/oapi-codegen/v2/cmd/oapi-codegen@v2.1.0
22
LEFTHOOK = github.com/evilmartians/lefthook@v1.6.9
3-
GOLANGCILINT = github.com/golangci/golangci-lint/cmd/golangci-lint@v1.64.8
3+
GOLANGCILINT = github.com/golangci/golangci-lint/v2/cmd/golangci-lint@v2.2.1
44
PROTOCGENGO = google.golang.org/protobuf/cmd/protoc-gen-go@v1.32.0
55
GOFUMPT = mvdan.cc/gofumpt@v0.6.0
66
COUNTERFEITER = github.com/maxbrunsfeld/counterfeiter/v6@v6.8.1

‎go.mod‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
module github.com/nginx/agent/v3
22

3-
go 1.23.7
3+
go 1.24.0
44

5-
toolchain go1.23.10
5+
toolchain go1.24.4
66

77
require (
88
buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go v1.36.4-20250130201111-63bb56e20495.1

‎internal/bus/message_pipe.go‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,16 @@ func (p *MessagePipe) IsPluginRegistered(pluginName string) bool {
147147
return isPluginRegistered
148148
}
149149

150+
func (p *MessagePipe) Index(pluginName string, plugins []Plugin) int {
151+
for index, plugin := range plugins {
152+
if pluginName == plugin.Info().Name {
153+
return index
154+
}
155+
}
156+
157+
return -1
158+
}
159+
150160
func (p *MessagePipe) unsubscribePlugin(ctx context.Context, index int, plugin Plugin) error {
151161
if index != -1 {
152162
p.plugins = append(p.plugins[:index], p.plugins[index+1:]...)
@@ -181,16 +191,6 @@ func (p *MessagePipe) findPlugins(pluginNames []string) []Plugin {
181191
return plugins
182192
}
183193

184-
func (p *MessagePipe) Index(pluginName string, plugins []Plugin) int {
185-
for index, plugin := range plugins {
186-
if pluginName == plugin.Info().Name {
187-
return index
188-
}
189-
}
190-
191-
return -1
192-
}
193-
194194
func (p *MessagePipe) initPlugins(ctx context.Context) {
195195
for index, plugin := range p.plugins {
196196
err := plugin.Init(ctx, p)

‎internal/collector/logsgzipprocessor/processor.go‎

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,22 @@ func (p *logsGzipProcessor) ConsumeLogs(ctx context.Context, ld plog.Logs) error
9595
return p.nextConsumer.ConsumeLogs(ctx, ld)
9696
}
9797

98+
func (p *logsGzipProcessor) Capabilities() consumer.Capabilities {
99+
return consumer.Capabilities{
100+
MutatesData: true,
101+
}
102+
}
103+
104+
func (p *logsGzipProcessor) Start(ctx context.Context, _ component.Host) error {
105+
p.settings.Logger.Info("Starting logs gzip processor")
106+
return nil
107+
}
108+
109+
func (p *logsGzipProcessor) Shutdown(ctx context.Context) error {
110+
p.settings.Logger.Info("Shutting down logs gzip processor")
111+
return nil
112+
}
113+
98114
func (p *logsGzipProcessor) processLogRecords(logRecords plog.LogRecordSlice) error {
99115
var errs error
100116
// Filter out unsupported data types in the log before processing
@@ -164,19 +180,3 @@ func (p *logsGzipProcessor) gzipCompress(data []byte) ([]byte, error) {
164180

165181
return buf.Bytes(), nil
166182
}
167-
168-
func (p *logsGzipProcessor) Capabilities() consumer.Capabilities {
169-
return consumer.Capabilities{
170-
MutatesData: true,
171-
}
172-
}
173-
174-
func (p *logsGzipProcessor) Start(ctx context.Context, _ component.Host) error {
175-
p.settings.Logger.Info("Starting logs gzip processor")
176-
return nil
177-
}
178-
179-
func (p *logsGzipProcessor) Shutdown(ctx context.Context) error {
180-
p.settings.Logger.Info("Shutting down logs gzip processor")
181-
return nil
182-
}

‎internal/collector/logsgzipprocessor/processor_benchmark_test.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ func generateLogs(numRecords, recordSize int) plog.Logs {
2020
logs := plog.NewLogs()
2121
rl := logs.ResourceLogs().AppendEmpty()
2222
sl := rl.ScopeLogs().AppendEmpty()
23-
for i := 0; i < numRecords; i++ {
23+
for range numRecords {
2424
lr := sl.LogRecords().AppendEmpty()
2525
content, _ := randomString(recordSize)
2626
lr.Body().SetStr(content)
@@ -64,7 +64,7 @@ func BenchmarkGzipProcessor(b *testing.B) {
6464
logs := generateLogs(bm.numRecords, bm.recordSize)
6565

6666
b.ResetTimer()
67-
for i := 0; i < b.N; i++ {
67+
for range b.N {
6868
_ = p.ConsumeLogs(context.Background(), logs)
6969
}
7070
})

‎internal/collector/nginxossreceiver/factory_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import (
2323
func TestType(t *testing.T) {
2424
factory := NewFactory()
2525
ft := factory.Type()
26-
require.EqualValues(t, metadata.Type, ft)
26+
require.Equal(t, metadata.Type, ft)
2727
}
2828

2929
func TestValidConfig(t *testing.T) {

‎internal/collector/nginxossreceiver/internal/scraper/accesslog/nginx_log_scraper.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,12 @@ func (nls *NginxLogScraper) Shutdown(_ context.Context) error {
224224
return err
225225
}
226226

227+
func (nls *NginxLogScraper) ConsumerCallback(_ context.Context, entries []*entry.Entry) {
228+
nls.mut.Lock()
229+
nls.entries = append(nls.entries, entries...)
230+
nls.mut.Unlock()
231+
}
232+
227233
func (nls *NginxLogScraper) initStanzaPipeline(
228234
operators []operator.Config,
229235
logger *zap.Logger,
@@ -248,12 +254,6 @@ func (nls *NginxLogScraper) initStanzaPipeline(
248254
return pipe, err
249255
}
250256

251-
func (nls *NginxLogScraper) ConsumerCallback(_ context.Context, entries []*entry.Entry) {
252-
nls.mut.Lock()
253-
nls.entries = append(nls.entries, entries...)
254-
nls.mut.Unlock()
255-
}
256-
257257
func (nls *NginxLogScraper) runConsumer(ctx context.Context) {
258258
nls.logger.Info("Starting NGINX access log receiver's consumer")
259259
defer nls.wg.Done()

‎internal/collector/nginxossreceiver/internal/scraper/accesslog/operator/input/file/config.go‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,13 @@ import (
2121

2222
const operatorType = "access_log_file_input"
2323

24+
// Config is the configuration of a file input operator
25+
type Config struct {
26+
helper.InputConfig `mapstructure:",squash"`
27+
AccessLogFormat string `mapstructure:"access_log_format"`
28+
fileconsumer.Config `mapstructure:",squash"`
29+
}
30+
2431
func init() {
2532
operator.Register(operatorType, func() operator.Builder { return NewConfig() })
2633
}
@@ -38,13 +45,6 @@ func NewConfigWithID(operatorID string) *Config {
3845
}
3946
}
4047

41-
// Config is the configuration of a file input operator
42-
type Config struct {
43-
helper.InputConfig `mapstructure:",squash"`
44-
AccessLogFormat string `mapstructure:"access_log_format"`
45-
fileconsumer.Config `mapstructure:",squash"`
46-
}
47-
4848
// Build will build a file input operator from the supplied configuration
4949
// nolint: ireturn
5050
func (c Config) Build(set component.TelemetrySettings) (operator.Operator, error) {

0 commit comments

Comments
 (0)