beater

Documentation

Index

• Constants
• func AlertEntityToCommonMap(entity sophoscentral.AlertEntity) (common.MapStr, error)
• func GenerateYesterdayTimeStamp() int64
• func GetEvent(data interface{}) beat.Event
• func GetSophosAlerts(scb Sophoscentralbeat) error
• func GetSophosEvents(scb Sophoscentralbeat) error
• func LegacyEventEntityToCommonMap(entity sophoscentral.LegacyEventEntity) (common.MapStr, error)
• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• func UpdateAlertTime(scb *Sophoscentralbeat, alertTimeStamp int64)
• func UpdateEventTime(scb *Sophoscentralbeat, eventTimeStamp int64)
• type Sophoscentralbeat
  • func (scb *Sophoscentralbeat) Run(b *beat.Beat) error
  • func (scb *Sophoscentralbeat) Stop()

Constants

const ServiceName = "sophoscentralbeat"

ServiceName is the name of the service

Functions

func AlertEntityToCommonMap

func AlertEntityToCommonMap(entity sophoscentral.AlertEntity) (common.MapStr, error)

func GenerateYesterdayTimeStamp

func GenerateYesterdayTimeStamp() int64

GenerateYesterdayTimeStamp : generate 24 hour prior timestamp

func GetEvent

func GetEvent(data interface{}) beat.Event

GetEvent converts json data to beats json response

func GetSophosAlerts

func GetSophosAlerts(scb Sophoscentralbeat) error

GetSophosAlerts : call alerts API

func GetSophosEvents

func GetSophosEvents(scb Sophoscentralbeat) error

GetSophosEvents : calls Sophos Events Api

func LegacyEventEntityToCommonMap

func LegacyEventEntityToCommonMap(entity sophoscentral.LegacyEventEntity) (common.MapStr, error)

func New

func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)

New creates an instance of sophoscentralbeat.

func UpdateAlertTime

func UpdateAlertTime(scb *Sophoscentralbeat, alertTimeStamp int64)

func UpdateEventTime

func UpdateEventTime(scb *Sophoscentralbeat, eventTimeStamp int64)

Types

type Sophoscentralbeat

type Sophoscentralbeat struct {
	StopChan chan struct{}
	// contains filtered or unexported fields
}

Sophoscentralbeat configuration.

func (*Sophoscentralbeat) Run

func (scb *Sophoscentralbeat) Run(b *beat.Beat) error

Run starts sophoscentralbeat.

func (*Sophoscentralbeat) Stop

func (scb *Sophoscentralbeat) Stop()

Stop stops sophoscentralbeat.