sqlstore

Documentation

Index

• type OperationRepository
  • func (r *OperationRepository) Create(ctx context.Context, operations ...*model.Operation) error
  • func (r *OperationRepository) DeleteByResourceID(ctx context.Context, id int64) (int64, error)
  • func (r *OperationRepository) FindByNumber(ctx context.Context, number string, limit uint64, order string) ([]model.Operation, error)
  • func (r *OperationRepository) FindByVIN(ctx context.Context, vin string, limit uint64, order string) ([]model.Operation, error)
• type ResourceRepository
  • func (r *ResourceRepository) All(ctx context.Context) ([]model.Resource, error)
  • func (r *ResourceRepository) Create(ctx context.Context, resource *model.Resource) error
  • func (r *ResourceRepository) FindByUID(ctx context.Context, uid string) (*model.Resource, error)
  • func (r *ResourceRepository) Update(ctx context.Context, resource *model.Resource) error
• type Store
  • func New(settings *config.Database) (*Store, error)
  • func TestDB(t *testing.T, conf *config.Database) (store *Store, teardown func(...string))
  • func (s *Store) Operation() domain.OperationRepository
  • func (s *Store) Resource() domain.ResourceRepository

Types

type OperationRepository

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

OperationRepository is responsible for operations data.

func (*OperationRepository) Create

func (r *OperationRepository) Create(ctx context.Context, operations ...*model.Operation) error

Create adds new records to the operations table. TODO: Benchmark & Speed Up (Batch INSERT).

func (*OperationRepository) DeleteByResourceID

func (r *OperationRepository) DeleteByResourceID(ctx context.Context, id int64) (int64, error)

DeleteByResourceID removes records with specified resource_id from operations table.

func (*OperationRepository) FindByNumber

func (r *OperationRepository) FindByNumber(ctx context.Context, number string, limit uint64, order string) ([]model.Operation, error)

FindByNumber returns list operations on vehicles with specified number plates.

func (*OperationRepository) FindByVIN

func (r *OperationRepository) FindByVIN(ctx context.Context, vin string, limit uint64, order string) ([]model.Operation, error)

FindByNumber returns list operations on vehicles with specified number plates.

type ResourceRepository

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

ResourceRepository is responsible for resources data.

func (*ResourceRepository) All

func (r *ResourceRepository) All(ctx context.Context) ([]model.Resource, error)

func (*ResourceRepository) Create

func (r *ResourceRepository) Create(ctx context.Context, resource *model.Resource) error

func (*ResourceRepository) FindByUID

func (r *ResourceRepository) FindByUID(ctx context.Context, uid string) (*model.Resource, error)

func (*ResourceRepository) Update

func (r *ResourceRepository) Update(ctx context.Context, resource *model.Resource) error

type Store

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

Store is an implementation of domain.Store interface based on SQL.

func New

func New(settings *config.Database) (*Store, error)

New returns new instance of Store.

func TestDB

func TestDB(t *testing.T, conf *config.Database) (store *Store, teardown func(...string))

TestDB returns special test connection and teardown function.

func (*Store) Operation

func (s *Store) Operation() domain.OperationRepository

Operation returns repository, who is responsible for operations.

func (*Store) Resource

func (s *Store) Resource() domain.ResourceRepository

Resource returns repository, who is responsible for resources.