postgres

Documentation

Index

• Constants
• type DebugHook
  • func (DebugHook) AfterQuery(ctx context.Context, event *pg.QueryEvent) error
  • func (DebugHook) BeforeQuery(ctx context.Context, event *pg.QueryEvent) (context.Context, error)
• type Postgres
  • func Connect(opt *pg.Options) (*Postgres, error)
  • func (p *Postgres) Check(ctx context.Context) error
  • func (p *Postgres) Insert(ctx context.Context, token ledger.Token) error
• type SecretToken

Constants

const (
	DefaultURL = "postgres://localhost:5432/ledger"
)

Types

type DebugHook

type DebugHook struct{}

func (DebugHook) AfterQuery

func (DebugHook) AfterQuery(ctx context.Context, event *pg.QueryEvent) error

func (DebugHook) BeforeQuery

func (DebugHook) BeforeQuery(ctx context.Context, event *pg.QueryEvent) (context.Context, error)

type Postgres

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

func Connect

func Connect(opt *pg.Options) (*Postgres, error)

Connect parses a database URL into options that can be used to connect to PostgreSQL.

func (*Postgres) Check

func (p *Postgres) Check(ctx context.Context) error

func (*Postgres) Insert

func (p *Postgres) Insert(ctx context.Context, token ledger.Token) error

type SecretToken

type SecretToken struct {
	Data ledger.Token `pg:"data,pk"`
	// contains filtered or unexported fields
}