db

Documentation

Index

• type Database
  • func New(logger logging.Logger, db database.Database) Database
  • func NewSql(logger logging.Logger, db database.Database) Database
• type Endpoint
• type SqlEndpoint
  • func (sql *SqlEndpoint) Scan(ctx context.Context, query *entities.ScanningQuery) chan *entities.ScanningResult[[]entities.Endpoint]

Types

type Database

type Database interface {
	Transaction(ctx context.Context, handler func(txctx context.Context) (interface{}, error)) (res interface{}, err error)
	Endpoint() Endpoint
}

func New

func New(logger logging.Logger, db database.Database) Database

func NewSql

func NewSql(logger logging.Logger, db database.Database) Database

type Endpoint

type Endpoint interface {
	Scan(ctx context.Context, query *entities.ScanningQuery) chan *entities.ScanningResult[[]entities.Endpoint]
}

type SqlEndpoint

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

func (*SqlEndpoint) Scan

func (sql *SqlEndpoint) Scan(ctx context.Context, query *entities.ScanningQuery) chan *entities.ScanningResult[[]entities.Endpoint]