metastore

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2021 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrStacktraceNotFound = errors.New("stacktrace not found")
	ErrLocationNotFound   = errors.New("location not found")
	ErrMappingNotFound    = errors.New("mapping not found")
	ErrFunctionNotFound   = errors.New("function not found")
)

Functions

func GetLocationsByIDs added in v0.5.0 

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

func MakeFunctionKey 

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

func MakeLocationKey 

func MakeLocationKey(l *Location) []byte

func MakeMappingKey 

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

func UnsymbolizableMapping added in v0.5.0 

func UnsymbolizableMapping(m *pb.Mapping) bool

UnsymbolizableMapping returns true if a mapping points to a binary for which locations can't be symbolized in principle, at least now. Examples are "[vdso]", [vsyscall]" and some others, see the code.

Types

type BadgerLogger added in v0.5.0 

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

func (*BadgerLogger) Debugf added in v0.5.0 

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

func (*BadgerLogger) Errorf added in v0.5.0 

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

func (*BadgerLogger) Infof added in v0.5.0 

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

func (*BadgerLogger) Warningf added in v0.5.0 

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

type BadgerMetastore added in v0.5.0 

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

BadgerMetastore is an implementation of the metastore using the badger KV store.

func NewBadgerMetastore added in v0.5.0 

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

NewBadgerMetastore returns a new BadgerMetastore with using in-memory badger instance.

func (*BadgerMetastore) Close added in v0.5.0 

func (m *BadgerMetastore) Close() error

Close closes the badger store.

func (*BadgerMetastore) CreateFunction added in v0.5.0 

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

CreateFunction creates a new function in the database.

func (*BadgerMetastore) CreateLocation added in v0.5.0 

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

func (*BadgerMetastore) CreateLocationLines added in v0.5.0 

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

CreateLocationLines writes a set of lines related to a location to the database.

func (*BadgerMetastore) CreateMapping added in v0.5.0 

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

CreateMapping creates a new mapping in the database.

func (*BadgerMetastore) CreateStacktrace added in v0.6.0 

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

func (*BadgerMetastore) GetFunctionByKey added in v0.5.0 

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

GetFunctionByKey returns the function for the given key.

func (*BadgerMetastore) GetFunctions added in v0.5.0 

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

GetFunctions returns all functions in the database.

func (*BadgerMetastore) GetFunctionsByIDs added in v0.5.0 

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

GetFunctionByID returns the function for the given ID.

func (*BadgerMetastore) GetLinesByLocationIDs added in v0.5.0 

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

GetLinesByLocationIDs returns the lines for the given location IDs.

func (*BadgerMetastore) GetLocationByKey added in v0.5.0 

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

func (*BadgerMetastore) GetLocations added in v0.5.0 

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

func (*BadgerMetastore) GetLocationsByIDs added in v0.5.0 

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

func (*BadgerMetastore) GetMappingByKey added in v0.5.0 

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

GetMappingByKey returns the mapping for the given key.

func (*BadgerMetastore) GetMappingsByIDs added in v0.5.0 

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

GetMappingsByIDs returns the mappings for the given IDs.

func (*BadgerMetastore) GetStacktraceByIDs added in v0.6.0 

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

func (*BadgerMetastore) GetStacktraceByKey added in v0.6.0 

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

func (*BadgerMetastore) GetSymbolizableLocations added in v0.5.0 

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

func (*BadgerMetastore) Ping added in v0.5.0 

func (m *BadgerMetastore) Ping() error

Ping returns an error if the metastore is not available.

func (*BadgerMetastore) Symbolize added in v0.5.0 

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

type FunctionKey 

type FunctionKey struct {
	StartLine                  int64
	Name, SystemName, Filename string
}

func MakeSQLFunctionKey added in v0.5.0 

func MakeSQLFunctionKey(f *pb.Function) FunctionKey

type FunctionStore 

type FunctionStore interface {
	GetFunctionByKey(ctx context.Context, key *pb.Function) (*pb.Function, error)
	CreateFunction(ctx context.Context, f *pb.Function) ([]byte, error)
	GetFunctionsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Function, error)
	GetFunctions(ctx context.Context) ([]*pb.Function, error)
}

type InMemorySQLiteMetaStore 

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

func NewInMemorySQLiteProfileMetaStore 

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

func (InMemorySQLiteMetaStore) Close 

func (s InMemorySQLiteMetaStore) Close() error

func (InMemorySQLiteMetaStore) CreateFunction 

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

func (InMemorySQLiteMetaStore) CreateLocation 

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

func (InMemorySQLiteMetaStore) CreateLocationLines added in v0.5.0 

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

func (InMemorySQLiteMetaStore) CreateMapping 

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

func (InMemorySQLiteMetaStore) CreateStacktrace added in v0.6.0 

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

func (InMemorySQLiteMetaStore) GetFunctionByKey 

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

func (InMemorySQLiteMetaStore) GetFunctions 

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

func (InMemorySQLiteMetaStore) GetFunctionsByIDs added in v0.5.0 

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

func (InMemorySQLiteMetaStore) GetLinesByLocationIDs added in v0.5.0 

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

func (InMemorySQLiteMetaStore) GetLocationByKey 

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

func (InMemorySQLiteMetaStore) GetLocations 

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

func (InMemorySQLiteMetaStore) GetLocationsByIDs 

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

func (InMemorySQLiteMetaStore) GetMappingByKey 

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

func (InMemorySQLiteMetaStore) GetMappingsByIDs 

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

func (InMemorySQLiteMetaStore) GetStacktraceByIDs added in v0.6.0 

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

func (InMemorySQLiteMetaStore) GetStacktraceByKey added in v0.6.0 

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

func (InMemorySQLiteMetaStore) GetSymbolizableLocations 

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

func (InMemorySQLiteMetaStore) Ping 

func (s InMemorySQLiteMetaStore) Ping() error

func (InMemorySQLiteMetaStore) Symbolize 

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

type Location 

type Location struct {
	ID       uuid.UUID
	Address  uint64
	Mapping  *pb.Mapping
	Lines    []LocationLine
	IsFolded bool
}

func GetLocationByKey added in v0.5.0 

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

func GetLocations added in v0.5.0 

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

Only used in tests so not as important to be efficient.

func GetSymbolizableLocations added in v0.5.0 

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

type LocationKey 

type LocationKey struct {
	NormalizedAddress uint64
	MappingID         uuid.UUID
	Lines             string
	IsFolded          bool
}

func MakeSQLLocationKey added in v0.5.0 

func MakeSQLLocationKey(l *Location) LocationKey

type LocationLine added in v0.4.0 

type LocationLine struct {
	Line     int64
	Function *pb.Function
}

type LocationLineStore added in v0.5.0 

type LocationLineStore interface {
	CreateLocationLines(ctx context.Context, locID []byte, lines []LocationLine) error
	GetLinesByLocationIDs(ctx context.Context, id ...[]byte) (map[string][]*pb.Line, [][]byte, error)
}

type LocationStore 

type LocationStore interface {
	GetLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)
	GetLocationByKey(ctx context.Context, key *Location) (*pb.Location, error)
	GetLocationsByIDs(ctx context.Context, id ...[]byte) (map[string]*pb.Location, [][]byte, error)
	CreateLocation(ctx context.Context, l *Location) ([]byte, error)
	Symbolize(ctx context.Context, location *Location) error
	GetSymbolizableLocations(ctx context.Context) ([]*pb.Location, [][]byte, error)
}

type MappingKey 

type MappingKey struct {
	Size, Offset  uint64
	BuildIDOrFile string
}

func MakeSQLMappingKey added in v0.5.0 

func MakeSQLMappingKey(m *pb.Mapping) MappingKey

type MappingStore 

type MappingStore interface {
	GetMappingByKey(ctx context.Context, key *pb.Mapping) (*pb.Mapping, error)
	CreateMapping(ctx context.Context, m *pb.Mapping) ([]byte, error)
	GetMappingsByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Mapping, error)
}

type OnDiskSQLiteMetaStore 

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

func NewDiskProfileMetaStore 

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

func (OnDiskSQLiteMetaStore) Close 

func (s OnDiskSQLiteMetaStore) Close() error

func (OnDiskSQLiteMetaStore) CreateFunction 

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

func (OnDiskSQLiteMetaStore) CreateLocation 

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

func (OnDiskSQLiteMetaStore) CreateLocationLines added in v0.5.0 

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

func (OnDiskSQLiteMetaStore) CreateMapping 

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

func (OnDiskSQLiteMetaStore) CreateStacktrace added in v0.6.0 

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

func (OnDiskSQLiteMetaStore) GetFunctionByKey 

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

func (OnDiskSQLiteMetaStore) GetFunctions 

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

func (OnDiskSQLiteMetaStore) GetFunctionsByIDs added in v0.5.0 

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

func (OnDiskSQLiteMetaStore) GetLinesByLocationIDs added in v0.5.0 

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

func (OnDiskSQLiteMetaStore) GetLocationByKey 

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

func (OnDiskSQLiteMetaStore) GetLocations 

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

func (OnDiskSQLiteMetaStore) GetLocationsByIDs 

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

func (OnDiskSQLiteMetaStore) GetMappingByKey 

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

func (OnDiskSQLiteMetaStore) GetMappingsByIDs 

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

func (OnDiskSQLiteMetaStore) GetStacktraceByIDs added in v0.6.0 

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

func (OnDiskSQLiteMetaStore) GetStacktraceByKey added in v0.6.0 

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

func (OnDiskSQLiteMetaStore) GetSymbolizableLocations 

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

func (OnDiskSQLiteMetaStore) Ping 

func (s OnDiskSQLiteMetaStore) Ping() error

func (OnDiskSQLiteMetaStore) Symbolize 

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

type ProfileMetaStore 

type ProfileMetaStore interface {
	StacktraceStore
	LocationStore
	LocationLineStore
	FunctionStore
	MappingStore
	Close() error
	Ping() error
}

type RandomUUIDGenerator added in v0.5.0 

type RandomUUIDGenerator struct{}

RandomUUIDGenerator returns a new random UUID.

func (*RandomUUIDGenerator) New added in v0.5.0 

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

New returns a new UUID.

type RemoteMetaStore 

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

func NewRemoteProfileMetaStore 

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

func (RemoteMetaStore) Close 

func (s RemoteMetaStore) Close() error

func (RemoteMetaStore) CreateFunction 

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

func (RemoteMetaStore) CreateLocation 

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

func (RemoteMetaStore) CreateLocationLines added in v0.5.0 

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

func (RemoteMetaStore) CreateMapping 

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

func (RemoteMetaStore) CreateStacktrace added in v0.6.0 

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

func (RemoteMetaStore) GetFunctionByKey 

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

func (RemoteMetaStore) GetFunctions 

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

func (RemoteMetaStore) GetFunctionsByIDs added in v0.5.0 

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

func (RemoteMetaStore) GetLinesByLocationIDs added in v0.5.0 

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

func (RemoteMetaStore) GetLocationByKey 

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

func (RemoteMetaStore) GetLocations 

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

func (RemoteMetaStore) GetLocationsByIDs 

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

func (RemoteMetaStore) GetMappingByKey 

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

func (RemoteMetaStore) GetMappingsByIDs 

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

func (RemoteMetaStore) GetStacktraceByIDs added in v0.6.0 

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

func (RemoteMetaStore) GetStacktraceByKey added in v0.6.0 

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

func (RemoteMetaStore) GetSymbolizableLocations 

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

func (RemoteMetaStore) Ping 

func (s RemoteMetaStore) Ping() error

func (RemoteMetaStore) Symbolize 

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

type StacktraceStore added in v0.6.0 

type StacktraceStore interface {
	GetStacktraceByKey(ctx context.Context, key []byte) (uuid.UUID, error)
	GetStacktraceByIDs(ctx context.Context, ids ...[]byte) (map[string]*pb.Sample, error)
	CreateStacktrace(ctx context.Context, key []byte, sample *pb.Sample) (uuid.UUID, error)
}

type UUIDGenerator added in v0.5.0 

type UUIDGenerator interface {
	New() uuid.UUID
}

UUIDGenerator returns new UUIDs.

func NewRandomUUIDGenerator added in v0.5.0 

func NewRandomUUIDGenerator() UUIDGenerator

NewRandomUUIDGenerator returns a new random UUID generator.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.