database

package

v1.1.92 Latest Latest Go to latest Published: Dec 6, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/munnik/gosk

Documentation ¶

Index ¶

type BigCache
- func NewBigCache(c *config.BigCacheConfig) *BigCache
type DatabaseCountReader
type DatabaseReader
type DatabaseWriter
type PostgresqlDatabase
- func NewPostgresqlDatabase(c *config.PostgresqlConfig) *PostgresqlDatabase

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.1.28

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 ¶ added in v0.1.62

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 ¶ added in v0.1.51

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 ¶ added in v0.1.62

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

func (*PostgresqlDatabase) SelectCountPerUuid ¶ added in v0.1.62

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 ¶ added in v0.1.62

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

func (*PostgresqlDatabase) SelectFirstMappedDataPerOrigin ¶ added in v0.1.62

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 ¶ added in v0.1.31

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 ¶ added in v0.1.38

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL