Documentation
¶
Index ¶
- Constants
- Variables
- func GetFiles(domain, key string, start, end time.Time, tAggr TimeAggrLevel) []string
- func ParseRecords(in []Record, tAggr TimeAggrLevel) map[string]Table
- func RecordToCSV(raw Record) (line string)
- type DataAggrFunc
- type DataAggrLevel
- type DataAggrMethod
- type DataQueryRecord
- func (*DataQueryRecord) Descriptor() ([]byte, []int)deprecated
- func (x *DataQueryRecord) GetTimestamp() int64
- func (x *DataQueryRecord) GetValue() string
- func (*DataQueryRecord) ProtoMessage()
- func (x *DataQueryRecord) ProtoReflect() protoreflect.Message
- func (x *DataQueryRecord) Reset()
- func (x *DataQueryRecord) String() string
- type DataQueryResult
- func (*DataQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *DataQueryResult) GetDomain() string
- func (x *DataQueryResult) GetField() string
- func (x *DataQueryResult) GetKey() string
- func (x *DataQueryResult) GetRecords() []*DataQueryRecord
- func (*DataQueryResult) ProtoMessage()
- func (x *DataQueryResult) ProtoReflect() protoreflect.Message
- func (x *DataQueryResult) Reset()
- func (x *DataQueryResult) String() string
- type DataQueryResults
- func (*DataQueryResults) Descriptor() ([]byte, []int)deprecated
- func (x *DataQueryResults) GetResults() []*DataQueryResult
- func (*DataQueryResults) ProtoMessage()
- func (x *DataQueryResults) ProtoReflect() protoreflect.Message
- func (x *DataQueryResults) Reset()
- func (x *DataQueryResults) String() string
- type DomainMetadataList
- func (*DomainMetadataList) Descriptor() ([]byte, []int)deprecated
- func (x *DomainMetadataList) GetDomain() string
- func (x *DomainMetadataList) GetKeys() []string
- func (x *DomainMetadataList) GetMetadata() map[string]*MetadataValuesList
- func (x *DomainMetadataList) GetTags() []string
- func (*DomainMetadataList) ProtoMessage()
- func (x *DomainMetadataList) ProtoReflect() protoreflect.Message
- func (x *DomainMetadataList) Reset()
- func (x *DomainMetadataList) String() string
- type KeyMetadata
- func (*KeyMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *KeyMetadata) GetDomain() string
- func (x *KeyMetadata) GetKey() string
- func (x *KeyMetadata) GetLocation() []*PointSpan
- func (x *KeyMetadata) GetMetadata() map[string]*Metadata
- func (x *KeyMetadata) GetRelations() map[string]*RelationSpans
- func (x *KeyMetadata) GetSpan() []*Timespan
- func (x *KeyMetadata) GetTags() map[string]*Tag
- func (*KeyMetadata) ProtoMessage()
- func (x *KeyMetadata) ProtoReflect() protoreflect.Message
- func (x *KeyMetadata) Reset()
- func (x *KeyMetadata) String() string
- type KeyMetadataList
- type KeyMetadataSnapshot
- func (*KeyMetadataSnapshot) Descriptor() ([]byte, []int)deprecated
- func (x *KeyMetadataSnapshot) GetDomain() string
- func (x *KeyMetadataSnapshot) GetKey() string
- func (x *KeyMetadataSnapshot) GetLocation() *Point
- func (x *KeyMetadataSnapshot) GetMetadata() map[string]string
- func (x *KeyMetadataSnapshot) GetMoment() int64
- func (x *KeyMetadataSnapshot) GetRelations() []*SnapshotRelation
- func (x *KeyMetadataSnapshot) GetTags() []string
- func (*KeyMetadataSnapshot) ProtoMessage()
- func (x *KeyMetadataSnapshot) ProtoReflect() protoreflect.Message
- func (x *KeyMetadataSnapshot) Reset()
- func (x *KeyMetadataSnapshot) String() string
- type KeyMetadataSnapshotList
- func (*KeyMetadataSnapshotList) Descriptor() ([]byte, []int)deprecated
- func (x *KeyMetadataSnapshotList) GetMetadata() []*KeyMetadataSnapshot
- func (*KeyMetadataSnapshotList) ProtoMessage()
- func (x *KeyMetadataSnapshotList) ProtoReflect() protoreflect.Message
- func (x *KeyMetadataSnapshotList) Reset()
- func (x *KeyMetadataSnapshotList) String() string
- type Metadata
- type MetadataValue
- func (*MetadataValue) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataValue) GetSpan() *Timespan
- func (x *MetadataValue) GetValue() string
- func (*MetadataValue) ProtoMessage()
- func (x *MetadataValue) ProtoReflect() protoreflect.Message
- func (x *MetadataValue) Reset()
- func (x *MetadataValue) String() string
- type MetadataValuesList
- func (*MetadataValuesList) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataValuesList) GetName() string
- func (x *MetadataValuesList) GetValues() []string
- func (*MetadataValuesList) ProtoMessage()
- func (x *MetadataValuesList) ProtoReflect() protoreflect.Message
- func (x *MetadataValuesList) Reset()
- func (x *MetadataValuesList) String() string
- type Point
- type PointSpan
- type Record
- type RelationSpan
- func (*RelationSpan) Descriptor() ([]byte, []int)deprecated
- func (x *RelationSpan) GetRelType() string
- func (x *RelationSpan) GetSpan() *Timespan
- func (*RelationSpan) ProtoMessage()
- func (x *RelationSpan) ProtoReflect() protoreflect.Message
- func (x *RelationSpan) Reset()
- func (x *RelationSpan) String() string
- type RelationSpans
- type SendClient
- type SnapshotRelation
- func (*SnapshotRelation) Descriptor() ([]byte, []int)deprecated
- func (x *SnapshotRelation) GetFromKey() string
- func (x *SnapshotRelation) GetRelType() string
- func (x *SnapshotRelation) GetToKey() string
- func (*SnapshotRelation) ProtoMessage()
- func (x *SnapshotRelation) ProtoReflect() protoreflect.Message
- func (x *SnapshotRelation) Reset()
- func (x *SnapshotRelation) String() string
- type Table
- func (t *Table) AddCSV(in [][]string, filter []string) error
- func (t Table) Aggregate(method DataAggrMethod, level DataAggrLevel) Table
- func (t *Table) Append(rec Record)
- func (t Table) Len() int
- func (t *Table) Merge(t2 Table) error
- func (t Table) ToCSV() [][]string
- func (t Table) ToDQR() *DataQueryResults
- func (t Table) ToRecords(toSort bool) []Record
- func (t Table) Trim(start, end time.Time) Table
- type Tag
- type TimeAggrLevel
- type Timespan
Constants ¶
const RECORDS_PER_BATCH = 500 // AWS Firehose limit
Variables ¶
var File_dapper_proto protoreflect.FileDescriptor
Functions ¶
func GetFiles ¶
func GetFiles(domain, key string, start, end time.Time, tAggr TimeAggrLevel) []string
func ParseRecords ¶
func ParseRecords(in []Record, tAggr TimeAggrLevel) map[string]Table
func RecordToCSV ¶
Types ¶
type DataAggrFunc ¶
type DataAggrLevel ¶
type DataAggrLevel int
const ( AUTO DataAggrLevel = iota NONE MINS30 HOUR1 HOUR2 HOUR4 DAY1 )
type DataAggrMethod ¶
type DataAggrMethod string
const ( DATA_AGGR_NONE DataAggrMethod = "" DATA_AGGR_MIN DataAggrMethod = "min" DATA_AGGR_MAX DataAggrMethod = "max" DATA_AGGR_AVG DataAggrMethod = "avg" )
type DataQueryRecord ¶
type DataQueryRecord struct {
// A unix timestamp representing when the value was recorded
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// The value of the record (encoded as a string)
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*DataQueryRecord) Descriptor
deprecated
func (*DataQueryRecord) Descriptor() ([]byte, []int)
Deprecated: Use DataQueryRecord.ProtoReflect.Descriptor instead.
func (*DataQueryRecord) GetTimestamp ¶
func (x *DataQueryRecord) GetTimestamp() int64
func (*DataQueryRecord) GetValue ¶
func (x *DataQueryRecord) GetValue() string
func (*DataQueryRecord) ProtoMessage ¶
func (*DataQueryRecord) ProtoMessage()
func (*DataQueryRecord) ProtoReflect ¶
func (x *DataQueryRecord) ProtoReflect() protoreflect.Message
func (*DataQueryRecord) Reset ¶
func (x *DataQueryRecord) Reset()
func (*DataQueryRecord) String ¶
func (x *DataQueryRecord) String() string
type DataQueryResult ¶
type DataQueryResult struct {
Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Field string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
Records []*DataQueryRecord `protobuf:"bytes,4,rep,name=records,proto3" json:"records,omitempty"`
// contains filtered or unexported fields
}
func (*DataQueryResult) Descriptor
deprecated
func (*DataQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use DataQueryResult.ProtoReflect.Descriptor instead.
func (*DataQueryResult) GetDomain ¶
func (x *DataQueryResult) GetDomain() string
func (*DataQueryResult) GetField ¶
func (x *DataQueryResult) GetField() string
func (*DataQueryResult) GetKey ¶
func (x *DataQueryResult) GetKey() string
func (*DataQueryResult) GetRecords ¶
func (x *DataQueryResult) GetRecords() []*DataQueryRecord
func (*DataQueryResult) ProtoMessage ¶
func (*DataQueryResult) ProtoMessage()
func (*DataQueryResult) ProtoReflect ¶
func (x *DataQueryResult) ProtoReflect() protoreflect.Message
func (*DataQueryResult) Reset ¶
func (x *DataQueryResult) Reset()
func (*DataQueryResult) String ¶
func (x *DataQueryResult) String() string
type DataQueryResults ¶
type DataQueryResults struct {
Results []*DataQueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
// contains filtered or unexported fields
}
func (*DataQueryResults) Descriptor
deprecated
func (*DataQueryResults) Descriptor() ([]byte, []int)
Deprecated: Use DataQueryResults.ProtoReflect.Descriptor instead.
func (*DataQueryResults) GetResults ¶
func (x *DataQueryResults) GetResults() []*DataQueryResult
func (*DataQueryResults) ProtoMessage ¶
func (*DataQueryResults) ProtoMessage()
func (*DataQueryResults) ProtoReflect ¶
func (x *DataQueryResults) ProtoReflect() protoreflect.Message
func (*DataQueryResults) Reset ¶
func (x *DataQueryResults) Reset()
func (*DataQueryResults) String ¶
func (x *DataQueryResults) String() string
type DomainMetadataList ¶
type DomainMetadataList struct {
// The domain being listed
Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
// All keys in the domain
Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
// All possible metadata fields & values in the domain
Metadata map[string]*MetadataValuesList `` /* 157-byte string literal not displayed */
// All possible tags in the domain
Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*DomainMetadataList) Descriptor
deprecated
func (*DomainMetadataList) Descriptor() ([]byte, []int)
Deprecated: Use DomainMetadataList.ProtoReflect.Descriptor instead.
func (*DomainMetadataList) GetDomain ¶
func (x *DomainMetadataList) GetDomain() string
func (*DomainMetadataList) GetKeys ¶
func (x *DomainMetadataList) GetKeys() []string
func (*DomainMetadataList) GetMetadata ¶
func (x *DomainMetadataList) GetMetadata() map[string]*MetadataValuesList
func (*DomainMetadataList) GetTags ¶
func (x *DomainMetadataList) GetTags() []string
func (*DomainMetadataList) ProtoMessage ¶
func (*DomainMetadataList) ProtoMessage()
func (*DomainMetadataList) ProtoReflect ¶
func (x *DomainMetadataList) ProtoReflect() protoreflect.Message
func (*DomainMetadataList) Reset ¶
func (x *DomainMetadataList) Reset()
func (*DomainMetadataList) String ¶
func (x *DomainMetadataList) String() string
type KeyMetadata ¶
type KeyMetadata struct {
// The domain the metadata is associated with
Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
// The key the metadata is associated with
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// The timespan(s) for which this key exists
Span []*Timespan `protobuf:"bytes,3,rep,name=span,proto3" json:"span,omitempty"`
// Name/Value pairs of metadata (e.g. 'model: MikroTik')
Metadata map[string]*Metadata `` /* 157-byte string literal not displayed */
// String tags of metadata (e.g. 'LINZ')
Tags map[string]*Tag `` /* 149-byte string literal not displayed */
Location []*PointSpan `protobuf:"bytes,6,rep,name=location,proto3" json:"location,omitempty"`
// The relations to other keys from this metadata, the key of map is to_key
Relations map[string]*RelationSpans `` /* 159-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*KeyMetadata) Descriptor
deprecated
func (*KeyMetadata) Descriptor() ([]byte, []int)
Deprecated: Use KeyMetadata.ProtoReflect.Descriptor instead.
func (*KeyMetadata) GetDomain ¶
func (x *KeyMetadata) GetDomain() string
func (*KeyMetadata) GetKey ¶
func (x *KeyMetadata) GetKey() string
func (*KeyMetadata) GetLocation ¶
func (x *KeyMetadata) GetLocation() []*PointSpan
func (*KeyMetadata) GetMetadata ¶
func (x *KeyMetadata) GetMetadata() map[string]*Metadata
func (*KeyMetadata) GetRelations ¶
func (x *KeyMetadata) GetRelations() map[string]*RelationSpans
func (*KeyMetadata) GetSpan ¶
func (x *KeyMetadata) GetSpan() []*Timespan
func (*KeyMetadata) GetTags ¶
func (x *KeyMetadata) GetTags() map[string]*Tag
func (*KeyMetadata) ProtoMessage ¶
func (*KeyMetadata) ProtoMessage()
func (*KeyMetadata) ProtoReflect ¶
func (x *KeyMetadata) ProtoReflect() protoreflect.Message
func (*KeyMetadata) Reset ¶
func (x *KeyMetadata) Reset()
func (*KeyMetadata) String ¶
func (x *KeyMetadata) String() string
type KeyMetadataList ¶
type KeyMetadataList struct {
Metadata []*KeyMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
func (*KeyMetadataList) Descriptor
deprecated
func (*KeyMetadataList) Descriptor() ([]byte, []int)
Deprecated: Use KeyMetadataList.ProtoReflect.Descriptor instead.
func (*KeyMetadataList) GetMetadata ¶
func (x *KeyMetadataList) GetMetadata() []*KeyMetadata
func (*KeyMetadataList) ProtoMessage ¶
func (*KeyMetadataList) ProtoMessage()
func (*KeyMetadataList) ProtoReflect ¶
func (x *KeyMetadataList) ProtoReflect() protoreflect.Message
func (*KeyMetadataList) Reset ¶
func (x *KeyMetadataList) Reset()
func (*KeyMetadataList) String ¶
func (x *KeyMetadataList) String() string
type KeyMetadataSnapshot ¶
type KeyMetadataSnapshot struct {
// The domain the metadata is associated with
Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
// The key the metadata is associated with
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// The moment of the metadata snapshot
Moment int64 `protobuf:"varint,3,opt,name=moment,proto3" json:"moment,omitempty"`
// Name/Value pairs of metadata (e.g. 'model: MikroTik')
Metadata map[string]string `` /* 157-byte string literal not displayed */
// String tags of metadata (e.g. 'LINZ')
Tags []string `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
Location *Point `protobuf:"bytes,6,opt,name=location,proto3" json:"location,omitempty"`
// The relation type of to_key
Relations []*SnapshotRelation `protobuf:"bytes,7,rep,name=relations,proto3" json:"relations,omitempty"`
// contains filtered or unexported fields
}
A simplified version of KeyMetadata without Timespan components (snapshot of metadata at one moment in time)
func (*KeyMetadataSnapshot) Descriptor
deprecated
func (*KeyMetadataSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use KeyMetadataSnapshot.ProtoReflect.Descriptor instead.
func (*KeyMetadataSnapshot) GetDomain ¶
func (x *KeyMetadataSnapshot) GetDomain() string
func (*KeyMetadataSnapshot) GetKey ¶
func (x *KeyMetadataSnapshot) GetKey() string
func (*KeyMetadataSnapshot) GetLocation ¶
func (x *KeyMetadataSnapshot) GetLocation() *Point
func (*KeyMetadataSnapshot) GetMetadata ¶
func (x *KeyMetadataSnapshot) GetMetadata() map[string]string
func (*KeyMetadataSnapshot) GetMoment ¶
func (x *KeyMetadataSnapshot) GetMoment() int64
func (*KeyMetadataSnapshot) GetRelations ¶
func (x *KeyMetadataSnapshot) GetRelations() []*SnapshotRelation
func (*KeyMetadataSnapshot) GetTags ¶
func (x *KeyMetadataSnapshot) GetTags() []string
func (*KeyMetadataSnapshot) ProtoMessage ¶
func (*KeyMetadataSnapshot) ProtoMessage()
func (*KeyMetadataSnapshot) ProtoReflect ¶
func (x *KeyMetadataSnapshot) ProtoReflect() protoreflect.Message
func (*KeyMetadataSnapshot) Reset ¶
func (x *KeyMetadataSnapshot) Reset()
func (*KeyMetadataSnapshot) String ¶
func (x *KeyMetadataSnapshot) String() string
type KeyMetadataSnapshotList ¶
type KeyMetadataSnapshotList struct {
Metadata []*KeyMetadataSnapshot `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
func (*KeyMetadataSnapshotList) Descriptor
deprecated
func (*KeyMetadataSnapshotList) Descriptor() ([]byte, []int)
Deprecated: Use KeyMetadataSnapshotList.ProtoReflect.Descriptor instead.
func (*KeyMetadataSnapshotList) GetMetadata ¶
func (x *KeyMetadataSnapshotList) GetMetadata() []*KeyMetadataSnapshot
func (*KeyMetadataSnapshotList) ProtoMessage ¶
func (*KeyMetadataSnapshotList) ProtoMessage()
func (*KeyMetadataSnapshotList) ProtoReflect ¶
func (x *KeyMetadataSnapshotList) ProtoReflect() protoreflect.Message
func (*KeyMetadataSnapshotList) Reset ¶
func (x *KeyMetadataSnapshotList) Reset()
func (*KeyMetadataSnapshotList) String ¶
func (x *KeyMetadataSnapshotList) String() string
type Metadata ¶
type Metadata struct {
// The name of the metadata (e.g. 'model')
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The value (and potentially past values)
Values []*MetadataValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*Metadata) Descriptor
deprecated
func (*Metadata) GetValues ¶
func (x *Metadata) GetValues() []*MetadataValue
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶
func (x *Metadata) ProtoReflect() protoreflect.Message
type MetadataValue ¶
type MetadataValue struct {
// The value of the metadata (e.g. 'MikroTik')
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
// The timespan this value is valid for
Span *Timespan `protobuf:"bytes,2,opt,name=span,proto3" json:"span,omitempty"`
// contains filtered or unexported fields
}
func (*MetadataValue) Descriptor
deprecated
func (*MetadataValue) Descriptor() ([]byte, []int)
Deprecated: Use MetadataValue.ProtoReflect.Descriptor instead.
func (*MetadataValue) GetSpan ¶
func (x *MetadataValue) GetSpan() *Timespan
func (*MetadataValue) GetValue ¶
func (x *MetadataValue) GetValue() string
func (*MetadataValue) ProtoMessage ¶
func (*MetadataValue) ProtoMessage()
func (*MetadataValue) ProtoReflect ¶
func (x *MetadataValue) ProtoReflect() protoreflect.Message
func (*MetadataValue) Reset ¶
func (x *MetadataValue) Reset()
func (*MetadataValue) String ¶
func (x *MetadataValue) String() string
type MetadataValuesList ¶
type MetadataValuesList struct {
// The metadata field name
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// All potential values for that field
Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*MetadataValuesList) Descriptor
deprecated
func (*MetadataValuesList) Descriptor() ([]byte, []int)
Deprecated: Use MetadataValuesList.ProtoReflect.Descriptor instead.
func (*MetadataValuesList) GetName ¶
func (x *MetadataValuesList) GetName() string
func (*MetadataValuesList) GetValues ¶
func (x *MetadataValuesList) GetValues() []string
func (*MetadataValuesList) ProtoMessage ¶
func (*MetadataValuesList) ProtoMessage()
func (*MetadataValuesList) ProtoReflect ¶
func (x *MetadataValuesList) ProtoReflect() protoreflect.Message
func (*MetadataValuesList) Reset ¶
func (x *MetadataValuesList) Reset()
func (*MetadataValuesList) String ¶
func (x *MetadataValuesList) String() string
type Point ¶
type Point struct {
Latitude float32 `protobuf:"fixed32,1,opt,name=latitude,proto3" json:"latitude,omitempty"`
Longitude float32 `protobuf:"fixed32,2,opt,name=longitude,proto3" json:"longitude,omitempty"`
// contains filtered or unexported fields
}
func (*Point) Descriptor
deprecated
func (*Point) GetLatitude ¶
func (*Point) GetLongitude ¶
func (*Point) ProtoMessage ¶
func (*Point) ProtoMessage()
func (*Point) ProtoReflect ¶
func (x *Point) ProtoReflect() protoreflect.Message
type PointSpan ¶
type PointSpan struct {
//The Lat/Lon of the point
Location *Point `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
//The timespan the value is valid for
Span *Timespan `protobuf:"bytes,2,opt,name=span,proto3" json:"span,omitempty"`
// contains filtered or unexported fields
}
func (*PointSpan) Descriptor
deprecated
func (*PointSpan) GetLocation ¶
func (*PointSpan) ProtoMessage ¶
func (*PointSpan) ProtoMessage()
func (*PointSpan) ProtoReflect ¶
func (x *PointSpan) ProtoReflect() protoreflect.Message
type Record ¶
type Record struct {
Domain string // Broad class of the data. e.g. FdMP, gloria-qc
Key string // A key used to uniquely identify an item in the domain. e.g. a device name in FdMP or a Station in gloria-qc
Field string // The field name of this value, e.g. 'temperature' in FdMP
Time time.Time
Value string
}
func RecordFromCSV ¶
type RelationSpan ¶
type RelationSpan struct {
// The type of the relation
RelType string `protobuf:"bytes,1,opt,name=rel_type,json=relType,proto3" json:"rel_type,omitempty"`
// The timespan this value is valid for
Span *Timespan `protobuf:"bytes,2,opt,name=span,proto3" json:"span,omitempty"`
// contains filtered or unexported fields
}
func (*RelationSpan) Descriptor
deprecated
func (*RelationSpan) Descriptor() ([]byte, []int)
Deprecated: Use RelationSpan.ProtoReflect.Descriptor instead.
func (*RelationSpan) GetRelType ¶
func (x *RelationSpan) GetRelType() string
func (*RelationSpan) GetSpan ¶
func (x *RelationSpan) GetSpan() *Timespan
func (*RelationSpan) ProtoMessage ¶
func (*RelationSpan) ProtoMessage()
func (*RelationSpan) ProtoReflect ¶
func (x *RelationSpan) ProtoReflect() protoreflect.Message
func (*RelationSpan) Reset ¶
func (x *RelationSpan) Reset()
func (*RelationSpan) String ¶
func (x *RelationSpan) String() string
type RelationSpans ¶
type RelationSpans struct {
// The relations to other keys
Spans []*RelationSpan `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
// contains filtered or unexported fields
}
func (*RelationSpans) Descriptor
deprecated
func (*RelationSpans) Descriptor() ([]byte, []int)
Deprecated: Use RelationSpans.ProtoReflect.Descriptor instead.
func (*RelationSpans) GetSpans ¶
func (x *RelationSpans) GetSpans() []*RelationSpan
func (*RelationSpans) ProtoMessage ¶
func (*RelationSpans) ProtoMessage()
func (*RelationSpans) ProtoReflect ¶
func (x *RelationSpans) ProtoReflect() protoreflect.Message
func (*RelationSpans) Reset ¶
func (x *RelationSpans) Reset()
func (*RelationSpans) String ¶
func (x *RelationSpans) String() string
type SendClient ¶
type SendClient struct {
// contains filtered or unexported fields
}
func NewSendClient ¶
func NewSendClient(fhStream string) (*SendClient, error)
NewSendClient returns a SendClient struct that wraps a Firehose client using the default AWS credentials chain. This consults (in order) environment vars, config files, EC2 and ECS roles. It is an error if the AWS_REGION environment variable is not set. Requests with recoverable errors will be retried with the default retrier.
func NewSendClientWithConfig ¶
func NewSendClientWithConfig(fhStream string, cfg aws.Config) *SendClient
NewSendClientWithConfig returns a SendClient struct that wraps a Firehose client using a provided AWS Config.
func (SendClient) Send ¶
func (sc SendClient) Send(data []Record) error
Send sends a list of Dapper Records to the AWS Firehose.
type SnapshotRelation ¶
type SnapshotRelation struct {
FromKey string `protobuf:"bytes,1,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
ToKey string `protobuf:"bytes,2,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
RelType string `protobuf:"bytes,3,opt,name=rel_type,json=relType,proto3" json:"rel_type,omitempty"`
// contains filtered or unexported fields
}
func (*SnapshotRelation) Descriptor
deprecated
func (*SnapshotRelation) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotRelation.ProtoReflect.Descriptor instead.
func (*SnapshotRelation) GetFromKey ¶
func (x *SnapshotRelation) GetFromKey() string
func (*SnapshotRelation) GetRelType ¶
func (x *SnapshotRelation) GetRelType() string
func (*SnapshotRelation) GetToKey ¶
func (x *SnapshotRelation) GetToKey() string
func (*SnapshotRelation) ProtoMessage ¶
func (*SnapshotRelation) ProtoMessage()
func (*SnapshotRelation) ProtoReflect ¶
func (x *SnapshotRelation) ProtoReflect() protoreflect.Message
func (*SnapshotRelation) Reset ¶
func (x *SnapshotRelation) Reset()
func (*SnapshotRelation) String ¶
func (x *SnapshotRelation) String() string
type Table ¶
func (Table) Aggregate ¶
func (t Table) Aggregate(method DataAggrMethod, level DataAggrLevel) Table
func (Table) ToDQR ¶
func (t Table) ToDQR() *DataQueryResults
type Tag ¶
type Tag struct {
// The name of the tag (e.g. 'LINZ')
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The timespan this value is valid for
Span []*Timespan `protobuf:"bytes,2,rep,name=span,proto3" json:"span,omitempty"`
// contains filtered or unexported fields
}
func (*Tag) Descriptor
deprecated
func (*Tag) ProtoMessage ¶
func (*Tag) ProtoMessage()
func (*Tag) ProtoReflect ¶
func (x *Tag) ProtoReflect() protoreflect.Message
type TimeAggrLevel ¶
type TimeAggrLevel int
These constants define how much (timewise) data to aggregate into a single table
const ( DAY TimeAggrLevel = iota MONTH YEAR )
type Timespan ¶
type Timespan struct {
Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
// contains filtered or unexported fields
}
func (*Timespan) Descriptor
deprecated
func (*Timespan) ProtoMessage ¶
func (*Timespan) ProtoMessage()
func (*Timespan) ProtoReflect ¶
func (x *Timespan) ProtoReflect() protoreflect.Message