tracetest

package
v2.30.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2021 License: Apache-2.0 Imports: 7 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" db:"serviceName" json:"serviceName"`
	ServerRole  string      `thrift:"serverRole,2,required" db:"serverRole" json:"serverRole"`
	Host        string      `thrift:"host,3,required" db:"host" json:"host"`
	Port        string      `thrift:"port,4,required" db:"port" json:"port"`
	Transport   Transport   `thrift:"transport,5,required" db:"transport" json:"transport"`
	Downstream  *Downstream `thrift:"downstream,6" db:"downstream" 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) Equals

func (p *Downstream) Equals(other *Downstream) bool

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(ctx context.Context, iprot thrift.TProtocol) error

func (*Downstream) ReadField1

func (p *Downstream) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Downstream) ReadField2

func (p *Downstream) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*Downstream) ReadField3

func (p *Downstream) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*Downstream) ReadField4

func (p *Downstream) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*Downstream) ReadField5

func (p *Downstream) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*Downstream) ReadField6

func (p *Downstream) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*Downstream) String

func (p *Downstream) String() string

func (*Downstream) Write

func (p *Downstream) Write(ctx context.Context, oprot thrift.TProtocol) error

type JoinTraceRequest

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

Attributes:

  • ServerRole
  • Downstream
var TracedServiceJoinTraceArgs_Request_DEFAULT *JoinTraceRequest

func NewJoinTraceRequest

func NewJoinTraceRequest() *JoinTraceRequest

func (*JoinTraceRequest) Equals

func (p *JoinTraceRequest) Equals(other *JoinTraceRequest) bool

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(ctx context.Context, iprot thrift.TProtocol) error

func (*JoinTraceRequest) ReadField1

func (p *JoinTraceRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*JoinTraceRequest) ReadField2

func (p *JoinTraceRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*JoinTraceRequest) String

func (p *JoinTraceRequest) String() string

func (*JoinTraceRequest) Write

func (p *JoinTraceRequest) Write(ctx context.Context, 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) Equals

func (p *ObservedSpan) Equals(other *ObservedSpan) bool

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(ctx context.Context, iprot thrift.TProtocol) error

func (*ObservedSpan) ReadField1

func (p *ObservedSpan) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ObservedSpan) ReadField2

func (p *ObservedSpan) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ObservedSpan) ReadField3

func (p *ObservedSpan) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ObservedSpan) String

func (p *ObservedSpan) String() string

func (*ObservedSpan) Write

func (p *ObservedSpan) Write(ctx context.Context, oprot thrift.TProtocol) error

type StartTraceRequest

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

Attributes:

  • ServerRole
  • Sampled
  • Baggage
  • Downstream
var TracedServiceStartTraceArgs_Request_DEFAULT *StartTraceRequest

func NewStartTraceRequest

func NewStartTraceRequest() *StartTraceRequest

func (*StartTraceRequest) Equals

func (p *StartTraceRequest) Equals(other *StartTraceRequest) bool

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(ctx context.Context, iprot thrift.TProtocol) error

func (*StartTraceRequest) ReadField1

func (p *StartTraceRequest) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*StartTraceRequest) ReadField2

func (p *StartTraceRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*StartTraceRequest) ReadField3

func (p *StartTraceRequest) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*StartTraceRequest) ReadField4

func (p *StartTraceRequest) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*StartTraceRequest) String

func (p *StartTraceRequest) String() string

func (*StartTraceRequest) Write

func (p *StartTraceRequest) Write(ctx context.Context, oprot thrift.TProtocol) error

type TraceResponse

type TraceResponse struct {
	Span                *ObservedSpan  `thrift:"span,1" db:"span" json:"span,omitempty"`
	Downstream          *TraceResponse `thrift:"downstream,2" db:"downstream" json:"downstream,omitempty"`
	NotImplementedError string         `thrift:"notImplementedError,3,required" db:"notImplementedError" 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) Equals

func (p *TraceResponse) Equals(other *TraceResponse) bool

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(ctx context.Context, iprot thrift.TProtocol) error

func (*TraceResponse) ReadField1

func (p *TraceResponse) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TraceResponse) ReadField2

func (p *TraceResponse) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TraceResponse) ReadField3

func (p *TraceResponse) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TraceResponse) String

func (p *TraceResponse) String() string

func (*TraceResponse) Write

func (p *TraceResponse) Write(ctx context.Context, oprot thrift.TProtocol) error

type TracedService

type TracedService interface {
	// Parameters:
	//  - Request
	StartTrace(ctx context.Context, request *StartTraceRequest) (_r *TraceResponse, _err error)
	// Parameters:
	//  - Request
	JoinTrace(ctx context.Context, request *JoinTraceRequest) (_r *TraceResponse, _err error)
}

type TracedServiceClient

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

func NewTracedServiceClient

func NewTracedServiceClient(c thrift.TClient) *TracedServiceClient

func NewTracedServiceClientProtocol

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

func (*TracedServiceClient) Client_

func (p *TracedServiceClient) Client_() thrift.TClient

func (*TracedServiceClient) JoinTrace

func (p *TracedServiceClient) JoinTrace(ctx context.Context, request *JoinTraceRequest) (_r *TraceResponse, _err error)

Parameters:

  • Request

func (*TracedServiceClient) LastResponseMeta_

func (p *TracedServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*TracedServiceClient) SetLastResponseMeta_

func (p *TracedServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

func (*TracedServiceClient) StartTrace

func (p *TracedServiceClient) StartTrace(ctx context.Context, 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 (*TracedServiceJoinTraceArgs) IsSetRequest

func (p *TracedServiceJoinTraceArgs) IsSetRequest() bool

func (*TracedServiceJoinTraceArgs) Read

func (*TracedServiceJoinTraceArgs) ReadField1

func (p *TracedServiceJoinTraceArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TracedServiceJoinTraceArgs) String

func (p *TracedServiceJoinTraceArgs) String() string

func (*TracedServiceJoinTraceArgs) Write

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 (*TracedServiceJoinTraceResult) IsSetSuccess

func (p *TracedServiceJoinTraceResult) IsSetSuccess() bool

func (*TracedServiceJoinTraceResult) Read

func (*TracedServiceJoinTraceResult) ReadField0

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(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TracedServiceProcessor) ProcessorMap

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 (*TracedServiceStartTraceArgs) IsSetRequest

func (p *TracedServiceStartTraceArgs) IsSetRequest() bool

func (*TracedServiceStartTraceArgs) Read

func (*TracedServiceStartTraceArgs) ReadField1

func (*TracedServiceStartTraceArgs) String

func (p *TracedServiceStartTraceArgs) String() string

func (*TracedServiceStartTraceArgs) Write

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 (*TracedServiceStartTraceResult) IsSetSuccess

func (p *TracedServiceStartTraceResult) IsSetSuccess() bool

func (*TracedServiceStartTraceResult) Read

func (*TracedServiceStartTraceResult) ReadField0

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

Jump to

Keyboard shortcuts

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