thrift

Documentation

Index

• func DeserializeThriftMessage(buf *bytes.Buffer, ts thrift.TStruct) (string, thrift.TMessageType, int32, error)
• func NewThriftRequestExec(tFac thrift.TTransportFactory, clientExec ClientExecutor, ...) bender.RequestExecutor
• type ClientExecutor

Functions

func DeserializeThriftMessage

func DeserializeThriftMessage(buf *bytes.Buffer, ts thrift.TStruct) (string, thrift.TMessageType, int32, error)

DeserializeThriftMessage deserializes a Thrift-encoded byte array.

func NewThriftRequestExec

func NewThriftRequestExec(tFac thrift.TTransportFactory, clientExec ClientExecutor, timeout time.Duration, hosts ...string) bender.RequestExecutor

NewThriftRequestExec creates a new Thrift-based RequestExecutor.

Types

type ClientExecutor

type ClientExecutor func(interface{}, thrift.TTransport) (interface{}, error)

A ClientExecutor executes a Thrift request.