debuginfo

package

v0.11.0 Latest Latest Go to latest Published: May 4, 2022 License: Apache-2.0 Imports: 30 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/parca-dev/parca

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type BucketRule
- func (r BucketRule) Validate(value interface{}) error
type CacheConfig
type CacheProvider
type Client
- func NewDebugInfoClient(conn *grpc.ClientConn) *Client
- func (c *Client) Exists(ctx context.Context, buildID, hash string) (bool, error)
- func (c *Client) Upload(ctx context.Context, buildID, hash string, r io.Reader) (uint64, error)
type Config
type DebugInfodClient
- func NewDebugInfodClientWithObjectStorageCache(logger log.Logger, config *Config, h DebugInfodClient) (DebugInfodClient, error)
type DebugInfodClientObjectStorageCache
- func (c *DebugInfodClientObjectStorageCache) GetDebugInfo(ctx context.Context, buildID string) (io.ReadCloser, error)
type FilesystemCacheConfig
type HTTPDebugInfodClient
- func NewHTTPDebugInfodClient(logger log.Logger, serverURLs []string, timeoutDuration time.Duration) (*HTTPDebugInfodClient, error)
- func (c *HTTPDebugInfodClient) GetDebugInfo(ctx context.Context, buildID string) (io.ReadCloser, error)
type NopDebugInfodClient
- func (NopDebugInfodClient) GetDebugInfo(context.Context, string) (io.ReadCloser, error)
type Store
- func NewStore(logger log.Logger, symbolizer *symbol.Symbolizer, config *Config, ...) (*Store, error)
- func (s *Store) Exists(ctx context.Context, req *debuginfopb.ExistsRequest) (*debuginfopb.ExistsResponse, error)
- func (s *Store) Symbolize(ctx context.Context, m *pb.Mapping, locations ...*metastore.Location) (map[*metastore.Location][]metastore.LocationLine, error)
- func (s *Store) Upload(stream debuginfopb.DebugInfoService_UploadServer) error
type UploadReader
- func (r *UploadReader) Read(p []byte) (int, error)
type ValidRule
- func (v ValidRule) Validate(value interface{}) error

Constants ¶

This section is empty.

Variables ¶

View Source

var BucketValid = BucketRule{}

View Source

var ErrDebugInfoAlreadyExists = errors.New("debug info already exists")

View Source

var Valid = ValidRule{}

Valid is the ValidRule.

Functions ¶

This section is empty.

Types ¶

type BucketRule ¶ added in v0.2.0

type BucketRule struct{}

func (BucketRule) Validate ¶ added in v0.2.0

func (r BucketRule) Validate(value interface{}) error

Validate the bucket config.

type CacheConfig ¶

type CacheConfig struct {
	Type   CacheProvider `yaml:"type"`
	Config interface{}   `yaml:"config"`
}

type CacheProvider ¶

type CacheProvider string

const (
	FILESYSTEM CacheProvider = "FILESYSTEM"
)

type Client ¶ added in v0.8.0

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

func NewDebugInfoClient ¶

func NewDebugInfoClient(conn *grpc.ClientConn) *Client

func (*Client) Exists ¶ added in v0.8.0

func (c *Client) Exists(ctx context.Context, buildID, hash string) (bool, error)

func (*Client) Upload ¶ added in v0.8.0

func (c *Client) Upload(ctx context.Context, buildID, hash string, r io.Reader) (uint64, error)

type Config ¶

type Config struct {
	Bucket *client.BucketConfig `yaml:"bucket"`
	Cache  *CacheConfig         `yaml:"cache"`
}

type DebugInfodClient ¶ added in v0.8.0

type DebugInfodClient interface {
	GetDebugInfo(ctx context.Context, buildid string) (io.ReadCloser, error)
}

func NewDebugInfodClientWithObjectStorageCache ¶ added in v0.8.0

func NewDebugInfodClientWithObjectStorageCache(logger log.Logger, config *Config, h DebugInfodClient) (DebugInfodClient, error)

NewDebugInfodClientWithObjectStorageCache creates a new DebugInfodClient that caches the debug information in the object storage.

type DebugInfodClientObjectStorageCache ¶ added in v0.8.0

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

func (*DebugInfodClientObjectStorageCache) GetDebugInfo ¶ added in v0.8.0

func (c *DebugInfodClientObjectStorageCache) GetDebugInfo(ctx context.Context, buildID string) (io.ReadCloser, error)

GetDebugInfo returns debug info for given buildid while caching it in object storage.

type FilesystemCacheConfig ¶

type FilesystemCacheConfig struct {
	Directory string `yaml:"directory"`
}

type HTTPDebugInfodClient ¶ added in v0.8.0

type HTTPDebugInfodClient struct {
	UpstreamServers []*url.URL
	// contains filtered or unexported fields
}

func NewHTTPDebugInfodClient ¶ added in v0.8.0

func NewHTTPDebugInfodClient(logger log.Logger, serverURLs []string, timeoutDuration time.Duration) (*HTTPDebugInfodClient, error)

NewHTTPDebugInfodClient returns a new HTTP debug info client.

func (*HTTPDebugInfodClient) GetDebugInfo ¶ added in v0.8.0

func (c *HTTPDebugInfodClient) GetDebugInfo(ctx context.Context, buildID string) (io.ReadCloser, error)

GetDebugInfo returns debug information file for given buildID by downloading it from upstream servers.

type NopDebugInfodClient ¶ added in v0.9.0

type NopDebugInfodClient struct{}

func (NopDebugInfodClient) GetDebugInfo ¶ added in v0.9.0

func (NopDebugInfodClient) GetDebugInfo(context.Context, string) (io.ReadCloser, error)

type Store ¶

type Store struct {
	debuginfopb.UnimplementedDebugInfoServiceServer
	// contains filtered or unexported fields
}

func NewStore ¶

func NewStore(logger log.Logger, symbolizer *symbol.Symbolizer, config *Config, debuginfodClient DebugInfodClient) (*Store, error)

NewStore returns a new debug info store.

func (*Store) Exists ¶

func (s *Store) Exists(ctx context.Context, req *debuginfopb.ExistsRequest) (*debuginfopb.ExistsResponse, error)

func (*Store) Symbolize ¶

func (s *Store) Symbolize(ctx context.Context, m *pb.Mapping, locations ...*metastore.Location) (map[*metastore.Location][]metastore.LocationLine, error)

func (*Store) Upload ¶

func (s *Store) Upload(stream debuginfopb.DebugInfoService_UploadServer) error

type UploadReader ¶

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

func (*UploadReader) Read ¶

func (r *UploadReader) Read(p []byte) (int, error)

type ValidRule ¶ added in v0.2.0

type ValidRule struct{}

ValidRule is a validation rule for the Config. It implements the validation.Rule interface.

func (ValidRule) Validate ¶ added in v0.2.0

func (v ValidRule) Validate(value interface{}) error

Validate returns an error if the config is not valid.

Source Files ¶

View all Source files

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