ztcpclient

Documentation

Index

• Constants
• Variables
• func BenchTicket(tcpClients *MultiClient)
• func ClientStart(addr string)
• func GetGroupMessageID(msg []byte) string
• type Command
  • func (s Command) String() string
  • func (s Command) Toa() string
• type MultiClient
  • func MultiClientCreate(addr string) *MultiClient
  • func (s *MultiClient) Get() *TcpClient
  • func (s *MultiClient) GetMessage(key string) []byte
  • func (s *MultiClient) GetViaCpu(cpu int) *TcpClient
  • func (s *MultiClient) SendMessage(msg string) string
  • func (s *MultiClient) SendMessageViaCpu(msg string, cpu int) string
• type TcpClient
  • func NewTcpClient(addr string) *TcpClient
  • func (s *TcpClient) GetMessage(key string) []byte
  • func (s *TcpClient) SendBinary(data []byte)
  • func (s *TcpClient) SendMessage(msgstr string) string
  • func (s *TcpClient) SendMessageEncode(m interface{}) uint64

Constants

const CMaxResultRetry = 10

Variables

var Result ztcputil.ConcurrentMap // [CMaxResultBuffer]*[]byte

var ResultIndex ztcputil.Count32

Functions

func BenchTicket

func BenchTicket(tcpClients *MultiClient)

func ClientStart

func ClientStart(addr string)

func GetGroupMessageID

func GetGroupMessageID(msg []byte) string

Types

type Command

type Command int

const (
	MessageNew Command = iota
	MessageEdit
	MessageBroadcast
)

func (Command) String

func (s Command) String() string

func (Command) Toa

func (s Command) Toa() string

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 NewTcpClient(addr string) *TcpClient

func (*TcpClient) GetMessage

func (s *TcpClient) GetMessage(key string) []byte

func (*TcpClient) SendBinary

func (s *TcpClient) SendBinary(data []byte)

func (*TcpClient) SendMessage

func (s *TcpClient) SendMessage(msgstr string) string

func (*TcpClient) SendMessageEncode

func (s *TcpClient) SendMessageEncode(m interface{}) uint64