Versions in this module Expand all Collapse all v1 v1.7.1 Nov 14, 2018 v1.7.0 Nov 7, 2018 Changes in this version + var ErrIntOverflowBinary = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthBinary = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrWriteAfterClose = errors.New("format/binary: write after close") + var ErrWriteBucketAfterClose = errors.New("format/binary: write to closed bucket") + var FieldType_name = map[int32]string + var FieldType_value = map[string]int32 + var Header_Version_name = map[int32]string + var Header_Version_value = map[string]int32 + var Magic = [...]byte + type BooleanPoints struct + Timestamps []int64 + Values []bool + func (*BooleanPoints) Descriptor() ([]byte, []int) + func (*BooleanPoints) ProtoMessage() + func (m *BooleanPoints) Marshal() (dAtA []byte, err error) + func (m *BooleanPoints) MarshalTo(dAtA []byte) (int, error) + func (m *BooleanPoints) Reset() + func (m *BooleanPoints) Size() (n int) + func (m *BooleanPoints) String() string + func (m *BooleanPoints) Unmarshal(dAtA []byte) error + type BucketFooter struct + func (*BucketFooter) Descriptor() ([]byte, []int) + func (*BucketFooter) ProtoMessage() + func (m *BucketFooter) Marshal() (dAtA []byte, err error) + func (m *BucketFooter) MarshalTo(dAtA []byte) (int, error) + func (m *BucketFooter) Reset() + func (m *BucketFooter) Size() (n int) + func (m *BucketFooter) String() string + func (m *BucketFooter) Unmarshal(dAtA []byte) error + type BucketHeader struct + End int64 + Start int64 + func (*BucketHeader) Descriptor() ([]byte, []int) + func (*BucketHeader) ProtoMessage() + func (m *BucketHeader) Marshal() (dAtA []byte, err error) + func (m *BucketHeader) MarshalTo(dAtA []byte) (int, error) + func (m *BucketHeader) Reset() + func (m *BucketHeader) Size() (n int) + func (m *BucketHeader) String() string + func (m *BucketHeader) Unmarshal(dAtA []byte) error + type FieldType int32 + const BooleanFieldType + const FloatFieldType + const IntegerFieldType + const StringFieldType + const UnsignedFieldType + func (FieldType) EnumDescriptor() ([]byte, []int) + func (x FieldType) String() string + type FloatPoints struct + Timestamps []int64 + Values []float64 + func (*FloatPoints) Descriptor() ([]byte, []int) + func (*FloatPoints) ProtoMessage() + func (m *FloatPoints) Marshal() (dAtA []byte, err error) + func (m *FloatPoints) MarshalTo(dAtA []byte) (int, error) + func (m *FloatPoints) Reset() + func (m *FloatPoints) Size() (n int) + func (m *FloatPoints) String() string + func (m *FloatPoints) Unmarshal(dAtA []byte) error + type Header struct + Database string + RetentionPolicy string + ShardDuration time.Duration + Version Header_Version + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (m *Header) Marshal() (dAtA []byte, err error) + func (m *Header) MarshalTo(dAtA []byte) (int, error) + func (m *Header) Reset() + func (m *Header) Size() (n int) + func (m *Header) String() string + func (m *Header) Unmarshal(dAtA []byte) error + type Header_Version int32 + const Version0 + func (Header_Version) EnumDescriptor() ([]byte, []int) + func (x Header_Version) String() string + type IntegerPoints struct + Timestamps []int64 + Values []int64 + func (*IntegerPoints) Descriptor() ([]byte, []int) + func (*IntegerPoints) ProtoMessage() + func (m *IntegerPoints) Marshal() (dAtA []byte, err error) + func (m *IntegerPoints) MarshalTo(dAtA []byte) (int, error) + func (m *IntegerPoints) Reset() + func (m *IntegerPoints) Size() (n int) + func (m *IntegerPoints) String() string + func (m *IntegerPoints) Unmarshal(dAtA []byte) error + type MessageType byte + const BooleanPointsType + const BucketFooterType + const BucketHeaderType + const FloatPointsType + const HeaderType + const IntegerPointsType + const SeriesFooterType + const SeriesHeaderType + const StringPointsType + const UnsignedPointsType + func (i MessageType) String() string + type PointsReader struct + func (pr *PointsReader) Next() (bool, error) + func (pr *PointsReader) Reset(pointsType MessageType) + func (pr *PointsReader) Values() tsm1.Values + type Reader struct + func NewReader(reader io.Reader) *Reader + func (r *Reader) Close() error + func (r *Reader) NextBucket() (*BucketHeader, error) + func (r *Reader) NextSeries() (*SeriesHeader, error) + func (r *Reader) Points() *PointsReader + func (r *Reader) ReadHeader() (*Header, error) + type SeriesFooter struct + func (*SeriesFooter) Descriptor() ([]byte, []int) + func (*SeriesFooter) ProtoMessage() + func (m *SeriesFooter) Marshal() (dAtA []byte, err error) + func (m *SeriesFooter) MarshalTo(dAtA []byte) (int, error) + func (m *SeriesFooter) Reset() + func (m *SeriesFooter) Size() (n int) + func (m *SeriesFooter) String() string + func (m *SeriesFooter) Unmarshal(dAtA []byte) error + type SeriesHeader struct + Field []byte + FieldType FieldType + SeriesKey []byte + func (*SeriesHeader) Descriptor() ([]byte, []int) + func (*SeriesHeader) ProtoMessage() + func (m *SeriesHeader) Marshal() (dAtA []byte, err error) + func (m *SeriesHeader) MarshalTo(dAtA []byte) (int, error) + func (m *SeriesHeader) Reset() + func (m *SeriesHeader) Size() (n int) + func (m *SeriesHeader) String() string + func (m *SeriesHeader) Unmarshal(dAtA []byte) error + type StringPoints struct + Timestamps []int64 + Values []string + func (*StringPoints) Descriptor() ([]byte, []int) + func (*StringPoints) ProtoMessage() + func (m *StringPoints) Marshal() (dAtA []byte, err error) + func (m *StringPoints) MarshalTo(dAtA []byte) (int, error) + func (m *StringPoints) Reset() + func (m *StringPoints) Size() (n int) + func (m *StringPoints) String() string + func (m *StringPoints) Unmarshal(dAtA []byte) error + type UnsignedPoints struct + Timestamps []int64 + Values []uint64 + func (*UnsignedPoints) Descriptor() ([]byte, []int) + func (*UnsignedPoints) ProtoMessage() + func (m *UnsignedPoints) Marshal() (dAtA []byte, err error) + func (m *UnsignedPoints) MarshalTo(dAtA []byte) (int, error) + func (m *UnsignedPoints) Reset() + func (m *UnsignedPoints) Size() (n int) + func (m *UnsignedPoints) String() string + func (m *UnsignedPoints) Unmarshal(dAtA []byte) error + type Writer struct + func NewWriter(w io.Writer, database, rp string, duration time.Duration) *Writer + func (w *Writer) Close() error + func (w *Writer) NewBucket(start, end int64) (format.BucketWriter, error) + func (w *Writer) WriteStats(o io.Writer)
Go to main page