types

Documentation

Index

• Variables
• func GenerateUUID(uri SubscriptionURI, data []byte) uuid.UUID
• func ParseUUID(data string) uuid.UUID
• type Extract
• type ExtractedTimeseries
  • func (ts ExtractedTimeseries) Empty() bool
  • func (ts ExtractedTimeseries) String() string
• type SubscriptionURI
  • func (uri SubscriptionURI) Hash() string

Variables

var NoMatch = errors.New("No Match")

Functions

func GenerateUUID

func GenerateUUID(uri SubscriptionURI, data []byte) uuid.UUID

func ParseUUID

func ParseUUID(data string) uuid.UUID

Types

type Extract

type Extract func(uri SubscriptionURI, msg xbospb.XBOS, add func(ExtractedTimeseries) error) error

type ExtractedTimeseries

type ExtractedTimeseries struct {
	// values extracted from the message
	Values []float64
	// corresponding times for each above value
	Times []int64
	// engineering units
	Unit string
	// BTRDB specific below this point
	// stream identifier
	UUID uuid.UUID
	// possibly temporary properties
	Annotations map[string]string
	// permanent properties
	Tags    map[string]string
	IntTags map[string]int64
	// collection name
	Collection string
}

func (ExtractedTimeseries) Empty

func (ts ExtractedTimeseries) Empty() bool

func (ExtractedTimeseries) String

func (ts ExtractedTimeseries) String() string

type SubscriptionURI

type SubscriptionURI struct {
	// WAVE namespace (base64-encoded)
	Namespace string
	// '/'-delimited resource path to subscribe to
	Resource string
}

func (SubscriptionURI) Hash

func (uri SubscriptionURI) Hash() string