api_v3

package
v1.64.0 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQueryService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueryService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueryService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer)

Types

type FindTracesRequest 

type FindTracesRequest struct {
	Query                *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Request object to search traces.

func (*FindTracesRequest) Descriptor 

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

func (*FindTracesRequest) GetQuery 

func (m *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) Marshal added in v1.64.0 

func (m *FindTracesRequest) Marshal() (dAtA []byte, err error)

func (*FindTracesRequest) MarshalTo added in v1.64.0 

func (m *FindTracesRequest) MarshalTo(dAtA []byte) (int, error)

func (*FindTracesRequest) MarshalToSizedBuffer added in v1.64.0 

func (m *FindTracesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FindTracesRequest) ProtoMessage 

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) Reset 

func (m *FindTracesRequest) Reset()

func (*FindTracesRequest) Size added in v1.64.0 

func (m *FindTracesRequest) Size() (n int)

func (*FindTracesRequest) String 

func (m *FindTracesRequest) String() string

func (*FindTracesRequest) Unmarshal added in v1.64.0 

func (m *FindTracesRequest) Unmarshal(dAtA []byte) error

func (*FindTracesRequest) XXX_DiscardUnknown 

func (m *FindTracesRequest) XXX_DiscardUnknown()

func (*FindTracesRequest) XXX_Marshal 

func (m *FindTracesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindTracesRequest) XXX_Merge 

func (m *FindTracesRequest) XXX_Merge(src proto.Message)

func (*FindTracesRequest) XXX_Size 

func (m *FindTracesRequest) XXX_Size() int

func (*FindTracesRequest) XXX_Unmarshal 

func (m *FindTracesRequest) XXX_Unmarshal(b []byte) error

type GRPCGatewayError 

type GRPCGatewayError struct {
	Error                *GRPCGatewayError_GRPCGatewayErrorDetails `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

GRPCGatewayError is the type returned when GRPC server returns an error. Example: {"error":{"grpcCode":2,"httpCode":500,"message":"...","httpStatus":"text..."}}.

func (*GRPCGatewayError) Descriptor 

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

func (*GRPCGatewayError) GetError 

func (m *GRPCGatewayError) GetError() *GRPCGatewayError_GRPCGatewayErrorDetails

func (*GRPCGatewayError) Marshal added in v1.64.0 

func (m *GRPCGatewayError) Marshal() (dAtA []byte, err error)

func (*GRPCGatewayError) MarshalTo added in v1.64.0 

func (m *GRPCGatewayError) MarshalTo(dAtA []byte) (int, error)

func (*GRPCGatewayError) MarshalToSizedBuffer added in v1.64.0 

func (m *GRPCGatewayError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCGatewayError) ProtoMessage 

func (*GRPCGatewayError) ProtoMessage()

func (*GRPCGatewayError) Reset 

func (m *GRPCGatewayError) Reset()

func (*GRPCGatewayError) Size added in v1.64.0 

func (m *GRPCGatewayError) Size() (n int)

func (*GRPCGatewayError) String 

func (m *GRPCGatewayError) String() string

func (*GRPCGatewayError) Unmarshal added in v1.64.0 

func (m *GRPCGatewayError) Unmarshal(dAtA []byte) error

func (*GRPCGatewayError) XXX_DiscardUnknown 

func (m *GRPCGatewayError) XXX_DiscardUnknown()

func (*GRPCGatewayError) XXX_Marshal 

func (m *GRPCGatewayError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GRPCGatewayError) XXX_Merge 

func (m *GRPCGatewayError) XXX_Merge(src proto.Message)

func (*GRPCGatewayError) XXX_Size 

func (m *GRPCGatewayError) XXX_Size() int

func (*GRPCGatewayError) XXX_Unmarshal 

func (m *GRPCGatewayError) XXX_Unmarshal(b []byte) error

type GRPCGatewayError_GRPCGatewayErrorDetails 

type GRPCGatewayError_GRPCGatewayErrorDetails struct {
	GrpcCode             int32    `protobuf:"varint,1,opt,name=grpcCode,proto3" json:"grpcCode,omitempty"`
	HttpCode             int32    `protobuf:"varint,2,opt,name=httpCode,proto3" json:"httpCode,omitempty"`
	Message              string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	HttpStatus           string   `protobuf:"bytes,4,opt,name=httpStatus,proto3" json:"httpStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GRPCGatewayError_GRPCGatewayErrorDetails) Descriptor 

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

func (*GRPCGatewayError_GRPCGatewayErrorDetails) GetGrpcCode 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) GetGrpcCode() int32

func (*GRPCGatewayError_GRPCGatewayErrorDetails) GetHttpCode 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) GetHttpCode() int32

func (*GRPCGatewayError_GRPCGatewayErrorDetails) GetHttpStatus 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) GetHttpStatus() string

func (*GRPCGatewayError_GRPCGatewayErrorDetails) GetMessage 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) GetMessage() string

func (*GRPCGatewayError_GRPCGatewayErrorDetails) Marshal added in v1.64.0 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) Marshal() (dAtA []byte, err error)

func (*GRPCGatewayError_GRPCGatewayErrorDetails) MarshalTo added in v1.64.0 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) MarshalTo(dAtA []byte) (int, error)

func (*GRPCGatewayError_GRPCGatewayErrorDetails) MarshalToSizedBuffer added in v1.64.0 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCGatewayError_GRPCGatewayErrorDetails) ProtoMessage 

func (*GRPCGatewayError_GRPCGatewayErrorDetails) ProtoMessage()

func (*GRPCGatewayError_GRPCGatewayErrorDetails) Reset 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) Reset()

func (*GRPCGatewayError_GRPCGatewayErrorDetails) Size added in v1.64.0 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) Size() (n int)

func (*GRPCGatewayError_GRPCGatewayErrorDetails) String 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) String() string

func (*GRPCGatewayError_GRPCGatewayErrorDetails) Unmarshal added in v1.64.0 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) Unmarshal(dAtA []byte) error

func (*GRPCGatewayError_GRPCGatewayErrorDetails) XXX_DiscardUnknown 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) XXX_DiscardUnknown()

func (*GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Marshal 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Merge 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Merge(src proto.Message)

func (*GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Size 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Size() int

func (*GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Unmarshal 

func (m *GRPCGatewayError_GRPCGatewayErrorDetails) XXX_Unmarshal(b []byte) error

type GRPCGatewayWrapper 

type GRPCGatewayWrapper struct {
	Result               *TracesData `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

GRPCGatewayWrapper wraps streaming responses from GetTrace/FindTraces for HTTP. Today there is always only one response because internally the HTTP server gets data from QueryService that does not support multiple responses. But in the future the server may return multiple responeses using Transfer-Encoding: chunked. In case of errors, GRPCGatewayError above is used.

Example: 

{"result": {"resourceSpans": ...}}

See https://github.com/grpc-ecosystem/grpc-gateway/issues/2189

func (*GRPCGatewayWrapper) Descriptor 

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

func (*GRPCGatewayWrapper) GetResult 

func (m *GRPCGatewayWrapper) GetResult() *TracesData

func (*GRPCGatewayWrapper) Marshal added in v1.64.0 

func (m *GRPCGatewayWrapper) Marshal() (dAtA []byte, err error)

func (*GRPCGatewayWrapper) MarshalTo added in v1.64.0 

func (m *GRPCGatewayWrapper) MarshalTo(dAtA []byte) (int, error)

func (*GRPCGatewayWrapper) MarshalToSizedBuffer added in v1.64.0 

func (m *GRPCGatewayWrapper) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCGatewayWrapper) ProtoMessage 

func (*GRPCGatewayWrapper) ProtoMessage()

func (*GRPCGatewayWrapper) Reset 

func (m *GRPCGatewayWrapper) Reset()

func (*GRPCGatewayWrapper) Size added in v1.64.0 

func (m *GRPCGatewayWrapper) Size() (n int)

func (*GRPCGatewayWrapper) String 

func (m *GRPCGatewayWrapper) String() string

func (*GRPCGatewayWrapper) Unmarshal added in v1.64.0 

func (m *GRPCGatewayWrapper) Unmarshal(dAtA []byte) error

func (*GRPCGatewayWrapper) XXX_DiscardUnknown 

func (m *GRPCGatewayWrapper) XXX_DiscardUnknown()

func (*GRPCGatewayWrapper) XXX_Marshal 

func (m *GRPCGatewayWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GRPCGatewayWrapper) XXX_Merge 

func (m *GRPCGatewayWrapper) XXX_Merge(src proto.Message)

func (*GRPCGatewayWrapper) XXX_Size 

func (m *GRPCGatewayWrapper) XXX_Size() int

func (*GRPCGatewayWrapper) XXX_Unmarshal 

func (m *GRPCGatewayWrapper) XXX_Unmarshal(b []byte) error

type GetOperationsRequest 

type GetOperationsRequest struct {
	// Required service name.
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Optional span kind.
	SpanKind             string   `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request object to get operation names.

func (*GetOperationsRequest) Descriptor 

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

func (*GetOperationsRequest) GetService 

func (m *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind 

func (m *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) Marshal added in v1.64.0 

func (m *GetOperationsRequest) Marshal() (dAtA []byte, err error)

func (*GetOperationsRequest) MarshalTo added in v1.64.0 

func (m *GetOperationsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetOperationsRequest) MarshalToSizedBuffer added in v1.64.0 

func (m *GetOperationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetOperationsRequest) ProtoMessage 

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) Reset 

func (m *GetOperationsRequest) Reset()

func (*GetOperationsRequest) Size added in v1.64.0 

func (m *GetOperationsRequest) Size() (n int)

func (*GetOperationsRequest) String 

func (m *GetOperationsRequest) String() string

func (*GetOperationsRequest) Unmarshal added in v1.64.0 

func (m *GetOperationsRequest) Unmarshal(dAtA []byte) error

func (*GetOperationsRequest) XXX_DiscardUnknown 

func (m *GetOperationsRequest) XXX_DiscardUnknown()

func (*GetOperationsRequest) XXX_Marshal 

func (m *GetOperationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOperationsRequest) XXX_Merge 

func (m *GetOperationsRequest) XXX_Merge(src proto.Message)

func (*GetOperationsRequest) XXX_Size 

func (m *GetOperationsRequest) XXX_Size() int

func (*GetOperationsRequest) XXX_Unmarshal 

func (m *GetOperationsRequest) XXX_Unmarshal(b []byte) error

type GetOperationsResponse 

type GetOperationsResponse struct {
	Operations           []*Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Response object to get operation names.

func (*GetOperationsResponse) Descriptor 

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

func (*GetOperationsResponse) GetOperations 

func (m *GetOperationsResponse) GetOperations() []*Operation

func (*GetOperationsResponse) Marshal added in v1.64.0 

func (m *GetOperationsResponse) Marshal() (dAtA []byte, err error)

func (*GetOperationsResponse) MarshalTo added in v1.64.0 

func (m *GetOperationsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetOperationsResponse) MarshalToSizedBuffer added in v1.64.0 

func (m *GetOperationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetOperationsResponse) ProtoMessage 

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) Reset 

func (m *GetOperationsResponse) Reset()

func (*GetOperationsResponse) Size added in v1.64.0 

func (m *GetOperationsResponse) Size() (n int)

func (*GetOperationsResponse) String 

func (m *GetOperationsResponse) String() string

func (*GetOperationsResponse) Unmarshal added in v1.64.0 

func (m *GetOperationsResponse) Unmarshal(dAtA []byte) error

func (*GetOperationsResponse) XXX_DiscardUnknown 

func (m *GetOperationsResponse) XXX_DiscardUnknown()

func (*GetOperationsResponse) XXX_Marshal 

func (m *GetOperationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOperationsResponse) XXX_Merge 

func (m *GetOperationsResponse) XXX_Merge(src proto.Message)

func (*GetOperationsResponse) XXX_Size 

func (m *GetOperationsResponse) XXX_Size() int

func (*GetOperationsResponse) XXX_Unmarshal 

func (m *GetOperationsResponse) XXX_Unmarshal(b []byte) error

type GetServicesRequest 

type GetServicesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request object to get service names.

func (*GetServicesRequest) Descriptor 

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

func (*GetServicesRequest) Marshal added in v1.64.0 

func (m *GetServicesRequest) Marshal() (dAtA []byte, err error)

func (*GetServicesRequest) MarshalTo added in v1.64.0 

func (m *GetServicesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetServicesRequest) MarshalToSizedBuffer added in v1.64.0 

func (m *GetServicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetServicesRequest) ProtoMessage 

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) Reset 

func (m *GetServicesRequest) Reset()

func (*GetServicesRequest) Size added in v1.64.0 

func (m *GetServicesRequest) Size() (n int)

func (*GetServicesRequest) String 

func (m *GetServicesRequest) String() string

func (*GetServicesRequest) Unmarshal added in v1.64.0 

func (m *GetServicesRequest) Unmarshal(dAtA []byte) error

func (*GetServicesRequest) XXX_DiscardUnknown 

func (m *GetServicesRequest) XXX_DiscardUnknown()

func (*GetServicesRequest) XXX_Marshal 

func (m *GetServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServicesRequest) XXX_Merge 

func (m *GetServicesRequest) XXX_Merge(src proto.Message)

func (*GetServicesRequest) XXX_Size 

func (m *GetServicesRequest) XXX_Size() int

func (*GetServicesRequest) XXX_Unmarshal 

func (m *GetServicesRequest) XXX_Unmarshal(b []byte) error

type GetServicesResponse 

type GetServicesResponse struct {
	Services             []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response object to get service names.

func (*GetServicesResponse) Descriptor 

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

func (*GetServicesResponse) GetServices 

func (m *GetServicesResponse) GetServices() []string

func (*GetServicesResponse) Marshal added in v1.64.0 

func (m *GetServicesResponse) Marshal() (dAtA []byte, err error)

func (*GetServicesResponse) MarshalTo added in v1.64.0 

func (m *GetServicesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetServicesResponse) MarshalToSizedBuffer added in v1.64.0 

func (m *GetServicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetServicesResponse) ProtoMessage 

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) Reset 

func (m *GetServicesResponse) Reset()

func (*GetServicesResponse) Size added in v1.64.0 

func (m *GetServicesResponse) Size() (n int)

func (*GetServicesResponse) String 

func (m *GetServicesResponse) String() string

func (*GetServicesResponse) Unmarshal added in v1.64.0 

func (m *GetServicesResponse) Unmarshal(dAtA []byte) error

func (*GetServicesResponse) XXX_DiscardUnknown 

func (m *GetServicesResponse) XXX_DiscardUnknown()

func (*GetServicesResponse) XXX_Marshal 

func (m *GetServicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServicesResponse) XXX_Merge 

func (m *GetServicesResponse) XXX_Merge(src proto.Message)

func (*GetServicesResponse) XXX_Size 

func (m *GetServicesResponse) XXX_Size() int

func (*GetServicesResponse) XXX_Unmarshal 

func (m *GetServicesResponse) XXX_Unmarshal(b []byte) error

type GetTraceRequest 

type GetTraceRequest struct {
	// Hex encoded 64 or 128 bit trace ID.
	TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// Optional. The start time to search trace ID.
	StartTime time.Time `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	// Optional. The end time to search trace ID.
	EndTime              time.Time `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Request object to get a trace.

func (*GetTraceRequest) Descriptor 

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

func (*GetTraceRequest) GetEndTime 

func (m *GetTraceRequest) GetEndTime() time.Time

func (*GetTraceRequest) GetStartTime 

func (m *GetTraceRequest) GetStartTime() time.Time

func (*GetTraceRequest) GetTraceId 

func (m *GetTraceRequest) GetTraceId() string

func (*GetTraceRequest) Marshal added in v1.64.0 

func (m *GetTraceRequest) Marshal() (dAtA []byte, err error)

func (*GetTraceRequest) MarshalTo added in v1.64.0 

func (m *GetTraceRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetTraceRequest) MarshalToSizedBuffer added in v1.64.0 

func (m *GetTraceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTraceRequest) ProtoMessage 

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) Reset 

func (m *GetTraceRequest) Reset()

func (*GetTraceRequest) Size added in v1.64.0 

func (m *GetTraceRequest) Size() (n int)

func (*GetTraceRequest) String 

func (m *GetTraceRequest) String() string

func (*GetTraceRequest) Unmarshal added in v1.64.0 

func (m *GetTraceRequest) Unmarshal(dAtA []byte) error

func (*GetTraceRequest) XXX_DiscardUnknown 

func (m *GetTraceRequest) XXX_DiscardUnknown()

func (*GetTraceRequest) XXX_Marshal 

func (m *GetTraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTraceRequest) XXX_Merge 

func (m *GetTraceRequest) XXX_Merge(src proto.Message)

func (*GetTraceRequest) XXX_Size 

func (m *GetTraceRequest) XXX_Size() int

func (*GetTraceRequest) XXX_Unmarshal 

func (m *GetTraceRequest) XXX_Unmarshal(b []byte) error

type Operation 

type Operation struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SpanKind             string   `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Operation encapsulates information about operation.

func (*Operation) Descriptor 

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

func (*Operation) GetName 

func (m *Operation) GetName() string

func (*Operation) GetSpanKind 

func (m *Operation) GetSpanKind() string

func (*Operation) Marshal added in v1.64.0 

func (m *Operation) Marshal() (dAtA []byte, err error)

func (*Operation) MarshalTo added in v1.64.0 

func (m *Operation) MarshalTo(dAtA []byte) (int, error)

func (*Operation) MarshalToSizedBuffer added in v1.64.0 

func (m *Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) Reset 

func (m *Operation) Reset()

func (*Operation) Size added in v1.64.0 

func (m *Operation) Size() (n int)

func (*Operation) String 

func (m *Operation) String() string

func (*Operation) Unmarshal added in v1.64.0 

func (m *Operation) Unmarshal(dAtA []byte) error

func (*Operation) XXX_DiscardUnknown 

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal 

func (m *Operation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Operation) XXX_Merge 

func (m *Operation) XXX_Merge(src proto.Message)

func (*Operation) XXX_Size 

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal 

func (m *Operation) XXX_Unmarshal(b []byte) error

type QueryServiceClient 

type QueryServiceClient interface {
	// GetTrace returns a single trace.
	// Note that the JSON response over HTTP is wrapped into result envelope "{"result": ...}"
	// It means that the JSON response cannot be directly unmarshalled using JSONPb.
	// This can be fixed by first parsing into user-defined envelope with standard JSON library
	// or string manipulation to remove the envelope. Alternatively generate objects using OpenAPI.
	GetTrace(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (QueryService_GetTraceClient, error)
	// FindTraces searches for traces.
	// See GetTrace for JSON unmarshalling.
	FindTraces(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (QueryService_FindTracesClient, error)
	// GetServices returns service names.
	GetServices(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error)
	// GetOperations returns operation names.
	GetOperations(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error)
}

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryServiceClient 

func NewQueryServiceClient(cc *grpc.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// GetTrace returns a single trace.
	// Note that the JSON response over HTTP is wrapped into result envelope "{"result": ...}"
	// It means that the JSON response cannot be directly unmarshalled using JSONPb.
	// This can be fixed by first parsing into user-defined envelope with standard JSON library
	// or string manipulation to remove the envelope. Alternatively generate objects using OpenAPI.
	GetTrace(*GetTraceRequest, QueryService_GetTraceServer) error
	// FindTraces searches for traces.
	// See GetTrace for JSON unmarshalling.
	FindTraces(*FindTracesRequest, QueryService_FindTracesServer) error
	// GetServices returns service names.
	GetServices(context.Context, *GetServicesRequest) (*GetServicesResponse, error)
	// GetOperations returns operation names.
	GetOperations(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type QueryService_FindTracesClient 

type QueryService_FindTracesClient interface {
	Recv() (*TracesData, error)
	grpc.ClientStream
}

type QueryService_FindTracesServer 

type QueryService_FindTracesServer interface {
	Send(*TracesData) error
	grpc.ServerStream
}

type QueryService_GetTraceClient 

type QueryService_GetTraceClient interface {
	Recv() (*TracesData, error)
	grpc.ClientStream
}

type QueryService_GetTraceServer 

type QueryService_GetTraceServer interface {
	Send(*TracesData) error
	grpc.ServerStream
}

type TraceQueryParameters 

type TraceQueryParameters struct {
	ServiceName   string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	OperationName string `protobuf:"bytes,2,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	// Attributes are matched against Span and Resource attributes.
	// At least one span in a trace must match all specified attributes.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// Span min start time in. REST API uses RFC-3339ns format. Required.
	StartTimeMin time.Time `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3,stdtime" json:"start_time_min"`
	// Span max start time. REST API uses RFC-3339ns format. Required.
	StartTimeMax time.Time `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3,stdtime" json:"start_time_max"`
	// Span min duration. REST API uses Golang's time format e.g. 10s.
	DurationMin time.Duration `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3,stdduration" json:"duration_min"`
	// Span max duration. REST API uses Golang's time format e.g. 10s.
	DurationMax time.Duration `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3,stdduration" json:"duration_max"`
	// Maximum depth of search. Depending on the backend storage
	// implementtaion this could be like a regular LIMIT clause in SQL,
	// but not all implementations support such accuracy and for those
	// the larger depth value simply means more traces returned.
	SearchDepth          int32    `protobuf:"varint,8,opt,name=search_depth,json=searchDepth,proto3" json:"search_depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Query parameters to find traces. Except for num_traces, all fields should be treated as forming a conjunction, e.g., "service_name='X' AND operation_name='Y' AND ...". All fields are matched against individual spans, not at the trace level. The returned results contain traces where at least one span matches the conditions. When num_traces results in fewer traces returned, there is no required ordering.

Note: num_traces should restrict the number of traces returned, but not all backends interpret it this way. For instance, in Cassandra this limits the number of _spans_ that match the conditions, and the resulting number of traces can be less.

Note: some storage implementations do not guarantee the correct implementation of all parameters.

func (*TraceQueryParameters) Descriptor 

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

func (*TraceQueryParameters) GetAttributes 

func (m *TraceQueryParameters) GetAttributes() map[string]string

func (*TraceQueryParameters) GetDurationMax 

func (m *TraceQueryParameters) GetDurationMax() time.Duration

func (*TraceQueryParameters) GetDurationMin 

func (m *TraceQueryParameters) GetDurationMin() time.Duration

func (*TraceQueryParameters) GetOperationName 

func (m *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetSearchDepth added in v1.64.0 

func (m *TraceQueryParameters) GetSearchDepth() int32

func (*TraceQueryParameters) GetServiceName 

func (m *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax 

func (m *TraceQueryParameters) GetStartTimeMax() time.Time

func (*TraceQueryParameters) GetStartTimeMin 

func (m *TraceQueryParameters) GetStartTimeMin() time.Time

func (*TraceQueryParameters) Marshal added in v1.64.0 

func (m *TraceQueryParameters) Marshal() (dAtA []byte, err error)

func (*TraceQueryParameters) MarshalTo added in v1.64.0 

func (m *TraceQueryParameters) MarshalTo(dAtA []byte) (int, error)

func (*TraceQueryParameters) MarshalToSizedBuffer added in v1.64.0 

func (m *TraceQueryParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TraceQueryParameters) ProtoMessage 

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) Reset 

func (m *TraceQueryParameters) Reset()

func (*TraceQueryParameters) Size added in v1.64.0 

func (m *TraceQueryParameters) Size() (n int)

func (*TraceQueryParameters) String 

func (m *TraceQueryParameters) String() string

func (*TraceQueryParameters) Unmarshal added in v1.64.0 

func (m *TraceQueryParameters) Unmarshal(dAtA []byte) error

func (*TraceQueryParameters) XXX_DiscardUnknown 

func (m *TraceQueryParameters) XXX_DiscardUnknown()

func (*TraceQueryParameters) XXX_Marshal 

func (m *TraceQueryParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TraceQueryParameters) XXX_Merge 

func (m *TraceQueryParameters) XXX_Merge(src proto.Message)

func (*TraceQueryParameters) XXX_Size 

func (m *TraceQueryParameters) XXX_Size() int

func (*TraceQueryParameters) XXX_Unmarshal 

func (m *TraceQueryParameters) XXX_Unmarshal(b []byte) error

type TracesData 

type TracesData ptrace.Traces

TracesData is an alias to ptrace.Traces that supports Gogo marshaling. Our .proto APIs may refer to otlp.TraceData type, but its corresponding protoc-generated struct is internal in OTel Collector, so we substitute it for this TracesData type that implements marshaling methods by delegating to public functions in the OTel Collector's ptrace module.

func (*TracesData) Marshal 

func (td *TracesData) Marshal() ([]byte, error)

Marshal implements gogocodec.CustomType.

func (*TracesData) MarshalJSONPB 

func (td *TracesData) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)

MarshalJSONPB implements gogocodec.CustomType.

func (*TracesData) MarshalTo 

func (td *TracesData) MarshalTo(buf []byte) (n int, err error)

MarshalTo implements gogocodec.CustomType.

func (*TracesData) MarshalToSizedBuffer added in v1.64.0 

func (td *TracesData) MarshalToSizedBuffer(buf []byte) (int, error)

MarshalToSizedBuffer is used by Gogo.

func (*TracesData) ProtoMessage 

func (*TracesData) ProtoMessage()

ProtoMessage implements proto.Message.

func (*TracesData) Reset 

func (td *TracesData) Reset()

Reset implements proto.Message.

func (*TracesData) Size 

func (td *TracesData) Size() int

Size implements gogocodec.CustomType.

func (*TracesData) String 

func (*TracesData) String() string

String implements proto.Message.

func (TracesData) ToTraces 

func (td TracesData) ToTraces() ptrace.Traces

func (*TracesData) Unmarshal 

func (td *TracesData) Unmarshal(data []byte) error

Unmarshal implements gogocodec.CustomType.

func (*TracesData) UnmarshalJSONPB 

func (td *TracesData) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, data []byte) error

UnmarshalJSONPB implements gogocodec.CustomType.

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) FindTraces 

func (*UnimplementedQueryServiceServer) FindTraces(req *FindTracesRequest, srv QueryService_FindTracesServer) error

func (*UnimplementedQueryServiceServer) GetOperations 

func (*UnimplementedQueryServiceServer) GetOperations(ctx context.Context, req *GetOperationsRequest) (*GetOperationsResponse, error)

func (*UnimplementedQueryServiceServer) GetServices 

func (*UnimplementedQueryServiceServer) GetServices(ctx context.Context, req *GetServicesRequest) (*GetServicesResponse, error)

func (*UnimplementedQueryServiceServer) GetTrace 

func (*UnimplementedQueryServiceServer) GetTrace(req *GetTraceRequest, srv QueryService_GetTraceServer) 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.