model

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const (
	LayoutRaw     = "raw"
	LayoutNested  = "nested"
	LayoutFlat    = "flat"
	FormatJSON    = "json"
	FormatParquet = "parquet"
)

Variables

This section is empty.

Functions

func Marshal

func Marshal(value model.Value, layout Layout, format Format) ([]byte, error)

func MarshalSlice

func MarshalSlice(values []model.Value, layout Layout, format Format) ([]byte, error)

func ParquetSchemaFor

func ParquetSchemaFor(data map[string]interface{}) (string, error)

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 Format

type Format string

type Layout

type Layout string

type Marshaler

type Marshaler interface {
	AsJSON() ([]byte, error)
	AsParquet() ([]byte, error)
}

func AsMarshaler

func AsMarshaler(value model.Value, layout Layout) (Marshaler, error)

func AsMarshalerSlice

func AsMarshalerSlice(values []model.Value, layout Layout) (Marshaler, 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)

Jump to

Keyboard shortcuts

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