netx

Documentation

Index

• Constants
• type Client
  • func NewClient(address string, conf Config) (*Client, error)
  • func NewTcpClient(address string, conf Config) (*Client, error)
  • func NewUdpClient(address string, conf Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Receive() ([]byte, error)
  • func (c *Client) Send(data []byte) error
  • func (c *Client) TcpRecv() ([]byte, error)
  • func (c *Client) TcpSend(data []byte) error
  • func (c *Client) UdpRecv() ([]byte, error)
  • func (c *Client) UdpSend(data []byte) error
• type Config

Constants

const (
	DefaultNetwork      = "tcp"
	DefaultDialTimeout  = 6 * time.Second
	DefaultWriteTimeout = 6 * time.Second
	DefaultReadTimeout  = 6 * time.Second
	DefaultRetryDelay   = 2 * time.Second
	DefaultReadSize     = 1024 * 2
	DefaultMaxRetries   = 3
)

Types

type Client

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

func NewClient

func NewClient(address string, conf Config) (*Client, error)

func NewTcpClient

func NewTcpClient(address string, conf Config) (*Client, error)

func NewUdpClient

func NewUdpClient(address string, conf Config) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Receive

func (c *Client) Receive() ([]byte, error)

func (*Client) Send

func (c *Client) Send(data []byte) error

func (*Client) TcpRecv

func (c *Client) TcpRecv() ([]byte, error)

func (*Client) TcpSend

func (c *Client) TcpSend(data []byte) error

func (*Client) UdpRecv

func (c *Client) UdpRecv() ([]byte, error)

func (*Client) UdpSend

func (c *Client) UdpSend(data []byte) error

type Config

type Config struct {
	Network      string
	MaxRetries   int
	ReadSize     int
	DialTimeout  time.Duration
	WriteTimeout time.Duration
	ReadTimeout  time.Duration
	RetryDelay   time.Duration
}