client

func DumpFBS ¶

func DumpFBS(req_fbs []byte, rsp_fbs []byte) error

TODO for debug dump req_fbs and rsp_fbs to file. req_fbs is flatbuffer encoded data, rsp_fbs is flatbuffer encoded data returned from server side. User can read from dump file, get req_fbs and send it to server, then check if the response from server is equal to rsp_fbs.

func GenerateMindAlphaServingRequest ¶

func GenerateMindAlphaServingRequest(batch *fe.IndexBatch, algoName string) (*flatbuffers.Builder, []byte, error)

encode IndexBatch to flatbufer.

func ParseMindAlphaServingRequest ¶

func ParseMindAlphaServingRequest(rqstBuf []byte)

for debug. deserialize flatbuffered byte slice to IndexBatch, and print Indexbatch

func ParseMindAlphaServingResponse ¶

func ParseMindAlphaServingResponse(rspBuf []byte) (*tensor.TensorScores, error)

func PutFBSBuilder ¶

func PutFBSBuilder(builder *flatbuffers.Builder)

func Request ¶

func Request(data []byte, connWrap *pool.ConnWrap, deadline time.Time) (<-chan []byte, error)

Request send flatbuffer encoded data to server, with the tcp connection represented by connWrap.. data: flatbufer encoded data connWrap: a wrapper of tcp connection, with some other informations deadline: timeout time

func WaitResponse ¶

func WaitResponse(rspChan <-chan []byte, rspTimeout time.Duration) ([]byte, error)

WaitResponse wait response data from server side. rspChan: return value of connWrap.PutRequest(reqId).