agent

Documentation

Index

• func NewMatchingProfileListener(logger log.Logger, next profilestorepb.ProfileStoreServiceClient) *profileListener
• func NewNoopProfileStoreClient() profilestorepb.ProfileStoreServiceClient
• type BatchWriteClient
  • func NewBatchWriteClient(logger log.Logger, reg prometheus.Registerer, ...) *BatchWriteClient
  • func (b *BatchWriteClient) Run(ctx context.Context) error
  • func (b *BatchWriteClient) 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)

Functions

func NewMatchingProfileListener

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

func NewNoopProfileStoreClient

func NewNoopProfileStoreClient() profilestorepb.ProfileStoreServiceClient

Types

type BatchWriteClient

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

BatchWriteClient is a batch writer for profiles.

func NewBatchWriteClient

func NewBatchWriteClient(logger log.Logger, reg prometheus.Registerer, wc profilestorepb.ProfileStoreServiceClient, writeInterval time.Duration, isNormalized bool) *BatchWriteClient

func (*BatchWriteClient) Run

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

func (*BatchWriteClient) WriteRaw

func (b *BatchWriteClient) 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)