144 lines
4.2 KiB
Go
144 lines
4.2 KiB
Go
// Package dis provides the main distillery
|
|
package dis
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/control"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/control/home"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/control/info"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/control/static"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/exporter"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/exporter/logger"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/instances"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/instances/malt"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/meta"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/resolver"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/sql"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/ssh"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/triplestore"
|
|
"github.com/FAU-CDI/wisski-distillery/internal/dis/component/web"
|
|
"github.com/FAU-CDI/wisski-distillery/pkg/lazy"
|
|
)
|
|
|
|
// Distillery represents a WissKI Distillery
|
|
//
|
|
// It is the main structure used to interact with different components.
|
|
type Distillery struct {
|
|
// core holds the core of the distillery
|
|
component.Still
|
|
|
|
// internal context for the distillery
|
|
context context.Context
|
|
|
|
// Upstream holds information to connect to the various running
|
|
// distillery components.
|
|
//
|
|
// NOTE(twiesing): This is intended to eventually allow full remote management of the distillery.
|
|
// But for now this will just hold upstream configuration.
|
|
Upstream Upstream
|
|
|
|
// pool holds all components
|
|
pool lazy.Pool[component.Component, component.Still]
|
|
poolInit sync.Once
|
|
}
|
|
|
|
// Upstream contains the configuration for accessing remote configuration.
|
|
type Upstream struct {
|
|
SQL string
|
|
Triplestore string
|
|
}
|
|
|
|
// Context returns a new Context belonging to this distillery
|
|
func (dis *Distillery) Context() context.Context {
|
|
return dis.context
|
|
}
|
|
|
|
//
|
|
// PUBLIC COMPONENT GETTERS
|
|
//
|
|
|
|
func (dis *Distillery) Control() *control.Control {
|
|
return export[*control.Control](dis)
|
|
}
|
|
func (dis *Distillery) Resolver() *resolver.Resolver {
|
|
return export[*resolver.Resolver](dis)
|
|
}
|
|
func (dis *Distillery) SSH() *ssh.SSH {
|
|
return export[*ssh.SSH](dis)
|
|
}
|
|
func (dis *Distillery) SQL() *sql.SQL {
|
|
return export[*sql.SQL](dis)
|
|
}
|
|
func (dis *Distillery) Triplestore() *triplestore.Triplestore {
|
|
return export[*triplestore.Triplestore](dis)
|
|
}
|
|
func (dis *Distillery) Instances() *instances.Instances {
|
|
return export[*instances.Instances](dis)
|
|
}
|
|
func (dis *Distillery) Exporter() *exporter.Exporter {
|
|
return export[*exporter.Exporter](dis)
|
|
}
|
|
|
|
func (dis *Distillery) Installable() []component.Installable {
|
|
return exportAll[component.Installable](dis)
|
|
}
|
|
func (dis *Distillery) Updatable() []component.Updatable {
|
|
return exportAll[component.Updatable](dis)
|
|
}
|
|
func (dis *Distillery) Provisionable() []component.Provisionable {
|
|
return exportAll[component.Provisionable](dis)
|
|
}
|
|
|
|
//
|
|
// All components
|
|
// THESE SHOULD NEVER BE CALLED DIRECTLY
|
|
//
|
|
|
|
func (dis *Distillery) allComponents() []initFunc {
|
|
return []initFunc{
|
|
auto[*web.Web],
|
|
|
|
auto[*ssh.SSH],
|
|
|
|
manual(func(ts *triplestore.Triplestore) {
|
|
ts.BaseURL = "http://" + dis.Upstream.Triplestore
|
|
ts.PollContext = dis.Context()
|
|
ts.PollInterval = time.Second
|
|
}),
|
|
manual(func(sql *sql.SQL) {
|
|
sql.ServerURL = dis.Upstream.SQL
|
|
sql.PollContext = dis.Context()
|
|
sql.PollInterval = time.Second
|
|
}),
|
|
|
|
// instainces
|
|
auto[*instances.Instances],
|
|
auto[*meta.Meta],
|
|
auto[*malt.Malt],
|
|
|
|
// Snapshots
|
|
auto[*exporter.Exporter],
|
|
auto[*logger.Logger],
|
|
auto[*exporter.Config],
|
|
auto[*exporter.Bookkeeping],
|
|
auto[*exporter.Filesystem],
|
|
auto[*exporter.Pathbuilders],
|
|
|
|
// Control server
|
|
auto[*control.Control],
|
|
auto[*static.Static],
|
|
manual(func(home *home.Home) {
|
|
home.RefreshInterval = time.Minute
|
|
}),
|
|
manual(func(resolver *resolver.Resolver) {
|
|
resolver.RefreshInterval = time.Minute
|
|
}),
|
|
manual(func(info *info.Info) {
|
|
info.Analytics = &dis.pool.Analytics
|
|
}),
|
|
}
|
|
}
|