binary

package
v1.8.7 Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2021 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBinary        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBinary          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBinary = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrWriteAfterClose       = errors.New("format/binary: write after close")
	ErrWriteBucketAfterClose = errors.New("format/binary: write to closed bucket")
)
View Source 
var FieldType_name = map[int32]string{
	0: "FLOAT",
	1: "INTEGER",
	2: "UNSIGNED",
	3: "BOOLEAN",
	4: "STRING",
}
View Source 
var FieldType_value = map[string]int32{
	"FLOAT":    0,
	"INTEGER":  1,
	"UNSIGNED": 2,
	"BOOLEAN":  3,
	"STRING":   4,
}
View Source 
var Header_Version_name = map[int32]string{
	0: "VERSION_0",
}
View Source 
var Header_Version_value = map[string]int32{
	"VERSION_0": 0,
}
View Source 
var (
	Magic = [...]byte{0x49, 0x46, 0x4c, 0x58, 0x44, 0x55, 0x4d, 0x50} // IFLXDUMP
)

Functions

This section is empty.

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"`
}

func (*BooleanPoints) Descriptor 

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

func (*BooleanPoints) Marshal 

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

func (*BooleanPoints) MarshalTo 

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

func (*BooleanPoints) MarshalToSizedBuffer added in v1.8.7 

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

func (*BooleanPoints) ProtoMessage 

func (*BooleanPoints) ProtoMessage()

func (*BooleanPoints) Reset 

func (m *BooleanPoints) Reset()

func (*BooleanPoints) Size 

func (m *BooleanPoints) Size() (n int)

func (*BooleanPoints) String 

func (m *BooleanPoints) String() string

func (*BooleanPoints) Unmarshal 

func (m *BooleanPoints) Unmarshal(dAtA []byte) error

func (*BooleanPoints) XXX_DiscardUnknown added in v1.8.7 

func (m *BooleanPoints) XXX_DiscardUnknown()

func (*BooleanPoints) XXX_Marshal added in v1.8.7 

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

func (*BooleanPoints) XXX_Merge added in v1.8.7 

func (m *BooleanPoints) XXX_Merge(src proto.Message)

func (*BooleanPoints) XXX_Size added in v1.8.7 

func (m *BooleanPoints) XXX_Size() int

func (*BooleanPoints) XXX_Unmarshal added in v1.8.7 

func (m *BooleanPoints) XXX_Unmarshal(b []byte) error

type BucketFooter 

type BucketFooter struct {
}

func (*BucketFooter) Descriptor 

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

func (*BucketFooter) Marshal 

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

func (*BucketFooter) MarshalTo 

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

func (*BucketFooter) MarshalToSizedBuffer added in v1.8.7 

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

func (*BucketFooter) ProtoMessage 

func (*BucketFooter) ProtoMessage()

func (*BucketFooter) Reset 

func (m *BucketFooter) Reset()

func (*BucketFooter) Size 

func (m *BucketFooter) Size() (n int)

func (*BucketFooter) String 

func (m *BucketFooter) String() string

func (*BucketFooter) Unmarshal 

func (m *BucketFooter) Unmarshal(dAtA []byte) error

func (*BucketFooter) XXX_DiscardUnknown added in v1.8.7 

func (m *BucketFooter) XXX_DiscardUnknown()

func (*BucketFooter) XXX_Marshal added in v1.8.7 

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

func (*BucketFooter) XXX_Merge added in v1.8.7 

func (m *BucketFooter) XXX_Merge(src proto.Message)

func (*BucketFooter) XXX_Size added in v1.8.7 

func (m *BucketFooter) XXX_Size() int

func (*BucketFooter) XXX_Unmarshal added in v1.8.7 

func (m *BucketFooter) XXX_Unmarshal(b []byte) error

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"`
}

func (*BucketHeader) Descriptor 

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

func (*BucketHeader) Marshal 

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

func (*BucketHeader) MarshalTo 

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

func (*BucketHeader) MarshalToSizedBuffer added in v1.8.7 

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

func (*BucketHeader) ProtoMessage 

func (*BucketHeader) ProtoMessage()

func (*BucketHeader) Reset 

func (m *BucketHeader) Reset()

func (*BucketHeader) Size 

func (m *BucketHeader) Size() (n int)

func (*BucketHeader) String 

func (m *BucketHeader) String() string

func (*BucketHeader) Unmarshal 

func (m *BucketHeader) Unmarshal(dAtA []byte) error

func (*BucketHeader) XXX_DiscardUnknown added in v1.8.7 

func (m *BucketHeader) XXX_DiscardUnknown()

func (*BucketHeader) XXX_Marshal added in v1.8.7 

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

func (*BucketHeader) XXX_Merge added in v1.8.7 

func (m *BucketHeader) XXX_Merge(src proto.Message)

func (*BucketHeader) XXX_Size added in v1.8.7 

func (m *BucketHeader) XXX_Size() int

func (*BucketHeader) XXX_Unmarshal added in v1.8.7 

func (m *BucketHeader) XXX_Unmarshal(b []byte) error

type FieldType 

type FieldType int32
const (
	FloatFieldType    FieldType = 0
	IntegerFieldType  FieldType = 1
	UnsignedFieldType FieldType = 2
	BooleanFieldType  FieldType = 3
	StringFieldType   FieldType = 4
)

func (FieldType) EnumDescriptor 

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

func (FieldType) String 

func (x FieldType) String() string

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"`
}

func (*FloatPoints) Descriptor 

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

func (*FloatPoints) Marshal 

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

func (*FloatPoints) MarshalTo 

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

func (*FloatPoints) MarshalToSizedBuffer added in v1.8.7 

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

func (*FloatPoints) ProtoMessage 

func (*FloatPoints) ProtoMessage()

func (*FloatPoints) Reset 

func (m *FloatPoints) Reset()

func (*FloatPoints) Size 

func (m *FloatPoints) Size() (n int)

func (*FloatPoints) String 

func (m *FloatPoints) String() string

func (*FloatPoints) Unmarshal 

func (m *FloatPoints) Unmarshal(dAtA []byte) error

func (*FloatPoints) XXX_DiscardUnknown added in v1.8.7 

func (m *FloatPoints) XXX_DiscardUnknown()

func (*FloatPoints) XXX_Marshal added in v1.8.7 

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

func (*FloatPoints) XXX_Merge added in v1.8.7 

func (m *FloatPoints) XXX_Merge(src proto.Message)

func (*FloatPoints) XXX_Size added in v1.8.7 

func (m *FloatPoints) XXX_Size() int

func (*FloatPoints) XXX_Unmarshal added in v1.8.7 

func (m *FloatPoints) XXX_Unmarshal(b []byte) error
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   time.Duration  `protobuf:"varint,4,opt,name=shard_duration,json=shardDuration,proto3,stdduration" json:"shard_duration,omitempty"`
}

func (*Header) Descriptor 

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

func (*Header) Marshal 

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

func (*Header) MarshalTo 

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

func (*Header) MarshalToSizedBuffer added in v1.8.7 

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

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

func (m *Header) Size() (n int)

func (*Header) String 

func (m *Header) String() string

func (*Header) Unmarshal 

func (m *Header) Unmarshal(dAtA []byte) error

func (*Header) XXX_DiscardUnknown added in v1.8.7 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal added in v1.8.7 

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

func (*Header) XXX_Merge added in v1.8.7 

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size added in v1.8.7 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal added in v1.8.7 

func (m *Header) XXX_Unmarshal(b []byte) error

type Header_Version 

type Header_Version int32
const (
	Version0 Header_Version = 0
)

func (Header_Version) EnumDescriptor 

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

func (Header_Version) String 

func (x Header_Version) String() string

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"`
}

func (*IntegerPoints) Descriptor 

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

func (*IntegerPoints) Marshal 

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

func (*IntegerPoints) MarshalTo 

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

func (*IntegerPoints) MarshalToSizedBuffer added in v1.8.7 

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

func (*IntegerPoints) ProtoMessage 

func (*IntegerPoints) ProtoMessage()

func (*IntegerPoints) Reset 

func (m *IntegerPoints) Reset()

func (*IntegerPoints) Size 

func (m *IntegerPoints) Size() (n int)

func (*IntegerPoints) String 

func (m *IntegerPoints) String() string

func (*IntegerPoints) Unmarshal 

func (m *IntegerPoints) Unmarshal(dAtA []byte) error

func (*IntegerPoints) XXX_DiscardUnknown added in v1.8.7 

func (m *IntegerPoints) XXX_DiscardUnknown()

func (*IntegerPoints) XXX_Marshal added in v1.8.7 

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

func (*IntegerPoints) XXX_Merge added in v1.8.7 

func (m *IntegerPoints) XXX_Merge(src proto.Message)

func (*IntegerPoints) XXX_Size added in v1.8.7 

func (m *IntegerPoints) XXX_Size() int

func (*IntegerPoints) XXX_Unmarshal added in v1.8.7 

func (m *IntegerPoints) XXX_Unmarshal(b []byte) error

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 {
}

func (*SeriesFooter) Descriptor 

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

func (*SeriesFooter) Marshal 

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

func (*SeriesFooter) MarshalTo 

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

func (*SeriesFooter) MarshalToSizedBuffer added in v1.8.7 

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

func (*SeriesFooter) ProtoMessage 

func (*SeriesFooter) ProtoMessage()

func (*SeriesFooter) Reset 

func (m *SeriesFooter) Reset()

func (*SeriesFooter) Size 

func (m *SeriesFooter) Size() (n int)

func (*SeriesFooter) String 

func (m *SeriesFooter) String() string

func (*SeriesFooter) Unmarshal 

func (m *SeriesFooter) Unmarshal(dAtA []byte) error

func (*SeriesFooter) XXX_DiscardUnknown added in v1.8.7 

func (m *SeriesFooter) XXX_DiscardUnknown()

func (*SeriesFooter) XXX_Marshal added in v1.8.7 

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

func (*SeriesFooter) XXX_Merge added in v1.8.7 

func (m *SeriesFooter) XXX_Merge(src proto.Message)

func (*SeriesFooter) XXX_Size added in v1.8.7 

func (m *SeriesFooter) XXX_Size() int

func (*SeriesFooter) XXX_Unmarshal added in v1.8.7 

func (m *SeriesFooter) XXX_Unmarshal(b []byte) error

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"`
}

func (*SeriesHeader) Descriptor 

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

func (*SeriesHeader) Marshal 

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

func (*SeriesHeader) MarshalTo 

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

func (*SeriesHeader) MarshalToSizedBuffer added in v1.8.7 

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

func (*SeriesHeader) ProtoMessage 

func (*SeriesHeader) ProtoMessage()

func (*SeriesHeader) Reset 

func (m *SeriesHeader) Reset()

func (*SeriesHeader) Size 

func (m *SeriesHeader) Size() (n int)

func (*SeriesHeader) String 

func (m *SeriesHeader) String() string

func (*SeriesHeader) Unmarshal 

func (m *SeriesHeader) Unmarshal(dAtA []byte) error

func (*SeriesHeader) XXX_DiscardUnknown added in v1.8.7 

func (m *SeriesHeader) XXX_DiscardUnknown()

func (*SeriesHeader) XXX_Marshal added in v1.8.7 

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

func (*SeriesHeader) XXX_Merge added in v1.8.7 

func (m *SeriesHeader) XXX_Merge(src proto.Message)

func (*SeriesHeader) XXX_Size added in v1.8.7 

func (m *SeriesHeader) XXX_Size() int

func (*SeriesHeader) XXX_Unmarshal added in v1.8.7 

func (m *SeriesHeader) XXX_Unmarshal(b []byte) error

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"`
}

func (*StringPoints) Descriptor 

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

func (*StringPoints) Marshal 

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

func (*StringPoints) MarshalTo 

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

func (*StringPoints) MarshalToSizedBuffer added in v1.8.7 

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

func (*StringPoints) ProtoMessage 

func (*StringPoints) ProtoMessage()

func (*StringPoints) Reset 

func (m *StringPoints) Reset()

func (*StringPoints) Size 

func (m *StringPoints) Size() (n int)

func (*StringPoints) String 

func (m *StringPoints) String() string

func (*StringPoints) Unmarshal 

func (m *StringPoints) Unmarshal(dAtA []byte) error

func (*StringPoints) XXX_DiscardUnknown added in v1.8.7 

func (m *StringPoints) XXX_DiscardUnknown()

func (*StringPoints) XXX_Marshal added in v1.8.7 

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

func (*StringPoints) XXX_Merge added in v1.8.7 

func (m *StringPoints) XXX_Merge(src proto.Message)

func (*StringPoints) XXX_Size added in v1.8.7 

func (m *StringPoints) XXX_Size() int

func (*StringPoints) XXX_Unmarshal added in v1.8.7 

func (m *StringPoints) XXX_Unmarshal(b []byte) error

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"`
}

func (*UnsignedPoints) Descriptor 

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

func (*UnsignedPoints) Marshal 

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

func (*UnsignedPoints) MarshalTo 

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

func (*UnsignedPoints) MarshalToSizedBuffer added in v1.8.7 

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

func (*UnsignedPoints) ProtoMessage 

func (*UnsignedPoints) ProtoMessage()

func (*UnsignedPoints) Reset 

func (m *UnsignedPoints) Reset()

func (*UnsignedPoints) Size 

func (m *UnsignedPoints) Size() (n int)

func (*UnsignedPoints) String 

func (m *UnsignedPoints) String() string

func (*UnsignedPoints) Unmarshal 

func (m *UnsignedPoints) Unmarshal(dAtA []byte) error

func (*UnsignedPoints) XXX_DiscardUnknown added in v1.8.7 

func (m *UnsignedPoints) XXX_DiscardUnknown()

func (*UnsignedPoints) XXX_Marshal added in v1.8.7 

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

func (*UnsignedPoints) XXX_Merge added in v1.8.7 

func (m *UnsignedPoints) XXX_Merge(src proto.Message)

func (*UnsignedPoints) XXX_Size added in v1.8.7 

func (m *UnsignedPoints) XXX_Size() int

func (*UnsignedPoints) XXX_Unmarshal added in v1.8.7 

func (m *UnsignedPoints) XXX_Unmarshal(b []byte) error

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.