Versions in this module Expand all Collapse all v2 v2.0.1 Apr 22, 2026 v2.0.0 Apr 22, 2026 Changes in this version + const AgentLLM + const ArrayFieldType + const CAgentLLM + const CCO + const CDT + const CDynamicDW + const CE + const CEL + const CL + const CLlm + const CM + const CN + const CO + const COCH + const CP + const CR + const CS + const CT + const CUnknown + const CustomObject + const DefaultLoggingStatus + const DialTesting + const DictFieldType + const DynamicDWCategory + const EnvDefaultEncoding + const EnvEnableDictField + const EnvEnableMixedArrayField + const ExecutionLog + const KeyEvent + const LLM + const Logging + const Metric + const MetricDeprecated + const Network + const Object + const ObjectChange + const Pcheck + const Ppb + const Ppooled + const Profiling + const Psent + const RUM + const SAgentLLM + const SCustomObject + const SDialTesting + const SDynamicDWCategory + const SExecutionLog + const SKeyEvent + const SLlm + const SLogging + const SMetric + const SMetricDeprecated + const SNetwork + const SObject + const SObjectChange + const SProfiling + const SRUM + const SSecurity + const STracing + const SUnknownCategory + const Security + const Tracing + const URLAgentLLM + const URLCustomObject + const URLDialTesting + const URLDynamicDWCategory + const URLExecutionLog + const URLKeyEvent + const URLLlm + const URLLogging + const URLMetric + const URLMetricDeprecated + const URLNetwork + const URLObject + const URLObjectChange + const URLProfiling + const URLRUM + const URLSecurity + const URLTracing + const URLUnknownCategory + const UnknownCategory + const WarnAddRequiredKV + const WarnDotInkey + const WarnFieldB64Encoded + const WarnFieldDisabled + const WarnInfConvertToMaxValue + const WarnInfConvertToMinValue + const WarnInvalidFieldValueType + const WarnInvalidMeasurement + const WarnInvalidTagKey + const WarnInvalidTagValue + const WarnInvalidUTF8String + const WarnKeyNameConflict + const WarnMaxFieldKeyLen + const WarnMaxFieldValueInt + const WarnMaxFieldValueLen + const WarnMaxFields + const WarnMaxTagKeyLen + const WarnMaxTagKeyValueCompose + const WarnMaxTagValueLen + const WarnMaxTags + const WarnNROrTailEscape + const WarnNilField + const WarnNoField + const WarnSameTagFieldKey + const WarnTagDisabled + var DefaultEncoding = LineProtocol + var DefaultMeasurementName = "__default" + var EnableDictField = false + var EnableMixedArrayField = false + var ErrIntOverflowPoint = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPoint = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLineProtocol = errors.New("invalid lineprotocol") + var ErrNoFields = errors.New("no fields") + var ErrUnexpectedEndOfGroupPoint = fmt.Errorf("proto: unexpected end of group") + var KeyClass = NewKey("class", S) + var KeyDate = NewKey("date", I) + var KeyMeasurement = NewKey("measurement", S) + var KeyName = NewKey("name", S, defaultObjectName) + var KeySource = NewKey("source", S) + var KeyStatus = NewKey("status", S, DefaultLoggingStatus) + var KeyTime = NewKey("time", 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 AnyRaw(x *types.Any) (any, error) + func AppendPBPointToPBPointsPayload(dst []byte, pb *PBPoint) []byte + func AppendPointToPBPointsPayload(dst []byte, pt *Point) []byte + func ClearPointPool() + func GetCfg(opts ...Option) *cfg + func MustAnyRaw(x *types.Any) any + func MustNewAny(x proto.Message) *types.Any + func MustNewAnyArray(a ...any) *types.Any + func MustNewBoolArray(b ...bool) *types.Any + func MustNewBytesArray(bytes ...[]byte) *types.Any + func MustNewFloatArray[T float32 | float64](f ...T) *types.Any + func MustNewIntArray[T int8 | int16 | int | int32 | int64](i ...T) *types.Any + func MustNewStringArray(s ...string) *types.Any + func MustNewUintArray[T uint16 | uint | uint32 | uint64](i ...T) *types.Any + func NewAny(x proto.Message) (*types.Any, error) + func NewAnyArray(a ...any) (*types.Any, error) + func NewBoolArray(b ...bool) (*types.Any, error) + func NewBytesArray(bytes ...[]byte) (*types.Any, error) + func NewFloatArray[T float32 | float64](f ...T) (*types.Any, error) + func NewIntArray[T int8 | int16 | int | int32 | int64](i ...T) (*types.Any, error) + func NewRander(opts ...RandOption) *ptRander + func NewStringArray(s ...string) (*types.Any, error) + func NewUintArray[T uint16 | uint | uint32 | uint64](i ...T) (*types.Any, error) + func PB2LP(pb []byte) (lp []byte, err error) + func PutCfg(c *cfg) + func PutDecoder(d *Decoder) + func PutEncoder(e *Encoder) + func SetPointPool(pp PointPool) + func SortByTime(pts []*Point) + func WalkPBPointsPayload(payload []byte, fn func(rawPBPoint []byte) bool) error + type AnyDemo struct + Demo string + func (*AnyDemo) Descriptor() ([]byte, []int) + func (*AnyDemo) ProtoMessage() + func (m *AnyDemo) GetDemo() string + 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) Reset() + 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 + func (this *AnyDemo) String() string + type Array struct + Arr []*BasicTypes + func NewArray(ents ...any) (arr *Array, err error) + func (*Array) Descriptor() ([]byte, []int) + func (*Array) ProtoMessage() + func (m *Array) GetArr() []*BasicTypes + 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) Reset() + 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 + func (this *Array) String() string + type BasicTypes struct + X isBasicTypes_X + func (*BasicTypes) Descriptor() ([]byte, []int) + func (*BasicTypes) ProtoMessage() + func (*BasicTypes) XXX_OneofWrappers() []interface{} + func (m *BasicTypes) GetB() bool + func (m *BasicTypes) GetD() []byte + func (m *BasicTypes) GetF() float64 + func (m *BasicTypes) GetI() int64 + func (m *BasicTypes) GetS() string + func (m *BasicTypes) GetU() uint64 + func (m *BasicTypes) GetX() isBasicTypes_X + 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) Reset() + 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 + func (this *BasicTypes) String() string + type BasicTypes_B struct + B bool + 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 struct + D []byte + 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 struct + F float64 + 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 struct + I int64 + 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 struct + S string + 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 struct + U uint64 + 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 BatchPoints struct + Points []*Point + func NewBatchPoints() *BatchPoints + func (bp *BatchPoints) Release() + func (bp *BatchPoints) Reset() + func (bp *BatchPoints) Unmarshal(src []byte) (err error) + 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 (m *Debug) GetInfo() string + 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) Reset() + 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 + func (this *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 WithDecEasyproto(on bool) DecoderOption + 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) + func (e *Encoder) EncodeV2(pts []*Point) + func (e *Encoder) LastErr() error + func (e *Encoder) LastTrimmed() int + func (e *Encoder) Next(buf []byte) ([]byte, bool) + func (e *Encoder) SkippedPoints() int + func (e *Encoder) String() string + func (e *Encoder) TotalPoints() int + type EncoderOption func(e *Encoder) + func WithApproxSize(on bool) EncoderOption + func WithEncBatchBytes(bytes int) EncoderOption + func WithEncBatchSize(size int) EncoderOption + func WithEncEncoding(enc Encoding) EncoderOption + func WithEncFn(fn EncodeFn) EncoderOption + func WithIgnoreLargePoint(on bool) EncoderOption + type Encoding int + const JSON + const LineProtocol + const PBJSON + const Protobuf + func EncodingStr(s string) Encoding + func HTTPContentType(ct string) Encoding + func (e Encoding) HTTPContentType() string + func (e Encoding) String() string + type EqualOption func(*eqopt) + func EqualWithMeasurement(on bool) EqualOption + func EqualWithoutKeys(keys ...string) EqualOption + type Field struct + Description string + IsTag bool + Key string + Type MetricType + Unit string + Val isField_Val + func NewKV(k string, v any, opts ...KVOption) *Field + func (*Field) Descriptor() ([]byte, []int) + func (*Field) ProtoMessage() + func (*Field) XXX_OneofWrappers() []interface{} + func (kv *Field) Raw() any + func (m *Field) GetA() *types.Any + func (m *Field) GetB() bool + func (m *Field) GetD() []byte + func (m *Field) GetDescription() string + func (m *Field) GetF() float64 + func (m *Field) GetI() int64 + func (m *Field) GetIsTag() bool + func (m *Field) GetKey() string + func (m *Field) GetS() string + func (m *Field) GetType() MetricType + func (m *Field) GetU() uint64 + func (m *Field) GetUnit() string + func (m *Field) GetVal() isField_Val + 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) Reset() + 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 + func (this *Field) String() string + type Field_A struct + A *types.Any + 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 struct + B bool + 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 struct + D []byte + 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 struct + F float64 + 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 struct + I int64 + 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 struct + S string + 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 struct + U uint64 + 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 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 WithKVDesc(desc string) KVOption + 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 string, v any, opts ...KVOption) KVs + func (x KVs) AddKV(kv *Field) KVs + func (x KVs) AddTag(k, v string) KVs + func (x KVs) Del(k string) KVs + func (x KVs) FieldCount() (i int) + func (x KVs) Fields() (arr KVs) + func (x KVs) Get(k string) *Field + func (x KVs) GetTag(k string) string + func (x KVs) Has(k string) bool + func (x KVs) InfluxFields() map[string]any + func (x KVs) InfluxTags() (res influxm.Tags) + func (x KVs) Keys() *Keys + func (x KVs) Len() int + func (x KVs) Less(i, j int) bool + func (x KVs) Pretty() string + func (x KVs) PrettySorted() string + func (x KVs) RawPretty() string + func (x KVs) Reset() + func (x KVs) ResetFull() + func (x KVs) Set(k string, v any, opts ...KVOption) KVs + func (x KVs) SetKV(kv *Field) KVs + func (x KVs) SetTag(k, v string) KVs + 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(kv *Field) *Key + func NewKey(k string, t KeyType, defaultVal ...any) *Key + func NewTagKey(k string, defaultVal string) *Key + func (k *Key) Default() any + func (k *Key) Key() string + func (k *Key) Type() KeyType + type KeyType int32 + const A + const B + const D + const F + const I + const NIL + const S + const U + const X + func PBType(v isField_Val) KeyType + func (KeyType) EnumDescriptor() ([]byte, []int) + 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 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 (m *Map) GetMap() map[string]*BasicTypes + 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) Reset() + 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 + func (this *Map) String() string + type MetricType int32 + const COUNT + const EXPONENTIAL_HISTOGRAM_AVG + const EXPONENTIAL_HISTOGRAM_COUNT + const EXPONENTIAL_HISTOGRAM_FLAGS + const EXPONENTIAL_HISTOGRAM_MAX + const EXPONENTIAL_HISTOGRAM_MIN + const EXPONENTIAL_HISTOGRAM_NEG_BUCKET_COUNTS + const EXPONENTIAL_HISTOGRAM_NEG_OFFSET + const EXPONENTIAL_HISTOGRAM_POS_BUCKET_COUNTS + const EXPONENTIAL_HISTOGRAM_POS_OFFSET + const EXPONENTIAL_HISTOGRAM_SCALE + const EXPONENTIAL_HISTOGRAM_START_TIME + const EXPONENTIAL_HISTOGRAM_SUM + const EXPONENTIAL_HISTOGRAM_ZERO_COUNT + const GAUGE + const HISTOGRAM_BUCKET_BOUNDS + const HISTOGRAM_BUCKET_COUNTS + const HISTOGRAM_COUNT + const HISTOGRAM_MAX + const HISTOGRAM_MIN + const HISTOGRAM_SUM + const RATE + const SUMMARY_COUNT + const SUMMARY_QUANTILE + const SUMMARY_SUM + const SUM_CUMULATIVE + const SUM_DELTA + const UNSPECIFIED + func (MetricType) EnumDescriptor() ([]byte, []int) + func (x MetricType) String() string + type Option func(*cfg) + func CommonLoggingOptions() []Option + 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 WithKeySorted(on bool) 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 WithTimestamp(ts int64) Option + func WithU64Field(on bool) Option + type PBPoint struct + Debugs []*Debug + Fields []*Field + Name string + Time int64 + Warns []*Warn + func (*PBPoint) Descriptor() ([]byte, []int) + func (*PBPoint) ProtoMessage() + func (m *PBPoint) GetDebugs() []*Debug + func (m *PBPoint) GetFields() []*Field + func (m *PBPoint) GetName() string + func (m *PBPoint) GetTime() int64 + func (m *PBPoint) GetWarns() []*Warn + 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) Reset() + 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 + func (this *PBPoint) String() string + type PBPoints struct + Arr []*PBPoint + func RandPBPoints(count int) *PBPoints + func (*PBPoints) Descriptor() ([]byte, []int) + func (*PBPoints) ProtoMessage() + func (m *PBPoints) GetArr() []*PBPoint + 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) Reset() + 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 + func (this *PBPoints) String() string + type Point struct + func CheckPoints(pts []*Point, opts ...Option) (arr []*Point) + func FromModelsLP(lp influxm.Point) *Point + func FromPB(pb *PBPoint) *Point + func FromPBJson(j []byte) (*Point, error) + func GatherPoints(reg prometheus.Gatherer) ([]*Point, error) + func MustFromPBJson(j []byte) *Point + func NewLPPoint(lp influxm.Point) *Point + func NewPoint(name string, kvs KVs, opts ...Option) *Point + func NewPointDeprecated(name string, tags map[string]string, fields map[string]any, opts ...Option) (*Point, error) + func RandPoints(count int) []*Point + func WrapPB(pt *Point, pb *PBPoint) *Point + func WrapPoint(pts []influxm.Point) (arr []*Point) + func (p *Point) Add(k string, v any) + func (p *Point) AddDebug(d *Debug) + func (p *Point) AddKVs(kvs ...*Field) + func (p *Point) AddTag(k, v string) + func (p *Point) ClearFlag(f uint64) + func (p *Point) CopyField(kvs ...*Field) + func (p *Point) CopyTags(kvs ...*Field) + func (p *Point) Del(k string) + func (p *Point) Equal(x *Point, opts ...EqualOption) bool + func (p *Point) EqualWithReason(x *Point, opts ...EqualOption) (bool, string) + func (p *Point) Fields() (arr KVs) + func (p *Point) Get(k string) any + func (p *Point) GetA(k string) (*types.Any, bool) + func (p *Point) GetB(k string) (bool, bool) + func (p *Point) GetD(k string) ([]byte, bool) + func (p *Point) GetF(k string) (float64, bool) + func (p *Point) GetI(k string) (int64, bool) + func (p *Point) GetS(k string) (string, bool) + func (p *Point) GetTag(k string) string + func (p *Point) GetU(k string) (uint64, bool) + func (p *Point) HasFlag(f uint) bool + func (p *Point) InfluxFields() map[string]any + func (p *Point) InfluxTags() influxm.Tags + func (p *Point) KVMap() map[string]any + func (p *Point) KVs() (arr KVs) + func (p *Point) Keys() *Keys + func (p *Point) LPPoint() (influxm.Point, error) + func (p *Point) LPSize() int + func (p *Point) LineProto(prec ...Precision) string + func (p *Point) MD5() string + func (p *Point) MapTags() map[string]string + func (p *Point) MarshalJSON() ([]byte, error) + func (p *Point) MustAdd(k string, v any) + func (p *Point) MustAddKVs(kvs ...*Field) + func (p *Point) MustLPPoint() influxm.Point + func (p *Point) Name() string + 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) Reset() + func (p *Point) Set(k string, v any) + func (p *Point) SetFlag(f uint) + func (p *Point) SetKVs(kvs ...*Field) + func (p *Point) SetName(name string) + func (p *Point) SetTag(k, v 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) TimeSeriesHash() []string + func (p *Point) UnmarshalJSON(j []byte) error + func (p *Point) Warns() []*Warn + func (p *Point) WarnsPretty() string + type PointPool interface + Get func() *Point + GetKV func(k string, v any) *Field + Put func(*Point) + PutKV func(f *Field) + func GetPointPool() PointPool + func NewReservedCapPointPool(capacity int64) PointPool + type Points []*Point + type Precision int + const PrecD + const PrecDyn + const PrecH + const PrecM + const PrecMS + const PrecNS + const PrecS + const PrecUS + const PrecW + 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 WithKVSorted(on bool) RandOption + func WithRandFields(n int) RandOption + func WithRandKeyLen(n int) RandOption + func WithRandMeasurementPrefix(s string) RandOption + func WithRandPB(on bool) RandOption + func WithRandSampleText(st []string) RandOption + func WithRandStringValues(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 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 struct + Msg string + Type string + func (*Warn) Descriptor() ([]byte, []int) + func (*Warn) ProtoMessage() + func (m *Warn) GetMsg() string + func (m *Warn) GetType() string + 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) Reset() + 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 + func (this *Warn) String() string Other modules containing this package github.com/GuanceCloud/cliutils
Go to main page