datastore

Documentation

Overview

Package datastore provides a repository implementation.

Index

• 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 client.Filter, first int) (int, error)
  • func (ctx *Context) Rollback() error
  • func (ctx *Context) Update(collection string, filter client.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) Filter() client.Filter
  • func (r *Repository) Query() client.Query
  • func (r *Repository) Search(ctx context.Context, query client.Query, dst interface{}) error
  • func (r *Repository) Tag(tag string) *Repository

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 client.Filter, first int) (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 client.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) Filter

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

Filter gets a new filter for searching the repository.

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.

func (*Repository) Tag

func (r *Repository) Tag(tag string) *Repository

Tag sets the tag for adding to repository