loki

Documentation

Index

• func ProcessCloudTrailLogLines(accountContext *model2.AccountContext, streamContext *StreamContext, ...) error
• func ProcessFalcoLogLines(accountContext *model2.AccountContext, streamContext *StreamContext, ...) error
• func ProcessKubeBenchLogLines(accountContext *model2.AccountContext, streamContext *StreamContext, ...) error
• type Line
• type LineProcessor
• type StreamContext

Functions

func ProcessCloudTrailLogLines

func ProcessCloudTrailLogLines(accountContext *model2.AccountContext, streamContext *StreamContext, findingCategory model2.SecurityFindingCategory, findingType string, findingDescription string, priority int, lines []*Line, securityFindingChannel chan *model2.SecurityFinding) error

func ProcessFalcoLogLines

func ProcessFalcoLogLines(accountContext *model2.AccountContext, streamContext *StreamContext, lines []*Line, securityFindingChannel chan *model2.SecurityFinding) error

func ProcessKubeBenchLogLines

func ProcessKubeBenchLogLines(accountContext *model2.AccountContext, streamContext *StreamContext, lines []*Line, securityFindingChannel chan *model2.SecurityFinding) error

Types

type Line

type Line struct {
	Timestamp time.Time
	Line      string
}

type LineProcessor

type LineProcessor func(accountContext *model2.AccountContext, streamContext *StreamContext, lines []*Line, securityFindingChannel chan *model2.SecurityFinding) error

type StreamContext

type StreamContext struct {
	AccountId           string
	Region              string
	LogGroup            string
	KubernetesCluster   string
	HostName            string
	KubernetesNamespace string
	ContainerName       string
	IoStream            string
}