device

package

Go to main page

Versions in this module

v0

v0.0.5

Feb 7, 2022

v0.0.4

Aug 3, 2020

Changes in this version

+ const MessageIndexSize

+ const MessageTransportOffsetTimestamp

type MessageInitiation

+ ClientIndex [MessageIndexSize]uint8

type MessageResponse

+ ClientIndex [MessageIndexSize]uint8

type MessageTransport

+ ClientIndex [MessageIndexSize]uint8

+ TimeStamp uint64

v0.0.3

May 4, 2020

Changes in this version

+ const AtomicFalse

+ const AtomicTrue

+ const ConnRoutineNumber

+ const CookieRefreshTime

+ const DefaultMTU

+ const DeviceRoutineNumberAdditional

+ const DeviceRoutineNumberPerCPU

+ const FD_ERR — linux/amd64

+ const HandshakeInitationRate

+ const HandshakeInitiationConsumed

+ const HandshakeInitiationCreated

+ const HandshakeResponseConsumed

+ const HandshakeResponseCreated

+ const HandshakeZeroed

+ const IPv4offsetDst

+ const IPv4offsetSrc

+ const IPv4offsetTotalLength

+ const IPv6offsetDst

+ const IPv6offsetPayloadLength

+ const IPv6offsetSrc

+ const KeepaliveTimeout

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelSilent

+ const MaxContentSize

+ const MaxMessageSize

+ const MaxPeers

+ const MaxSegmentSize

+ const MaxTimerHandshakes

+ const MessageAppidChkSize

+ const MessageCookieReplySize

+ const MessageCookieReplyType

+ const MessageHandshakeSize

+ const MessageInitiationSize

+ const MessageInitiationType

+ const MessageKeepaliveSize

+ const MessageRandomSize

+ const MessageResponseSize

+ const MessageResponseType

+ const MessageTransportHeaderOffSet

+ const MessageTransportHeaderSize

+ const MessageTransportOffsetContent

+ const MessageTransportOffsetCounter

+ const MessageTransportOffsetReceiver

+ const MessageTransportSize

+ const MessageTransportType

+ const MessageTypeOffset

+ const MessageTypeSize

+ const MessageUsridChkSize

+ const MinMessageSize

+ const NoiseConstruction

+ const NoisePrivateKeySize

+ const NoisePublicKeySize

+ const PaddingMultiple

+ const PeerRoutineNumber

+ const PreallocatedBuffersPerPool

+ const QueueHandshakeSize

+ const QueueInboundSize

+ const QueueOutboundSize

+ const RejectAfterMessages

+ const RejectAfterTime

+ const RekeyAfterMessages

+ const RekeyAfterTime

+ const RekeyAttemptTime

+ const RekeyTimeout

+ const RekeyTimeoutJitterMaxMs

+ const UnderLoadAfterTime

+ const UnderLoadQueueSize

+ const WGIdentifier

+ const WGLabelCookie

+ const WGLabelMAC1

+ const ZtSDPGoVersion

+ var InitialChainKey [blake2s.Size]byte

+ var InitialHash [blake2s.Size]byte

+ var RoamingDisabled bool

+ var ZeroNonce [chacha20poly1305.NonceSize]byte

+ func CreateBind(port uint16, device *Device) (*nativeBind, uint16, error) — linux/amd64

+ func HMAC1(sum *[blake2s.Size]byte, key, in0 []byte)

+ func HMAC2(sum *[blake2s.Size]byte, key, in0, in1 []byte)

+ func KDF1(t0 *[blake2s.Size]byte, key, input []byte)

+ func KDF2(t0, t1 *[blake2s.Size]byte, key, input []byte)

+ func KDF3(t0, t1, t2 *[blake2s.Size]byte, key, input []byte)

+ type AllowedIPs struct

+ IPv4 *trieEntry

+ IPv6 *trieEntry

+ func (table *AllowedIPs) EntriesForPeer(peer *Peer) []net.IPNet

+ func (table *AllowedIPs) Insert(ip net.IP, cidr uint, peer *Peer)

+ func (table *AllowedIPs) LookupIPv4(address []byte) *Peer

+ func (table *AllowedIPs) LookupIPv6(address []byte) *Peer

+ func (table *AllowedIPs) RemoveByPeer(peer *Peer)

+ func (table *AllowedIPs) Reset()

+ type AtomicBool struct

+ func (a *AtomicBool) Get() bool

+ func (a *AtomicBool) Set(val bool)

+ func (a *AtomicBool) Swap(val bool) bool

+ type Bind interface

+ Close func() error

+ ReceiveIPv4 func(buff []byte) (int, Endpoint, error)

+ ReceiveIPv6 func(buff []byte) (int, Endpoint, error)

+ Send func(buff []byte, end Endpoint) error

+ SetMark func(value uint32) error

+ func CreateBind(uport uint16, device *Device) (Bind, uint16, error)

+ type CookieChecker struct

+ func (st *CookieChecker) CheckMAC1(msg []byte) bool

+ func (st *CookieChecker) CheckMAC2(msg []byte, src []byte) bool

+ func (st *CookieChecker) CreateReply(msg []byte, recv uint32, src []byte) (*MessageCookieReply, error)

+ func (st *CookieChecker) Init(pk NoisePublicKey)

+ type CookieGenerator struct

+ func (st *CookieGenerator) AddMacs(msg []byte)

+ func (st *CookieGenerator) ConsumeReply(msg *MessageCookieReply) bool

+ func (st *CookieGenerator) Init(pk NoisePublicKey)

+ type Device struct

+ func NewDevice(tunDevice tun.Device, logger *Logger) *Device

+ func (device *Device) BindClose() error

+ func (device *Device) BindSetMark(mark uint32) error

+ func (device *Device) BindSocketToInterface4(interfaceIndex uint32, blackhole bool) error

+ func (device *Device) BindSocketToInterface6(interfaceIndex uint32, blackhole bool) error

+ func (device *Device) BindUpdate() error

+ func (device *Device) Close()

+ func (device *Device) ConsumeMessageInitiation(msg *MessageInitiation) *Peer

+ func (device *Device) ConsumeMessageResponse(msg *MessageResponse) *Peer

+ func (device *Device) CreateMessageInitiation(peer *Peer) (*MessageInitiation, error)

+ func (device *Device) CreateMessageResponse(peer *Peer) (*MessageResponse, error)

+ func (device *Device) DeleteKeypair(key *Keypair)

+ func (device *Device) Down()

+ func (device *Device) FlushPacketQueues()

+ func (device *Device) GetInboundElement() *QueueInboundElement

+ func (device *Device) GetMessageBuffer() *[MaxMessageSize]byte

+ func (device *Device) GetOutboundElement() *QueueOutboundElement

+ func (device *Device) IpcGetOperation(socket *bufio.Writer) *IPCError

+ func (device *Device) IpcHandle(socket net.Conn)

+ func (device *Device) IpcSetOperation(socket *bufio.Reader) *IPCError

+ func (device *Device) IsUnderLoad() bool

+ func (device *Device) LookupPeer(pk NoisePublicKey) *Peer

+ func (device *Device) NewOutboundElement() *QueueOutboundElement

+ func (device *Device) NewPeer(pk NoisePublicKey) (*Peer, error)

+ func (device *Device) PopulatePools()

+ func (device *Device) PutInboundElement(msg *QueueInboundElement)

+ func (device *Device) PutMessageBuffer(msg *[MaxMessageSize]byte)

+ func (device *Device) PutOutboundElement(msg *QueueOutboundElement)

+ func (device *Device) RemoveAllPeers()

+ func (device *Device) RemovePeer(key NoisePublicKey)

+ func (device *Device) RoutineDecryption()

+ func (device *Device) RoutineEncryption()

+ func (device *Device) RoutineHandshake()

+ func (device *Device) RoutineReadFromTUN()

+ func (device *Device) RoutineReceiveIncoming(IP int, bind Bind)

+ func (device *Device) RoutineTUNEventReader()

+ func (device *Device) SendHandshakeCookie(initiatingElem *QueueHandshakeElement) error

+ func (device *Device) SendKeepalivesToPeersWithCurrentKeypair()

+ func (device *Device) SetPrivateKey(sk NoisePrivateKey) error

+ func (device *Device) Up()

+ func (device *Device) Wait() chan struct{}

+ type Endpoint interface

+ ClearSrc func()

+ DstIP func() net.IP

+ DstToBytes func() []byte

+ DstToString func() string

+ SrcIP func() net.IP

+ SrcToString func() string

+ func CreateEndpoint(s string) (Endpoint, error)

+ type Handshake struct

+ func (h *Handshake) Clear()

+ type IPCError struct

+ func (s IPCError) Error() string

+ func (s IPCError) ErrorCode() int64

+ type IPv4Source struct — linux/amd64

+ type IPv6Source struct — linux/amd64

+ type IndexTable struct

+ func (table *IndexTable) Delete(index uint32)

+ func (table *IndexTable) Init()

+ func (table *IndexTable) Lookup(id uint32) IndexTableEntry

+ func (table *IndexTable) NewIndexForHandshake(peer *Peer, handshake *Handshake) (uint32, error)

+ func (table *IndexTable) SwapIndexForKeypair(index uint32, keypair *Keypair)

+ type IndexTableEntry struct

+ type Keypair struct

+ type Keypairs struct

+ func (kp *Keypairs) Current() *Keypair

+ type Logger struct

+ Debug *log.Logger

+ Error *log.Logger

+ Info *log.Logger

+ func NewLogger(level int, prepend string) *Logger

+ type MessageCookieReply struct

+ Cookie [blake2s.Size128 + poly1305.TagSize]byte

+ Nonce [chacha20poly1305.NonceSizeX]byte

+ Receiver uint32

+ Type uint32

+ type MessageInitiation struct

+ AppidChk [MessageAppidChkSize]uint8

+ Ephemeral NoisePublicKey

+ MAC1 [blake2s.Size128]byte

+ MAC2 [blake2s.Size128]byte

+ Random [MessageRandomSize]uint8

+ Sender uint32

+ Static [NoisePublicKeySize + poly1305.TagSize]byte

+ Timestamp [tai64n.TimestampSize + poly1305.TagSize]byte

+ Type uint32

+ UsridChk [MessageUsridChkSize]uint8

+ type MessageResponse struct

+ AppidChk [MessageAppidChkSize]uint8

+ Empty [poly1305.TagSize]byte

+ Ephemeral NoisePublicKey

+ MAC1 [blake2s.Size128]byte

+ MAC2 [blake2s.Size128]byte

+ Random [MessageRandomSize]uint8

+ Receiver uint32

+ Sender uint32

+ Type uint32

+ UsridChk [MessageUsridChkSize]uint8

+ type MessageTransport struct

+ AppidChk [MessageAppidChkSize]uint8

+ Content []byte

+ Counter uint64

+ Random [MessageRandomSize]uint8

+ Receiver uint32

+ Type uint32

+ UsridChk [MessageUsridChkSize]uint8

+ type NativeEndpoint net.UDPAddr — darwin/amd64, js/wasm, windows/amd64

+ func (_ *NativeEndpoint) ClearSrc()

+ func (e *NativeEndpoint) DstIP() net.IP

+ func (e *NativeEndpoint) DstToBytes() []byte

+ func (e *NativeEndpoint) DstToString() string

+ func (e *NativeEndpoint) SrcIP() net.IP

+ func (e *NativeEndpoint) SrcToString() string

+ type NativeEndpoint struct — linux/amd64

+ func (end *NativeEndpoint) ClearDst()

+ func (end *NativeEndpoint) ClearSrc()

+ func (end *NativeEndpoint) DstIP() net.IP

+ func (end *NativeEndpoint) DstToBytes() []byte

+ func (end *NativeEndpoint) DstToString() string

+ func (end *NativeEndpoint) SrcIP() net.IP

+ func (end *NativeEndpoint) SrcToString() string

+ type NoiseNonce uint64

+ type NoisePrivateKey [NoisePrivateKeySize]byte

+ func (key *NoisePrivateKey) FromHex(src string) (err error)

+ func (key NoisePrivateKey) Equals(tar NoisePrivateKey) bool

+ func (key NoisePrivateKey) IsZero() bool

+ func (key NoisePrivateKey) ToHex() string

+ type NoisePublicKey [NoisePublicKeySize]byte

+ func (key *NoisePublicKey) FromHex(src string) error

+ func (key NoisePublicKey) Equals(tar NoisePublicKey) bool

+ func (key NoisePublicKey) IsZero() bool

+ func (key NoisePublicKey) ToHex() string

+ type NoiseSymmetricKey [chacha20poly1305.KeySize]byte

+ func (key *NoiseSymmetricKey) FromHex(src string) error

+ func (key NoiseSymmetricKey) ToHex() string

+ type Peer struct

+ func (peer *Peer) BeginSymmetricSession() error

+ func (peer *Peer) ExpireCurrentKeypairs()

+ func (peer *Peer) FlushNonceQueue()

+ func (peer *Peer) GetId() auth.AuthID

+ func (peer *Peer) NewTimer(expirationFunction func(*Peer)) *Timer

+ func (peer *Peer) ReceivedWithKeypair(receivedKeypair *Keypair) bool

+ func (peer *Peer) RoutineNonce()

+ func (peer *Peer) RoutineSequentialReceiver()

+ func (peer *Peer) RoutineSequentialSender()

+ func (peer *Peer) SendBuffer(buffer []byte) error

+ func (peer *Peer) SendHandshakeInitiation(isRetry bool) error

+ func (peer *Peer) SendHandshakeResponse() error

+ func (peer *Peer) SendKeepalive() bool

+ func (peer *Peer) SetEndpointFromPacket(endpoint Endpoint)

+ func (peer *Peer) Start()

+ func (peer *Peer) Stop()

+ func (peer *Peer) String() string

+ func (peer *Peer) ZeroAndFlushAll()

+ type QueueHandshakeElement struct

+ type QueueInboundElement struct

+ func (elem *QueueInboundElement) Drop()

+ func (elem *QueueInboundElement) IsDropped() bool

+ type QueueOutboundElement struct

+ func (elem *QueueOutboundElement) Drop()

+ func (elem *QueueOutboundElement) IsDropped() bool

+ type Timer struct

+ func (timer *Timer) Del()

+ func (timer *Timer) DelSync()

+ func (timer *Timer) IsPending() bool

+ func (timer *Timer) Mod(d time.Duration)

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