proxypb

package
v0.0.0-...-1215978 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package proxypb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	TraceProxyService_ExportTraceProxy_FullMethodName    = "/proto.TraceProxyService/ExportTraceProxy"
	TraceProxyService_ExportLogTraceProxy_FullMethodName = "/proto.TraceProxyService/ExportLogTraceProxy"
	TraceProxyService_Status_FullMethodName              = "/proto.TraceProxyService/Status"
)

Variables

View Source 
var File_proto_proxyspan_proto protoreflect.FileDescriptor
View Source 
var TraceProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.TraceProxyService",
	HandlerType: (*TraceProxyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExportTraceProxy",
			Handler:    _TraceProxyService_ExportTraceProxy_Handler,
		},
		{
			MethodName: "ExportLogTraceProxy",
			Handler:    _TraceProxyService_ExportLogTraceProxy_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _TraceProxyService_Status_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/proxyspan.proto",
}

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

Functions

func RegisterTraceProxyServiceHandler 

func RegisterTraceProxyServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterTraceProxyServiceHandler registers the http handlers for service TraceProxyService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTraceProxyServiceHandlerClient 

func RegisterTraceProxyServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TraceProxyServiceClient) error

RegisterTraceProxyServiceHandlerClient registers the http handlers for service TraceProxyService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TraceProxyServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TraceProxyServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TraceProxyServiceClient" to call the correct interceptors.

func RegisterTraceProxyServiceHandlerFromEndpoint 

func RegisterTraceProxyServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTraceProxyServiceHandlerFromEndpoint is same as RegisterTraceProxyServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTraceProxyServiceHandlerServer 

func RegisterTraceProxyServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TraceProxyServiceServer) error

RegisterTraceProxyServiceHandlerServer registers the http handlers for service TraceProxyService to "mux". UnaryRPC :call TraceProxyServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterTraceProxyServiceHandlerFromEndpoint instead.

func RegisterTraceProxyServiceServer 

func RegisterTraceProxyServiceServer(s grpc.ServiceRegistrar, srv TraceProxyServiceServer)

Types

type AnyValue 

type AnyValue struct {

	// The value is one of the listed fields. It is valid for all values to be unspecified
	// in which case this AnyValue is considered to be "empty".
	//
	// Types that are assignable to Value:
	//
	//	*AnyValue_StringValue
	//	*AnyValue_BoolValue
	//	*AnyValue_IntValue
	//	*AnyValue_DoubleValue
	//	*AnyValue_ArrayValue
	//	*AnyValue_KvlistValue
	//	*AnyValue_BytesValue
	Value isAnyValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

AnyValue is used to represent any type of attribute value. AnyValue may contain a primitive value such as a string or integer or it may contain an arbitrary nested object containing arrays, key-value lists and primitives.

func (*AnyValue) Descriptor deprecated 

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

Deprecated: Use AnyValue.ProtoReflect.Descriptor instead.

func (*AnyValue) GetArrayValue 

func (x *AnyValue) GetArrayValue() *ArrayValue

func (*AnyValue) GetBoolValue 

func (x *AnyValue) GetBoolValue() bool

func (*AnyValue) GetBytesValue 

func (x *AnyValue) GetBytesValue() []byte

func (*AnyValue) GetDoubleValue 

func (x *AnyValue) GetDoubleValue() float64

func (*AnyValue) GetIntValue 

func (x *AnyValue) GetIntValue() int64

func (*AnyValue) GetKvlistValue 

func (x *AnyValue) GetKvlistValue() *KeyValueList

func (*AnyValue) GetStringValue 

func (x *AnyValue) GetStringValue() string

func (*AnyValue) GetValue 

func (m *AnyValue) GetValue() isAnyValue_Value

func (*AnyValue) ProtoMessage 

func (*AnyValue) ProtoMessage()

func (*AnyValue) ProtoReflect 

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

func (*AnyValue) Reset 

func (x *AnyValue) Reset()

func (*AnyValue) String 

func (x *AnyValue) String() string

type AnyValue_ArrayValue 

type AnyValue_ArrayValue struct {
	ArrayValue *ArrayValue `protobuf:"bytes,5,opt,name=array_value,json=arrayValue,proto3,oneof"`
}

type AnyValue_BoolValue 

type AnyValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type AnyValue_BytesValue 

type AnyValue_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,7,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type AnyValue_DoubleValue 

type AnyValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type AnyValue_IntValue 

type AnyValue_IntValue struct {
	IntValue int64 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}

type AnyValue_KvlistValue 

type AnyValue_KvlistValue struct {
	KvlistValue *KeyValueList `protobuf:"bytes,6,opt,name=kvlist_value,json=kvlistValue,proto3,oneof"`
}

type AnyValue_StringValue 

type AnyValue_StringValue struct {
	StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type ArrayValue 

type ArrayValue struct {

	// Array of values. The array may be empty (contain 0 elements).
	Values []*AnyValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

ArrayValue is a list of AnyValue messages. We need ArrayValue as a message since oneof in AnyValue does not allow repeated fields.

func (*ArrayValue) Descriptor deprecated 

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

Deprecated: Use ArrayValue.ProtoReflect.Descriptor instead.

func (*ArrayValue) GetValues 

func (x *ArrayValue) GetValues() []*AnyValue

func (*ArrayValue) ProtoMessage 

func (*ArrayValue) ProtoMessage()

func (*ArrayValue) ProtoReflect 

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

func (*ArrayValue) Reset 

func (x *ArrayValue) Reset()

func (*ArrayValue) String 

func (x *ArrayValue) String() string

type Data 

type Data struct {
	DurationMs       float64 `protobuf:"fixed64,1,opt,name=durationMs,proto3" json:"durationMs,omitempty"`
	Type             string  `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	SpanName         string  `protobuf:"bytes,5,opt,name=spanName,proto3" json:"spanName,omitempty"`
	ParentName       string  `protobuf:"bytes,6,opt,name=parentName,proto3" json:"parentName,omitempty"`
	SpanKind         string  `protobuf:"bytes,8,opt,name=spanKind,proto3" json:"spanKind,omitempty"`
	SpanNumEvents    int64   `protobuf:"varint,9,opt,name=spanNumEvents,proto3" json:"spanNumEvents,omitempty"`
	SpanNumLinks     int64   `protobuf:"varint,10,opt,name=spanNumLinks,proto3" json:"spanNumLinks,omitempty"`
	StatusCode       int64   `protobuf:"varint,11,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	FromProxy        bool    `protobuf:"varint,12,opt,name=fromProxy,proto3" json:"fromProxy,omitempty"`
	TraceParentID    string  `protobuf:"bytes,13,opt,name=traceParentID,proto3" json:"traceParentID,omitempty"`
	TraceSpanID      string  `protobuf:"bytes,14,opt,name=traceSpanID,proto3" json:"traceSpanID,omitempty"`
	TraceTraceID     string  `protobuf:"bytes,15,opt,name=traceTraceID,proto3" json:"traceTraceID,omitempty"`
	TraceLinkSpanID  string  `protobuf:"bytes,16,opt,name=traceLinkSpanID,proto3" json:"traceLinkSpanID,omitempty"`
	TraceLinkTraceID string  `protobuf:"bytes,17,opt,name=traceLinkTraceID,proto3" json:"traceLinkTraceID,omitempty"`
	Error            bool    `protobuf:"varint,18,opt,name=error,proto3" json:"error,omitempty"`
	StatusMessage    string  `protobuf:"bytes,19,opt,name=statusMessage,proto3" json:"statusMessage,omitempty"`
	Time             int64   `protobuf:"varint,20,opt,name=time,proto3" json:"time,omitempty"`
	MetaType         string  `protobuf:"bytes,21,opt,name=metaType,proto3" json:"metaType,omitempty"`
	// The OpenTelemetry API specification further restricts the allowed value types:
	// https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/common/common.md#attributes
	// Attribute keys MUST be unique (it is not allowed to have more than one
	// attribute with the same key).
	ResourceAttributes []*KeyValue `protobuf:"bytes,22,rep,name=resourceAttributes,proto3" json:"resourceAttributes,omitempty"`
	SpanAttributes     []*KeyValue `protobuf:"bytes,23,rep,name=spanAttributes,proto3" json:"spanAttributes,omitempty"`
	EventAttributes    []*KeyValue `protobuf:"bytes,24,rep,name=eventAttributes,proto3" json:"eventAttributes,omitempty"`
	StartTime          int64       `protobuf:"varint,25,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime            int64       `protobuf:"varint,26,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetDurationMs 

func (x *Data) GetDurationMs() float64

func (*Data) GetEndTime 

func (x *Data) GetEndTime() int64

func (*Data) GetError 

func (x *Data) GetError() bool

func (*Data) GetEventAttributes 

func (x *Data) GetEventAttributes() []*KeyValue

func (*Data) GetFromProxy 

func (x *Data) GetFromProxy() bool

func (*Data) GetMetaType 

func (x *Data) GetMetaType() string

func (*Data) GetParentName 

func (x *Data) GetParentName() string

func (*Data) GetResourceAttributes 

func (x *Data) GetResourceAttributes() []*KeyValue

func (*Data) GetSpanAttributes 

func (x *Data) GetSpanAttributes() []*KeyValue

func (*Data) GetSpanKind 

func (x *Data) GetSpanKind() string

func (*Data) GetSpanName 

func (x *Data) GetSpanName() string

func (*Data) GetSpanNumEvents 

func (x *Data) GetSpanNumEvents() int64
func (x *Data) GetSpanNumLinks() int64

func (*Data) GetStartTime 

func (x *Data) GetStartTime() int64

func (*Data) GetStatusCode 

func (x *Data) GetStatusCode() int64

func (*Data) GetStatusMessage 

func (x *Data) GetStatusMessage() string

func (*Data) GetTime 

func (x *Data) GetTime() int64

func (*Data) GetTraceLinkSpanID 

func (x *Data) GetTraceLinkSpanID() string

func (*Data) GetTraceLinkTraceID 

func (x *Data) GetTraceLinkTraceID() string

func (*Data) GetTraceParentID 

func (x *Data) GetTraceParentID() string

func (*Data) GetTraceSpanID 

func (x *Data) GetTraceSpanID() string

func (*Data) GetTraceTraceID 

func (x *Data) GetTraceTraceID() string

func (*Data) GetType 

func (x *Data) GetType() string

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

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

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type ExportLogTraceProxyServiceRequest 

type ExportLogTraceProxyServiceRequest struct {
	Items    []*ProxyLogSpan `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	TenantId string          `protobuf:"bytes,2,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportLogTraceProxyServiceRequest) Descriptor deprecated 

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

Deprecated: Use ExportLogTraceProxyServiceRequest.ProtoReflect.Descriptor instead.

func (*ExportLogTraceProxyServiceRequest) GetItems 

func (x *ExportLogTraceProxyServiceRequest) GetItems() []*ProxyLogSpan

func (*ExportLogTraceProxyServiceRequest) GetTenantId 

func (x *ExportLogTraceProxyServiceRequest) GetTenantId() string

func (*ExportLogTraceProxyServiceRequest) ProtoMessage 

func (*ExportLogTraceProxyServiceRequest) ProtoMessage()

func (*ExportLogTraceProxyServiceRequest) ProtoReflect 

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

func (*ExportLogTraceProxyServiceRequest) Reset 

func (x *ExportLogTraceProxyServiceRequest) Reset()

func (*ExportLogTraceProxyServiceRequest) String 

func (x *ExportLogTraceProxyServiceRequest) String() string

type ExportTraceProxyServiceRequest 

type ExportTraceProxyServiceRequest struct {
	Items    []*ProxySpan `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	TenantId string       `protobuf:"bytes,2,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportTraceProxyServiceRequest) Descriptor deprecated 

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

Deprecated: Use ExportTraceProxyServiceRequest.ProtoReflect.Descriptor instead.

func (*ExportTraceProxyServiceRequest) GetItems 

func (x *ExportTraceProxyServiceRequest) GetItems() []*ProxySpan

func (*ExportTraceProxyServiceRequest) GetTenantId 

func (x *ExportTraceProxyServiceRequest) GetTenantId() string

func (*ExportTraceProxyServiceRequest) ProtoMessage 

func (*ExportTraceProxyServiceRequest) ProtoMessage()

func (*ExportTraceProxyServiceRequest) ProtoReflect 

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

func (*ExportTraceProxyServiceRequest) Reset 

func (x *ExportTraceProxyServiceRequest) Reset()

func (*ExportTraceProxyServiceRequest) String 

func (x *ExportTraceProxyServiceRequest) String() string

type ExportTraceProxyServiceResponse 

type ExportTraceProxyServiceResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Status  string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message

func (*ExportTraceProxyServiceResponse) Descriptor deprecated 

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

Deprecated: Use ExportTraceProxyServiceResponse.ProtoReflect.Descriptor instead.

func (*ExportTraceProxyServiceResponse) GetMessage 

func (x *ExportTraceProxyServiceResponse) GetMessage() string

func (*ExportTraceProxyServiceResponse) GetStatus 

func (x *ExportTraceProxyServiceResponse) GetStatus() string

func (*ExportTraceProxyServiceResponse) ProtoMessage 

func (*ExportTraceProxyServiceResponse) ProtoMessage()

func (*ExportTraceProxyServiceResponse) ProtoReflect 

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

func (*ExportTraceProxyServiceResponse) Reset 

func (x *ExportTraceProxyServiceResponse) Reset()

func (*ExportTraceProxyServiceResponse) String 

func (x *ExportTraceProxyServiceResponse) String() string

type KeyValue 

type KeyValue struct {
	Key   string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *AnyValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

KeyValue is a key-value pair that is used to store Span attributes, Link attributes, etc.

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (x *KeyValue) GetValue() *AnyValue

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect 

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

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) String 

func (x *KeyValue) String() string

type KeyValueList 

type KeyValueList struct {

	// A collection of key/value pairs of key-value pairs. The list may be empty (may
	// contain 0 elements).
	// The keys MUST be unique (it is not allowed to have more than one
	// value with the same key).
	Values []*KeyValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

KeyValueList is a list of KeyValue messages. We need KeyValueList as a message since `oneof` in AnyValue does not allow repeated fields. Everywhere else where we need a list of KeyValue messages (e.g. in Span) we use `repeated KeyValue` directly to avoid unnecessary extra wrapping (which slows down the protocol). The 2 approaches are semantically equivalent.

func (*KeyValueList) Descriptor deprecated 

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

Deprecated: Use KeyValueList.ProtoReflect.Descriptor instead.

func (*KeyValueList) GetValues 

func (x *KeyValueList) GetValues() []*KeyValue

func (*KeyValueList) ProtoMessage 

func (*KeyValueList) ProtoMessage()

func (*KeyValueList) ProtoReflect 

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

func (*KeyValueList) Reset 

func (x *KeyValueList) Reset()

func (*KeyValueList) String 

func (x *KeyValueList) String() string

type LogTraceData 

type LogTraceData struct {
	DurationMs       float64 `protobuf:"fixed64,1,opt,name=durationMs,proto3" json:"durationMs,omitempty"`
	Type             string  `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	SpanName         string  `protobuf:"bytes,5,opt,name=spanName,proto3" json:"spanName,omitempty"`
	ParentName       string  `protobuf:"bytes,6,opt,name=parentName,proto3" json:"parentName,omitempty"`
	SpanKind         string  `protobuf:"bytes,8,opt,name=spanKind,proto3" json:"spanKind,omitempty"`
	SpanNumEvents    int64   `protobuf:"varint,9,opt,name=spanNumEvents,proto3" json:"spanNumEvents,omitempty"`
	SpanNumLinks     int64   `protobuf:"varint,10,opt,name=spanNumLinks,proto3" json:"spanNumLinks,omitempty"`
	StatusCode       int64   `protobuf:"varint,11,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	FromProxy        bool    `protobuf:"varint,12,opt,name=fromProxy,proto3" json:"fromProxy,omitempty"`
	TraceParentID    string  `protobuf:"bytes,13,opt,name=traceParentID,proto3" json:"traceParentID,omitempty"`
	TraceSpanID      string  `protobuf:"bytes,14,opt,name=traceSpanID,proto3" json:"traceSpanID,omitempty"`
	TraceTraceID     string  `protobuf:"bytes,15,opt,name=traceTraceID,proto3" json:"traceTraceID,omitempty"`
	TraceLinkSpanID  string  `protobuf:"bytes,16,opt,name=traceLinkSpanID,proto3" json:"traceLinkSpanID,omitempty"`
	TraceLinkTraceID string  `protobuf:"bytes,17,opt,name=traceLinkTraceID,proto3" json:"traceLinkTraceID,omitempty"`
	Error            bool    `protobuf:"varint,18,opt,name=error,proto3" json:"error,omitempty"`
	StatusMessage    string  `protobuf:"bytes,19,opt,name=statusMessage,proto3" json:"statusMessage,omitempty"`
	Time             int64   `protobuf:"varint,20,opt,name=time,proto3" json:"time,omitempty"`
	MetaType         string  `protobuf:"bytes,21,opt,name=metaType,proto3" json:"metaType,omitempty"`
	// The OpenTelemetry API specification further restricts the allowed value types:
	// https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/common/common.md#attributes
	// Attribute keys MUST be unique (it is not allowed to have more than one
	// attribute with the same key).
	ResourceAttributes []*KeyValue  `protobuf:"bytes,22,rep,name=resourceAttributes,proto3" json:"resourceAttributes,omitempty"`
	SpanAttributes     []*KeyValue  `protobuf:"bytes,23,rep,name=spanAttributes,proto3" json:"spanAttributes,omitempty"`
	EventAttributes    []*KeyValue  `protobuf:"bytes,24,rep,name=eventAttributes,proto3" json:"eventAttributes,omitempty"`
	SpanEvents         []*SpanEvent `protobuf:"bytes,25,rep,name=spanEvents,proto3" json:"spanEvents,omitempty"`
	StartTime          int64        `protobuf:"varint,26,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime            int64        `protobuf:"varint,27,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

func (*LogTraceData) Descriptor deprecated 

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

Deprecated: Use LogTraceData.ProtoReflect.Descriptor instead.

func (*LogTraceData) GetDurationMs 

func (x *LogTraceData) GetDurationMs() float64

func (*LogTraceData) GetEndTime 

func (x *LogTraceData) GetEndTime() int64

func (*LogTraceData) GetError 

func (x *LogTraceData) GetError() bool

func (*LogTraceData) GetEventAttributes 

func (x *LogTraceData) GetEventAttributes() []*KeyValue

func (*LogTraceData) GetFromProxy 

func (x *LogTraceData) GetFromProxy() bool

func (*LogTraceData) GetMetaType 

func (x *LogTraceData) GetMetaType() string

func (*LogTraceData) GetParentName 

func (x *LogTraceData) GetParentName() string

func (*LogTraceData) GetResourceAttributes 

func (x *LogTraceData) GetResourceAttributes() []*KeyValue

func (*LogTraceData) GetSpanAttributes 

func (x *LogTraceData) GetSpanAttributes() []*KeyValue

func (*LogTraceData) GetSpanEvents 

func (x *LogTraceData) GetSpanEvents() []*SpanEvent

func (*LogTraceData) GetSpanKind 

func (x *LogTraceData) GetSpanKind() string

func (*LogTraceData) GetSpanName 

func (x *LogTraceData) GetSpanName() string

func (*LogTraceData) GetSpanNumEvents 

func (x *LogTraceData) GetSpanNumEvents() int64
func (x *LogTraceData) GetSpanNumLinks() int64

func (*LogTraceData) GetStartTime 

func (x *LogTraceData) GetStartTime() int64

func (*LogTraceData) GetStatusCode 

func (x *LogTraceData) GetStatusCode() int64

func (*LogTraceData) GetStatusMessage 

func (x *LogTraceData) GetStatusMessage() string

func (*LogTraceData) GetTime 

func (x *LogTraceData) GetTime() int64

func (*LogTraceData) GetTraceLinkSpanID 

func (x *LogTraceData) GetTraceLinkSpanID() string

func (*LogTraceData) GetTraceLinkTraceID 

func (x *LogTraceData) GetTraceLinkTraceID() string

func (*LogTraceData) GetTraceParentID 

func (x *LogTraceData) GetTraceParentID() string

func (*LogTraceData) GetTraceSpanID 

func (x *LogTraceData) GetTraceSpanID() string

func (*LogTraceData) GetTraceTraceID 

func (x *LogTraceData) GetTraceTraceID() string

func (*LogTraceData) GetType 

func (x *LogTraceData) GetType() string

func (*LogTraceData) ProtoMessage 

func (*LogTraceData) ProtoMessage()

func (*LogTraceData) ProtoReflect 

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

func (*LogTraceData) Reset 

func (x *LogTraceData) Reset()

func (*LogTraceData) String 

func (x *LogTraceData) String() string

type ProxyLogSpan 

type ProxyLogSpan struct {
	Data      *LogTraceData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp string        `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyLogSpan) Descriptor deprecated 

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

Deprecated: Use ProxyLogSpan.ProtoReflect.Descriptor instead.

func (*ProxyLogSpan) GetData 

func (x *ProxyLogSpan) GetData() *LogTraceData

func (*ProxyLogSpan) GetTimestamp 

func (x *ProxyLogSpan) GetTimestamp() string

func (*ProxyLogSpan) ProtoMessage 

func (*ProxyLogSpan) ProtoMessage()

func (*ProxyLogSpan) ProtoReflect 

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

func (*ProxyLogSpan) Reset 

func (x *ProxyLogSpan) Reset()

func (*ProxyLogSpan) String 

func (x *ProxyLogSpan) String() string

type ProxySpan 

type ProxySpan struct {
	Data      *Data  `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp string `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxySpan) Descriptor deprecated 

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

Deprecated: Use ProxySpan.ProtoReflect.Descriptor instead.

func (*ProxySpan) GetData 

func (x *ProxySpan) GetData() *Data

func (*ProxySpan) GetTimestamp 

func (x *ProxySpan) GetTimestamp() string

func (*ProxySpan) ProtoMessage 

func (*ProxySpan) ProtoMessage()

func (*ProxySpan) ProtoReflect 

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

func (*ProxySpan) Reset 

func (x *ProxySpan) Reset()

func (*ProxySpan) String 

func (x *ProxySpan) String() string

type SpanEvent 

type SpanEvent struct {
	Name                string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TimeStamp           uint64      `protobuf:"varint,2,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"`
	SpanEventAttributes []*KeyValue `protobuf:"bytes,3,rep,name=spanEventAttributes,proto3" json:"spanEventAttributes,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanEvent) Descriptor deprecated 

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

Deprecated: Use SpanEvent.ProtoReflect.Descriptor instead.

func (*SpanEvent) GetName 

func (x *SpanEvent) GetName() string

func (*SpanEvent) GetSpanEventAttributes 

func (x *SpanEvent) GetSpanEventAttributes() []*KeyValue

func (*SpanEvent) GetTimeStamp 

func (x *SpanEvent) GetTimeStamp() uint64

func (*SpanEvent) ProtoMessage 

func (*SpanEvent) ProtoMessage()

func (*SpanEvent) ProtoReflect 

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

func (*SpanEvent) Reset 

func (x *SpanEvent) Reset()

func (*SpanEvent) String 

func (x *SpanEvent) String() string

type StatusRequest 

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

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	PeerActive bool `protobuf:"varint,1,opt,name=peerActive,proto3" json:"peerActive,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetPeerActive 

func (x *StatusResponse) GetPeerActive() bool

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type TraceProxyServiceClient 

type TraceProxyServiceClient interface {
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	ExportTraceProxy(ctx context.Context, in *ExportTraceProxyServiceRequest, opts ...grpc.CallOption) (*ExportTraceProxyServiceResponse, error)
	ExportLogTraceProxy(ctx context.Context, in *ExportLogTraceProxyServiceRequest, opts ...grpc.CallOption) (*ExportTraceProxyServiceResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

TraceProxyServiceClient is the client API for TraceProxyService 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 NewTraceProxyServiceClient 

func NewTraceProxyServiceClient(cc grpc.ClientConnInterface) TraceProxyServiceClient

type TraceProxyServiceServer 

type TraceProxyServiceServer interface {
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	ExportTraceProxy(context.Context, *ExportTraceProxyServiceRequest) (*ExportTraceProxyServiceResponse, error)
	ExportLogTraceProxy(context.Context, *ExportLogTraceProxyServiceRequest) (*ExportTraceProxyServiceResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

TraceProxyServiceServer is the server API for TraceProxyService service. All implementations must embed UnimplementedTraceProxyServiceServer for forward compatibility

type UnimplementedTraceProxyServiceServer 

type UnimplementedTraceProxyServiceServer struct {
}

UnimplementedTraceProxyServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTraceProxyServiceServer) ExportLogTraceProxy 

func (UnimplementedTraceProxyServiceServer) ExportLogTraceProxy(context.Context, *ExportLogTraceProxyServiceRequest) (*ExportTraceProxyServiceResponse, error)

func (UnimplementedTraceProxyServiceServer) ExportTraceProxy 

func (UnimplementedTraceProxyServiceServer) ExportTraceProxy(context.Context, *ExportTraceProxyServiceRequest) (*ExportTraceProxyServiceResponse, error)

func (UnimplementedTraceProxyServiceServer) Status 

func (UnimplementedTraceProxyServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeTraceProxyServiceServer 

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

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

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.