ss2022

package

Go to main page

Versions in this module

v1

v1.10.1

Feb 22, 2024

v1.10.0

Feb 21, 2024

v1.9.0

Oct 5, 2023

v1.8.0

Jun 20, 2023

Changes in this version

+ const DefaultSlidingWindowFilterSize

+ type SlidingWindowFilter struct

+ func NewSlidingWindowFilter(size uint64) *SlidingWindowFilter

+ func (f *SlidingWindowFilter) Add(counter uint64) bool

+ func (f *SlidingWindowFilter) IsOk(counter uint64) bool

+ func (f *SlidingWindowFilter) MustAdd(counter uint64)

+ func (f *SlidingWindowFilter) Reset()

+ func (f *SlidingWindowFilter) Size() uint64

v1.7.0

Mar 24, 2023

v1.6.0

Feb 16, 2023

Changes in this version

+ var ShadowStreamHeadroom = zerocopy.Headroom

+ var ShadowStreamReaderInfo = zerocopy.ReaderInfo

+ var ShadowStreamWriterInfo = zerocopy.WriterInfo

+ func CheckPSKLength(method string, psk []byte, psks [][]byte) error

+ func PSKHash(psk []byte) [IdentityHeaderLength]byte

+ func PSKLengthForMethod(method string) (int, error)

+ type ClientCipherConfig struct

+ func NewClientCipherConfig(psk []byte, iPSKs [][]byte, enableUDP bool) (c *ClientCipherConfig, err error)

+ func (c *ClientCipherConfig) EIHPSKHashes() [][IdentityHeaderLength]byte

+ func (c *ClientCipherConfig) TCPIdentityHeaderCiphers(salt []byte) ([]cipher.Block, error)

+ func (c *ClientCipherConfig) UDPIdentityHeaderCiphers() []cipher.Block

+ func (c *ClientCipherConfig) UDPSeparateHeaderPackerCipher() cipher.Block

+ type CredStore struct

+ func (s *CredStore) Lock()

+ func (s *CredStore) ReplaceUserLookupMap(ulm UserLookupMap)

+ func (s *CredStore) Unlock()

+ func (s *CredStore) UpdateUserLookupMap(f func(ulm UserLookupMap))

+ type PSKLengthError struct

+ ExpectedLength int

+ PSK []byte

+ func (e PSKLengthError) Error() string

type SaltPool

+ func (p *SaltPool[T]) Check(salt T) bool

+ type ServerIdentityCipherConfig struct

+ IPSK []byte

+ func NewServerIdentityCipherConfig(iPSK []byte, enableUDP bool) (c ServerIdentityCipherConfig, err error)

+ func (c ServerIdentityCipherConfig) TCP(salt []byte) (cipher.Block, error)

+ func (c ServerIdentityCipherConfig) UDP() cipher.Block

+ type ServerUserCipherConfig struct

+ Name string

+ func NewServerUserCipherConfig(name string, psk []byte, enableUDP bool) (c *ServerUserCipherConfig, err error)

type ShadowPacketClientPacker

+ func (p *ShadowPacketClientPacker) ClientPackerInfo() zerocopy.ClientPackerInfo

type ShadowPacketClientUnpacker

+ func (p *ShadowPacketClientUnpacker) ClientUnpackerInfo() zerocopy.ClientUnpackerInfo

type ShadowPacketServerPacker

+ func (p *ShadowPacketServerPacker) ServerPackerInfo() zerocopy.ServerPackerInfo

type ShadowPacketServerUnpacker

+ func (p *ShadowPacketServerUnpacker) NewPacker() (zerocopy.ServerPacker, error)

+ func (p *ShadowPacketServerUnpacker) ServerUnpackerInfo() zerocopy.ServerUnpackerInfo

type ShadowStreamCipher

+ func NewShadowStreamCipher(aead cipher.AEAD) *ShadowStreamCipher

type ShadowStreamReader

+ func (r *ShadowStreamReader) ReaderInfo() zerocopy.ReaderInfo

type ShadowStreamWriter

+ func (w *ShadowStreamWriter) WriterInfo() zerocopy.WriterInfo

type TCPClient

+ func (c *TCPClient) Info() zerocopy.TCPClientInfo

type TCPServer

+ func (s *TCPServer) Info() zerocopy.TCPServerInfo

type UDPClient

+ func (c *UDPClient) Info() zerocopy.UDPClientInfo

type UDPServer

+ func (s *UDPServer) Info() zerocopy.UDPSessionServerInfo

+ type UserCipherConfig struct

+ PSK []byte

+ func NewUserCipherConfig(psk []byte, enableUDP bool) (c UserCipherConfig, err error)

+ func (c UserCipherConfig) AEAD(salt []byte) (cipher.AEAD, error)

+ func (c UserCipherConfig) Block() cipher.Block

+ func (c UserCipherConfig) ShadowStreamCipher(salt []byte) (*ShadowStreamCipher, error)

+ type UserLookupMap map[[IdentityHeaderLength]byte]*ServerUserCipherConfig

v1.5.2

Feb 3, 2023

v1.5.1

Nov 30, 2022

v1.5.0

Oct 30, 2022

Changes in this version

type TCPClient

+ func (c *TCPClient) String() string

type UDPClient

+ func (c *UDPClient) String() string

v1.4.0

Oct 15, 2022

Changes in this version

+ var ErrUnsafeStreamPrefixMismatch = errors.New("unsafe stream prefix mismatch")

+ type ShadowPacketClientMessageHeadroom struct

+ func (h ShadowPacketClientMessageHeadroom) FrontHeadroom() int

+ func (h ShadowPacketClientMessageHeadroom) RearHeadroom() int

+ type ShadowPacketServerMessageHeadroom struct

+ func (ShadowPacketServerMessageHeadroom) FrontHeadroom() int

+ func (ShadowPacketServerMessageHeadroom) RearHeadroom() int

v1.3.1

Sep 30, 2022

v1.3.0

Sep 29, 2022

v1.2.0

Sep 10, 2022

v1.1.0

Aug 11, 2022

Changes in this version

type UDPClient

+ func (c *UDPClient) LinkInfo() (int, int)

v1.0.0

Jul 16, 2022

Changes in this version

+ const HeaderTypeClientPacket

+ const HeaderTypeClientStream

+ const HeaderTypeServerPacket

+ const HeaderTypeServerStream

+ const IdentityHeaderLength

+ const MaxEpochDiff

+ const MaxPaddingLength

+ const MaxPayloadSize

+ const MaxTimeDiff

+ const MinPaddingLength

+ const ReplayWindowDuration

+ const TCPRequestFixedLengthHeaderLength

+ const TCPRequestVariableLengthHeaderNoPayloadMaxLength

+ const TCPResponseHeaderMaxLength

+ const UDPClientMessageHeaderFixedLength

+ const UDPClientMessageHeaderMaxLength

+ const UDPSeparateHeaderLength

+ const UDPServerMessageHeaderFixedLength

+ const UDPServerMessageHeaderMaxLength

+ var ErrBadPSKLength = errors.New("PSK length does not meet method requirements")

+ var ErrBadTimestamp = errors.New("time diff is over 30 seconds")

+ var ErrClientSaltMismatch = errors.New("client salt in response header does not match request")

+ var ErrClientSessionIDMismatch = errors.New("client session ID in server message header does not match current session")

+ var ErrFirstRead = errors.New("failed to read fixed-length header in one read call")

+ var ErrIdentityHeaderUserPSKNotFound = errors.New("decrypted identity header does not match any known uPSK")

+ var ErrIncompleteHeaderInFirstChunk = errors.New("header in first chunk is missing or incomplete")

+ var ErrPacketIncompleteHeader = errors.New("packet contains incomplete header")

+ var ErrPacketMissingPayload = errors.New("packet has no payload")

+ var ErrPaddingExceedChunkBorder = errors.New("padding in first chunk is shorter than advertised")

+ var ErrPaddingLengthOutOfRange = errors.New("padding length is less than 0 or greater than 900")

+ var ErrRepeatedSalt = errors.New("detected replay: repeated salt")

+ var ErrReplay = errors.New("detected replay")

+ var ErrTooManyServerSessions = errors.New("server session changed more than once during the last minute")

+ var ErrTypeMismatch = errors.New("header type mismatch")

+ var ErrUnknownMethod = errors.New("unknown method")

+ var ErrZeroLengthChunk = errors.New("length in length chunk is zero")

+ func NoPadding(_ socks5.Addr) bool

+ func PadAll(_ socks5.Addr) bool

+ func PadPlainDNS(targetAddr socks5.Addr) bool

+ func ParseSessionIDAndPacketID(b []byte) (sid, pid uint64)

+ func ParseTCPRequestFixedLengthHeader(b []byte) (n int, err error)

+ func ParseTCPRequestVariableLengthHeader(b []byte) (targetAddr socks5.Addr, payload []byte, err error)

+ func ParseTCPResponseHeader(b []byte, requestSalt []byte) (n int, err error)

+ func ParseUDPClientMessageHeader(b []byte) (targetAddr socks5.Addr, payloadStart, payloadLen int, err error)

+ func ParseUDPServerMessageHeader(b []byte, csid uint64) (targetAddr socks5.Addr, payloadStart, payloadLen int, err error)

+ func ValidateUnixEpochTimestamp(b []byte) error

+ func WriteSessionIDAndPacketID(b []byte, sid, pid uint64)

+ func WriteTCPRequestFixedLengthHeader(b []byte, length uint16)

+ func WriteTCPRequestVariableLengthHeader(b []byte, targetAddr socks5.Addr, payload []byte) (n int)

+ func WriteTCPResponseHeader(b []byte, requestSalt []byte, length uint16) (n int)

+ func WriteUDPClientMessageHeader(b []byte, targetAddr socks5.Addr, shouldPad func(socks5.Addr) bool) (n int, err error)

+ func WriteUDPServerMessageHeader(b []byte, csid uint64, targetAddr socks5.Addr, ...) (n int, err error)

+ type CipherConfig struct

+ PSK []byte

+ PSKs [][]byte

+ func NewCipherConfig(method string, psk []byte, psks [][]byte) (*CipherConfig, error)

+ func NewRandomCipherConfig(method string, keySize, eihCount int) (cipherConfig *CipherConfig, err error)

+ func (c *CipherConfig) ClientPSKHashes() [][IdentityHeaderLength]byte

+ func (c *CipherConfig) NewAEAD(salt []byte) cipher.AEAD

+ func (c *CipherConfig) NewBlock() cipher.Block

+ func (c *CipherConfig) NewShadowStreamCipher(salt []byte) *ShadowStreamCipher

+ func (c *CipherConfig) NewTCPIdentityHeaderClientCiphers(salt []byte) []cipher.Block

+ func (c *CipherConfig) NewTCPIdentityHeaderServerCipher(salt []byte) cipher.Block

+ func (c *CipherConfig) NewUDPIdentityHeaderClientCiphers() []cipher.Block

+ func (c *CipherConfig) NewUDPIdentityHeaderServerCipher() cipher.Block

+ func (c *CipherConfig) ServerPSKHashMap() map[[IdentityHeaderLength]byte]*CipherConfig

+ type Filter struct

+ func (f *Filter) Add(counter uint64) bool

+ func (f *Filter) IsOk(counter uint64) bool

+ func (f *Filter) MustAdd(counter uint64)

+ func (f *Filter) Reset()

+ type HeaderError struct

+ Err error

+ Expected T

+ Got T

+ func (e *HeaderError[T]) Error() string

+ func (e *HeaderError[T]) Unwrap() error

+ type PaddingPolicy func(targetAddr socks5.Addr) (shouldPad bool)

+ func ParsePaddingPolicy(paddingPolicy string) (PaddingPolicy, error)

+ type SaltPool struct

+ func NewSaltPool(retention time.Duration) *SaltPool[T]

+ func (p *SaltPool[T]) Add(salt T) bool

+ type ShadowPacketClientPacker struct

+ func (p *ShadowPacketClientPacker) FrontHeadroom() int

+ func (p *ShadowPacketClientPacker) PackInPlace(b []byte, targetAddr socks5.Addr, payloadStart, payloadLen, maxPacketLen int) (packetStart, packetLen int, err error)

+ func (p *ShadowPacketClientPacker) RearHeadroom() int

+ type ShadowPacketClientUnpacker struct

+ func (p *ShadowPacketClientUnpacker) FrontHeadroom() int

+ func (p *ShadowPacketClientUnpacker) RearHeadroom() int

+ func (p *ShadowPacketClientUnpacker) UnpackInPlace(b []byte, packetStart, packetLen int) (targetAddr socks5.Addr, hasTargetAddr bool, payloadStart, payloadLen int, ...)

+ type ShadowPacketReplayError struct

+ func (e *ShadowPacketReplayError) Error() string

+ func (e *ShadowPacketReplayError) Unwrap() error

+ type ShadowPacketServerPacker struct

+ func (p *ShadowPacketServerPacker) FrontHeadroom() int

+ func (p *ShadowPacketServerPacker) PackInPlace(b []byte, targetAddr socks5.Addr, payloadStart, payloadLen, maxPacketLen int) (packetStart, packetLen int, err error)

+ func (p *ShadowPacketServerPacker) RearHeadroom() int

+ type ShadowPacketServerUnpacker struct

+ func (p *ShadowPacketServerUnpacker) FrontHeadroom() int

+ func (p *ShadowPacketServerUnpacker) RearHeadroom() int

+ func (p *ShadowPacketServerUnpacker) UnpackInPlace(b []byte, packetStart, packetLen int) (targetAddr socks5.Addr, hasTargetAddr bool, payloadStart, payloadLen int, ...)

+ type ShadowStreamCipher struct

+ func (c *ShadowStreamCipher) DecryptInPlace(ciphertext []byte) (plaintext []byte, err error)

+ func (c *ShadowStreamCipher) DecryptTo(dst, ciphertext []byte) (plaintext []byte, err error)

+ func (c *ShadowStreamCipher) EncryptInPlace(plaintext []byte) (ciphertext []byte)

+ func (c *ShadowStreamCipher) EncryptTo(dst, plaintext []byte) (ciphertext []byte)

+ func (c *ShadowStreamCipher) Overhead() int

+ type ShadowStreamClientReadWriter struct

+ func NewShadowStreamClientReadWriter(rw zerocopy.DirectReadWriteCloser, cipherConfig *CipherConfig, ...) (sscrw *ShadowStreamClientReadWriter, err error)

+ func (rw *ShadowStreamClientReadWriter) Close() error

+ func (rw *ShadowStreamClientReadWriter) CloseRead() error

+ func (rw *ShadowStreamClientReadWriter) CloseWrite() error

+ func (rw *ShadowStreamClientReadWriter) FrontHeadroom() int

+ func (rw *ShadowStreamClientReadWriter) MaxPayloadSizePerWrite() int

+ func (rw *ShadowStreamClientReadWriter) MinPayloadBufferSizePerRead() int

+ func (rw *ShadowStreamClientReadWriter) ReadZeroCopy(b []byte, payloadBufStart, payloadBufLen int) (int, error)

+ func (rw *ShadowStreamClientReadWriter) RearHeadroom() int

+ func (rw *ShadowStreamClientReadWriter) WriteZeroCopy(b []byte, payloadStart, payloadLen int) (int, error)

+ type ShadowStreamReader struct

+ func (r *ShadowStreamReader) Close() error

+ func (r *ShadowStreamReader) FrontHeadroom() int

+ func (r *ShadowStreamReader) MinPayloadBufferSizePerRead() int

+ func (r *ShadowStreamReader) ReadZeroCopy(b []byte, payloadBufStart, payloadBufLen int) (payloadLen int, err error)

+ func (r *ShadowStreamReader) RearHeadroom() int

+ type ShadowStreamServerReadWriter struct

+ func NewShadowStreamServerReadWriter(rw zerocopy.DirectReadWriteCloser, cipherConfig *CipherConfig, ...) (sssrw *ShadowStreamServerReadWriter, targetAddr socks5.Addr, payload []byte, ...)

+ func (rw *ShadowStreamServerReadWriter) Close() error

+ func (rw *ShadowStreamServerReadWriter) CloseRead() error

+ func (rw *ShadowStreamServerReadWriter) CloseWrite() error

+ func (rw *ShadowStreamServerReadWriter) FrontHeadroom() int

+ func (rw *ShadowStreamServerReadWriter) MaxPayloadSizePerWrite() int

+ func (rw *ShadowStreamServerReadWriter) MinPayloadBufferSizePerRead() int

+ func (rw *ShadowStreamServerReadWriter) ReadZeroCopy(b []byte, payloadBufStart, payloadBufLen int) (int, error)

+ func (rw *ShadowStreamServerReadWriter) RearHeadroom() int

+ func (rw *ShadowStreamServerReadWriter) WriteZeroCopy(b []byte, payloadStart, payloadLen int) (int, error)

+ type ShadowStreamWriter struct

+ func (w *ShadowStreamWriter) Close() error

+ func (w *ShadowStreamWriter) FrontHeadroom() int

+ func (w *ShadowStreamWriter) MaxPayloadSizePerWrite() int

+ func (w *ShadowStreamWriter) RearHeadroom() int

+ func (w *ShadowStreamWriter) WriteZeroCopy(b []byte, payloadStart, payloadLen int) (payloadWritten int, err error)

+ type TCPClient struct

+ func NewTCPClient(address string, dialerTFO bool, dialerFwmark int, cipherConfig *CipherConfig, ...) *TCPClient

+ func (c *TCPClient) Dial(targetAddr socks5.Addr, payload []byte) (tfoConn tfo.Conn, rw zerocopy.ReadWriter, err error)

+ func (c *TCPClient) NativeInitialPayload() bool

+ type TCPServer struct

+ func NewTCPServer(cipherConfig *CipherConfig, ...) *TCPServer

+ func (s *TCPServer) Accept(conn tfo.Conn) (rw zerocopy.ReadWriter, targetAddr socks5.Addr, payload []byte, err error)

+ func (s *TCPServer) DefaultTCPConnCloser() zerocopy.TCPConnCloser

+ func (s *TCPServer) NativeInitialPayload() bool

+ type UDPClient struct

+ func NewUDPClient(addrPort netip.AddrPort, mtu, fwmark int, cipherConfig *CipherConfig, ...) *UDPClient

+ func (c *UDPClient) AddrPort() (netip.AddrPort, int, int, bool)

+ func (c *UDPClient) FrontHeadroom() int

+ func (c *UDPClient) NewSession() (zerocopy.Packer, zerocopy.Unpacker, error)

+ func (c *UDPClient) RearHeadroom() int

+ type UDPServer struct

+ func NewUDPServer(cipherConfig *CipherConfig, shouldPad PaddingPolicy, ...) *UDPServer

+ func (s *UDPServer) FrontHeadroom() int

+ func (s *UDPServer) NewPacker(csid uint64) (zerocopy.Packer, error)

+ func (s *UDPServer) NewUnpacker(b []byte, csid uint64) (zerocopy.Unpacker, error)

+ func (s *UDPServer) RearHeadroom() int

+ func (s *UDPServer) SessionInfo(b []byte) (csid uint64, err error)

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