Versions in this module Expand all Collapse all v1 v1.1.0 Feb 2, 2016 Changes in this version + const ThriftFieldState + const ThriftMsgTypeCall + const ThriftMsgTypeException + const ThriftMsgTypeOneway + const ThriftMsgTypeReply + const ThriftStartState + const ThriftTBinary + const ThriftTCompact + const ThriftTFramed + const ThriftTSocket + const ThriftTypeBool + const ThriftTypeByte + const ThriftTypeDouble + const ThriftTypeI16 + const ThriftTypeI32 + const ThriftTypeI64 + const ThriftTypeList + const ThriftTypeMap + const ThriftTypeMask + const ThriftTypeSet + const ThriftTypeStop + const ThriftTypeString + const ThriftTypeStruct + const ThriftTypeUtf16 + const ThriftTypeUtf8 + const ThriftTypeVoid + const ThriftVersion1 + const ThriftVersionMask + func BuildMethodsMap(thrift_files map[string]parser.Thrift) map[string]*ThriftIdlMethod + func ReadFiles(files []string) (map[string]parser.Thrift, error) + type Thrift struct + CaptureReply bool + CollectionMaxSize int + DropAfterNStructFields int + Idl *ThriftIdl + ObfuscateStrings bool + Ports []int + ProtocolType byte + PublishQueue chan *ThriftTransaction + Send_request bool + Send_response bool + StringMaxSize int + TransportType byte + var ThriftMod Thrift + func (thrift *Thrift) ConnectionTimeout() time.Duration + func (thrift *Thrift) GapInStream(tcptuple *common.TcpTuple, dir uint8, nbytes int, private protos.ProtocolData) (priv protos.ProtocolData, drop bool) + func (thrift *Thrift) GetPorts() []int + func (thrift *Thrift) Init(test_mode bool, results publish.Transactions) error + func (thrift *Thrift) InitDefaults() + func (thrift *Thrift) Parse(pkt *protos.Packet, tcptuple *common.TcpTuple, dir uint8, ...) protos.ProtocolData + func (thrift *Thrift) ReceivedFin(tcptuple *common.TcpTuple, dir uint8, private protos.ProtocolData) protos.ProtocolData + type ThriftField struct + Id uint16 + Type byte + Value string + type ThriftFieldReader func(data []byte) (value string, ok bool, complete bool, off int) + type ThriftIdl struct + MethodsByName map[string]*ThriftIdlMethod + func NewThriftIdl(idl_files []string) (*ThriftIdl, error) + func (thriftidl *ThriftIdl) FindMethod(name string) *ThriftIdlMethod + type ThriftIdlMethod struct + Exceptions []*string + Method *parser.Method + Params []*string + Service *parser.Service + type ThriftMessage struct + CmdlineTuple *common.CmdlineTuple + Direction uint8 + Exceptions string + FrameSize uint32 + HasException bool + IsRequest bool + Method string + Notes []string + Params string + ReturnValue string + SeqId uint32 + Service string + TcpTuple common.TcpTuple + Ts time.Time + Type uint32 + Version uint32 + func (m *ThriftMessage) String() string + type ThriftStream struct + func (stream *ThriftStream) PrepareForNewMessage(flush bool) + type ThriftTransaction struct + BytesIn uint64 + BytesOut uint64 + Dst common.Endpoint + JsTs time.Time + Reply *ThriftMessage + Request *ThriftMessage + ResponseTime int32 + Src common.Endpoint + Ts int64 + Type string v1.0.1 Dec 17, 2015
Go to main page