ingesterv1

type BlockHints struct {

	// The ULID of blocks to query
	Ulids []string `protobuf:"bytes,1,rep,name=ulids,proto3" json:"ulids,omitempty"`
	// When all blocks are compacted, there is no effect of the replication factor, hence we do not need to run deduplication.
	Deduplication bool `protobuf:"varint,2,opt,name=deduplication,proto3" json:"deduplication,omitempty"`
	// contains filtered or unexported fields
}

type BlockMetadataRequest struct {

	// Milliseconds since epoch. If missing or zero, only the ingesters will be
	// queried.
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// Milliseconds since epoch. If missing or zero, only the ingesters will be
	// queried.
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

type BlockMetadataResponse struct {

	// Blocks that are present on the instance for the start to end period
	Blocks []*v1.BlockInfo `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

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

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

type Hints struct {
	Block *BlockHints `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

type IngesterServiceClient interface {
	Push(ctx context.Context, in *v11.PushRequest, opts ...grpc.CallOption) (*v11.PushResponse, error)
	LabelValues(ctx context.Context, in *v1.LabelValuesRequest, opts ...grpc.CallOption) (*v1.LabelValuesResponse, error)
	LabelNames(ctx context.Context, in *v1.LabelNamesRequest, opts ...grpc.CallOption) (*v1.LabelNamesResponse, error)
	ProfileTypes(ctx context.Context, in *ProfileTypesRequest, opts ...grpc.CallOption) (*ProfileTypesResponse, error)
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesResponse, error)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	MergeProfilesStacktraces(ctx context.Context, opts ...grpc.CallOption) (IngesterService_MergeProfilesStacktracesClient, error)
	MergeProfilesLabels(ctx context.Context, opts ...grpc.CallOption) (IngesterService_MergeProfilesLabelsClient, error)
	MergeProfilesPprof(ctx context.Context, opts ...grpc.CallOption) (IngesterService_MergeProfilesPprofClient, error)
	MergeSpanProfile(ctx context.Context, opts ...grpc.CallOption) (IngesterService_MergeSpanProfileClient, error)
	BlockMetadata(ctx context.Context, in *BlockMetadataRequest, opts ...grpc.CallOption) (*BlockMetadataResponse, error)
}

type IngesterServiceServer interface {
	Push(context.Context, *v11.PushRequest) (*v11.PushResponse, error)
	LabelValues(context.Context, *v1.LabelValuesRequest) (*v1.LabelValuesResponse, error)
	LabelNames(context.Context, *v1.LabelNamesRequest) (*v1.LabelNamesResponse, error)
	ProfileTypes(context.Context, *ProfileTypesRequest) (*ProfileTypesResponse, error)
	Series(context.Context, *SeriesRequest) (*SeriesResponse, error)
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	MergeProfilesStacktraces(IngesterService_MergeProfilesStacktracesServer) error
	MergeProfilesLabels(IngesterService_MergeProfilesLabelsServer) error
	MergeProfilesPprof(IngesterService_MergeProfilesPprofServer) error
	MergeSpanProfile(IngesterService_MergeSpanProfileServer) error
	BlockMetadata(context.Context, *BlockMetadataRequest) (*BlockMetadataResponse, error)
	// contains filtered or unexported methods
}

type IngesterService_MergeProfilesLabelsClient interface {
	Send(*MergeProfilesLabelsRequest) error
	Recv() (*MergeProfilesLabelsResponse, error)
	grpc.ClientStream
}

type IngesterService_MergeProfilesLabelsServer interface {
	Send(*MergeProfilesLabelsResponse) error
	Recv() (*MergeProfilesLabelsRequest, error)
	grpc.ServerStream
}

type IngesterService_MergeProfilesPprofClient interface {
	Send(*MergeProfilesPprofRequest) error
	Recv() (*MergeProfilesPprofResponse, error)
	grpc.ClientStream
}

type IngesterService_MergeProfilesPprofServer interface {
	Send(*MergeProfilesPprofResponse) error
	Recv() (*MergeProfilesPprofRequest, error)
	grpc.ServerStream
}

type IngesterService_MergeProfilesStacktracesClient interface {
	Send(*MergeProfilesStacktracesRequest) error
	Recv() (*MergeProfilesStacktracesResponse, error)
	grpc.ClientStream
}

type IngesterService_MergeProfilesStacktracesServer interface {
	Send(*MergeProfilesStacktracesResponse) error
	Recv() (*MergeProfilesStacktracesRequest, error)
	grpc.ServerStream
}

type IngesterService_MergeSpanProfileClient interface {
	Send(*MergeSpanProfileRequest) error
	Recv() (*MergeSpanProfileResponse, error)
	grpc.ClientStream
}

type IngesterService_MergeSpanProfileServer interface {
	Send(*MergeSpanProfileResponse) error
	Recv() (*MergeSpanProfileRequest, error)
	grpc.ServerStream
}

type MergeProfilesLabelsRequest struct {

	// The client starts the stream with a request containing the profile type and the labels.
	Request *SelectProfilesRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// The labels to merge by
	By []string `protobuf:"bytes,2,rep,name=by,proto3" json:"by,omitempty"`
	// On a batch of profiles, the client sends the profiles to keep for merging.
	Profiles []bool `protobuf:"varint,3,rep,packed,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

type MergeProfilesLabelsResponse struct {

	// The server replies batch of profiles.
	// A last message without profiles signals the next message will be the result of the merge.
	SelectedProfiles *ProfileSets `protobuf:"bytes,1,opt,name=selectedProfiles,proto3" json:"selectedProfiles,omitempty"`
	// The list of series for the profile with their respective value
	Series []*v1.Series `protobuf:"bytes,2,rep,name=series,proto3" json:"series,omitempty"`
	// contains filtered or unexported fields
}

type MergeProfilesPprofRequest struct {

	// The client starts the stream with a request containing the profile type and the labels.
	Request *SelectProfilesRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Max nodes in the resulting profile.
	MaxNodes *int64 `protobuf:"varint,3,opt,name=max_nodes,json=maxNodes,proto3,oneof" json:"max_nodes,omitempty"`
	// Include stack traces that match the selector.
	StackTraceSelector *v1.StackTraceSelector `protobuf:"bytes,4,opt,name=stack_trace_selector,json=stackTraceSelector,proto3,oneof" json:"stack_trace_selector,omitempty"`
	// On a batch of profiles, the client sends the profiles to keep for merging.
	Profiles []bool `protobuf:"varint,2,rep,packed,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

type MergeProfilesPprofResponse struct {

	// The server replies batch of profiles.
	// A last message without profiles signals the next message will be the result of the merge.
	SelectedProfiles *ProfileSets `protobuf:"bytes,1,opt,name=selectedProfiles,proto3" json:"selectedProfiles,omitempty"`
	// The merge result in the pprof format.
	Result []byte `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type MergeProfilesStacktracesRequest struct {

	// The client starts the stream with a request containing the profile type and the labels.
	Request *SelectProfilesRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Max nodes in the resulting tree.
	MaxNodes *int64 `protobuf:"varint,3,opt,name=max_nodes,json=maxNodes,proto3,oneof" json:"max_nodes,omitempty"`
	// On a batch of profiles, the client sends the profiles to keep for merging.
	Profiles []bool `protobuf:"varint,2,rep,packed,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

type MergeProfilesStacktracesResponse struct {

	// The server replies batch of profiles.
	// A last message without profiles signals the next message will be the result of the merge.
	SelectedProfiles *ProfileSets `protobuf:"bytes,1,opt,name=selectedProfiles,proto3" json:"selectedProfiles,omitempty"`
	// The list of stracktraces for the profile with their respective value
	Result *MergeProfilesStacktracesResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type MergeProfilesStacktracesResult struct {
	Format StacktracesMergeFormat `protobuf:"varint,3,opt,name=format,proto3,enum=ingester.v1.StacktracesMergeFormat" json:"format,omitempty"`
	// The list of stracktraces with their respective value
	Stacktraces   []*StacktraceSample `protobuf:"bytes,1,rep,name=stacktraces,proto3" json:"stacktraces,omitempty"`
	FunctionNames []string            `protobuf:"bytes,2,rep,name=function_names,json=functionNames,proto3" json:"function_names,omitempty"`
	// Merge result marshaled to pyroscope tree bytes.
	TreeBytes []byte `protobuf:"bytes,4,opt,name=tree_bytes,json=treeBytes,proto3" json:"tree_bytes,omitempty"`
	// contains filtered or unexported fields
}

type MergeSpanProfileRequest struct {

	// The client starts the stream with a request containing the profile type and the labels.
	Request *SelectSpanProfileRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Max nodes in the resulting tree.
	MaxNodes *int64 `protobuf:"varint,2,opt,name=max_nodes,json=maxNodes,proto3,oneof" json:"max_nodes,omitempty"`
	// On a batch of profiles, the client sends the profiles to keep for merging.
	Profiles []bool `protobuf:"varint,3,rep,packed,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

type MergeSpanProfileResponse struct {

	// The server replies batch of profiles.
	// A last message without profiles signals the next message will be the result of the merge.
	SelectedProfiles *ProfileSets `protobuf:"bytes,1,opt,name=selectedProfiles,proto3" json:"selectedProfiles,omitempty"`
	// The list of stracktraces for the profile with their respective value
	Result *MergeSpanProfileResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type MergeSpanProfileResult struct {
	TreeBytes []byte `protobuf:"bytes,1,opt,name=tree_bytes,json=treeBytes,proto3" json:"tree_bytes,omitempty"`
	// contains filtered or unexported fields
}

type Profile struct {

	// The ID of the profile.
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// The name and type of the profile.
	Type *v1.ProfileType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// LabelPair is the key value pairs to identify the corresponding profile
	Labels []*v1.LabelPair `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	// Timestamp is when that profile was created
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The list of stracktraces for the profile with their respective value
	Stacktraces []*StacktraceSample `protobuf:"bytes,5,rep,name=stacktraces,proto3" json:"stacktraces,omitempty"`
	// contains filtered or unexported fields
}

type ProfileSets struct {
	LabelsSets []*v1.Labels     `protobuf:"bytes,1,rep,name=labelsSets,proto3" json:"labelsSets,omitempty"`
	Profiles   []*SeriesProfile `protobuf:"bytes,2,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

type ProfileTypesRequest struct {

	// Milliseconds since epoch.
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// Milliseconds since epoch.
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

type ProfileTypesResponse struct {
	ProfileTypes []*v1.ProfileType `protobuf:"bytes,1,rep,name=profile_types,json=profileTypes,proto3" json:"profile_types,omitempty"`
	// contains filtered or unexported fields
}

type SelectProfilesRequest struct {
	LabelSelector string          `protobuf:"bytes,1,opt,name=label_selector,json=labelSelector,proto3" json:"label_selector,omitempty"`
	Type          *v1.ProfileType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Milliseconds since epoch.
	Start int64 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	// Milliseconds since epoch.
	End int64 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// Optional: Hints for querying
	Hints *Hints `protobuf:"bytes,5,opt,name=hints,proto3,oneof" json:"hints,omitempty"`
	// Optional: Aggregation
	Aggregation *v1.TimeSeriesAggregationType `protobuf:"varint,6,opt,name=aggregation,proto3,enum=types.v1.TimeSeriesAggregationType,oneof" json:"aggregation,omitempty"`
	// contains filtered or unexported fields
}

type SelectSpanProfileRequest struct {
	LabelSelector string          `protobuf:"bytes,1,opt,name=label_selector,json=labelSelector,proto3" json:"label_selector,omitempty"`
	Type          *v1.ProfileType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Milliseconds since epoch.
	Start int64 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	// Milliseconds since epoch.
	End int64 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// List of span identifiers.
	SpanSelector []string `protobuf:"bytes,5,rep,name=span_selector,json=spanSelector,proto3" json:"span_selector,omitempty"`
	// Optional: Hints for querying
	Hints *Hints `protobuf:"bytes,6,opt,name=hints,proto3,oneof" json:"hints,omitempty"`
	// contains filtered or unexported fields
}

type SeriesProfile struct {

	// The labels index of the series
	LabelIndex int32 `protobuf:"varint,1,opt,name=labelIndex,proto3" json:"labelIndex,omitempty"`
	// timestamp in milliseconds
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type SeriesRequest struct {
	Matchers   []string `protobuf:"bytes,1,rep,name=matchers,proto3" json:"matchers,omitempty"`
	LabelNames []string `protobuf:"bytes,2,rep,name=label_names,json=labelNames,proto3" json:"label_names,omitempty"`
	// Milliseconds since epoch. If missing or zero, only the ingesters will be
	// queried.
	Start int64 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	// Milliseconds since epoch. If missing or zero, only the ingesters will be
	// queried.
	End int64 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

type SeriesResponse struct {
	LabelsSet []*v1.Labels `protobuf:"bytes,2,rep,name=labels_set,json=labelsSet,proto3" json:"labels_set,omitempty"`
	// contains filtered or unexported fields
}

type StacktraceSample struct {
	FunctionIds []int32 `protobuf:"varint,1,rep,packed,name=function_ids,json=functionIds,proto3" json:"function_ids,omitempty"`
	Value       int64   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type StacktracesMergeFormat int32

type UnimplementedIngesterServiceServer struct {
}

type UnsafeIngesterServiceServer interface {
	// contains filtered or unexported methods
}