store

Documentation

Index

• Constants
• type Data
  • func New(db *mongo.Database) *Data
  • func (d Data) Fetch(ctx context.Context, since, until, offset, limit int64, ids []string) ([]model.Data, error)
  • func (d *Data) Insert(ctx context.Context, i model.Data) error
  • func (d Data) PerProjectCount(ctx context.Context, projectID string) (map[string]int, error)
• type Project
  • func (ps Project) Create(ctx context.Context, p model.Project) error
  • func (ps Project) Delete(ctx context.Context, id string) error
  • func (ps Project) Get(ctx context.Context, id string) (model.Project, error)
  • func (ps Project) List(ctx context.Context) ([]model.Project, error)
  • func (ps Project) Logs(ctx context.Context, name string, limit int) ([]model.ProjectLog, error)
  • func (ps Project) Update(ctx context.Context, id string, fields map[string]interface{}) (model.Project, error)
• type Thing
  • func (ts Thing) Create(ctx context.Context, t model.Thing) error
  • func (ts Thing) GetByName(ctx context.Context, id string) (model.Thing, error)
  • func (ts Thing) GetByProjectID(ctx context.Context, pid string) ([]model.Thing, error)
  • func (ts Thing) Remove(ctx context.Context, id string) error
  • func (ts Thing) Update(ctx context.Context, id string, m *string, s *bool) (model.Thing, error)

Constants

const DataCollection = "data"

DataCollection is mongodb collection name for data

const ProjectCollection = "project"

ProjectCollection is mongodb collection name for project

const ThingCollection = "thing"

ThingCollection is mongodb collection name for things

Types

type Data

type Data struct {
	DB *mongo.Database
}

Data store handles database communication for data elements

func New

func New(db *mongo.Database) *Data

New creates new data store

func (Data) Fetch

func (d Data) Fetch(ctx context.Context, since, until, offset, limit int64, ids []string) ([]model.Data, error)

Fetch fetches given things data in given time range and sorts it.

func (*Data) Insert

func (d *Data) Insert(ctx context.Context, i model.Data) error

Insert given instance of data into database

func (Data) PerProjectCount

func (d Data) PerProjectCount(ctx context.Context, projectID string) (map[string]int, error)

PerProjectCount counts number of records for given project per things it returns a map between thing identification and number of records for that thing

type Project

type Project struct {
	DB *mongo.Database
}

Project stores and retrieves projects collection

func (Project) Create

func (ps Project) Create(ctx context.Context, p model.Project) error

func (Project) Delete

func (ps Project) Delete(ctx context.Context, id string) error

func (Project) Get

func (ps Project) Get(ctx context.Context, id string) (model.Project, error)

func (Project) List

func (ps Project) List(ctx context.Context) ([]model.Project, error)

List returns all registered projects

func (Project) Logs

func (ps Project) Logs(ctx context.Context, name string, limit int) ([]model.ProjectLog, error)

func (Project) Update

func (ps Project) Update(ctx context.Context, id string, fields map[string]interface{}) (model.Project, error)

type Thing

type Thing struct {
	DB *mongo.Database
}

Thing stores and retrieves things collection

func (Thing) Create

func (ts Thing) Create(ctx context.Context, t model.Thing) error

Create creates the given thing in things collection

func (Thing) GetByName

func (ts Thing) GetByName(ctx context.Context, id string) (model.Thing, error)

GetByName returns the thing that has given identification

func (Thing) GetByProjectID

func (ts Thing) GetByProjectID(ctx context.Context, pid string) ([]model.Thing, error)

GetByProjectID returns all things that are associated with given project identification

func (Thing) Remove

func (ts Thing) Remove(ctx context.Context, id string) error

Remove removes the given thing from the things collection

func (Thing) Update

func (ts Thing) Update(ctx context.Context, id string, m *string, s *bool) (model.Thing, error)

Update update the given thing's model