testhelper

Documentation

Index

• Constants
• func NewTcpComm(addr string) loadgenlib.Caller
• type ServerReq
• type ServerResp
• type TcpComm
  • func (comm *TcpComm) BuildReq() loadgenlib.RawReq
  • func (comm *TcpComm) Call(req []byte, timeoutNs time.Duration) ([]byte, error)
  • func (comm *TcpComm) CheckResp(rawReq loadgenlib.RawReq, rawResp loadgenlib.RawResp) *loadgenlib.CallResult
• type TcpServer
  • func NewTcpServer() *TcpServer
  • func (self *TcpServer) Close() bool
  • func (self *TcpServer) Listen(addr string) error

Constants

const (
	DELIM = '\n'
)

Functions

func NewTcpComm

func NewTcpComm(addr string) loadgenlib.Caller

Types

type ServerReq

type ServerReq struct {
	Id       int64
	Operands []int
	Operator string
}

type ServerResp

type ServerResp struct {
	Id      int64
	Formula string
	Result  int
	Err     error
}

type TcpComm

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

func (*TcpComm) BuildReq

func (comm *TcpComm) BuildReq() loadgenlib.RawReq

func (*TcpComm) Call

func (comm *TcpComm) Call(req []byte, timeoutNs time.Duration) ([]byte, error)

func (*TcpComm) CheckResp

func (comm *TcpComm) CheckResp(
	rawReq loadgenlib.RawReq, rawResp loadgenlib.RawResp) *loadgenlib.CallResult

type TcpServer

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

func NewTcpServer

func NewTcpServer() *TcpServer

func (*TcpServer) Close

func (self *TcpServer) Close() bool

func (*TcpServer) Listen

func (self *TcpServer) Listen(addr string) error