shadowsocks

type ChunkReader interface {
	// ReadChunk reads the next chunk and returns its payload.  The caller must
	// complete its use of the returned buffer before the next call.
	// The buffer is nil iff there is an error.  io.EOF indicates a close.
	ReadChunk() ([]byte, error)
}

type CipherEntry struct {
	ID            string
	Cipher        shadowaead.Cipher
	SaltGenerator ServerSaltGenerator
	// contains filtered or unexported fields
}

type CipherList interface {
	// Returns a snapshot of the cipher list optimized for this client IP,
	// and also the number of bytes needed for TCP trial decryption.
	SnapshotForClientIP(clientIP net.IP) (int, []*list.Element)
	MarkUsedByClientIP(e *list.Element, clientIP net.IP)
	// Update replaces the current contents of the CipherList with `contents`,
	// which is a List of *CipherEntry.  Update takes ownership of `contents`,
	// which must not be read or written after this call.
	Update(contents *list.List) error
}

type Client interface {
	// DialTCP connects to `raddr` over TCP though a Shadowsocks proxy.
	// `laddr` is a local bind address, a local address is automatically chosen if nil.
	// `raddr` has the form `host:port`, where `host` can be a domain name or IP address.
	DialTCP(laddr *net.TCPAddr, raddr string) (onet.DuplexConn, error)

	// ListenUDP relays UDP packets though a Shadowsocks proxy.
	// `laddr` is a local bind address, a local address is automatically chosen if nil.
	ListenUDP(laddr *net.UDPAddr) (net.PacketConn, error)
}

type Reader interface {
	io.Reader
	io.WriterTo
}

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

type SaltGenerator interface {
	// Returns a new salt
	GetSalt(salt []byte) error
}

type ServerSaltGenerator interface {
	SaltGenerator
	// IsServerSalt returns true if the salt was created by this generator
	// and is marked as server-originated.
	IsServerSalt(salt []byte) bool
}

type TCPService interface {
	// Serve adopts the listener, which will be closed before Serve returns.  Serve returns an error unless Stop() was called.
	Serve(listener *net.TCPListener) error
	// Stop closes the listener but does not interfere with existing connections.
	Stop() error
	// GracefulStop calls Stop(), and then blocks until all resources have been cleaned up.
	GracefulStop() error
}

type UDPService interface {
	// Serve adopts the clientConn, and will not return until it is closed by Stop().
	Serve(clientConn net.PacketConn) error
	// Stop closes the clientConn and prevents further forwarding of packets.
	Stop() error
	// GracefulStop calls Stop(), and then blocks until all resources have been cleaned up.
	GracefulStop() error
}

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