Skip to content

Commit a1d913f

Browse files
authored
fix(doc): fix TCP sender examples (#29)
1 parent 0f785ff commit a1d913f

File tree

3 files changed

+3
-1
lines changed

3 files changed

+3
-1
lines changed

examples/tcp/auth-and-tls/main.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ func main() {
1212
ctx := context.TODO()
1313
sender, err := qdb.NewLineSender(
1414
ctx,
15+
qdb.WithTcp(),
1516
qdb.WithAddress("localhost:9009"),
1617
qdb.WithAuth(
1718
"testUser1", // token name here

examples/tcp/auth/main.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ func main() {
1212
ctx := context.TODO()
1313
sender, err := qdb.NewLineSender(
1414
ctx,
15+
qdb.WithTcp(),
1516
qdb.WithAddress("localhost:9009"),
1617
qdb.WithAuth(
1718
"testUser1", // token name here

examples/tcp/basic/main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
func main() {
1212
ctx := context.TODO()
1313
// Connect to QuestDB running on 127.0.0.1:9009
14-
sender, err := qdb.NewLineSender(ctx)
14+
sender, err := qdb.NewLineSender(ctx, qdb.WithTcp())
1515
if err != nil {
1616
log.Fatal(err)
1717
}

0 commit comments

Comments
 (0)