pg

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 24, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	ConnString  string           `json:"connString"`
	Replication pglogrepl.Config `json:"replication"`
}

type PeerPG 

type PeerPG struct {
	// contains filtered or unexported fields
}

func (*PeerPG) Connect 

func (p *PeerPG) Connect(config json.RawMessage, _ ...any) error

func (*PeerPG) Disconnect 

func (p *PeerPG) Disconnect() error

func (*PeerPG) Pub 

func (p *PeerPG) Pub(event cdc.Event, _ ...any) error

func (*PeerPG) Sub 

func (p *PeerPG) Sub(_ ...any) (<-chan cdc.Event, error)

func (*PeerPG) Type 

func (p *PeerPG) Type() pipeline.ConnectorType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.