mirror of
https://github.com/status-im/fathom.git
synced 2025-03-01 11:30:28 +00:00
67 lines
2.1 KiB
Go
67 lines
2.1 KiB
Go
package datastore
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/usefathom/fathom/pkg/datastore/sqlstore"
|
|
"github.com/usefathom/fathom/pkg/models"
|
|
)
|
|
|
|
// ErrNoResults is returned whenever a single-item query returns 0 results
|
|
var ErrNoResults = sqlstore.ErrNoResults // ???
|
|
|
|
// Datastore represents a database implementations
|
|
type Datastore interface {
|
|
// users
|
|
GetUser(int64) (*models.User, error)
|
|
GetUserByEmail(string) (*models.User, error)
|
|
SaveUser(*models.User) error
|
|
DeleteUser(*models.User) error
|
|
CountUsers() (int64, error)
|
|
|
|
// sites
|
|
GetSites() ([]*models.Site, error)
|
|
GetSite(id int64) (*models.Site, error)
|
|
SaveSite(s *models.Site) error
|
|
DeleteSite(s *models.Site) error
|
|
|
|
// site stats
|
|
GetSiteStats(int64, time.Time) (*models.SiteStats, error)
|
|
GetAggregatedSiteStats(int64, time.Time, time.Time) (*models.SiteStats, error)
|
|
SelectSiteStats(int64, time.Time, time.Time) ([]*models.SiteStats, error)
|
|
GetRealtimeVisitorCount(int64) (int64, error)
|
|
SaveSiteStats(*models.SiteStats) error
|
|
|
|
// pageviews
|
|
InsertPageviews([]*models.Pageview) error
|
|
UpdatePageviews([]*models.Pageview) error
|
|
GetPageview(string) (*models.Pageview, error)
|
|
GetProcessablePageviews() ([]*models.Pageview, error)
|
|
DeletePageviews([]*models.Pageview) error
|
|
|
|
// page stats
|
|
GetPageStats(int64, time.Time, int64, int64) (*models.PageStats, error)
|
|
SavePageStats(*models.PageStats) error
|
|
SelectAggregatedPageStats(int64, time.Time, time.Time, int64, int64) ([]*models.PageStats, error)
|
|
GetAggregatedPageStatsPageviews(int64, time.Time, time.Time) (int64, error)
|
|
|
|
// referrer stats
|
|
GetReferrerStats(int64, time.Time, int64, int64) (*models.ReferrerStats, error)
|
|
SaveReferrerStats(*models.ReferrerStats) error
|
|
SelectAggregatedReferrerStats(int64, time.Time, time.Time, int64, int64) ([]*models.ReferrerStats, error)
|
|
GetAggregatedReferrerStatsPageviews(int64, time.Time, time.Time) (int64, error)
|
|
|
|
// hostnames
|
|
HostnameID(name string) (int64, error)
|
|
PathnameID(name string) (int64, error)
|
|
|
|
// misc
|
|
Health() error
|
|
Close() error
|
|
}
|
|
|
|
// New instantiates a new datastore from the given configuration struct
|
|
func New(c *sqlstore.Config) Datastore {
|
|
return sqlstore.New(c)
|
|
}
|