agent

package

v0.4.0 Latest Latest Go to latest Published: Jan 6, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Details

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

Repository

github.com/parca-dev/parca-agent

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewNoopProfileStoreClient() profilestorepb.ProfileStoreServiceClient
type Batcher
- func NewBatchWriteClient(logger log.Logger, wc profilestorepb.ProfileStoreServiceClient) *Batcher
- func (b *Batcher) Run(ctx context.Context) error
- func (b *Batcher) WriteRaw(ctx context.Context, r *profilestorepb.WriteRawRequest, ...) (*profilestorepb.WriteRawResponse, error)
type NoopProfileStoreClient
- func (c *NoopProfileStoreClient) WriteRaw(ctx context.Context, in *profilestorepb.WriteRawRequest, ...) (*profilestorepb.WriteRawResponse, error)
type ProfileListener
- func NewProfileListener(logger log.Logger, next profilestorepb.ProfileStoreServiceClient) *ProfileListener
type Record

Constants ¶

View Source

const CgroupPathLabelName = model.LabelName("__cgroup_path__")

Variables ¶

This section is empty.

Functions ¶

func NewNoopProfileStoreClient ¶

func NewNoopProfileStoreClient() profilestorepb.ProfileStoreServiceClient

Types ¶

type Batcher ¶ added in v0.3.0

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

func NewBatchWriteClient ¶ added in v0.3.0

func NewBatchWriteClient(logger log.Logger, wc profilestorepb.ProfileStoreServiceClient) *Batcher

func (*Batcher) Run ¶ added in v0.3.0

func (b *Batcher) Run(ctx context.Context) error

func (*Batcher) WriteRaw ¶ added in v0.3.0

func (b *Batcher) WriteRaw(ctx context.Context, r *profilestorepb.WriteRawRequest, opts ...grpc.CallOption) (*profilestorepb.WriteRawResponse, error)

type NoopProfileStoreClient ¶

type NoopProfileStoreClient struct{}

func (*NoopProfileStoreClient) WriteRaw ¶

func (c *NoopProfileStoreClient) WriteRaw(ctx context.Context, in *profilestorepb.WriteRawRequest, opts ...grpc.CallOption) (*profilestorepb.WriteRawResponse, error)

type ProfileListener ¶ added in v0.4.0

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

func NewProfileListener ¶ added in v0.4.0

func NewProfileListener(logger log.Logger, next profilestorepb.ProfileStoreServiceClient) *ProfileListener

func (*ProfileListener) NextMatchingProfile ¶ added in v0.4.0

func (l *ProfileListener) NextMatchingProfile(ctx context.Context, matchers []*labels.Matcher) (*profile.Profile, error)

func (*ProfileListener) Observe ¶ added in v0.4.0

func (l *ProfileListener) Observe(f func(*profilestorepb.WriteRawRequest)) *observer

func (*ProfileListener) ObserveProfile ¶ added in v0.4.0

func (l *ProfileListener) ObserveProfile(r *profilestorepb.WriteRawRequest)

func (*ProfileListener) RemoveObserver ¶ added in v0.4.0

func (l *ProfileListener) RemoveObserver(o *observer)

func (*ProfileListener) WriteRaw ¶ added in v0.4.0

func (l *ProfileListener) WriteRaw(ctx context.Context, r *profilestorepb.WriteRawRequest, opts ...grpc.CallOption) (*profilestorepb.WriteRawResponse, error)

type Record ¶

type Record struct {
	Labels  []*profilestorepb.Label
	Profile *profile.Profile
}

TODO(kakkoyun): Remove?

Source Files ¶

View all Source files

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