storepb

package
v0.0.0-...-42b049c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 12, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Chunk_Encoding_name = map[int32]string{
	0: "XOR",
	1: "None",
}
View Source 
var Chunk_Encoding_value = map[string]int32{
	"XOR":  0,
	"None": 1,
}
View Source 
var LabelMatcher_Type_name = map[int32]string{
	0: "EQ",
	1: "NEQ",
	2: "RE",
	3: "NRE",
}
View Source 
var LabelMatcher_Type_value = map[string]int32{
	"EQ":  0,
	"NEQ": 1,
	"RE":  2,
	"NRE": 3,
}

Functions

func RegisterReadableProfileStoreServer 

func RegisterReadableProfileStoreServer(s *grpc.Server, srv ReadableProfileStoreServer)

func RegisterSymbolStoreServer 

func RegisterSymbolStoreServer(s *grpc.Server, srv SymbolStoreServer)

func RegisterWritableProfileStoreServer 

func RegisterWritableProfileStoreServer(s *grpc.Server, srv WritableProfileStoreServer)

func TsdbSelectHints 

func TsdbSelectHints(h *SelectHints) *storage.SelectHints

Types

type AggrChunk 

type AggrChunk struct {
	MinTime int64  `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime int64  `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	Raw     *Chunk `protobuf:"bytes,3,opt,name=raw,proto3" json:"raw,omitempty"`
}

func (AggrChunk) Compare 

func (m AggrChunk) Compare(b AggrChunk) int

Compare returns positive 1 if chunk is smaller -1 if larger than b by min time, then max time. It returns 0 if chunks are exactly the same.

func (*AggrChunk) Descriptor 

func (*AggrChunk) Descriptor() ([]byte, []int)

func (*AggrChunk) Marshal 

func (m *AggrChunk) Marshal() (dAtA []byte, err error)

func (*AggrChunk) MarshalTo 

func (m *AggrChunk) MarshalTo(dAtA []byte) (int, error)

func (*AggrChunk) MarshalToSizedBuffer 

func (m *AggrChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggrChunk) ProtoMessage 

func (*AggrChunk) ProtoMessage()

func (*AggrChunk) Reset 

func (m *AggrChunk) Reset()

func (*AggrChunk) Size 

func (m *AggrChunk) Size() (n int)

func (*AggrChunk) String 

func (m *AggrChunk) String() string

func (*AggrChunk) Unmarshal 

func (m *AggrChunk) Unmarshal(dAtA []byte) error

func (*AggrChunk) XXX_DiscardUnknown 

func (m *AggrChunk) XXX_DiscardUnknown()

func (*AggrChunk) XXX_Marshal 

func (m *AggrChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggrChunk) XXX_Merge 

func (m *AggrChunk) XXX_Merge(src proto.Message)

func (*AggrChunk) XXX_Size 

func (m *AggrChunk) XXX_Size() int

func (*AggrChunk) XXX_Unmarshal 

func (m *AggrChunk) XXX_Unmarshal(b []byte) error

type Chunk 

type Chunk struct {
	Type Chunk_Encoding `protobuf:"varint,1,opt,name=type,proto3,enum=conprof.Chunk_Encoding" json:"type,omitempty"`
	Data []byte         `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Chunk) Compare 

func (m *Chunk) Compare(b *Chunk) int

Compare returns positive 1 if chunk is smaller -1 if larger. It returns 0 if chunks are exactly the same.

func (*Chunk) Descriptor 

func (*Chunk) Descriptor() ([]byte, []int)

func (*Chunk) Marshal 

func (m *Chunk) Marshal() (dAtA []byte, err error)

func (*Chunk) MarshalTo 

func (m *Chunk) MarshalTo(dAtA []byte) (int, error)

func (*Chunk) MarshalToSizedBuffer 

func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) Size 

func (m *Chunk) Size() (n int)

func (*Chunk) String 

func (m *Chunk) String() string

func (*Chunk) Unmarshal 

func (m *Chunk) Unmarshal(dAtA []byte) error

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chunk) XXX_Merge 

func (m *Chunk) XXX_Merge(src proto.Message)

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

func (m *Chunk) XXX_Unmarshal(b []byte) error

type Chunk_Encoding 

type Chunk_Encoding int32
const (
	Chunk_XOR  Chunk_Encoding = 0
	Chunk_None Chunk_Encoding = 1
)

func (Chunk_Encoding) EnumDescriptor 

func (Chunk_Encoding) EnumDescriptor() ([]byte, []int)

func (Chunk_Encoding) String 

func (x Chunk_Encoding) String() string

type Function 

type Function struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
}

func (*Function) Descriptor 

func (*Function) Descriptor() ([]byte, []int)

func (*Function) Marshal 

func (m *Function) Marshal() (dAtA []byte, err error)

func (*Function) MarshalTo 

func (m *Function) MarshalTo(dAtA []byte) (int, error)

func (*Function) MarshalToSizedBuffer 

func (m *Function) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Function) ProtoMessage 

func (*Function) ProtoMessage()

func (*Function) Reset 

func (m *Function) Reset()

func (*Function) Size 

func (m *Function) Size() (n int)

func (*Function) String 

func (m *Function) String() string

func (*Function) Unmarshal 

func (m *Function) Unmarshal(dAtA []byte) error

func (*Function) XXX_DiscardUnknown 

func (m *Function) XXX_DiscardUnknown()

func (*Function) XXX_Marshal 

func (m *Function) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Function) XXX_Merge 

func (m *Function) XXX_Merge(src proto.Message)

func (*Function) XXX_Size 

func (m *Function) XXX_Size() int

func (*Function) XXX_Unmarshal 

func (m *Function) XXX_Unmarshal(b []byte) error

type LabelMatcher 

type LabelMatcher struct {
	Type  LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=conprof.LabelMatcher_Type" json:"type,omitempty"`
	Name  string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value string            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

Matcher specifies a rule, which can match or set of labels or not.

func (*LabelMatcher) Descriptor 

func (*LabelMatcher) Descriptor() ([]byte, []int)

func (*LabelMatcher) Marshal 

func (m *LabelMatcher) Marshal() (dAtA []byte, err error)

func (*LabelMatcher) MarshalTo 

func (m *LabelMatcher) MarshalTo(dAtA []byte) (int, error)

func (*LabelMatcher) MarshalToSizedBuffer 

func (m *LabelMatcher) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelMatcher) ProtoMessage 

func (*LabelMatcher) ProtoMessage()

func (*LabelMatcher) Reset 

func (m *LabelMatcher) Reset()

func (*LabelMatcher) Size 

func (m *LabelMatcher) Size() (n int)

func (*LabelMatcher) String 

func (m *LabelMatcher) String() string

func (*LabelMatcher) Unmarshal 

func (m *LabelMatcher) Unmarshal(dAtA []byte) error

func (*LabelMatcher) XXX_DiscardUnknown 

func (m *LabelMatcher) XXX_DiscardUnknown()

func (*LabelMatcher) XXX_Marshal 

func (m *LabelMatcher) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelMatcher) XXX_Merge 

func (m *LabelMatcher) XXX_Merge(src proto.Message)

func (*LabelMatcher) XXX_Size 

func (m *LabelMatcher) XXX_Size() int

func (*LabelMatcher) XXX_Unmarshal 

func (m *LabelMatcher) XXX_Unmarshal(b []byte) error

type LabelMatcher_Type 

type LabelMatcher_Type int32
const (
	LabelMatcher_EQ  LabelMatcher_Type = 0
	LabelMatcher_NEQ LabelMatcher_Type = 1
	LabelMatcher_RE  LabelMatcher_Type = 2
	LabelMatcher_NRE LabelMatcher_Type = 3
)

func (LabelMatcher_Type) EnumDescriptor 

func (LabelMatcher_Type) EnumDescriptor() ([]byte, []int)

func (LabelMatcher_Type) String 

func (x LabelMatcher_Type) String() string

type LabelNamesRequest 

type LabelNamesRequest struct {
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End   int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
}

func (*LabelNamesRequest) Descriptor 

func (*LabelNamesRequest) Descriptor() ([]byte, []int)

func (*LabelNamesRequest) Marshal 

func (m *LabelNamesRequest) Marshal() (dAtA []byte, err error)

func (*LabelNamesRequest) MarshalTo 

func (m *LabelNamesRequest) MarshalTo(dAtA []byte) (int, error)

func (*LabelNamesRequest) MarshalToSizedBuffer 

func (m *LabelNamesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelNamesRequest) ProtoMessage 

func (*LabelNamesRequest) ProtoMessage()

func (*LabelNamesRequest) Reset 

func (m *LabelNamesRequest) Reset()

func (*LabelNamesRequest) Size 

func (m *LabelNamesRequest) Size() (n int)

func (*LabelNamesRequest) String 

func (m *LabelNamesRequest) String() string

func (*LabelNamesRequest) Unmarshal 

func (m *LabelNamesRequest) Unmarshal(dAtA []byte) error

func (*LabelNamesRequest) XXX_DiscardUnknown 

func (m *LabelNamesRequest) XXX_DiscardUnknown()

func (*LabelNamesRequest) XXX_Marshal 

func (m *LabelNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelNamesRequest) XXX_Merge 

func (m *LabelNamesRequest) XXX_Merge(src proto.Message)

func (*LabelNamesRequest) XXX_Size 

func (m *LabelNamesRequest) XXX_Size() int

func (*LabelNamesRequest) XXX_Unmarshal 

func (m *LabelNamesRequest) XXX_Unmarshal(b []byte) error

type LabelNamesResponse 

type LabelNamesResponse struct {
	Names    []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
}

func (*LabelNamesResponse) Descriptor 

func (*LabelNamesResponse) Descriptor() ([]byte, []int)

func (*LabelNamesResponse) Marshal 

func (m *LabelNamesResponse) Marshal() (dAtA []byte, err error)

func (*LabelNamesResponse) MarshalTo 

func (m *LabelNamesResponse) MarshalTo(dAtA []byte) (int, error)

func (*LabelNamesResponse) MarshalToSizedBuffer 

func (m *LabelNamesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelNamesResponse) ProtoMessage 

func (*LabelNamesResponse) ProtoMessage()

func (*LabelNamesResponse) Reset 

func (m *LabelNamesResponse) Reset()

func (*LabelNamesResponse) Size 

func (m *LabelNamesResponse) Size() (n int)

func (*LabelNamesResponse) String 

func (m *LabelNamesResponse) String() string

func (*LabelNamesResponse) Unmarshal 

func (m *LabelNamesResponse) Unmarshal(dAtA []byte) error

func (*LabelNamesResponse) XXX_DiscardUnknown 

func (m *LabelNamesResponse) XXX_DiscardUnknown()

func (*LabelNamesResponse) XXX_Marshal 

func (m *LabelNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelNamesResponse) XXX_Merge 

func (m *LabelNamesResponse) XXX_Merge(src proto.Message)

func (*LabelNamesResponse) XXX_Size 

func (m *LabelNamesResponse) XXX_Size() int

func (*LabelNamesResponse) XXX_Unmarshal 

func (m *LabelNamesResponse) XXX_Unmarshal(b []byte) error

type LabelValuesRequest 

type LabelValuesRequest struct {
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Start int64  `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End   int64  `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
}

func (*LabelValuesRequest) Descriptor 

func (*LabelValuesRequest) Descriptor() ([]byte, []int)

func (*LabelValuesRequest) Marshal 

func (m *LabelValuesRequest) Marshal() (dAtA []byte, err error)

func (*LabelValuesRequest) MarshalTo 

func (m *LabelValuesRequest) MarshalTo(dAtA []byte) (int, error)

func (*LabelValuesRequest) MarshalToSizedBuffer 

func (m *LabelValuesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelValuesRequest) ProtoMessage 

func (*LabelValuesRequest) ProtoMessage()

func (*LabelValuesRequest) Reset 

func (m *LabelValuesRequest) Reset()

func (*LabelValuesRequest) Size 

func (m *LabelValuesRequest) Size() (n int)

func (*LabelValuesRequest) String 

func (m *LabelValuesRequest) String() string

func (*LabelValuesRequest) Unmarshal 

func (m *LabelValuesRequest) Unmarshal(dAtA []byte) error

func (*LabelValuesRequest) XXX_DiscardUnknown 

func (m *LabelValuesRequest) XXX_DiscardUnknown()

func (*LabelValuesRequest) XXX_Marshal 

func (m *LabelValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelValuesRequest) XXX_Merge 

func (m *LabelValuesRequest) XXX_Merge(src proto.Message)

func (*LabelValuesRequest) XXX_Size 

func (m *LabelValuesRequest) XXX_Size() int

func (*LabelValuesRequest) XXX_Unmarshal 

func (m *LabelValuesRequest) XXX_Unmarshal(b []byte) error

type LabelValuesResponse 

type LabelValuesResponse struct {
	Values   []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
}

func (*LabelValuesResponse) Descriptor 

func (*LabelValuesResponse) Descriptor() ([]byte, []int)

func (*LabelValuesResponse) Marshal 

func (m *LabelValuesResponse) Marshal() (dAtA []byte, err error)

func (*LabelValuesResponse) MarshalTo 

func (m *LabelValuesResponse) MarshalTo(dAtA []byte) (int, error)

func (*LabelValuesResponse) MarshalToSizedBuffer 

func (m *LabelValuesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelValuesResponse) ProtoMessage 

func (*LabelValuesResponse) ProtoMessage()

func (*LabelValuesResponse) Reset 

func (m *LabelValuesResponse) Reset()

func (*LabelValuesResponse) Size 

func (m *LabelValuesResponse) Size() (n int)

func (*LabelValuesResponse) String 

func (m *LabelValuesResponse) String() string

func (*LabelValuesResponse) Unmarshal 

func (m *LabelValuesResponse) Unmarshal(dAtA []byte) error

func (*LabelValuesResponse) XXX_DiscardUnknown 

func (m *LabelValuesResponse) XXX_DiscardUnknown()

func (*LabelValuesResponse) XXX_Marshal 

func (m *LabelValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelValuesResponse) XXX_Merge 

func (m *LabelValuesResponse) XXX_Merge(src proto.Message)

func (*LabelValuesResponse) XXX_Size 

func (m *LabelValuesResponse) XXX_Size() int

func (*LabelValuesResponse) XXX_Unmarshal 

func (m *LabelValuesResponse) XXX_Unmarshal(b []byte) error

type Line 

type Line struct {
	Line     int64     `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"`
	Function *Function `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
}

func (*Line) Descriptor 

func (*Line) Descriptor() ([]byte, []int)

func (*Line) Marshal 

func (m *Line) Marshal() (dAtA []byte, err error)

func (*Line) MarshalTo 

func (m *Line) MarshalTo(dAtA []byte) (int, error)

func (*Line) MarshalToSizedBuffer 

func (m *Line) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Line) ProtoMessage 

func (*Line) ProtoMessage()

func (*Line) Reset 

func (m *Line) Reset()

func (*Line) Size 

func (m *Line) Size() (n int)

func (*Line) String 

func (m *Line) String() string

func (*Line) Unmarshal 

func (m *Line) Unmarshal(dAtA []byte) error

func (*Line) XXX_DiscardUnknown 

func (m *Line) XXX_DiscardUnknown()

func (*Line) XXX_Marshal 

func (m *Line) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Line) XXX_Merge 

func (m *Line) XXX_Merge(src proto.Message)

func (*Line) XXX_Size 

func (m *Line) XXX_Size() int

func (*Line) XXX_Unmarshal 

func (m *Line) XXX_Unmarshal(b []byte) error

type Location 

type Location struct {
	Address uint64  `protobuf:"varint,1,opt,name=address,proto3" json:"address,omitempty"`
	Lines   []*Line `protobuf:"bytes,2,rep,name=lines,proto3" json:"lines,omitempty"`
}

func (*Location) Descriptor 

func (*Location) Descriptor() ([]byte, []int)

func (*Location) Marshal 

func (m *Location) Marshal() (dAtA []byte, err error)

func (*Location) MarshalTo 

func (m *Location) MarshalTo(dAtA []byte) (int, error)

func (*Location) MarshalToSizedBuffer 

func (m *Location) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) Size 

func (m *Location) Size() (n int)

func (*Location) String 

func (m *Location) String() string

func (*Location) Unmarshal 

func (m *Location) Unmarshal(dAtA []byte) error

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge 

func (m *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

func (m *Location) XXX_Unmarshal(b []byte) error

type Mapping 

type Mapping struct {
	BuildId     string      `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	MemoryStart uint64      `protobuf:"varint,2,opt,name=memory_start,json=memoryStart,proto3" json:"memory_start,omitempty"`
	MemoryLimit uint64      `protobuf:"varint,3,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"`
	FileOffset  uint64      `protobuf:"varint,4,opt,name=file_offset,json=fileOffset,proto3" json:"file_offset,omitempty"`
	Locations   []*Location `protobuf:"bytes,5,rep,name=locations,proto3" json:"locations,omitempty"`
}

func (*Mapping) Descriptor 

func (*Mapping) Descriptor() ([]byte, []int)

func (*Mapping) Marshal 

func (m *Mapping) Marshal() (dAtA []byte, err error)

func (*Mapping) MarshalTo 

func (m *Mapping) MarshalTo(dAtA []byte) (int, error)

func (*Mapping) MarshalToSizedBuffer 

func (m *Mapping) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Mapping) ProtoMessage 

func (*Mapping) ProtoMessage()

func (*Mapping) Reset 

func (m *Mapping) Reset()

func (*Mapping) Size 

func (m *Mapping) Size() (n int)

func (*Mapping) String 

func (m *Mapping) String() string

func (*Mapping) Unmarshal 

func (m *Mapping) Unmarshal(dAtA []byte) error

func (*Mapping) XXX_DiscardUnknown 

func (m *Mapping) XXX_DiscardUnknown()

func (*Mapping) XXX_Marshal 

func (m *Mapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mapping) XXX_Merge 

func (m *Mapping) XXX_Merge(src proto.Message)

func (*Mapping) XXX_Size 

func (m *Mapping) XXX_Size() int

func (*Mapping) XXX_Unmarshal 

func (m *Mapping) XXX_Unmarshal(b []byte) error

type ProfileRequest 

type ProfileRequest struct {
	Timestamp int64          `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Matchers  []LabelMatcher `protobuf:"bytes,2,rep,name=matchers,proto3" json:"matchers"`
}

func (*ProfileRequest) Descriptor 

func (*ProfileRequest) Descriptor() ([]byte, []int)

func (*ProfileRequest) Marshal 

func (m *ProfileRequest) Marshal() (dAtA []byte, err error)

func (*ProfileRequest) MarshalTo 

func (m *ProfileRequest) MarshalTo(dAtA []byte) (int, error)

func (*ProfileRequest) MarshalToSizedBuffer 

func (m *ProfileRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProfileRequest) ProtoMessage 

func (*ProfileRequest) ProtoMessage()

func (*ProfileRequest) Reset 

func (m *ProfileRequest) Reset()

func (*ProfileRequest) Size 

func (m *ProfileRequest) Size() (n int)

func (*ProfileRequest) String 

func (m *ProfileRequest) String() string

func (*ProfileRequest) Unmarshal 

func (m *ProfileRequest) Unmarshal(dAtA []byte) error

func (*ProfileRequest) XXX_DiscardUnknown 

func (m *ProfileRequest) XXX_DiscardUnknown()

func (*ProfileRequest) XXX_Marshal 

func (m *ProfileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProfileRequest) XXX_Merge 

func (m *ProfileRequest) XXX_Merge(src proto.Message)

func (*ProfileRequest) XXX_Size 

func (m *ProfileRequest) XXX_Size() int

func (*ProfileRequest) XXX_Unmarshal 

func (m *ProfileRequest) XXX_Unmarshal(b []byte) error

type ProfileResponse 

type ProfileResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*ProfileResponse) Descriptor 

func (*ProfileResponse) Descriptor() ([]byte, []int)

func (*ProfileResponse) Marshal 

func (m *ProfileResponse) Marshal() (dAtA []byte, err error)

func (*ProfileResponse) MarshalTo 

func (m *ProfileResponse) MarshalTo(dAtA []byte) (int, error)

func (*ProfileResponse) MarshalToSizedBuffer 

func (m *ProfileResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProfileResponse) ProtoMessage 

func (*ProfileResponse) ProtoMessage()

func (*ProfileResponse) Reset 

func (m *ProfileResponse) Reset()

func (*ProfileResponse) Size 

func (m *ProfileResponse) Size() (n int)

func (*ProfileResponse) String 

func (m *ProfileResponse) String() string

func (*ProfileResponse) Unmarshal 

func (m *ProfileResponse) Unmarshal(dAtA []byte) error

func (*ProfileResponse) XXX_DiscardUnknown 

func (m *ProfileResponse) XXX_DiscardUnknown()

func (*ProfileResponse) XXX_Marshal 

func (m *ProfileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProfileResponse) XXX_Merge 

func (m *ProfileResponse) XXX_Merge(src proto.Message)

func (*ProfileResponse) XXX_Size 

func (m *ProfileResponse) XXX_Size() int

func (*ProfileResponse) XXX_Unmarshal 

func (m *ProfileResponse) XXX_Unmarshal(b []byte) error

type ProfileSeries 

type ProfileSeries struct {
	Labels  []github_com_thanos_io_thanos_pkg_store_labelpb.Label `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/thanos-io/thanos/pkg/store/labelpb.Label" json:"labels"`
	Samples []Sample                                              `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
}

ProfileSeries represents samples and labels for a single time series.

func (*ProfileSeries) Descriptor 

func (*ProfileSeries) Descriptor() ([]byte, []int)

func (*ProfileSeries) Marshal 

func (m *ProfileSeries) Marshal() (dAtA []byte, err error)

func (*ProfileSeries) MarshalTo 

func (m *ProfileSeries) MarshalTo(dAtA []byte) (int, error)

func (*ProfileSeries) MarshalToSizedBuffer 

func (m *ProfileSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProfileSeries) ProtoMessage 

func (*ProfileSeries) ProtoMessage()

func (*ProfileSeries) Reset 

func (m *ProfileSeries) Reset()

func (*ProfileSeries) Size 

func (m *ProfileSeries) Size() (n int)

func (*ProfileSeries) String 

func (m *ProfileSeries) String() string

func (*ProfileSeries) Unmarshal 

func (m *ProfileSeries) Unmarshal(dAtA []byte) error

func (*ProfileSeries) XXX_DiscardUnknown 

func (m *ProfileSeries) XXX_DiscardUnknown()

func (*ProfileSeries) XXX_Marshal 

func (m *ProfileSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProfileSeries) XXX_Merge 

func (m *ProfileSeries) XXX_Merge(src proto.Message)

func (*ProfileSeries) XXX_Size 

func (m *ProfileSeries) XXX_Size() int

func (*ProfileSeries) XXX_Unmarshal 

func (m *ProfileSeries) XXX_Unmarshal(b []byte) error

type RawProfileSeries 

type RawProfileSeries struct {
	Labels []github_com_thanos_io_thanos_pkg_store_labelpb.Label `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/thanos-io/thanos/pkg/store/labelpb.Label" json:"labels"`
	Chunks []AggrChunk                                           `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
}

func (*RawProfileSeries) Descriptor 

func (*RawProfileSeries) Descriptor() ([]byte, []int)

func (*RawProfileSeries) Marshal 

func (m *RawProfileSeries) Marshal() (dAtA []byte, err error)

func (*RawProfileSeries) MarshalTo 

func (m *RawProfileSeries) MarshalTo(dAtA []byte) (int, error)

func (*RawProfileSeries) MarshalToSizedBuffer 

func (m *RawProfileSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RawProfileSeries) PromLabels 

func (m *RawProfileSeries) PromLabels() labels.Labels

PromLabels return Prometheus labels.Labels without extra allocation.

func (*RawProfileSeries) ProtoMessage 

func (*RawProfileSeries) ProtoMessage()

func (*RawProfileSeries) Reset 

func (m *RawProfileSeries) Reset()

func (*RawProfileSeries) Size 

func (m *RawProfileSeries) Size() (n int)

func (*RawProfileSeries) String 

func (m *RawProfileSeries) String() string

func (*RawProfileSeries) Unmarshal 

func (m *RawProfileSeries) Unmarshal(dAtA []byte) error

func (*RawProfileSeries) XXX_DiscardUnknown 

func (m *RawProfileSeries) XXX_DiscardUnknown()

func (*RawProfileSeries) XXX_Marshal 

func (m *RawProfileSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawProfileSeries) XXX_Merge 

func (m *RawProfileSeries) XXX_Merge(src proto.Message)

func (*RawProfileSeries) XXX_Size 

func (m *RawProfileSeries) XXX_Size() int

func (*RawProfileSeries) XXX_Unmarshal 

func (m *RawProfileSeries) XXX_Unmarshal(b []byte) error

type ReadableProfileStoreClient 

type ReadableProfileStoreClient interface {
	/// Series streams each Series (Labels and chunk/downsampling chunk) for given label matchers and time range.
	///
	/// Series should strictly stream full series after series, optionally split by time. This means that a single frame can contain
	/// partition of the single series, but once a new series is started to be streamed it means that no more data will
	/// be sent for previous one.
	/// Series has to be sorted.
	///
	/// There is no requirements on chunk sorting, however it is recommended to have chunk sorted by chunk min time.
	/// This heavily optimizes the resource usage on Querier / Federated Queries.
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (ReadableProfileStore_SeriesClient, error)
	/// Profile returns the raw bytes of the profile requested with an exact label match and exact timestamp.
	Profile(ctx context.Context, in *ProfileRequest, opts ...grpc.CallOption) (*ProfileResponse, error)
	/// LabelNames returns all label names that are available.
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)
	/// LabelValues returns all label values for given label name.
	LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
}

ReadableProfileStoreClient is the client API for ReadableProfileStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewReadableProfileStoreClient 

func NewReadableProfileStoreClient(cc *grpc.ClientConn) ReadableProfileStoreClient

type ReadableProfileStoreServer 

type ReadableProfileStoreServer interface {
	/// Series streams each Series (Labels and chunk/downsampling chunk) for given label matchers and time range.
	///
	/// Series should strictly stream full series after series, optionally split by time. This means that a single frame can contain
	/// partition of the single series, but once a new series is started to be streamed it means that no more data will
	/// be sent for previous one.
	/// Series has to be sorted.
	///
	/// There is no requirements on chunk sorting, however it is recommended to have chunk sorted by chunk min time.
	/// This heavily optimizes the resource usage on Querier / Federated Queries.
	Series(*SeriesRequest, ReadableProfileStore_SeriesServer) error
	/// Profile returns the raw bytes of the profile requested with an exact label match and exact timestamp.
	Profile(context.Context, *ProfileRequest) (*ProfileResponse, error)
	/// LabelNames returns all label names that are available.
	LabelNames(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)
	/// LabelValues returns all label values for given label name.
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
}

ReadableProfileStoreServer is the server API for ReadableProfileStore service.

type ReadableProfileStore_SeriesClient 

type ReadableProfileStore_SeriesClient interface {
	Recv() (*SeriesResponse, error)
	grpc.ClientStream
}

type ReadableProfileStore_SeriesServer 

type ReadableProfileStore_SeriesServer interface {
	Send(*SeriesResponse) error
	grpc.ServerStream
}

type Sample 

type Sample struct {
	Value     []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*Sample) Descriptor 

func (*Sample) Descriptor() ([]byte, []int)

func (*Sample) Marshal 

func (m *Sample) Marshal() (dAtA []byte, err error)

func (*Sample) MarshalTo 

func (m *Sample) MarshalTo(dAtA []byte) (int, error)

func (*Sample) MarshalToSizedBuffer 

func (m *Sample) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

func (m *Sample) Size() (n int)

func (*Sample) String 

func (m *Sample) String() string

func (*Sample) Unmarshal 

func (m *Sample) Unmarshal(dAtA []byte) error

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

func (m *Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sample) XXX_Merge 

func (m *Sample) XXX_Merge(src proto.Message)

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

func (m *Sample) XXX_Unmarshal(b []byte) error

type SelectHints 

type SelectHints struct {
	Start int64  `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End   int64  `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	Func  string `protobuf:"bytes,3,opt,name=func,proto3" json:"func,omitempty"`
}

func PbSelectHints 

func PbSelectHints(h *storage.SelectHints) *SelectHints

func (*SelectHints) Descriptor 

func (*SelectHints) Descriptor() ([]byte, []int)

func (*SelectHints) Marshal 

func (m *SelectHints) Marshal() (dAtA []byte, err error)

func (*SelectHints) MarshalTo 

func (m *SelectHints) MarshalTo(dAtA []byte) (int, error)

func (*SelectHints) MarshalToSizedBuffer 

func (m *SelectHints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SelectHints) ProtoMessage 

func (*SelectHints) ProtoMessage()

func (*SelectHints) Reset 

func (m *SelectHints) Reset()

func (*SelectHints) Size 

func (m *SelectHints) Size() (n int)

func (*SelectHints) String 

func (m *SelectHints) String() string

func (*SelectHints) Unmarshal 

func (m *SelectHints) Unmarshal(dAtA []byte) error

func (*SelectHints) XXX_DiscardUnknown 

func (m *SelectHints) XXX_DiscardUnknown()

func (*SelectHints) XXX_Marshal 

func (m *SelectHints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SelectHints) XXX_Merge 

func (m *SelectHints) XXX_Merge(src proto.Message)

func (*SelectHints) XXX_Size 

func (m *SelectHints) XXX_Size() int

func (*SelectHints) XXX_Unmarshal 

func (m *SelectHints) XXX_Unmarshal(b []byte) error

type SeriesRequest 

type SeriesRequest struct {
	MinTime     int64          `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime     int64          `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	Matchers    []LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers"`
	SkipChunks  bool           `protobuf:"varint,4,opt,name=skip_chunks,json=skipChunks,proto3" json:"skip_chunks,omitempty"`
	SelectHints *SelectHints   `protobuf:"bytes,5,opt,name=select_hints,json=selectHints,proto3" json:"select_hints,omitempty"`
}

func (*SeriesRequest) Descriptor 

func (*SeriesRequest) Descriptor() ([]byte, []int)

func (*SeriesRequest) Marshal 

func (m *SeriesRequest) Marshal() (dAtA []byte, err error)

func (*SeriesRequest) MarshalTo 

func (m *SeriesRequest) MarshalTo(dAtA []byte) (int, error)

func (*SeriesRequest) MarshalToSizedBuffer 

func (m *SeriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SeriesRequest) ProtoMessage 

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset 

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size 

func (m *SeriesRequest) Size() (n int)

func (*SeriesRequest) String 

func (m *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal 

func (m *SeriesRequest) Unmarshal(dAtA []byte) error

func (*SeriesRequest) XXX_DiscardUnknown 

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal 

func (m *SeriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SeriesRequest) XXX_Merge 

func (m *SeriesRequest) XXX_Merge(src proto.Message)

func (*SeriesRequest) XXX_Size 

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal 

func (m *SeriesRequest) XXX_Unmarshal(b []byte) error

type SeriesResponse 

type SeriesResponse struct {
	// Types that are valid to be assigned to Result:
	//	*SeriesResponse_Series
	//	*SeriesResponse_Warning
	Result isSeriesResponse_Result `protobuf_oneof:"result"`
}

func NewSeriesResponse 

func NewSeriesResponse(series *RawProfileSeries) *SeriesResponse

func NewWarnSeriesResponse 

func NewWarnSeriesResponse(err error) *SeriesResponse

func (*SeriesResponse) Descriptor 

func (*SeriesResponse) Descriptor() ([]byte, []int)

func (*SeriesResponse) GetResult 

func (m *SeriesResponse) GetResult() isSeriesResponse_Result

func (*SeriesResponse) GetSeries 

func (m *SeriesResponse) GetSeries() *RawProfileSeries

func (*SeriesResponse) GetWarning 

func (m *SeriesResponse) GetWarning() string

func (*SeriesResponse) Marshal 

func (m *SeriesResponse) Marshal() (dAtA []byte, err error)

func (*SeriesResponse) MarshalTo 

func (m *SeriesResponse) MarshalTo(dAtA []byte) (int, error)

func (*SeriesResponse) MarshalToSizedBuffer 

func (m *SeriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SeriesResponse) ProtoMessage 

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset 

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size 

func (m *SeriesResponse) Size() (n int)

func (*SeriesResponse) String 

func (m *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal 

func (m *SeriesResponse) Unmarshal(dAtA []byte) error

func (*SeriesResponse) XXX_DiscardUnknown 

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal 

func (m *SeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SeriesResponse) XXX_Merge 

func (m *SeriesResponse) XXX_Merge(src proto.Message)

func (*SeriesResponse) XXX_OneofWrappers 

func (*SeriesResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SeriesResponse) XXX_Size 

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal 

func (m *SeriesResponse) XXX_Unmarshal(b []byte) error

type SeriesResponse_Series 

type SeriesResponse_Series struct {
	Series *RawProfileSeries `protobuf:"bytes,1,opt,name=series,proto3,oneof" json:"series,omitempty"`
}

func (*SeriesResponse_Series) MarshalTo 

func (m *SeriesResponse_Series) MarshalTo(dAtA []byte) (int, error)

func (*SeriesResponse_Series) MarshalToSizedBuffer 

func (m *SeriesResponse_Series) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SeriesResponse_Series) Size 

func (m *SeriesResponse_Series) Size() (n int)

type SeriesResponse_Warning 

type SeriesResponse_Warning struct {
	Warning string `protobuf:"bytes,2,opt,name=warning,proto3,oneof" json:"warning,omitempty"`
}

func (*SeriesResponse_Warning) MarshalTo 

func (m *SeriesResponse_Warning) MarshalTo(dAtA []byte) (int, error)

func (*SeriesResponse_Warning) MarshalToSizedBuffer 

func (m *SeriesResponse_Warning) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SeriesResponse_Warning) Size 

func (m *SeriesResponse_Warning) Size() (n int)

type SeriesSet 

type SeriesSet interface {
	Next() bool
	At() (labels.Labels, []AggrChunk)
	Err() error
}

SeriesSet is a set of series and their corresponding chunks. The set is sorted by the label sets. Chunks may be overlapping or expected of order.

func EmptySeriesSet 

func EmptySeriesSet() SeriesSet

EmptySeriesSet returns a new series set that contains no series.

func MergeSeriesSets 

func MergeSeriesSets(all ...SeriesSet) SeriesSet

MergeSeriesSets takes all series sets and returns as a union single series set. It assumes series are sorted by labels within single SeriesSet, similar to remote read guarantees. However, they can be partial: in such case, if the single SeriesSet returns the same series within many iterations, MergeSeriesSets will merge those into one.

It also assumes in a "best effort" way that chunks are sorted by min time. It's done as an optimization only, so if input series' chunks are NOT sorted, the only consequence is that the duplicates might be not correctly removed. This is double checked which on just-before PromQL level as well, so the only consequence is increased network bandwidth. If all chunks were sorted, MergeSeriesSet ALSO returns sorted chunks by min time.

Chunks within the same series can also overlap (within all SeriesSet as well as single SeriesSet alone). If the chunk ranges overlap, the *exact* chunk duplicates will be removed (except one), and any other overlaps will be appended into on chunks slice.

type SymbolExistsRequest 

type SymbolExistsRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*SymbolExistsRequest) Descriptor 

func (*SymbolExistsRequest) Descriptor() ([]byte, []int)

func (*SymbolExistsRequest) Marshal 

func (m *SymbolExistsRequest) Marshal() (dAtA []byte, err error)

func (*SymbolExistsRequest) MarshalTo 

func (m *SymbolExistsRequest) MarshalTo(dAtA []byte) (int, error)

func (*SymbolExistsRequest) MarshalToSizedBuffer 

func (m *SymbolExistsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolExistsRequest) ProtoMessage 

func (*SymbolExistsRequest) ProtoMessage()

func (*SymbolExistsRequest) Reset 

func (m *SymbolExistsRequest) Reset()

func (*SymbolExistsRequest) Size 

func (m *SymbolExistsRequest) Size() (n int)

func (*SymbolExistsRequest) String 

func (m *SymbolExistsRequest) String() string

func (*SymbolExistsRequest) Unmarshal 

func (m *SymbolExistsRequest) Unmarshal(dAtA []byte) error

func (*SymbolExistsRequest) XXX_DiscardUnknown 

func (m *SymbolExistsRequest) XXX_DiscardUnknown()

func (*SymbolExistsRequest) XXX_Marshal 

func (m *SymbolExistsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SymbolExistsRequest) XXX_Merge 

func (m *SymbolExistsRequest) XXX_Merge(src proto.Message)

func (*SymbolExistsRequest) XXX_Size 

func (m *SymbolExistsRequest) XXX_Size() int

func (*SymbolExistsRequest) XXX_Unmarshal 

func (m *SymbolExistsRequest) XXX_Unmarshal(b []byte) error

type SymbolExistsResponse 

type SymbolExistsResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
}

func (*SymbolExistsResponse) Descriptor 

func (*SymbolExistsResponse) Descriptor() ([]byte, []int)

func (*SymbolExistsResponse) Marshal 

func (m *SymbolExistsResponse) Marshal() (dAtA []byte, err error)

func (*SymbolExistsResponse) MarshalTo 

func (m *SymbolExistsResponse) MarshalTo(dAtA []byte) (int, error)

func (*SymbolExistsResponse) MarshalToSizedBuffer 

func (m *SymbolExistsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolExistsResponse) ProtoMessage 

func (*SymbolExistsResponse) ProtoMessage()

func (*SymbolExistsResponse) Reset 

func (m *SymbolExistsResponse) Reset()

func (*SymbolExistsResponse) Size 

func (m *SymbolExistsResponse) Size() (n int)

func (*SymbolExistsResponse) String 

func (m *SymbolExistsResponse) String() string

func (*SymbolExistsResponse) Unmarshal 

func (m *SymbolExistsResponse) Unmarshal(dAtA []byte) error

func (*SymbolExistsResponse) XXX_DiscardUnknown 

func (m *SymbolExistsResponse) XXX_DiscardUnknown()

func (*SymbolExistsResponse) XXX_Marshal 

func (m *SymbolExistsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SymbolExistsResponse) XXX_Merge 

func (m *SymbolExistsResponse) XXX_Merge(src proto.Message)

func (*SymbolExistsResponse) XXX_Size 

func (m *SymbolExistsResponse) XXX_Size() int

func (*SymbolExistsResponse) XXX_Unmarshal 

func (m *SymbolExistsResponse) XXX_Unmarshal(b []byte) error

type SymbolStoreClient 

type SymbolStoreClient interface {
	Exists(ctx context.Context, in *SymbolExistsRequest, opts ...grpc.CallOption) (*SymbolExistsResponse, error)
	Upload(ctx context.Context, opts ...grpc.CallOption) (SymbolStore_UploadClient, error)
	Symbolize(ctx context.Context, in *SymbolizeRequest, opts ...grpc.CallOption) (*SymbolizeResponse, error)
}

SymbolStoreClient is the client API for SymbolStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSymbolStoreClient 

func NewSymbolStoreClient(cc *grpc.ClientConn) SymbolStoreClient

type SymbolStoreServer 

type SymbolStoreServer interface {
	Exists(context.Context, *SymbolExistsRequest) (*SymbolExistsResponse, error)
	Upload(SymbolStore_UploadServer) error
	Symbolize(context.Context, *SymbolizeRequest) (*SymbolizeResponse, error)
}

SymbolStoreServer is the server API for SymbolStore service.

type SymbolStore_UploadClient 

type SymbolStore_UploadClient interface {
	Send(*SymbolUploadRequest) error
	CloseAndRecv() (*SymbolUploadResponse, error)
	grpc.ClientStream
}

type SymbolStore_UploadServer 

type SymbolStore_UploadServer interface {
	SendAndClose(*SymbolUploadResponse) error
	Recv() (*SymbolUploadRequest, error)
	grpc.ServerStream
}

type SymbolUploadInfo 

type SymbolUploadInfo struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*SymbolUploadInfo) Descriptor 

func (*SymbolUploadInfo) Descriptor() ([]byte, []int)

func (*SymbolUploadInfo) Marshal 

func (m *SymbolUploadInfo) Marshal() (dAtA []byte, err error)

func (*SymbolUploadInfo) MarshalTo 

func (m *SymbolUploadInfo) MarshalTo(dAtA []byte) (int, error)

func (*SymbolUploadInfo) MarshalToSizedBuffer 

func (m *SymbolUploadInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolUploadInfo) ProtoMessage 

func (*SymbolUploadInfo) ProtoMessage()

func (*SymbolUploadInfo) Reset 

func (m *SymbolUploadInfo) Reset()

func (*SymbolUploadInfo) Size 

func (m *SymbolUploadInfo) Size() (n int)

func (*SymbolUploadInfo) String 

func (m *SymbolUploadInfo) String() string

func (*SymbolUploadInfo) Unmarshal 

func (m *SymbolUploadInfo) Unmarshal(dAtA []byte) error

func (*SymbolUploadInfo) XXX_DiscardUnknown 

func (m *SymbolUploadInfo) XXX_DiscardUnknown()

func (*SymbolUploadInfo) XXX_Marshal 

func (m *SymbolUploadInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SymbolUploadInfo) XXX_Merge 

func (m *SymbolUploadInfo) XXX_Merge(src proto.Message)

func (*SymbolUploadInfo) XXX_Size 

func (m *SymbolUploadInfo) XXX_Size() int

func (*SymbolUploadInfo) XXX_Unmarshal 

func (m *SymbolUploadInfo) XXX_Unmarshal(b []byte) error

type SymbolUploadRequest 

type SymbolUploadRequest struct {
	// Types that are valid to be assigned to Data:
	//	*SymbolUploadRequest_Info
	//	*SymbolUploadRequest_ChunkData
	Data isSymbolUploadRequest_Data `protobuf_oneof:"data"`
}

func (*SymbolUploadRequest) Descriptor 

func (*SymbolUploadRequest) Descriptor() ([]byte, []int)

func (*SymbolUploadRequest) GetChunkData 

func (m *SymbolUploadRequest) GetChunkData() []byte

func (*SymbolUploadRequest) GetData 

func (m *SymbolUploadRequest) GetData() isSymbolUploadRequest_Data

func (*SymbolUploadRequest) GetInfo 

func (m *SymbolUploadRequest) GetInfo() *SymbolUploadInfo

func (*SymbolUploadRequest) Marshal 

func (m *SymbolUploadRequest) Marshal() (dAtA []byte, err error)

func (*SymbolUploadRequest) MarshalTo 

func (m *SymbolUploadRequest) MarshalTo(dAtA []byte) (int, error)

func (*SymbolUploadRequest) MarshalToSizedBuffer 

func (m *SymbolUploadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolUploadRequest) ProtoMessage 

func (*SymbolUploadRequest) ProtoMessage()

func (*SymbolUploadRequest) Reset 

func (m *SymbolUploadRequest) Reset()

func (*SymbolUploadRequest) Size 

func (m *SymbolUploadRequest) Size() (n int)

func (*SymbolUploadRequest) String 

func (m *SymbolUploadRequest) String() string

func (*SymbolUploadRequest) Unmarshal 

func (m *SymbolUploadRequest) Unmarshal(dAtA []byte) error

func (*SymbolUploadRequest) XXX_DiscardUnknown 

func (m *SymbolUploadRequest) XXX_DiscardUnknown()

func (*SymbolUploadRequest) XXX_Marshal 

func (m *SymbolUploadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SymbolUploadRequest) XXX_Merge 

func (m *SymbolUploadRequest) XXX_Merge(src proto.Message)

func (*SymbolUploadRequest) XXX_OneofWrappers 

func (*SymbolUploadRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SymbolUploadRequest) XXX_Size 

func (m *SymbolUploadRequest) XXX_Size() int

func (*SymbolUploadRequest) XXX_Unmarshal 

func (m *SymbolUploadRequest) XXX_Unmarshal(b []byte) error

type SymbolUploadRequest_ChunkData 

type SymbolUploadRequest_ChunkData struct {
	ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3,oneof" json:"chunk_data,omitempty"`
}

func (*SymbolUploadRequest_ChunkData) MarshalTo 

func (m *SymbolUploadRequest_ChunkData) MarshalTo(dAtA []byte) (int, error)

func (*SymbolUploadRequest_ChunkData) MarshalToSizedBuffer 

func (m *SymbolUploadRequest_ChunkData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolUploadRequest_ChunkData) Size 

func (m *SymbolUploadRequest_ChunkData) Size() (n int)

type SymbolUploadRequest_Info 

type SymbolUploadRequest_Info struct {
	Info *SymbolUploadInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof" json:"info,omitempty"`
}

func (*SymbolUploadRequest_Info) MarshalTo 

func (m *SymbolUploadRequest_Info) MarshalTo(dAtA []byte) (int, error)

func (*SymbolUploadRequest_Info) MarshalToSizedBuffer 

func (m *SymbolUploadRequest_Info) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolUploadRequest_Info) Size 

func (m *SymbolUploadRequest_Info) Size() (n int)

type SymbolUploadResponse 

type SymbolUploadResponse struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Size_ uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
}

func (*SymbolUploadResponse) Descriptor 

func (*SymbolUploadResponse) Descriptor() ([]byte, []int)

func (*SymbolUploadResponse) Marshal 

func (m *SymbolUploadResponse) Marshal() (dAtA []byte, err error)

func (*SymbolUploadResponse) MarshalTo 

func (m *SymbolUploadResponse) MarshalTo(dAtA []byte) (int, error)

func (*SymbolUploadResponse) MarshalToSizedBuffer 

func (m *SymbolUploadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolUploadResponse) ProtoMessage 

func (*SymbolUploadResponse) ProtoMessage()

func (*SymbolUploadResponse) Reset 

func (m *SymbolUploadResponse) Reset()

func (*SymbolUploadResponse) Size 

func (m *SymbolUploadResponse) Size() (n int)

func (*SymbolUploadResponse) String 

func (m *SymbolUploadResponse) String() string

func (*SymbolUploadResponse) Unmarshal 

func (m *SymbolUploadResponse) Unmarshal(dAtA []byte) error

func (*SymbolUploadResponse) XXX_DiscardUnknown 

func (m *SymbolUploadResponse) XXX_DiscardUnknown()

func (*SymbolUploadResponse) XXX_Marshal 

func (m *SymbolUploadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SymbolUploadResponse) XXX_Merge 

func (m *SymbolUploadResponse) XXX_Merge(src proto.Message)

func (*SymbolUploadResponse) XXX_Size 

func (m *SymbolUploadResponse) XXX_Size() int

func (*SymbolUploadResponse) XXX_Unmarshal 

func (m *SymbolUploadResponse) XXX_Unmarshal(b []byte) error

type SymbolizeClient 

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

func NewSymbolizeClient 

func NewSymbolizeClient(conn *grpc.ClientConn) *SymbolizeClient

func (*SymbolizeClient) Symbolize 

func (c *SymbolizeClient) Symbolize(ctx context.Context, r *SymbolizeRequest) (*SymbolizeResponse, error)

type SymbolizeRequest 

type SymbolizeRequest struct {
	Mappings []*Mapping `protobuf:"bytes,1,rep,name=mappings,proto3" json:"mappings,omitempty"`
}

func (*SymbolizeRequest) Descriptor 

func (*SymbolizeRequest) Descriptor() ([]byte, []int)

func (*SymbolizeRequest) Marshal 

func (m *SymbolizeRequest) Marshal() (dAtA []byte, err error)

func (*SymbolizeRequest) MarshalTo 

func (m *SymbolizeRequest) MarshalTo(dAtA []byte) (int, error)

func (*SymbolizeRequest) MarshalToSizedBuffer 

func (m *SymbolizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolizeRequest) ProtoMessage 

func (*SymbolizeRequest) ProtoMessage()

func (*SymbolizeRequest) Reset 

func (m *SymbolizeRequest) Reset()

func (*SymbolizeRequest) Size 

func (m *SymbolizeRequest) Size() (n int)

func (*SymbolizeRequest) String 

func (m *SymbolizeRequest) String() string

func (*SymbolizeRequest) Unmarshal 

func (m *SymbolizeRequest) Unmarshal(dAtA []byte) error

func (*SymbolizeRequest) XXX_DiscardUnknown 

func (m *SymbolizeRequest) XXX_DiscardUnknown()

func (*SymbolizeRequest) XXX_Marshal 

func (m *SymbolizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SymbolizeRequest) XXX_Merge 

func (m *SymbolizeRequest) XXX_Merge(src proto.Message)

func (*SymbolizeRequest) XXX_Size 

func (m *SymbolizeRequest) XXX_Size() int

func (*SymbolizeRequest) XXX_Unmarshal 

func (m *SymbolizeRequest) XXX_Unmarshal(b []byte) error

type SymbolizeResponse 

type SymbolizeResponse struct {
	Mappings []*Mapping `protobuf:"bytes,1,rep,name=mappings,proto3" json:"mappings,omitempty"`
}

func (*SymbolizeResponse) Descriptor 

func (*SymbolizeResponse) Descriptor() ([]byte, []int)

func (*SymbolizeResponse) Marshal 

func (m *SymbolizeResponse) Marshal() (dAtA []byte, err error)

func (*SymbolizeResponse) MarshalTo 

func (m *SymbolizeResponse) MarshalTo(dAtA []byte) (int, error)

func (*SymbolizeResponse) MarshalToSizedBuffer 

func (m *SymbolizeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SymbolizeResponse) ProtoMessage 

func (*SymbolizeResponse) ProtoMessage()

func (*SymbolizeResponse) Reset 

func (m *SymbolizeResponse) Reset()

func (*SymbolizeResponse) Size 

func (m *SymbolizeResponse) Size() (n int)

func (*SymbolizeResponse) String 

func (m *SymbolizeResponse) String() string

func (*SymbolizeResponse) Unmarshal 

func (m *SymbolizeResponse) Unmarshal(dAtA []byte) error

func (*SymbolizeResponse) XXX_DiscardUnknown 

func (m *SymbolizeResponse) XXX_DiscardUnknown()

func (*SymbolizeResponse) XXX_Marshal 

func (m *SymbolizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SymbolizeResponse) XXX_Merge 

func (m *SymbolizeResponse) XXX_Merge(src proto.Message)

func (*SymbolizeResponse) XXX_Size 

func (m *SymbolizeResponse) XXX_Size() int

func (*SymbolizeResponse) XXX_Unmarshal 

func (m *SymbolizeResponse) XXX_Unmarshal(b []byte) error

type UnimplementedReadableProfileStoreServer 

type UnimplementedReadableProfileStoreServer struct {
}

UnimplementedReadableProfileStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedReadableProfileStoreServer) LabelNames 

func (*UnimplementedReadableProfileStoreServer) LabelNames(ctx context.Context, req *LabelNamesRequest) (*LabelNamesResponse, error)

func (*UnimplementedReadableProfileStoreServer) LabelValues 

func (*UnimplementedReadableProfileStoreServer) LabelValues(ctx context.Context, req *LabelValuesRequest) (*LabelValuesResponse, error)

func (*UnimplementedReadableProfileStoreServer) Profile 

func (*UnimplementedReadableProfileStoreServer) Profile(ctx context.Context, req *ProfileRequest) (*ProfileResponse, error)

func (*UnimplementedReadableProfileStoreServer) Series 

func (*UnimplementedReadableProfileStoreServer) Series(req *SeriesRequest, srv ReadableProfileStore_SeriesServer) error

type UnimplementedSymbolStoreServer 

type UnimplementedSymbolStoreServer struct {
}

UnimplementedSymbolStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedSymbolStoreServer) Exists 

func (*UnimplementedSymbolStoreServer) Exists(ctx context.Context, req *SymbolExistsRequest) (*SymbolExistsResponse, error)

func (*UnimplementedSymbolStoreServer) Symbolize 

func (*UnimplementedSymbolStoreServer) Symbolize(ctx context.Context, req *SymbolizeRequest) (*SymbolizeResponse, error)

func (*UnimplementedSymbolStoreServer) Upload 

func (*UnimplementedSymbolStoreServer) Upload(srv SymbolStore_UploadServer) error

type UnimplementedWritableProfileStoreServer 

type UnimplementedWritableProfileStoreServer struct {
}

UnimplementedWritableProfileStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedWritableProfileStoreServer) Write 

func (*UnimplementedWritableProfileStoreServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)

type WritableProfileStoreClient 

type WritableProfileStoreClient interface {
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
}

WritableProfileStoreClient is the client API for WritableProfileStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWritableProfileStoreClient 

func NewWritableProfileStoreClient(cc *grpc.ClientConn) WritableProfileStoreClient

type WritableProfileStoreServer 

type WritableProfileStoreServer interface {
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
}

WritableProfileStoreServer is the server API for WritableProfileStore service.

type WriteRequest 

type WriteRequest struct {
	ProfileSeries []ProfileSeries `protobuf:"bytes,1,rep,name=profileSeries,proto3" json:"profileSeries"`
	Tenant        string          `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
}

func (*WriteRequest) Descriptor 

func (*WriteRequest) Descriptor() ([]byte, []int)

func (*WriteRequest) Marshal 

func (m *WriteRequest) Marshal() (dAtA []byte, err error)

func (*WriteRequest) MarshalTo 

func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)

func (*WriteRequest) MarshalToSizedBuffer 

func (m *WriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

func (m *WriteRequest) Size() (n int)

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

func (m *WriteRequest) Unmarshal(dAtA []byte) error

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRequest) XXX_Merge 

func (m *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

func (m *WriteRequest) XXX_Unmarshal(b []byte) error

type WriteResponse 

type WriteResponse struct {
}

func (*WriteResponse) Descriptor 

func (*WriteResponse) Descriptor() ([]byte, []int)

func (*WriteResponse) Marshal 

func (m *WriteResponse) Marshal() (dAtA []byte, err error)

func (*WriteResponse) MarshalTo 

func (m *WriteResponse) MarshalTo(dAtA []byte) (int, error)

func (*WriteResponse) MarshalToSizedBuffer 

func (m *WriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

func (m *WriteResponse) Size() (n int)

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

func (m *WriteResponse) Unmarshal(dAtA []byte) error

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteResponse) XXX_Merge 

func (m *WriteResponse) XXX_Merge(src proto.Message)

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

func (m *WriteResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.