data

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

const DialSysHeartbeatSubject = "dialsys.heartbeat"

const DialSysNodeMetadataSubject = "dialsys.node.metadata"

const DialSysProbeResultsSubject = "dialsys.probe.results"

const DialSysProbeTaskSubject = "dialsys.probe.task"

Variables

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

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