package binary

import "github.com/influxdata/influxdb/cmd/influx_tools/internal/format/binary"

Index

Variables 

var (
	ErrWriteAfterClose       = errors.New("format/binary: write after close")
	ErrWriteBucketAfterClose = errors.New("format/binary: write to closed bucket")
)
var (
	FieldType_name = map[int32]string{
		0: "FloatFieldType",
		1: "IntegerFieldType",
		2: "UnsignedFieldType",
		3: "BooleanFieldType",
		4: "StringFieldType",
	}
	FieldType_value = map[string]int32{
		"FloatFieldType":    0,
		"IntegerFieldType":  1,
		"UnsignedFieldType": 2,
		"BooleanFieldType":  3,
		"StringFieldType":   4,
	}
)

Enum value maps for FieldType. 

var (
	Header_Version_name = map[int32]string{
		0: "Version0",
	}
	Header_Version_value = map[string]int32{
		"Version0": 0,
	}
)

Enum value maps for Header_Version. 

var File_tools_binary_proto protoreflect.FileDescriptor
var (
	Magic = [...]byte{0x49, 0x46, 0x4c, 0x58, 0x44, 0x55, 0x4d, 0x50} // IFLXDUMP
)

Types

type BooleanPoints 

type BooleanPoints struct {
	Timestamps []int64 `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []bool  `protobuf:"varint,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BooleanPoints) Descriptor 

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

Deprecated: Use BooleanPoints.ProtoReflect.Descriptor instead.

func (*BooleanPoints) GetTimestamps 

func (x *BooleanPoints) GetTimestamps() []int64

func (*BooleanPoints) GetValues 

func (x *BooleanPoints) GetValues() []bool

func (*BooleanPoints) ProtoMessage 

func (*BooleanPoints) ProtoMessage()

func (*BooleanPoints) ProtoReflect 

func (x *BooleanPoints) ProtoReflect() protoreflect.Message

func (*BooleanPoints) Reset 

func (x *BooleanPoints) Reset()

func (*BooleanPoints) String 

func (x *BooleanPoints) String() string

type BucketFooter 

type BucketFooter struct {
	// contains filtered or unexported fields
}

func (*BucketFooter) Descriptor 

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

Deprecated: Use BucketFooter.ProtoReflect.Descriptor instead.

func (*BucketFooter) ProtoMessage 

func (*BucketFooter) ProtoMessage()

func (*BucketFooter) ProtoReflect 

func (x *BucketFooter) ProtoReflect() protoreflect.Message

func (*BucketFooter) Reset 

func (x *BucketFooter) Reset()

func (*BucketFooter) String 

func (x *BucketFooter) String() string

type BucketHeader 

type BucketHeader struct {
	Start int64 `protobuf:"fixed64,1,opt,name=start,proto3" json:"start,omitempty"`
	End   int64 `protobuf:"fixed64,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketHeader) Descriptor 

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

Deprecated: Use BucketHeader.ProtoReflect.Descriptor instead.

func (*BucketHeader) GetEnd 

func (x *BucketHeader) GetEnd() int64

func (*BucketHeader) GetStart 

func (x *BucketHeader) GetStart() int64

func (*BucketHeader) ProtoMessage 

func (*BucketHeader) ProtoMessage()

func (*BucketHeader) ProtoReflect 

func (x *BucketHeader) ProtoReflect() protoreflect.Message

func (*BucketHeader) Reset 

func (x *BucketHeader) Reset()

func (*BucketHeader) String 

func (x *BucketHeader) String() string

type FieldType 

type FieldType int32
const (
	FieldType_FloatFieldType    FieldType = 0
	FieldType_IntegerFieldType  FieldType = 1
	FieldType_UnsignedFieldType FieldType = 2
	FieldType_BooleanFieldType  FieldType = 3
	FieldType_StringFieldType   FieldType = 4
)

func (FieldType) Descriptor 

func (FieldType) Descriptor() protoreflect.EnumDescriptor

func (FieldType) Enum 

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor 

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

Deprecated: Use FieldType.Descriptor instead.

func (FieldType) Number 

func (x FieldType) Number() protoreflect.EnumNumber

func (FieldType) String 

func (x FieldType) String() string

func (FieldType) Type 

func (FieldType) Type() protoreflect.EnumType

type FloatPoints 

type FloatPoints struct {
	Timestamps []int64   `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []float64 `protobuf:"fixed64,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*FloatPoints) Descriptor 

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

Deprecated: Use FloatPoints.ProtoReflect.Descriptor instead.

func (*FloatPoints) GetTimestamps 

func (x *FloatPoints) GetTimestamps() []int64

func (*FloatPoints) GetValues 

func (x *FloatPoints) GetValues() []float64

func (*FloatPoints) ProtoMessage 

func (*FloatPoints) ProtoMessage()

func (*FloatPoints) ProtoReflect 

func (x *FloatPoints) ProtoReflect() protoreflect.Message

func (*FloatPoints) Reset 

func (x *FloatPoints) Reset()

func (*FloatPoints) String 

func (x *FloatPoints) String() string
type Header struct {
	Version         Header_Version `protobuf:"varint,1,opt,name=version,proto3,enum=binary.Header_Version" json:"version,omitempty"`
	Database        string         `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	RetentionPolicy string         `protobuf:"bytes,3,opt,name=retention_policy,json=retentionPolicy,proto3" json:"retention_policy,omitempty"`
	ShardDuration   int64          `protobuf:"varint,4,opt,name=shard_duration,json=shardDuration,proto3" json:"shard_duration,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetDatabase 

func (x *Header) GetDatabase() string

func (*Header) GetRetentionPolicy 

func (x *Header) GetRetentionPolicy() string

func (*Header) GetShardDuration 

func (x *Header) GetShardDuration() int64

func (*Header) GetVersion 

func (x *Header) GetVersion() Header_Version

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

func (x *Header) ProtoReflect() protoreflect.Message

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type Header_Version 

type Header_Version int32
const (
	Header_Version0 Header_Version = 0
)

func (Header_Version) Descriptor 

func (Header_Version) Descriptor() protoreflect.EnumDescriptor

func (Header_Version) Enum 

func (x Header_Version) Enum() *Header_Version

func (Header_Version) EnumDescriptor 

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

Deprecated: Use Header_Version.Descriptor instead.

func (Header_Version) Number 

func (x Header_Version) Number() protoreflect.EnumNumber

func (Header_Version) String 

func (x Header_Version) String() string

func (Header_Version) Type 

func (Header_Version) Type() protoreflect.EnumType

type IntegerPoints 

type IntegerPoints struct {
	Timestamps []int64 `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []int64 `protobuf:"varint,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*IntegerPoints) Descriptor 

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

Deprecated: Use IntegerPoints.ProtoReflect.Descriptor instead.

func (*IntegerPoints) GetTimestamps 

func (x *IntegerPoints) GetTimestamps() []int64

func (*IntegerPoints) GetValues 

func (x *IntegerPoints) GetValues() []int64

func (*IntegerPoints) ProtoMessage 

func (*IntegerPoints) ProtoMessage()

func (*IntegerPoints) ProtoReflect 

func (x *IntegerPoints) ProtoReflect() protoreflect.Message

func (*IntegerPoints) Reset 

func (x *IntegerPoints) Reset()

func (*IntegerPoints) String 

func (x *IntegerPoints) String() string

type MessageType 

type MessageType byte
const (
	HeaderType MessageType = iota + 1
	BucketHeaderType
	BucketFooterType
	SeriesHeaderType
	FloatPointsType
	IntegerPointsType
	UnsignedPointsType
	BooleanPointsType
	StringPointsType
	SeriesFooterType
)

func (MessageType) String 

func (i MessageType) String() string

type PointsReader 

type PointsReader struct {
	// contains filtered or unexported fields
}

func (*PointsReader) Next 

func (pr *PointsReader) Next() (bool, error)

func (*PointsReader) Reset 

func (pr *PointsReader) Reset(pointsType MessageType)

func (*PointsReader) Values 

func (pr *PointsReader) Values() tsm1.Values

type Reader 

type Reader struct {
	// contains filtered or unexported fields
}

func NewReader 

func NewReader(reader io.Reader) *Reader

func (*Reader) Close 

func (r *Reader) Close() error

func (*Reader) NextBucket 

func (r *Reader) NextBucket() (*BucketHeader, error)

func (*Reader) NextSeries 

func (r *Reader) NextSeries() (*SeriesHeader, error)

func (*Reader) Points 

func (r *Reader) Points() *PointsReader

func (*Reader) ReadHeader 

func (r *Reader) ReadHeader() (*Header, error)

type SeriesFooter 

type SeriesFooter struct {
	// contains filtered or unexported fields
}

func (*SeriesFooter) Descriptor 

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

Deprecated: Use SeriesFooter.ProtoReflect.Descriptor instead.

func (*SeriesFooter) ProtoMessage 

func (*SeriesFooter) ProtoMessage()

func (*SeriesFooter) ProtoReflect 

func (x *SeriesFooter) ProtoReflect() protoreflect.Message

func (*SeriesFooter) Reset 

func (x *SeriesFooter) Reset()

func (*SeriesFooter) String 

func (x *SeriesFooter) String() string

type SeriesHeader 

type SeriesHeader struct {
	FieldType FieldType `protobuf:"varint,1,opt,name=field_type,json=fieldType,proto3,enum=binary.FieldType" json:"field_type,omitempty"`
	SeriesKey []byte    `protobuf:"bytes,2,opt,name=series_key,json=seriesKey,proto3" json:"series_key,omitempty"`
	Field     []byte    `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*SeriesHeader) Descriptor 

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

Deprecated: Use SeriesHeader.ProtoReflect.Descriptor instead.

func (*SeriesHeader) GetField 

func (x *SeriesHeader) GetField() []byte

func (*SeriesHeader) GetFieldType 

func (x *SeriesHeader) GetFieldType() FieldType

func (*SeriesHeader) GetSeriesKey 

func (x *SeriesHeader) GetSeriesKey() []byte

func (*SeriesHeader) ProtoMessage 

func (*SeriesHeader) ProtoMessage()

func (*SeriesHeader) ProtoReflect 

func (x *SeriesHeader) ProtoReflect() protoreflect.Message

func (*SeriesHeader) Reset 

func (x *SeriesHeader) Reset()

func (*SeriesHeader) String 

func (x *SeriesHeader) String() string

type StringPoints 

type StringPoints struct {
	Timestamps []int64  `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StringPoints) Descriptor 

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

Deprecated: Use StringPoints.ProtoReflect.Descriptor instead.

func (*StringPoints) GetTimestamps 

func (x *StringPoints) GetTimestamps() []int64

func (*StringPoints) GetValues 

func (x *StringPoints) GetValues() []string

func (*StringPoints) ProtoMessage 

func (*StringPoints) ProtoMessage()

func (*StringPoints) ProtoReflect 

func (x *StringPoints) ProtoReflect() protoreflect.Message

func (*StringPoints) Reset 

func (x *StringPoints) Reset()

func (*StringPoints) String 

func (x *StringPoints) String() string

type UnsignedPoints 

type UnsignedPoints struct {
	Timestamps []int64  `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []uint64 `protobuf:"varint,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsignedPoints) Descriptor 

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

Deprecated: Use UnsignedPoints.ProtoReflect.Descriptor instead.

func (*UnsignedPoints) GetTimestamps 

func (x *UnsignedPoints) GetTimestamps() []int64

func (*UnsignedPoints) GetValues 

func (x *UnsignedPoints) GetValues() []uint64

func (*UnsignedPoints) ProtoMessage 

func (*UnsignedPoints) ProtoMessage()

func (*UnsignedPoints) ProtoReflect 

func (x *UnsignedPoints) ProtoReflect() protoreflect.Message

func (*UnsignedPoints) Reset 

func (x *UnsignedPoints) Reset()

func (*UnsignedPoints) String 

func (x *UnsignedPoints) String() string

type Writer 

type Writer struct {
	// contains filtered or unexported fields
}

func NewWriter 

func NewWriter(w io.Writer, database, rp string, duration time.Duration) *Writer

func (*Writer) Close 

func (w *Writer) Close() error

func (*Writer) NewBucket 

func (w *Writer) NewBucket(start, end int64) (format.BucketWriter, error)

func (*Writer) WriteStats 

func (w *Writer) WriteStats(o io.Writer)

Source Files

common.go messagetype_string.go reader.go tools_binary.pb.go writer.go

Version
v1.12.0 (latest)
Published
Apr 8, 2025
Platform
linux/amd64
Imports
18 packages
Last checked
2 days ago –

Tools for package owners.