50 lines
999 B
Go
50 lines
999 B
Go
|
package transactions
|
||
|
|
|
||
|
|
import "time"
|
||
|
|
|
||
|
|
type TransactionCountQuery struct {
|
||
|
|
TimeSpan string
|
||
|
|
SampleRate string
|
||
|
|
CumulativeSum bool
|
||
|
|
}
|
||
|
|
|
||
|
|
type TransactionCountResult struct {
|
||
|
|
Time time.Time `json:"time" mapstructure:"_time"`
|
||
|
|
Count uint64 `json:"count" mapstructure:"count"`
|
||
|
|
}
|
||
|
|
|
||
|
|
type ChainActivityResult struct {
|
||
|
|
ChainSourceID string `mapstructure:"chain_source_id"`
|
||
|
|
ChainDestinationID string `mapstructure:"chain_destination_id"`
|
||
|
|
Volume uint64 `mapstructure:"volume"`
|
||
|
|
}
|
||
|
|
|
||
|
|
type ChainActivityQuery struct {
|
||
|
|
Start *time.Time
|
||
|
|
End *time.Time
|
||
|
|
AppIDs []string
|
||
|
|
IsNotional bool
|
||
|
|
}
|
||
|
|
|
||
|
|
func (q *ChainActivityQuery) HasAppIDS() bool {
|
||
|
|
return len(q.AppIDs) > 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (q *ChainActivityQuery) GetAppIDs() []string {
|
||
|
|
return q.AppIDs
|
||
|
|
}
|
||
|
|
|
||
|
|
func (q *ChainActivityQuery) GetStart() time.Time {
|
||
|
|
if q.Start == nil {
|
||
|
|
return time.UnixMilli(0)
|
||
|
|
}
|
||
|
|
return *q.Start
|
||
|
|
}
|
||
|
|
|
||
|
|
func (q *ChainActivityQuery) GetEnd() time.Time {
|
||
|
|
if q.End == nil {
|
||
|
|
return time.Now()
|
||
|
|
}
|
||
|
|
return *q.End
|
||
|
|
}
|