db

Documentation

Index

• type Archiver
  • func NewArchiver(client *ent.Client, logger *Logger) *Archiver
  • func (a *Archiver) Process()
  • func (a *Archiver) Stop()
  • func (a *Archiver) Store(sr *SniffRecord)
• type LogLevel
• type Logger
  • func NewLogger(client *ent.Client) *Logger
  • func (l *Logger) LogDebug(message string) error
  • func (l *Logger) LogError(message string) error
  • func (l *Logger) LogInfo(message string) error
  • func (l *Logger) LogTrace(message string) error
  • func (l *Logger) LogWarning(message string) error
• type MessageHeader
• type SegmentHeader
• type SniffRecord
  • func (s *SniffRecord) GetDestinationAddress() net.IP
  • func (s *SniffRecord) GetSourceAddress() net.IP

Types

type Archiver

type Archiver struct {
	// contains filtered or unexported fields
}

func NewArchiver

func NewArchiver(client *ent.Client, logger *Logger) *Archiver

func (*Archiver) Process

func (a *Archiver) Process()

func (*Archiver) Stop

func (a *Archiver) Stop()

func (*Archiver) Store

func (a *Archiver) Store(sr *SniffRecord)

type LogLevel

type LogLevel int

const (
	Info LogLevel = iota
	Warning
	Error
	Debug
	Trace
)

type Logger

type Logger struct {
	// contains filtered or unexported fields
}

func NewLogger

func NewLogger(client *ent.Client) *Logger

func (*Logger) LogDebug

func (l *Logger) LogDebug(message string) error

func (*Logger) LogError

func (l *Logger) LogError(message string) error

func (*Logger) LogInfo

func (l *Logger) LogInfo(message string) error

func (*Logger) LogTrace

func (l *Logger) LogTrace(message string) error

func (*Logger) LogWarning

func (l *Logger) LogWarning(message string) error

type MessageHeader

type MessageHeader struct {
	Opcode    int    `json:"opcode"`
	Server    int    `json:"server"`
	Timestamp uint32 `json:"timestamp"`
}

type SegmentHeader

type SegmentHeader struct {
	Size        uint32 `json:"size"`
	SourceActor uint32 `json:"source_actor"`
	TargetActor uint32 `json:"target_actor"`
	Type        int    `json:"type"`
}

type SniffRecord

type SniffRecord struct {
	Timestamp          time.Time      `json:"t"`
	Version            int            `json:"v"`
	SourceAddress      string         `json:"src_addr"`
	SourcePort         int            `json:"src_port"`
	DestinationAddress string         `json:"dst_addr"`
	DestinationPort    int            `json:"dst_port"`
	SegmentHeader      *SegmentHeader `json:"segment_header"`
	MessageHeader      *MessageHeader `json:"message_header"`
	MessageData        []byte         `json:"message_data"`
}

func (*SniffRecord) GetDestinationAddress

func (s *SniffRecord) GetDestinationAddress() net.IP

func (*SniffRecord) GetSourceAddress

func (s *SniffRecord) GetSourceAddress() net.IP