mongo

package
v0.0.0-...-37fced7 Latest Latest
Warning

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

Go to latest
Published: Sep 21, 2023 License: MIT Imports: 13 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL