service

Mar 28, 2024

Changes in this version

+ func StreamServe(accept StreamListener, handle StreamHandler)

type CipherEntry

+ CryptoKey *shadowsocks.EncryptionKey

+ type NoOpTCPMetrics struct

+ func (m *NoOpTCPMetrics) AddAuthenticatedTCPConnection(clientAddr net.Addr, accessKey string)

+ func (m *NoOpTCPMetrics) AddClosedTCPConnection(clientInfo ipinfo.IPInfo, clientAddr net.Addr, accessKey string, status string, ...)

+ func (m *NoOpTCPMetrics) AddOpenTCPConnection(clientInfo ipinfo.IPInfo)

+ func (m *NoOpTCPMetrics) AddTCPCipherSearch(accessKeyFound bool, timeToCipher time.Duration)

+ func (m *NoOpTCPMetrics) AddTCPProbe(status, drainResult string, port int, clientProxyBytes int64)

+ func (m *NoOpTCPMetrics) GetIPInfo(net.IP) (ipinfo.IPInfo, error)

+ type NoOpUDPMetrics struct

+ func (m *NoOpUDPMetrics) AddUDPCipherSearch(accessKeyFound bool, timeToCipher time.Duration)

+ func (m *NoOpUDPMetrics) AddUDPNatEntry(clientAddr net.Addr, accessKey string)

+ func (m *NoOpUDPMetrics) AddUDPPacketFromClient(clientInfo ipinfo.IPInfo, accessKey, status string, ...)

+ func (m *NoOpUDPMetrics) AddUDPPacketFromTarget(clientInfo ipinfo.IPInfo, accessKey, status string, ...)

+ func (m *NoOpUDPMetrics) GetIPInfo(net.IP) (ipinfo.IPInfo, error)

+ func (m *NoOpUDPMetrics) RemoveUDPNatEntry(clientAddr net.Addr, accessKey string)

+ type PacketHandler interface

+ Handle func(clientConn net.PacketConn)

+ SetTargetIPValidator func(targetIPValidator onet.TargetIPValidator)

+ func NewPacketHandler(natTimeout time.Duration, cipherList CipherList, m UDPMetrics) PacketHandler

+ type ShadowsocksTCPMetrics interface

+ AddTCPCipherSearch func(accessKeyFound bool, timeToCipher time.Duration)

+ type StreamAuthenticateFunc func(clientConn transport.StreamConn) (string, transport.StreamConn, *onet.ConnectionError)

+ func NewShadowsocksStreamAuthenticator(ciphers CipherList, replayCache *ReplayCache, metrics ShadowsocksTCPMetrics) StreamAuthenticateFunc

+ type StreamHandler func(ctx context.Context, conn transport.StreamConn)

+ type StreamListener func() (transport.StreamConn, error)

+ func WrapStreamListener[T transport.StreamConn](f func() (T, error)) StreamListener

+ type TCPHandler interface

+ Handle func(ctx context.Context, conn transport.StreamConn)

+ SetTargetDialer func(dialer transport.StreamDialer)

+ func NewTCPHandler(port int, authenticate StreamAuthenticateFunc, m TCPMetrics, ...) TCPHandler

+ type TCPMetrics interface

+ AddAuthenticatedTCPConnection func(clientAddr net.Addr, accessKey string)

+ AddClosedTCPConnection func(clientInfo ipinfo.IPInfo, clientAddr net.Addr, accessKey string, status string, ...)

+ AddOpenTCPConnection func(clientInfo ipinfo.IPInfo)

+ AddTCPProbe func(status, drainResult string, port int, clientProxyBytes int64)

+ type UDPMetrics interface

+ AddUDPCipherSearch func(accessKeyFound bool, timeToCipher time.Duration)

+ AddUDPNatEntry func(clientAddr net.Addr, accessKey string)

+ AddUDPPacketFromClient func(clientInfo ipinfo.IPInfo, accessKey, status string, ...)

+ AddUDPPacketFromTarget func(clientInfo ipinfo.IPInfo, accessKey, status string, ...)

+ RemoveUDPNatEntry func(clientAddr net.Addr, accessKey string)

Oct 5, 2020

Changes in this version

+ const MaxCapacity

+ const ServerSaltMarkLen

+ type CipherEntry struct

+ Cipher shadowaead.Cipher

+ ID string

+ SaltGenerator ServerSaltGenerator

+ func MakeCipherEntry(id string, cipher shadowaead.Cipher, secret string) CipherEntry

+ type CipherList interface

+ MarkUsedByClientIP func(e *list.Element, clientIP net.IP)

+ SnapshotForClientIP func(clientIP net.IP) (int, []*list.Element)

+ Update func(contents *list.List) error

+ func MakeTestCiphers(secrets []string) (CipherList, error)

+ func NewCipherList() CipherList

+ type ReplayCache struct

+ func NewReplayCache(capacity int) ReplayCache

+ func (c *ReplayCache) Add(id string, salt []byte) bool

+ type ServerSaltGenerator interface

+ IsServerSalt func(salt []byte) bool

+ var RandomServerSaltGenerator ServerSaltGenerator = randomServerSaltGenerator{}

+ func NewServerSaltGenerator(secret string) ServerSaltGenerator

+ type TCPService interface

+ GracefulStop func() error

+ Serve func(listener *net.TCPListener) error

+ SetTargetIPValidator func(targetIPValidator onet.TargetIPValidator)

+ Stop func() error

+ func NewTCPService(ciphers CipherList, replayCache *ReplayCache, m metrics.ShadowsocksMetrics, ...) TCPService

+ type UDPService interface

+ GracefulStop func() error

+ Serve func(clientConn net.PacketConn) error

+ SetTargetIPValidator func(targetIPValidator onet.TargetIPValidator)

+ Stop func() error

+ func NewUDPService(natTimeout time.Duration, cipherList CipherList, m metrics.ShadowsocksMetrics) UDPService