profilestore

Documentation

Index

• type GRPCForwarder
  • func NewGRPCForwarder(conn grpc.ClientConnInterface, logger log.Logger) *GRPCForwarder
  • func (s *GRPCForwarder) WriteRaw(ctx context.Context, req *profilestorepb.WriteRawRequest) (*profilestorepb.WriteRawResponse, error)
• type ProfileColumnStore
  • func NewProfileColumnStore(reg prometheus.Registerer, logger log.Logger, tracer trace.Tracer, ...) *ProfileColumnStore
  • func (s *ProfileColumnStore) Agents(ctx context.Context, req *profilestorepb.AgentsRequest) (*profilestorepb.AgentsResponse, error)
  • func (s *ProfileColumnStore) WriteRaw(ctx context.Context, req *profilestorepb.WriteRawRequest) (*profilestorepb.WriteRawResponse, error)

Types

type GRPCForwarder

type GRPCForwarder struct {
	profilestorepb.UnimplementedProfileStoreServiceServer
	// contains filtered or unexported fields
}

GRPCForwarder forward profiles via gRPC to another Parca instance instead of storing the profiles locally in a database.

func NewGRPCForwarder

func NewGRPCForwarder(conn grpc.ClientConnInterface, logger log.Logger) *GRPCForwarder

func (*GRPCForwarder) WriteRaw

func (s *GRPCForwarder) WriteRaw(ctx context.Context, req *profilestorepb.WriteRawRequest) (*profilestorepb.WriteRawResponse, error)

type ProfileColumnStore

type ProfileColumnStore struct {
	profilestorepb.UnimplementedProfileStoreServiceServer
	profilestorepb.UnimplementedAgentsServiceServer
	// contains filtered or unexported fields
}

func NewProfileColumnStore

func NewProfileColumnStore(
	reg prometheus.Registerer,
	logger log.Logger,
	tracer trace.Tracer,
	metastore metastorev1alpha1.MetastoreServiceClient,
	ingester ingester.Ingester,
	enableAddressNormalization bool,
) *ProfileColumnStore

func (*ProfileColumnStore) Agents

func (s *ProfileColumnStore) Agents(ctx context.Context, req *profilestorepb.AgentsRequest) (*profilestorepb.AgentsResponse, error)

func (*ProfileColumnStore) WriteRaw

func (s *ProfileColumnStore) WriteRaw(ctx context.Context, req *profilestorepb.WriteRawRequest) (*profilestorepb.WriteRawResponse, error)