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) CreateRemoteCount(start time.Time, origin string, count int) error
  • func (db *PostgresqlDatabase) DowngradeDatabase() error
  • func (db *PostgresqlDatabase) GetConnection() *pgxpool.Pool
  • func (db *PostgresqlDatabase) LogTransferRequest(origin string, message interface{}) error
  • func (db *PostgresqlDatabase) ReadMapped(appendToQuery string, arguments ...interface{}) ([]message.Mapped, error)
  • func (db *PostgresqlDatabase) SelectCountMapped(origin string, start time.Time) (int, error)
  • func (db *PostgresqlDatabase) SelectCountPerUuid(origin string, start time.Time) (map[uuid.UUID]int, error)
  • func (db *PostgresqlDatabase) SelectExistingRemoteCounts(from time.Time) (map[string]map[time.Time]struct{}, error)
  • func (db *PostgresqlDatabase) SelectFirstMappedDataPerOrigin() (map[string]time.Time, error)
  • func (db *PostgresqlDatabase) SelectIncompletePeriods() (map[string][]time.Time, error)
  • func (db *PostgresqlDatabase) UpgradeDatabase() error
  • func (db *PostgresqlDatabase) WriteMapped(mapped message.Mapped)
  • func (db *PostgresqlDatabase) WriteRaw(raw message.Raw)
  • func (db *PostgresqlDatabase) WriteSingleValueMapped(svm message.SingleValueMapped)

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) CreateRemoteCount

func (db *PostgresqlDatabase) CreateRemoteCount(start time.Time, origin string, count 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) LogTransferRequest

func (db *PostgresqlDatabase) LogTransferRequest(origin string, message interface{}) error

Log the transfer request

func (*PostgresqlDatabase) ReadMapped

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

func (*PostgresqlDatabase) SelectCountMapped

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

func (*PostgresqlDatabase) SelectCountPerUuid

func (db *PostgresqlDatabase) SelectCountPerUuid(origin string, start time.Time) (map[uuid.UUID]int, error)

Return the number of rows per (raw) uuid in the mapped_data table

func (*PostgresqlDatabase) SelectExistingRemoteCounts

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

func (*PostgresqlDatabase) SelectFirstMappedDataPerOrigin

func (db *PostgresqlDatabase) SelectFirstMappedDataPerOrigin() (map[string]time.Time, error)

Returns the start timestamp of each period that has local count but no remote count

func (*PostgresqlDatabase) SelectIncompletePeriods

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

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

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)

func (*PostgresqlDatabase) WriteSingleValueMapped

func (db *PostgresqlDatabase) WriteSingleValueMapped(svm message.SingleValueMapped)