pb

Oct 6, 2023

Changes in this version

+ func PbToStringSlice(s []protoiface.MessageV1) []string

Aug 31, 2023

Changes in this version

type ClientGroupedStats

+ SpanKind string

+ func (m *ClientGroupedStats) GetSpanKind() string

Jul 6, 2023

Changes in this version

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_agent_payload_proto protoreflect.FileDescriptor

+ var File_span_proto protoreflect.FileDescriptor

+ var File_tracer_payload_proto protoreflect.FileDescriptor

type AgentPayload

+ func (m *AgentPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *AgentPayload) MarshalToVT(dAtA []byte) (int, error)

+ func (m *AgentPayload) MarshalVT() (dAtA []byte, err error)

+ func (m *AgentPayload) SizeVT() (n int)

+ func (m *AgentPayload) UnmarshalVT(dAtA []byte) error

+ func (x *AgentPayload) ProtoReflect() protoreflect.Message

type Span

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

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

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

+ func (m *Span) SizeVT() (n int)

+ func (m *Span) UnmarshalVT(dAtA []byte) error

+ func (s *Span) ShallowCopy() *Span

+ func (x *Span) ProtoReflect() protoreflect.Message

type TraceChunk

+ func (m *TraceChunk) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TraceChunk) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TraceChunk) MarshalVT() (dAtA []byte, err error)

+ func (m *TraceChunk) SizeVT() (n int)

+ func (m *TraceChunk) UnmarshalVT(dAtA []byte) error

+ func (t *TraceChunk) ShallowCopy() *TraceChunk

+ func (x *TraceChunk) ProtoReflect() protoreflect.Message

type TracerPayload

+ func (m *TracerPayload) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TracerPayload) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TracerPayload) MarshalVT() (dAtA []byte, err error)

+ func (m *TracerPayload) SizeVT() (n int)

+ func (m *TracerPayload) UnmarshalVT(dAtA []byte) error

+ func (x *TracerPayload) ProtoReflect() protoreflect.Message

May 31, 2023

Changes in this version

type ClientGroupedStats

+ PeerService string

+ func (m *ClientGroupedStats) GetPeerService() string

Jan 18, 2023

Changes in this version

type AgentPayload

+ RareSamplerEnabled bool

+ func (m *AgentPayload) GetAgentVersion() string

+ func (m *AgentPayload) GetEnv() string

+ func (m *AgentPayload) GetErrorTPS() float64

+ func (m *AgentPayload) GetHostName() string

+ func (m *AgentPayload) GetRareSamplerEnabled() bool

+ func (m *AgentPayload) GetTargetTPS() float64

+ func (m *AgentPayload) XXX_DiscardUnknown()

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

+ func (m *AgentPayload) XXX_Merge(src proto.Message)

+ func (m *AgentPayload) XXX_Size() int

+ func (m *AgentPayload) XXX_Unmarshal(b []byte) error

type Span

+ func (m *Span) GetDuration() int64

+ func (m *Span) GetError() int32

+ func (m *Span) GetName() string

+ func (m *Span) GetParentID() uint64

+ func (m *Span) GetResource() string

+ func (m *Span) GetService() string

+ func (m *Span) GetSpanID() uint64

+ func (m *Span) GetStart() int64

+ func (m *Span) GetTraceID() uint64

+ func (m *Span) GetType() string

+ func (m *Span) XXX_DiscardUnknown()

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

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

+ func (m *Span) XXX_Size() int

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

type TraceChunk

+ func (m *TraceChunk) GetDroppedTrace() bool

+ func (m *TraceChunk) GetOrigin() string

+ func (m *TraceChunk) GetPriority() int32

+ func (m *TraceChunk) XXX_DiscardUnknown()

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

+ func (m *TraceChunk) XXX_Merge(src proto.Message)

+ func (m *TraceChunk) XXX_Size() int

+ func (m *TraceChunk) XXX_Unmarshal(b []byte) error

type TracerPayload

+ func (m *TracerPayload) GetAppVersion() string

+ func (m *TracerPayload) GetContainerID() string

+ func (m *TracerPayload) GetEnv() string

+ func (m *TracerPayload) GetHostname() string

+ func (m *TracerPayload) GetLanguageName() string

+ func (m *TracerPayload) GetLanguageVersion() string

+ func (m *TracerPayload) GetRuntimeID() string

+ func (m *TracerPayload) GetTracerVersion() string

+ func (m *TracerPayload) XXX_DiscardUnknown()

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

+ func (m *TracerPayload) XXX_Merge(src proto.Message)

+ func (m *TracerPayload) XXX_Size() int

+ func (m *TracerPayload) XXX_Unmarshal(b []byte) error

May 23, 2022

Changes in this version

+ var ErrIntOverflowAgentPayload = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowSpan = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowStats = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTracerPayload = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthAgentPayload = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthSpan = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTracerPayload = fmt.Errorf("proto: negative length found during unmarshaling")

+ func MetaHook() (hook func(k, v string) string, ok bool)

+ func SetMetaHook(hook func(k, v string) string)

+ type AgentPayload struct

+ AgentVersion string

+ Env string

+ ErrorTPS float64

+ HostName string

+ Tags map[string]string

+ TargetTPS float64

+ TracerPayloads []*TracerPayload

+ func (*AgentPayload) Descriptor() ([]byte, []int)

+ func (*AgentPayload) ProtoMessage()

+ func (m *AgentPayload) GetTags() map[string]string

+ func (m *AgentPayload) GetTracerPayloads() []*TracerPayload

+ func (m *AgentPayload) Marshal() (data []byte, err error)

+ func (m *AgentPayload) MarshalTo(data []byte) (int, error)

+ func (m *AgentPayload) Reset()

+ func (m *AgentPayload) Size() (n int)

+ func (m *AgentPayload) String() string

+ func (m *AgentPayload) Unmarshal(data []byte) error

+ type ClientGroupedStats struct

+ DBType string

+ Duration uint64

+ ErrorSummary []byte

+ Errors uint64

+ HTTPStatusCode uint32

+ Hits uint64

+ Name string

+ OkSummary []byte

+ Resource string

+ Service string

+ Synthetics bool

+ TopLevelHits uint64

+ Type string

+ func (*ClientGroupedStats) Descriptor() ([]byte, []int)

+ func (*ClientGroupedStats) ProtoMessage()

+ func (dst *ClientGroupedStats) XXX_Merge(src proto.Message)

+ func (m *ClientGroupedStats) GetDBType() string

+ func (m *ClientGroupedStats) GetDuration() uint64

+ func (m *ClientGroupedStats) GetErrorSummary() []byte

+ func (m *ClientGroupedStats) GetErrors() uint64

+ func (m *ClientGroupedStats) GetHTTPStatusCode() uint32

+ func (m *ClientGroupedStats) GetHits() uint64

+ func (m *ClientGroupedStats) GetName() string

+ func (m *ClientGroupedStats) GetOkSummary() []byte

+ func (m *ClientGroupedStats) GetResource() string

+ func (m *ClientGroupedStats) GetService() string

+ func (m *ClientGroupedStats) GetSynthetics() bool

+ func (m *ClientGroupedStats) GetTopLevelHits() uint64

+ func (m *ClientGroupedStats) GetType() string

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

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

+ func (m *ClientGroupedStats) Reset()

+ func (m *ClientGroupedStats) Size() (n int)

+ func (m *ClientGroupedStats) String() string

+ func (m *ClientGroupedStats) Unmarshal(dAtA []byte) error

+ func (m *ClientGroupedStats) XXX_DiscardUnknown()

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

+ func (m *ClientGroupedStats) XXX_Size() int

+ func (m *ClientGroupedStats) XXX_Unmarshal(b []byte) error

+ func (z *ClientGroupedStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ClientGroupedStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ClientGroupedStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ClientGroupedStats) Msgsize() (s int)

+ func (z *ClientGroupedStats) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type ClientStatsBucket struct

+ AgentTimeShift int64

+ Duration uint64

+ Start uint64

+ Stats []ClientGroupedStats

+ func (*ClientStatsBucket) Descriptor() ([]byte, []int)

+ func (*ClientStatsBucket) ProtoMessage()

+ func (dst *ClientStatsBucket) XXX_Merge(src proto.Message)

+ func (m *ClientStatsBucket) GetAgentTimeShift() int64

+ func (m *ClientStatsBucket) GetDuration() uint64

+ func (m *ClientStatsBucket) GetStart() uint64

+ func (m *ClientStatsBucket) GetStats() []ClientGroupedStats

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

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

+ func (m *ClientStatsBucket) Reset()

+ func (m *ClientStatsBucket) Size() (n int)

+ func (m *ClientStatsBucket) String() string

+ func (m *ClientStatsBucket) Unmarshal(dAtA []byte) error

+ func (m *ClientStatsBucket) XXX_DiscardUnknown()

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

+ func (m *ClientStatsBucket) XXX_Size() int

+ func (m *ClientStatsBucket) XXX_Unmarshal(b []byte) error

+ func (z *ClientStatsBucket) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ClientStatsBucket) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ClientStatsBucket) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ClientStatsBucket) Msgsize() (s int)

+ func (z *ClientStatsBucket) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type ClientStatsPayload struct

+ AgentAggregation string

+ ContainerID string

+ Env string

+ Hostname string

+ Lang string

+ RuntimeID string

+ Sequence uint64

+ Service string

+ Stats []ClientStatsBucket

+ Tags []string

+ TracerVersion string

+ Version string

+ func (*ClientStatsPayload) Descriptor() ([]byte, []int)

+ func (*ClientStatsPayload) ProtoMessage()

+ func (dst *ClientStatsPayload) XXX_Merge(src proto.Message)

+ func (m *ClientStatsPayload) GetAgentAggregation() string

+ func (m *ClientStatsPayload) GetContainerID() string

+ func (m *ClientStatsPayload) GetEnv() string

+ func (m *ClientStatsPayload) GetHostname() string

+ func (m *ClientStatsPayload) GetLang() string

+ func (m *ClientStatsPayload) GetRuntimeID() string

+ func (m *ClientStatsPayload) GetSequence() uint64

+ func (m *ClientStatsPayload) GetService() string

+ func (m *ClientStatsPayload) GetStats() []ClientStatsBucket

+ func (m *ClientStatsPayload) GetTags() []string

+ func (m *ClientStatsPayload) GetTracerVersion() string

+ func (m *ClientStatsPayload) GetVersion() string

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

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

+ func (m *ClientStatsPayload) Reset()

+ func (m *ClientStatsPayload) Size() (n int)

+ func (m *ClientStatsPayload) String() string

+ func (m *ClientStatsPayload) Unmarshal(dAtA []byte) error

+ func (m *ClientStatsPayload) XXX_DiscardUnknown()

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

+ func (m *ClientStatsPayload) XXX_Size() int

+ func (m *ClientStatsPayload) XXX_Unmarshal(b []byte) error

+ func (z *ClientStatsPayload) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ClientStatsPayload) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ClientStatsPayload) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ClientStatsPayload) Msgsize() (s int)

+ func (z *ClientStatsPayload) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Span struct

+ Duration int64

+ Error int32

+ Meta map[string]string

+ MetaStruct map[string][]byte

+ Metrics map[string]float64

+ Name string

+ ParentID uint64

+ Resource string

+ Service string

+ SpanID uint64

+ Start int64

+ TraceID uint64

+ Type string

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

+ func (*Span) ProtoMessage()

+ func (m *Span) GetMeta() map[string]string

+ func (m *Span) GetMetaStruct() map[string][]byte

+ func (m *Span) GetMetrics() map[string]float64

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

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

+ func (m *Span) Reset()

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

+ func (m *Span) String() string

+ func (m *Span) Unmarshal(data []byte) error

+ func (z *Span) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Span) Msgsize() (s int)

+ func (z *Span) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Span) UnmarshalMsgDictionary(bts []byte, dict []string) ([]byte, error)

+ type StatsPayload struct

+ AgentEnv string

+ AgentHostname string

+ AgentVersion string

+ ClientComputed bool

+ Stats []ClientStatsPayload

+ func (*StatsPayload) Descriptor() ([]byte, []int)

+ func (*StatsPayload) ProtoMessage()

+ func (dst *StatsPayload) XXX_Merge(src proto.Message)

+ func (m *StatsPayload) GetAgentEnv() string

+ func (m *StatsPayload) GetAgentHostname() string

+ func (m *StatsPayload) GetAgentVersion() string

+ func (m *StatsPayload) GetClientComputed() bool

+ func (m *StatsPayload) GetStats() []ClientStatsPayload

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

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

+ func (m *StatsPayload) Reset()

+ func (m *StatsPayload) Size() (n int)

+ func (m *StatsPayload) String() string

+ func (m *StatsPayload) Unmarshal(dAtA []byte) error

+ func (m *StatsPayload) XXX_DiscardUnknown()

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

+ func (m *StatsPayload) XXX_Size() int

+ func (m *StatsPayload) XXX_Unmarshal(b []byte) error

+ func (z *StatsPayload) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *StatsPayload) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *StatsPayload) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *StatsPayload) Msgsize() (s int)

+ func (z *StatsPayload) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Trace []*Span

+ func (z *Trace) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Trace) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Trace) Msgsize() (s int)

+ type TraceChunk struct

+ DroppedTrace bool

+ Origin string

+ Priority int32

+ Spans []*Span

+ Tags map[string]string

+ func (*TraceChunk) Descriptor() ([]byte, []int)

+ func (*TraceChunk) ProtoMessage()

+ func (m *TraceChunk) GetSpans() []*Span

+ func (m *TraceChunk) GetTags() map[string]string

+ func (m *TraceChunk) Marshal() (data []byte, err error)

+ func (m *TraceChunk) MarshalTo(data []byte) (int, error)

+ func (m *TraceChunk) Reset()

+ func (m *TraceChunk) Size() (n int)

+ func (m *TraceChunk) String() string

+ func (m *TraceChunk) Unmarshal(data []byte) error

+ func (z *TraceChunk) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TraceChunk) Msgsize() (s int)

+ func (z *TraceChunk) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type TracerPayload struct

+ AppVersion string

+ Chunks []*TraceChunk

+ ContainerID string

+ Env string

+ Hostname string

+ LanguageName string

+ LanguageVersion string

+ RuntimeID string

+ Tags map[string]string

+ TracerVersion string

+ func (*TracerPayload) Descriptor() ([]byte, []int)

+ func (*TracerPayload) ProtoMessage()

+ func (m *TracerPayload) GetChunks() []*TraceChunk

+ func (m *TracerPayload) GetTags() map[string]string

+ func (m *TracerPayload) Marshal() (data []byte, err error)

+ func (m *TracerPayload) MarshalTo(data []byte) (int, error)

+ func (m *TracerPayload) Reset()

+ func (m *TracerPayload) Size() (n int)

+ func (m *TracerPayload) String() string

+ func (m *TracerPayload) Unmarshal(data []byte) error

+ func (p *TracerPayload) Cut(i int) *TracerPayload

+ func (p *TracerPayload) RemoveChunk(i int)

+ func (z *TracerPayload) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TracerPayload) Msgsize() (s int)

+ func (z *TracerPayload) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Traces []Trace

+ func (t *Traces) UnmarshalMsgDictionary(bts []byte) error

+ func (z *Traces) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Traces) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Traces) Msgsize() (s int)