lifecycle

type GroupConfig struct {
	*commonv1.Group
	NodeSelector    node.Selector
	QueueClient     queue.Client
	AccumulatedTTL  *commonv1.IntervalRule
	SegmentInterval *commonv1.IntervalRule
	TargetShardNum  uint32
	TargetReplicas  uint32
}

type Progress struct {
	CompletedGroups             map[string]bool                                            `json:"completed_groups"`
	DeletedStreamGroups         map[string]bool                                            `json:"deleted_stream_groups"`
	DeletedMeasureGroups        map[string]bool                                            `json:"deleted_measure_groups"`
	DeletedTraceGroups          map[string]bool                                            `json:"deleted_trace_groups"`
	CompletedStreamParts        map[string]map[string]map[common.ShardID]map[uint64]bool   `json:"completed_stream_parts"`
	StreamPartErrors            map[string]map[string]map[common.ShardID]map[uint64]string `json:"stream_part_errors"`
	CompletedStreamSeries       map[string]map[string]map[common.ShardID]bool              `json:"completed_stream_series"`
	StreamSeriesErrors          map[string]map[string]map[common.ShardID]string            `json:"stream_series_errors"`
	CompletedStreamElementIndex map[string]map[string]map[common.ShardID]bool              `json:"completed_stream_element_index"`
	StreamElementIndexErrors    map[string]map[string]map[common.ShardID]string            `json:"stream_element_index_errors"`
	StreamPartCounts            map[string]int                                             `json:"stream_part_counts"`
	StreamPartProgress          map[string]int                                             `json:"stream_part_progress"`
	StreamSeriesCounts          map[string]int                                             `json:"stream_series_counts"`
	StreamSeriesProgress        map[string]int                                             `json:"stream_series_progress"`
	StreamElementIndexCounts    map[string]int                                             `json:"stream_element_index_counts"`
	StreamElementIndexProgress  map[string]int                                             `json:"stream_element_index_progress"`
	// Measure part-specific progress tracking
	CompletedMeasureParts  map[string]map[string]map[common.ShardID]map[uint64]bool   `json:"completed_measure_parts"`
	MeasurePartErrors      map[string]map[string]map[common.ShardID]map[uint64]string `json:"measure_part_errors"`
	MeasurePartCounts      map[string]int                                             `json:"measure_part_counts"`
	MeasurePartProgress    map[string]int                                             `json:"measure_part_progress"`
	CompletedMeasureSeries map[string]map[string]map[common.ShardID]bool              `json:"completed_measure_series"`
	MeasureSeriesErrors    map[string]map[string]map[common.ShardID]string            `json:"measure_series_errors"`
	MeasureSeriesCounts    map[string]int                                             `json:"measure_series_counts"`
	MeasureSeriesProgress  map[string]int                                             `json:"measure_series_progress"`
	// Trace part-specific progress tracking
	CompletedTraceShards map[string]map[string]map[common.ShardID]bool   `json:"completed_trace_shards"`
	TraceShardErrors     map[string]map[string]map[common.ShardID]string `json:"trace_shard_errors"`
	TraceShardCounts     map[string]int                                  `json:"trace_shard_counts"`
	TraceShardProgress   map[string]int                                  `json:"trace_shard_progress"`
	CompletedTraceSeries map[string]map[string]map[common.ShardID]bool   `json:"completed_trace_series"`
	TraceSeriesErrors    map[string]map[string]map[common.ShardID]string `json:"trace_series_errors"`
	TraceSeriesCounts    map[string]int                                  `json:"trace_series_counts"`
	TraceSeriesProgress  map[string]int                                  `json:"trace_series_progress"`

	SnapshotStreamDir  string `json:"snapshot_stream_dir"`
	SnapshotMeasureDir string `json:"snapshot_measure_dir"`
	SnapshotTraceDir   string `json:"snapshot_trace_dir"`
	// contains filtered or unexported fields
}