point

package

Go to main page

Versions in this module

v1

v1.1.21

Sep 5, 2024

Changes in this version

+ const CDT

+ const DialTesting

+ const SDialTesting

+ const URLDialTesting

v1.1.20

Jul 10, 2024

v1.1.19

Jul 8, 2024

v1.1.18

Jun 20, 2024

v1.1.17

Jun 1, 2024

v1.1.16

May 31, 2024

v1.1.15

May 29, 2024

Changes in this version

+ const WarnInfConvertToMaxValue

+ const WarnInfConvertToMinValue

+ const WarnNROrTailEscape

type Encoding

+ const PBJSON

+ type EqualOption func(*eqopt)

+ func EqualWithMeasurement(on bool) EqualOption

+ func EqualWithoutKeys(keys ...string) EqualOption

type KVs

+ func (x KVs) PrettySorted() string

type PointPool

+ func GetPointPool() PointPool

type Precision

+ const PrecDyn

v1.1.14

Apr 24, 2024

v1.1.13

Apr 18, 2024

v1.1.12

Apr 17, 2024

Changes in this version

+ const Ppooled

+ const WarnKeyNameConflict

+ var ErrIntOverflowPoint = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPoint = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPoint = fmt.Errorf("proto: unexpected end of group")

+ func ClearPointPool()

+ func MustNewBytesArray(bytes ...[]byte) *types.Any

+ func NewBytesArray(bytes ...[]byte) (*types.Any, error)

+ func SetPointPool(pp PointPool)

type AnyDemo

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

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

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

+ func (m *AnyDemo) Size() (n int)

+ func (m *AnyDemo) Unmarshal(dAtA []byte) error

+ func (m *AnyDemo) XXX_DiscardUnknown()

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

+ func (m *AnyDemo) XXX_Merge(src proto.Message)

+ func (m *AnyDemo) XXX_Size() int

+ func (m *AnyDemo) XXX_Unmarshal(b []byte) error

+ func (this *AnyDemo) Equal(that interface{}) bool

+ func (this *AnyDemo) GoString() string

type Array

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

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

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

+ func (m *Array) Size() (n int)

+ func (m *Array) Unmarshal(dAtA []byte) error

+ func (m *Array) XXX_DiscardUnknown()

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

+ func (m *Array) XXX_Merge(src proto.Message)

+ func (m *Array) XXX_Size() int

+ func (m *Array) XXX_Unmarshal(b []byte) error

+ func (this *Array) Equal(that interface{}) bool

+ func (this *Array) GoString() string

type BasicTypes

+ func (*BasicTypes) XXX_OneofWrappers() []interface{}

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

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

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

+ func (m *BasicTypes) Size() (n int)

+ func (m *BasicTypes) Unmarshal(dAtA []byte) error

+ func (m *BasicTypes) XXX_DiscardUnknown()

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

+ func (m *BasicTypes) XXX_Merge(src proto.Message)

+ func (m *BasicTypes) XXX_Size() int

+ func (m *BasicTypes) XXX_Unmarshal(b []byte) error

+ func (this *BasicTypes) Equal(that interface{}) bool

+ func (this *BasicTypes) GoString() string

type BasicTypes_B

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

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

+ func (m *BasicTypes_B) Size() (n int)

+ func (this *BasicTypes_B) Equal(that interface{}) bool

+ func (this *BasicTypes_B) GoString() string

+ func (this *BasicTypes_B) String() string

type BasicTypes_D

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

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

+ func (m *BasicTypes_D) Size() (n int)

+ func (this *BasicTypes_D) Equal(that interface{}) bool

+ func (this *BasicTypes_D) GoString() string

+ func (this *BasicTypes_D) String() string

type BasicTypes_F

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

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

+ func (m *BasicTypes_F) Size() (n int)

+ func (this *BasicTypes_F) Equal(that interface{}) bool

+ func (this *BasicTypes_F) GoString() string

+ func (this *BasicTypes_F) String() string

type BasicTypes_I

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

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

+ func (m *BasicTypes_I) Size() (n int)

+ func (this *BasicTypes_I) Equal(that interface{}) bool

+ func (this *BasicTypes_I) GoString() string

+ func (this *BasicTypes_I) String() string

type BasicTypes_S

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

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

+ func (m *BasicTypes_S) Size() (n int)

+ func (this *BasicTypes_S) Equal(that interface{}) bool

+ func (this *BasicTypes_S) GoString() string

+ func (this *BasicTypes_S) String() string

type BasicTypes_U

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

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

+ func (m *BasicTypes_U) Size() (n int)

+ func (this *BasicTypes_U) Equal(that interface{}) bool

+ func (this *BasicTypes_U) GoString() string

+ func (this *BasicTypes_U) String() string

type Debug

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

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

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

+ func (m *Debug) Size() (n int)

+ func (m *Debug) Unmarshal(dAtA []byte) error

+ func (m *Debug) XXX_DiscardUnknown()

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

+ func (m *Debug) XXX_Merge(src proto.Message)

+ func (m *Debug) XXX_Size() int

+ func (m *Debug) XXX_Unmarshal(b []byte) error

+ func (this *Debug) Equal(that interface{}) bool

+ func (this *Debug) GoString() string

type DecoderOption

+ func WithDecEasyproto(on bool) DecoderOption

type Encoder

+ func (e *Encoder) EncodeV2(pts []*Point)

+ func (e *Encoder) LastErr() error

+ func (e *Encoder) Next(buf []byte) ([]byte, bool)

+ func (e *Encoder) String() string

type Field

+ func (*Field) XXX_OneofWrappers() []interface{}

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

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

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

+ func (m *Field) Size() (n int)

+ func (m *Field) Unmarshal(dAtA []byte) error

+ func (m *Field) XXX_DiscardUnknown()

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

+ func (m *Field) XXX_Merge(src proto.Message)

+ func (m *Field) XXX_Size() int

+ func (m *Field) XXX_Unmarshal(b []byte) error

+ func (this *Field) Equal(that interface{}) bool

+ func (this *Field) GoString() string

type Field_A

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

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

+ func (m *Field_A) Size() (n int)

+ func (this *Field_A) Equal(that interface{}) bool

+ func (this *Field_A) GoString() string

+ func (this *Field_A) String() string

type Field_B

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

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

+ func (m *Field_B) Size() (n int)

+ func (this *Field_B) Equal(that interface{}) bool

+ func (this *Field_B) GoString() string

+ func (this *Field_B) String() string

type Field_D

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

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

+ func (m *Field_D) Size() (n int)

+ func (this *Field_D) Equal(that interface{}) bool

+ func (this *Field_D) GoString() string

+ func (this *Field_D) String() string

type Field_F

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

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

+ func (m *Field_F) Size() (n int)

+ func (this *Field_F) Equal(that interface{}) bool

+ func (this *Field_F) GoString() string

+ func (this *Field_F) String() string

type Field_I

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

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

+ func (m *Field_I) Size() (n int)

+ func (this *Field_I) Equal(that interface{}) bool

+ func (this *Field_I) GoString() string

+ func (this *Field_I) String() string

type Field_S

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

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

+ func (m *Field_S) Size() (n int)

+ func (this *Field_S) Equal(that interface{}) bool

+ func (this *Field_S) GoString() string

+ func (this *Field_S) String() string

type Field_U

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

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

+ func (m *Field_U) Size() (n int)

+ func (this *Field_U) Equal(that interface{}) bool

+ func (this *Field_U) GoString() string

+ func (this *Field_U) String() string

type KVs

+ func (x KVs) AddV2(k string, v any, force bool, opts ...KVOption) KVs

+ func (x KVs) Reset()

+ func (x KVs) ResetFull()

type KeyType

+ const A

+ const B

+ const F

+ const I

+ const NIL

+ const U

+ const X

type Map

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

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

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

+ func (m *Map) Size() (n int)

+ func (m *Map) Unmarshal(dAtA []byte) error

+ func (m *Map) XXX_DiscardUnknown()

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

+ func (m *Map) XXX_Merge(src proto.Message)

+ func (m *Map) XXX_Size() int

+ func (m *Map) XXX_Unmarshal(b []byte) error

+ func (this *Map) Equal(that interface{}) bool

+ func (this *Map) GoString() string

type MetricType

+ const COUNT

+ const GAUGE

+ const RATE

+ const UNSPECIFIED

type Option

+ func WithTimestamp(ts int64) Option

type PBPoint

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

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

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

+ func (m *PBPoint) Size() (n int)

+ func (m *PBPoint) Unmarshal(dAtA []byte) error

+ func (m *PBPoint) XXX_DiscardUnknown()

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

+ func (m *PBPoint) XXX_Merge(src proto.Message)

+ func (m *PBPoint) XXX_Size() int

+ func (m *PBPoint) XXX_Unmarshal(b []byte) error

+ func (this *PBPoint) Equal(that interface{}) bool

+ func (this *PBPoint) GoString() string

type PBPoints

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

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

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

+ func (m *PBPoints) Size() (n int)

+ func (m *PBPoints) Unmarshal(dAtA []byte) error

+ func (m *PBPoints) XXX_DiscardUnknown()

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

+ func (m *PBPoints) XXX_Merge(src proto.Message)

+ func (m *PBPoints) XXX_Size() int

+ func (m *PBPoints) XXX_Unmarshal(b []byte) error

+ func (this *PBPoints) Equal(that interface{}) bool

+ func (this *PBPoints) GoString() string

type Point

+ func CheckPoints(pts []*Point, opts ...Option) (arr []*Point)

+ func GatherPoints(reg prometheus.Gatherer) ([]*Point, error)

+ func (p *Point) AddKVs(kvs ...*Field)

+ func (p *Point) CopyField(kvs ...*Field)

+ func (p *Point) CopyTags(kvs ...*Field)

+ func (p *Point) MustAddKVs(kvs ...*Field)

+ func (p *Point) Reset()

+ func (p *Point) SetKVs(kvs ...*Field)

+ type PointPool interface

+ Get func() *Point

+ GetKV func(k string, v any) *Field

+ Put func(*Point)

+ PutKV func(f *Field)

+ String func() string

+ func NewPointPoolLevel1() PointPool

+ func NewPointPoolLevel2() PointPool

+ func NewPointPoolLevel3() PointPool

+ func NewReservedCapPointPool(capacity int64) PointPool

+ type Points []*Point

type Precision

+ const PrecD

+ const PrecH

+ const PrecM

+ const PrecMS

+ const PrecNS

+ const PrecS

+ const PrecUS

+ const PrecW

type RandOption

+ func WithRandPointPool(pp PointPool) RandOption

+ func WithRandSampleText(st []string) RandOption

+ func WithRandStringValues(on bool) RandOption

+ type ReservedCapPointPool struct

+ func (cpp *ReservedCapPointPool) Collect(ch chan<- p8s.Metric)

+ func (cpp *ReservedCapPointPool) Describe(ch chan<- *p8s.Desc)

+ func (cpp *ReservedCapPointPool) Get() *Point

+ func (cpp *ReservedCapPointPool) GetKV(k string, v any) *Field

+ func (cpp *ReservedCapPointPool) Put(p *Point)

+ func (cpp *ReservedCapPointPool) PutKV(f *Field)

+ func (cpp *ReservedCapPointPool) String() string

type Warn

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

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

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

+ func (m *Warn) Size() (n int)

+ func (m *Warn) Unmarshal(dAtA []byte) error

+ func (m *Warn) XXX_DiscardUnknown()

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

+ func (m *Warn) XXX_Merge(src proto.Message)

+ func (m *Warn) XXX_Size() int

+ func (m *Warn) XXX_Unmarshal(b []byte) error

+ func (this *Warn) Equal(that interface{}) bool

+ func (this *Warn) GoString() string

v0

v0.1.11

Mar 27, 2024

Changes in this version

+ const ArrayFieldType

+ const DictFieldType

+ const EnvEnableDictField

+ const EnvEnableMixedArrayField

+ var EnableDictField = false

+ var EnableMixedArrayField = false

v0.1.10

Feb 27, 2024

v0.1.9

Dec 8, 2023

v0.1.8

Dec 8, 2023

Changes in this version

type Point

+ func (p *Point) TimeSeriesHash() []string

v0.1.7

Dec 7, 2023

v0.1.6

Nov 20, 2023

Changes in this version

+ const WarnInvalidUTF8String

+ func AnyRaw(x *anypb.Any) (any, error)

+ func MustAnyRaw(x *anypb.Any) any

+ func MustNewAny(x proto.Message) *anypb.Any

+ func MustNewAnyArray(a ...any) *anypb.Any

+ func MustNewBoolArray(b ...bool) *anypb.Any

+ func MustNewFloatArray[T float32 | float64](f ...T) *anypb.Any

+ func MustNewIntArray[T int8 | int16 | int | int32 | int64](i ...T) *anypb.Any

+ func MustNewStringArray(s ...string) *anypb.Any

+ func MustNewUintArray[T uint16 | uint | uint32 | uint64](i ...T) *anypb.Any

+ func NewAny(x proto.Message) (*anypb.Any, error)

+ func NewAnyArray(a ...any) (*anypb.Any, error)

+ func NewBoolArray(b ...bool) (*anypb.Any, error)

+ func NewFloatArray[T float32 | float64](f ...T) (*anypb.Any, error)

+ func NewIntArray[T int8 | int16 | int | int32 | int64](i ...T) (*anypb.Any, error)

+ func NewStringArray(s ...string) (*anypb.Any, error)

+ func NewUintArray[T uint16 | uint | uint32 | uint64](i ...T) (*anypb.Any, error)

+ func SortByTime(pts []*Point)

+ type Array struct

+ Arr []*BasicTypes

+ func NewArray(ents ...any) (arr *Array, err error)

+ func (*Array) Descriptor() ([]byte, []int)

+ func (*Array) ProtoMessage()

+ func (x *Array) GetArr() []*BasicTypes

+ func (x *Array) ProtoReflect() protoreflect.Message

+ func (x *Array) Reset()

+ func (x *Array) String() string

+ type BasicTypes struct

+ X isBasicTypes_X

+ func (*BasicTypes) Descriptor() ([]byte, []int)

+ func (*BasicTypes) ProtoMessage()

+ func (m *BasicTypes) GetX() isBasicTypes_X

+ func (x *BasicTypes) GetB() bool

+ func (x *BasicTypes) GetD() []byte

+ func (x *BasicTypes) GetF() float64

+ func (x *BasicTypes) GetI() int64

+ func (x *BasicTypes) GetS() string

+ func (x *BasicTypes) GetU() uint64

+ func (x *BasicTypes) ProtoReflect() protoreflect.Message

+ func (x *BasicTypes) Reset()

+ func (x *BasicTypes) String() string

+ type BasicTypes_B struct

+ B bool

+ type BasicTypes_D struct

+ D []byte

+ type BasicTypes_F struct

+ F float64

+ type BasicTypes_I struct

+ I int64

+ type BasicTypes_S struct

+ S string

+ type BasicTypes_U struct

+ U uint64

type EncoderOption

+ func WithEncBatchBytes(bytes int) EncoderOption

type Field

+ func (kv *Field) Raw() any

+ func (x *Field) GetS() string

+ type Field_S struct

+ S string

type KeyType

+ const KeyType_A

+ const KeyType_S

+ type Map struct

+ Map map[string]*BasicTypes

+ func MustNewMap(ents map[string]any) *Map

+ func NewMap(ents map[string]any) (dict *Map, err error)

+ func (*Map) Descriptor() ([]byte, []int)

+ func (*Map) ProtoMessage()

+ func (x *Map) GetMap() map[string]*BasicTypes

+ func (x *Map) ProtoReflect() protoreflect.Message

+ func (x *Map) Reset()

+ func (x *Map) String() string

type Option

+ func WithKeySorted(on bool) Option

type Point

+ func (p *Point) KVMap() map[string]any

+ func (p *Point) MapTags() map[string]string

+ func (p *Point) MustLPPoint() influxm.Point

+ func (p *Point) WarnsPretty() string

type RandOption

+ func WithKVSorted(on bool) RandOption

v0.1.5

Oct 17, 2023

Changes in this version

type Encoding

+ func HTTPContentType(ct string) Encoding

+ func (e Encoding) HTTPContentType() string

+ func (e Encoding) String() string

v0.1.4

Aug 14, 2023

v0.1.3

Jul 14, 2023

v0.1.2

Jul 14, 2023

v0.1.1

Apr 20, 2023

Changes in this version

type Option

+ func CommonLoggingOptions() []Option

v0.1.0

Apr 12, 2023

Changes in this version

+ const CCO

+ const CDynamicDW

+ const CE

+ const CL

+ const CM

+ const CN

+ const CO

+ const CP

+ const CR

+ const CS

+ const CT

+ const CUnknown

+ const CustomObject

+ const DynamicDWCategory

+ const EnvDefaultEncoding

+ const KeyEvent

+ const Logging

+ const Metric

+ const MetricDeprecated

+ const Network

+ const Object

+ const PBContentType

+ const Pcheck

+ const Ppb

+ const Profiling

+ const Psent

+ const RUM

+ const SCustomObject

+ const SDynamicDWCategory

+ const SKeyEvent

+ const SLogging

+ const SMetric

+ const SMetricDeprecated

+ const SNetwork

+ const SObject

+ const SProfiling

+ const SRUM

+ const SSecurity

+ const STracing

+ const SUnknownCategory

+ const Security

+ const Tracing

+ const URLCustomObject

+ const URLDynamicDWCategory

+ const URLKeyEvent

+ const URLLogging

+ const URLMetric

+ const URLMetricDeprecated

+ const URLNetwork

+ const URLObject

+ const URLProfiling

+ const URLRUM

+ const URLSecurity

+ const URLTracing

+ const URLUnknownCategory

+ const UnknownCategory

+ const WarnAddRequiredKV

+ const WarnDotInkey

+ const WarnFieldB64Encoded

+ const WarnFieldDisabled

+ const WarnInvalidFieldValueType

+ const WarnInvalidMeasurement

+ const WarnInvalidTagKey

+ const WarnInvalidTagValue

+ const WarnMaxFieldKeyLen

+ const WarnMaxFieldValueInt

+ const WarnMaxFieldValueLen

+ const WarnMaxFields

+ const WarnMaxTagKeyLen

+ const WarnMaxTagKeyValueCompose

+ const WarnMaxTagValueLen

+ const WarnMaxTags

+ const WarnNilField

+ const WarnNoField

+ const WarnSameTagFieldKey

+ const WarnTagDisabled

+ var DefaultEncoding = LineProtocol

+ var DefaultMeasurementName = []byte("__default")

+ var ErrInvalidLineProtocol = errors.New("invalid lineprotocol")

+ var ErrNoFields = errors.New("no fields")

+ var File_point_proto protoreflect.FileDescriptor

+ var KeyClass = NewKey([]byte("class"), KeyType_D)

+ var KeyDate = NewKey([]byte("date"), KeyType_I)

+ var KeyMeasurement = NewKey([]byte("measurement"), KeyType_D)

+ var KeyName = NewKey([]byte("name"), KeyType_D, []byte(defaultObjectName))

+ var KeySource = NewKey([]byte("source"), KeyType_D)

+ var KeyStatus = NewKey([]byte("status"), KeyType_D, []byte(defaultLoggingStatus))

+ var KeyTime = NewKey([]byte("time"), KeyType_I)

+ var KeyType_name = map[int32]string

+ var KeyType_value = map[string]int32

+ var MetricType_name = map[int32]string

+ var MetricType_value = map[string]int32

+ func GetCfg(opts ...Option) *cfg

+ func NewRander(opts ...RandOption) *ptRander

+ func PB2LP(pb []byte) (lp []byte, err error)

+ func PutCfg(c *cfg)

+ func PutDecoder(d *Decoder)

+ func PutEncoder(e *Encoder)

+ type AnyDemo struct

+ Demo string

+ func (*AnyDemo) Descriptor() ([]byte, []int)

+ func (*AnyDemo) ProtoMessage()

+ func (x *AnyDemo) GetDemo() string

+ func (x *AnyDemo) ProtoReflect() protoreflect.Message

+ func (x *AnyDemo) Reset()

+ func (x *AnyDemo) String() string

+ type Callback func(*Point) (*Point, error)

+ type Category int

+ func AllCategories() []Category

+ func CatAlias(c string) Category

+ func CatString(c string) Category

+ func CatURL(c string) Category

+ func (c Category) Alias() string

+ func (c Category) String() string

+ func (c Category) URL() string

+ type Debug struct

+ Info string

+ func (*Debug) Descriptor() ([]byte, []int)

+ func (*Debug) ProtoMessage()

+ func (x *Debug) GetInfo() string

+ func (x *Debug) ProtoReflect() protoreflect.Message

+ func (x *Debug) Reset()

+ func (x *Debug) String() string

+ type DecodeFn func([]*Point) error

+ type Decoder struct

+ func GetDecoder(opts ...DecoderOption) *Decoder

+ func (d *Decoder) Decode(data []byte, opts ...Option) ([]*Point, error)

+ func (d *Decoder) DetailedError() error

+ type DecoderOption func(e *Decoder)

+ func WithDecEncoding(enc Encoding) DecoderOption

+ func WithDecFn(fn DecodeFn) DecoderOption

+ type EncodeFn func(batchSize int, payload []byte) error

+ type Encoder struct

+ func GetEncoder(opts ...EncoderOption) *Encoder

+ func (e *Encoder) Encode(pts []*Point) ([][]byte, error)

+ type EncoderOption func(e *Encoder)

+ func WithEncBatchSize(size int) EncoderOption

+ func WithEncEncoding(enc Encoding) EncoderOption

+ func WithEncFn(fn EncodeFn) EncoderOption

+ type Encoding int

+ const JSON

+ const LineProtocol

+ const Protobuf

+ func EncodingStr(s string) Encoding

+ type Field struct

+ IsTag bool

+ Key []byte

+ Type MetricType

+ Unit string

+ Val isField_Val

+ func NewKV(k []byte, v any, opts ...KVOption) *Field

+ func (*Field) Descriptor() ([]byte, []int)

+ func (*Field) ProtoMessage()

+ func (m *Field) GetVal() isField_Val

+ func (x *Field) GetA() *anypb.Any

+ func (x *Field) GetB() bool

+ func (x *Field) GetD() []byte

+ func (x *Field) GetF() float64

+ func (x *Field) GetI() int64

+ func (x *Field) GetIsTag() bool

+ func (x *Field) GetKey() []byte

+ func (x *Field) GetType() MetricType

+ func (x *Field) GetU() uint64

+ func (x *Field) GetUnit() string

+ func (x *Field) ProtoReflect() protoreflect.Message

+ func (x *Field) Reset()

+ func (x *Field) String() string

+ type Field_A struct

+ A *anypb.Any

+ type Field_B struct

+ B bool

+ type Field_D struct

+ D []byte

+ type Field_F struct

+ F float64

+ type Field_I struct

+ I int64

+ type Field_U struct

+ U uint64

+ type JSONPoint struct

+ Fields map[string]interface{}

+ Measurement string

+ Tags map[string]string

+ Time int64

+ func (jp *JSONPoint) Point(opts ...Option) (*Point, error)

+ type KVOption func(kv *Field)

+ func WithKVTagSet(on bool) KVOption

+ func WithKVType(t MetricType) KVOption

+ func WithKVUnit(u string) KVOption

+ type KVs []*Field

+ func NewKVs(kvs map[string]interface{}) (res KVs)

+ func NewTags(tags map[string]string) (arr KVs)

+ func (x KVs) Add(k []byte, v any, isTag, force bool) KVs

+ func (x KVs) AddKV(kv *Field, force bool) KVs

+ func (x KVs) AddTag(k, v []byte) KVs

+ func (x KVs) Del(k []byte) KVs

+ func (x KVs) FieldCount() (i int)

+ func (x KVs) Fields() (arr KVs)

+ func (x KVs) Get(k []byte) *Field

+ func (x KVs) GetTag(k []byte) []byte

+ func (x KVs) Has(k []byte) bool

+ func (x KVs) InfluxFields() map[string]any

+ func (x KVs) InfluxTags() (res map[string]string)

+ func (x KVs) Keys() *Keys

+ func (x KVs) Len() int

+ func (x KVs) Less(i, j int) bool

+ func (x KVs) MustAddKV(kv *Field) KVs

+ func (x KVs) MustAddTag(k, v []byte) KVs

+ func (x KVs) Pretty() string

+ func (x KVs) Swap(i, j int)

+ func (x KVs) TagCount() (i int)

+ func (x KVs) Tags() (arr KVs)

+ func (x KVs) TrimFields(n int) (arr KVs)

+ func (x KVs) TrimTags(n int) (arr KVs)

+ type Key struct

+ func KVKey(f *Field) *Key

+ func NewKey(k []byte, t KeyType, defaultVal ...any) *Key

+ func NewTagKey(k []byte, defaultVal []byte) *Key

+ func (k *Key) Default() any

+ func (k *Key) Key() []byte

+ func (k *Key) Type() KeyType

+ type KeyType int32

+ const KeyType_B

+ const KeyType_D

+ const KeyType_F

+ const KeyType_I

+ const KeyType_NIL

+ const KeyType_U

+ const KeyType_X

+ func PBType(v isField_Val) KeyType

+ func (KeyType) Descriptor() protoreflect.EnumDescriptor

+ func (KeyType) EnumDescriptor() ([]byte, []int)

+ func (KeyType) Type() protoreflect.EnumType

+ func (x KeyType) Enum() *KeyType

+ func (x KeyType) Number() protoreflect.EnumNumber

+ func (x KeyType) String() string

+ type Keys struct

+ func (x *Keys) Add(k *Key)

+ func (x *Keys) Del(k *Key)

+ func (x *Keys) Has(k *Key) bool

+ func (x *Keys) Hash() uint64

+ func (x *Keys) Len() int

+ func (x *Keys) Less(i, j int) bool

+ func (x *Keys) Pretty() string

+ func (x *Keys) Swap(i, j int)

+ type MetricType int32

+ const MetricType_COUNT

+ const MetricType_GAUGE

+ const MetricType_RATE

+ const MetricType_UNSPECIFIED

+ func (MetricType) Descriptor() protoreflect.EnumDescriptor

+ func (MetricType) EnumDescriptor() ([]byte, []int)

+ func (MetricType) Type() protoreflect.EnumType

+ func (x MetricType) Enum() *MetricType

+ func (x MetricType) Number() protoreflect.EnumNumber

+ func (x MetricType) String() string

+ type Option func(*cfg)

+ func DefaultLoggingOptions() []Option

+ func DefaultMetricOptions() []Option

+ func DefaultMetricOptionsForInflux1X() []Option

+ func DefaultObjectOptions() []Option

+ func WithCallback(fn Callback) Option

+ func WithDisabledKeys(keys ...*Key) Option

+ func WithDotInKey(on bool) Option

+ func WithEncoding(enc Encoding) Option

+ func WithExtraTags(tags map[string]string) Option

+ func WithMaxFieldKeyLen(n int) Option

+ func WithMaxFieldValLen(n int) Option

+ func WithMaxFields(n int) Option

+ func WithMaxKVComposeLen(n int) Option

+ func WithMaxMeasurementLen(n int) Option

+ func WithMaxTagKeyLen(n int) Option

+ func WithMaxTagValLen(n int) Option

+ func WithMaxTags(n int) Option

+ func WithPrecheck(on bool) Option

+ func WithPrecision(p Precision) Option

+ func WithRequiredKeys(keys ...*Key) Option

+ func WithStrField(on bool) Option

+ func WithTime(t time.Time) Option

+ func WithU64Field(on bool) Option

+ type PBPoint struct

+ Debugs []*Debug

+ Fields []*Field

+ Name []byte

+ Time int64

+ Warns []*Warn

+ func (*PBPoint) Descriptor() ([]byte, []int)

+ func (*PBPoint) ProtoMessage()

+ func (x *PBPoint) GetDebugs() []*Debug

+ func (x *PBPoint) GetFields() []*Field

+ func (x *PBPoint) GetName() []byte

+ func (x *PBPoint) GetTime() int64

+ func (x *PBPoint) GetWarns() []*Warn

+ func (x *PBPoint) ProtoReflect() protoreflect.Message

+ func (x *PBPoint) Reset()

+ func (x *PBPoint) String() string

+ type PBPoints struct

+ Arr []*PBPoint

+ func RandPBPoints(count int) *PBPoints

+ func (*PBPoints) Descriptor() ([]byte, []int)

+ func (*PBPoints) ProtoMessage()

+ func (x *PBPoints) GetArr() []*PBPoint

+ func (x *PBPoints) ProtoReflect() protoreflect.Message

+ func (x *PBPoints) Reset()

+ func (x *PBPoints) String() string

+ type Point struct

+ func FromJSONPoint(j *JSONPoint) *Point

+ func FromLP(lp *influxdb.Point) *Point

+ func FromModelsLP(lp models.Point) *Point

+ func FromPB(pb *PBPoint) *Point

+ func FromPBJson(j []byte) (*Point, error)

+ func MustFromPBJson(j []byte) *Point

+ func NewLPPoint(lp *influxdb.Point) *Point

+ func NewPoint(name string, tags map[string]string, fields map[string]any, opts ...Option) (*Point, error)

+ func NewPointV2(name []byte, kvs KVs, opts ...Option) *Point

+ func RandPoints(count int) []*Point

+ func WrapPoint(pts []*influxdb.Point) (arr []*Point)

+ func (p *Point) Add(k []byte, v any)

+ func (p *Point) AddDebug(d *Debug)

+ func (p *Point) AddKV(kv *Field)

+ func (p *Point) AddTag(k, v []byte)

+ func (p *Point) ClearFlag(f uint64)

+ func (p *Point) Del(k []byte)

+ func (p *Point) Equal(x *Point) bool

+ func (p *Point) EqualWithReason(x *Point) (bool, string)

+ func (p *Point) Fields() (arr KVs)

+ func (p *Point) Get(k []byte) any

+ func (p *Point) GetTag(k []byte) []byte

+ func (p *Point) HasFlag(f uint) bool

+ func (p *Point) InfluxFields() map[string]any

+ func (p *Point) InfluxTags() map[string]string

+ func (p *Point) KVs() (arr KVs)

+ func (p *Point) Keys() *Keys

+ func (p *Point) LPPoint() *influxdb.Point

+ func (p *Point) LPSize() int

+ func (p *Point) LineProto(prec ...Precision) string

+ func (p *Point) MD5() string

+ func (p *Point) MarshalJSON() ([]byte, error)

+ func (p *Point) MustAdd(k []byte, v any)

+ func (p *Point) MustAddKV(kv *Field)

+ func (p *Point) MustAddTag(k, v []byte)

+ func (p *Point) Name() []byte

+ func (p *Point) PBJson() ([]byte, error)

+ func (p *Point) PBJsonPretty() ([]byte, error)

+ func (p *Point) PBPoint() *PBPoint

+ func (p *Point) PBSize() int

+ func (p *Point) Pretty() string

+ func (p *Point) SetFlag(f uint)

+ func (p *Point) SetName(name string)

+ func (p *Point) SetTime(t time.Time)

+ func (p *Point) Sha256() string

+ func (p *Point) Size() int

+ func (p *Point) Tags() (arr KVs)

+ func (p *Point) Time() time.Time

+ func (p *Point) UnmarshalJSON(j []byte) error

+ func (p *Point) Warns() []*Warn

+ type Precision int

+ const D

+ const H

+ const M

+ const MS

+ const NS

+ const S

+ const US

+ const W

+ func PrecStr(s string) Precision

+ func (p Precision) String() string

+ type RandOption func(*ptRander)

+ func WithCategory(c Category) RandOption

+ func WithFixedKeys(on bool) RandOption

+ func WithFixedTags(on bool) RandOption

+ func WithRandFields(n int) RandOption

+ func WithRandKeyLen(n int) RandOption

+ func WithRandMeasurementPrefix(s string) RandOption

+ func WithRandPB(on bool) RandOption

+ func WithRandTags(n int) RandOption

+ func WithRandText(n int) RandOption

+ func WithRandTime(t time.Time) RandOption

+ func WithRandValLen(n int) RandOption

+ type Warn struct

+ Msg string

+ Type string

+ func (*Warn) Descriptor() ([]byte, []int)

+ func (*Warn) ProtoMessage()

+ func (x *Warn) GetMsg() string

+ func (x *Warn) GetType() string

+ func (x *Warn) ProtoReflect() protoreflect.Message

+ func (x *Warn) Reset()

+ func (x *Warn) String() string

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