func()

in pkg/mem/upstream.go [27:37]

• 11 lines of code
• 3 McCabe index (conditional complexity)

func (db *UpstreamDB) Insert() error {
	txn := DB.Txn(true)
	defer txn.Abort()
	for _, r := range db.Upstreams {
		if err := txn.Insert(UpstreamTable, r); err != nil {
			return err
		}
	}
	txn.Commit()
	return nil
}