conntracker

package

v1.1.1 Latest Latest Go to latest Published: Oct 16, 2024 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/epfl-si/mariadb-conntracker

Links

Open Source Insights

Documentation ¶

Index ¶

func FilterAndSortNewFiles(cfg Config, lastProcessedTime time.Time) ([]string, time.Time, error)
func GetLastProcessedTime(cfg Config, db *sql.DB) (time.Time, error)
func InitDatabase(db *sql.DB) error
func InsertOrUpdateAccounts(cfg Config, db *sql.DB, accounts map[string]AccountInfo) (uint64, uint64, error)
func OpenOrCreateDB(cfg Config) (*sql.DB, error)
func ParseAuditFile(cfg Config, filename string) (map[string]AccountInfo, error)
func ProcessFilesParallel(cfg Config, filenames []string) (map[string]AccountInfo, error)
func UpdateLastProcessedTime(cfg Config, db *sql.DB, lastProcessedTime time.Time) error
type AccountInfo
type ChunkResult
type Config
- func InitConfig() (Config, error)
type FileInfo

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FilterAndSortNewFiles ¶

func FilterAndSortNewFiles(cfg Config, lastProcessedTime time.Time) ([]string, time.Time, error)

func GetLastProcessedTime ¶

func GetLastProcessedTime(cfg Config, db *sql.DB) (time.Time, error)

func InitDatabase ¶

func InitDatabase(db *sql.DB) error

func InsertOrUpdateAccounts ¶

func InsertOrUpdateAccounts(cfg Config, db *sql.DB, accounts map[string]AccountInfo) (uint64, uint64, error)

func OpenOrCreateDB ¶

func OpenOrCreateDB(cfg Config) (*sql.DB, error)

func ParseAuditFile ¶

func ParseAuditFile(cfg Config, filename string) (map[string]AccountInfo, error)

func ProcessFilesParallel ¶

func ProcessFilesParallel(cfg Config, filenames []string) (map[string]AccountInfo, error)

func UpdateLastProcessedTime ¶

func UpdateLastProcessedTime(cfg Config, db *sql.DB, lastProcessedTime time.Time) error

Types ¶

type AccountInfo ¶

type AccountInfo struct {
	Name     string
	Host     string
	LastSeen time.Time
}

type ChunkResult ¶

type ChunkResult struct {
	Accounts map[string]AccountInfo // key is "username@hostname"
}

type Config ¶

type Config struct {
	AuditLogPath    string
	SqlitePath      string
	TimeFormatAudit string
	TimeFormatDB    string
	TimeLocation    *time.Location
	MaxWorkers      int
	LogLevel        slog.Level
}

func InitConfig ¶

func InitConfig() (Config, error)

type FileInfo ¶

type FileInfo struct {
	Path    string
	ModTime time.Time
}

Source Files ¶

View all Source files

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