Documentation
¶
Index ¶
- Constants
- func WrapContext(ctx context.Context, timeout time.Duration) (thrift.Context, context.CancelFunc)
- type Server
- func (s *Server) Close() error
- func (s *Server) GetPortHTTP() string
- func (s *Server) GetPortTChannel() string
- func (s *Server) JoinTrace(ctx thrift.Context, request *tracetest.JoinTraceRequest) (*tracetest.TraceResponse, error)
- func (s *Server) Start() error
- func (s *Server) StartTrace(ctx thrift.Context, request *tracetest.StartTraceRequest) (*tracetest.TraceResponse, error)
Constants ¶
View Source
const BaggageKey = "crossdock-baggage-key"
BaggageKey is the key used to pass baggage item
Variables ¶
This section is empty.
Functions ¶
func WrapContext ¶
WrapContext takes a regular `net.Context` and converts it into `thrift.Context` suitable for outbound calls to TChannel servers. If the input context contains a OpoenTracing span, that span is converted to TChannel-compatible Span.
Types ¶
type Server ¶
type Server struct {
HostPortHTTP string
HostPortTChannel string
Tracer opentracing.Tracer
// contains filtered or unexported fields
}
Server implements S1-S3 servers
func (*Server) GetPortHTTP ¶
GetPortHTTP returns the actual port the server listens to
func (*Server) GetPortTChannel ¶
GetPortTChannel returns the actual port the server listens to
func (*Server) JoinTrace ¶
func (s *Server) JoinTrace(ctx thrift.Context, request *tracetest.JoinTraceRequest) (*tracetest.TraceResponse, error)
JoinTrace implements JoinTrace() of TChanTracedService
func (*Server) Start ¶
Start starts the test server called by the Client and other upstream servers.
func (*Server) StartTrace ¶
func (s *Server) StartTrace(ctx thrift.Context, request *tracetest.StartTraceRequest) (*tracetest.TraceResponse, error)
StartTrace implements StartTrace() of TChanTracedService
Source Files
Click to show internal directories.
Click to hide internal directories.