profilestore

type GRPCForwarder ¶ added in v0.9.0

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(conn grpc.ClientConnInterface, logger log.Logger) *GRPCForwarder

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
	// contains filtered or unexported fields
}

func NewProfileColumnStore(
	logger log.Logger,
	tracer trace.Tracer,
	metaStore metastore.ProfileMetaStore,
	table *arcticdb.Table,
	debugValueLog bool,
) *ProfileColumnStore

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