tracetest

package
v2.23.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2020 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int

Functions

This section is empty.

Types

type Downstream 

type Downstream struct {
	ServiceName string      `thrift:"serviceName,1,required" json:"serviceName"`
	ServerRole  string      `thrift:"serverRole,2,required" json:"serverRole"`
	Host        string      `thrift:"host,3,required" json:"host"`
	Port        string      `thrift:"port,4,required" json:"port"`
	Transport   Transport   `thrift:"transport,5,required" json:"transport"`
	Downstream  *Downstream `thrift:"downstream,6" json:"downstream,omitempty"`
}

Attributes:

  • ServiceName
  • ServerRole
  • Host
  • Port
  • Transport
  • Downstream
var Downstream_Downstream_DEFAULT Downstream
var JoinTraceRequest_Downstream_DEFAULT *Downstream
var StartTraceRequest_Downstream_DEFAULT *Downstream

func NewDownstream 

func NewDownstream() *Downstream

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) GetServerRole 

func (p *Downstream) GetServerRole() string

func (*Downstream) GetServiceName 

func (p *Downstream) GetServiceName() 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) String 

func (p *Downstream) String() string

func (*Downstream) Write 

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

type JoinTraceRequest 

type JoinTraceRequest struct {
	ServerRole string      `thrift:"serverRole,1,required" json:"serverRole"`
	Downstream *Downstream `thrift:"downstream,2" json:"downstream,omitempty"`
}

Attributes:

  • ServerRole
  • Downstream
var TracedServiceJoinTraceArgs_Request_DEFAULT *JoinTraceRequest

func NewJoinTraceRequest 

func NewJoinTraceRequest() *JoinTraceRequest

func (*JoinTraceRequest) GetDownstream 

func (p *JoinTraceRequest) GetDownstream() *Downstream

func (*JoinTraceRequest) GetServerRole 

func (p *JoinTraceRequest) GetServerRole() string

func (*JoinTraceRequest) IsSetDownstream 

func (p *JoinTraceRequest) IsSetDownstream() bool

func (*JoinTraceRequest) Read 

func (p *JoinTraceRequest) Read(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" json:"traceId"`
	Sampled bool   `thrift:"sampled,2,required" json:"sampled"`
	Baggage string `thrift:"baggage,3,required" 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) String 

func (p *ObservedSpan) String() string

func (*ObservedSpan) Write 

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

type StartTraceRequest 

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

Attributes:

  • ServerRole
  • 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) GetServerRole 

func (p *StartTraceRequest) GetServerRole() string

func (*StartTraceRequest) IsSetDownstream 

func (p *StartTraceRequest) IsSetDownstream() bool

func (*StartTraceRequest) Read 

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

func (*StartTraceRequest) String 

func (p *StartTraceRequest) String() string

func (*StartTraceRequest) Write 

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

type TraceResponse 

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

Each server must include the information about the span it observed. It can only be omitted from the response if notImplementedError field is not empty. If the server was instructed to make a downstream call, it must embed the downstream response in its own response.

Attributes:

  • Span
  • Downstream
  • NotImplementedError
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) GetNotImplementedError 

func (p *TraceResponse) GetNotImplementedError() string

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) 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" 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) 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" 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) 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" 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) 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" 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) 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
	Transport_DUMMY    Transport = 2
)

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) String 

func (p Transport) String() string

func (*Transport) UnmarshalText 

func (p *Transport) UnmarshalText(text []byte) 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.