store

Documentation

Index

• Variables
• type Mut
• type OneOpts
• type Op
  • func AddRec(kind string, attrs any) Op
  • func AddRel(id, kind, to string, attrs any) Op
  • func ClearAttrs() Op
  • func DelAttr(key string) Op
  • func DelRel(id string) Op
  • func SetAttr(key string, val any) Op
• type Query
• type Record
• type Relation
• type Store
  • func New(ctx context.Context, conn string) (*Store, error)
  • func NewFromPool(pool *pgxpool.Pool) (*Store, error)
  • func (s *Store) Many(ctx context.Context, query Query) ([]*Record, error)
  • func (s *Store) Mutate(ctx context.Context, muts ...Mut) error
  • func (s *Store) One(ctx context.Context, opts OneOpts) (*Record, error)

Variables

var ErrNotFound = errors.New("not found")

Types

type Mut

type Mut struct {
	RecordID string
	Author   string
	Reason   string
	Ops      []Op
}

type OneOpts

type OneOpts struct {
	ID     string `json:"id,omitempty"`
	Kind   string `json:"kind,omitempty"`
	Attr   string `json:"attr,omitempty"`
	Follow string `json:"follow,omitempty"`
}

type Op

type Op struct {
	Name string `json:"name"`
	Args any    `json:"args,omitempty"`
}

TODO make ops opaque

func AddRec

func AddRec(kind string, attrs any) Op

func AddRel

func AddRel(id, kind, to string, attrs any) Op

func ClearAttrs

func ClearAttrs() Op

func DelAttr

func DelAttr(key string) Op

func DelRel

func DelRel(id string) Op

func SetAttr

func SetAttr(key string, val any) Op

type Query

type Query struct {
	Limit  int      `json:"-"`
	Offset int      `json:"-"`
	ID     string   `json:"id,omitempty"`
	IDIn   []string `json:"id_in,omitempty"`
	Kind   string   `json:"kind,omitempty"`
	Attr   string   `json:"attr,omitempty"`
	Follow string   `json:"follow,omitempty"`
}

type Record

type Record struct {
	ID         string          `json:"id"`
	Kind       string          `json:"kind"`
	Attributes json.RawMessage `json:"attributes"`
	Relations  []*Relation     `json:"relations"`
	CreatedAt  time.Time       `json:"created_at"`
	UpdatedAt  time.Time       `json:"updated_at"`
}

type Relation

type Relation struct {
	ID         string          `json:"id"`
	Kind       string          `json:"kind"`
	Attributes json.RawMessage `json:"attributes"`
	Record     *Record         `json:"record"`
	CreatedAt  time.Time       `json:"created_at"`
	UpdatedAt  time.Time       `json:"updated_at"`
}

type Store

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

func New

func New(ctx context.Context, conn string) (*Store, error)

func NewFromPool

func NewFromPool(pool *pgxpool.Pool) (*Store, error)

func (*Store) Many

func (s *Store) Many(ctx context.Context, query Query) ([]*Record, error)

func (*Store) Mutate

func (s *Store) Mutate(ctx context.Context, muts ...Mut) error

TODO optimistic locking

func (*Store) One

func (s *Store) One(ctx context.Context, opts OneOpts) (*Record, error)