dao

Documentation

Index

• func Auth(user string, pwd string) auth
• func NewConnection(s server, a auth) (driver.Conn, error)
• func Opts(prefix string) *opts
• func Server(host string, port int16, db string) server
• type DAO
  • func New(conn clickhouse.Conn, opts *opts) *DAO
  • func (p *DAO) Close() error
  • func (p *DAO) DeleteOwnerHostname(hostname, username string) error
  • func (p *DAO) GetSubscription(id string) (*types.SubscriptionWithHostname, error)
  • func (p *DAO) GetSubscriptions() (map[string]*types.SubscriptionWithHostname, error)
  • func (p *DAO) InsertOwnerHostname(item types.OwnerHostname) error
  • func (p *DAO) Save(rumEvent beacon.RumEvent) error
  • func (p *DAO) SaveHost(event beacon.HostnameEvent) error
• type IDAO
• type MigrationDAO
  • func NewMigrationDAO(s server, a auth, opts *opts) *MigrationDAO
  • func (p *MigrationDAO) Migrate() error

Functions

func Auth

func Auth(user string, pwd string) auth

Auth creates the authentication options for persistance service nolint: revive

func NewConnection

func NewConnection(s server, a auth) (driver.Conn, error)

New Clickhouse connection nolint: revive

func Opts

func Opts(prefix string) *opts

Opts creates the options for persistance service nolint: revive

func Server

func Server(host string, port int16, db string) server

Server creates the datastore (click house) options nolint: revive

Types

type DAO

type DAO struct {
	// contains filtered or unexported fields
}

DAO is data access object for clickhouse database

func New

func New(conn clickhouse.Conn, opts *opts) *DAO

New creates persistance service nolint: revive

func (*DAO) Close

func (p *DAO) Close() error

Close the clickhouse connection

func (*DAO) DeleteOwnerHostname

func (p *DAO) DeleteOwnerHostname(hostname, username string) error

DeleteOwnerHostname deletes the hostname

func (*DAO) GetSubscription

func (p *DAO) GetSubscription(id string) (*types.SubscriptionWithHostname, error)

GetSubscription gets subscription by id

func (*DAO) GetSubscriptions

func (p *DAO) GetSubscriptions() (map[string]*types.SubscriptionWithHostname, error)

GetSubscriptions gets all subscriptions

func (*DAO) InsertOwnerHostname

func (p *DAO) InsertOwnerHostname(item types.OwnerHostname) error

InsertOwnerHostname inserts a new hostname

func (*DAO) Save

func (p *DAO) Save(rumEvent beacon.RumEvent) error

Save stores data into table in clickhouse database

func (*DAO) SaveHost

func (p *DAO) SaveHost(event beacon.HostnameEvent) error

SaveHost stores hostname data into table in clickhouse database

type IDAO

type IDAO interface {
	Close() error
	Save(rumEvent beacon.RumEvent) error
	SaveHost(event beacon.HostnameEvent) error
	InsertOwnerHostname(item types.OwnerHostname) error
	DeleteOwnerHostname(hostname, username string) error
	GetSubscriptions() (map[string]*types.SubscriptionWithHostname, error)
	GetSubscription(id string) (*types.SubscriptionWithHostname, error)
}

IDAO is data access object inteface

type MigrationDAO

type MigrationDAO struct {
	// contains filtered or unexported fields
}

MigrationDAO is data access object for clickhouse database

func NewMigrationDAO

func NewMigrationDAO(s server, a auth, opts *opts) *MigrationDAO

New creates persistance service nolint: revive

func (*MigrationDAO) Migrate

func (p *MigrationDAO) Migrate() error

Migrate applies all pending database migrations