kitex

Documentation

Index

• func EqualData(d1, d2 *echo.KitexData) bool
• func ExchangeFixed(data *echo.KitexData, client kitexechoservice.Client, ...)
• func ExchangeQPS(data *echo.KitexData, client kitexechoservice.Client, wg *sync.WaitGroup, ...)
• func MakeClient(addr string) (kitexechoservice.Client, error)
• func StartServer(addr string, wg *sync.WaitGroup) (srv server.Server)
• func WithClientIOBufferSize() client.Option
• func WithServerIOBufferSize() server.Option
• type DataSet
  • func ConvertDataSet(ds data.DataSet) (ads DataSet)
• type EchoImpl
  • func (s *EchoImpl) Echo(ctx context.Context, req *echo.KitexData) (resp *echo.KitexData, err error)

Functions

func EqualData

func EqualData(d1, d2 *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 MakeClient

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

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 DataSet

type DataSet = [][]*echo.KitexData

func ConvertDataSet

func ConvertDataSet(ds data.DataSet) (ads DataSet)

type EchoImpl

type EchoImpl struct{}

func (*EchoImpl) Echo

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