Skip to content

Commit

Permalink
[create-pull-request] automated change (#289)
Browse files Browse the repository at this point in the history
Co-authored-by: nicolasparada <7969166+nicolasparada@users.noreply.github.com>
  • Loading branch information
calyptia-ci and nicolasparada committed Jun 13, 2024
1 parent 9b14c95 commit 22d7c8d
Showing 1 changed file with 84 additions and 0 deletions.
84 changes: 84 additions & 0 deletions types/metric.go
Original file line number Diff line number Diff line change
Expand Up @@ -196,12 +196,27 @@ type MetricsOverTime struct {
Output MetricsOverTimeOutput `json:"output"`
}

func (m *MetricsOverTime) Init() {
m.Input.Init()
m.Filter.Init()
m.Output.Init()
}

// MetricsOverTimeInput stores a list of metrics over time for a core instance input.
type MetricsOverTimeInput struct {
Bytes []MetricOverTime `json:"bytes"`
Records []MetricOverTime `json:"records"`
}

func (m *MetricsOverTimeInput) Init() {
if m.Bytes == nil {
m.Bytes = []MetricOverTime{}
}
if m.Records == nil {
m.Records = []MetricOverTime{}
}
}

// MetricsOverTimeFilter stores a list of metrics over time for a core instance filter.
type MetricsOverTimeFilter struct {
Bytes []MetricOverTime `json:"bytes"`
Expand All @@ -211,6 +226,24 @@ type MetricsOverTimeFilter struct {
EmitRecords []MetricOverTime `json:"emitRecords"`
}

func (m *MetricsOverTimeFilter) Init() {
if m.Bytes == nil {
m.Bytes = []MetricOverTime{}
}
if m.Records == nil {
m.Records = []MetricOverTime{}
}
if m.AddRecords == nil {
m.AddRecords = []MetricOverTime{}
}
if m.DropRecords == nil {
m.DropRecords = []MetricOverTime{}
}
if m.EmitRecords == nil {
m.EmitRecords = []MetricOverTime{}
}
}

// MetricsOverTimeOutput stores a list of metrics over time for a core instance output.
type MetricsOverTimeOutput struct {
Bytes []MetricOverTime `json:"bytes"`
Expand All @@ -226,6 +259,33 @@ type MetricsOverTimeOutput struct {
Loads []MetricOverTime `json:"loads"`
}

func (m *MetricsOverTimeOutput) Init() {
if m.Bytes == nil {
m.Bytes = []MetricOverTime{}
}
if m.Records == nil {
m.Records = []MetricOverTime{}
}
if m.Errors == nil {
m.Errors = []MetricOverTime{}
}
if m.Retries == nil {
m.Retries = []MetricOverTime{}
}
if m.RetriedRecords == nil {
m.RetriedRecords = []MetricOverTime{}
}
if m.RetriesFailed == nil {
m.RetriesFailed = []MetricOverTime{}
}
if m.DroppedRecords == nil {
m.DroppedRecords = []MetricOverTime{}
}
if m.Loads == nil {
m.Loads = []MetricOverTime{}
}
}

type MetricOverTime struct {
Time time.Time `json:"time"`
Value float64 `json:"value"`
Expand All @@ -239,6 +299,18 @@ type MetricsSummaryPlugin struct {
Outputs []MetricsOutputPlugin `json:"outputs"`
}

func (m *MetricsSummaryPlugin) Init() {
if m.Inputs == nil {
m.Inputs = []MetricsInputPlugin{}
}
if m.Filters == nil {
m.Filters = []MetricsFilterPlugin{}
}
if m.Outputs == nil {
m.Outputs = []MetricsOutputPlugin{}
}
}

type MetricsInputPlugin struct {
Instance string `json:"instance"`
Metrics MetricsInput `json:"metrics"`
Expand All @@ -262,6 +334,18 @@ type MetricsOverTimeByPlugin struct {
Outputs []MetricsOverTimeByPluginOutput `json:"outputs"`
}

func (m *MetricsOverTimeByPlugin) Init() {
if m.Inputs == nil {
m.Inputs = []MetricsOverTimeByPluginInput{}
}
if m.Filters == nil {
m.Filters = []MetricsOverTimeByPluginFilter{}
}
if m.Outputs == nil {
m.Outputs = []MetricsOverTimeByPluginOutput{}
}
}

// MetricsOverTimeByPluginInput stores a list of metrics over time for core instance inputs
// organized by plugin.
type MetricsOverTimeByPluginInput struct {
Expand Down

0 comments on commit 22d7c8d

Please sign in to comment.