Documentation ¶
Index ¶
- func AddLogging(p HasProcessFunc, stats *report.Recorder, debug bool) thrift.TProcessor
- func NewClientProts(url string, compact bool) (recv, send thrift.TProtocol)
- func NewDynamicClientProts(url func() string, compact bool) (recv, send thrift.TProtocol)
- type HasProcessFunc
- type LoggedProcessor
- type ThriftOverHTTPHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddLogging ¶
func AddLogging(p HasProcessFunc, stats *report.Recorder, debug bool) thrift.TProcessor
func NewClientProts ¶
pass these to the generated `NewFooClientProtocol(nil, recv, send)` method.
Types ¶
type HasProcessFunc ¶
type HasProcessFunc interface {
GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
}
Thrift's generated Processors have `GetProcessorFunction` and satisfy this interface.
type LoggedProcessor ¶
type LoggedProcessor struct { HasProcessFunc // contains filtered or unexported fields }
Wraps a generated thrift Processor, providing a ServeHTTP method to serve thrift-over-http.
func (LoggedProcessor) Process ¶
func (p LoggedProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
Mostly borrowed from generated thrift code `Process` method, but with timing added.
type ThriftOverHTTPHandler ¶
type ThriftOverHTTPHandler struct { thrift.TProcessor // contains filtered or unexported fields }
func NewThriftOverHTTPHandler ¶
func NewThriftOverHTTPHandler(p thrift.TProcessor, stats *report.Recorder) *ThriftOverHTTPHandler
func (*ThriftOverHTTPHandler) ServeHTTP ¶
func (h *ThriftOverHTTPHandler) ServeHTTP(out http.ResponseWriter, req *http.Request)
Click to show internal directories.
Click to hide internal directories.