postgresql

Documentation

Index

• type DB
  • func NewDB(dsn string) *DB
  • func (db *DB) BeginTX(ctx context.Context, opts *sql.TxOptions) (*Tx, error)
  • func (db *DB) Close() error
  • func (db *DB) DB() *sql.DB
  • func (db *DB) Open() (err error)
• type PostgreSqlStoreService
  • func NewPostgresqlStore(db *DB, cache service.Cache) *PostgreSqlStoreService
  • func (s *PostgreSqlStoreService) AddFriendship(ctx context.Context, friendship internal.Friendship) error
  • func (s *PostgreSqlStoreService) AddPerson(ctx context.Context, person *internal.Person) error
  • func (s *PostgreSqlStoreService) RemovePerson(ctx context.Context, id int64) error
• type Tx

Types

type DB

type DB struct {
	DSN string

	Now func() time.Time
	// contains filtered or unexported fields
}

func NewDB

func NewDB(dsn string) *DB

func (*DB) BeginTX

func (db *DB) BeginTX(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) DB

func (db *DB) DB() *sql.DB

func (*DB) Open

func (db *DB) Open() (err error)

type PostgreSqlStoreService

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

PostgreSqlStoreService

func NewPostgresqlStore

func NewPostgresqlStore(db *DB, cache service.Cache) *PostgreSqlStoreService

func (*PostgreSqlStoreService) AddFriendship

func (s *PostgreSqlStoreService) AddFriendship(ctx context.Context, friendship internal.Friendship) error

AddFriendship

func (*PostgreSqlStoreService) AddPerson

func (s *PostgreSqlStoreService) AddPerson(ctx context.Context, person *internal.Person) error

AddPerson

func (*PostgreSqlStoreService) RemovePerson

func (s *PostgreSqlStoreService) RemovePerson(ctx context.Context, id int64) error

RemovePerson

type Tx

type Tx struct {
	*sql.Tx
	// contains filtered or unexported fields
}