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) CreateMissingRemoteOrigins(epoch time.Time, duration time.Duration) error
  • func (db *PostgresqlDatabase) CreateTransferRequests(appendToQuery string, arguments ...interface{}) ([]message.TransferRequest, error)
  • func (db *PostgresqlDatabase) DowngradeDatabase() error
  • func (db *PostgresqlDatabase) GetConnection() *pgxpool.Pool
  • func (db *PostgresqlDatabase) InsertRemoteData(message message.TransferRequest)
  • func (db *PostgresqlDatabase) ReadMapped(appendToQuery string, arguments ...interface{}) ([]message.Mapped, error)
  • func (db *PostgresqlDatabase) ReadMappedCount(appendToQuery string, arguments ...interface{}) (int, error)
  • func (db *PostgresqlDatabase) ReadRawCount(appendToQuery string, arguments ...interface{}) (int, error)
  • func (db *PostgresqlDatabase) ReadRemoteOrigins() ([]string, error)
  • func (db *PostgresqlDatabase) UpdateRemoteDataLocalPoints(message message.TransferRequest)
  • func (db *PostgresqlDatabase) UpdateRemoteDataRemotePoints(message message.TransferRequest)
  • 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) CreateMissingRemoteOrigins

func (db *PostgresqlDatabase) CreateMissingRemoteOrigins(epoch time.Time, duration time.Duration) error

func (*PostgresqlDatabase) CreateTransferRequests

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

func (*PostgresqlDatabase) DowngradeDatabase

func (db *PostgresqlDatabase) DowngradeDatabase() error

func (*PostgresqlDatabase) GetConnection

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

func (*PostgresqlDatabase) InsertRemoteData

func (db *PostgresqlDatabase) InsertRemoteData(message message.TransferRequest)

func (*PostgresqlDatabase) ReadMapped

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

func (*PostgresqlDatabase) ReadMappedCount

func (db *PostgresqlDatabase) ReadMappedCount(appendToQuery string, arguments ...interface{}) (int, error)

func (*PostgresqlDatabase) ReadRawCount

func (db *PostgresqlDatabase) ReadRawCount(appendToQuery string, arguments ...interface{}) (int, error)

func (*PostgresqlDatabase) ReadRemoteOrigins

func (db *PostgresqlDatabase) ReadRemoteOrigins() ([]string, error)

func (*PostgresqlDatabase) UpdateRemoteDataLocalPoints

func (db *PostgresqlDatabase) UpdateRemoteDataLocalPoints(message message.TransferRequest)

func (*PostgresqlDatabase) UpdateRemoteDataRemotePoints

func (db *PostgresqlDatabase) UpdateRemoteDataRemotePoints(message message.TransferRequest)

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)