scan

type Engine interface {
	Start(ctx context.Context, r *Range) (done <-chan interface{}, errc <-chan error)
}

type EngineResulter interface {
	Engine
	Resulter
}

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

type GenericEngineOption func(s *GenericEngine)

type IPContainer interface {
	Contains(ip net.IP) (bool, error)
}

type IPGenerator interface {
	IPs(ctx context.Context, r *Range) (<-chan IPGetter, error)
}

type IPGetter interface {
	GetIP() (net.IP, error)
}

type IPPort struct {
	IP   string `json:"ip"`
	Port int    `json:"port"`
}

type OpenFileFunc func() (io.ReadCloser, error)

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

type PacketFiller interface {
	Fill(packet gopacket.SerializeBuffer, r *Request) error
}

type PacketGenerator interface {
	Packets(ctx context.Context, in <-chan *Request) <-chan *packet.BufferData
}

type PacketMethod interface {
	PacketSource
	packet.Processor
	Resulter
}

type PacketSource interface {
	Packets(ctx context.Context, r *Range) <-chan *packet.BufferData
}

type PortGenerator interface {
	Ports(ctx context.Context, r *Range) (<-chan PortGetter, error)
}

type PortGetter interface {
	GetPort() (uint16, error)
}

type PortRange struct {
	StartPort uint16
	EndPort   uint16
}

type Range struct {
	Interface *net.Interface
	DstSubnet *net.IPNet
	SrcIP     net.IP
	SrcMAC    net.HardwareAddr
	Ports     []*PortRange
}

type RateLimiter interface {
	// Take should block to make sure that the RPS is met.
	Take() time.Time
}

type Request struct {
	Meta    map[string]interface{}
	SrcIP   net.IP
	DstIP   net.IP
	SrcMAC  []byte
	DstMAC  []byte
	DstPort uint16
	Err     error
}

type RequestGenerator interface {
	GenerateRequests(ctx context.Context, r *Range) (<-chan *Request, error)
}

type Result interface {
	fmt.Stringer
	json.Marshaler
	ID() string
}

type ResultChan interface {
	Put(r Result)
	Chan() <-chan Result
}

type Resulter interface {
	Results() <-chan Result
}

type Scanner interface {
	Scan(ctx context.Context, r *Request) (Result, error)
}

type WrapIP net.IP

type WrapPort uint16