db

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 25, 2022 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.3.0

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

type SegmentHeader added in v0.3.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL