Skip to content

Commit

Permalink
Change module name
Browse files Browse the repository at this point in the history
  • Loading branch information
Leonardo Reis committed Sep 5, 2023
1 parent 27bb73b commit 5738d10
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# arqbeam-sink-pubsub
# arqbeam-pubsubio
An Apache Beam sink for arqbeam-app.

This implementation uses go/pubsub google sdk to publish messages in Pubsub topic.
Expand All @@ -10,8 +10,8 @@ package main

import (
"context"
"github.com/arquivei/arqbeam-sink-pubsub"
errorpubsubio "github.com/arquivei/arqbeam-sink-pubsub/error"
"github.com/arquivei/arqbeam-pubsubio"
errorpubsubio "github.com/arquivei/arqbeam-pubsubio/error"

"github.com/apache/beam/sdks/v2/go/pkg/beam"
"github.com/apache/beam/sdks/v2/go/pkg/beam/io/textio"
Expand All @@ -32,7 +32,7 @@ func getPipeline(ctx context.Context) *beam.Pipeline {
// Read some files with textio default from apache beam go sdk
readRows := textio.Read(s, config.GCSInputFile)

// Send each line to pubsub with pubsubio from arqbeam-sink-pubsub
// Send each line to pubsub with pubsubio from arqbeam-pubsubio
pbResult := pubsubio.Publish(s, config.Pubsub.Project, config.Pubsub.Topic, config.Pubsub.BatchSize, readRows)

// Log if any error happened in publish step
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/arquivei/arqbeam-sink-pubsub
module github.com/arquivei/arqbeam-pubsubio

go 1.20

Expand Down

0 comments on commit 5738d10

Please sign in to comment.