com_oldfritter_trace_v1

package
v3.15.4 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

README

com_oldfritter_trace_v1

To generate the v1.pb.go code, run the following from the top level github.com/oldfritter/go-agent package:

protoc --go_out=paths=source_relative,plugins=grpc:. v3/internal/com_oldfritter_trace_v1/v1.proto

Be mindful which version of protoc-gen-go you are using. Upgrade protoc-gen-go to the latest with:

go get -u github.com/golang/protobuf/protoc-gen-go

When you regenerate the file

Once you have generated the code, you will need to add a build tag to the file:

// +build go1.9

This is because the gRPC/Protocol Buffer libraries only support Go 1.9 and above.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterIngestServiceServer 

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

Types

type AttributeValue 

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 

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

func (*AttributeValue) GetBoolValue 

func (m *AttributeValue) GetBoolValue() bool

func (*AttributeValue) GetDoubleValue 

func (m *AttributeValue) GetDoubleValue() float64

func (*AttributeValue) GetIntValue 

func (m *AttributeValue) GetIntValue() int64

func (*AttributeValue) GetStringValue 

func (m *AttributeValue) GetStringValue() string

func (*AttributeValue) GetValue 

func (m *AttributeValue) GetValue() isAttributeValue_Value

func (*AttributeValue) ProtoMessage 

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) Reset 

func (m *AttributeValue) Reset()

func (*AttributeValue) String 

func (m *AttributeValue) String() string

func (*AttributeValue) XXX_DiscardUnknown 

func (m *AttributeValue) XXX_DiscardUnknown()

func (*AttributeValue) XXX_Marshal 

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

func (*AttributeValue) XXX_Merge 

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

func (*AttributeValue) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*AttributeValue) XXX_Size 

func (m *AttributeValue) XXX_Size() int

func (*AttributeValue) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecordStatus) Descriptor 

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

func (*RecordStatus) GetMessagesSeen 

func (m *RecordStatus) GetMessagesSeen() uint64

func (*RecordStatus) ProtoMessage 

func (*RecordStatus) ProtoMessage()

func (*RecordStatus) Reset 

func (m *RecordStatus) Reset()

func (*RecordStatus) String 

func (m *RecordStatus) String() string

func (*RecordStatus) XXX_DiscardUnknown 

func (m *RecordStatus) XXX_DiscardUnknown()

func (*RecordStatus) XXX_Marshal 

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

func (*RecordStatus) XXX_Merge 

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

func (*RecordStatus) XXX_Size 

func (m *RecordStatus) XXX_Size() int

func (*RecordStatus) XXX_Unmarshal 

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

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 */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*Span) Descriptor 

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

func (*Span) GetAgentAttributes 

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

func (*Span) GetIntrinsics 

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

func (*Span) GetTraceId 

func (m *Span) GetTraceId() string

func (*Span) GetUserAttributes 

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

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) Reset 

func (m *Span) Reset()

func (*Span) String 

func (m *Span) String() string

func (*Span) XXX_DiscardUnknown 

func (m *Span) XXX_DiscardUnknown()

func (*Span) XXX_Marshal 

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

func (*Span) XXX_Merge 

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

func (*Span) XXX_Size 

func (m *Span) XXX_Size() int

func (*Span) XXX_Unmarshal 

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

type SpanBatch 

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 

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

func (*SpanBatch) GetSpans 

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

func (*SpanBatch) ProtoMessage 

func (*SpanBatch) ProtoMessage()

func (*SpanBatch) Reset 

func (m *SpanBatch) Reset()

func (*SpanBatch) String 

func (m *SpanBatch) String() string

func (*SpanBatch) XXX_DiscardUnknown 

func (m *SpanBatch) XXX_DiscardUnknown()

func (*SpanBatch) XXX_Marshal 

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

func (*SpanBatch) XXX_Merge 

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

func (*SpanBatch) XXX_Size 

func (m *SpanBatch) XXX_Size() int

func (*SpanBatch) XXX_Unmarshal 

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

type UnimplementedIngestServiceServer 

type UnimplementedIngestServiceServer struct {
}

UnimplementedIngestServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestServiceServer) RecordSpan 

func (*UnimplementedIngestServiceServer) RecordSpan(srv IngestService_RecordSpanServer) error

func (*UnimplementedIngestServiceServer) RecordSpanBatch 

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