server

type AsnStorer interface {
	StartAsnLoad() func(*error)
	UpsertAsn(context.Context, model.Asn) error
	GetAsn(context.Context, string) (model.Asn, error)
}

type Config struct {
	ConfigDirectory string
	Store           *Store
	Wui             *WuiConfig
	Tui             *TuiConfig
	Bus             *bus.Config
	Discovery       *discovery.Config
	Pinger          *pinger.Config
	Enrichment      *enrichment.Config
	NetFlows        *netflows.Config
	Asn             *asn.Config
	Oui             *oui.Config
}

type DeviceStorer interface {
	AddDevice(context.Context, model.Device) error
	RemoveDeviceByAddr(context.Context, model.Addr) error
	UpdateDevice(context.Context, model.Device) (bool, error)
	GetDeviceByAddr(context.Context, model.Addr) (model.Device, error)
	GetFilteredDevices(context.Context, model.DeviceFilter) []model.Device
	ListDevices(context.Context) []model.Device
	CountDevices(context.Context) int
}

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

type MasonInternalsView struct {
	NumberOfGoProcs int

	NetworkStoreCount int
	DeviceStoreCount  int

	DiscoveryMaxWorkers    int
	EnrichmentMaxWorkers   int
	EnrichmentBackPressure int
	PortScanMaxWorkers     int
	PingerMaxWorkers       int

	AddressScanActive  int
	DeviceEnrichActive int
	PerfPingActive     int
	NetworkScanActive  int

	BusBackPressure int

	CurrentNetworkScan string
	Events             []bus.HistoricalEvent
	Errors             []bus.HistoricalError

	Memstats  runtime.MemStats
	Buildinfo debug.BuildInfo
}

type NetflowStorer interface {
	AsnStorer
	AddNetflows(context.Context, []model.IpFlow) error
	GetNetflows(context.Context, model.Addr) ([]model.IpFlow, error)
	FlowSummaryByIP(context.Context, model.Addr) ([]model.FlowSummaryForAddrByIP, error)
	FlowSummaryByName(context.Context, model.Addr) ([]model.FlowSummaryForAddrByName, error)
	FlowSummaryByCountry(
		context.Context,
		model.Addr,
	) ([]model.FlowSummaryForAddrByCountry, error)
}

type NetworkStorer interface {
	AddNetwork(context.Context, model.Network) error
	RemoveNetworkByName(context.Context, string) error
	UpdateNetwork(context.Context, model.Network) error
	GetNetworkByName(context.Context, string) (model.Network, error)
	GetFilteredNetworks(context.Context, model.NetworkFilter) []model.Network
	ListNetworks(context.Context) []model.Network
	CountNetworks(context.Context) int
}

type Option func(*Options)

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

type PerformancePingStorer interface {
	WritePerformancePing(
		context.Context,
		time.Time,
		model.Device,
		nettools.Icmp4EchoResponseStatistics,
	) error
	ReadPerformancePings(
		context.Context,
		model.Device,
		time.Duration,
	) ([]pinger.Point, error)
}

type Store struct {
	Combo  *combostore.Config
	Sqlite *sqlitestore.Config
}

type Storer interface {
	NetworkStorer
	DeviceStorer
	PerformancePingStorer
	Close() error
}

type TuiConfig struct {
	Enabled       bool
	ListenAddress string
	KeyDirectory  string
}

type WuiConfig struct {
	Enabled       bool
	ListenAddress string
}