configdb

Documentation

Index

• func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
• type Database
  • func (d *Database) SelectServerInstance(ctx context.Context, serverName string) (instance int64, err error)
  • func (d *Database) SelectServerNames(ctx context.Context) (results []string, err error)
  • func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)
  • func (d *Database) UpsertServerInstance(ctx context.Context, nid int64, serverName string) error
  • func (d *Database) UpsertServerName(ctx context.Context, nid int64, serverName string) error

Functions

func NewDatabase

func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)

NewDatabase creates a new device database

Types

type Database

type Database struct {
	AsyncSave bool
	// contains filtered or unexported fields
}

func (*Database) SelectServerInstance

func (d *Database) SelectServerInstance(
	ctx context.Context,
	serverName string,
) (instance int64, err error)

func (*Database) SelectServerNames

func (d *Database) SelectServerNames(
	ctx context.Context,
) (results []string, err error)

func (*Database) SetGauge

func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)

func (*Database) UpsertServerInstance

func (d *Database) UpsertServerInstance(
	ctx context.Context,
	nid int64,
	serverName string,
) error

func (*Database) UpsertServerName

func (d *Database) UpsertServerName(
	ctx context.Context,
	nid int64,
	serverName string,
) error