Skip to content

Commit b187aa3

Browse files
authored
Merge branch 'main' into steve/pool-constructor
2 parents 61f3491 + f7f593f commit b187aa3

File tree

1 file changed

+25
-0
lines changed

1 file changed

+25
-0
lines changed

sender.go

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -537,6 +537,31 @@ func NewLineSender(ctx context.Context, opts ...LineSenderOption) (LineSender, e
537537
return newLineSender(ctx, conf)
538538
}
539539

540+
func newLineSenderConfig(t senderType) *lineSenderConfig {
541+
switch t {
542+
case tcpSenderType:
543+
return &lineSenderConfig{
544+
senderType: t,
545+
address: defaultTcpAddress,
546+
initBufSize: defaultInitBufferSize,
547+
fileNameLimit: defaultFileNameLimit,
548+
}
549+
default:
550+
return &lineSenderConfig{
551+
senderType: t,
552+
address: defaultHttpAddress,
553+
requestTimeout: defaultRequestTimeout,
554+
retryTimeout: defaultRetryTimeout,
555+
minThroughput: defaultMinThroughput,
556+
autoFlushRows: defaultAutoFlushRows,
557+
autoFlushInterval: defaultAutoFlushInterval,
558+
initBufSize: defaultInitBufferSize,
559+
maxBufSize: defaultMaxBufferSize,
560+
fileNameLimit: defaultFileNameLimit,
561+
}
562+
}
563+
}
564+
540565
func newLineSender(ctx context.Context, conf *lineSenderConfig) (LineSender, error) {
541566
switch conf.senderType {
542567
case tcpSenderType:

0 commit comments

Comments
 (0)