db

Documentation

Index

• type Application
• type Database
  • func New(logger logging.Logger, db database.Database) Database
  • func NewSql(logger logging.Logger, db database.Database) Database
• type SqlApplication
  • func (sql *SqlApplication) GetRoutes(ctx context.Context, ids []string) (map[string][]routing.Route, error)
  • func (sql *SqlApplication) Scan(ctx context.Context, query *entities.ScanningQuery) chan *entities.ScanningResult[[]entities.Application]
• type SqlWorkspace
  • func (sql *SqlWorkspace) Get(ctx context.Context, id string) (*entities.Workspace, error)
• type Workspace

Types

type Application

type Application interface {
	Scan(ctx context.Context, query *entities.ScanningQuery) chan *entities.ScanningResult[[]entities.Application]
	GetRoutes(ctx context.Context, ids []string) (map[string][]routing.Route, error)
}

type Database

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

func New

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

func NewSql

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

type SqlApplication

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

func (*SqlApplication) GetRoutes

func (sql *SqlApplication) GetRoutes(ctx context.Context, ids []string) (map[string][]routing.Route, error)

func (*SqlApplication) Scan

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

type SqlWorkspace

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

func (*SqlWorkspace) Get

func (sql *SqlWorkspace) Get(ctx context.Context, id string) (*entities.Workspace, error)

type Workspace

type Workspace interface {
	Get(ctx context.Context, id string) (*entities.Workspace, error)
}