data

package

v0.0.0-...-9e464cf Latest Latest Go to latest Published: Aug 14, 2026 License: MIT Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/omalloc/probecube-console

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewAlertEvaluatorConfig(c *conf.Data) *biz.AlertEvaluatorConfig
func NewAlertRepo(txm orm.Transaction) biz.AlertRepo
func NewIPGeolocator() biz.IPGeolocator
func NewNATSClient(bc *conf.Data) (*nats.Conn, func(), error)
func NewNodeMessaging(conn *nats.Conn, store *nodeStore) biz.NodeMessaging
func NewNodeRepo(txm orm.Transaction) biz.NodeRepo
func NewNodeStore(repo biz.NodeRepo) *nodeStore
func NewProbeMessaging(conn *nats.Conn, store *nodeStore, nodeRepo biz.NodeRepo, ...) biz.ProbeMessaging
func NewRealtimeRepo(txm orm.Transaction) biz.RealtimeRepo
func NewTaskRepo(txm orm.Transaction) biz.TaskRepo
type Data
- func NewData(c *conf.Data, logger *slog.Logger) (*Data, func(), error)
- func (d *Data) GetDataSource() *gorm.DB
type DriverDialector

Constants ¶

View Source

const DialSysHeartbeatSubject = "dialsys.heartbeat"

View Source

const DialSysNodeMetadataSubject = "dialsys.node.metadata"

View Source

const DialSysProbeResultsSubject = "dialsys.probe.results"

View Source

const DialSysProbeTaskSubject = "dialsys.probe.task"

Variables ¶

View Source

var ErrNodeNotFound = errors.New("node not found")

View Source

var ProviderSet = wire.NewSet(
	NewData,
	NewAlertEvaluatorConfig,
	wire.Bind(new(orm.DataSourceManager), new(*Data)),
	orm.NewTransactionManager,

	NewNATSClient,

	NewIPGeolocator,

	NewTaskRepo,
	NewRealtimeRepo,
	NewAlertRepo,
	NewNodeRepo,
	NewNodeStore,

	NewNodeMessaging,
	NewProbeMessaging,
)

ProviderSet is data providers.

Functions ¶

func NewAlertEvaluatorConfig ¶

func NewAlertEvaluatorConfig(c *conf.Data) *biz.AlertEvaluatorConfig

func NewAlertRepo ¶

func NewAlertRepo(txm orm.Transaction) biz.AlertRepo

func NewIPGeolocator ¶

func NewIPGeolocator() biz.IPGeolocator

func NewNATSClient ¶

func NewNATSClient(bc *conf.Data) (*nats.Conn, func(), error)

func NewNodeMessaging ¶

func NewNodeMessaging(conn *nats.Conn, store *nodeStore) biz.NodeMessaging

func NewNodeRepo ¶

func NewNodeRepo(txm orm.Transaction) biz.NodeRepo

func NewNodeStore ¶

func NewNodeStore(repo biz.NodeRepo) *nodeStore

func NewProbeMessaging ¶

func NewProbeMessaging(conn *nats.Conn, store *nodeStore, nodeRepo biz.NodeRepo, taskRepo biz.TaskRepo) biz.ProbeMessaging

func NewRealtimeRepo ¶

func NewRealtimeRepo(txm orm.Transaction) biz.RealtimeRepo

func NewTaskRepo ¶

func NewTaskRepo(txm orm.Transaction) biz.TaskRepo

Types ¶

type Data ¶

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

Data .

func NewData ¶

func NewData(c *conf.Data, logger *slog.Logger) (*Data, func(), error)

NewData .

func (*Data) GetDataSource ¶

func (d *Data) GetDataSource() *gorm.DB

type DriverDialector ¶

type DriverDialector func(dsn string) gorm.Dialector

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL