flatb

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

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

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