workers

Documentation

Index

• type Options
  • func (o Options) AttributeFilter() map[string]interface{}
  • func (o Options) Authorize(req *http.Request)
  • func (o Options) EventFilter() map[string]interface{}
  • func (o Options) ObjectFilter() map[string]interface{}
  • func (o Options) Validate() error
• type Worker
  • func New(o *Options, l zerolog.Logger) (Worker, error)

Types

type Options

type Options struct {
	URL              string
	Key              string
	Insecure         bool
	Period           []string
	Events           []int
	IDSIgnore        bool
	IDSExclude       bool
	PublishedInclude bool
	PublishedExclude bool
	Buffer           int
	WarningInclude   bool
	Tags             []string
	ThreatLevel      []string
	Keywords         []string
}

func (Options) AttributeFilter

func (o Options) AttributeFilter() map[string]interface{}

func (Options) Authorize

func (o Options) Authorize(req *http.Request)

func (Options) EventFilter

func (o Options) EventFilter() map[string]interface{}

func (Options) ObjectFilter

func (o Options) ObjectFilter() map[string]interface{}

func (Options) Validate

func (o Options) Validate() error

type Worker

type Worker interface {
	Enrich(events chan *event.Event) chan *event.Event
	Events() chan *event.Event
	Error() error
}

func New

func New(o *Options, l zerolog.Logger) (Worker, error)