flowlogger

Documentation

Index

• Constants
• func PrettyPrintPolicyType(policyType uint8) string
• func PrettyPrintProtocolIdentifier(protocolID uint8) string
• func PrettyPrintRuleAction(action uint8) string
• type FlowLogger
  • func NewFlowLogger(path string, maxSize int, maxBackups int, maxAge int, compress bool) *FlowLogger
  • func (fl *FlowLogger) Close()
  • func (fl *FlowLogger) Flush() error
  • func (fl *FlowLogger) FlushLoop(stopCh <-chan struct{})
  • func (fl *FlowLogger) WriteRecord(r *flowrecord.FlowRecord, prettyPrint bool) error

Constants

const MaxLatency = 5 * time.Second

Functions

func PrettyPrintPolicyType

func PrettyPrintPolicyType(policyType uint8) string

func PrettyPrintProtocolIdentifier

func PrettyPrintProtocolIdentifier(protocolID uint8) string

func PrettyPrintRuleAction

func PrettyPrintRuleAction(action uint8) string

Types

type FlowLogger

type FlowLogger struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewFlowLogger

func NewFlowLogger(path string, maxSize int, maxBackups int, maxAge int, compress bool) *FlowLogger

func (*FlowLogger) Close

func (fl *FlowLogger) Close()

func (*FlowLogger) Flush

func (fl *FlowLogger) Flush() error

func (*FlowLogger) FlushLoop

func (fl *FlowLogger) FlushLoop(stopCh <-chan struct{})

func (*FlowLogger) WriteRecord

func (fl *FlowLogger) WriteRecord(r *flowrecord.FlowRecord, prettyPrint bool) error