collectorpb

package
v0.0.0-...-a8dfcb8 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2021 License: MIT Imports: 9 Imported by: 2

Documentation

Overview

Package collectorpb is a generated protocol buffer package.

It is generated from these files: 

github.com/lightstep/lightstep-tracer-common/tmpgen/collector.proto

It has these top-level messages: 

SpanContext
KeyValue
Log
Reference
Span
Reporter
MetricsSample
InternalMetrics
Auth
ReportRequest
Command
ReportResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCollector = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCollector   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Reference_Relationship_name = map[int32]string{
	0: "CHILD_OF",
	1: "FOLLOWS_FROM",
}
View Source 
var Reference_Relationship_value = map[string]int32{
	"CHILD_OF":     0,
	"FOLLOWS_FROM": 1,
}

Functions

func RegisterCollectorServiceServer 

func RegisterCollectorServiceServer(s *grpc.Server, srv CollectorServiceServer)

Types

type Auth 

type Auth struct {
	AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
}

func (*Auth) Descriptor 

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

func (*Auth) GetAccessToken 

func (m *Auth) GetAccessToken() string

func (*Auth) Marshal 

func (m *Auth) Marshal() (dAtA []byte, err error)

func (*Auth) MarshalTo 

func (m *Auth) MarshalTo(dAtA []byte) (int, error)

func (*Auth) ProtoMessage 

func (*Auth) ProtoMessage()

func (*Auth) Reset 

func (m *Auth) Reset()

func (*Auth) Size 

func (m *Auth) Size() (n int)

func (*Auth) String 

func (m *Auth) String() string

func (*Auth) Unmarshal 

func (m *Auth) Unmarshal(dAtA []byte) error

type CollectorServiceClient 

type CollectorServiceClient interface {
	Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error)
}

func NewCollectorServiceClient 

func NewCollectorServiceClient(cc *grpc.ClientConn) CollectorServiceClient

type CollectorServiceServer 

type CollectorServiceServer interface {
	Report(context.Context, *ReportRequest) (*ReportResponse, error)
}

type Command 

type Command struct {
	Disable bool `protobuf:"varint,1,opt,name=disable,proto3" json:"disable,omitempty"`
	DevMode bool `protobuf:"varint,2,opt,name=dev_mode,json=devMode,proto3" json:"dev_mode,omitempty"`
}

func (*Command) Descriptor 

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

func (*Command) GetDevMode 

func (m *Command) GetDevMode() bool

func (*Command) GetDisable 

func (m *Command) GetDisable() bool

func (*Command) Marshal 

func (m *Command) Marshal() (dAtA []byte, err error)

func (*Command) MarshalTo 

func (m *Command) MarshalTo(dAtA []byte) (int, error)

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

func (m *Command) Size() (n int)

func (*Command) String 

func (m *Command) String() string

func (*Command) Unmarshal 

func (m *Command) Unmarshal(dAtA []byte) error

type InternalMetrics 

type InternalMetrics struct {
	StartTimestamp *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=start_timestamp,json=startTimestamp" json:"start_timestamp,omitempty"`
	DurationMicros uint64                     `protobuf:"varint,2,opt,name=duration_micros,json=durationMicros,proto3" json:"duration_micros,omitempty"`
	Logs           []*Log                     `protobuf:"bytes,3,rep,name=logs" json:"logs,omitempty"`
	Counts         []*MetricsSample           `protobuf:"bytes,4,rep,name=counts" json:"counts,omitempty"`
	Gauges         []*MetricsSample           `protobuf:"bytes,5,rep,name=gauges" json:"gauges,omitempty"`
}

func (*InternalMetrics) Descriptor 

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

func (*InternalMetrics) GetCounts 

func (m *InternalMetrics) GetCounts() []*MetricsSample

func (*InternalMetrics) GetDurationMicros 

func (m *InternalMetrics) GetDurationMicros() uint64

func (*InternalMetrics) GetGauges 

func (m *InternalMetrics) GetGauges() []*MetricsSample

func (*InternalMetrics) GetLogs 

func (m *InternalMetrics) GetLogs() []*Log

func (*InternalMetrics) GetStartTimestamp 

func (m *InternalMetrics) GetStartTimestamp() *google_protobuf.Timestamp

func (*InternalMetrics) Marshal 

func (m *InternalMetrics) Marshal() (dAtA []byte, err error)

func (*InternalMetrics) MarshalTo 

func (m *InternalMetrics) MarshalTo(dAtA []byte) (int, error)

func (*InternalMetrics) ProtoMessage 

func (*InternalMetrics) ProtoMessage()

func (*InternalMetrics) Reset 

func (m *InternalMetrics) Reset()

func (*InternalMetrics) Size 

func (m *InternalMetrics) Size() (n int)

func (*InternalMetrics) String 

func (m *InternalMetrics) String() string

func (*InternalMetrics) Unmarshal 

func (m *InternalMetrics) Unmarshal(dAtA []byte) error

type KeyValue 

type KeyValue struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*KeyValue_StringValue
	//	*KeyValue_IntValue
	//	*KeyValue_DoubleValue
	//	*KeyValue_BoolValue
	//	*KeyValue_JsonValue
	Value isKeyValue_Value `protobuf_oneof:"value"`
}

Represent both tags and log fields.

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetBoolValue 

func (m *KeyValue) GetBoolValue() bool

func (*KeyValue) GetDoubleValue 

func (m *KeyValue) GetDoubleValue() float64

func (*KeyValue) GetIntValue 

func (m *KeyValue) GetIntValue() int64

func (*KeyValue) GetJsonValue 

func (m *KeyValue) GetJsonValue() string

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() string

func (*KeyValue) GetStringValue 

func (m *KeyValue) GetStringValue() string

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() isKeyValue_Value

func (*KeyValue) Marshal 

func (m *KeyValue) Marshal() (dAtA []byte, err error)

func (*KeyValue) MarshalTo 

func (m *KeyValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) Size 

func (m *KeyValue) Size() (n int)

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal 

func (m *KeyValue) Unmarshal(dAtA []byte) error

func (*KeyValue) XXX_OneofFuncs 

func (*KeyValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type KeyValue_BoolValue 

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

func (*KeyValue_BoolValue) MarshalTo 

func (m *KeyValue_BoolValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue_BoolValue) Size 

func (m *KeyValue_BoolValue) Size() (n int)

type KeyValue_DoubleValue 

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

func (*KeyValue_DoubleValue) MarshalTo 

func (m *KeyValue_DoubleValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue_DoubleValue) Size 

func (m *KeyValue_DoubleValue) Size() (n int)

type KeyValue_IntValue 

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

func (*KeyValue_IntValue) MarshalTo 

func (m *KeyValue_IntValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue_IntValue) Size 

func (m *KeyValue_IntValue) Size() (n int)

type KeyValue_JsonValue 

type KeyValue_JsonValue struct {
	JsonValue string `protobuf:"bytes,6,opt,name=json_value,json=jsonValue,proto3,oneof"`
}

func (*KeyValue_JsonValue) MarshalTo 

func (m *KeyValue_JsonValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue_JsonValue) Size 

func (m *KeyValue_JsonValue) Size() (n int)

type KeyValue_StringValue 

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

func (*KeyValue_StringValue) MarshalTo 

func (m *KeyValue_StringValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue_StringValue) Size 

func (m *KeyValue_StringValue) Size() (n int)

type Log 

type Log struct {
	Timestamp *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"`
	Fields    []*KeyValue                `protobuf:"bytes,2,rep,name=fields" json:"fields,omitempty"`
}

func (*Log) Descriptor 

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

func (*Log) GetFields 

func (m *Log) GetFields() []*KeyValue

func (*Log) GetTimestamp 

func (m *Log) GetTimestamp() *google_protobuf.Timestamp

func (*Log) Marshal 

func (m *Log) Marshal() (dAtA []byte, err error)

func (*Log) MarshalTo 

func (m *Log) MarshalTo(dAtA []byte) (int, error)

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) Size 

func (m *Log) Size() (n int)

func (*Log) String 

func (m *Log) String() string

func (*Log) Unmarshal 

func (m *Log) Unmarshal(dAtA []byte) error

type MetricsSample 

type MetricsSample struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*MetricsSample_IntValue
	//	*MetricsSample_DoubleValue
	Value isMetricsSample_Value `protobuf_oneof:"value"`
}

func (*MetricsSample) Descriptor 

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

func (*MetricsSample) GetDoubleValue 

func (m *MetricsSample) GetDoubleValue() float64

func (*MetricsSample) GetIntValue 

func (m *MetricsSample) GetIntValue() int64

func (*MetricsSample) GetName 

func (m *MetricsSample) GetName() string

func (*MetricsSample) GetValue 

func (m *MetricsSample) GetValue() isMetricsSample_Value

func (*MetricsSample) Marshal 

func (m *MetricsSample) Marshal() (dAtA []byte, err error)

func (*MetricsSample) MarshalTo 

func (m *MetricsSample) MarshalTo(dAtA []byte) (int, error)

func (*MetricsSample) ProtoMessage 

func (*MetricsSample) ProtoMessage()

func (*MetricsSample) Reset 

func (m *MetricsSample) Reset()

func (*MetricsSample) Size 

func (m *MetricsSample) Size() (n int)

func (*MetricsSample) String 

func (m *MetricsSample) String() string

func (*MetricsSample) Unmarshal 

func (m *MetricsSample) Unmarshal(dAtA []byte) error

func (*MetricsSample) XXX_OneofFuncs 

func (*MetricsSample) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type MetricsSample_DoubleValue 

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

func (*MetricsSample_DoubleValue) MarshalTo 

func (m *MetricsSample_DoubleValue) MarshalTo(dAtA []byte) (int, error)

func (*MetricsSample_DoubleValue) Size 

func (m *MetricsSample_DoubleValue) Size() (n int)

type MetricsSample_IntValue 

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

func (*MetricsSample_IntValue) MarshalTo 

func (m *MetricsSample_IntValue) MarshalTo(dAtA []byte) (int, error)

func (*MetricsSample_IntValue) Size 

func (m *MetricsSample_IntValue) Size() (n int)

type Reference 

type Reference struct {
	Relationship Reference_Relationship `` /* 126-byte string literal not displayed */
	SpanContext  *SpanContext           `protobuf:"bytes,2,opt,name=span_context,json=spanContext" json:"span_context,omitempty"`
}

func (*Reference) Descriptor 

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

func (*Reference) GetRelationship 

func (m *Reference) GetRelationship() Reference_Relationship

func (*Reference) GetSpanContext 

func (m *Reference) GetSpanContext() *SpanContext

func (*Reference) Marshal 

func (m *Reference) Marshal() (dAtA []byte, err error)

func (*Reference) MarshalTo 

func (m *Reference) MarshalTo(dAtA []byte) (int, error)

func (*Reference) ProtoMessage 

func (*Reference) ProtoMessage()

func (*Reference) Reset 

func (m *Reference) Reset()

func (*Reference) Size 

func (m *Reference) Size() (n int)

func (*Reference) String 

func (m *Reference) String() string

func (*Reference) Unmarshal 

func (m *Reference) Unmarshal(dAtA []byte) error

type Reference_Relationship 

type Reference_Relationship int32
const (
	Reference_CHILD_OF     Reference_Relationship = 0
	Reference_FOLLOWS_FROM Reference_Relationship = 1
)

func (Reference_Relationship) EnumDescriptor 

func (Reference_Relationship) EnumDescriptor() ([]byte, []int)

func (Reference_Relationship) String 

func (x Reference_Relationship) String() string

type ReportRequest 

type ReportRequest struct {
	Reporter              *Reporter        `protobuf:"bytes,1,opt,name=reporter" json:"reporter,omitempty"`
	Auth                  *Auth            `protobuf:"bytes,2,opt,name=auth" json:"auth,omitempty"`
	Spans                 []*Span          `protobuf:"bytes,3,rep,name=spans" json:"spans,omitempty"`
	TimestampOffsetMicros int64            `` /* 127-byte string literal not displayed */
	InternalMetrics       *InternalMetrics `protobuf:"bytes,6,opt,name=internal_metrics,json=internalMetrics" json:"internal_metrics,omitempty"`
}

func (*ReportRequest) Descriptor 

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

func (*ReportRequest) GetAuth 

func (m *ReportRequest) GetAuth() *Auth

func (*ReportRequest) GetInternalMetrics 

func (m *ReportRequest) GetInternalMetrics() *InternalMetrics

func (*ReportRequest) GetReporter 

func (m *ReportRequest) GetReporter() *Reporter

func (*ReportRequest) GetSpans 

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

func (*ReportRequest) GetTimestampOffsetMicros 

func (m *ReportRequest) GetTimestampOffsetMicros() int64

func (*ReportRequest) Marshal 

func (m *ReportRequest) Marshal() (dAtA []byte, err error)

func (*ReportRequest) MarshalTo 

func (m *ReportRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReportRequest) ProtoMessage 

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) Reset 

func (m *ReportRequest) Reset()

func (*ReportRequest) Size 

func (m *ReportRequest) Size() (n int)

func (*ReportRequest) String 

func (m *ReportRequest) String() string

func (*ReportRequest) Unmarshal 

func (m *ReportRequest) Unmarshal(dAtA []byte) error

type ReportResponse 

type ReportResponse struct {
	Commands          []*Command                 `protobuf:"bytes,1,rep,name=commands" json:"commands,omitempty"`
	ReceiveTimestamp  *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=receive_timestamp,json=receiveTimestamp" json:"receive_timestamp,omitempty"`
	TransmitTimestamp *google_protobuf.Timestamp `protobuf:"bytes,3,opt,name=transmit_timestamp,json=transmitTimestamp" json:"transmit_timestamp,omitempty"`
	Errors            []string                   `protobuf:"bytes,4,rep,name=errors" json:"errors,omitempty"`
	Warnings          []string                   `protobuf:"bytes,5,rep,name=warnings" json:"warnings,omitempty"`
	Infos             []string                   `protobuf:"bytes,6,rep,name=infos" json:"infos,omitempty"`
}

func (*ReportResponse) Descriptor 

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

func (*ReportResponse) GetCommands 

func (m *ReportResponse) GetCommands() []*Command

func (*ReportResponse) GetErrors 

func (m *ReportResponse) GetErrors() []string

func (*ReportResponse) GetInfos 

func (m *ReportResponse) GetInfos() []string

func (*ReportResponse) GetReceiveTimestamp 

func (m *ReportResponse) GetReceiveTimestamp() *google_protobuf.Timestamp

func (*ReportResponse) GetTransmitTimestamp 

func (m *ReportResponse) GetTransmitTimestamp() *google_protobuf.Timestamp

func (*ReportResponse) GetWarnings 

func (m *ReportResponse) GetWarnings() []string

func (*ReportResponse) Marshal 

func (m *ReportResponse) Marshal() (dAtA []byte, err error)

func (*ReportResponse) MarshalTo 

func (m *ReportResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReportResponse) ProtoMessage 

func (*ReportResponse) ProtoMessage()

func (*ReportResponse) Reset 

func (m *ReportResponse) Reset()

func (*ReportResponse) Size 

func (m *ReportResponse) Size() (n int)

func (*ReportResponse) String 

func (m *ReportResponse) String() string

func (*ReportResponse) Unmarshal 

func (m *ReportResponse) Unmarshal(dAtA []byte) error

type Reporter 

type Reporter struct {
	ReporterId uint64      `protobuf:"varint,1,opt,name=reporter_id,json=reporterId,proto3" json:"reporter_id,omitempty"`
	Tags       []*KeyValue `protobuf:"bytes,4,rep,name=tags" json:"tags,omitempty"`
}

func (*Reporter) Descriptor 

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

func (*Reporter) GetReporterId 

func (m *Reporter) GetReporterId() uint64

func (*Reporter) GetTags 

func (m *Reporter) GetTags() []*KeyValue

func (*Reporter) Marshal 

func (m *Reporter) Marshal() (dAtA []byte, err error)

func (*Reporter) MarshalTo 

func (m *Reporter) MarshalTo(dAtA []byte) (int, error)

func (*Reporter) ProtoMessage 

func (*Reporter) ProtoMessage()

func (*Reporter) Reset 

func (m *Reporter) Reset()

func (*Reporter) Size 

func (m *Reporter) Size() (n int)

func (*Reporter) String 

func (m *Reporter) String() string

func (*Reporter) Unmarshal 

func (m *Reporter) Unmarshal(dAtA []byte) error

type Span 

type Span struct {
	SpanContext    *SpanContext               `protobuf:"bytes,1,opt,name=span_context,json=spanContext" json:"span_context,omitempty"`
	OperationName  string                     `protobuf:"bytes,2,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	References     []*Reference               `protobuf:"bytes,3,rep,name=references" json:"references,omitempty"`
	StartTimestamp *google_protobuf.Timestamp `protobuf:"bytes,4,opt,name=start_timestamp,json=startTimestamp" json:"start_timestamp,omitempty"`
	DurationMicros uint64                     `protobuf:"varint,5,opt,name=duration_micros,json=durationMicros,proto3" json:"duration_micros,omitempty"`
	Tags           []*KeyValue                `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
	Logs           []*Log                     `protobuf:"bytes,7,rep,name=logs" json:"logs,omitempty"`
}

func (*Span) Descriptor 

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

func (*Span) GetDurationMicros 

func (m *Span) GetDurationMicros() uint64

func (*Span) GetLogs 

func (m *Span) GetLogs() []*Log

func (*Span) GetOperationName 

func (m *Span) GetOperationName() string

func (*Span) GetReferences 

func (m *Span) GetReferences() []*Reference

func (*Span) GetSpanContext 

func (m *Span) GetSpanContext() *SpanContext

func (*Span) GetStartTimestamp 

func (m *Span) GetStartTimestamp() *google_protobuf.Timestamp

func (*Span) GetTags 

func (m *Span) GetTags() []*KeyValue

func (*Span) Marshal 

func (m *Span) Marshal() (dAtA []byte, err error)

func (*Span) MarshalTo 

func (m *Span) MarshalTo(dAtA []byte) (int, error)

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) Reset 

func (m *Span) Reset()

func (*Span) Size 

func (m *Span) Size() (n int)

func (*Span) String 

func (m *Span) String() string

func (*Span) Unmarshal 

func (m *Span) Unmarshal(dAtA []byte) error

type SpanContext 

type SpanContext struct {
	TraceId uint64            `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId  uint64            `protobuf:"varint,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	Baggage map[string]string `` /* 148-byte string literal not displayed */
}

func (*SpanContext) Descriptor 

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

func (*SpanContext) GetBaggage 

func (m *SpanContext) GetBaggage() map[string]string

func (*SpanContext) GetSpanId 

func (m *SpanContext) GetSpanId() uint64

func (*SpanContext) GetTraceId 

func (m *SpanContext) GetTraceId() uint64

func (*SpanContext) Marshal 

func (m *SpanContext) Marshal() (dAtA []byte, err error)

func (*SpanContext) MarshalTo 

func (m *SpanContext) MarshalTo(dAtA []byte) (int, error)

func (*SpanContext) ProtoMessage 

func (*SpanContext) ProtoMessage()

func (*SpanContext) Reset 

func (m *SpanContext) Reset()

func (*SpanContext) Size 

func (m *SpanContext) Size() (n int)

func (*SpanContext) String 

func (m *SpanContext) String() string

func (*SpanContext) Unmarshal 

func (m *SpanContext) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

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.