dataset_profile

package
v0.5.4-0...-f651017 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ChunkHeader_ChunkType_name = map[int32]string{
	0: "DATASET",
	2: "COLUMN",
}
View Source
var ChunkHeader_ChunkType_value = map[string]int32{
	"DATASET": 0,
	"COLUMN":  2,
}
View Source
var DataType_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "NULL",
	2: "FRACTIONAL",
	3: "INTEGRAL",
	4: "BOOLEAN",
	5: "STRING",
}
View Source
var DataType_Type_value = map[string]int32{
	"UNKNOWN":    0,
	"NULL":       1,
	"FRACTIONAL": 2,
	"INTEGRAL":   3,
	"BOOLEAN":    4,
	"STRING":     5,
}

Functions

This section is empty.

Types

type ChunkHeader

type ChunkHeader struct {
	Type                 ChunkHeader_ChunkType `protobuf:"varint,1,opt,name=type,proto3,enum=dataset_profile.ChunkHeader_ChunkType" json:"type,omitempty"`
	Tag                  string                `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	Length               uint32                `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ChunkHeader) Descriptor

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

func (*ChunkHeader) GetLength

func (m *ChunkHeader) GetLength() uint32

func (*ChunkHeader) GetTag

func (m *ChunkHeader) GetTag() string

func (*ChunkHeader) GetType

func (m *ChunkHeader) GetType() ChunkHeader_ChunkType

func (*ChunkHeader) ProtoMessage

func (*ChunkHeader) ProtoMessage()

func (*ChunkHeader) Reset

func (m *ChunkHeader) Reset()

func (*ChunkHeader) String

func (m *ChunkHeader) String() string

func (*ChunkHeader) XXX_DiscardUnknown

func (m *ChunkHeader) XXX_DiscardUnknown()

func (*ChunkHeader) XXX_Marshal

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

func (*ChunkHeader) XXX_Merge

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

func (*ChunkHeader) XXX_Size

func (m *ChunkHeader) XXX_Size() int

func (*ChunkHeader) XXX_Unmarshal

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

type ChunkHeader_ChunkType

type ChunkHeader_ChunkType int32
const (
	ChunkHeader_DATASET ChunkHeader_ChunkType = 0
	ChunkHeader_COLUMN  ChunkHeader_ChunkType = 2
)

func (ChunkHeader_ChunkType) EnumDescriptor

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

func (ChunkHeader_ChunkType) String

func (x ChunkHeader_ChunkType) String() string

type ChunkMessage

type ChunkMessage struct {
	MetricComponents     map[uint32]*MetricComponentMessage `` /* 198-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*ChunkMessage) Descriptor

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

func (*ChunkMessage) GetMetricComponents

func (m *ChunkMessage) GetMetricComponents() map[uint32]*MetricComponentMessage

func (*ChunkMessage) ProtoMessage

func (*ChunkMessage) ProtoMessage()

func (*ChunkMessage) Reset

func (m *ChunkMessage) Reset()

func (*ChunkMessage) String

func (m *ChunkMessage) String() string

func (*ChunkMessage) XXX_DiscardUnknown

func (m *ChunkMessage) XXX_DiscardUnknown()

func (*ChunkMessage) XXX_Marshal

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

func (*ChunkMessage) XXX_Merge

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

func (*ChunkMessage) XXX_Size

func (m *ChunkMessage) XXX_Size() int

func (*ChunkMessage) XXX_Unmarshal

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

type ChunkOffsets

type ChunkOffsets struct {
	Offsets              []uint64 `protobuf:"varint,1,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChunkOffsets) Descriptor

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

func (*ChunkOffsets) GetOffsets

func (m *ChunkOffsets) GetOffsets() []uint64

func (*ChunkOffsets) ProtoMessage

func (*ChunkOffsets) ProtoMessage()

func (*ChunkOffsets) Reset

func (m *ChunkOffsets) Reset()

func (*ChunkOffsets) String

func (m *ChunkOffsets) String() string

func (*ChunkOffsets) XXX_DiscardUnknown

func (m *ChunkOffsets) XXX_DiscardUnknown()

func (*ChunkOffsets) XXX_Marshal

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

func (*ChunkOffsets) XXX_Merge

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

func (*ChunkOffsets) XXX_Size

func (m *ChunkOffsets) XXX_Size() int

func (*ChunkOffsets) XXX_Unmarshal

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

type ColumnMessage

type ColumnMessage struct {
	MetricComponents     map[string]*MetricComponentMessage `` /* 197-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*ColumnMessage) Descriptor

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

func (*ColumnMessage) GetMetricComponents

func (m *ColumnMessage) GetMetricComponents() map[string]*MetricComponentMessage

func (*ColumnMessage) ProtoMessage

func (*ColumnMessage) ProtoMessage()

func (*ColumnMessage) Reset

func (m *ColumnMessage) Reset()

func (*ColumnMessage) String

func (m *ColumnMessage) String() string

func (*ColumnMessage) XXX_DiscardUnknown

func (m *ColumnMessage) XXX_DiscardUnknown()

func (*ColumnMessage) XXX_Marshal

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

func (*ColumnMessage) XXX_Merge

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

func (*ColumnMessage) XXX_Size

func (m *ColumnMessage) XXX_Size() int

func (*ColumnMessage) XXX_Unmarshal

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

type CpcSketchMessage

type CpcSketchMessage struct {
	Sketch               []byte   `protobuf:"bytes,1,opt,name=sketch,proto3" json:"sketch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CpcSketchMessage) Descriptor

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

func (*CpcSketchMessage) GetSketch

func (m *CpcSketchMessage) GetSketch() []byte

func (*CpcSketchMessage) ProtoMessage

func (*CpcSketchMessage) ProtoMessage()

func (*CpcSketchMessage) Reset

func (m *CpcSketchMessage) Reset()

func (*CpcSketchMessage) String

func (m *CpcSketchMessage) String() string

func (*CpcSketchMessage) XXX_DiscardUnknown

func (m *CpcSketchMessage) XXX_DiscardUnknown()

func (*CpcSketchMessage) XXX_Marshal

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

func (*CpcSketchMessage) XXX_Merge

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

func (*CpcSketchMessage) XXX_Size

func (m *CpcSketchMessage) XXX_Size() int

func (*CpcSketchMessage) XXX_Unmarshal

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

type DataType

type DataType struct {
	Type                 DataType_Type `protobuf:"varint,1,opt,name=type,proto3,enum=dataset_profile.DataType_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DataType) Descriptor

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

func (*DataType) GetType

func (m *DataType) GetType() DataType_Type

func (*DataType) ProtoMessage

func (*DataType) ProtoMessage()

func (*DataType) Reset

func (m *DataType) Reset()

func (*DataType) String

func (m *DataType) String() string

func (*DataType) XXX_DiscardUnknown

func (m *DataType) XXX_DiscardUnknown()

func (*DataType) XXX_Marshal

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

func (*DataType) XXX_Merge

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

func (*DataType) XXX_Size

func (m *DataType) XXX_Size() int

func (*DataType) XXX_Unmarshal

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

type DataType_Type

type DataType_Type int32
const (
	DataType_UNKNOWN    DataType_Type = 0
	DataType_NULL       DataType_Type = 1
	DataType_FRACTIONAL DataType_Type = 2
	DataType_INTEGRAL   DataType_Type = 3
	DataType_BOOLEAN    DataType_Type = 4
	DataType_STRING     DataType_Type = 5
)

func (DataType_Type) EnumDescriptor

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

func (DataType_Type) String

func (x DataType_Type) String() string

type DatasetProfile

type DatasetProfile struct {
	// When the profile was calculated.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The number of examples in this dataset.
	NumExamples int64 `protobuf:"varint,2,opt,name=num_examples,json=numExamples,proto3" json:"num_examples,omitempty"`
	// The total size of this dataset in bytes.
	SizeBytes int64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// Map of feature name to FeatureProfile.
	FeatureProfiles      map[string]*FeatureProfile `` /* 195-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Dataset profile represents a collection of in-memory profiling stats for a dataset. Used for recommending Ludwig configs and Ludwig data type inference.

func (*DatasetProfile) Descriptor

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

func (*DatasetProfile) GetFeatureProfiles

func (m *DatasetProfile) GetFeatureProfiles() map[string]*FeatureProfile

func (*DatasetProfile) GetNumExamples

func (m *DatasetProfile) GetNumExamples() int64

func (*DatasetProfile) GetSizeBytes

func (m *DatasetProfile) GetSizeBytes() int64

func (*DatasetProfile) GetTimestamp

func (m *DatasetProfile) GetTimestamp() int64

func (*DatasetProfile) ProtoMessage

func (*DatasetProfile) ProtoMessage()

func (*DatasetProfile) Reset

func (m *DatasetProfile) Reset()

func (*DatasetProfile) String

func (m *DatasetProfile) String() string

func (*DatasetProfile) XXX_DiscardUnknown

func (m *DatasetProfile) XXX_DiscardUnknown()

func (*DatasetProfile) XXX_Marshal

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

func (*DatasetProfile) XXX_Merge

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

func (*DatasetProfile) XXX_Size

func (m *DatasetProfile) XXX_Size() int

func (*DatasetProfile) XXX_Unmarshal

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

type DatasetProfileHeader

type DatasetProfileHeader struct {
	Properties           *DatasetProperties       `protobuf:"bytes,1,opt,name=properties,proto3" json:"properties,omitempty"`
	ColumnOffsets        map[string]*ChunkOffsets `` /* 188-byte string literal not displayed */
	MetricOffsets        []*ChunkOffsets          `protobuf:"bytes,3,rep,name=metric_offsets,json=metricOffsets,proto3" json:"metric_offsets,omitempty"`
	Length               uint64                   `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	IndexedMetricPaths   map[uint32]string        `` /* 206-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*DatasetProfileHeader) Descriptor

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

func (*DatasetProfileHeader) GetColumnOffsets

func (m *DatasetProfileHeader) GetColumnOffsets() map[string]*ChunkOffsets

func (*DatasetProfileHeader) GetIndexedMetricPaths

func (m *DatasetProfileHeader) GetIndexedMetricPaths() map[uint32]string

func (*DatasetProfileHeader) GetLength

func (m *DatasetProfileHeader) GetLength() uint64

func (*DatasetProfileHeader) GetMetricOffsets

func (m *DatasetProfileHeader) GetMetricOffsets() []*ChunkOffsets

func (*DatasetProfileHeader) GetProperties

func (m *DatasetProfileHeader) GetProperties() *DatasetProperties

func (*DatasetProfileHeader) ProtoMessage

func (*DatasetProfileHeader) ProtoMessage()

func (*DatasetProfileHeader) Reset

func (m *DatasetProfileHeader) Reset()

func (*DatasetProfileHeader) String

func (m *DatasetProfileHeader) String() string

func (*DatasetProfileHeader) XXX_DiscardUnknown

func (m *DatasetProfileHeader) XXX_DiscardUnknown()

func (*DatasetProfileHeader) XXX_Marshal

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

func (*DatasetProfileHeader) XXX_Merge

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

func (*DatasetProfileHeader) XXX_Size

func (m *DatasetProfileHeader) XXX_Size() int

func (*DatasetProfileHeader) XXX_Unmarshal

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

type DatasetProperties

type DatasetProperties struct {
	SchemaMajorVersion   uint32            `protobuf:"varint,1,opt,name=schema_major_version,json=schemaMajorVersion,proto3" json:"schema_major_version,omitempty"`
	SchemaMinorVersion   uint32            `protobuf:"varint,2,opt,name=schema_minor_version,json=schemaMinorVersion,proto3" json:"schema_minor_version,omitempty"`
	CreationTimestamp    uint64            `protobuf:"varint,4,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	DatasetTimestamp     uint64            `protobuf:"varint,5,opt,name=dataset_timestamp,json=datasetTimestamp,proto3" json:"dataset_timestamp,omitempty"`
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DatasetProperties) Descriptor

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

func (*DatasetProperties) GetCreationTimestamp

func (m *DatasetProperties) GetCreationTimestamp() uint64

func (*DatasetProperties) GetDatasetTimestamp

func (m *DatasetProperties) GetDatasetTimestamp() uint64

func (*DatasetProperties) GetMetadata

func (m *DatasetProperties) GetMetadata() map[string]string

func (*DatasetProperties) GetSchemaMajorVersion

func (m *DatasetProperties) GetSchemaMajorVersion() uint32

func (*DatasetProperties) GetSchemaMinorVersion

func (m *DatasetProperties) GetSchemaMinorVersion() uint32

func (*DatasetProperties) GetTags

func (m *DatasetProperties) GetTags() map[string]string

func (*DatasetProperties) ProtoMessage

func (*DatasetProperties) ProtoMessage()

func (*DatasetProperties) Reset

func (m *DatasetProperties) Reset()

func (*DatasetProperties) String

func (m *DatasetProperties) String() string

func (*DatasetProperties) XXX_DiscardUnknown

func (m *DatasetProperties) XXX_DiscardUnknown()

func (*DatasetProperties) XXX_Marshal

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

func (*DatasetProperties) XXX_Merge

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

func (*DatasetProperties) XXX_Size

func (m *DatasetProperties) XXX_Size() int

func (*DatasetProperties) XXX_Unmarshal

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

type DatasetSegmentHeader

type DatasetSegmentHeader struct {
	// whether the file contains segmented data or not
	HasSegments bool `protobuf:"varint,1,opt,name=has_segments,json=hasSegments,proto3" json:"has_segments,omitempty"`
	// list of segments
	Segments []*Segment `protobuf:"bytes,4,rep,name=segments,proto3" json:"segments,omitempty"`
	// we want the indices of the map of offsets to have static size, and thus we use fixed32 bytes
	Offsets              map[uint32]uint64 `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DatasetSegmentHeader) Descriptor

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

func (*DatasetSegmentHeader) GetHasSegments

func (m *DatasetSegmentHeader) GetHasSegments() bool

func (*DatasetSegmentHeader) GetOffsets

func (m *DatasetSegmentHeader) GetOffsets() map[uint32]uint64

func (*DatasetSegmentHeader) GetSegments

func (m *DatasetSegmentHeader) GetSegments() []*Segment

func (*DatasetSegmentHeader) ProtoMessage

func (*DatasetSegmentHeader) ProtoMessage()

func (*DatasetSegmentHeader) Reset

func (m *DatasetSegmentHeader) Reset()

func (*DatasetSegmentHeader) String

func (m *DatasetSegmentHeader) String() string

func (*DatasetSegmentHeader) XXX_DiscardUnknown

func (m *DatasetSegmentHeader) XXX_DiscardUnknown()

func (*DatasetSegmentHeader) XXX_Marshal

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

func (*DatasetSegmentHeader) XXX_Merge

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

func (*DatasetSegmentHeader) XXX_Size

func (m *DatasetSegmentHeader) XXX_Size() int

func (*DatasetSegmentHeader) XXX_Unmarshal

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

type FeatureProfile

type FeatureProfile struct {
	// Whylogs metrics.
	// optional whylogs.ColumnMessage whylogs_metrics = 1;
	WhylogsMetrics       *ColumnMessage `protobuf:"bytes,1,opt,name=whylogs_metrics,json=whylogsMetrics,proto3" json:"whylogs_metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Feature profile represents a collection of in-memory profiling stats for a single feature column.

func (*FeatureProfile) Descriptor

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

func (*FeatureProfile) GetWhylogsMetrics

func (m *FeatureProfile) GetWhylogsMetrics() *ColumnMessage

func (*FeatureProfile) ProtoMessage

func (*FeatureProfile) ProtoMessage()

func (*FeatureProfile) Reset

func (m *FeatureProfile) Reset()

func (*FeatureProfile) String

func (m *FeatureProfile) String() string

func (*FeatureProfile) XXX_DiscardUnknown

func (m *FeatureProfile) XXX_DiscardUnknown()

func (*FeatureProfile) XXX_Marshal

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

func (*FeatureProfile) XXX_Merge

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

func (*FeatureProfile) XXX_Size

func (m *FeatureProfile) XXX_Size() int

func (*FeatureProfile) XXX_Unmarshal

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

type FrequentItemsSketchMessage

type FrequentItemsSketchMessage struct {
	Sketch               []byte   `protobuf:"bytes,1,opt,name=sketch,proto3" json:"sketch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FrequentItemsSketchMessage) Descriptor

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

func (*FrequentItemsSketchMessage) GetSketch

func (m *FrequentItemsSketchMessage) GetSketch() []byte

func (*FrequentItemsSketchMessage) ProtoMessage

func (*FrequentItemsSketchMessage) ProtoMessage()

func (*FrequentItemsSketchMessage) Reset

func (m *FrequentItemsSketchMessage) Reset()

func (*FrequentItemsSketchMessage) String

func (m *FrequentItemsSketchMessage) String() string

func (*FrequentItemsSketchMessage) XXX_DiscardUnknown

func (m *FrequentItemsSketchMessage) XXX_DiscardUnknown()

func (*FrequentItemsSketchMessage) XXX_Marshal

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

func (*FrequentItemsSketchMessage) XXX_Merge

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

func (*FrequentItemsSketchMessage) XXX_Size

func (m *FrequentItemsSketchMessage) XXX_Size() int

func (*FrequentItemsSketchMessage) XXX_Unmarshal

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

type HllSketchMessage

type HllSketchMessage struct {
	Sketch               []byte   `protobuf:"bytes,1,opt,name=sketch,proto3" json:"sketch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HllSketchMessage) Descriptor

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

func (*HllSketchMessage) GetSketch

func (m *HllSketchMessage) GetSketch() []byte

func (*HllSketchMessage) ProtoMessage

func (*HllSketchMessage) ProtoMessage()

func (*HllSketchMessage) Reset

func (m *HllSketchMessage) Reset()

func (*HllSketchMessage) String

func (m *HllSketchMessage) String() string

func (*HllSketchMessage) XXX_DiscardUnknown

func (m *HllSketchMessage) XXX_DiscardUnknown()

func (*HllSketchMessage) XXX_Marshal

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

func (*HllSketchMessage) XXX_Merge

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

func (*HllSketchMessage) XXX_Size

func (m *HllSketchMessage) XXX_Size() int

func (*HllSketchMessage) XXX_Unmarshal

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

type KllSketchMessage

type KllSketchMessage struct {
	Sketch               []byte   `protobuf:"bytes,1,opt,name=sketch,proto3" json:"sketch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KllSketchMessage) Descriptor

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

func (*KllSketchMessage) GetSketch

func (m *KllSketchMessage) GetSketch() []byte

func (*KllSketchMessage) ProtoMessage

func (*KllSketchMessage) ProtoMessage()

func (*KllSketchMessage) Reset

func (m *KllSketchMessage) Reset()

func (*KllSketchMessage) String

func (m *KllSketchMessage) String() string

func (*KllSketchMessage) XXX_DiscardUnknown

func (m *KllSketchMessage) XXX_DiscardUnknown()

func (*KllSketchMessage) XXX_Marshal

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

func (*KllSketchMessage) XXX_Merge

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

func (*KllSketchMessage) XXX_Size

func (m *KllSketchMessage) XXX_Size() int

func (*KllSketchMessage) XXX_Unmarshal

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

type MetricComponentMessage

type MetricComponentMessage struct {
	TypeId uint32 `protobuf:"varint,1,opt,name=type_id,json=typeId,proto3" json:"type_id,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*MetricComponentMessage_N
	//	*MetricComponentMessage_D
	//	*MetricComponentMessage_FrequentItems
	//	*MetricComponentMessage_Hll
	//	*MetricComponentMessage_Kll
	//	*MetricComponentMessage_Cpc
	//	*MetricComponentMessage_SerializedBytes
	//	*MetricComponentMessage_DataclassParam
	//	*MetricComponentMessage_Msg
	Value                isMetricComponentMessage_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*MetricComponentMessage) Descriptor

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

func (*MetricComponentMessage) GetCpc

func (*MetricComponentMessage) GetD

func (m *MetricComponentMessage) GetD() float64

func (*MetricComponentMessage) GetDataclassParam

func (m *MetricComponentMessage) GetDataclassParam() *_struct.Struct

func (*MetricComponentMessage) GetFrequentItems

func (m *MetricComponentMessage) GetFrequentItems() *FrequentItemsSketchMessage

func (*MetricComponentMessage) GetHll

func (*MetricComponentMessage) GetKll

func (*MetricComponentMessage) GetMsg

func (m *MetricComponentMessage) GetMsg() *any.Any

func (*MetricComponentMessage) GetN

func (m *MetricComponentMessage) GetN() int64

func (*MetricComponentMessage) GetSerializedBytes

func (m *MetricComponentMessage) GetSerializedBytes() []byte

func (*MetricComponentMessage) GetTypeId

func (m *MetricComponentMessage) GetTypeId() uint32

func (*MetricComponentMessage) GetValue

func (m *MetricComponentMessage) GetValue() isMetricComponentMessage_Value

func (*MetricComponentMessage) ProtoMessage

func (*MetricComponentMessage) ProtoMessage()

func (*MetricComponentMessage) Reset

func (m *MetricComponentMessage) Reset()

func (*MetricComponentMessage) String

func (m *MetricComponentMessage) String() string

func (*MetricComponentMessage) XXX_DiscardUnknown

func (m *MetricComponentMessage) XXX_DiscardUnknown()

func (*MetricComponentMessage) XXX_Marshal

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

func (*MetricComponentMessage) XXX_Merge

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

func (*MetricComponentMessage) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MetricComponentMessage) XXX_Size

func (m *MetricComponentMessage) XXX_Size() int

func (*MetricComponentMessage) XXX_Unmarshal

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

type MetricComponentMessage_Cpc

type MetricComponentMessage_Cpc struct {
	Cpc *CpcSketchMessage `protobuf:"bytes,7,opt,name=cpc,proto3,oneof"`
}

type MetricComponentMessage_D

type MetricComponentMessage_D struct {
	D float64 `protobuf:"fixed64,3,opt,name=d,proto3,oneof"`
}

type MetricComponentMessage_DataclassParam

type MetricComponentMessage_DataclassParam struct {
	DataclassParam *_struct.Struct `protobuf:"bytes,11,opt,name=dataclass_param,json=dataclassParam,proto3,oneof"`
}

type MetricComponentMessage_FrequentItems

type MetricComponentMessage_FrequentItems struct {
	FrequentItems *FrequentItemsSketchMessage `protobuf:"bytes,4,opt,name=frequent_items,json=frequentItems,proto3,oneof"`
}

type MetricComponentMessage_Hll

type MetricComponentMessage_Hll struct {
	Hll *HllSketchMessage `protobuf:"bytes,5,opt,name=hll,proto3,oneof"`
}

type MetricComponentMessage_Kll

type MetricComponentMessage_Kll struct {
	Kll *KllSketchMessage `protobuf:"bytes,6,opt,name=kll,proto3,oneof"`
}

type MetricComponentMessage_Msg

type MetricComponentMessage_Msg struct {
	Msg *any.Any `protobuf:"bytes,12,opt,name=msg,proto3,oneof"`
}

type MetricComponentMessage_N

type MetricComponentMessage_N struct {
	N int64 `protobuf:"varint,2,opt,name=n,proto3,oneof"`
}

type MetricComponentMessage_SerializedBytes

type MetricComponentMessage_SerializedBytes struct {
	SerializedBytes []byte `protobuf:"bytes,10,opt,name=serialized_bytes,json=serializedBytes,proto3,oneof"`
}

type MetricMessage

type MetricMessage struct {
	MetricComponents     map[string]*MetricComponentMessage `` /* 197-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*MetricMessage) Descriptor

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

func (*MetricMessage) GetMetricComponents

func (m *MetricMessage) GetMetricComponents() map[string]*MetricComponentMessage

func (*MetricMessage) ProtoMessage

func (*MetricMessage) ProtoMessage()

func (*MetricMessage) Reset

func (m *MetricMessage) Reset()

func (*MetricMessage) String

func (m *MetricMessage) String() string

func (*MetricMessage) XXX_DiscardUnknown

func (m *MetricMessage) XXX_DiscardUnknown()

func (*MetricMessage) XXX_Marshal

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

func (*MetricMessage) XXX_Merge

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

func (*MetricMessage) XXX_Size

func (m *MetricMessage) XXX_Size() int

func (*MetricMessage) XXX_Unmarshal

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

type Segment

type Segment struct {
	Tags                 []*SegmentTag `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Segment) Descriptor

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

func (*Segment) GetTags

func (m *Segment) GetTags() []*SegmentTag

func (*Segment) ProtoMessage

func (*Segment) ProtoMessage()

func (*Segment) Reset

func (m *Segment) Reset()

func (*Segment) String

func (m *Segment) String() string

func (*Segment) XXX_DiscardUnknown

func (m *Segment) XXX_DiscardUnknown()

func (*Segment) XXX_Marshal

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

func (*Segment) XXX_Merge

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

func (*Segment) XXX_Size

func (m *Segment) XXX_Size() int

func (*Segment) XXX_Unmarshal

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

type SegmentTag

type SegmentTag struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SegmentTag) Descriptor

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

func (*SegmentTag) GetKey

func (m *SegmentTag) GetKey() string

func (*SegmentTag) GetValue

func (m *SegmentTag) GetValue() string

func (*SegmentTag) ProtoMessage

func (*SegmentTag) ProtoMessage()

func (*SegmentTag) Reset

func (m *SegmentTag) Reset()

func (*SegmentTag) String

func (m *SegmentTag) String() string

func (*SegmentTag) XXX_DiscardUnknown

func (m *SegmentTag) XXX_DiscardUnknown()

func (*SegmentTag) XXX_Marshal

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

func (*SegmentTag) XXX_Merge

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

func (*SegmentTag) XXX_Size

func (m *SegmentTag) XXX_Size() int

func (*SegmentTag) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL