tracetest

package
v0.0.0-...-aff9e74 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 3, 2016 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package tracetest is generated code used to make or handle TChannel calls using Thrift.

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int

Functions

func NewTChanTracedServiceInheritedClient 

func NewTChanTracedServiceInheritedClient(thriftService string, client thrift.TChanClient) *tchanTracedServiceClient

func NewTChanTracedServiceServer 

func NewTChanTracedServiceServer(handler TChanTracedService) thrift.TChanServer

NewTChanTracedServiceServer wraps a handler for TChanTracedService so it can be registered with a thrift.Server.

Types

type Downstream 

type Downstream struct {
	Host       string      `thrift:"host,1,required" db:"host" json:"host"`
	Port       string      `thrift:"port,2,required" db:"port" json:"port"`
	Transport  Transport   `thrift:"transport,3,required" db:"transport" json:"transport"`
	ClientType string      `thrift:"clientType,4,required" db:"clientType" json:"clientType"`
	Downstream *Downstream `thrift:"downstream,5" db:"downstream" json:"downstream,omitempty"`
}

Attributes:

  • Host
  • Port
  • Transport
  • ClientType
  • Downstream
var Downstream_Downstream_DEFAULT Downstream
var JoinTraceRequest_Downstream_DEFAULT *Downstream
var StartTraceRequest_Downstream_DEFAULT *Downstream

func NewDownstream 

func NewDownstream() *Downstream

func (*Downstream) GetClientType 

func (p *Downstream) GetClientType() string

func (*Downstream) GetDownstream 

func (p *Downstream) GetDownstream() Downstream

func (*Downstream) GetHost 

func (p *Downstream) GetHost() string

func (*Downstream) GetPort 

func (p *Downstream) GetPort() string

func (*Downstream) GetTransport 

func (p *Downstream) GetTransport() Transport

func (*Downstream) IsSetDownstream 

func (p *Downstream) IsSetDownstream() bool

func (*Downstream) Read 

func (p *Downstream) Read(iprot thrift.TProtocol) error

func (*Downstream) ReadField1 

func (p *Downstream) ReadField1(iprot thrift.TProtocol) error

func (*Downstream) ReadField2 

func (p *Downstream) ReadField2(iprot thrift.TProtocol) error

func (*Downstream) ReadField3 

func (p *Downstream) ReadField3(iprot thrift.TProtocol) error

func (*Downstream) ReadField4 

func (p *Downstream) ReadField4(iprot thrift.TProtocol) error

func (*Downstream) ReadField5 

func (p *Downstream) ReadField5(iprot thrift.TProtocol) error

func (*Downstream) String 

func (p *Downstream) String() string

func (*Downstream) Write 

func (p *Downstream) Write(oprot thrift.TProtocol) error

type JoinTraceRequest 

type JoinTraceRequest struct {
	Downstream *Downstream `thrift:"downstream,1" db:"downstream" json:"downstream,omitempty"`
}

Attributes:

  • Downstream
var TracedServiceJoinTraceArgs_Request_DEFAULT *JoinTraceRequest

func NewJoinTraceRequest 

func NewJoinTraceRequest() *JoinTraceRequest

func (*JoinTraceRequest) GetDownstream 

func (p *JoinTraceRequest) GetDownstream() *Downstream

func (*JoinTraceRequest) IsSetDownstream 

func (p *JoinTraceRequest) IsSetDownstream() bool

func (*JoinTraceRequest) Read 

func (p *JoinTraceRequest) Read(iprot thrift.TProtocol) error

func (*JoinTraceRequest) ReadField1 

func (p *JoinTraceRequest) ReadField1(iprot thrift.TProtocol) error

func (*JoinTraceRequest) String 

func (p *JoinTraceRequest) String() string

func (*JoinTraceRequest) Write 

func (p *JoinTraceRequest) Write(oprot thrift.TProtocol) error

type ObservedSpan 

type ObservedSpan struct {
	TraceId string `thrift:"traceId,1,required" db:"traceId" json:"traceId"`
	Sampled bool   `thrift:"sampled,2,required" db:"sampled" json:"sampled"`
	Baggage string `thrift:"baggage,3,required" db:"baggage" json:"baggage"`
}

Attributes:

  • TraceId
  • Sampled
  • Baggage
var TraceResponse_Span_DEFAULT *ObservedSpan

func NewObservedSpan 

func NewObservedSpan() *ObservedSpan

func (*ObservedSpan) GetBaggage 

func (p *ObservedSpan) GetBaggage() string

func (*ObservedSpan) GetSampled 

func (p *ObservedSpan) GetSampled() bool

func (*ObservedSpan) GetTraceId 

func (p *ObservedSpan) GetTraceId() string

func (*ObservedSpan) Read 

func (p *ObservedSpan) Read(iprot thrift.TProtocol) error

func (*ObservedSpan) ReadField1 

func (p *ObservedSpan) ReadField1(iprot thrift.TProtocol) error

func (*ObservedSpan) ReadField2 

func (p *ObservedSpan) ReadField2(iprot thrift.TProtocol) error

func (*ObservedSpan) ReadField3 

func (p *ObservedSpan) ReadField3(iprot thrift.TProtocol) error

func (*ObservedSpan) String 

func (p *ObservedSpan) String() string

func (*ObservedSpan) Write 

func (p *ObservedSpan) Write(oprot thrift.TProtocol) error

type StartTraceRequest 

type StartTraceRequest struct {
	Sampled    bool        `thrift:"sampled,1,required" db:"sampled" json:"sampled"`
	Baggage    string      `thrift:"baggage,2,required" db:"baggage" json:"baggage"`
	Downstream *Downstream `thrift:"downstream,3,required" db:"downstream" json:"downstream"`
}

Attributes:

  • Sampled
  • Baggage
  • Downstream
var TracedServiceStartTraceArgs_Request_DEFAULT *StartTraceRequest

func NewStartTraceRequest 

func NewStartTraceRequest() *StartTraceRequest

func (*StartTraceRequest) GetBaggage 

func (p *StartTraceRequest) GetBaggage() string

func (*StartTraceRequest) GetDownstream 

func (p *StartTraceRequest) GetDownstream() *Downstream

func (*StartTraceRequest) GetSampled 

func (p *StartTraceRequest) GetSampled() bool

func (*StartTraceRequest) IsSetDownstream 

func (p *StartTraceRequest) IsSetDownstream() bool

func (*StartTraceRequest) Read 

func (p *StartTraceRequest) Read(iprot thrift.TProtocol) error

func (*StartTraceRequest) ReadField1 

func (p *StartTraceRequest) ReadField1(iprot thrift.TProtocol) error

func (*StartTraceRequest) ReadField2 

func (p *StartTraceRequest) ReadField2(iprot thrift.TProtocol) error

func (*StartTraceRequest) ReadField3 

func (p *StartTraceRequest) ReadField3(iprot thrift.TProtocol) error

func (*StartTraceRequest) String 

func (p *StartTraceRequest) String() string

func (*StartTraceRequest) Write 

func (p *StartTraceRequest) Write(oprot thrift.TProtocol) error

type TChanTracedService 

type TChanTracedService interface {
	JoinTrace(ctx thrift.Context, request *JoinTraceRequest) (*TraceResponse, error)
	StartTrace(ctx thrift.Context, request *StartTraceRequest) (*TraceResponse, error)
}

TChanTracedService is the interface that defines the server handler and client interface.

func NewTChanTracedServiceClient 

func NewTChanTracedServiceClient(client thrift.TChanClient) TChanTracedService

NewTChanTracedServiceClient creates a client that can be used to make remote calls.

type TraceResponse 

type TraceResponse struct {
	Span       *ObservedSpan  `thrift:"span,1,required" db:"span" json:"span"`
	Downstream *TraceResponse `thrift:"downstream,2" db:"downstream" json:"downstream,omitempty"`
}

Attributes:

  • Span
  • Downstream
var TraceResponse_Downstream_DEFAULT TraceResponse
var TracedServiceJoinTraceResult_Success_DEFAULT *TraceResponse
var TracedServiceStartTraceResult_Success_DEFAULT *TraceResponse

func NewTraceResponse 

func NewTraceResponse() *TraceResponse

func (*TraceResponse) GetDownstream 

func (p *TraceResponse) GetDownstream() TraceResponse

func (*TraceResponse) GetSpan 

func (p *TraceResponse) GetSpan() *ObservedSpan

func (*TraceResponse) IsSetDownstream 

func (p *TraceResponse) IsSetDownstream() bool

func (*TraceResponse) IsSetSpan 

func (p *TraceResponse) IsSetSpan() bool

func (*TraceResponse) Read 

func (p *TraceResponse) Read(iprot thrift.TProtocol) error

func (*TraceResponse) ReadField1 

func (p *TraceResponse) ReadField1(iprot thrift.TProtocol) error

func (*TraceResponse) ReadField2 

func (p *TraceResponse) ReadField2(iprot thrift.TProtocol) error

func (*TraceResponse) String 

func (p *TraceResponse) String() string

func (*TraceResponse) Write 

func (p *TraceResponse) Write(oprot thrift.TProtocol) error

type TracedService 

type TracedService interface {
	// Parameters:
	//  - Request
	StartTrace(request *StartTraceRequest) (r *TraceResponse, err error)
	// Parameters:
	//  - Request
	JoinTrace(request *JoinTraceRequest) (r *TraceResponse, err error)
}

type TracedServiceClient 

type TracedServiceClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewTracedServiceClientFactory 

func NewTracedServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TracedServiceClient

func NewTracedServiceClientProtocol 

func NewTracedServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TracedServiceClient

func (*TracedServiceClient) JoinTrace 

func (p *TracedServiceClient) JoinTrace(request *JoinTraceRequest) (r *TraceResponse, err error)

Parameters:

  • Request

func (*TracedServiceClient) StartTrace 

func (p *TracedServiceClient) StartTrace(request *StartTraceRequest) (r *TraceResponse, err error)

Parameters:

  • Request

type TracedServiceJoinTraceArgs 

type TracedServiceJoinTraceArgs struct {
	Request *JoinTraceRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewTracedServiceJoinTraceArgs 

func NewTracedServiceJoinTraceArgs() *TracedServiceJoinTraceArgs

func (*TracedServiceJoinTraceArgs) GetRequest 

func (p *TracedServiceJoinTraceArgs) GetRequest() *JoinTraceRequest

func (*TracedServiceJoinTraceArgs) IsSetRequest 

func (p *TracedServiceJoinTraceArgs) IsSetRequest() bool

func (*TracedServiceJoinTraceArgs) Read 

func (p *TracedServiceJoinTraceArgs) Read(iprot thrift.TProtocol) error

func (*TracedServiceJoinTraceArgs) ReadField1 

func (p *TracedServiceJoinTraceArgs) ReadField1(iprot thrift.TProtocol) error

func (*TracedServiceJoinTraceArgs) String 

func (p *TracedServiceJoinTraceArgs) String() string

func (*TracedServiceJoinTraceArgs) Write 

func (p *TracedServiceJoinTraceArgs) Write(oprot thrift.TProtocol) error

type TracedServiceJoinTraceResult 

type TracedServiceJoinTraceResult struct {
	Success *TraceResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTracedServiceJoinTraceResult 

func NewTracedServiceJoinTraceResult() *TracedServiceJoinTraceResult

func (*TracedServiceJoinTraceResult) GetSuccess 

func (p *TracedServiceJoinTraceResult) GetSuccess() *TraceResponse

func (*TracedServiceJoinTraceResult) IsSetSuccess 

func (p *TracedServiceJoinTraceResult) IsSetSuccess() bool

func (*TracedServiceJoinTraceResult) Read 

func (p *TracedServiceJoinTraceResult) Read(iprot thrift.TProtocol) error

func (*TracedServiceJoinTraceResult) ReadField0 

func (p *TracedServiceJoinTraceResult) ReadField0(iprot thrift.TProtocol) error

func (*TracedServiceJoinTraceResult) String 

func (p *TracedServiceJoinTraceResult) String() string

func (*TracedServiceJoinTraceResult) Write 

func (p *TracedServiceJoinTraceResult) Write(oprot thrift.TProtocol) error

type TracedServiceProcessor 

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

func NewTracedServiceProcessor 

func NewTracedServiceProcessor(handler TracedService) *TracedServiceProcessor

func (*TracedServiceProcessor) AddToProcessorMap 

func (p *TracedServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TracedServiceProcessor) GetProcessorFunction 

func (p *TracedServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TracedServiceProcessor) Process 

func (p *TracedServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TracedServiceProcessor) ProcessorMap 

func (p *TracedServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type TracedServiceStartTraceArgs 

type TracedServiceStartTraceArgs struct {
	Request *StartTraceRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewTracedServiceStartTraceArgs 

func NewTracedServiceStartTraceArgs() *TracedServiceStartTraceArgs

func (*TracedServiceStartTraceArgs) GetRequest 

func (p *TracedServiceStartTraceArgs) GetRequest() *StartTraceRequest

func (*TracedServiceStartTraceArgs) IsSetRequest 

func (p *TracedServiceStartTraceArgs) IsSetRequest() bool

func (*TracedServiceStartTraceArgs) Read 

func (p *TracedServiceStartTraceArgs) Read(iprot thrift.TProtocol) error

func (*TracedServiceStartTraceArgs) ReadField1 

func (p *TracedServiceStartTraceArgs) ReadField1(iprot thrift.TProtocol) error

func (*TracedServiceStartTraceArgs) String 

func (p *TracedServiceStartTraceArgs) String() string

func (*TracedServiceStartTraceArgs) Write 

func (p *TracedServiceStartTraceArgs) Write(oprot thrift.TProtocol) error

type TracedServiceStartTraceResult 

type TracedServiceStartTraceResult struct {
	Success *TraceResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTracedServiceStartTraceResult 

func NewTracedServiceStartTraceResult() *TracedServiceStartTraceResult

func (*TracedServiceStartTraceResult) GetSuccess 

func (p *TracedServiceStartTraceResult) GetSuccess() *TraceResponse

func (*TracedServiceStartTraceResult) IsSetSuccess 

func (p *TracedServiceStartTraceResult) IsSetSuccess() bool

func (*TracedServiceStartTraceResult) Read 

func (p *TracedServiceStartTraceResult) Read(iprot thrift.TProtocol) error

func (*TracedServiceStartTraceResult) ReadField0 

func (p *TracedServiceStartTraceResult) ReadField0(iprot thrift.TProtocol) error

func (*TracedServiceStartTraceResult) String 

func (p *TracedServiceStartTraceResult) String() string

func (*TracedServiceStartTraceResult) Write 

func (p *TracedServiceStartTraceResult) Write(oprot thrift.TProtocol) error

type Transport 

type Transport int64
const (
	Transport_HTTP     Transport = 0
	Transport_TCHANNEL Transport = 1
)

func TransportFromString 

func TransportFromString(s string) (Transport, error)

func TransportPtr 

func TransportPtr(v Transport) *Transport

func (Transport) MarshalText 

func (p Transport) MarshalText() ([]byte, error)

func (*Transport) Scan 

func (p *Transport) Scan(value interface{}) error

func (Transport) String 

func (p Transport) String() string

func (*Transport) UnmarshalText 

func (p *Transport) UnmarshalText(text []byte) error

func (*Transport) Value 

func (p *Transport) Value() (driver.Value, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.