forked from open-telemetry/opentelemetry-collector-contrib
-
Notifications
You must be signed in to change notification settings - Fork 2
/
custom.go
26 lines (19 loc) · 758 Bytes
/
custom.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
package splitter // import "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/fileconsumer/internal/splitter"
import (
"bufio"
"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/tokenize"
)
type customFactory struct {
flusherCfg tokenize.FlusherConfig
splitFunc bufio.SplitFunc
}
var _ Factory = (*customFactory)(nil)
func NewCustomFactory(flusherCfg tokenize.FlusherConfig, splitFunc bufio.SplitFunc) Factory {
return &customFactory{flusherCfg: flusherCfg, splitFunc: splitFunc}
}
// Build builds Multiline Splitter struct
func (f *customFactory) Build() (bufio.SplitFunc, error) {
return f.flusherCfg.Wrap(f.splitFunc), nil
}