thrift

Documentation

Index

• Constants
• func Deserialize(payload []byte) thrift.TStruct
• func Serialize(tStruct thrift.TStruct) []byte
• func SerializeNew(tStruct thrift.TStruct) []byte
• func TBaseLookup(Type int16) thrift.TStruct
• type DeserializeServer
  • func NewDeserializeServer() *DeserializeServer
• type Header
  • func HeaderLookup(tStruct thrift.TStruct) *Header
  • func NewHeader(Type int16) *Header
• type SerializeServer
  • func NewSerializeServer() *SerializeServer

Constants

const (
	NETWORK_CHECK    int16 = 10
	SPAN             int16 = 40
	AGENT_INFO       int16 = 50
	AGENT_STAT       int16 = 55
	AGENT_STAT_BATCH int16 = 56
	SPANCHUNK        int16 = 70
	SPANEVENT        int16 = 80
	SQLMETADATA      int16 = 300
	APIMETADATA      int16 = 310
	RESULT           int16 = 320
	STRINGMETADATA   int16 = 330
	CHUNK            int16 = 400

	//####################command#####################
	TRANSFER                          int16 = 700
	TRANSFER_RESPONSE                 int16 = 701
	ECHO                              int16 = 710
	THREAD_DUMP                       int16 = 720
	THREAD_DUMP_RESPONSE              int16 = 721
	ACTIVE_THREAD_COUNT               int16 = 730
	ACTIVE_THREAD_COUNT_RESPONSE      int16 = 731
	ACTIVE_THREAD_DUMP                int16 = 740
	ACTIVE_THREAD_DUMP_RESPONSE       int16 = 741
	ACTIVE_THREAD_LIGHT_DUMP          int16 = 750
	ACTIVE_THREAD_LIGHT_DUMP_RESPONSE int16 = 751

	ACTIVE_COMMAND_HEAP          int16 = 780
	ACTIVE_COMMAND_HEAP_RESPONSE int16 = 781

	HEADER_SIGNATURE byte = 0xef
)

Functions

func Deserialize

func Deserialize(payload []byte) thrift.TStruct

func Serialize

func Serialize(tStruct thrift.TStruct) []byte

func SerializeNew

func SerializeNew(tStruct thrift.TStruct) []byte

func TBaseLookup

func TBaseLookup(Type int16) thrift.TStruct

Types

type DeserializeServer

type DeserializeServer struct {
	// contains filtered or unexported fields
}

func NewDeserializeServer

func NewDeserializeServer() *DeserializeServer

type Header

type Header struct {
	Signature byte
	Version   byte
	Type      int16
}

func HeaderLookup

func HeaderLookup(tStruct thrift.TStruct) *Header

func NewHeader

func NewHeader(Type int16) *Header

type SerializeServer

type SerializeServer struct {
	// contains filtered or unexported fields
}

func NewSerializeServer

func NewSerializeServer() *SerializeServer