ingesterv1

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

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

type IngesterServiceClient interface {
	Push(ctx context.Context, in *v1.PushRequest, opts ...grpc.CallOption) (*v1.PushResponse, error)
	LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*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)
}

type IngesterServiceServer interface {
	Push(context.Context, *v1.PushRequest) (*v1.PushResponse, error)
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
	LabelNames(context.Context, *LabelNamesRequest) (*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
	// 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 LabelNamesRequest struct {
	// contains filtered or unexported fields
}

type LabelNamesResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

type LabelValuesRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type LabelValuesResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

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"`
	// 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"`
	// 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 {

	// 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"`
	// 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 {
	// 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"`
	Start         int64           `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	End           int64           `protobuf:"varint,4,opt,name=end,proto3" json:"end,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"`
	// 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 UnimplementedIngesterServiceServer struct {
}

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