RowBinary

Documentation

Index

• Constants
• func ReverseBytes(target []byte) []byte
• type Reader
  • func NewReader(filename string) (*Reader, error)
  • func NewReverseReader(filename string) (*Reader, error)
  • func (r *Reader) Close()
  • func (r *Reader) Days() uint16
  • func (r *Reader) DaysString() string
  • func (r *Reader) Read(p []byte) (int, error)
  • func (r *Reader) ReadRecord() ([]byte, error)
  • func (r *Reader) Timestamp() uint32
  • func (r *Reader) Value() float64
  • func (r *Reader) Version() uint32
• type WriteBuffer
  • func GetWriteBuffer() *WriteBuffer
  • func GetWriterBufferWithConfirm(wg *sync.WaitGroup, errorChan chan error) *WriteBuffer
  • func (wb *WriteBuffer) Bytes() []byte
  • func (wb *WriteBuffer) CanWriteGraphitePoint(metricLen int) bool
  • func (wb *WriteBuffer) Confirm()
  • func (wb *WriteBuffer) ConfirmRequired() bool
  • func (wb *WriteBuffer) Empty() bool
  • func (wb *WriteBuffer) Fail(err error)
  • func (wb *WriteBuffer) Release()
  • func (wb *WriteBuffer) Reset() *WriteBuffer
  • func (wb *WriteBuffer) Write(p []byte)
  • func (wb *WriteBuffer) WriteBytes(p []byte)
  • func (wb *WriteBuffer) WriteFloat64(value float64)
  • func (wb *WriteBuffer) WriteGraphitePoint(name []byte, value float64, timestamp uint32, days uint16, version uint32)
  • func (wb *WriteBuffer) WriteReversePath(p []byte)
  • func (wb *WriteBuffer) WriteUint16(value uint16)
  • func (wb *WriteBuffer) WriteUint32(value uint32)
  • func (wb *WriteBuffer) WriteUint64(value uint64)

Constants

const WriteBufferSize = 524288

Functions

func ReverseBytes

func ReverseBytes(target []byte) []byte

Types

type Reader

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

Read all good records from unfinished RowBinary file.

func NewReader

func NewReader(filename string) (*Reader, error)

func NewReverseReader

func NewReverseReader(filename string) (*Reader, error)

func (*Reader) Close

func (r *Reader) Close()

func (*Reader) Days

func (r *Reader) Days() uint16

func (*Reader) DaysString

func (r *Reader) DaysString() string

func (*Reader) Read

func (r *Reader) Read(p []byte) (int, error)

func (*Reader) ReadRecord

func (r *Reader) ReadRecord() ([]byte, error)

func (*Reader) Timestamp

func (r *Reader) Timestamp() uint32

func (*Reader) Value

func (r *Reader) Value() float64

func (*Reader) Version

func (r *Reader) Version() uint32

type WriteBuffer

type WriteBuffer struct {
	Used int
	Body [WriteBufferSize]byte
	// contains filtered or unexported fields
}

func GetWriteBuffer

func GetWriteBuffer() *WriteBuffer

func GetWriterBufferWithConfirm

func GetWriterBufferWithConfirm(wg *sync.WaitGroup, errorChan chan error) *WriteBuffer

func (*WriteBuffer) Bytes

func (wb *WriteBuffer) Bytes() []byte

func (*WriteBuffer) CanWriteGraphitePoint

func (wb *WriteBuffer) CanWriteGraphitePoint(metricLen int) bool

func (*WriteBuffer) Confirm

func (wb *WriteBuffer) Confirm()

func (*WriteBuffer) ConfirmRequired

func (wb *WriteBuffer) ConfirmRequired() bool

func (*WriteBuffer) Empty

func (wb *WriteBuffer) Empty() bool

func (*WriteBuffer) Fail

func (wb *WriteBuffer) Fail(err error)

func (*WriteBuffer) Release

func (wb *WriteBuffer) Release()

func (*WriteBuffer) Reset

func (wb *WriteBuffer) Reset() *WriteBuffer

func (*WriteBuffer) Write

func (wb *WriteBuffer) Write(p []byte)

func (*WriteBuffer) WriteBytes

func (wb *WriteBuffer) WriteBytes(p []byte)

func (*WriteBuffer) WriteFloat64

func (wb *WriteBuffer) WriteFloat64(value float64)

func (*WriteBuffer) WriteGraphitePoint

func (wb *WriteBuffer) WriteGraphitePoint(name []byte, value float64, timestamp uint32, days uint16, version uint32)

func (*WriteBuffer) WriteReversePath

func (wb *WriteBuffer) WriteReversePath(p []byte)

func (*WriteBuffer) WriteUint16

func (wb *WriteBuffer) WriteUint16(value uint16)

func (*WriteBuffer) WriteUint32

func (wb *WriteBuffer) WriteUint32(value uint32)

func (*WriteBuffer) WriteUint64

func (wb *WriteBuffer) WriteUint64(value uint64)