analytics

Mar 1, 2024

Changes in this version

type AnalyticsRecord

+ GraphQLStats GraphQLStats

+ type GraphQLOperations int

+ const OperationMutation

+ const OperationQuery

+ const OperationSubscription

+ const OperationUnknown

+ type GraphQLStats struct

+ Errors []GraphError

+ HasErrors bool

+ IsGraphQL bool

+ OperationType GraphQLOperations

+ RootFields []string

+ Types map[string][]string

+ Variables string

+ type GraphSQLAnalyticsRecordAggregate struct

+ APIID string

+ Dimension string

+ DimensionValue string

+ ID string

+ OrgID string

+ TimeStamp int64

Sep 7, 2023

Changes in this version

+ var GraphSQLTableName string

Apr 28, 2023

Changes in this version

+ const AggregateGraphSQLTable

+ const GraphAggregateMixedCollectionName

+ func AggregateGraphData(data []interface{}, dbIdentifier string, aggregationTime int) map[string]GraphRecordAggregate

+ type AggregateFieldList struct

+ APIEndpoint []Counter

+ APIID []Counter

+ APIKeys []Counter

+ Endpoints []Counter

+ Errors []Counter

+ Geo []Counter

+ KeyEndpoint map[string][]Counter

+ OauthEndpoint map[string][]Counter

+ OauthIDs []Counter

+ Tags []Counter

type AnalyticsRecord

+ APISchema string

+ CollectionName string

+ func (a *AnalyticsRecord) GetObjectID() model.ObjectID

+ func (a *AnalyticsRecord) SetObjectID(id model.ObjectID)

type AnalyticsRecordAggregate

+ Mixed bool

+ func (f *AnalyticsRecordAggregate) GetObjectID() model.ObjectID

+ func (f *AnalyticsRecordAggregate) SetObjectID(id model.ObjectID)

+ func (f *AnalyticsRecordAggregate) TableName() string

type GraphRecord

+ AnalyticsRecord AnalyticsRecord

+ RootFields []string

+ func (*GraphRecord) GetObjectID() model.ObjectID

+ func (*GraphRecord) SetObjectID(model.ObjectID)

+ func (g *GraphRecord) TableName() string

+ type GraphRecordAggregate struct

+ Fields map[string]*Counter

+ Operation map[string]*Counter

+ RootFields map[string]*Counter

+ Types map[string]*Counter

+ func NewGraphRecordAggregate() GraphRecordAggregate

+ func (g *GraphRecordAggregate) Dimensions() []Dimension

type UptimeReportData

+ ID model.ObjectID

+ func (a *UptimeReportData) GetObjectID() model.ObjectID

+ func (a *UptimeReportData) SetObjectID(id model.ObjectID)

+ func (a *UptimeReportData) TableName() string

Dec 2, 2022

Changes in this version

+ const PredefinedTagGraphAnalytics

+ func SetlastTimestampAgggregateRecord(id string, date time.Time)

type AnalyticsRecord

+ ApiSchema string

+ func (a *AnalyticsRecord) IsGraphRecord() bool

+ func (a *AnalyticsRecord) RemoveIgnoredFields(ignoreFields []string)

+ func (a *AnalyticsRecord) ToGraphRecord() (GraphRecord, error)

+ type GraphError struct

+ Message string

+ Path []interface{}

+ type GraphRecord struct

+ Errors []GraphError

+ HasErrors bool

+ OperationType string

+ Types map[string][]string

+ Variables string

Jun 27, 2022

Changes in this version

+ func TrimTag(thisTag string) string

type AnalyticsRecord

+ func (a *AnalyticsRecord) GetGeo(ipStr string, GeoIPDB *maxminddb.Reader)

+ func (a *AnalyticsRecord) SetExpiry(expiresInSeconds int64)

+ func (a *AnalyticsRecord) TimeStampFromProto(protoRecord analyticsproto.AnalyticsRecord)

+ func (a *AnalyticsRecord) TimestampToProto(newRecord *analyticsproto.AnalyticsRecord)

+ type City struct

+ GeoNameID uint

+ Names map[string]string

type GeoData

+ func GeoIPLookup(ipStr string, GeoIPDB *maxminddb.Reader) (*GeoData, error)

+ type Location struct

+ Latitude float64

+ Longitude float64

+ TimeZone string

type NetworkStats

+ func (n *NetworkStats) Flush() NetworkStats

Sep 23, 2021

Changes in this version

+ const AggregateSQLTable

+ const SQLTable

+ const UptimeSQLTable

+ func AggregateUptimeData(data []UptimeReportData) map[string]UptimeReportAggregate

+ func OnConflictAssignments(tableName string, tempTable string) map[string]interface

+ func OnConflictUptimeAssignments(tableName string, tempTable string) map[string]interface

type AnalyticsRecord

+ func (a *AnalyticsRecord) TrimRawData(size int)

+ func (ar *AnalyticsRecord) TableName() string

type AnalyticsRecordAggregate

+ func (f *AnalyticsRecordAggregate) Dimensions() (dimensions []Dimension)

+ type Code struct

+ Code1x int

+ Code200 int

+ Code201 int

+ Code2x int

+ Code301 int

+ Code302 int

+ Code303 int

+ Code304 int

+ Code3x int

+ Code400 int

+ Code401 int

+ Code403 int

+ Code404 int

+ Code429 int

+ Code4x int

+ Code500 int

+ Code501 int

+ Code502 int

+ Code503 int

+ Code504 int

+ Code5x int

+ func (c *Code) ProcessStatusCodes(errorMap map[string]int)

+ type Country struct

+ ISOCode string

+ type Dimension struct

+ Counter *Counter

+ Name string

+ Value string

+ type SQLAnalyticsRecordAggregate struct

+ Dimension string

+ DimensionValue string

+ ID string

+ OrgID string

+ TimeStamp int64

+ func (f *SQLAnalyticsRecordAggregate) TableName() string

+ type UptimeReportAggregate struct

+ Errors map[string]*Counter

+ ExpireAt time.Time

+ LastTime time.Time

+ OrgID string

+ TimeID struct{ ... }

+ TimeStamp time.Time

+ Total Counter

+ URL map[string]*Counter

+ func (u *UptimeReportAggregate) Dimensions() (dimensions []Dimension)

+ func (u UptimeReportAggregate) New() UptimeReportAggregate

+ type UptimeReportAggregateSQL struct

+ Dimension string

+ DimensionValue string

+ ID string

+ OrgID string

+ TimeStamp int64

+ func (a *UptimeReportAggregateSQL) TableName() string

Apr 22, 2021

Changes in this version

type GeoData

+ func (g *GeoData) GetFieldNames() []string

+ func (g *GeoData) GetLineValues() []string

type Latency

+ func (l *Latency) GetFieldNames() []string

+ func (l *Latency) GetLineValues() []string

type NetworkStats

+ func (n *NetworkStats) GetFieldNames() []string

+ func (n *NetworkStats) GetLineValues() []string

Feb 4, 2021

Changes in this version

+ func ObfuscateString(keyName string) string

type AnalyticsFilters

+ ResponseCodes []int

+ SkippedResponseCodes []int

type AnalyticsRecord

+ func (a *AnalyticsRecord) ObfuscateKey()

type AnalyticsRecordAggregate

+ func (f *AnalyticsRecordAggregate) DiscardAggregations(fields []string)

Jul 16, 2020

Changes in this version

+ type AnalyticsFilters struct

+ APIIDs []string

+ OrgsIDs []string

+ SkippedAPIIDs []string

+ SkippedOrgsIDs []string

+ func (filters AnalyticsFilters) HasFilter() bool

+ func (filters AnalyticsFilters) ShouldFilter(record AnalyticsRecord) bool

type AnalyticsRecordAggregate

+ ApiEndpoint map[string]*Counter

+ func (f *AnalyticsRecordAggregate) SetErrorList(parent, thisUnit string, counter *Counter, newUpdate bson.M)

type Counter

+ ErrorList []ErrorData

+ ErrorMap map[string]int

+ type ErrorData struct

+ Code string

+ Count int

Jan 30, 2020

Changes in this version

+ const AgggregateMixedCollectionName

+ const MongoAggregatePrefix

+ func AggregateData(data []interface{}, trackAllPaths bool, ignoreTagPrefixList []string, ...) map[string]AnalyticsRecordAggregate

+ type AnalyticsRecord struct

+ APIID string

+ APIKey string

+ APIName string

+ APIVersion string

+ Alias string

+ ContentLength int64

+ Day int

+ ExpireAt time.Time

+ Geo GeoData

+ Host string

+ Hour int

+ IPAddress string

+ Latency Latency

+ Method string

+ Month time.Month

+ Network NetworkStats

+ OauthID string

+ OrgID string

+ Path string

+ RawPath string

+ RawRequest string

+ RawResponse string

+ RequestTime int64

+ ResponseCode int

+ Tags []string

+ TimeStamp time.Time

+ TrackPath bool

+ UserAgent string

+ Year int

+ func (a *AnalyticsRecord) GetFieldNames() []string

+ func (a *AnalyticsRecord) GetLineValues() []string

+ type AnalyticsRecordAggregate struct

+ APIID map[string]*Counter

+ APIKeys map[string]*Counter

+ Endpoints map[string]*Counter

+ Errors map[string]*Counter

+ ExpireAt time.Time

+ Geo map[string]*Counter

+ KeyEndpoint map[string]map[string]*Counter

+ LastTime time.Time

+ Lists struct{ ... }

+ OauthEndpoint map[string]map[string]*Counter

+ OauthIDs map[string]*Counter

+ OrgID string

+ Tags map[string]*Counter

+ TimeID struct{ ... }

+ TimeStamp time.Time

+ Total Counter

+ Versions map[string]*Counter

+ func (f *AnalyticsRecordAggregate) AsChange() bson.M

+ func (f *AnalyticsRecordAggregate) AsTimeUpdate() bson.M

+ func (f AnalyticsRecordAggregate) New() AnalyticsRecordAggregate

+ type Counter struct

+ BytesIn int64

+ BytesOut int64

+ ClosedConnections int64

+ ErrorTotal int

+ Hits int

+ HumanIdentifier string

+ Identifier string

+ LastTime time.Time

+ Latency float64

+ MaxLatency int64

+ MaxUpstreamLatency int64

+ MinLatency int64

+ MinUpstreamLatency int64

+ OpenConnections int64

+ RequestTime float64

+ Success int

+ TotalLatency int64

+ TotalRequestTime float64

+ TotalUpstreamLatency int64

+ UpstreamLatency float64

+ type GeoData struct

+ City struct{ ... }

+ Country struct{ ... }

+ Location struct{ ... }

+ type Latency struct

+ Total int64

+ Upstream int64

+ type NetworkStats struct

+ BytesIn int64

+ BytesOut int64

+ ClosedConnection int64

+ OpenConnections int64

+ type UptimeReportData struct

+ APIID string

+ Day int

+ ExpireAt time.Time

+ Hour int

+ Minute int

+ Month time.Month

+ OrgID string

+ RequestTime int64

+ ResponseCode int

+ ServerError bool

+ TCPError bool

+ TimeStamp time.Time

+ URL string

+ Year int