collectorpb

package
Version: v0.15.1 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2017 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package collectorpb is a generated protocol buffer package.

It is generated from these files:

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 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" json:"access_token,omitempty"`
}

func (*Auth) Descriptor

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

func (*Auth) GetAccessToken

func (m *Auth) GetAccessToken() string

func (*Auth) ProtoMessage

func (*Auth) ProtoMessage()

func (*Auth) Reset

func (m *Auth) Reset()

func (*Auth) String

func (m *Auth) String() string

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" json:"disable,omitempty"`
}

func (*Command) Descriptor

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

func (*Command) GetDisable

func (m *Command) GetDisable() bool

func (*Command) ProtoMessage

func (*Command) ProtoMessage()

func (*Command) Reset

func (m *Command) Reset()

func (*Command) String

func (m *Command) String() string

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" 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) ProtoMessage

func (*InternalMetrics) ProtoMessage()

func (*InternalMetrics) Reset

func (m *InternalMetrics) Reset()

func (*InternalMetrics) String

func (m *InternalMetrics) String() string

type KeyValue

type KeyValue struct {
	Key string `protobuf:"bytes,1,opt,name=key" 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) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset

func (m *KeyValue) Reset()

func (*KeyValue) String

func (m *KeyValue) String() string

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,oneof"`
}

type KeyValue_DoubleValue

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

type KeyValue_IntValue

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

type KeyValue_JsonValue

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

type KeyValue_StringValue

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

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 added in v0.15.0

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

func (*Log) GetTimestamp

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

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) Reset

func (m *Log) Reset()

func (*Log) String

func (m *Log) String() string

type MetricsSample

type MetricsSample struct {
	Name string `protobuf:"bytes,1,opt,name=name" 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) ProtoMessage

func (*MetricsSample) ProtoMessage()

func (*MetricsSample) Reset

func (m *MetricsSample) Reset()

func (*MetricsSample) String

func (m *MetricsSample) String() string

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,oneof"`
}

type MetricsSample_IntValue

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

type Reference

type Reference struct {
	Relationship Reference_Relationship `protobuf:"varint,1,opt,name=relationship,enum=lightstep.collector.Reference_Relationship" json:"relationship,omitempty"`
	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) ProtoMessage

func (*Reference) ProtoMessage()

func (*Reference) Reset

func (m *Reference) Reset()

func (*Reference) String

func (m *Reference) String() string

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 int32            `protobuf:"varint,5,opt,name=timestamp_offset_micros,json=timestampOffsetMicros" json:"timestamp_offset_micros,omitempty"`
	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() int32

func (*ReportRequest) ProtoMessage

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) Reset

func (m *ReportRequest) Reset()

func (*ReportRequest) String

func (m *ReportRequest) String() string

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) Disable added in v0.13.0

func (res *ReportResponse) Disable() bool

func (*ReportResponse) GetCommands

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

func (*ReportResponse) GetErrors

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

func (*ReportResponse) GetInfos added in v0.15.0

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 added in v0.15.0

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

func (*ReportResponse) ProtoMessage

func (*ReportResponse) ProtoMessage()

func (*ReportResponse) Reset

func (m *ReportResponse) Reset()

func (*ReportResponse) String

func (m *ReportResponse) String() string

type Reporter

type Reporter struct {
	ReporterId uint64      `protobuf:"varint,1,opt,name=reporter_id,json=reporterId" 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) ProtoMessage

func (*Reporter) ProtoMessage()

func (*Reporter) Reset

func (m *Reporter) Reset()

func (*Reporter) String

func (m *Reporter) String() string

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" 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" 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) ProtoMessage

func (*Span) ProtoMessage()

func (*Span) Reset

func (m *Span) Reset()

func (*Span) String

func (m *Span) String() string

type SpanContext

type SpanContext struct {
	TraceId uint64            `protobuf:"varint,1,opt,name=trace_id,json=traceId" json:"trace_id,omitempty"`
	SpanId  uint64            `protobuf:"varint,2,opt,name=span_id,json=spanId" json:"span_id,omitempty"`
	Baggage map[string]string `` /* 134-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) ProtoMessage

func (*SpanContext) ProtoMessage()

func (*SpanContext) Reset

func (m *SpanContext) Reset()

func (*SpanContext) String

func (m *SpanContext) String() string

Directories

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL