Search code examples
gothrift

How do I decode an Apache Thrift payload in Go?


This is the working JavaScript version of what I'm trying to do in Go.

let next = TBufferedTransport.receiver(data => {

 let proto = new TCompactProtocol(data)
 let ae = new AnalyticEventBatch()

 ae.read(proto)
});

Using Go, I can't get Thrift to decode the payload - what should I be doing?


Solution

  • var data []byte //that's the byte array you received
    
    transp := &TMemoryBuffer{Buffer: bytes.NewBuffer(data)}
    proto := NewTCompactProtocol(transp)
    
    ae := NewAnalyticEventBatch()
    ae.Read(proto)
    

    It would be cleaner if you could read from file/socket directly. Then you would only need thrift StreamTransport