datastore

Documentation

Overview

Package datastore provides a repository implementation.

Index

• func Fields(args ...interface{}) []string
• func Item(in interface{}, transient ...interface{}) (map[string]interface{}, error)
• type Context
  • func NewContext(ctx context.Context, repo *Repository) (*Context, error)
  • func (ctx *Context) Add(collection string, data interface{}) error
  • func (ctx *Context) Commit() error
  • func (ctx *Context) Remove(collection string, filter interface{}) (int, error)
  • func (ctx *Context) Rollback() error
  • func (ctx *Context) Update(collection string, filter, data interface{}) (int, error)
• type Repository
  • func New(client client.Client) (*Repository, error)
  • func (r *Repository) Context(ctx context.Context) (*Context, error)
  • func (r *Repository) Procedure(ctx context.Context, subroutines ...func(tx *Context) error) error
  • func (r *Repository) Query() client.Query
  • func (r *Repository) Search(ctx context.Context, query client.Query, dst interface{}) error

Functions

func Fields

func Fields(args ...interface{}) []string

Fields gets all fields for datastore item(s)

func Item

func Item(in interface{}, transient ...interface{}) (map[string]interface{}, error)

Item converts a struct to a map using reflection variation of: https://play.golang.org/p/2Qi3thFf--

Types

type Context

type Context struct {
	context.Context
	// contains filtered or unexported fields
}

Context is a data store transactions

func NewContext

func NewContext(ctx context.Context, repo *Repository) (*Context, error)

NewContext creates a new instance of the data store context

func (*Context) Add

func (ctx *Context) Add(collection string, data interface{}) error

Add adds item to the repository

func (*Context) Commit

func (ctx *Context) Commit() error

Commit a datastore transaction

func (*Context) Remove

func (ctx *Context) Remove(collection string, filter interface{}) (int, error)

Remove removes items from the repository matching criteria.

func (*Context) Rollback

func (ctx *Context) Rollback() error

Rollback a datastore transaction

func (*Context) Update

func (ctx *Context) Update(collection string, filter, data interface{}) (int, error)

Update updates items matching filters

type Repository

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

Repository is an instance of a postgres Database

func New

func New(client client.Client) (*Repository, error)

New creates a new postgres database

func (*Repository) Context

func (r *Repository) Context(ctx context.Context) (*Context, error)

Context creates a new data store context

func (*Repository) Procedure

func (r *Repository) Procedure(ctx context.Context, subroutines ...func(tx *Context) error) error

Procedure executes a series of subroutines and bails fast if any errors occur

func (*Repository) Query

func (r *Repository) Query() client.Query

Query gets a new query for searching the repository.

func (*Repository) Search

func (r *Repository) Search(ctx context.Context, query client.Query, dst interface{}) error

Search retrieves items from the repository matching criteria.