Versions in this module Expand all Collapse all v1 v1.0.0 Jun 7, 2023 Changes in this version + func ClientWithExpectReply(expectReply bool) func(*ClientOptions) + func ClientWithKeepAlive(keepAlive bool) func(*ClientOptions) + func ClientWithKeyFetcher(keyFetcher key.ClientFetcher) func(*ClientOptions) + func ClientWithReadTimeout(timeout time.Duration) func(*ClientOptions) + func ClientWithWriteTimeout(timeout time.Duration) func(*ClientOptions) + func ServerWithKeyManager(keyManager key.ServerManager) func(*ServerOptions) + func ServerWithLogger(logger *log.Logger) func(*ServerOptions) + func ServerWithReadTimeout(timeout time.Duration) func(*ServerOptions) + func ServerWithSecretManager(secretManager secret.Manager) func(*ServerOptions) + func ServerWithWriteTimeout(timeout time.Duration) func(*ServerOptions) + type Client struct + func DialTCP(hostport string, optFunc ...func(*ClientOptions)) (*Client, error) + func DialUDP(hostport string, optFunc ...func(*ClientOptions)) (*Client, error) + func (c *Client) Close() error + func (c *Client) LocalAddr() net.Addr + func (c *Client) Read(p []byte) (int, error) + func (c *Client) RemoteAddr() net.Addr + func (c *Client) SetDeadline(t time.Time) error + func (c *Client) SetReadDeadline(t time.Time) error + func (c *Client) SetWriteDeadline(t time.Time) error + func (c *Client) Write(p []byte) (n int, err error) + type ClientOptions struct + type ClientPool struct + func NewClientPool(hostport string, maxIdleClients int64, maxOpenClients int64, ...) ClientPool + func (cp *ClientPool) Close() error + func (cp *ClientPool) Get() (*Client, error) + type Server struct + func NewServer(handler ServerHandler, optFuncs ...func(*ServerOptions)) *Server + func (s *Server) Close() error + func (s *Server) StartTCP(hostport string) (net.Addr, error) + func (s *Server) StartUDP(hostport string) (net.Addr, error) + type ServerHandler interface + Handle func(w io.Writer, r io.Reader, remoteAddr net.Addr) error + type ServerHandlerFunc func(w io.Writer, r io.Reader, remoteAddr net.Addr) error + func (s ServerHandlerFunc) Handle(w io.Writer, r io.Reader, remoteAddr net.Addr) error + type ServerOptions struct