Skip to content

Add new database type

Write a new package to implement the interface database.Connection:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
type Connection interface {
    InsertNode(node *runtime.Node)

    InsertLink(*runtime.Link, time.Time)

    InsertGlobals(*runtime.GlobalStats, time.Time, string)

    PruneNodes(deleteAfter time.Duration)

    Close()
}

InsertNode is stores statistics per node

InsertLink is stores statistics per link

InsertGlobals is stores global statistics (by site_code, and "global" like in runtime.GLOBAL_SITE overall sites).

PruneNodes is prunes historical per-node data

Close is called during shutdown of Yanic.

For startup, you need to bind your database type by calling database.RegisterAdapter("typeofdatabase",ConnectFunction)

it should be in the func init() {} of your package.

The typeofdatabase is used as mapping in the configuration [[database.connection.typeofdatabase]] the map[string]interface{} of the content are parsed to the ConnectFunction and on of your implemented Connection or a error is needed as result.

Short: the function signature of ConnectFunction should be func Connect(configuration interface{}) (Connection, error)

At last add you import string to compile the your database as well in this all package.

TIP: take a look in the easy database type logging.