Skip to content

Commit

Permalink
Merge branch 'main' of https://github.com/risingwavelabs/risingwave i…
Browse files Browse the repository at this point in the history 
…nto li0k/storage_panic_when_send_fail
  • Loading branch information
@Li0k
Li0k committed May 5, 2023
2 parents 02f349f + f46046f commit e29a1d8
Show file tree
Hide file tree
Showing 19 changed files with 401 additions and 228 deletions.
1 change: 1 addition & 0 deletions Cargo.lock
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 1 addition & 2 deletions docker/dashboards/risingwave-dev-dashboard.json
View file

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion docker/dashboards/risingwave-user-dashboard.json
View file

Large diffs are not rendered by default.

52 changes: 29 additions & 23 deletions grafana/common.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -91,6 +91,12 @@ def next_one_third_width_graph(self):

class Panels:

common_options = {
"fillOpacity": 10,
"interval": "1s",
"maxDataPoints": 1000,
}

def __init__(self, datasource):
self.layout = Layout()
self.datasource = datasource
Expand Down Expand Up @@ -129,7 +135,7 @@ def timeseries(self, title, description, targets):
description=description,
targets=targets,
gridPos=gridPos,
fillOpacity=10,
**self.common_options,
)

def timeseries_count(self,
Expand All @@ -143,10 +149,10 @@ def timeseries_count(self,
description=description,
targets=targets,
gridPos=gridPos,
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_percentage(self,
Expand All @@ -162,10 +168,10 @@ def timeseries_percentage(self,
targets=targets,
gridPos=gridPos,
unit="percentunit",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_latency(self,
Expand All @@ -180,10 +186,10 @@ def timeseries_latency(self,
targets=targets,
gridPos=gridPos,
unit="s",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_actor_latency(self,
Expand All @@ -198,10 +204,10 @@ def timeseries_actor_latency(self,
targets=targets,
gridPos=gridPos,
unit="s",
fillOpacity=0,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_actor_latency_small(self,
Expand All @@ -216,10 +222,10 @@ def timeseries_actor_latency_small(self,
targets=targets,
gridPos=gridPos,
unit="s",
fillOpacity=0,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_query_per_sec(self,
Expand All @@ -234,10 +240,10 @@ def timeseries_query_per_sec(self,
targets=targets,
gridPos=gridPos,
unit="Qps",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_bytes_per_sec(self,
Expand All @@ -252,10 +258,10 @@ def timeseries_bytes_per_sec(self,
targets=targets,
gridPos=gridPos,
unit="Bps",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_bytes(self,
Expand All @@ -270,10 +276,10 @@ def timeseries_bytes(self,
targets=targets,
gridPos=gridPos,
unit="bytes",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_row(self, title, description, targets, legendCols=["mean"]):
Expand All @@ -284,10 +290,10 @@ def timeseries_row(self, title, description, targets, legendCols=["mean"]):
targets=targets,
gridPos=gridPos,
unit="row",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_ms(self, title, description, targets, legendCols=["mean"]):
Expand All @@ -297,10 +303,10 @@ def timeseries_ms(self, title, description, targets, legendCols=["mean"]):
description=description,
targets=targets,
gridPos=gridPos,
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_kilobytes(self,
Expand All @@ -315,10 +321,10 @@ def timeseries_kilobytes(self,
targets=targets,
gridPos=gridPos,
unit="kbytes",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_dollar(self,
Expand All @@ -333,10 +339,10 @@ def timeseries_dollar(self,
targets=targets,
gridPos=gridPos,
unit="$",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_ops(self, title, description, targets, legendCols=["mean"]):
Expand All @@ -347,10 +353,10 @@ def timeseries_ops(self, title, description, targets, legendCols=["mean"]):
targets=targets,
gridPos=gridPos,
unit="ops",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_actor_ops(self,
Expand All @@ -365,10 +371,10 @@ def timeseries_actor_ops(self,
targets=targets,
gridPos=gridPos,
unit="ops",
fillOpacity=0,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_actor_ops_small(self,
Expand All @@ -383,10 +389,10 @@ def timeseries_actor_ops_small(self,
targets=targets,
gridPos=gridPos,
unit="ops",
fillOpacity=0,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_rowsps(self,
Expand All @@ -401,10 +407,10 @@ def timeseries_rowsps(self,
targets=targets,
gridPos=gridPos,
unit="rows/s",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_bytesps(self,
Expand All @@ -419,10 +425,10 @@ def timeseries_bytesps(self,
targets=targets,
gridPos=gridPos,
unit="MB/s",
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
legendCalcs=legendCols,
**self.common_options,
)

def timeseries_actor_rowsps(self, title, description, targets):
Expand All @@ -433,9 +439,9 @@ def timeseries_actor_rowsps(self, title, description, targets):
targets=targets,
gridPos=gridPos,
unit="rows/s",
fillOpacity=0,
legendDisplayMode="table",
legendPlacement="right",
**self.common_options,
)

def timeseries_memory(self, title, description, targets):
Expand All @@ -446,7 +452,7 @@ def timeseries_memory(self, title, description, targets):
targets=targets,
gridPos=gridPos,
unit="bytes",
fillOpacity=10,
**self.common_options,
)

def timeseries_cpu(self, title, description, targets):
Expand All @@ -457,7 +463,7 @@ def timeseries_cpu(self, title, description, targets):
targets=targets,
gridPos=gridPos,
unit="percentunit",
fillOpacity=10,
**self.common_options,
)

def timeseries_latency_small(self, title, description, targets):
Expand All @@ -468,7 +474,7 @@ def timeseries_latency_small(self, title, description, targets):
targets=targets,
gridPos=gridPos,
unit="s",
fillOpacity=10,
**self.common_options,
)

def timeseries_id(self, title, description, targets):
Expand All @@ -478,9 +484,9 @@ def timeseries_id(self, title, description, targets):
description=description,
targets=targets,
gridPos=gridPos,
fillOpacity=10,
legendDisplayMode="table",
legendPlacement="right",
**self.common_options,
)

def table_info(self, title, description, targets, excluded_columns):
Expand Down
Loading

0 comments on commit e29a1d8

Please sign in to comment.