usedatabrew/pglogicalstream

Consider move /internal/replication package out of /internal

Closed this issue · 5 comments

gekpp commented

Hi,

Thank you for your work published. I was looking for initial snapshot feature and found out your project.

The problem I experience is that the Basic usage example doesn't work.

I have changed it a bit but it still fails to compile because in the code:

pgStream.OnMessage(
  func(message replication.Wal2JsonChanges) {
  // ...
  }
)

the package replication is defined inside /internal what makes the callback function impossible to use:

package pglogicalstream

import "github.com/usedatabrew/pglogicalstream/internal/replication"

type OnMessage = func(message replication.Wal2JsonChanges)
le-vlad commented

Hey @gekpp
Thanks for your issue. I'll take a look tomorrow.

  • 👍1
whygee-dev commented

I'm still not able to import "github.com/usedatabrew/pglogicalstream/messages"

imports
        github.com/usedatabrew/pglogicalstream/messages: cannot find module providing package github.com/usedatabrew/pglogicalstream/messages
le-vlad commented

I'm still not able to import "github.com/usedatabrew/pglogicalstream/messages"

imports
        github.com/usedatabrew/pglogicalstream/messages: cannot find module providing package github.com/usedatabrew/pglogicalstream/messages

Hey @whygee-dev
Can you share your code here? I'll take a look today.

whygee-dev commented

I'm still not able to import "github.com/usedatabrew/pglogicalstream/messages"

imports
        github.com/usedatabrew/pglogicalstream/messages: cannot find module providing package github.com/usedatabrew/pglogicalstream/messages

Hey @whygee-dev Can you share your code here? I'll take a look today.

👋 its exactly the same code as simple/main.go

  • 👀1
le-vlad commented

I'm still not able to import "github.com/usedatabrew/pglogicalstream/messages"

imports
        github.com/usedatabrew/pglogicalstream/messages: cannot find module providing package github.com/usedatabrew/pglogicalstream/messages

Hey @whygee-dev Can you share your code here? I'll take a look today.

👋 its exactly the same code as simple/main.go

Hey @whygee-dev

It should work now.
Please, use v0.0.26

go get github.com/usedatabrew/pglogicalstream@v0.0.26