Versions in this module Expand all Collapse all v0 v0.0.2 Sep 14, 2024 Changes in this version + func ProcessAssetsWithSource(e *et.Event, findings []*Finding, src *dbt.Asset, pname, hname string) + type Finding struct + From *dbt.Asset + FromName string + Rel string + To *dbt.Asset + ToName string v0.0.1 Sep 7, 2024 Changes in this version + const MaxHandlerInstances + func AppendToDBQueue(callback func()) + func AssetMonitoredWithinTTL(session et.Session, asset, src *dbt.Asset, since time.Time) bool + func EmailToOAMEmailAddress(e string) *contact.EmailAddress + func FullNameToPerson(raw string) *people.Person + func GetAPI(name string, e *et.Event) (string, error) + func GetSource(session et.Session, psrc *source.Source) *dbt.Asset + func IPToNetblock(session et.Session, ip *oamnet.IPAddress) (*oamnet.Netblock, error) + func IPToNetblockWithAttempts(session et.Session, ip *oamnet.IPAddress, num int, d time.Duration) (*oamnet.Netblock, error) + func IsAddressInScope(session et.Session, ip *oamnet.IPAddress) bool + func IsCNAME(session et.Session, name *domain.FQDN) (*domain.FQDN, bool) + func MarkAssetMonitored(session et.Session, asset, src *dbt.Asset) + func NameIPAddresses(session et.Session, name *domain.FQDN) []*oamnet.IPAddress + func NameResolved(session et.Session, name *domain.FQDN) bool + func NumResolvers() int + func PerformQuery(name string, qtype uint16) ([]*resolve.ExtractedAnswer, error) + func PhoneToOAMPhone(phone, ext, country string) *contact.Phone + func ProcessEmailsWithSource(e *et.Event, assets []*dbt.Asset, src *dbt.Asset) + func ProcessFQDNsWithSource(e *et.Event, assets []*dbt.Asset, src *dbt.Asset) + func RawURLToOAM(raw string) *oamurl.URL + func ScrapeSubdomainNames(s string) []string + func Shutdown() + func SourceToAssetsWithinTTL(session et.Session, name, atype string, src *dbt.Asset, since time.Time) []*dbt.Asset + func StoreEmailsWithSource(session et.Session, emails []string, src *dbt.Asset, plugin, handler string) []*dbt.Asset + func StoreFQDNsWithSource(session et.Session, names []string, src *dbt.Asset, plugin, handler string) []*dbt.Asset + func StreetAddressToLocation(address string) *contact.Location + func TTLStartTime(c *config.Config, from, to, plugin string) (time.Time, error) + func TimeToJSONString(t *time.Time) string + type FQDNFilter map[string]interface + func (r FQDNFilter) Close() + func (r FQDNFilter) Insert(fqdn string) + func (r FQDNFilter) Prune(limit int) + func (r FQDNFilter) Slice() []string + func NewFQDNFilter() FQDNFilter