aboutsummaryrefslogtreecommitdiff
path: root/weed/telemetry/collector.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/telemetry/collector.go')
-rw-r--r--weed/telemetry/collector.go41
1 files changed, 4 insertions, 37 deletions
diff --git a/weed/telemetry/collector.go b/weed/telemetry/collector.go
index 7991d92c8..19d4452ef 100644
--- a/weed/telemetry/collector.go
+++ b/weed/telemetry/collector.go
@@ -14,8 +14,6 @@ type Collector struct {
topo *topology.Topology
cluster *cluster.Cluster
masterServer interface{} // Will be set to *weed_server.MasterServer to access client tracking
- features []string
- deployment string
version string
os string
}
@@ -27,23 +25,11 @@ func NewCollector(client *Client, topo *topology.Topology, cluster *cluster.Clus
topo: topo,
cluster: cluster,
masterServer: nil,
- features: []string{},
- deployment: "unknown",
version: "unknown",
os: "unknown",
}
}
-// SetFeatures sets the list of enabled features
-func (c *Collector) SetFeatures(features []string) {
- c.features = features
-}
-
-// SetDeployment sets the deployment type (standalone, cluster, etc.)
-func (c *Collector) SetDeployment(deployment string) {
- c.deployment = deployment
-}
-
// SetVersion sets the SeaweedFS version
func (c *Collector) SetVersion(version string) {
c.version = version
@@ -82,7 +68,7 @@ func (c *Collector) StartPeriodicCollection(interval time.Duration) {
// Send initial telemetry after a short delay
go func() {
- time.Sleep(30 * time.Second) // Wait for cluster to stabilize
+ time.Sleep(61 * time.Second) // Wait for cluster to stabilize
c.CollectAndSendAsync()
}()
@@ -99,11 +85,9 @@ func (c *Collector) StartPeriodicCollection(interval time.Duration) {
// collectData gathers telemetry data from the topology
func (c *Collector) collectData() *proto.TelemetryData {
data := &proto.TelemetryData{
- Version: c.version,
- Os: c.os,
- Features: c.features,
- Deployment: c.deployment,
- Timestamp: time.Now().Unix(),
+ Version: c.version,
+ Os: c.os,
+ Timestamp: time.Now().Unix(),
}
if c.topo != nil {
@@ -199,20 +183,3 @@ func (c *Collector) getAllBrokerGroups() []string {
// In a more sophisticated implementation, we could enumerate all groups
return []string{""}
}
-
-// DetermineDeployment determines the deployment type based on configuration
-func DetermineDeployment(isMasterEnabled, isVolumeEnabled bool, peerCount int) string {
- if isMasterEnabled && isVolumeEnabled {
- if peerCount > 1 {
- return "cluster"
- }
- return "standalone"
- }
- if isMasterEnabled {
- return "master-only"
- }
- if isVolumeEnabled {
- return "volume-only"
- }
- return "unknown"
-}