Skip to content

feat(check): add corrupt chunk check #629

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
akrem-chabchoub wants to merge 2 commits into from
Closed

feat(check): add corrupt chunk check #629

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
c827657
feat(check): add corrupt chunk check
akrem-chabchoub Oct 15, 2026
4d9cfc3
chore(config): update image and enable persistence for local node group
akrem-chabchoub Oct 15, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions cmd/beekeeper/cmd/check.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -104,8 +104,9 @@ Use --metrics-enabled to collect and push metrics to Prometheus.`,

// set global config
checkGlobalConfig := config.CheckGlobalConfig{
Seed: c.globalConfig.GetInt64(optionNameSeed),
GethURL: c.globalConfig.GetString(optionNameGethURL),
Seed: c.globalConfig.GetInt64(optionNameSeed),
GethURL: c.globalConfig.GetString(optionNameGethURL),
K8sClient: c.k8sClient,
}

checkRunner := check.NewCheckRunner(checkGlobalConfig, c.config.Checks, cluster, metricsPusher, tracer, c.log)
Expand Down
20 changes: 17 additions & 3 deletions config/local.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ clusters:
bee:
bee-config: bee-local
config: local
count: 2
count: 8
mode: node
local-dns:
_inherit: "local"
Expand Down Expand Up @@ -101,7 +101,7 @@ clusters:
node-groups:
local:
_inherit: ""
image: k3d-registry.localhost:5000/ethersphere/bee:latest
image: akram951/bee:before-5640
image-pull-policy: Always
ingress-annotations:
nginx.ingress.kubernetes.io/affinity: "cookie"
Expand All @@ -122,14 +122,16 @@ node-groups:
beekeeper.ethswarm.org/node-funder: "true"
node-selector:
node-group: "local"
persistence-enabled: false
persistence-enabled: true
pod-management-policy: "OrderedReady"
resources-limit-cpu: "250m"
resources-limit-memory: 0.5Gi
resources-request-cpu: 150m
resources-request-memory: 0.25Gi
restart-policy: "Always"
update-strategy: "RollingUpdate"
persistence-storage-class: "local-path"
persistence-storage-request: "1Mi"
local-dns:
_inherit: "local"
local-autotls:
Expand Down Expand Up @@ -427,6 +429,18 @@ checks:
seed:
data-size:
type: redundancy
ci-corrupt-chunk:
options:
postage-ttl: 24h
postage-depth: 22
postage-label: test-label
seed:
import-image: akram951/bee:before-5640
restart-image:
expect-removed: true
ready-timeout: 5m
timeout: 30m
type: corrupt-chunk
ci-gsoc:
options:
postage-ttl: 24h
Expand Down
4 changes: 3 additions & 1 deletion pkg/bee/api/node.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,9 @@ func (n *NodeService) HasChunk(ctx context.Context, a swarm.Address) (bool, erro

// Health represents node's health
type Health struct {
Status string `json:"status"`
Status string `json:"status"`
Version string `json:"version"`
APIVersion string `json:"apiVersion"`
}

// Health returns node's health
Expand Down
5 changes: 5 additions & 0 deletions pkg/bee/client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -211,6 +211,11 @@ func (c *Client) DownloadBytes(ctx context.Context, a swarm.Address, opts *api.D
return io.ReadAll(r)
}

// Health returns node's health
func (c *Client) Health(ctx context.Context) (api.Health, error) {
return c.api.Node.Health(ctx)
}

// DownloadChunk downloads chunk from the node
func (c *Client) DownloadChunk(ctx context.Context, a swarm.Address, targets string, opts *api.DownloadOptions) (data []byte, err error) {
r, err := c.api.Chunks.Download(ctx, a, targets, opts)
Expand Down
Loading
Loading