Documentation ¶
Index ¶
Constants ¶
View Source
const CMaxResultRetry = 10
Variables ¶
View Source
var Result ztcputil.ConcurrentMap // [CMaxResultBuffer]*[]byte
View Source
var ResultIndex ztcputil.Count32
Functions ¶
func BenchTicket ¶
func BenchTicket(tcpClients *MultiClient)
func ClientStart ¶
func ClientStart(addr string)
func GetGroupMessageID ¶
Types ¶
type MultiClient ¶
type MultiClient struct {
// contains filtered or unexported fields
}
func MultiClientCreate ¶
func MultiClientCreate(addr string) *MultiClient
func (*MultiClient) Get ¶
func (s *MultiClient) Get() *TcpClient
func (*MultiClient) GetMessage ¶
func (s *MultiClient) GetMessage(key string) []byte
func (*MultiClient) GetViaCpu ¶
func (s *MultiClient) GetViaCpu(cpu int) *TcpClient
func (*MultiClient) SendMessage ¶
func (s *MultiClient) SendMessage(msg string) string
func (*MultiClient) SendMessageViaCpu ¶
func (s *MultiClient) SendMessageViaCpu(msg string, cpu int) string
type TcpClient ¶
type TcpClient struct {
// contains filtered or unexported fields
}
func NewTcpClient ¶
func (*TcpClient) GetMessage ¶
func (*TcpClient) SendBinary ¶
func (*TcpClient) SendMessage ¶
func (*TcpClient) SendMessageEncode ¶
Click to show internal directories.
Click to hide internal directories.