debuginfo

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 string) (bool, error)
  • func (c *Client) Upload(ctx context.Context, buildID string, r io.Reader) (uint64, error)
• type Config
• type DebugInfodClient
• type DebugInfodClientObjectStorageCache
  • func NewDebugInfodClientWithObjectStorageCache(logger log.Logger, config *Config, h DebugInfodClient) (*DebugInfodClientObjectStorageCache, error)
  • func (c *DebugInfodClientObjectStorageCache) GetDebugInfo(ctx context.Context, buildID string) (io.ReadCloser, error)
• type FilesystemCacheConfig
• type HTTPDebugInfodClient
  • func NewHTTPDebugInfodClient(logger log.Logger, serverURL string, timeoutDuration time.Duration) (*HTTPDebugInfodClient, error)
  • func (c *HTTPDebugInfodClient) GetDebugInfo(ctx context.Context, buildID 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

Variables

var BucketValid = BucketRule{}

var ErrDebugInfoNotFound = errors.New("debug info not found")

var Valid = ValidRule{}

Valid is the ValidRule.

Types

type BucketRule

type BucketRule struct{}

func (BucketRule) Validate

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

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

func NewDebugInfoClient

func NewDebugInfoClient(conn *grpc.ClientConn) *Client

func (*Client) Exists

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

func (*Client) Upload

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

type Config

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

type DebugInfodClient

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

type DebugInfodClientObjectStorageCache

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

func NewDebugInfodClientWithObjectStorageCache

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

func (*DebugInfodClientObjectStorageCache) GetDebugInfo

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

type FilesystemCacheConfig

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

type HTTPDebugInfodClient

type HTTPDebugInfodClient struct {
	UpstreamServer *url.URL
	// contains filtered or unexported fields
}

func NewHTTPDebugInfodClient

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

func (*HTTPDebugInfodClient) GetDebugInfo

func (c *HTTPDebugInfodClient) GetDebugInfo(ctx context.Context, buildID 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

type ValidRule struct{}

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

func (ValidRule) Validate

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

Validate returns an error if the config is not valid.