sqlite

Documentation

Index

• Variables
• type DB
  • func NewDB(dsn string) *DB
  • func (db *DB) Close() error
  • func (db *DB) Open(drop bool) (err error)
• type SiteService
  • func NewSiteService(db sqlc.DBTX) *SiteService
  • func (s *SiteService) AddSite(ctx context.Context, site pc.Site) error
  • func (s *SiteService) DeletePolicy(ctx context.Context, siteID, id uint32) (pc.Policy, error)
  • func (s *SiteService) GetObservation(ctx context.Context, siteID uint32, speciesName string) (pc.Observation, error)
  • func (s *SiteService) GetPolicy(ctx context.Context, siteID uint32, species string) (pc.Policy, error)
  • func (s *SiteService) GetSite(ctx context.Context, siteID uint32) (pc.Site, error)
  • func (s *SiteService) RecordObservation(ctx context.Context, obs pc.Observation) error
  • func (s *SiteService) SetPolicy(ctx context.Context, policyID uint32, siteID uint32, species string, ...) error
  • func (s *SiteService) SetTargetPopulations(ctx context.Context, siteID uint32, pops []pc.TargetPopulation) error

Variables

var (
	ErrDSNRequired = errors.New("DSN required")
)

Types

type DB

type DB struct {
	DB *sql.DB

	// Data source name.
	DSN string

	// Returns the current time. Defaults to time.Now().
	// Can be mocked for tests.
	Now func() time.Time
	// contains filtered or unexported fields
}

DB represents the database connection. Based off Ben Johnson's WTF Dial example. https://github.com/benbjohnson/wtf

func NewDB

func NewDB(dsn string) *DB

func (*DB) Close

func (db *DB) Close() error

func (*DB) Open

func (db *DB) Open(drop bool) (err error)

Open opens the database connection.

type SiteService

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

func NewSiteService

func NewSiteService(db sqlc.DBTX) *SiteService

func (*SiteService) AddSite

func (s *SiteService) AddSite(ctx context.Context, site pc.Site) error

func (*SiteService) DeletePolicy

func (s *SiteService) DeletePolicy(ctx context.Context, siteID, id uint32) (pc.Policy, error)

func (*SiteService) GetObservation

func (s *SiteService) GetObservation(ctx context.Context, siteID uint32, speciesName string) (pc.Observation, error)

func (*SiteService) GetPolicy

func (s *SiteService) GetPolicy(ctx context.Context, siteID uint32, species string) (pc.Policy, error)

func (*SiteService) GetSite

func (s *SiteService) GetSite(ctx context.Context, siteID uint32) (pc.Site, error)

func (*SiteService) RecordObservation

func (s *SiteService) RecordObservation(ctx context.Context, obs pc.Observation) error

func (*SiteService) SetPolicy

func (s *SiteService) SetPolicy(ctx context.Context, policyID uint32, siteID uint32, species string, action pc.PolicyAction) error

func (*SiteService) SetTargetPopulations

func (s *SiteService) SetTargetPopulations(ctx context.Context, siteID uint32, pops []pc.TargetPopulation) error