metastore

package

Go to main page

Versions in this module

v0

v0.21.0

Feb 27, 2024

v0.20.0

Oct 20, 2023

v0.19.0

Sep 21, 2023

Changes in this version

type KeyMaker

+ func (m *KeyMaker) MakeProfileLocationID(l *profile.Location) string

v0.18.0

Jun 14, 2023

Changes in this version

+ type KeyMaker struct

+ func NewKeyMaker() *KeyMaker

+ func (m *KeyMaker) MakeFunctionID(f *pb.Function) string

+ func (m *KeyMaker) MakeFunctionKey(f *pb.Function) string

+ func (m *KeyMaker) MakeLocationID(l *pb.Location) string

+ func (m *KeyMaker) MakeLocationKey(l *pb.Location) string

+ func (m *KeyMaker) MakeMappingID(mp *pb.Mapping) string

+ func (m *KeyMaker) MakeMappingKey(mp *pb.Mapping) string

+ func (m *KeyMaker) MakeStacktraceID(s *pb.Stacktrace) string

+ func (m *KeyMaker) MakeStacktraceKey(s *pb.Stacktrace) string

v0.17.0

Mar 29, 2023

v0.16.2

Mar 7, 2023

v0.16.1

Mar 2, 2023

v0.16.0

Mar 1, 2023

v0.15.0

Dec 20, 2022

v0.14.0

Nov 10, 2022

v0.13.0

Oct 20, 2022

Changes in this version

type BadgerLogger

+ Logger log.Logger

v0.12.1

Jul 29, 2022

v0.12.0

Jul 15, 2022

Changes in this version

+ const UnsymbolizedLocationLinesKeyPrefix

+ func FunctionIDFromKey(key string) string

+ func LocationIDFromKey(key string) string

+ func LocationIDFromUnsymbolizedKey(key string) string

+ func MakeFunctionID(f *pb.Function) string

+ func MakeFunctionKeyWithID(functionID string) string

+ func MakeLocationID(l *pb.Location) string

+ func MakeLocationKeyWithID(locationID string) string

+ func MakeLocationLinesKeyWithID(locationID string) string

+ func MakeMappingID(m *pb.Mapping) string

+ func MakeMappingKeyWithID(mappingID string) string

+ func MakeStacktraceID(s *pb.Stacktrace) string

+ func MakeStacktraceKey(s *pb.Stacktrace) string

+ func MakeStacktraceKeyWithID(stacktraceID string) string

+ func MakeUnsymbolizedLocationKeyWithID(locationID string) string

+ func MappingIDFromKey(key string) string

+ func StacktraceIDFromKey(key string) string

type BadgerMetastore

+ func (m *BadgerMetastore) Functions(ctx context.Context, r *pb.FunctionsRequest) (*pb.FunctionsResponse, error)

+ func (m *BadgerMetastore) GetOrCreateFunctions(ctx context.Context, r *pb.GetOrCreateFunctionsRequest) (*pb.GetOrCreateFunctionsResponse, error)

+ func (m *BadgerMetastore) GetOrCreateLocations(ctx context.Context, r *pb.GetOrCreateLocationsRequest) (*pb.GetOrCreateLocationsResponse, error)

+ func (m *BadgerMetastore) GetOrCreateMappings(ctx context.Context, r *pb.GetOrCreateMappingsRequest) (*pb.GetOrCreateMappingsResponse, error)

+ func (m *BadgerMetastore) GetOrCreateStacktraces(ctx context.Context, r *pb.GetOrCreateStacktracesRequest) (*pb.GetOrCreateStacktracesResponse, error)

+ func (m *BadgerMetastore) LocationLines(ctx context.Context, r *pb.LocationLinesRequest) (*pb.LocationLinesResponse, error)

+ func (m *BadgerMetastore) Locations(ctx context.Context, r *pb.LocationsRequest) (*pb.LocationsResponse, error)

+ func (m *BadgerMetastore) Mappings(ctx context.Context, r *pb.MappingsRequest) (*pb.MappingsResponse, error)

+ func (m *BadgerMetastore) Stacktraces(ctx context.Context, r *pb.StacktracesRequest) (*pb.StacktracesResponse, error)

+ func (m *BadgerMetastore) UnsymbolizedLocations(ctx context.Context, r *pb.UnsymbolizedLocationsRequest) (*pb.UnsymbolizedLocationsResponse, error)

+ type InProcessClient struct

+ func NewInProcessClient(m pb.MetastoreServiceServer) *InProcessClient

+ func (c *InProcessClient) CreateLocationLines(ctx context.Context, in *pb.CreateLocationLinesRequest, ...) (*pb.CreateLocationLinesResponse, error)

+ func (c *InProcessClient) Functions(ctx context.Context, in *pb.FunctionsRequest, opts ...grpc.CallOption) (*pb.FunctionsResponse, error)

+ func (c *InProcessClient) GetOrCreateFunctions(ctx context.Context, in *pb.GetOrCreateFunctionsRequest, ...) (*pb.GetOrCreateFunctionsResponse, error)

+ func (c *InProcessClient) GetOrCreateLocations(ctx context.Context, in *pb.GetOrCreateLocationsRequest, ...) (*pb.GetOrCreateLocationsResponse, error)

+ func (c *InProcessClient) GetOrCreateMappings(ctx context.Context, in *pb.GetOrCreateMappingsRequest, ...) (*pb.GetOrCreateMappingsResponse, error)

+ func (c *InProcessClient) GetOrCreateStacktraces(ctx context.Context, in *pb.GetOrCreateStacktracesRequest, ...) (*pb.GetOrCreateStacktracesResponse, error)

+ func (c *InProcessClient) LocationLines(ctx context.Context, in *pb.LocationLinesRequest, opts ...grpc.CallOption) (*pb.LocationLinesResponse, error)

+ func (c *InProcessClient) Locations(ctx context.Context, in *pb.LocationsRequest, opts ...grpc.CallOption) (*pb.LocationsResponse, error)

+ func (c *InProcessClient) Mappings(ctx context.Context, in *pb.MappingsRequest, opts ...grpc.CallOption) (*pb.MappingsResponse, error)

+ func (c *InProcessClient) Stacktraces(ctx context.Context, in *pb.StacktracesRequest, opts ...grpc.CallOption) (*pb.StacktracesResponse, error)

+ func (c *InProcessClient) UnsymbolizedLocations(ctx context.Context, in *pb.UnsymbolizedLocationsRequest, ...) (*pb.UnsymbolizedLocationsResponse, error)

v0.12.0-rc.0

Jul 14, 2022

v0.11.1

May 17, 2022

v0.11.0

May 4, 2022

v0.10.0

Mar 31, 2022

v0.9.0

Mar 25, 2022

Changes in this version

type LocationKey

+ Address uint64

type RemoteMetaStore

+ func NewRemoteMetaStore(reg prometheus.Registerer, db *sql.DB) (*RemoteMetaStore, error)

v0.8.1

Feb 28, 2022

v0.8.0

Feb 22, 2022

v0.7.1

Jan 10, 2022

v0.7.0

Jan 6, 2022

Changes in this version

+ var ErrFunctionNotFound = errors.New("function not found")

+ var ErrLocationNotFound = errors.New("location not found")

+ var ErrMappingNotFound = errors.New("mapping not found")

+ var ErrStacktraceNotFound = errors.New("stacktrace not found")

+ func GetLocationsByIDs(ctx context.Context, s ProfileMetaStore, ids ...[]byte) (map[string]*Location, error)

+ func MakeFunctionKey(f *pb.Function) []byte

+ func MakeLocationKey(l *Location) []byte

+ func MakeMappingKey(m *pb.Mapping) []byte

+ func UnsymbolizableMapping(m *pb.Mapping) bool

+ type BadgerLogger struct

+ func (l *BadgerLogger) Debugf(f string, v ...interface{})

+ func (l *BadgerLogger) Errorf(f string, v ...interface{})

+ func (l *BadgerLogger) Infof(f string, v ...interface{})

+ func (l *BadgerLogger) Warningf(f string, v ...interface{})

+ type BadgerMetastore struct

+ func NewBadgerMetastore(logger log.Logger, reg prometheus.Registerer, tracer trace.Tracer, ...) *BadgerMetastore

+ func (m *BadgerMetastore) Close() error

+ func (m *BadgerMetastore) CreateFunction(ctx context.Context, f *pb.Function) ([]byte, error)

+ func (m *BadgerMetastore) CreateLocation(ctx context.Context, l *Location) ([]byte, error)

+ func (m *BadgerMetastore) CreateLocationLines(ctx context.Context, locID []byte, lines []LocationLine) error

+ func (m *BadgerMetastore) CreateMapping(ctx context.Context, mapping *pb.Mapping) ([]byte, error)

+ func (m *BadgerMetastore) CreateStacktrace(ctx context.Context, key []byte, sample *pb.Sample) (uuid.UUID, error)

+ func (m *BadgerMetastore) GetFunctionByKey(ctx context.Context, key *pb.Function) (*pb.Function, error)

+ func (m *BadgerMetastore) GetFunctions(ctx context.Context) ([]*pb.Function, error)

+ func (m *BadgerMetastore) GetFunctionsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Function, error)

+ func (m *BadgerMetastore) GetLinesByLocationIDs(ctx context.Context, ids ...[]byte) (map[string][]*pb.Line, [][]byte, error)

+ func (m *BadgerMetastore) GetLocationByKey(ctx context.Context, key *Location) (*pb.Location, error)

+ func (m *BadgerMetastore) GetLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (m *BadgerMetastore) GetLocationsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Location, [][]byte, error)

+ func (m *BadgerMetastore) GetMappingByKey(ctx context.Context, key *pb.Mapping) (*pb.Mapping, error)

+ func (m *BadgerMetastore) GetMappingsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Mapping, error)

+ func (m *BadgerMetastore) GetStacktraceByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Sample, error)

+ func (m *BadgerMetastore) GetStacktraceByKey(ctx context.Context, key []byte) (uuid.UUID, error)

+ func (m *BadgerMetastore) GetSymbolizableLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (m *BadgerMetastore) Ping() error

+ func (m *BadgerMetastore) Symbolize(ctx context.Context, l *Location) error

+ type FunctionKey struct

+ Filename string

+ Name string

+ StartLine int64

+ SystemName string

+ func MakeSQLFunctionKey(f *pb.Function) FunctionKey

+ type FunctionStore interface

+ CreateFunction func(ctx context.Context, f *pb.Function) ([]byte, error)

+ GetFunctionByKey func(ctx context.Context, key *pb.Function) (*pb.Function, error)

+ GetFunctions func(ctx context.Context) ([]*pb.Function, error)

+ GetFunctionsByIDs func(ctx context.Context, ids ...[]byte) (map[string]*pb.Function, error)

+ type InMemorySQLiteMetaStore struct

+ func NewInMemorySQLiteProfileMetaStore(reg prometheus.Registerer, tracer trace.Tracer, name ...string) (*InMemorySQLiteMetaStore, error)

+ func (i InMemorySQLiteMetaStore) CreateStacktrace(ctx context.Context, key []byte, sample *pb.Sample) (uuid.UUID, error)

+ func (i InMemorySQLiteMetaStore) GetStacktraceByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Sample, error)

+ func (i InMemorySQLiteMetaStore) GetStacktraceByKey(ctx context.Context, key []byte) (uuid.UUID, error)

+ func (s InMemorySQLiteMetaStore) Close() error

+ func (s InMemorySQLiteMetaStore) CreateFunction(ctx context.Context, fn *pb.Function) ([]byte, error)

+ func (s InMemorySQLiteMetaStore) CreateLocation(ctx context.Context, l *Location) ([]byte, error)

+ func (s InMemorySQLiteMetaStore) CreateLocationLines(ctx context.Context, locID []byte, lines []LocationLine) error

+ func (s InMemorySQLiteMetaStore) CreateMapping(ctx context.Context, m *pb.Mapping) ([]byte, error)

+ func (s InMemorySQLiteMetaStore) GetFunctionByKey(ctx context.Context, fkey *pb.Function) (*pb.Function, error)

+ func (s InMemorySQLiteMetaStore) GetFunctions(ctx context.Context) ([]*pb.Function, error)

+ func (s InMemorySQLiteMetaStore) GetFunctionsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Function, error)

+ func (s InMemorySQLiteMetaStore) GetLinesByLocationIDs(ctx context.Context, ids ...[]byte) (map[string][]*pb.Line, [][]byte, error)

+ func (s InMemorySQLiteMetaStore) GetLocationByKey(ctx context.Context, lkey *Location) (*pb.Location, error)

+ func (s InMemorySQLiteMetaStore) GetLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (s InMemorySQLiteMetaStore) GetLocationsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Location, [][]byte, error)

+ func (s InMemorySQLiteMetaStore) GetMappingByKey(ctx context.Context, mkey *pb.Mapping) (*pb.Mapping, error)

+ func (s InMemorySQLiteMetaStore) GetMappingsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Mapping, error)

+ func (s InMemorySQLiteMetaStore) GetSymbolizableLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (s InMemorySQLiteMetaStore) Ping() error

+ func (s InMemorySQLiteMetaStore) Symbolize(ctx context.Context, l *Location) error

+ type LinearUUIDGenerator struct

+ func (g *LinearUUIDGenerator) New() uuid.UUID

+ type Location struct

+ Address uint64

+ ID uuid.UUID

+ IsFolded bool

+ Lines []LocationLine

+ Mapping *pb.Mapping

+ func GetLocationByKey(ctx context.Context, s ProfileMetaStore, key *Location) (*Location, error)

+ func GetLocations(ctx context.Context, s ProfileMetaStore) ([]*Location, error)

+ func GetSymbolizableLocations(ctx context.Context, s ProfileMetaStore) ([]*Location, error)

+ type LocationKey struct

+ IsFolded bool

+ Lines string

+ MappingID uuid.UUID

+ NormalizedAddress uint64

+ func MakeSQLLocationKey(l *Location) LocationKey

+ type LocationLine struct

+ Function *pb.Function

+ Line int64

+ type LocationLineStore interface

+ CreateLocationLines func(ctx context.Context, locID []byte, lines []LocationLine) error

+ GetLinesByLocationIDs func(ctx context.Context, id ...[]byte) (map[string][]*pb.Line, [][]byte, error)

+ type LocationStore interface

+ CreateLocation func(ctx context.Context, l *Location) ([]byte, error)

+ GetLocationByKey func(ctx context.Context, key *Location) (*pb.Location, error)

+ GetLocations func(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ GetLocationsByIDs func(ctx context.Context, id ...[]byte) (map[string]*pb.Location, [][]byte, error)

+ GetSymbolizableLocations func(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ Symbolize func(ctx context.Context, location *Location) error

+ type MappingKey struct

+ BuildIDOrFile string

+ Offset uint64

+ Size uint64

+ func MakeSQLMappingKey(m *pb.Mapping) MappingKey

+ type MappingStore interface

+ CreateMapping func(ctx context.Context, m *pb.Mapping) ([]byte, error)

+ GetMappingByKey func(ctx context.Context, key *pb.Mapping) (*pb.Mapping, error)

+ GetMappingsByIDs func(ctx context.Context, ids ...[]byte) (map[string]*pb.Mapping, error)

+ type OnDiskSQLiteMetaStore struct

+ func NewDiskProfileMetaStore(reg prometheus.Registerer, tracer trace.Tracer, path ...string) (*OnDiskSQLiteMetaStore, error)

+ func (o OnDiskSQLiteMetaStore) CreateStacktrace(ctx context.Context, key []byte, sample *pb.Sample) (uuid.UUID, error)

+ func (o OnDiskSQLiteMetaStore) GetStacktraceByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Sample, error)

+ func (o OnDiskSQLiteMetaStore) GetStacktraceByKey(ctx context.Context, key []byte) (uuid.UUID, error)

+ func (s OnDiskSQLiteMetaStore) Close() error

+ func (s OnDiskSQLiteMetaStore) CreateFunction(ctx context.Context, fn *pb.Function) ([]byte, error)

+ func (s OnDiskSQLiteMetaStore) CreateLocation(ctx context.Context, l *Location) ([]byte, error)

+ func (s OnDiskSQLiteMetaStore) CreateLocationLines(ctx context.Context, locID []byte, lines []LocationLine) error

+ func (s OnDiskSQLiteMetaStore) CreateMapping(ctx context.Context, m *pb.Mapping) ([]byte, error)

+ func (s OnDiskSQLiteMetaStore) GetFunctionByKey(ctx context.Context, fkey *pb.Function) (*pb.Function, error)

+ func (s OnDiskSQLiteMetaStore) GetFunctions(ctx context.Context) ([]*pb.Function, error)

+ func (s OnDiskSQLiteMetaStore) GetFunctionsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Function, error)

+ func (s OnDiskSQLiteMetaStore) GetLinesByLocationIDs(ctx context.Context, ids ...[]byte) (map[string][]*pb.Line, [][]byte, error)

+ func (s OnDiskSQLiteMetaStore) GetLocationByKey(ctx context.Context, lkey *Location) (*pb.Location, error)

+ func (s OnDiskSQLiteMetaStore) GetLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (s OnDiskSQLiteMetaStore) GetLocationsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Location, [][]byte, error)

+ func (s OnDiskSQLiteMetaStore) GetMappingByKey(ctx context.Context, mkey *pb.Mapping) (*pb.Mapping, error)

+ func (s OnDiskSQLiteMetaStore) GetMappingsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Mapping, error)

+ func (s OnDiskSQLiteMetaStore) GetSymbolizableLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (s OnDiskSQLiteMetaStore) Ping() error

+ func (s OnDiskSQLiteMetaStore) Symbolize(ctx context.Context, l *Location) error

+ type ProfileMetaStore interface

+ Close func() error

+ Ping func() error

+ type RandomUUIDGenerator struct

+ func (g *RandomUUIDGenerator) New() uuid.UUID

+ type RemoteMetaStore struct

+ func NewRemoteProfileMetaStore(addr string) (*RemoteMetaStore, error)

+ func (r RemoteMetaStore) CreateStacktrace(ctx context.Context, key []byte, sample *pb.Sample) (uuid.UUID, error)

+ func (r RemoteMetaStore) GetStacktraceByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Sample, error)

+ func (r RemoteMetaStore) GetStacktraceByKey(ctx context.Context, key []byte) (uuid.UUID, error)

+ func (s RemoteMetaStore) Close() error

+ func (s RemoteMetaStore) CreateFunction(ctx context.Context, fn *pb.Function) ([]byte, error)

+ func (s RemoteMetaStore) CreateLocation(ctx context.Context, l *Location) ([]byte, error)

+ func (s RemoteMetaStore) CreateLocationLines(ctx context.Context, locID []byte, lines []LocationLine) error

+ func (s RemoteMetaStore) CreateMapping(ctx context.Context, m *pb.Mapping) ([]byte, error)

+ func (s RemoteMetaStore) GetFunctionByKey(ctx context.Context, fkey *pb.Function) (*pb.Function, error)

+ func (s RemoteMetaStore) GetFunctions(ctx context.Context) ([]*pb.Function, error)

+ func (s RemoteMetaStore) GetFunctionsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Function, error)

+ func (s RemoteMetaStore) GetLinesByLocationIDs(ctx context.Context, ids ...[]byte) (map[string][]*pb.Line, [][]byte, error)

+ func (s RemoteMetaStore) GetLocationByKey(ctx context.Context, lkey *Location) (*pb.Location, error)

+ func (s RemoteMetaStore) GetLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (s RemoteMetaStore) GetLocationsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Location, [][]byte, error)

+ func (s RemoteMetaStore) GetMappingByKey(ctx context.Context, mkey *pb.Mapping) (*pb.Mapping, error)

+ func (s RemoteMetaStore) GetMappingsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Mapping, error)

+ func (s RemoteMetaStore) GetSymbolizableLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)

+ func (s RemoteMetaStore) Ping() error

+ func (s RemoteMetaStore) Symbolize(ctx context.Context, l *Location) error

+ type StacktraceStore interface

+ CreateStacktrace func(ctx context.Context, key []byte, sample *pb.Sample) (uuid.UUID, error)

+ GetStacktraceByIDs func(ctx context.Context, ids ...[]byte) (map[string]*pb.Sample, error)

+ GetStacktraceByKey func(ctx context.Context, key []byte) (uuid.UUID, error)

+ type UUIDGenerator interface

+ New func() uuid.UUID

+ func NewLinearUUIDGenerator() UUIDGenerator

+ func NewRandomUUIDGenerator() UUIDGenerator

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL