flatb

package

v1.1.2 Latest Latest Go to latest Published: Oct 1, 2019 License: MPL-2.0 Imports: 2 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.ccut.club/blind-oracle/riemann-relay

Links

Open Source Insights

Documentation ¶

Index ¶

func AttrAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
func AttrAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
func AttrEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func AttrStart(builder *flatbuffers.Builder)
func BatchAddMetrics(builder *flatbuffers.Builder, metrics flatbuffers.UOffsetT)
func BatchEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func BatchStart(builder *flatbuffers.Builder)
func BatchStartMetricsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func MetricAddAttrs(builder *flatbuffers.Builder, attrs flatbuffers.UOffsetT)
func MetricAddDescription(builder *flatbuffers.Builder, description flatbuffers.UOffsetT)
func MetricAddHost(builder *flatbuffers.Builder, host flatbuffers.UOffsetT)
func MetricAddService(builder *flatbuffers.Builder, service flatbuffers.UOffsetT)
func MetricAddState(builder *flatbuffers.Builder, state flatbuffers.UOffsetT)
func MetricAddTags(builder *flatbuffers.Builder, tags flatbuffers.UOffsetT)
func MetricAddTime(builder *flatbuffers.Builder, time int64)
func MetricAddValue(builder *flatbuffers.Builder, value float64)
func MetricEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func MetricFromRiemannEvents(b *fb.Builder, evs []*rpb.Event)
func MetricStart(builder *flatbuffers.Builder)
func MetricStartAttrsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func MetricStartTagsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
type Attr
- func GetRootAsAttr(buf []byte, offset flatbuffers.UOffsetT) *Attr
- func (rcv *Attr) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Attr) Key() []byte
- func (rcv *Attr) Table() flatbuffers.Table
- func (rcv *Attr) Value() []byte
type Batch
- func GetRootAsBatch(buf []byte, offset flatbuffers.UOffsetT) *Batch
- func (rcv *Batch) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Batch) Metrics(obj *Metric, j int) bool
- func (rcv *Batch) MetricsLength() int
- func (rcv *Batch) Table() flatbuffers.Table
type Metric
- func GetRootAsMetric(buf []byte, offset flatbuffers.UOffsetT) *Metric
- func (rcv *Metric) Attrs(obj *Attr, j int) bool
- func (rcv *Metric) AttrsLength() int
- func (rcv *Metric) Description() []byte
- func (rcv *Metric) Host() []byte
- func (rcv *Metric) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Metric) MutateTime(n int64) bool
- func (rcv *Metric) MutateValue(n float64) bool
- func (rcv *Metric) Service() []byte
- func (rcv *Metric) State() []byte
- func (rcv *Metric) Table() flatbuffers.Table
- func (rcv *Metric) Tags(j int) []byte
- func (rcv *Metric) TagsLength() int
- func (rcv *Metric) Time() int64
- func (rcv *Metric) Value() float64

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AttrAddKey ¶

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

func AttrAddValue ¶

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

func AttrEnd ¶

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

func AttrStart ¶

func AttrStart(builder *flatbuffers.Builder)

func BatchAddMetrics ¶

func BatchAddMetrics(builder *flatbuffers.Builder, metrics flatbuffers.UOffsetT)

func BatchEnd ¶

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

func BatchStart ¶

func BatchStart(builder *flatbuffers.Builder)

func BatchStartMetricsVector ¶

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

func MetricAddAttrs ¶

func MetricAddAttrs(builder *flatbuffers.Builder, attrs flatbuffers.UOffsetT)

func MetricAddDescription ¶

func MetricAddDescription(builder *flatbuffers.Builder, description flatbuffers.UOffsetT)

func MetricAddHost ¶

func MetricAddHost(builder *flatbuffers.Builder, host flatbuffers.UOffsetT)

func MetricAddService ¶

func MetricAddService(builder *flatbuffers.Builder, service flatbuffers.UOffsetT)

func MetricAddState ¶

func MetricAddState(builder *flatbuffers.Builder, state flatbuffers.UOffsetT)

func MetricAddTags ¶

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

func MetricAddTime ¶

func MetricAddTime(builder *flatbuffers.Builder, time int64)

func MetricAddValue ¶

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

func MetricEnd ¶

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

func MetricFromRiemannEvents ¶ added in v1.1.1

func MetricFromRiemannEvents(b *fb.Builder, evs []*rpb.Event)

MetricFromRiemannEvents converts a slice of Riemann events to flatbuffer

func MetricStart ¶

func MetricStart(builder *flatbuffers.Builder)

func MetricStartAttrsVector ¶

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

func MetricStartTagsVector ¶

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

Types ¶

type Attr ¶

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

func GetRootAsAttr ¶

func GetRootAsAttr(buf []byte, offset flatbuffers.UOffsetT) *Attr

func (*Attr) Init ¶

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

func (*Attr) Key ¶

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

func (*Attr) Table ¶

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

func (*Attr) Value ¶

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

type Batch ¶

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

func GetRootAsBatch ¶

func GetRootAsBatch(buf []byte, offset flatbuffers.UOffsetT) *Batch

func (*Batch) Init ¶

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

func (*Batch) Metrics ¶

func (rcv *Batch) Metrics(obj *Metric, j int) bool

func (*Batch) MetricsLength ¶

func (rcv *Batch) MetricsLength() int

func (*Batch) Table ¶

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

type Metric ¶

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

func GetRootAsMetric ¶

func GetRootAsMetric(buf []byte, offset flatbuffers.UOffsetT) *Metric

func (*Metric) Attrs ¶

func (rcv *Metric) Attrs(obj *Attr, j int) bool

func (*Metric) AttrsLength ¶

func (rcv *Metric) AttrsLength() int

func (*Metric) Description ¶

func (rcv *Metric) Description() []byte

func (*Metric) Host ¶

func (rcv *Metric) Host() []byte

func (*Metric) Init ¶

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

func (*Metric) MutateTime ¶

func (rcv *Metric) MutateTime(n int64) bool

func (*Metric) MutateValue ¶

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

func (*Metric) Service ¶

func (rcv *Metric) Service() []byte

func (*Metric) State ¶

func (rcv *Metric) State() []byte

func (*Metric) Table ¶

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

func (*Metric) Tags ¶

func (rcv *Metric) Tags(j int) []byte

func (*Metric) TagsLength ¶

func (rcv *Metric) TagsLength() int

func (*Metric) Time ¶

func (rcv *Metric) Time() int64

func (*Metric) Value ¶

func (rcv *Metric) Value() float64

Source Files ¶

View all Source files

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