mongo

Documentation

Index

• func MongoPointAddFields(builder *flatbuffers.Builder, fields flatbuffers.UOffsetT)
• func MongoPointAddMeasurementName(builder *flatbuffers.Builder, measurementName flatbuffers.UOffsetT)
• func MongoPointAddTags(builder *flatbuffers.Builder, tags flatbuffers.UOffsetT)
• func MongoPointAddTimestamp(builder *flatbuffers.Builder, timestamp int64)
• func MongoPointEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func MongoPointStart(builder *flatbuffers.Builder)
• func MongoPointStartFieldsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
• func MongoPointStartTagsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
• func MongoReadingAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
• func MongoReadingAddValue(builder *flatbuffers.Builder, value float64)
• func MongoReadingEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func MongoReadingStart(builder *flatbuffers.Builder)
• func MongoTagAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
• func MongoTagAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
• func MongoTagEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func MongoTagStart(builder *flatbuffers.Builder)
• func NewTarget() targets.ImplementedTarget
• type MongoPoint
  • func GetRootAsMongoPoint(buf []byte, offset flatbuffers.UOffsetT) *MongoPoint
  • func (rcv *MongoPoint) Fields(obj *MongoReading, j int) bool
  • func (rcv *MongoPoint) FieldsLength() int
  • func (rcv *MongoPoint) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *MongoPoint) MeasurementName() []byte
  • func (rcv *MongoPoint) MutateTimestamp(n int64) bool
  • func (rcv *MongoPoint) Table() flatbuffers.Table
  • func (rcv *MongoPoint) Tags(obj *MongoTag, j int) bool
  • func (rcv *MongoPoint) TagsLength() int
  • func (rcv *MongoPoint) Timestamp() int64
• type MongoReading
  • func GetRootAsMongoReading(buf []byte, offset flatbuffers.UOffsetT) *MongoReading
  • func (rcv *MongoReading) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *MongoReading) Key() []byte
  • func (rcv *MongoReading) MutateValue(n float64) bool
  • func (rcv *MongoReading) Table() flatbuffers.Table
  • func (rcv *MongoReading) Value() float64
• type MongoTag
  • func GetRootAsMongoTag(buf []byte, offset flatbuffers.UOffsetT) *MongoTag
  • func (rcv *MongoTag) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *MongoTag) Key() []byte
  • func (rcv *MongoTag) Table() flatbuffers.Table
  • func (rcv *MongoTag) Value() []byte
• type Serializer
  • func (s *Serializer) Serialize(p *data.Point, w io.Writer) (err error)

Functions

func MongoPointAddFields

func MongoPointAddFields(builder *flatbuffers.Builder, fields flatbuffers.UOffsetT)

func MongoPointAddMeasurementName

func MongoPointAddMeasurementName(builder *flatbuffers.Builder, measurementName flatbuffers.UOffsetT)

func MongoPointAddTags

func MongoPointAddTags(builder *flatbuffers.Builder, tags flatbuffers.UOffsetT)

func MongoPointAddTimestamp

func MongoPointAddTimestamp(builder *flatbuffers.Builder, timestamp int64)

func MongoPointEnd

func MongoPointEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func MongoPointStart

func MongoPointStart(builder *flatbuffers.Builder)

func MongoPointStartFieldsVector

func MongoPointStartFieldsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func MongoPointStartTagsVector

func MongoPointStartTagsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func MongoReadingAddKey

func MongoReadingAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)

func MongoReadingAddValue

func MongoReadingAddValue(builder *flatbuffers.Builder, value float64)

func MongoReadingEnd

func MongoReadingEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func MongoReadingStart

func MongoReadingStart(builder *flatbuffers.Builder)

func MongoTagAddKey

func MongoTagAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)

func MongoTagAddValue

func MongoTagAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func MongoTagEnd

func MongoTagEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func MongoTagStart

func MongoTagStart(builder *flatbuffers.Builder)

func NewTarget

func NewTarget() targets.ImplementedTarget

Types

type MongoPoint

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

func GetRootAsMongoPoint

func GetRootAsMongoPoint(buf []byte, offset flatbuffers.UOffsetT) *MongoPoint

func (*MongoPoint) Fields

func (rcv *MongoPoint) Fields(obj *MongoReading, j int) bool

func (*MongoPoint) FieldsLength

func (rcv *MongoPoint) FieldsLength() int

func (*MongoPoint) Init

func (rcv *MongoPoint) Init(buf []byte, i flatbuffers.UOffsetT)

func (*MongoPoint) MeasurementName

func (rcv *MongoPoint) MeasurementName() []byte

func (*MongoPoint) MutateTimestamp

func (rcv *MongoPoint) MutateTimestamp(n int64) bool

func (*MongoPoint) Table

func (rcv *MongoPoint) Table() flatbuffers.Table

func (*MongoPoint) Tags

func (rcv *MongoPoint) Tags(obj *MongoTag, j int) bool

func (*MongoPoint) TagsLength

func (rcv *MongoPoint) TagsLength() int

func (*MongoPoint) Timestamp

func (rcv *MongoPoint) Timestamp() int64

type MongoReading

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

func GetRootAsMongoReading

func GetRootAsMongoReading(buf []byte, offset flatbuffers.UOffsetT) *MongoReading

func (*MongoReading) Init

func (rcv *MongoReading) Init(buf []byte, i flatbuffers.UOffsetT)

func (*MongoReading) Key

func (rcv *MongoReading) Key() []byte

func (*MongoReading) MutateValue

func (rcv *MongoReading) MutateValue(n float64) bool

func (*MongoReading) Table

func (rcv *MongoReading) Table() flatbuffers.Table

func (*MongoReading) Value

func (rcv *MongoReading) Value() float64

type MongoTag

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

func GetRootAsMongoTag

func GetRootAsMongoTag(buf []byte, offset flatbuffers.UOffsetT) *MongoTag

func (*MongoTag) Init

func (rcv *MongoTag) Init(buf []byte, i flatbuffers.UOffsetT)

func (*MongoTag) Key

func (rcv *MongoTag) Key() []byte

func (*MongoTag) Table

func (rcv *MongoTag) Table() flatbuffers.Table

func (*MongoTag) Value

func (rcv *MongoTag) Value() []byte

type Serializer

type Serializer struct{}

Serializer writes a Point in a serialized form for MongoDB

func (*Serializer) Serialize

func (s *Serializer) Serialize(p *data.Point, w io.Writer) (err error)

Serialize writes Point data to the given Writer, using basic gob encoding