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