kitex

Documentation

Index

• func EqualData(data1, data2 *echo.KitexData) bool
• func ExchangeFixed(data *echo.KitexData, client kitexechoservice.Client, ...)
• func ExchangeQPS(data *echo.KitexData, client kitexechoservice.Client, wg *sync.WaitGroup, ...)
• func GenData(clientsCount, size int, r *rand.Rand) (arr [][]*echo.KitexData)
• func MakeClient(addr string) (kitexechoservice.Client, error)
• func NewRandomData(r *rand.Rand) *echo.KitexData
• func StartServer(addr string, wg *sync.WaitGroup) (srv server.Server)
• func WithClientIOBufferSize() client.Option
• func WithServerIOBufferSize() server.Option
• type EchoImpl
  • func (s *EchoImpl) Echo(ctx context.Context, req *echo.KitexData) (resp *echo.KitexData, err error)

Functions

func EqualData

func EqualData(data1, data2 *echo.KitexData) bool

func ExchangeFixed

func ExchangeFixed(data *echo.KitexData, client kitexechoservice.Client,
	copsD chan<- time.Duration,
	wg *sync.WaitGroup,
	b *testing.B,
)

func ExchangeQPS

func ExchangeQPS(data *echo.KitexData, client kitexechoservice.Client,
	wg *sync.WaitGroup,
	b *testing.B,
)

func GenData

func GenData(clientsCount, size int, r *rand.Rand) (arr [][]*echo.KitexData)

func MakeClient

func MakeClient(addr string) (kitexechoservice.Client, error)

func NewRandomData

func NewRandomData(r *rand.Rand) *echo.KitexData

func StartServer

func StartServer(addr string, wg *sync.WaitGroup) (srv server.Server)

func WithClientIOBufferSize

func WithClientIOBufferSize() client.Option

func WithServerIOBufferSize

func WithServerIOBufferSize() server.Option

Types

type EchoImpl

type EchoImpl struct{}

func (*EchoImpl) Echo

func (s *EchoImpl) Echo(ctx context.Context, req *echo.KitexData) (resp *echo.KitexData, err error)