dbmodel

Documentation

Index

• Constants
• Variables
• func HashBucketData(bucket uint8, lst ...string) uint64
• func HashData(lst ...string) uint64
• func HashTagIndex(service, key, value string, bucket uint8) uint64
• func ToDomain(dbSpan *Span) (*model.Span, error)
• type IndexResult
• type Span
  • func FromDomain(span *model.Span) (*Span, error)
  • func (s *Span) StructValue() types.Value
• type SpanData
  • func (*SpanData) Descriptor() ([]byte, []int)
  • func (m *SpanData) GetLogs() []model.Log
  • func (m *SpanData) GetProcess() *model.Process
  • func (m *SpanData) GetReferences() []model.SpanRef
  • func (m *SpanData) GetTags() []model.KeyValue
  • func (m *SpanData) Marshal() (dAtA []byte, err error)
  • func (m *SpanData) MarshalTo(dAtA []byte) (int, error)
  • func (*SpanData) ProtoMessage()
  • func (m *SpanData) Reset()
  • func (m *SpanData) Size() (n int)
  • func (m *SpanData) String() string
  • func (m *SpanData) Unmarshal(dAtA []byte) error
  • func (m *SpanData) XXX_DiscardUnknown()
  • func (m *SpanData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SpanData) XXX_Merge(src proto.Message)
  • func (m *SpanData) XXX_Size() int
  • func (m *SpanData) XXX_Unmarshal(b []byte) error
• type TraceID
  • func TraceIDFromDomain(src model.TraceID) TraceID
  • func (dbTraceID *TraceID) Scan(src interface{}) error
  • func (dbTraceID TraceID) ToDomain() model.TraceID
• type TraceIDList
  • func TraceIDListFromBytes(buf []byte) (TraceIDList, error)
  • func (t *TraceIDList) Scan(src interface{}) error
• type UniqueTraceIDs
  • func IntersectTraceIDs(uniqueTraceIdsList []*UniqueTraceIDs) *UniqueTraceIDs
  • func NewUniqueTraceIDs() *UniqueTraceIDs
  • func (m *UniqueTraceIDs) Add(id TraceID)
  • func (m *UniqueTraceIDs) AsList() []TraceID
  • func (m *UniqueTraceIDs) Has(id TraceID) bool
  • func (m *UniqueTraceIDs) JoinWith(b *UniqueTraceIDs)
  • func (m *UniqueTraceIDs) Len() int

Constants

const (
	NumIndexBuckets = 10
)

Variables

var (
	ErrInvalidLengthSpandata = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSpandata   = fmt.Errorf("proto: integer overflow")
)

Functions

func HashBucketData

func HashBucketData(bucket uint8, lst ...string) uint64

func HashData

func HashData(lst ...string) uint64

func HashTagIndex

func HashTagIndex(service, key, value string, bucket uint8) uint64

func ToDomain

func ToDomain(dbSpan *Span) (*model.Span, error)

ToDomain converts db model to plugin model

Types

type IndexResult

type IndexResult struct {
	Ids   TraceIDList
	RevTs int64
}

type Span

type Span struct {
	TraceIDLow    uint64
	TraceIDHigh   uint64
	SpanID        uint64
	OperationName string
	Flags         uint32
	StartTime     int64
	Duration      int64
	Extra         []byte
}

Span represents db-serializable model

func FromDomain

func FromDomain(span *model.Span) (*Span, error)

FromDomain converts plugin model to db model or returns error

func (*Span) StructValue

func (s *Span) StructValue() types.Value

type SpanData

type SpanData struct {
	Process              *model.Process   `protobuf:"bytes,1,opt,name=Process,proto3" json:"Process,omitempty"`
	Tags                 []model.KeyValue `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags"`
	Logs                 []model.Log      `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs"`
	References           []model.SpanRef  `protobuf:"bytes,4,rep,name=references,proto3" json:"references"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SpanData) Descriptor

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

func (*SpanData) GetLogs

func (m *SpanData) GetLogs() []model.Log

func (*SpanData) GetProcess

func (m *SpanData) GetProcess() *model.Process

func (*SpanData) GetReferences

func (m *SpanData) GetReferences() []model.SpanRef

func (*SpanData) GetTags

func (m *SpanData) GetTags() []model.KeyValue

func (*SpanData) Marshal

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

func (*SpanData) MarshalTo

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

func (*SpanData) ProtoMessage

func (*SpanData) ProtoMessage()

func (*SpanData) Reset

func (m *SpanData) Reset()

func (*SpanData) Size

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

func (*SpanData) String

func (m *SpanData) String() string

func (*SpanData) Unmarshal

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

func (*SpanData) XXX_DiscardUnknown

func (m *SpanData) XXX_DiscardUnknown()

func (*SpanData) XXX_Marshal

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

func (*SpanData) XXX_Merge

func (m *SpanData) XXX_Merge(src proto.Message)

func (*SpanData) XXX_Size

func (m *SpanData) XXX_Size() int

func (*SpanData) XXX_Unmarshal

func (m *SpanData) XXX_Unmarshal(b []byte) error

type TraceID

type TraceID [16]byte

TraceID represents db-serializable trace id

func TraceIDFromDomain

func TraceIDFromDomain(src model.TraceID) TraceID

func (*TraceID) Scan

func (dbTraceID *TraceID) Scan(src interface{}) error

Scan converts db result bytes slice to TraceID type

func (TraceID) ToDomain

func (dbTraceID TraceID) ToDomain() model.TraceID

ToDomain converts trace ID from db-serializable form to domain TradeID

type TraceIDList

type TraceIDList []TraceID

func TraceIDListFromBytes

func TraceIDListFromBytes(buf []byte) (TraceIDList, error)

func (*TraceIDList) Scan

func (t *TraceIDList) Scan(src interface{}) error

type UniqueTraceIDs

type UniqueTraceIDs struct {
	// contains filtered or unexported fields
}

func IntersectTraceIDs

func IntersectTraceIDs(uniqueTraceIdsList []*UniqueTraceIDs) *UniqueTraceIDs

IntersectTraceIDs takes a list of UniqueTraceIDs and intersects them.

func NewUniqueTraceIDs

func NewUniqueTraceIDs() *UniqueTraceIDs

func (*UniqueTraceIDs) Add

func (m *UniqueTraceIDs) Add(id TraceID)

func (*UniqueTraceIDs) AsList

func (m *UniqueTraceIDs) AsList() []TraceID

func (*UniqueTraceIDs) Has

func (m *UniqueTraceIDs) Has(id TraceID) bool

func (*UniqueTraceIDs) JoinWith

func (m *UniqueTraceIDs) JoinWith(b *UniqueTraceIDs)

func (*UniqueTraceIDs) Len

func (m *UniqueTraceIDs) Len() int