collectorpb - ActiveState ActiveGo 1.8
...

Package collectorpb

import "github.com/lightstep/lightstep-tracer-go/collectorpb"
Overview
Index

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 ▾

Variables
func RegisterCollectorServiceServer(s *grpc.Server, srv CollectorServiceServer)
type Auth
    func (*Auth) Descriptor() ([]byte, []int)
    func (m *Auth) GetAccessToken() string
    func (*Auth) ProtoMessage()
    func (m *Auth) Reset()
    func (m *Auth) String() string
type CollectorServiceClient
    func NewCollectorServiceClient(cc *grpc.ClientConn) CollectorServiceClient
type CollectorServiceServer
type Command
    func (*Command) Descriptor() ([]byte, []int)
    func (m *Command) GetDisable() bool
    func (*Command) ProtoMessage()
    func (m *Command) Reset()
    func (m *Command) String() string
type InternalMetrics
    func (*InternalMetrics) Descriptor() ([]byte, []int)
    func (m *InternalMetrics) GetCounts() []*MetricsSample
    func (m *InternalMetrics) GetDurationMicros() uint64
    func (m *InternalMetrics) GetGauges() []*MetricsSample
    func (m *InternalMetrics) GetLogs() []*Log
    func (m *InternalMetrics) GetStartTimestamp() *google_protobuf.Timestamp
    func (*InternalMetrics) ProtoMessage()
    func (m *InternalMetrics) Reset()
    func (m *InternalMetrics) String() string
type KeyValue
    func (*KeyValue) Descriptor() ([]byte, []int)
    func (m *KeyValue) GetBoolValue() bool
    func (m *KeyValue) GetDoubleValue() float64
    func (m *KeyValue) GetIntValue() int64
    func (m *KeyValue) GetJsonValue() string
    func (m *KeyValue) GetKey() string
    func (m *KeyValue) GetStringValue() string
    func (m *KeyValue) GetValue() isKeyValue_Value
    func (*KeyValue) ProtoMessage()
    func (m *KeyValue) Reset()
    func (m *KeyValue) String() string
    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{})
type KeyValue_BoolValue
type KeyValue_DoubleValue
type KeyValue_IntValue
type KeyValue_JsonValue
type KeyValue_StringValue
type Log
    func (*Log) Descriptor() ([]byte, []int)
    func (m *Log) GetKeyvalues() []*KeyValue
    func (m *Log) GetTimestamp() *google_protobuf.Timestamp
    func (*Log) ProtoMessage()
    func (m *Log) Reset()
    func (m *Log) String() string
type MetricsSample
    func (*MetricsSample) Descriptor() ([]byte, []int)
    func (m *MetricsSample) GetDoubleValue() float64
    func (m *MetricsSample) GetIntValue() int64
    func (m *MetricsSample) GetName() string
    func (m *MetricsSample) GetValue() isMetricsSample_Value
    func (*MetricsSample) ProtoMessage()
    func (m *MetricsSample) Reset()
    func (m *MetricsSample) String() string
    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{})
type MetricsSample_DoubleValue
type MetricsSample_IntValue
type Reference
    func (*Reference) Descriptor() ([]byte, []int)
    func (m *Reference) GetRelationship() Reference_Relationship
    func (m *Reference) GetSpanContext() *SpanContext
    func (*Reference) ProtoMessage()
    func (m *Reference) Reset()
    func (m *Reference) String() string
type Reference_Relationship
    func (Reference_Relationship) EnumDescriptor() ([]byte, []int)
    func (x Reference_Relationship) String() string
type ReportRequest
    func (*ReportRequest) Descriptor() ([]byte, []int)
    func (m *ReportRequest) GetAuth() *Auth
    func (m *ReportRequest) GetInternalMetrics() *InternalMetrics
    func (m *ReportRequest) GetReporter() *Reporter
    func (m *ReportRequest) GetSpans() []*Span
    func (m *ReportRequest) GetTimestampOffsetMicros() int32
    func (*ReportRequest) ProtoMessage()
    func (m *ReportRequest) Reset()
    func (m *ReportRequest) String() string
type ReportResponse
    func (*ReportResponse) Descriptor() ([]byte, []int)
    func (m *ReportResponse) GetCommands() []*Command
    func (m *ReportResponse) GetErrors() []string
    func (m *ReportResponse) GetReceiveTimestamp() *google_protobuf.Timestamp
    func (m *ReportResponse) GetTransmitTimestamp() *google_protobuf.Timestamp
    func (*ReportResponse) ProtoMessage()
    func (m *ReportResponse) Reset()
    func (m *ReportResponse) String() string
type Reporter
    func (*Reporter) Descriptor() ([]byte, []int)
    func (m *Reporter) GetReporterId() uint64
    func (m *Reporter) GetTags() []*KeyValue
    func (*Reporter) ProtoMessage()
    func (m *Reporter) Reset()
    func (m *Reporter) String() string
type Span
    func (*Span) Descriptor() ([]byte, []int)
    func (m *Span) GetDurationMicros() uint64
    func (m *Span) GetLogs() []*Log
    func (m *Span) GetOperationName() string
    func (m *Span) GetReferences() []*Reference
    func (m *Span) GetSpanContext() *SpanContext
    func (m *Span) GetStartTimestamp() *google_protobuf.Timestamp
    func (m *Span) GetTags() []*KeyValue
    func (*Span) ProtoMessage()
    func (m *Span) Reset()
    func (m *Span) String() string
type SpanContext
    func (*SpanContext) Descriptor() ([]byte, []int)
    func (m *SpanContext) GetBaggage() map[string]string
    func (m *SpanContext) GetSpanId() uint64
    func (m *SpanContext) GetTraceId() uint64
    func (*SpanContext) ProtoMessage()
    func (m *SpanContext) Reset()
    func (m *SpanContext) String() string

Package files

collector.pb.go

Variables

var Reference_Relationship_name = map[int32]string{
    0: "CHILD_OF",
    1: "FOLLOWS_FROM",
}
var Reference_Relationship_value = map[string]int32{
    "CHILD_OF":     0,
    "FOLLOWS_FROM": 1,
}

func RegisterCollectorServiceServer

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

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

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"`
    Keyvalues []*KeyValue                `protobuf:"bytes,2,rep,name=keyvalues" json:"keyvalues,omitempty"`
}

func (*Log) Descriptor

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

func (*Log) GetKeyvalues

func (m *Log) GetKeyvalues() []*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"`
}

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) GetReceiveTimestamp

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

func (*ReportResponse) GetTransmitTimestamp

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

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 `protobuf:"bytes,3,rep,name=baggage" json:"baggage,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}

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