Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowTracepb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTracepb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTracepb = fmt.Errorf("proto: unexpected end of group") + func RegisterTraceRecordPubSubServer(s *grpc.Server, srv TraceRecordPubSubServer) + type NotifyCollect struct + TraceId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NotifyCollect) Descriptor() ([]byte, []int) + func (*NotifyCollect) ProtoMessage() + func (m *NotifyCollect) GetTraceId() uint64 + func (m *NotifyCollect) Marshal() (dAtA []byte, err error) + func (m *NotifyCollect) MarshalTo(dAtA []byte) (int, error) + func (m *NotifyCollect) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NotifyCollect) Reset() + func (m *NotifyCollect) Size() (n int) + func (m *NotifyCollect) String() string + func (m *NotifyCollect) Unmarshal(dAtA []byte) error + func (m *NotifyCollect) XXX_DiscardUnknown() + func (m *NotifyCollect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NotifyCollect) XXX_Merge(src proto.Message) + func (m *NotifyCollect) XXX_Size() int + func (m *NotifyCollect) XXX_Unmarshal(b []byte) error + type Property struct + Key string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Property) Descriptor() ([]byte, []int) + func (*Property) ProtoMessage() + func (m *Property) GetKey() string + func (m *Property) GetValue() string + func (m *Property) Marshal() (dAtA []byte, err error) + func (m *Property) MarshalTo(dAtA []byte) (int, error) + func (m *Property) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Property) Reset() + func (m *Property) Size() (n int) + func (m *Property) String() string + func (m *Property) Unmarshal(dAtA []byte) error + func (m *Property) XXX_DiscardUnknown() + func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Property) XXX_Merge(src proto.Message) + func (m *Property) XXX_Size() int + func (m *Property) XXX_Unmarshal(b []byte) error + type RemoteParentSpan struct + SpanId uint64 + TraceId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoteParentSpan) Descriptor() ([]byte, []int) + func (*RemoteParentSpan) ProtoMessage() + func (m *RemoteParentSpan) GetSpanId() uint64 + func (m *RemoteParentSpan) GetTraceId() uint64 + func (m *RemoteParentSpan) Marshal() (dAtA []byte, err error) + func (m *RemoteParentSpan) MarshalTo(dAtA []byte) (int, error) + func (m *RemoteParentSpan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RemoteParentSpan) Reset() + func (m *RemoteParentSpan) Size() (n int) + func (m *RemoteParentSpan) String() string + func (m *RemoteParentSpan) Unmarshal(dAtA []byte) error + func (m *RemoteParentSpan) XXX_DiscardUnknown() + func (m *RemoteParentSpan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoteParentSpan) XXX_Merge(src proto.Message) + func (m *RemoteParentSpan) XXX_Size() int + func (m *RemoteParentSpan) XXX_Unmarshal(b []byte) error + type Report struct + RemoteParentSpans []*RemoteParentSpan + Spans []*Span + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Report) Descriptor() ([]byte, []int) + func (*Report) ProtoMessage() + func (m *Report) GetRemoteParentSpans() []*RemoteParentSpan + func (m *Report) GetSpans() []*Span + func (m *Report) Marshal() (dAtA []byte, err error) + func (m *Report) MarshalTo(dAtA []byte) (int, error) + func (m *Report) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Report) Reset() + func (m *Report) Size() (n int) + func (m *Report) String() string + func (m *Report) Unmarshal(dAtA []byte) error + func (m *Report) XXX_DiscardUnknown() + func (m *Report) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Report) XXX_Merge(src proto.Message) + func (m *Report) XXX_Size() int + func (m *Report) XXX_Unmarshal(b []byte) error + type Span struct + BeginUnixNs uint64 + DurationNs uint64 + Event string + ParentId uint64 + Properties []*Property + SpanId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Span) Descriptor() ([]byte, []int) + func (*Span) ProtoMessage() + func (m *Span) GetBeginUnixNs() uint64 + func (m *Span) GetDurationNs() uint64 + func (m *Span) GetEvent() string + func (m *Span) GetParentId() uint64 + func (m *Span) GetProperties() []*Property + func (m *Span) GetSpanId() uint64 + func (m *Span) Marshal() (dAtA []byte, err error) + func (m *Span) MarshalTo(dAtA []byte) (int, error) + func (m *Span) MarshalToSizedBuffer(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 (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 TraceContext struct + DurationThresholdMs uint32 + RemoteParentSpans []*RemoteParentSpan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TraceContext) Descriptor() ([]byte, []int) + func (*TraceContext) ProtoMessage() + func (m *TraceContext) GetDurationThresholdMs() uint32 + func (m *TraceContext) GetRemoteParentSpans() []*RemoteParentSpan + func (m *TraceContext) Marshal() (dAtA []byte, err error) + func (m *TraceContext) MarshalTo(dAtA []byte) (int, error) + func (m *TraceContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TraceContext) Reset() + func (m *TraceContext) Size() (n int) + func (m *TraceContext) String() string + func (m *TraceContext) Unmarshal(dAtA []byte) error + func (m *TraceContext) XXX_DiscardUnknown() + func (m *TraceContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TraceContext) XXX_Merge(src proto.Message) + func (m *TraceContext) XXX_Size() int + func (m *TraceContext) XXX_Unmarshal(b []byte) error + type TraceRecord struct + RecordOneof isTraceRecord_RecordOneof + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TraceRecord) Descriptor() ([]byte, []int) + func (*TraceRecord) ProtoMessage() + func (*TraceRecord) XXX_OneofWrappers() []interface{} + func (m *TraceRecord) GetNotifyCollect() *NotifyCollect + func (m *TraceRecord) GetRecordOneof() isTraceRecord_RecordOneof + func (m *TraceRecord) GetReport() *Report + func (m *TraceRecord) Marshal() (dAtA []byte, err error) + func (m *TraceRecord) MarshalTo(dAtA []byte) (int, error) + func (m *TraceRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TraceRecord) Reset() + func (m *TraceRecord) Size() (n int) + func (m *TraceRecord) String() string + func (m *TraceRecord) Unmarshal(dAtA []byte) error + func (m *TraceRecord) XXX_DiscardUnknown() + func (m *TraceRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TraceRecord) XXX_Merge(src proto.Message) + func (m *TraceRecord) XXX_Size() int + func (m *TraceRecord) XXX_Unmarshal(b []byte) error + type TraceRecordPubSubClient interface + Subscribe func(ctx context.Context, in *TraceRecordRequest, opts ...grpc.CallOption) (TraceRecordPubSub_SubscribeClient, error) + func NewTraceRecordPubSubClient(cc *grpc.ClientConn) TraceRecordPubSubClient + type TraceRecordPubSubServer interface + Subscribe func(*TraceRecordRequest, TraceRecordPubSub_SubscribeServer) error + type TraceRecordPubSub_SubscribeClient interface + Recv func() (*TraceRecord, error) + type TraceRecordPubSub_SubscribeServer interface + Send func(*TraceRecord) error + type TraceRecordRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TraceRecordRequest) Descriptor() ([]byte, []int) + func (*TraceRecordRequest) ProtoMessage() + func (m *TraceRecordRequest) Marshal() (dAtA []byte, err error) + func (m *TraceRecordRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TraceRecordRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TraceRecordRequest) Reset() + func (m *TraceRecordRequest) Size() (n int) + func (m *TraceRecordRequest) String() string + func (m *TraceRecordRequest) Unmarshal(dAtA []byte) error + func (m *TraceRecordRequest) XXX_DiscardUnknown() + func (m *TraceRecordRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TraceRecordRequest) XXX_Merge(src proto.Message) + func (m *TraceRecordRequest) XXX_Size() int + func (m *TraceRecordRequest) XXX_Unmarshal(b []byte) error + type TraceRecord_NotifyCollect struct + NotifyCollect *NotifyCollect + func (m *TraceRecord_NotifyCollect) MarshalTo(dAtA []byte) (int, error) + func (m *TraceRecord_NotifyCollect) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TraceRecord_NotifyCollect) Size() (n int) + type TraceRecord_Report struct + Report *Report + func (m *TraceRecord_Report) MarshalTo(dAtA []byte) (int, error) + func (m *TraceRecord_Report) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TraceRecord_Report) Size() (n int) + type UnimplementedTraceRecordPubSubServer struct + func (*UnimplementedTraceRecordPubSubServer) Subscribe(req *TraceRecordRequest, srv TraceRecordPubSub_SubscribeServer) error
Go to main page