import "github.com/newrelic/go-agent/v3/internal/com_newrelic_trace_v1"
func RegisterIngestServiceServer(s *grpc.Server, srv IngestServiceServer)
type AttributeValue struct {
// Types that are valid to be assigned to Value:
// *AttributeValue_StringValue
// *AttributeValue_BoolValue
// *AttributeValue_IntValue
// *AttributeValue_DoubleValue
Value isAttributeValue_Value `protobuf_oneof:"value"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}func (*AttributeValue) Descriptor() ([]byte, []int)
func (m *AttributeValue) GetBoolValue() bool
func (m *AttributeValue) GetDoubleValue() float64
func (m *AttributeValue) GetIntValue() int64
func (m *AttributeValue) GetStringValue() string
func (m *AttributeValue) GetValue() isAttributeValue_Value
func (*AttributeValue) ProtoMessage()
func (m *AttributeValue) Reset()
func (m *AttributeValue) String() string
func (m *AttributeValue) XXX_DiscardUnknown()
func (m *AttributeValue) XXX_Merge(src proto.Message)
func (*AttributeValue) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (m *AttributeValue) XXX_Size() int
func (m *AttributeValue) XXX_Unmarshal(b []byte) error
type AttributeValue_BoolValue struct {
BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof"`
}type AttributeValue_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}type AttributeValue_IntValue struct {
IntValue int64 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}type AttributeValue_StringValue struct {
StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}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(cc grpc.ClientConnInterface) IngestServiceClient
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 interface {
Send(*SpanBatch) error
Recv() (*RecordStatus, error)
grpc.ClientStream
}type IngestService_RecordSpanBatchServer interface {
Send(*RecordStatus) error
Recv() (*SpanBatch, error)
grpc.ServerStream
}type IngestService_RecordSpanClient interface {
Send(*Span) error
Recv() (*RecordStatus, error)
grpc.ClientStream
}type IngestService_RecordSpanServer interface {
Send(*RecordStatus) error
Recv() (*Span, error)
grpc.ServerStream
}type RecordStatus struct {
MessagesSeen uint64 `protobuf:"varint,1,opt,name=messages_seen,json=messagesSeen,proto3" json:"messages_seen,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}func (*RecordStatus) Descriptor() ([]byte, []int)
func (m *RecordStatus) GetMessagesSeen() uint64
func (*RecordStatus) ProtoMessage()
func (m *RecordStatus) Reset()
func (m *RecordStatus) String() string
func (m *RecordStatus) XXX_DiscardUnknown()
func (m *RecordStatus) XXX_Merge(src proto.Message)
func (m *RecordStatus) XXX_Size() int
func (m *RecordStatus) XXX_Unmarshal(b []byte) error
type Span struct {
TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
Intrinsics map[string]*AttributeValue `protobuf:"bytes,2,rep,name=intrinsics,proto3" json:"intrinsics,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
UserAttributes map[string]*AttributeValue `protobuf:"bytes,3,rep,name=user_attributes,json=userAttributes,proto3" json:"user_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
AgentAttributes map[string]*AttributeValue `protobuf:"bytes,4,rep,name=agent_attributes,json=agentAttributes,proto3" json:"agent_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}func (m *Span) GetAgentAttributes() map[string]*AttributeValue
func (m *Span) GetIntrinsics() map[string]*AttributeValue
func (m *Span) GetUserAttributes() map[string]*AttributeValue
type SpanBatch struct {
Spans []*Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}type UnimplementedIngestServiceServer struct {
}UnimplementedIngestServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedIngestServiceServer) RecordSpan(srv IngestService_RecordSpanServer) error
func (*UnimplementedIngestServiceServer) RecordSpanBatch(srv IngestService_RecordSpanBatchServer) error
Package com_newrelic_trace_v1 imports 7 packages (graph) and is imported by 2 packages. Updated 2020-09-02. Refresh now. Tools for package owners.