canalyzecollect

type Config struct {
	DbURI    string
	Capturer string
}

type Database interface {
	Close() error                                                                               // Close the connection to the database
	Ping() (bool, error)                                                                        // Check that the database is still there
	AddContext(capturer string, captureName string, details string, target string) (int, error) // Create context entry
	AddCandumpFrame(packet string, context int) error                                           // Add unparsed data from SocketCan/Candump to the database
	AddRawFrame(frame canlib.RawCanFrame, context int) error                                    // Add raw frames to the database that have not been processed
	AddProcessedFrame(frame canlib.ProcessedCanFrame, context int) error                        // Add processed frames to the database
}

type PostgresDB struct {
	Con       *sql.DB
	Connected bool
	// contains filtered or unexported fields
}