postgres

package

v0.1.0 Latest Latest Go to latest Published: Oct 16, 2023 License: MIT Imports: 4 Imported by: 0

Details

Package postgres provides low-level persistence implementations that store data in PostgreSQL database.

This section is empty.

This section is empty.

func CreateJournalStoreSchema(
	ctx context.Context,
	db *sql.DB,
) error

CreateJournalStoreSchema creates the PostgreSQL schema elements required by JournalStore.

func CreateKeyValueStoreSchema(
	ctx context.Context,
	db *sql.DB,
) error

CreateKeyValueStoreSchema creates the PostgreSQL schema elements required by KeyValueStore.

type JournalStore struct {
	// DB is the PostgreSQL database connection.
	DB *sql.DB
}

JournalStore is an implementation of journal.Store that contains journals that persist records in a PostgresSQL table.

func (s *JournalStore) Open(_ context.Context, name string) (journal.Journal, error)

Open returns the journal with the given name.

type KeyValueStore struct {
	DB *sql.DB
}

KeyValueStore is an implementation of kv.Store that stores keyspaces in a PostgreSQL database.

func (s *KeyValueStore) Open(_ context.Context, name string) (kv.Keyspace, error)

Open returns the keyspace with the given name.