dapperlib

package
v0.0.0-...-1775924 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const RECORDS_PER_BATCH = 500 // AWS Firehose limit

Variables

View Source
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

func RecordToCSV(raw Record) (line string)

Types

type DataAggrFunc

type DataAggrFunc func([]string) string

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) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetName

func (x *Metadata) GetName() string

func (*Metadata) GetValues

func (x *Metadata) GetValues() []*MetadataValue

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetLatitude

func (x *Point) GetLatitude() float32

func (*Point) GetLongitude

func (x *Point) GetLongitude() float32

func (*Point) ProtoMessage

func (*Point) ProtoMessage()

func (*Point) ProtoReflect

func (x *Point) ProtoReflect() protoreflect.Message

func (*Point) Reset

func (x *Point) Reset()

func (*Point) String

func (x *Point) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use PointSpan.ProtoReflect.Descriptor instead.

func (*PointSpan) GetLocation

func (x *PointSpan) GetLocation() *Point

func (*PointSpan) GetSpan

func (x *PointSpan) GetSpan() *Timespan

func (*PointSpan) ProtoMessage

func (*PointSpan) ProtoMessage()

func (*PointSpan) ProtoReflect

func (x *PointSpan) ProtoReflect() protoreflect.Message

func (*PointSpan) Reset

func (x *PointSpan) Reset()

func (*PointSpan) String

func (x *PointSpan) String() string

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

func RecordFromCSV(line []string) (Record, error)

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

type Table struct {
	Domain string
	Key    string
	// contains filtered or unexported fields
}

func NewTable

func NewTable(domain, key string) Table

func (*Table) AddCSV

func (t *Table) AddCSV(in [][]string, filter []string) error

func (Table) Aggregate

func (t Table) Aggregate(method DataAggrMethod, level DataAggrLevel) Table

func (*Table) Append

func (t *Table) Append(rec Record)

func (Table) Len

func (t Table) Len() int

Returns the number of _rows_ in the table

func (*Table) Merge

func (t *Table) Merge(t2 Table) error

func (Table) ToCSV

func (t Table) ToCSV() [][]string

func (Table) ToDQR

func (t Table) ToDQR() *DataQueryResults

func (Table) ToRecords

func (t Table) ToRecords(toSort bool) []Record

func (Table) Trim

func (t Table) Trim(start, end time.Time) Table

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) Descriptor() ([]byte, []int)

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetName

func (x *Tag) GetName() string

func (*Tag) GetSpan

func (x *Tag) GetSpan() []*Timespan

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect

func (x *Tag) ProtoReflect() protoreflect.Message

func (*Tag) Reset

func (x *Tag) Reset()

func (*Tag) String

func (x *Tag) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Timespan.ProtoReflect.Descriptor instead.

func (*Timespan) GetEnd

func (x *Timespan) GetEnd() int64

func (*Timespan) GetStart

func (x *Timespan) GetStart() int64

func (*Timespan) ProtoMessage

func (*Timespan) ProtoMessage()

func (*Timespan) ProtoReflect

func (x *Timespan) ProtoReflect() protoreflect.Message

func (*Timespan) Reset

func (x *Timespan) Reset()

func (*Timespan) String

func (x *Timespan) String() string

Jump to

Keyboard shortcuts

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