profilestore

type Client ¶ added in v0.24.0

type Client struct {
	profilestorepb.ProfileStoreServiceClient
	otelgrpcprofilingpb.ProfilesServiceClient
}

func NewClient(
	profilestoreClient profilestorepb.ProfileStoreServiceClient,
	otelgrpcprofilingClient otelgrpcprofilingpb.ProfilesServiceClient,
) *Client

type GRPCForwarder ¶ added in v0.9.0

type GRPCForwarder struct {
	profilestorepb.UnimplementedProfileStoreServiceServer
	otelgrpcprofilingpb.UnimplementedProfilesServiceServer
	// 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(client *Client, logger log.Logger) *GRPCForwarder

func (s *GRPCForwarder) Export(ctx context.Context, req *otelgrpcprofilingpb.ExportProfilesServiceRequest) (*otelgrpcprofilingpb.ExportProfilesServiceResponse, error)

func (s *GRPCForwarder) Write(srv profilestorepb.ProfileStoreService_WriteServer) error

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

type ProfileColumnStore ¶ added in v0.11.0

type ProfileColumnStore struct {
	profilestorepb.UnimplementedProfileStoreServiceServer
	profilestorepb.UnimplementedAgentsServiceServer

	otelgrpcprofilingpb.UnimplementedProfilesServiceServer
	// contains filtered or unexported fields
}

func NewProfileColumnStore(
	reg prometheus.Registerer,
	logger log.Logger,
	tracer trace.Tracer,
	ingester ingester.Ingester,
	schema *dynparquet.Schema,
	mem memory.Allocator,
) *ProfileColumnStore

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

func (s *ProfileColumnStore) Export(ctx context.Context, req *otelgrpcprofilingpb.ExportProfilesServiceRequest) (*otelgrpcprofilingpb.ExportProfilesServiceResponse, error)

func (s *ProfileColumnStore) Write(server profilestorepb.ProfileStoreService_WriteServer) error

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