pgrecorder

Documentation

Index

• Constants
• type PGRecorder
• type PackingRecorder
  • func NewPackingRecorder(db PGRecorder) *PackingRecorder
  • func (r *PackingRecorder) Record(e string, p *packing.Port) error
• type Port
  • func NewPort(p *packing.Port) *Port
  • func (p *Port) Value() (driver.Value, error)

Constants

const CURRENT_EVENT_VERSION = 1

const DB_NAME = "postgres"

const DB_PASS = "squish-words-together-fun"

const DB_PORT = "5432"

const DB_URL = "porteventstore.crg0dcdtyinh.us-west-1.rds.amazonaws.com"

NOTE in a real app you'd put these in env

const DB_USER = "portman"

const EVENTSTORE = "events" // the event table

Types

type PGRecorder

type PGRecorder interface {
	Exec(string, ...interface{}) (sql.Result, error)
}

Executable implementations expose Exec with the same args as sql.DB.Exec

type PackingRecorder

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

func NewPackingRecorder

func NewPackingRecorder(db PGRecorder) *PackingRecorder

func (*PackingRecorder) Record

func (r *PackingRecorder) Record(e string, p *packing.Port) error

type Port

type Port struct {
	Maker  string `json:"maker"`
	First  string `json:"first"`
	Second string `json:"second"`
	Result string `json:"result"`
	Algo   string `json:"algo"` // "rando" || "carrollian"
}

Port is the repository representation of a portmanteau. It must implement the sql.driver.valuer in order to be marshal-able

func NewPort

func NewPort(p *packing.Port) *Port

func (*Port) Value

func (p *Port) Value() (driver.Value, error)

Value allows the Port to implement driver.Value, thus able to be marshaled by the sql driver