pgflonats

package

v0.0.13 Latest Latest Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

NATSClient represents a client for interacting with NATS

func NewNATSClient(url, stream, group string) (*NATSClient, error)

NewNATSClient creates a new NATS client with the specified configuration, setting up the connection, main stream, and state bucket.

func (nc *NATSClient) Close() error

Close closes the NATS connection.

func (nc *NATSClient) GetState() (State, error)

GetState retrieves the last saved state from NATS, initializing a new state if none is found.

func (nc *NATSClient) JetStream() nats.JetStreamContext

JetStream returns the JetStream context.

func (nc *NATSClient) PublishMessage(subject string, data []byte) error

PublishMessage publishes a message to the specified NATS subject.

func (nc *NATSClient) SaveState(state State) error

SaveState saves the current replication state to NATS.

type State struct {
	LSN              pglogrepl.LSN `json:"lsn"`
	LastProcessedSeq map[string]uint64
}

State represents the current state of the replication process