tracetest

package
v2.23.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 22, 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 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 (*TracedServiceJoinTraceArgs) IsSetRequest

func (p *TracedServiceJoinTraceArgs) IsSetRequest() bool

func (*TracedServiceJoinTraceArgs) Read

func (*TracedServiceJoinTraceArgs) String

func (p *TracedServiceJoinTraceArgs) String() string

func (*TracedServiceJoinTraceArgs) Write

type TracedServiceJoinTraceResult

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

Attributes:

  • Success

func NewTracedServiceJoinTraceResult

func NewTracedServiceJoinTraceResult() *TracedServiceJoinTraceResult

func (*TracedServiceJoinTraceResult) GetSuccess

func (*TracedServiceJoinTraceResult) IsSetSuccess

func (p *TracedServiceJoinTraceResult) IsSetSuccess() bool

func (*TracedServiceJoinTraceResult) Read

func (*TracedServiceJoinTraceResult) String

func (*TracedServiceJoinTraceResult) Write

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

type TracedServiceStartTraceArgs

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

Attributes:

  • Request

func NewTracedServiceStartTraceArgs

func NewTracedServiceStartTraceArgs() *TracedServiceStartTraceArgs

func (*TracedServiceStartTraceArgs) GetRequest

func (*TracedServiceStartTraceArgs) IsSetRequest

func (p *TracedServiceStartTraceArgs) IsSetRequest() bool

func (*TracedServiceStartTraceArgs) Read

func (*TracedServiceStartTraceArgs) String

func (p *TracedServiceStartTraceArgs) String() string

func (*TracedServiceStartTraceArgs) Write

type TracedServiceStartTraceResult

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

Attributes:

  • Success

func NewTracedServiceStartTraceResult

func NewTracedServiceStartTraceResult() *TracedServiceStartTraceResult

func (*TracedServiceStartTraceResult) GetSuccess

func (*TracedServiceStartTraceResult) IsSetSuccess

func (p *TracedServiceStartTraceResult) IsSetSuccess() bool

func (*TracedServiceStartTraceResult) Read

func (*TracedServiceStartTraceResult) String

func (*TracedServiceStartTraceResult) Write

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL