agent

Documentation

Index

• Constants
• func NewNoopProfileStoreClient() profilestorepb.ProfileStoreServiceClient
• func NewProfileListener(logger log.Logger, next profilestorepb.ProfileStoreServiceClient) *profileListener
• 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)

Constants

const CgroupPathLabelName = model.LabelName("__cgroup_path__")

Functions

func NewNoopProfileStoreClient

func NewNoopProfileStoreClient() profilestorepb.ProfileStoreServiceClient

func NewProfileListener

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

Types

type Batcher

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

func NewBatchWriteClient

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

func (*Batcher) Run

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

func (*Batcher) WriteRaw

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)