udpsdk

Documentation

Index

• type UDPClient
  • func NewClient(ctx context.Context, cfgs ...UDPClientConfig) (*UDPClient, error)
  • func (c *UDPClient) Close() error
  • func (c *UDPClient) ReceiveMessage(msg chan<- []byte)
  • func (c *UDPClient) SendMessage(msg []byte)
• type UDPClientConfig

Types

type UDPClient

type UDPClient struct {
	ID string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, cfgs ...UDPClientConfig) (*UDPClient, error)

func (*UDPClient) Close

func (c *UDPClient) Close() error

func (*UDPClient) ReceiveMessage

func (c *UDPClient) ReceiveMessage(msg chan<- []byte)

func (*UDPClient) SendMessage

func (c *UDPClient) SendMessage(msg []byte)

type UDPClientConfig

type UDPClientConfig struct {
	Gzip           bool
	WriteWait      time.Duration
	PongWait       time.Duration
	PingPeriod     time.Duration
	MaxMessageSize uint
	Addr           string
	TlsConf        *tls.Config
}