cluster

type Alert struct {
	ID        string                 `json:"id"`
	Type      AlertType              `json:"type"`
	Severity  AlertSeverity          `json:"severity"`
	Message   string                 `json:"message"`
	Data      map[string]interface{} `json:"data"`
	Timestamp time.Time              `json:"timestamp"`
	Resolved  bool                   `json:"resolved"`
}

type AlertChannel interface {
	Send(alert Alert) error
	GetType() string
}

type AlertManager struct {
	// contains filtered or unexported fields
}

type AlertSeverity string

type AlertTemplate struct {
	Subject string `yaml:"subject"`
	Body    string `yaml:"body"`
}

type AlertType string

type AppendEntriesRequest struct {
	Term         uint64     `json:"term"`
	LeaderID     string     `json:"leader_id"`
	PrevLogIndex uint64     `json:"prev_log_index"`
	PrevLogTerm  uint64     `json:"prev_log_term"`
	Entries      []LogEntry `json:"entries"`
	LeaderCommit uint64     `json:"leader_commit"`
}

type AppendEntriesResponse struct {
	Term    uint64 `json:"term"`
	Success bool   `json:"success"`
}

type Cluster struct {
	ID        string            `json:"id"`
	Name      string            `json:"name"`
	Nodes     map[string]*Node  `json:"nodes"`
	Shards    map[string]*Shard `json:"shards"`
	Config    ClusterConfig     `json:"config"`
	State     ClusterState      `json:"state"`
	CreatedAt time.Time         `json:"created_at"`
	UpdatedAt time.Time         `json:"updated_at"`
	// contains filtered or unexported fields
}

type ClusterConfig struct {
	ReplicationFactor int           `yaml:"replication_factor"`
	ShardSize         int           `yaml:"shard_size"`
	ElectionTimeout   time.Duration `yaml:"election_timeout"`
	HeartbeatInterval time.Duration `yaml:"heartbeat_interval"`
	MaxLogEntries     int           `yaml:"max_log_entries"`
	SnapshotThreshold int           `yaml:"snapshot_threshold"`
	AutoRebalance     bool          `yaml:"auto_rebalance"`
	ConsistencyLevel  string        `yaml:"consistency_level"`
}

type ClusterEvent struct {
	Type      ClusterEventType       `json:"type"`
	NodeID    string                 `json:"node_id"`
	ShardID   string                 `json:"shard_id"`
	Data      map[string]interface{} `json:"data"`
	Timestamp time.Time              `json:"timestamp"`
}

type ClusterEventType string

type ClusterHealth struct {
	Status       ClusterState `json:"status"`
	TotalNodes   int          `json:"total_nodes"`
	HealthyNodes int          `json:"healthy_nodes"`
	TotalShards  int          `json:"total_shards"`
	ActiveShards int          `json:"active_shards"`
	Timestamp    time.Time    `json:"timestamp"`
}

type ClusterState string

type Command struct {
	Type       CommandType            `json:"type"`
	Repository string                 `json:"repository"`
	Data       map[string]interface{} `json:"data"`
	Metadata   map[string]string      `json:"metadata"`
}

type CommandType string

type ConflictResolution struct {
	Strategy     ConflictStrategy       `json:"strategy"`
	WinnerNode   string                 `json:"winner_node"`
	ConflictData map[string]interface{} `json:"conflict_data"`
	Resolution   string                 `json:"resolution"`
	ResolvedAt   time.Time              `json:"resolved_at"`
}

type ConflictStrategy string

type ConsistentHashRing struct {
	// contains filtered or unexported fields
}

type FailoverEvent struct {
	ID          string            `json:"id"`
	Type        FailoverType      `json:"type"`
	SourceNode  string            `json:"source_node"`
	TargetNode  string            `json:"target_node"`
	Reason      string            `json:"reason"`
	Status      FailoverStatus    `json:"status"`
	StartedAt   time.Time         `json:"started_at"`
	CompletedAt time.Time         `json:"completed_at"`
	Duration    time.Duration     `json:"duration"`
	Errors      []string          `json:"errors"`
	Metadata    map[string]string `json:"metadata"`
}

type FailoverManager struct {
	// contains filtered or unexported fields
}

type FailoverPolicy struct {
	AutoFailoverEnabled   bool          `yaml:"auto_failover_enabled"`
	FailoverTimeout       time.Duration `yaml:"failover_timeout"`
	MinHealthyNodes       int           `yaml:"min_healthy_nodes"`
	RequireQuorum         bool          `yaml:"require_quorum"`
	PreventSplitBrain     bool          `yaml:"prevent_split_brain"`
	MaxFailoversPerMinute int           `yaml:"max_failovers_per_minute"`
	CooldownPeriod        time.Duration `yaml:"cooldown_period"`
}

type FailoverStatus string

type FailoverType string

type HealthCallback func(nodeID string, oldStatus, newStatus HealthStatus)

type HealthChecker struct {
	// contains filtered or unexported fields
}

type HealthStatus string

type JoinRequest struct {
	NodeID  string `json:"node_id"`
	Address string `json:"address"`
	Port    int    `json:"port"`
	Version string `json:"version"`
}

type JoinResponse struct {
	Success   bool     `json:"success"`
	Message   string   `json:"message"`
	LeaderID  string   `json:"leader_id"`
	ClusterID string   `json:"cluster_id"`
	Nodes     []string `json:"nodes"`
}

type LeaveRequest struct {
	NodeID string `json:"node_id"`
	Reason string `json:"reason"`
}

type LeaveResponse struct {
	Success bool   `json:"success"`
	Message string `json:"message"`
}

type LogEntry struct {
	Term      uint64    `json:"term"`
	Index     uint64    `json:"index"`
	Command   Command   `json:"command"`
	Timestamp time.Time `json:"timestamp"`
	ClientID  string    `json:"client_id"`
}

type MigrationQueue struct {
	// contains filtered or unexported fields
}

type MigrationState string

type MigrationTask struct {
	ID           string            `json:"id"`
	ShardID      string            `json:"shard_id"`
	SourceNode   string            `json:"source_node"`
	TargetNode   string            `json:"target_node"`
	Repositories []string          `json:"repositories"`
	State        MigrationState    `json:"state"`
	Progress     int               `json:"progress"`
	Error        string            `json:"error"`
	StartedAt    time.Time         `json:"started_at"`
	CompletedAt  time.Time         `json:"completed_at"`
	Metadata     map[string]string `json:"metadata"`
}

type Node struct {
	ID       string    `json:"id"`
	Address  string    `json:"address"`
	Port     int       `json:"port"`
	State    NodeState `json:"state"`
	LastSeen time.Time `json:"last_seen"`
	Version  string    `json:"version"`

	// Raft-specific fields
	Term        uint64   `json:"term"`
	VotedFor    string   `json:"voted_for"`
	IsLeader    bool     `json:"is_leader"`
	LeaderID    string   `json:"leader_id"`
	CommitIndex uint64   `json:"commit_index"`
	LastApplied uint64   `json:"last_applied"`
	NextIndex   []uint64 `json:"next_index"`
	MatchIndex  []uint64 `json:"match_index"`

	Stats    NodeStats         `json:"stats"`
	Metadata map[string]string `json:"metadata"`
	// contains filtered or unexported fields
}

type NodeCapacity struct {
	RepositoryCount   int64   `json:"repository_count"`
	MaxRepositories   int64   `json:"max_repositories"`
	AvailableCapacity float64 `json:"available_capacity"`
}

type NodeConfig struct {
	ID                string        `yaml:"id"`
	Address           string        `yaml:"address"`
	Port              int           `yaml:"port"`
	DataDir           string        `yaml:"data_dir"`
	ClusterPeers      []string      `yaml:"cluster_peers"`
	ElectionTimeout   time.Duration `yaml:"election_timeout"`
	HeartbeatTimeout  time.Duration `yaml:"heartbeat_timeout"`
	MaxLogEntries     int           `yaml:"max_log_entries"`
	SnapshotThreshold int           `yaml:"snapshot_threshold"`
}

type NodeHealth struct {
	NodeID           string        `json:"node_id"`
	Status           HealthStatus  `json:"status"`
	LastSeen         time.Time     `json:"last_seen"`
	ConsecutiveFails int           `json:"consecutive_fails"`
	ResponseTime     time.Duration `json:"response_time"`
	LoadAverage      float64       `json:"load_average"`
	MemoryUsage      float64       `json:"memory_usage"`
	DiskUsage        float64       `json:"disk_usage"`
	NetworkLatency   time.Duration `json:"network_latency"`
	Errors           []string      `json:"errors"`
}

type NodeState string

type NodeStats struct {
	CPUUsage        float64   `json:"cpu_usage"`
	MemoryUsage     float64   `json:"memory_usage"`
	DiskUsage       float64   `json:"disk_usage"`
	RepositoryCount int64     `json:"repository_count"`
	LastUpdate      time.Time `json:"last_update"`
}

type RaftState struct {
	// Persistent state
	CurrentTerm uint64     `json:"current_term"`
	VotedFor    string     `json:"voted_for"`
	Log         []LogEntry `json:"log"`

	// Volatile state
	CommitIndex uint64 `json:"commit_index"`
	LastApplied uint64 `json:"last_applied"`

	// Leader state (reinitialized after election)
	NextIndex  map[string]uint64 `json:"next_index"`
	MatchIndex map[string]uint64 `json:"match_index"`

	// Timing
	ElectionTimeout  time.Duration `json:"election_timeout"`
	HeartbeatTimeout time.Duration `json:"heartbeat_timeout"`
	LastHeartbeat    time.Time     `json:"last_heartbeat"`
	// contains filtered or unexported fields
}

type RebalanceTask struct {
	ID         string    `json:"id"`
	Type       string    `json:"type"`
	SourceNode string    `json:"source_node"`
	TargetNode string    `json:"target_node"`
	ShardID    string    `json:"shard_id"`
	Priority   int       `json:"priority"`
	CreatedAt  time.Time `json:"created_at"`
}

type RecoveryManager struct {
	// contains filtered or unexported fields
}

type RecoveryStatus string

type RecoveryTask struct {
	ID          string            `json:"id"`
	NodeID      string            `json:"node_id"`
	Type        RecoveryType      `json:"type"`
	Status      RecoveryStatus    `json:"status"`
	StartedAt   time.Time         `json:"started_at"`
	CompletedAt time.Time         `json:"completed_at"`
	Progress    int               `json:"progress"`
	Errors      []string          `json:"errors"`
	Metadata    map[string]string `json:"metadata"`
}

type RecoveryType string

type ReplicationManager struct {
	// contains filtered or unexported fields
}

type ReplicationMetrics struct {
	TotalReplications      uint64            `json:"total_replications"`
	SuccessfulReplications uint64            `json:"successful_replications"`
	FailedReplications     uint64            `json:"failed_replications"`
	AverageLatency         time.Duration     `json:"average_latency"`
	ThroughputBytesPerSec  uint64            `json:"throughput_bytes_per_sec"`
	ActiveReplications     int               `json:"active_replications"`
	ReplicationsByNode     map[string]uint64 `json:"replications_by_node"`
	ErrorsByType           map[string]uint64 `json:"errors_by_type"`
}

type ReplicationState string

type ReplicationStrategy struct {
	Type               ReplicationType `yaml:"type"`
	ConsistencyLevel   string          `yaml:"consistency_level"`
	SyncTimeout        time.Duration   `yaml:"sync_timeout"`
	AsyncBufferSize    int             `yaml:"async_buffer_size"`
	CompressionEnabled bool            `yaml:"compression_enabled"`
	EncryptionEnabled  bool            `yaml:"encryption_enabled"`
	BatchSize          int             `yaml:"batch_size"`
	RetryPolicy        RetryPolicy     `yaml:"retry_policy"`
}

type ReplicationTask struct {
	ID           string            `json:"id"`
	Type         ReplicationType   `json:"type"`
	SourceNode   string            `json:"source_node"`
	TargetNodes  []string          `json:"target_nodes"`
	RepositoryID string            `json:"repository_id"`
	ShardID      string            `json:"shard_id"`
	Data         []byte            `json:"data"`
	Checksum     string            `json:"checksum"`
	State        ReplicationState  `json:"state"`
	Progress     int               `json:"progress"`
	StartedAt    time.Time         `json:"started_at"`
	CompletedAt  time.Time         `json:"completed_at"`
	RetryCount   int               `json:"retry_count"`
	MaxRetries   int               `json:"max_retries"`
	Error        string            `json:"error"`
	Metadata     map[string]string `json:"metadata"`
}

type ReplicationType string

type RepositoryOperation struct {
	Operation string                 `json:"operation"`
	RepoID    string                 `json:"repo_id"`
	Data      map[string]interface{} `json:"data"`
}

type RequestVoteRequest struct {
	Term         uint64 `json:"term"`
	CandidateID  string `json:"candidate_id"`
	LastLogIndex uint64 `json:"last_log_index"`
	LastLogTerm  uint64 `json:"last_log_term"`
}

type RequestVoteResponse struct {
	Term        uint64 `json:"term"`
	VoteGranted bool   `json:"vote_granted"`
}

type RetryPolicy struct {
	MaxRetries    int           `yaml:"max_retries"`
	InitialDelay  time.Duration `yaml:"initial_delay"`
	MaxDelay      time.Duration `yaml:"max_delay"`
	BackoffFactor float64       `yaml:"backoff_factor"`
	JitterEnabled bool          `yaml:"jitter_enabled"`
}

type Shard struct {
	ID           string          `json:"id"`
	KeyRange     ShardKeyRange   `json:"key_range"`
	PrimaryNode  string          `json:"primary_node"`
	ReplicaNodes []string        `json:"replica_nodes"`
	State        ShardState      `json:"state"`
	Repositories map[string]bool `json:"repositories"`
	Size         int64           `json:"size"`
	LastAccessed time.Time       `json:"last_accessed"`
	CreatedAt    time.Time       `json:"created_at"`
}

type ShardKeyRange struct {
	Start string `json:"start"`
	End   string `json:"end"`
}

type ShardMetrics struct {
	TotalShards          int            `json:"total_shards"`
	ShardsPerNode        map[string]int `json:"shards_per_node"`
	RepositoriesPerShard map[string]int `json:"repositories_per_shard"`
	LoadBalance          float64        `json:"load_balance"`
	Imbalance            float64        `json:"imbalance"`
	HotSpots             []string       `json:"hot_spots"`
}

type ShardRebalancer struct {
	// contains filtered or unexported fields
}

type ShardState string

type ShardingManager struct {
	// contains filtered or unexported fields
}

type SnapshotRequest struct {
	Term              uint64 `json:"term"`
	LeaderID          string `json:"leader_id"`
	LastIncludedIndex uint64 `json:"last_included_index"`
	LastIncludedTerm  uint64 `json:"last_included_term"`
	Offset            uint64 `json:"offset"`
	Data              []byte `json:"data"`
	Done              bool   `json:"done"`
}

type SnapshotResponse struct {
	Term uint64 `json:"term"`
}

type StatusResponse struct {
	NodeID         string    `json:"node_id"`
	State          NodeState `json:"state"`
	IsLeader       bool      `json:"is_leader"`
	LeaderID       string    `json:"leader_id"`
	Term           uint64    `json:"term"`
	CommitIndex    uint64    `json:"commit_index"`
	LastApplied    uint64    `json:"last_applied"`
	LogLength      int       `json:"log_length"`
	ClusterSize    int       `json:"cluster_size"`
	ConnectedNodes []string  `json:"connected_nodes"`
}