dtls

Mar 9, 2023

Changes in this version

+ const SniffRead

+ const SniffWrite

+ func SetSniffPacketsCallback(callback SniffPacketsCallback)

+ type SniffPacketsCallback func(transportType string, op string, from string, to string, data []byte)

Mar 1, 2023

Changes in this version

type SessionStore

+ CidVersion uint16

+ PeerIdentity []byte

Feb 28, 2023

Changes in this version

+ const DtlsExtConnectionIdLegacy

type CipherSuite

+ func (cs CipherSuite) String() string

type Peer

+ func (p *Peer) CipherSuite() string

+ func (p *Peer) SessionPeerCid() []byte

Jul 13, 2022

Changes in this version

type Listener

+ func (l *Listener) UpdatePeer(p *Peer, trans TransportEndpoint, lock bool)

May 6, 2022

Changes in this version

+ const ContentType_Appdata_Cid

+ const DtlsExtConnectionId

type Listener

+ func (l *Listener) EnableConnectionId(cidLen int)

type Peer

+ func (p *Peer) SessionCid() []byte

type SessionStore

+ Cid []byte

+ PeerCid []byte

Feb 11, 2022

Changes in this version

type Peer

+ func (p *Peer) SessionIdentityOrPublicKeyString() string

Jan 7, 2022

Changes in this version

type SessionStore

+ SequenceNumber0 uint64

+ SequenceNumber1 uint64

Nov 29, 2021

Changes in this version

+ const DtlsVersion10

Nov 16, 2021

Changes in this version

+ var MaxPacketSize = 16384

Nov 3, 2021

Changes in this version

type Listener

+ func (l *Listener) LocalAddr() string

Sep 22, 2021

Changes in this version

type CipherSuite

+ func (cs CipherSuite) NeedCert() bool

+ func (cs CipherSuite) NeedPsk() bool

Aug 20, 2021

Changes in this version

type CipherSuite

+ const CipherSuite_TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256

Apr 28, 2021

Changes in this version

type Peer

+ func (p *Peer) SessionCertificate() *x509.Certificate

+ func (p *Peer) SessionPublicKey() []byte

Jan 19, 2021

Changes in this version

+ const EccCurve_P256

+ var ValidateCertificateCallback func(*Peer, *x509.Certificate) error

+ func CertificateFromDisk(keyPath string, certificatePath string) (*tls.Certificate, error)

type CipherSuite

+ const CipherSuite_TLS_ECDHE_ECDSA_WITH_AES_128_CCM_8

type Listener

+ func (l *Listener) SetCertificate(cert tls.Certificate) error

+ func (l *Listener) SetFrameLimits(maxPacket int, maxHandshake int)

Dec 12, 2020

Changes in this version

+ var SessionExportCallback func(*Peer)

+ var SessionImportCallback func(*Peer) string

+ var SessionInactivityTimeout = time.Hour * 24

+ func SetExportSecret(key string)

+ type KeyBlock struct

+ ClientIV []byte

+ ClientMac []byte

+ ClientWriteKey []byte

+ MasterSecret []byte

+ ServerIV []byte

+ ServerMac []byte

+ ServerWriteKey []byte

+ func (kb *KeyBlock) Print() string

type Listener

+ func (l *Listener) EachPeer(callback func(peer *Peer))

type Peer

+ func (p *Peer) SessionExport() string

+ type SessionStore struct

+ Epoch uint16

+ Id []byte

+ KeyBlock *KeyBlock

+ RemoteAddr string

+ SelectedCipherSuite CipherSuite

+ SequenceNumber uint64

+ Type string

Nov 24, 2020

Changes in this version

+ const AadAuthLen

+ const AlertDesc_AccessDenied

+ const AlertDesc_BadCertificate

+ const AlertDesc_BadRecordMac

+ const AlertDesc_CertificateExpired

+ const AlertDesc_CertificateRevoked

+ const AlertDesc_CertificateUnknown

+ const AlertDesc_CloseNotify

+ const AlertDesc_DecodeError

+ const AlertDesc_DecompressionFailure

+ const AlertDesc_DecryptError

+ const AlertDesc_DecryptionFailed

+ const AlertDesc_ExportRestriction

+ const AlertDesc_HandshakeFailure

+ const AlertDesc_IllegalParameter

+ const AlertDesc_InsufficientSecurity

+ const AlertDesc_InternalError

+ const AlertDesc_NoCertificate

+ const AlertDesc_NoRenegotiation

+ const AlertDesc_Noop

+ const AlertDesc_ProtocolVersion

+ const AlertDesc_RecordOverflow

+ const AlertDesc_UnexpectedMessage

+ const AlertDesc_UnknownCa

+ const AlertDesc_UnsupportedCertificate

+ const AlertDesc_UnsupportedExtension

+ const AlertDesc_UserCanceled

+ const AlertType_Fatal

+ const AlertType_Warning

+ const ContentType_Alert

+ const ContentType_Appdata

+ const ContentType_ChangeCipherSpec

+ const ContentType_Handshake

+ const DtlsVersion12

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelWarn

+ const SessionType_Client

+ const SessionType_Server

+ var DebugEncryption bool = false

+ var DebugHandshake bool = false

+ var DebugHandshakeHash bool = false

+ var HandshakeCompleteCallback func(*Peer, []byte, time.Duration, error)

+ var PeerInactivityTimeout = time.Hour * 24

+ var SessionCacheSweepInterval = time.Minute * -5

+ var SessionCacheTtl = time.Hour * 24

+ func DebugAll()

+ func GetPskFromKeystore(identity []byte, remoteAddr string) []byte

+ func SessionCacheSize() int

+ func SetKeyStores(ks []Keystore)

+ func SetLogFunc(lf LogFunc)

+ func SetLogLevel(level string)

+ type CCM interface

+ MaxLength func() int

+ func NewCCM(b cipher.Block, tagsize, noncesize int) (CCM, error)

+ type Cipher interface

+ Decrypt func(rec *record, key []byte, iv []byte, mac []byte) ([]byte, error)

+ Encrypt func(rec *record, key []byte, iv []byte, mac []byte) ([]byte, error)

+ GenerateKeyBlock func(masterSecret []byte, rawKeyBlock []byte) *keyBlock

+ GetPrfSize func() int

+ type CipherCBC struct

+ func (c CipherCBC) Decrypt(rec *record, key []byte, iv []byte, mac []byte) ([]byte, error)

+ func (c CipherCBC) Encrypt(rec *record, key []byte, iv []byte, mac []byte) ([]byte, error)

+ func (c CipherCBC) GenerateKeyBlock(masterSecret []byte, rawKeyBlock []byte) *keyBlock

+ func (c CipherCBC) GetPrfSize() int

+ type CipherCcm struct

+ func (c CipherCcm) Decrypt(rec *record, key []byte, iv []byte, mac []byte) ([]byte, error)

+ func (c CipherCcm) Encrypt(rec *record, key []byte, iv []byte, mac []byte) ([]byte, error)

+ func (c CipherCcm) GenerateKeyBlock(masterSecret []byte, rawKeyBlock []byte) *keyBlock

+ func (c CipherCcm) GetPrfSize() int

+ type CipherSuite uint16

+ const CipherSuite_TLS_PSK_WITH_AES_128_CBC_SHA256

+ const CipherSuite_TLS_PSK_WITH_AES_128_CCM_8

+ type CompressionMethod uint8

+ const CompressionMethod_Null

+ type ContentType uint8

+ type Keystore interface

+ GetPsk func(identity []byte, remoteAddr string) ([]byte, error)

+ type KeystoreInMemory struct

+ func NewKeystoreInMemory() *KeystoreInMemory

+ func (ks *KeystoreInMemory) AddKey(identity []byte, psk []byte)

+ func (ks *KeystoreInMemory) GetPsk(identity []byte, remoteAddr string) ([]byte, error)

+ type Listener struct

+ func NewUdpListener(listener string, readTimeout time.Duration) (*Listener, error)

+ func (l *Listener) AddCipherSuite(cipherSuite CipherSuite)

+ func (l *Listener) AddCompressionMethod(compressionMethod CompressionMethod)

+ func (l *Listener) AddPeer(addr string, identity []byte) (*Peer, error)

+ func (l *Listener) AddPeerWithParams(params *PeerParams) (*Peer, error)

+ func (l *Listener) CountPeers() int

+ func (l *Listener) FindPeer(addr string) (*Peer, error)

+ func (l *Listener) Read() ([]byte, *Peer)

+ func (l *Listener) RemovePeer(peer *Peer, alertDesc uint8) error

+ func (l *Listener) RemovePeerByAddr(addr string, alertDesc uint8) error

+ func (l *Listener) Shutdown() error

+ type LogFunc func(ts time.Time, level string, peer *Peer, err error, msg string)

+ type Peer struct

+ func (p *Peer) Close(alertDesc uint8)

+ func (p *Peer) LastActivity() time.Time

+ func (p *Peer) Lock()

+ func (p *Peer) Read(timeout time.Duration) ([]byte, error)

+ func (p *Peer) RemoteAddr() string

+ func (p *Peer) SessionIdentity() []byte

+ func (p *Peer) SessionIdentityString() string

+ func (p *Peer) SetName(name string)

+ func (p *Peer) Unlock()

+ func (p *Peer) UseQueue(en bool)

+ func (p *Peer) Write(data []byte) error

+ type PeerParams struct

+ Addr string

+ HandshakeTimeout time.Duration

+ Identity []byte

+ SessionId []byte

+ type Transport interface

+ Local func() string

+ NewEndpoint func(address string) TransportEndpoint

+ ReadPacket func() ([]byte, TransportEndpoint, error)

+ Shutdown func() error

+ Type func() string

+ type TransportEndpoint interface

+ String func() string

+ WritePacket func(data []byte) error

+ func NewUdpPeerFromSocket(socket *net.UDPConn, addr *net.UDPAddr) TransportEndpoint