Skip to content

Commit

Permalink
Rename internal 'pg' package to correspond with the path
Browse files Browse the repository at this point in the history
It's migration from private repo wasn't made clear.
  • Loading branch information
Tomas Prochazka committed Sep 5, 2023
1 parent f97489c commit dea504d
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion internal/pg/pg.go
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package pgutils
package pg

import (
"strconv"
Expand Down
4 changes: 2 additions & 2 deletions publisher.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,9 +111,9 @@ func (d *publisher) Publish(ctx context.Context, queue string, msgs ...Message)
func buildInsertQuery(queue string, msgCount int) string {
var sb strings.Builder
sb.WriteString("INSERT INTO ")
sb.WriteString(pgutils.QuoteIdentifier(queue))
sb.WriteString(pg.QuoteIdentifier(queue))
sb.WriteString(" (payload, metadata) VALUES ")
var params pgutils.StmtParams
var params pg.StmtParams
for rowIdx := 0; rowIdx < msgCount; rowIdx++ {
if rowIdx != 0 {
sb.WriteString(",")
Expand Down

0 comments on commit dea504d

Please sign in to comment.