pointsub

Jan 7, 2025

Changes in this version

+ func SetLog(filename string, stderr ...bool)

Dec 10, 2024

Changes in this version

+ var ErrServerAlreadyStarted = errors.New("服务器已经启动")

+ var Network = "pointsub"

+ func Dial(ctx context.Context, h host.Host, pid peer.ID, tag protocol.ID) (net.Conn, error)

+ func Listen(h host.Host, tag protocol.ID) (net.Listener, error)

+ func NewLimitedConn(conn net.Conn, maxSize int) net.Conn

+ type Client struct

+ func NewClient(h host.Host, config *ClientConfig) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Send(ctx context.Context, peerID peer.ID, protocolID protocol.ID, request []byte) ([]byte, error)

+ type ClientConfig struct

+ ConnectTimeout time.Duration

+ EnableCompression bool

+ IdleConnTimeout time.Duration

+ MaxBlockSize int

+ MaxIdleConns int

+ MaxRetries int

+ ReadTimeout time.Duration

+ RetryInterval time.Duration

+ WriteTimeout time.Duration

+ func DefaultClientConfig() *ClientConfig

+ type ConnectionInfo struct

+ IdleTime time.Duration

+ LastActive time.Time

+ RemoteAddr string

+ type LimitedConn struct

+ func (c *LimitedConn) Read(b []byte) (n int, err error)

+ func (c *LimitedConn) Write(b []byte) (n int, err error)

+ type Server struct

+ func NewServer(h host.Host, config *ServerConfig) (*Server, error)

+ func (s *Server) GetConnectionsInfo() []ConnectionInfo

+ func (s *Server) Start(protocolID protocol.ID, handler StreamHandler) error

+ func (s *Server) Stop() error

+ type ServerConfig struct

+ BufferPoolSize int

+ CleanupInterval time.Duration

+ ConnectTimeout time.Duration

+ EnableCompression bool

+ IdleTimeout time.Duration

+ MaxBlockSize int

+ MaxConcurrentConns int

+ MaxIdleTime time.Duration

+ MaxMemoryUsage uint64

+ MaxRequestsPerConn int

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func DefaultServerConfig() *ServerConfig

+ func (c *ServerConfig) Validate() error

+ type StreamHandler func(request []byte) (response []byte, err error)