trace

Documentation

Index

• Variables
• func RegisterTraceServiceServer(s grpc.ServiceRegistrar, srv TraceServiceServer)
• type Matcher
  • func (*Matcher) Descriptor() ([]byte, []int)
  • func (x *Matcher) GetIndex() int64
  • func (x *Matcher) GetMatchPath() string
  • func (x *Matcher) GetMatchValue() string
  • func (*Matcher) ProtoMessage()
  • func (x *Matcher) ProtoReflect() protoreflect.Message
  • func (x *Matcher) Reset()
  • func (x *Matcher) String() string
• type TraceRequest
  • func (*TraceRequest) Descriptor() ([]byte, []int)
  • func (x *TraceRequest) GetMatchers() []*Matcher
  • func (x *TraceRequest) GetMaxDepth() int64
  • func (x *TraceRequest) GetMaxLength() int64
  • func (x *TraceRequest) GetMethod() string
  • func (x *TraceRequest) GetPushToCollectorAddress() string
  • func (x *TraceRequest) GetSdid() string
  • func (*TraceRequest) ProtoMessage()
  • func (x *TraceRequest) ProtoReflect() protoreflect.Message
  • func (x *TraceRequest) Reset()
  • func (x *TraceRequest) String() string
• type TraceResponse
  • func (*TraceResponse) Descriptor() ([]byte, []int)
  • func (x *TraceResponse) GetCollectorAddress() string
  • func (x *TraceResponse) GetThriftSerializedSpans() []byte
  • func (x *TraceResponse) GetTraces() []*model.Trace
  • func (*TraceResponse) ProtoMessage()
  • func (x *TraceResponse) ProtoReflect() protoreflect.Message
  • func (x *TraceResponse) Reset()
  • func (x *TraceResponse) String() string
• type TraceServiceClient
  • func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient
• type TraceServiceServer
• type TraceService_TraceClient
• type TraceService_TraceServer
• type UnimplementedTraceServiceServer
  • func (UnimplementedTraceServiceServer) Trace(*TraceRequest, TraceService_TraceServer) error
• type UnsafeTraceServiceServer

Variables

var File_extension_aop_trace_api_ioc_golang_aop_trace_trace_proto protoreflect.FileDescriptor

var TraceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ioc_golang.aop.trace.TraceService",
	HandlerType: (*TraceServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Trace",
			Handler:       _TraceService_Trace_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "extension/aop/trace/api/ioc_golang/aop/trace/trace.proto",
}

TraceService_ServiceDesc is the grpc.ServiceDesc for TraceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTraceServiceServer

func RegisterTraceServiceServer(s grpc.ServiceRegistrar, srv TraceServiceServer)

Types

type Matcher

type Matcher struct {
	Index      int64  `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	MatchPath  string `protobuf:"bytes,2,opt,name=matchPath,proto3" json:"matchPath,omitempty"`
	MatchValue string `protobuf:"bytes,3,opt,name=matchValue,proto3" json:"matchValue,omitempty"`
	// contains filtered or unexported fields
}

func (*Matcher) Descriptor

func (*Matcher) Descriptor() ([]byte, []int)

Deprecated: Use Matcher.ProtoReflect.Descriptor instead.

func (*Matcher) GetIndex

func (x *Matcher) GetIndex() int64

func (*Matcher) GetMatchPath

func (x *Matcher) GetMatchPath() string

func (*Matcher) GetMatchValue

func (x *Matcher) GetMatchValue() string

func (*Matcher) ProtoMessage

func (*Matcher) ProtoMessage()

func (*Matcher) ProtoReflect

func (x *Matcher) ProtoReflect() protoreflect.Message

func (*Matcher) Reset

func (x *Matcher) Reset()

func (*Matcher) String

func (x *Matcher) String() string

type TraceRequest

type TraceRequest struct {
	Sdid                   string     `protobuf:"bytes,1,opt,name=sdid,proto3" json:"sdid,omitempty"`
	Method                 string     `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Matchers               []*Matcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
	PushToCollectorAddress string     `protobuf:"bytes,4,opt,name=pushToCollectorAddress,proto3" json:"pushToCollectorAddress,omitempty"`
	MaxDepth               int64      `protobuf:"varint,5,opt,name=maxDepth,proto3" json:"maxDepth,omitempty"`
	MaxLength              int64      `protobuf:"varint,6,opt,name=maxLength,proto3" json:"maxLength,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceRequest) Descriptor

func (*TraceRequest) Descriptor() ([]byte, []int)

Deprecated: Use TraceRequest.ProtoReflect.Descriptor instead.

func (*TraceRequest) GetMatchers

func (x *TraceRequest) GetMatchers() []*Matcher

func (*TraceRequest) GetMaxDepth

func (x *TraceRequest) GetMaxDepth() int64

func (*TraceRequest) GetMaxLength

func (x *TraceRequest) GetMaxLength() int64

func (*TraceRequest) GetMethod

func (x *TraceRequest) GetMethod() string

func (*TraceRequest) GetPushToCollectorAddress

func (x *TraceRequest) GetPushToCollectorAddress() string

func (*TraceRequest) GetSdid

func (x *TraceRequest) GetSdid() string

func (*TraceRequest) ProtoMessage

func (*TraceRequest) ProtoMessage()

func (*TraceRequest) ProtoReflect

func (x *TraceRequest) ProtoReflect() protoreflect.Message

func (*TraceRequest) Reset

func (x *TraceRequest) Reset()

func (*TraceRequest) String

func (x *TraceRequest) String() string

type TraceResponse

type TraceResponse struct {
	CollectorAddress      string         `protobuf:"bytes,1,opt,name=collectorAddress,proto3" json:"collectorAddress,omitempty"`
	ThriftSerializedSpans []byte         `protobuf:"bytes,2,opt,name=thriftSerializedSpans,proto3" json:"thriftSerializedSpans,omitempty"`
	Traces                []*model.Trace `protobuf:"bytes,3,rep,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceResponse) Descriptor

func (*TraceResponse) Descriptor() ([]byte, []int)

Deprecated: Use TraceResponse.ProtoReflect.Descriptor instead.

func (*TraceResponse) GetCollectorAddress

func (x *TraceResponse) GetCollectorAddress() string

func (*TraceResponse) GetThriftSerializedSpans

func (x *TraceResponse) GetThriftSerializedSpans() []byte

func (*TraceResponse) GetTraces

func (x *TraceResponse) GetTraces() []*model.Trace

func (*TraceResponse) ProtoMessage

func (*TraceResponse) ProtoMessage()

func (*TraceResponse) ProtoReflect

func (x *TraceResponse) ProtoReflect() protoreflect.Message

func (*TraceResponse) Reset

func (x *TraceResponse) Reset()

func (*TraceResponse) String

func (x *TraceResponse) String() string

type TraceServiceClient

type TraceServiceClient interface {
	Trace(ctx context.Context, in *TraceRequest, opts ...grpc.CallOption) (TraceService_TraceClient, error)
}

TraceServiceClient is the client API for TraceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTraceServiceClient

func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient

type TraceServiceServer

type TraceServiceServer interface {
	Trace(*TraceRequest, TraceService_TraceServer) error
	// contains filtered or unexported methods
}

TraceServiceServer is the server API for TraceService service. All implementations must embed UnimplementedTraceServiceServer for forward compatibility

type TraceService_TraceClient

type TraceService_TraceClient interface {
	Recv() (*TraceResponse, error)
	grpc.ClientStream
}

type TraceService_TraceServer

type TraceService_TraceServer interface {
	Send(*TraceResponse) error
	grpc.ServerStream
}

type UnimplementedTraceServiceServer

type UnimplementedTraceServiceServer struct {
}

UnimplementedTraceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTraceServiceServer) Trace

func (UnimplementedTraceServiceServer) Trace(*TraceRequest, TraceService_TraceServer) error

type UnsafeTraceServiceServer

type UnsafeTraceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTraceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TraceServiceServer will result in compilation errors.