go-agent: github.com/newrelic/go-agent/v3/internal/com_newrelic_trace_v1 Index | Files

package com_newrelic_trace_v1

import "github.com/newrelic/go-agent/v3/internal/com_newrelic_trace_v1"

Index

Package Files

v1.pb.go

func RegisterIngestServiceServer Uses

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

type AttributeValue Uses

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 Uses

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

func (*AttributeValue) GetBoolValue Uses

func (m *AttributeValue) GetBoolValue() bool

func (*AttributeValue) GetDoubleValue Uses

func (m *AttributeValue) GetDoubleValue() float64

func (*AttributeValue) GetIntValue Uses

func (m *AttributeValue) GetIntValue() int64

func (*AttributeValue) GetStringValue Uses

func (m *AttributeValue) GetStringValue() string

func (*AttributeValue) GetValue Uses

func (m *AttributeValue) GetValue() isAttributeValue_Value

func (*AttributeValue) ProtoMessage Uses

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) Reset Uses

func (m *AttributeValue) Reset()

func (*AttributeValue) String Uses

func (m *AttributeValue) String() string

func (*AttributeValue) XXX_DiscardUnknown Uses

func (m *AttributeValue) XXX_DiscardUnknown()

func (*AttributeValue) XXX_Marshal Uses

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

func (*AttributeValue) XXX_Merge Uses

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

func (*AttributeValue) XXX_OneofWrappers Uses

func (*AttributeValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AttributeValue) XXX_Size Uses

func (m *AttributeValue) XXX_Size() int

func (*AttributeValue) XXX_Unmarshal Uses

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

type AttributeValue_BoolValue Uses

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

type AttributeValue_DoubleValue Uses

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

type AttributeValue_IntValue Uses

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

type AttributeValue_StringValue Uses

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

type IngestServiceClient Uses

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 Uses

func NewIngestServiceClient(cc grpc.ClientConnInterface) IngestServiceClient

type IngestServiceServer Uses

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 Uses

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

type IngestService_RecordSpanBatchServer Uses

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

type IngestService_RecordSpanClient Uses

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

type IngestService_RecordSpanServer Uses

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

type RecordStatus Uses

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 Uses

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

func (*RecordStatus) GetMessagesSeen Uses

func (m *RecordStatus) GetMessagesSeen() uint64

func (*RecordStatus) ProtoMessage Uses

func (*RecordStatus) ProtoMessage()

func (*RecordStatus) Reset Uses

func (m *RecordStatus) Reset()

func (*RecordStatus) String Uses

func (m *RecordStatus) String() string

func (*RecordStatus) XXX_DiscardUnknown Uses

func (m *RecordStatus) XXX_DiscardUnknown()

func (*RecordStatus) XXX_Marshal Uses

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

func (*RecordStatus) XXX_Merge Uses

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

func (*RecordStatus) XXX_Size Uses

func (m *RecordStatus) XXX_Size() int

func (*RecordStatus) XXX_Unmarshal Uses

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

type Span Uses

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 (*Span) Descriptor Uses

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

func (*Span) GetAgentAttributes Uses

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

func (*Span) GetIntrinsics Uses

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

func (*Span) GetTraceId Uses

func (m *Span) GetTraceId() string

func (*Span) GetUserAttributes Uses

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

func (*Span) ProtoMessage Uses

func (*Span) ProtoMessage()

func (*Span) Reset Uses

func (m *Span) Reset()

func (*Span) String Uses

func (m *Span) String() string

func (*Span) XXX_DiscardUnknown Uses

func (m *Span) XXX_DiscardUnknown()

func (*Span) XXX_Marshal Uses

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

func (*Span) XXX_Merge Uses

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

func (*Span) XXX_Size Uses

func (m *Span) XXX_Size() int

func (*Span) XXX_Unmarshal Uses

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

type SpanBatch Uses

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:"-"`
}

func (*SpanBatch) Descriptor Uses

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

func (*SpanBatch) GetSpans Uses

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

func (*SpanBatch) ProtoMessage Uses

func (*SpanBatch) ProtoMessage()

func (*SpanBatch) Reset Uses

func (m *SpanBatch) Reset()

func (*SpanBatch) String Uses

func (m *SpanBatch) String() string

func (*SpanBatch) XXX_DiscardUnknown Uses

func (m *SpanBatch) XXX_DiscardUnknown()

func (*SpanBatch) XXX_Marshal Uses

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

func (*SpanBatch) XXX_Merge Uses

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

func (*SpanBatch) XXX_Size Uses

func (m *SpanBatch) XXX_Size() int

func (*SpanBatch) XXX_Unmarshal Uses

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

type UnimplementedIngestServiceServer Uses

type UnimplementedIngestServiceServer struct {
}

UnimplementedIngestServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestServiceServer) RecordSpan Uses

func (*UnimplementedIngestServiceServer) RecordSpan(srv IngestService_RecordSpanServer) error

func (*UnimplementedIngestServiceServer) RecordSpanBatch Uses

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.