windivert

package module
v0.0.0-...-34f9fc7 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2021 License: GPL-3.0 Imports: 23 Imported by: 0

README

go-WinDivert2

Go bindings for WinDivert 2.x

ChangeLogs

Thanks

Documentation

Index

Constants

View Source 
const (
	FlagDefault   = 0x0000
	FlagSniff     = 0x0001
	FlagDrop      = 0x0002
	FlagRecvOnly  = 0x0004
	FlagSendOnly  = 0x0008
	FlagNoInstall = 0x0010
	FlagFragments = 0x0020
)
View Source 
const (
	PriorityDefault    = 0
	PriorityHighest    = 3000
	PriorityLowest     = -3000
	QueueLengthDefault = 4096
	QueueLengthMin     = 32
	QueueLengthMax     = 16384
	QueueTimeDefault   = 2000
	QueueTimeMin       = 100
	QueueTimeMax       = 16000
	QueueSizeDefault   = 4194304
	QueueSizeMin       = 65535
	QueueSizeMax       = 33554432
)
View Source 
const (
	ChecksumDefault  = 0
	NoIPChecksum     = 1
	NoICMPChekcsum   = 2
	NoICMPV6Checksum = 4
	NoTCPChekcsum    = 8
	NoUDPChecksum    = 16
)
View Source 
const (
	BatchMax = 0xff
	MTUMax   = 40 + 0xffff
)
View Source 
const (
	FIN = 1 << 0
	SYN = 1 << 1
	RST = 1 << 2
	PSH = 1 << 3
	ACK = 1 << 4
	UGR = 1 << 5
	ECE = 1 << 6
	CWR = 1 << 7
)
View Source 
const (
	ErrInsufficientBuffer = Error(windows.ERROR_INSUFFICIENT_BUFFER)
	ErrNoData             = Error(windows.ERROR_NO_DATA)
	ErrIOPending          = Error(windows.ERROR_IO_PENDING)
	ErrHostUnreachable    = Error(windows.ERROR_HOST_UNREACHABLE)
)
View Source 
const (
	METHOD_BUFFERED   = 0
	METHOD_IN_DIRECT  = 1
	METHOD_OUT_DIRECT = 2
	METHOD_NEITHER    = 3
)
View Source 
const (
	FILE_READ_DATA  = 1
	FILE_WRITE_DATA = 2
)
View Source 
const (
	FILE_DEVICE_NETWORK             = 0x00000012
	FILE_DEVICE_NETWORK_BROWSER     = 0x00000013
	FILE_DEVICE_NETWORK_FILE_SYSTEM = 0x00000014
	FILE_DEVICE_NETWORK_REDIRECTOR  = 0x00000028
)

Variables

View Source 
var (
	IoCtlInitialize = CTL_CODE(FILE_DEVICE_NETWORK, 0x921, METHOD_OUT_DIRECT, FILE_READ_DATA|FILE_WRITE_DATA)
	IoCtlStartup    = CTL_CODE(FILE_DEVICE_NETWORK, 0x922, METHOD_IN_DIRECT, FILE_READ_DATA|FILE_WRITE_DATA)
	IoCtlRecv       = CTL_CODE(FILE_DEVICE_NETWORK, 0x923, METHOD_OUT_DIRECT, FILE_READ_DATA)
	IoCtlSend       = CTL_CODE(FILE_DEVICE_NETWORK, 0x924, METHOD_IN_DIRECT, FILE_READ_DATA|FILE_WRITE_DATA)
	IoCtlSetParam   = CTL_CODE(FILE_DEVICE_NETWORK, 0x925, METHOD_IN_DIRECT, FILE_READ_DATA|FILE_WRITE_DATA)
	IoCtlGetParam   = CTL_CODE(FILE_DEVICE_NETWORK, 0x926, METHOD_OUT_DIRECT, FILE_READ_DATA)
	IoCtlShutdown   = CTL_CODE(FILE_DEVICE_NETWORK, 0x927, METHOD_IN_DIRECT, FILE_READ_DATA|FILE_WRITE_DATA)
)
View Source 
var (
	DeviceName = windows.StringToUTF16Ptr("WinDivert")
)

Functions

func CloseMutex 

func CloseMutex(mutex windows.Handle)

func DialIPv4 

func DialIPv4(wg *sync.WaitGroup)

func DialIPv6 

func DialIPv6(wg *sync.WaitGroup)

func Download 

func Download() error

func GetDriverFileName 

func GetDriverFileName() (string, error)

func GetInterfaceIndex 

func GetInterfaceIndex() (uint32, uint32, error)

func InstallDriver 

func InstallDriver() error

func IoControl 

func IoControl(h windows.Handle, code CtlCode, ioctl unsafe.Pointer, buf *byte, bufLen uint32) (iolen uint32, err error)

func IoControlEx 

func IoControlEx(h windows.Handle, code CtlCode, ioctl unsafe.Pointer, buf *byte, bufLen uint32, overlapped *windows.Overlapped) (iolen uint32, err error)

func RegisterEventSource 

func RegisterEventSource(sys string) error

func RemoveDriver 

func RemoveDriver() error

Types

type Address 

type Address struct {
	Timestamp int64

	Flags uint8
	// contains filtered or unexported fields
}

func (*Address) Ethernet 

func (a *Address) Ethernet() *Ethernet

func (*Address) Event 

func (a *Address) Event() Event

func (*Address) Flow 

func (a *Address) Flow() *Flow

func (*Address) IPChecksum 

func (a *Address) IPChecksum() bool

func (*Address) IPv6 

func (a *Address) IPv6() bool

func (*Address) Impostor 

func (a *Address) Impostor() bool

func (*Address) Layer 

func (a *Address) Layer() Layer

func (*Address) Length 

func (a *Address) Length() uint32

func (*Address) Loopback 

func (a *Address) Loopback() bool

func (*Address) Network 

func (a *Address) Network() *Network

func (*Address) Outbound 

func (a *Address) Outbound() bool

func (*Address) Reflect 

func (a *Address) Reflect() *Reflect

func (*Address) SetEvent 

func (a *Address) SetEvent(event Event)

func (*Address) SetIPChecksum 

func (a *Address) SetIPChecksum()

func (*Address) SetIPv6 

func (a *Address) SetIPv6()

func (*Address) SetImpostor 

func (a *Address) SetImpostor()

func (*Address) SetLayer 

func (a *Address) SetLayer(layer Layer)

func (*Address) SetLength 

func (a *Address) SetLength(n uint32)

func (*Address) SetLoopback 

func (a *Address) SetLoopback()

func (*Address) SetOutbound 

func (a *Address) SetOutbound()

func (*Address) SetSniffed 

func (a *Address) SetSniffed()

func (*Address) SetTCPChecksum 

func (a *Address) SetTCPChecksum()

func (*Address) SetUDPChecksum 

func (a *Address) SetUDPChecksum()

func (*Address) Sniffed 

func (a *Address) Sniffed() bool

func (*Address) Socket 

func (a *Address) Socket() *Socket

func (*Address) TCPChecksum 

func (a *Address) TCPChecksum() bool

func (*Address) UDPChecksum 

func (a *Address) UDPChecksum() bool

func (*Address) UnsetIPChecksum 

func (a *Address) UnsetIPChecksum()

func (*Address) UnsetIPv6 

func (a *Address) UnsetIPv6()

func (*Address) UnsetImpostor 

func (a *Address) UnsetImpostor()

func (*Address) UnsetLoopback 

func (a *Address) UnsetLoopback()

func (*Address) UnsetOutbound 

func (a *Address) UnsetOutbound()

func (*Address) UnsetSniffed 

func (a *Address) UnsetSniffed()

func (*Address) UnsetTCPChecksum 

func (a *Address) UnsetTCPChecksum()

func (*Address) UnsetUDPChecksum 

func (a *Address) UnsetUDPChecksum()

type CtlCode 

type CtlCode uint32

func CTL_CODE 

func CTL_CODE(DeviceType, Function, Method, Access uint32) CtlCode

func (CtlCode) String 

func (code CtlCode) String() string

type Device 

type Device struct {
	*Address
	*io.PipeReader
	*io.PipeWriter
	*utils.AppFilter
	*utils.IPFilter
	*Handle
	TCP  [65536]uint8
	UDP  [65536]uint8
	TCP6 [65536]uint8
	UDP6 [65536]uint8
	// contains filtered or unexported fields
}

func NewDevice 

func NewDevice(filter string) (dev *Device, err error)

func (*Device) CheckIPv4 

func (d *Device) CheckIPv4(b []byte) bool

func (*Device) CheckIPv6 

func (d *Device) CheckIPv6(b []byte) bool

func (*Device) CheckTCP4 

func (d *Device) CheckTCP4(b []byte) bool

func (*Device) CheckTCP6 

func (d *Device) CheckTCP6(b []byte) bool

func (*Device) CheckUDP4 

func (d *Device) CheckUDP4(b []byte) bool

func (*Device) CheckUDP6 

func (d *Device) CheckUDP6(b []byte) bool

func (*Device) Close 

func (d *Device) Close() error

func (*Device) Write 

func (d *Device) Write(b []byte) (int, error)

func (*Device) WriteTo 

func (d *Device) WriteTo(w io.Writer) (n int64, err error)

type Error 

type Error syscall.Errno

func (Error) Error 

func (e Error) Error() string

type Ethernet 

type Ethernet struct {
	InterfaceIndex    uint32
	SubInterfaceIndex uint32
	// contains filtered or unexported fields
}

type Event 

type Event int
const (
	EventNetworkPacket   Event = 0
	EventFlowEstablished Event = 1
	EventFlowDeleted     Event = 2
	EventSocketBind      Event = 3
	EventSocketConnect   Event = 4
	EventSocketListen    Event = 5
	EventSocketAccept    Event = 6
	EventSocketClose     Event = 7
	EventReflectOpen     Event = 8
	EventReflectClose    Event = 9
	EventEthernetFrame   Event = 10
)

func (Event) String 

func (e Event) String() string

type Flow 

type Flow struct {
	EndpointID       uint64
	ParentEndpointID uint64
	ProcessID        uint32
	LocalAddress     [16]uint8
	RemoteAddress    [16]uint8
	LocalPort        uint16
	RemotePort       uint16
	Protocol         uint8
	// contains filtered or unexported fields
}

type Handle 

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

func Open 

func Open(filter string, layer Layer, priority int16, flags uint64) (*Handle, error)

func (*Handle) Close 

func (h *Handle) Close() error

func (*Handle) GetParam 

func (h *Handle) GetParam(p Param) (uint64, error)

func (*Handle) Recv 

func (h *Handle) Recv(buffer []byte, address *Address) (uint, error)

func (*Handle) RecvEx 

func (h *Handle) RecvEx(buffer []byte, address []Address, overlapped *windows.Overlapped) (uint, uint, error)

func (*Handle) Send 

func (h *Handle) Send(buffer []byte, address *Address) (uint, error)

func (*Handle) SendEx 

func (h *Handle) SendEx(buffer []byte, address []Address, overlapped *windows.Overlapped) (uint, error)

func (*Handle) SetParam 

func (h *Handle) SetParam(p Param, v uint64) error

func (*Handle) Shutdown 

func (h *Handle) Shutdown(how Shutdown) error

type IoCtl 

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

type Layer 

type Layer int
const (
	LayerNetwork        Layer = 0
	LayerNetworkForward Layer = 1
	LayerFlow           Layer = 2
	LayerSocket         Layer = 3
	LayerReflect        Layer = 4
	LayerEthernet       Layer = 5
)

func (Layer) String 

func (l Layer) String() string

type Network 

type Network struct {
	InterfaceIndex    uint32
	SubInterfaceIndex uint32
	// contains filtered or unexported fields
}

type Param 

type Param int
const (
	QueueLength  Param = 0
	QueueTime    Param = 1
	QueueSize    Param = 2
	VersionMajor Param = 3
	VersionMinor Param = 4
)

func (Param) String 

func (p Param) String() string

type Reflect 

type Reflect struct {
	TimeStamp int64
	ProcessID uint32

	Flags    uint64
	Priority int16
	// contains filtered or unexported fields
}

func (*Reflect) Layer 

func (r *Reflect) Layer() Layer

type Shutdown 

type Shutdown int
const (
	ShutdownRecv Shutdown = 0
	ShutdownSend Shutdown = 1
	ShutdownBoth Shutdown = 2
)

func (Shutdown) String 

func (h Shutdown) String() string

type Socket 

type Socket struct {
	EndpointID       uint64
	ParentEndpointID uint64
	ProcessID        uint32
	LocalAddress     [16]uint8
	RemoteAddress    [16]uint8
	LocalPort        uint16
	RemotePort       uint16
	Protocol         uint8
	// contains filtered or unexported fields
}

Source Files

View all Source files

Directories

Path Synopsis
internal
iana
Package iana provides protocol number resources managed by the Internet Assigned Numbers Authority (IANA).
 Package iana provides protocol number resources managed by the Internet Assigned Numbers Authority (IANA).
utils
utils/iptree
Package iptree implements radix tree data structure for IPv4 and IPv6 networks.
 Package iptree implements radix tree data structure for IPv4 and IPv6 networks.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.