mongo

package

v0.0.0-...-177a272 Latest Latest Go to latest Published: Nov 13, 2023 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/nishithmongo/tsbsplay

Links

Open Source Insights

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)

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

Source Files ¶

View all Source files

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