feeder

Documentation

Index

• Variables
• type AlertStruct
• type Feeder
  • func NewFeeder(clusterName string, node *tp.Node, port, output string) *Feeder
  • func (fd *Feeder) Debug(message string)
  • func (fd *Feeder) Debugf(message string, args ...interface{})
  • func (fd *Feeder) DestroyFeeder() error
  • func (fd *Feeder) Err(message string)
  • func (fd *Feeder) Errf(message string, args ...interface{})
  • func (fd *Feeder) Print(message string)
  • func (fd *Feeder) Printf(message string, args ...interface{})
  • func (fd *Feeder) PushLog(log tp.Log)
  • func (fd *Feeder) PushMessage(level, message string)
  • func (fd *Feeder) ServeLogFeeds()
  • func (fd *Feeder) StrToFile(str string)
  • func (fd *Feeder) UpdateHostSecurityPolicies(action string, secPolicies []tp.HostSecurityPolicy)
  • func (fd *Feeder) UpdateMatchedPolicy(log tp.Log) tp.Log
  • func (fd *Feeder) UpdateSecurityPolicies(action string, endPoint tp.EndPoint)
  • func (fd *Feeder) Warn(message string)
  • func (fd *Feeder) Warnf(message string, args ...interface{})
• type LogService
  • func (ls *LogService) HealthCheck(ctx context.Context, nonce *pb.NonceMessage) (*pb.ReplyMessage, error)
  • func (ls *LogService) WatchAlerts(req *pb.RequestMessage, svr pb.LogService_WatchAlertsServer) error
  • func (ls *LogService) WatchLogs(req *pb.RequestMessage, svr pb.LogService_WatchLogsServer) error
  • func (ls *LogService) WatchMessages(req *pb.RequestMessage, svr pb.LogService_WatchMessagesServer) error
• type LogStruct
• type MsgStruct

Variables

var AlertQueue chan pb.Alert

AlertQueue for alerts

var LogQueue chan pb.Log

LogQueue for Logs

var MsgQueue chan pb.Message

MsgQueue for Messages

var Running bool

Running flag

Types

type AlertStruct

type AlertStruct struct {
	Client pb.LogService_WatchAlertsServer
	Filter string
}

AlertStruct Structure

type Feeder

type Feeder struct {
	// cluster + host
	ClusterName string

	// node
	Node *tp.Node

	// port
	Port string

	// output
	Output  string
	LogFile *os.File

	// gRPC listener
	Listener net.Listener

	// log server
	LogServer *grpc.Server

	// wait group
	WgServer sync.WaitGroup

	// namespace name + endpoint name / host name -> corresponding security policies
	SecurityPolicies     map[string]tp.MatchPolicies
	SecurityPoliciesLock *sync.RWMutex

	// GKE
	IsGKE bool
}

Feeder Structure

func NewFeeder

func NewFeeder(clusterName string, node *tp.Node, port, output string) *Feeder

NewFeeder Function

func (*Feeder) Debug

func (fd *Feeder) Debug(message string)

Debug Function

func (*Feeder) Debugf

func (fd *Feeder) Debugf(message string, args ...interface{})

Debugf Function

func (*Feeder) DestroyFeeder

func (fd *Feeder) DestroyFeeder() error

DestroyFeeder Function

func (*Feeder) Err

func (fd *Feeder) Err(message string)

Err Function

func (*Feeder) Errf

func (fd *Feeder) Errf(message string, args ...interface{})

Errf Function

func (*Feeder) Print

func (fd *Feeder) Print(message string)

Print Function

func (*Feeder) Printf

func (fd *Feeder) Printf(message string, args ...interface{})

Printf Function

func (*Feeder) PushLog

func (fd *Feeder) PushLog(log tp.Log)

PushLog Function

func (*Feeder) PushMessage

func (fd *Feeder) PushMessage(level, message string)

PushMessage Function

func (*Feeder) ServeLogFeeds

func (fd *Feeder) ServeLogFeeds()

ServeLogFeeds Function

func (*Feeder) StrToFile

func (fd *Feeder) StrToFile(str string)

StrToFile Function

func (*Feeder) UpdateHostSecurityPolicies

func (fd *Feeder) UpdateHostSecurityPolicies(action string, secPolicies []tp.HostSecurityPolicy)

UpdateHostSecurityPolicies Function

func (*Feeder) UpdateMatchedPolicy

func (fd *Feeder) UpdateMatchedPolicy(log tp.Log) tp.Log

UpdateMatchedPolicy Function

func (*Feeder) UpdateSecurityPolicies

func (fd *Feeder) UpdateSecurityPolicies(action string, endPoint tp.EndPoint)

UpdateSecurityPolicies Function

func (*Feeder) Warn

func (fd *Feeder) Warn(message string)

Warn Function

func (*Feeder) Warnf

func (fd *Feeder) Warnf(message string, args ...interface{})

Warnf Function

type LogService

type LogService struct {
	MsgStructs map[string]MsgStruct
	MsgLock    *sync.Mutex

	AlertStructs map[string]AlertStruct
	AlertLock    *sync.Mutex

	LogStructs map[string]LogStruct
	LogLock    *sync.Mutex
}

LogService Structure

func (*LogService) HealthCheck

func (ls *LogService) HealthCheck(ctx context.Context, nonce *pb.NonceMessage) (*pb.ReplyMessage, error)

HealthCheck Function

func (*LogService) WatchAlerts

func (ls *LogService) WatchAlerts(req *pb.RequestMessage, svr pb.LogService_WatchAlertsServer) error

WatchAlerts Function

func (*LogService) WatchLogs

func (ls *LogService) WatchLogs(req *pb.RequestMessage, svr pb.LogService_WatchLogsServer) error

WatchLogs Function

func (*LogService) WatchMessages

func (ls *LogService) WatchMessages(req *pb.RequestMessage, svr pb.LogService_WatchMessagesServer) error

WatchMessages Function

type LogStruct

type LogStruct struct {
	Client pb.LogService_WatchLogsServer
	Filter string
}

LogStruct Structure

type MsgStruct

type MsgStruct struct {
	Client pb.LogService_WatchMessagesServer
	Filter string
}

MsgStruct Structure