Documentation ¶
Index ¶
- Variables
- func AnnotateInputDecode(conf *GlobalConf, inChan <-chan string, outChan chan<- inProcessIP, ...)
- func AnnotateOutputEncode(conf *GlobalConf, inChan <-chan inProcessIP, outChan chan<- string, ...)
- func AnnotateRead(conf *GlobalConf, path string, in chan<- string)
- func AnnotateWorker(a Annotator, inChan <-chan inProcessIP, outChan chan<- inProcessIP, ...)
- func AnnotateWrite(path string, out <-chan string, wg *sync.WaitGroup)
- func DoAnnotation(conf *GlobalConf)
- func RegisterAnnotator(af AnnotatorFactory)
- type Annotator
- type AnnotatorFactory
- type BasePluginConf
- type GeoIP2Annotator
- type GeoIP2AnnotatorFactory
- func (a *GeoIP2AnnotatorFactory) AddFlags(flags *flag.FlagSet)
- func (a *GeoIP2AnnotatorFactory) Close() error
- func (a *GeoIP2AnnotatorFactory) GetWorkers() int
- func (a *GeoIP2AnnotatorFactory) Initialize(conf *GlobalConf) error
- func (a *GeoIP2AnnotatorFactory) IsEnabled() bool
- func (a *GeoIP2AnnotatorFactory) MakeAnnotator(i int) Annotator
- type GeoIP2City
- type GeoIP2Country
- type GeoIP2LatLong
- type GeoIP2Output
- type GeoIP2Postal
- type GeoIP2Traits
- type GeoIPASNAnnotator
- type GeoIPASNAnnotatorFactory
- func (fact *GeoIPASNAnnotatorFactory) AddFlags(flags *flag.FlagSet)
- func (fact *GeoIPASNAnnotatorFactory) Close() error
- func (fact *GeoIPASNAnnotatorFactory) GetWorkers() int
- func (fact *GeoIPASNAnnotatorFactory) Initialize(conf *GlobalConf) error
- func (fact *GeoIPASNAnnotatorFactory) IsEnabled() bool
- func (fact *GeoIPASNAnnotatorFactory) MakeAnnotator(i int) Annotator
- type GeoIPASNOutput
- type GlobalConf
- type RDNSAnnotator
- type RDNSAnnotatorFactory
- func (a *RDNSAnnotatorFactory) AddFlags(flags *flag.FlagSet)
- func (a *RDNSAnnotatorFactory) Close() error
- func (a *RDNSAnnotatorFactory) GetWorkers() int
- func (a *RDNSAnnotatorFactory) Initialize(conf *GlobalConf) error
- func (a *RDNSAnnotatorFactory) IsEnabled() bool
- func (a *RDNSAnnotatorFactory) MakeAnnotator(i int) Annotator
- type RoutingAnnotator
- type RoutingAnnotatorFactory
- func (a *RoutingAnnotatorFactory) AddFlags(flags *flag.FlagSet)
- func (a *RoutingAnnotatorFactory) Close() error
- func (a *RoutingAnnotatorFactory) GetWorkers() int
- func (a *RoutingAnnotatorFactory) Initialize(conf *GlobalConf) error
- func (a *RoutingAnnotatorFactory) IsEnabled() bool
- func (a *RoutingAnnotatorFactory) MakeAnnotator(i int) Annotator
Constants ¶
This section is empty.
Variables ¶
View Source
var Annotators []AnnotatorFactory
Functions ¶
func AnnotateInputDecode ¶
func AnnotateInputDecode(conf *GlobalConf, inChan <-chan string, outChan chan<- inProcessIP, wg *sync.WaitGroup, i int)
multiple workers that decode raw lines from AnnotateRead from JSON/CSV into native golang objects
func AnnotateOutputEncode ¶
func AnnotateOutputEncode(conf *GlobalConf, inChan <-chan inProcessIP, outChan chan<- string, wg *sync.WaitGroup, i int)
func AnnotateRead ¶
func AnnotateRead(conf *GlobalConf, path string, in chan<- string)
single worker that reads from file and queues raw lines
func AnnotateWorker ¶
func DoAnnotation ¶
func DoAnnotation(conf *GlobalConf)
func RegisterAnnotator ¶
func RegisterAnnotator(af AnnotatorFactory)
Types ¶
type AnnotatorFactory ¶
type BasePluginConf ¶
type GeoIP2Annotator ¶
type GeoIP2Annotator struct { Factory *GeoIP2AnnotatorFactory Reader *geoip2.Reader Id int }
func (*GeoIP2Annotator) Annotate ¶
func (a *GeoIP2Annotator) Annotate(ip net.IP) interface{}
func (*GeoIP2Annotator) Close ¶
func (a *GeoIP2Annotator) Close() error
func (*GeoIP2Annotator) GeoIP2FillStruct ¶
func (a *GeoIP2Annotator) GeoIP2FillStruct(in *geoip2.City) *GeoIP2Output
func (*GeoIP2Annotator) GetFieldName ¶
func (a *GeoIP2Annotator) GetFieldName() string
func (*GeoIP2Annotator) Initialize ¶
func (a *GeoIP2Annotator) Initialize() error
type GeoIP2AnnotatorFactory ¶
type GeoIP2AnnotatorFactory struct { BasePluginConf Path string Mode string Language string RawInclude string Conf *GlobalConf // what data to include IncludeCity bool IncludeCountry bool IncludeContinent bool IncludePostal bool IncludeLatLong bool IncludeTraits bool IncludeSubdivisions bool IncludeRepresentedCountry bool IncludeRegisteredCountry bool }
func (*GeoIP2AnnotatorFactory) AddFlags ¶
func (a *GeoIP2AnnotatorFactory) AddFlags(flags *flag.FlagSet)
GeoIP2 Annotator Factory (Global)
func (*GeoIP2AnnotatorFactory) Close ¶
func (a *GeoIP2AnnotatorFactory) Close() error
func (*GeoIP2AnnotatorFactory) GetWorkers ¶
func (a *GeoIP2AnnotatorFactory) GetWorkers() int
func (*GeoIP2AnnotatorFactory) Initialize ¶
func (a *GeoIP2AnnotatorFactory) Initialize(conf *GlobalConf) error
func (*GeoIP2AnnotatorFactory) IsEnabled ¶
func (a *GeoIP2AnnotatorFactory) IsEnabled() bool
func (*GeoIP2AnnotatorFactory) MakeAnnotator ¶
func (a *GeoIP2AnnotatorFactory) MakeAnnotator(i int) Annotator
type GeoIP2City ¶
type GeoIP2Country ¶
type GeoIP2LatLong ¶
type GeoIP2Output ¶
type GeoIP2Output struct { City *GeoIP2City `json:"city,omitempty"` Country *GeoIP2Country `json:"country,omitempty"` Continent *GeoIP2Country `json:"continent,omitempty"` Postal *GeoIP2Postal `json:"postal,omitempty"` LatLong *GeoIP2LatLong `json:"latlong,omitempty"` RepresentedCountry *GeoIP2Country `json:"represented_country,omitempty"` RegisteredCountry *GeoIP2Country `json:"represented_country,omitempty"` Traits *GeoIP2Traits `json:"metadata,omitempty"` }
type GeoIP2Postal ¶
type GeoIP2Postal struct {
Code string `json:"code,omitempty"`
}
type GeoIP2Traits ¶
type GeoIPASNAnnotator ¶
type GeoIPASNAnnotator struct { Factory *GeoIPASNAnnotatorFactory Reader *geoip2.Reader Id int }
func (*GeoIPASNAnnotator) Annotate ¶
func (anno *GeoIPASNAnnotator) Annotate(ip net.IP) interface{}
func (*GeoIPASNAnnotator) Close ¶
func (anno *GeoIPASNAnnotator) Close() error
func (*GeoIPASNAnnotator) GetFieldName ¶
func (anno *GeoIPASNAnnotator) GetFieldName() string
func (*GeoIPASNAnnotator) Initialize ¶
func (anno *GeoIPASNAnnotator) Initialize() error
type GeoIPASNAnnotatorFactory ¶
type GeoIPASNAnnotatorFactory struct { BasePluginConf Path string Mode string }
func (*GeoIPASNAnnotatorFactory) AddFlags ¶
func (fact *GeoIPASNAnnotatorFactory) AddFlags(flags *flag.FlagSet)
func (*GeoIPASNAnnotatorFactory) Close ¶
func (fact *GeoIPASNAnnotatorFactory) Close() error
func (*GeoIPASNAnnotatorFactory) GetWorkers ¶
func (fact *GeoIPASNAnnotatorFactory) GetWorkers() int
func (*GeoIPASNAnnotatorFactory) Initialize ¶
func (fact *GeoIPASNAnnotatorFactory) Initialize(conf *GlobalConf) error
func (*GeoIPASNAnnotatorFactory) IsEnabled ¶
func (fact *GeoIPASNAnnotatorFactory) IsEnabled() bool
func (*GeoIPASNAnnotatorFactory) MakeAnnotator ¶
func (fact *GeoIPASNAnnotatorFactory) MakeAnnotator(i int) Annotator
type GeoIPASNOutput ¶
type GlobalConf ¶
type RDNSAnnotator ¶
type RDNSAnnotator struct { Factory *RDNSAnnotatorFactory Id int }
func (*RDNSAnnotator) Annotate ¶
func (a *RDNSAnnotator) Annotate(ip net.IP) interface{}
func (*RDNSAnnotator) Close ¶
func (a *RDNSAnnotator) Close() error
func (*RDNSAnnotator) GetFieldName ¶
func (a *RDNSAnnotator) GetFieldName() string
func (*RDNSAnnotator) Initialize ¶
func (a *RDNSAnnotator) Initialize() error
type RDNSAnnotatorFactory ¶
type RDNSAnnotatorFactory struct { BasePluginConf RawResolvers string }
func (*RDNSAnnotatorFactory) AddFlags ¶
func (a *RDNSAnnotatorFactory) AddFlags(flags *flag.FlagSet)
func (*RDNSAnnotatorFactory) Close ¶
func (a *RDNSAnnotatorFactory) Close() error
func (*RDNSAnnotatorFactory) GetWorkers ¶
func (a *RDNSAnnotatorFactory) GetWorkers() int
func (*RDNSAnnotatorFactory) Initialize ¶
func (a *RDNSAnnotatorFactory) Initialize(conf *GlobalConf) error
func (*RDNSAnnotatorFactory) IsEnabled ¶
func (a *RDNSAnnotatorFactory) IsEnabled() bool
func (*RDNSAnnotatorFactory) MakeAnnotator ¶
func (a *RDNSAnnotatorFactory) MakeAnnotator(i int) Annotator
type RoutingAnnotator ¶
type RoutingAnnotator struct { Factory *RoutingAnnotatorFactory Id int // contains filtered or unexported fields }
func (*RoutingAnnotator) Annotate ¶
func (a *RoutingAnnotator) Annotate(ip net.IP) interface{}
func (*RoutingAnnotator) Close ¶
func (a *RoutingAnnotator) Close() error
func (*RoutingAnnotator) GetFieldName ¶
func (a *RoutingAnnotator) GetFieldName() string
func (*RoutingAnnotator) Initialize ¶
func (a *RoutingAnnotator) Initialize() error
type RoutingAnnotatorFactory ¶
type RoutingAnnotatorFactory struct { BasePluginConf RoutingTablePath string ASNamesPath string ASDataPath string // contains filtered or unexported fields }
func (*RoutingAnnotatorFactory) AddFlags ¶
func (a *RoutingAnnotatorFactory) AddFlags(flags *flag.FlagSet)
Routing Annotator Factory (Global)
func (*RoutingAnnotatorFactory) Close ¶
func (a *RoutingAnnotatorFactory) Close() error
func (*RoutingAnnotatorFactory) GetWorkers ¶
func (a *RoutingAnnotatorFactory) GetWorkers() int
func (*RoutingAnnotatorFactory) Initialize ¶
func (a *RoutingAnnotatorFactory) Initialize(conf *GlobalConf) error
func (*RoutingAnnotatorFactory) IsEnabled ¶
func (a *RoutingAnnotatorFactory) IsEnabled() bool
func (*RoutingAnnotatorFactory) MakeAnnotator ¶
func (a *RoutingAnnotatorFactory) MakeAnnotator(i int) Annotator
Click to show internal directories.
Click to hide internal directories.