Documentation ¶
Index ¶
- Constants
- func Marshal(value model.Value, layout Layout, format Format) ([]byte, error)
- func MarshalSlice(values []model.Value, layout Layout, format Format) ([]byte, error)
- func ParquetSchemaFor(data map[string]interface{}) (string, error)
- type FlattenedSampleDump
- type FlattenedSampleDumps
- type Format
- type Layout
- type Marshaler
- type SampleDump
- type SampleDumps
- type WrappedValue
- type WrappedValueSlice
Constants ¶
View Source
const ( LayoutRaw = "raw" LayoutNested = "nested" LayoutFlat = "flat" FormatJSON = "json" FormatParquet = "parquet" )
Variables ¶
This section is empty.
Functions ¶
func MarshalSlice ¶
func ParquetSchemaFor ¶
Types ¶
type FlattenedSampleDump ¶
type FlattenedSampleDump struct {
Data map[string]interface{} `` /* 150-byte string literal not displayed */
}
func FlattenDump ¶
func FlattenDump(dump *SampleDump) FlattenedSampleDump
type FlattenedSampleDumps ¶
type FlattenedSampleDumps []FlattenedSampleDump
func FlattenDumps ¶
func FlattenDumps(dumps SampleDumps) FlattenedSampleDumps
func (*FlattenedSampleDumps) AsJSON ¶
func (flattened *FlattenedSampleDumps) AsJSON() ([]byte, error)
func (*FlattenedSampleDumps) AsParquet ¶
func (flattened *FlattenedSampleDumps) AsParquet() ([]byte, error)
type SampleDump ¶
type SampleDump struct { Metric string `json:"metric" parquet:"name=metric, type=BYTE_ARRAY, convertedtype=UTF8"` // encoding=DELTA_BYTE_ARRAY Labels model.LabelSet `` /* 154-byte string literal not displayed */ Timestamp int64 `json:"timestamp" parquet:"name=timestamp, type=INT64"` // encoding=DELTA_BINARY_PACKED Value float64 `json:"value" parquet:"name=value, type=DOUBLE"` }
type SampleDumps ¶
type SampleDumps []SampleDump
func ValueToSampleDumps ¶
func ValueToSampleDumps(value model.Value) (SampleDumps, error)
func (*SampleDumps) AsJSON ¶
func (dumps *SampleDumps) AsJSON() ([]byte, error)
func (*SampleDumps) AsParquet ¶
func (dumps *SampleDumps) AsParquet() ([]byte, error)
type WrappedValue ¶
type WrappedValue struct {
// contains filtered or unexported fields
}
func (*WrappedValue) AsJSON ¶
func (val *WrappedValue) AsJSON() ([]byte, error)
func (*WrappedValue) AsParquet ¶
func (val *WrappedValue) AsParquet() ([]byte, error)
type WrappedValueSlice ¶
type WrappedValueSlice struct {
// contains filtered or unexported fields
}
func (*WrappedValueSlice) AsJSON ¶
func (wvs *WrappedValueSlice) AsJSON() ([]byte, error)
func (*WrappedValueSlice) AsParquet ¶
func (wvs *WrappedValueSlice) AsParquet() ([]byte, error)
Click to show internal directories.
Click to hide internal directories.