com_newrelic_trace_v1

package
v0.0.0-...-51c1140 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_v1_proto protoreflect.FileDescriptor

Functions

func RegisterIngestServiceServer 

func RegisterIngestServiceServer(s *grpc.Server, srv IngestServiceServer)

Types

type AttributeValue 

type AttributeValue struct {

	// Types that are assignable to Value:
	//	*AttributeValue_StringValue
	//	*AttributeValue_BoolValue
	//	*AttributeValue_IntValue
	//	*AttributeValue_DoubleValue
	Value isAttributeValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*AttributeValue) Descriptor deprecated 

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

Deprecated: Use AttributeValue.ProtoReflect.Descriptor instead.

func (*AttributeValue) GetBoolValue 

func (x *AttributeValue) GetBoolValue() bool

func (*AttributeValue) GetDoubleValue 

func (x *AttributeValue) GetDoubleValue() float64

func (*AttributeValue) GetIntValue 

func (x *AttributeValue) GetIntValue() int64

func (*AttributeValue) GetStringValue 

func (x *AttributeValue) GetStringValue() string

func (*AttributeValue) GetValue 

func (m *AttributeValue) GetValue() isAttributeValue_Value

func (*AttributeValue) ProtoMessage 

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) ProtoReflect 

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

func (*AttributeValue) Reset 

func (x *AttributeValue) Reset()

func (*AttributeValue) String 

func (x *AttributeValue) String() string

type AttributeValue_BoolValue 

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

type AttributeValue_DoubleValue 

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

type AttributeValue_IntValue 

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

type AttributeValue_StringValue 

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

type IngestServiceClient 

type IngestServiceClient interface {
	// Accepts a stream of Span messages, and returns an irregular stream of
	// RecordStatus messages.
	RecordSpan(ctx context.Context, opts ...grpc.CallOption) (IngestService_RecordSpanClient, error)
	// Accepts a stream of SpanBatch messages, and returns an irregular
	// stream of RecordStatus messages. This endpoint can be used to improve
	// throughput when Span messages are small
	RecordSpanBatch(ctx context.Context, opts ...grpc.CallOption) (IngestService_RecordSpanBatchClient, error)
}

IngestServiceClient is the client API for IngestService service.

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

func NewIngestServiceClient 

func NewIngestServiceClient(cc grpc.ClientConnInterface) IngestServiceClient

type IngestServiceServer 

type IngestServiceServer interface {
	// Accepts a stream of Span messages, and returns an irregular stream of
	// RecordStatus messages.
	RecordSpan(IngestService_RecordSpanServer) error
	// Accepts a stream of SpanBatch messages, and returns an irregular
	// stream of RecordStatus messages. This endpoint can be used to improve
	// throughput when Span messages are small
	RecordSpanBatch(IngestService_RecordSpanBatchServer) error
}

IngestServiceServer is the server API for IngestService service.

type IngestService_RecordSpanBatchClient 

type IngestService_RecordSpanBatchClient interface {
	Send(*SpanBatch) error
	Recv() (*RecordStatus, error)
	grpc.ClientStream
}

type IngestService_RecordSpanBatchServer 

type IngestService_RecordSpanBatchServer interface {
	Send(*RecordStatus) error
	Recv() (*SpanBatch, error)
	grpc.ServerStream
}

type IngestService_RecordSpanClient 

type IngestService_RecordSpanClient interface {
	Send(*Span) error
	Recv() (*RecordStatus, error)
	grpc.ClientStream
}

type IngestService_RecordSpanServer 

type IngestService_RecordSpanServer interface {
	Send(*RecordStatus) error
	Recv() (*Span, error)
	grpc.ServerStream
}

type RecordStatus 

type RecordStatus struct {
	MessagesSeen uint64 `protobuf:"varint,1,opt,name=messages_seen,json=messagesSeen,proto3" json:"messages_seen,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordStatus) Descriptor deprecated 

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

Deprecated: Use RecordStatus.ProtoReflect.Descriptor instead.

func (*RecordStatus) GetMessagesSeen 

func (x *RecordStatus) GetMessagesSeen() uint64

func (*RecordStatus) ProtoMessage 

func (*RecordStatus) ProtoMessage()

func (*RecordStatus) ProtoReflect 

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

func (*RecordStatus) Reset 

func (x *RecordStatus) Reset()

func (*RecordStatus) String 

func (x *RecordStatus) String() string

type Span 

type Span struct {
	TraceId         string                     `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	Intrinsics      map[string]*AttributeValue `` /* 161-byte string literal not displayed */
	UserAttributes  map[string]*AttributeValue `` /* 191-byte string literal not displayed */
	AgentAttributes map[string]*AttributeValue `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Span) Descriptor deprecated 

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

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetAgentAttributes 

func (x *Span) GetAgentAttributes() map[string]*AttributeValue

func (*Span) GetIntrinsics 

func (x *Span) GetIntrinsics() map[string]*AttributeValue

func (*Span) GetTraceId 

func (x *Span) GetTraceId() string

func (*Span) GetUserAttributes 

func (x *Span) GetUserAttributes() map[string]*AttributeValue

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) ProtoReflect 

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

func (*Span) Reset 

func (x *Span) Reset()

func (*Span) String 

func (x *Span) String() string

type SpanBatch 

type SpanBatch struct {
	Spans []*Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanBatch) Descriptor deprecated 

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

Deprecated: Use SpanBatch.ProtoReflect.Descriptor instead.

func (*SpanBatch) GetSpans 

func (x *SpanBatch) GetSpans() []*Span

func (*SpanBatch) ProtoMessage 

func (*SpanBatch) ProtoMessage()

func (*SpanBatch) ProtoReflect 

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

func (*SpanBatch) Reset 

func (x *SpanBatch) Reset()

func (*SpanBatch) String 

func (x *SpanBatch) String() string

type UnimplementedIngestServiceServer 

type UnimplementedIngestServiceServer struct {
}

UnimplementedIngestServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestServiceServer) RecordSpan 

func (*UnimplementedIngestServiceServer) RecordSpan(IngestService_RecordSpanServer) error

func (*UnimplementedIngestServiceServer) RecordSpanBatch 

func (*UnimplementedIngestServiceServer) RecordSpanBatch(IngestService_RecordSpanBatchServer) 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.