level1

Documentation

Index

• type Database
  • func (db *Database) Close() error
  • func (db *Database) DeleteExpiredLevel1Keys(ctx context.Context, cutoff time.Time) (int, error)
  • func (db *Database) GetLevel1Key(ctx context.Context, meta drkey.Level1Meta) (drkey.Level1Key, error)
  • func (db *Database) InsertLevel1Key(ctx context.Context, key drkey.Level1Key) error
  • func (db *Database) SetMaxIdleConns(maxIdleConns int)
  • func (db *Database) SetMaxOpenConns(maxOpenConns int)
• type Metrics
  • func (m *Metrics) Observe(ctx context.Context, op string, action func(context.Context) error)

Types

type Database

type Database struct {
	Backend drkey.Level1DB
	Metrics *Metrics
}

func (*Database) Close

func (db *Database) Close() error

func (*Database) DeleteExpiredLevel1Keys

func (db *Database) DeleteExpiredLevel1Keys(ctx context.Context,
	cutoff time.Time) (int, error)

func (*Database) GetLevel1Key

func (db *Database) GetLevel1Key(
	ctx context.Context,
	meta drkey.Level1Meta,
) (drkey.Level1Key, error)

func (*Database) InsertLevel1Key

func (db *Database) InsertLevel1Key(ctx context.Context, key drkey.Level1Key) error

func (*Database) SetMaxIdleConns

func (db *Database) SetMaxIdleConns(maxIdleConns int)

func (*Database) SetMaxOpenConns

func (db *Database) SetMaxOpenConns(maxOpenConns int)

type Metrics

type Metrics struct {
	QueriesTotal func(op, result string) metrics.Counter
}

func (*Metrics) Observe

func (m *Metrics) Observe(ctx context.Context, op string, action func(context.Context) error)