database

Documentation

Index

• type BigCache
  • func NewBigCache(c *config.BigCacheConfig) *BigCache
  • func (c *BigCache) MappedIterator() *bigcache.EntryInfoIterator
  • func (c *BigCache) RawIterator() *bigcache.EntryInfoIterator
  • func (c *BigCache) ReadMapped(where string, arguments ...interface{}) ([]message.Mapped, error)
  • func (c *BigCache) ReadRaw(where string, arguments ...interface{}) ([]message.Raw, error)
  • func (c *BigCache) WriteMapped(mappedList ...message.Mapped) []message.Mapped
  • func (c *BigCache) WriteRaw(raw *message.Raw, returnChanges bool) []*message.Raw
• type DatabaseCountReader
• type DatabaseReader
• type DatabaseWriter
• type PostgresqlDatabase
  • func NewPostgresqlDatabase(c *config.PostgresqlConfig) *PostgresqlDatabase
  • func (db *PostgresqlDatabase) CreatePeriod(origin string, start time.Time, end time.Time, remote int) error
  • func (db *PostgresqlDatabase) DowngradeDatabase() error
  • func (db *PostgresqlDatabase) GetConnection() *pgxpool.Pool
  • func (db *PostgresqlDatabase) ReadMapped(appendToQuery string, arguments ...interface{}) ([]message.Mapped, error)
  • func (db *PostgresqlDatabase) ReadMappedCount(start time.Time, end time.Time) (int, error)
  • func (db *PostgresqlDatabase) SelectCompletePeriods(origin string) (map[time.Time]struct{}, error)
  • func (db *PostgresqlDatabase) SelectIncompletePeriods(origin string) (map[time.Time]struct{}, error)
  • func (db *PostgresqlDatabase) SelectLocalAndRemoteDataPoints(origin string, start time.Time, end time.Time) (int, int, error)
  • func (db *PostgresqlDatabase) UpdateLocalDataPoints(origin string, start time.Time, end time.Time, dataPoints int) error
  • func (db *PostgresqlDatabase) UpgradeDatabase() error
  • func (db *PostgresqlDatabase) WriteMapped(mapped message.Mapped)
  • func (db *PostgresqlDatabase) WriteRaw(raw message.Raw)

Types

type BigCache

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

func NewBigCache

func NewBigCache(c *config.BigCacheConfig) *BigCache

func (*BigCache) MappedIterator

func (c *BigCache) MappedIterator() *bigcache.EntryInfoIterator

func (*BigCache) RawIterator

func (c *BigCache) RawIterator() *bigcache.EntryInfoIterator

func (*BigCache) ReadMapped

func (c *BigCache) ReadMapped(where string, arguments ...interface{}) ([]message.Mapped, error)

func (*BigCache) ReadRaw

func (c *BigCache) ReadRaw(where string, arguments ...interface{}) ([]message.Raw, error)

func (*BigCache) WriteMapped

func (c *BigCache) WriteMapped(mappedList ...message.Mapped) []message.Mapped

func (*BigCache) WriteRaw

func (c *BigCache) WriteRaw(raw *message.Raw, returnChanges bool) []*message.Raw

type DatabaseCountReader

type DatabaseCountReader interface {
	ReadRawCount(where string, arguments ...interface{}) (int, error)
	ReadMappedCount(where string, arguments ...interface{}) (int, error)
}

type DatabaseReader

type DatabaseReader interface {
	ReadRaw(where string, arguments ...interface{}) ([]message.Raw, error)
	ReadMapped(where string, arguments ...interface{}) ([]message.Mapped, error)
}

type DatabaseWriter

type DatabaseWriter interface {
	WriteRaw(raw *message.Raw)
	WriteMapped(mapped *message.Mapped)
}

type PostgresqlDatabase

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

func NewPostgresqlDatabase

func NewPostgresqlDatabase(c *config.PostgresqlConfig) *PostgresqlDatabase

func (*PostgresqlDatabase) CreatePeriod

func (db *PostgresqlDatabase) CreatePeriod(origin string, start time.Time, end time.Time, remote int) error

Creates a period in the database, the default value for the local data points is -1

func (*PostgresqlDatabase) DowngradeDatabase

func (db *PostgresqlDatabase) DowngradeDatabase() error

func (*PostgresqlDatabase) GetConnection

func (db *PostgresqlDatabase) GetConnection() *pgxpool.Pool

func (*PostgresqlDatabase) ReadMapped

func (db *PostgresqlDatabase) ReadMapped(appendToQuery string, arguments ...interface{}) ([]message.Mapped, error)

func (*PostgresqlDatabase) ReadMappedCount

func (db *PostgresqlDatabase) ReadMappedCount(start time.Time, end time.Time) (int, error)

func (*PostgresqlDatabase) SelectCompletePeriods

func (db *PostgresqlDatabase) SelectCompletePeriods(origin string) (map[time.Time]struct{}, error)

Returns the start timestamp of each period that has the same or more local rows than remote

func (*PostgresqlDatabase) SelectIncompletePeriods

func (db *PostgresqlDatabase) SelectIncompletePeriods(origin string) (map[time.Time]struct{}, error)

Returns the start timestamp of each period that has the same or more local rows than remote

func (*PostgresqlDatabase) SelectLocalAndRemoteDataPoints

func (db *PostgresqlDatabase) SelectLocalAndRemoteDataPoints(origin string, start time.Time, end time.Time) (int, int, error)

func (*PostgresqlDatabase) UpdateLocalDataPoints

func (db *PostgresqlDatabase) UpdateLocalDataPoints(origin string, start time.Time, end time.Time, dataPoints int) error

Update the local data points in the database

func (*PostgresqlDatabase) UpgradeDatabase

func (db *PostgresqlDatabase) UpgradeDatabase() error

func (*PostgresqlDatabase) WriteMapped

func (db *PostgresqlDatabase) WriteMapped(mapped message.Mapped)

func (*PostgresqlDatabase) WriteRaw

func (db *PostgresqlDatabase) WriteRaw(raw message.Raw)