db

Documentation

Index

• Variables
• type Database
  • func NewDatabase(details *config.DatabaseDetails, networkConfig *config.NetworkConfiguration) (Database, error)
• type Persistable

Variables

var DefaultConnectionDetails = &config.DatabaseDetails{
	Driver:      "clickhouse",
	Address:     "127.0.0.1:9000",
	User:        "username",
	Password:    "password",
	Database:    "akai_test",
	TLSrequired: false,
}

Types

type Database

type Database interface {
	Init(context.Context, map[string]struct{}) error
	Serve(context.Context) error
	Close(context.Context) error
	// tables's perspective
	GetAllTables() map[string]struct{}
	// blocks
	PersistNewBlock(context.Context, *models.Block) error
	GetSampleableBlocks(context.Context) ([]models.Block, error)
	GetAllBlocks(context.Context) ([]models.Block, error)
	GetLastBlock(context.Context) (models.Block, error)
	// sample items
	PersistNewSamplingItem(context.Context, *models.SamplingItem) error
	PersistNewSamplingItems(context.Context, []*models.SamplingItem) error
	GetSampleableItems(context.Context) ([]models.SamplingItem, error)
	// cell visists
	PersistNewSampleGenericVisit(context.Context, *models.SampleGenericVisit) error
	PersistNewSampleValueVisit(context.Context, *models.SampleValueVisit) error
	PersistNewPeerInfoVisit(context.Context, *models.PeerInfoVisit) error
	PersistNewIPNSRecordVisit(context.Context, *models.IPNSRecordVisit) error
}

func NewDatabase

func NewDatabase(details *config.DatabaseDetails, networkConfig *config.NetworkConfiguration) (Database, error)

type Persistable

type Persistable interface {
	TableName() string
	QueryValues() map[string]any
}