database

package

Go to main page

Versions in this module

v5

v5.1.2

Apr 2, 2026

v5.1.1

Jan 21, 2026

v5.1.0

Sep 22, 2025

Changes in this version

+ var ZoneTransferTTLs = []string

+ func ValidateLogCombinations(hourMap map[string][]string) int

type ImportDatabase

+ IsSampleDB bool

v5.0.8

Aug 14, 2024

v5.0.7

Aug 1, 2024

Changes in this version

type ServerConn

+ func (server *ServerConn) CreateServerDBTables() error

v5.0.6

Jul 17, 2024

v5.0.5

Jul 17, 2024

Changes in this version

+ var ErrImportTwiceNonRolling = errors.New("cannot import more than once to a non-rolling database")

v5.0.4

Jul 10, 2024

v5.0.3

Jul 3, 2024

v5.0.2

Jul 3, 2024

Changes in this version

+ var AnalysisSnapshotAnalyzedAtTTLs = []string

+ var AnalysisSnapshotHourTTLs = []string

+ var ErrDatabaseNameEmpty = errors.New("database name cannot be empty")

+ var ErrDatabaseNotFound = errors.New("database does not exist")

+ var ErrInvalidDatabaseConnection = fmt.Errorf("database connection is nil")

+ var ErrInvalidMinMaxTimestamp = fmt.Errorf("invalid min or max timestamp")

+ var ErrMissingConfig = errors.New("config cannot be nil")

+ var ErrNoMetaDBImportRecordForDatabase = errors.New("no import record found for database")

+ var LogTableTTLs = []string

+ var LogTableViewsDayTTLs = []string

+ var LogTableViewsHourTTLs = []string

+ var MetaDatabaseTTLs = []string

+ var MetaDatabaseYearTTLS = []string

+ func DatabaseExists(conn driver.Conn, ctx context.Context, dbName string) (bool, error)

+ func GetFlatDatabaseList(dbs []ImportDatabase) []string

+ func GetRollingStatus(dbCtx context.Context, conn driver.Conn, dbName string) (bool, error)

+ func SensorDatabaseExists(conn driver.Conn, ctx context.Context, dbName string) (bool, error)

+ type BulkWriter struct

+ ProgChannel chan int

+ WriteChannel chan Data

+ WriteWg *errgroup.Group

+ func NewBulkWriter(db Database, conf *config.Config, numWorkers int, database string, ...) *BulkWriter

+ func (w *BulkWriter) Close()

+ func (w *BulkWriter) Start(id int)

+ type DB struct

+ Conn driver.Conn

+ ImportStartedAt time.Time

+ Rolling bool

+ func ConnectToDB(ctx context.Context, db string, cfg *config.Config, cancel context.CancelFunc) (*DB, error)

+ func SetUpNewImport(afs afero.Fs, cfg *config.Config, dbName string, rollingFlag bool, ...) (*DB, error)

+ func (db *DB) AddImportFinishedRecordToMetaDB(importID util.FixedString, minTS, maxTS time.Time) error

+ func (db *DB) AddImportStartRecordToMetaDB(importID util.FixedString) error

+ func (db *DB) CheckIfFilesWereAlreadyImported(fileMap map[string][]string) (int, error)

+ func (db *DB) GetBeaconMinMaxTimestamps() (time.Time, time.Time, bool, error)

+ func (db *DB) GetContext() context.Context

+ func (db *DB) GetNetworkSize(minTS time.Time) (uint64, error)

+ func (db *DB) GetSelectedDB() string

+ func (db *DB) GetTrueMinMaxTimestamps() (time.Time, time.Time, bool, bool, error)

+ func (db *DB) MarkFileImportedInMetaDB(hash util.FixedString, importID util.FixedString, path string) error

+ func (db *DB) QueryParameters(params clickhouse.Parameters) context.Context

+ func (db *DB) ResetTemporaryTables() error

+ func (db *DB) TruncateTmpLinkTables() error

+ type Data any

+ type Database interface

+ GetContext func() context.Context

+ QueryParameters func(clickhouse.Parameters) context.Context

+ type ImportDatabase struct

+ MaxTS time.Time

+ MinTS time.Time

+ Name string

+ Rolling bool

+ type MetaDBImportRecord struct

+ Database string

+ EndedAt time.Time

+ HoursSeen []time.Time

+ ImportID *util.FixedString

+ ImportVersion string

+ MaxOpenTimestamp time.Time

+ MaxTimestamp time.Time

+ MinOpenTimestamp time.Time

+ MinTimestamp time.Time

+ Rebuild bool

+ Rolling bool

+ StartedAt int64

+ type MetaDBImportedFile struct

+ Database string

+ Hash *util.FixedString

+ ImportID *util.FixedString

+ Path string

+ Timestamp time.Time

+ type ServerConn struct

+ Conn driver.Conn

+ func ConnectToServer(ctx context.Context, cfg *config.Config) (*ServerConn, error)

+ func (server *ServerConn) ClearMetaDBEntriesForDatabase(database string) error

+ func (server *ServerConn) DeleteSensorDB(database string) error

+ func (server *ServerConn) DropMultipleSensorDatabases(dbName string, wildcardStart, wildcardEnd bool) (int, error)

+ func (server *ServerConn) GetContext() context.Context

+ func (server *ServerConn) ListImportDatabases() ([]ImportDatabase, error)

+ func (server *ServerConn) QueryParameters(params clickhouse.Parameters) context.Context

+ type ValidMIMEType struct

+ Extension string

+ MIMEType string

Other modules containing this package

github.com/activecm/rita

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