postgres

Documentation

Overview

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

Index

• func CreateJournalStoreSchema(ctx context.Context, db *sql.DB) error
• func CreateKeyValueStoreSchema(ctx context.Context, db *sql.DB) error
• type JournalStore
  • func (s *JournalStore) Open(_ context.Context, name string) (journal.Journal, error)
• type KeyValueStore
  • func (s *KeyValueStore) Open(_ context.Context, name string) (kv.Keyspace, error)

Functions

func CreateJournalStoreSchema

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

CreateJournalStoreSchema creates the PostgreSQL schema elements required by JournalStore.

func CreateKeyValueStoreSchema

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

CreateKeyValueStoreSchema creates the PostgreSQL schema elements required by KeyValueStore.

Types

type JournalStore

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 (*JournalStore) Open

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

Open returns the journal with the given name.

type KeyValueStore

type KeyValueStore struct {
	DB *sql.DB
}

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

func (*KeyValueStore) Open

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

Open returns the keyspace with the given name.