stars

type AccessPolicy struct {
	ReadAllow   []string `json:"read_allow"`   // 允许读取的Agent
	WriteAllow  []string `json:"write_allow"`  // 允许写入的Agent
	DeleteAllow []string `json:"delete_allow"` // 允许删除的Agent
	AdminAllow  []string `json:"admin_allow"`  // 允许管理的Agent
	Public      bool     `json:"public"`       // 是否公开
}

type AgentConnection struct {
	ID               string                 `json:"id"`
	Name             string                 `json:"name"`
	Address          string                 `json:"address"`
	SubscribedStates []string               `json:"subscribed_states"`
	ConnectionType   ConnectionType         `json:"connection_type"`
	Status           ConnectionStatus       `json:"status"`
	LastHeartbeat    time.Time              `json:"last_heartbeat"`
	Metadata         map[string]interface{} `json:"metadata"`

	// 同步状态
	SyncStatus     map[string]SyncStatus `json:"sync_status"`
	PendingUpdates []StateUpdate         `json:"pending_updates"`
	ConflictCount  int64                 `json:"conflict_count"`
	// contains filtered or unexported fields
}

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

type ConflictInfo struct {
	ConflictID  string                  `json:"conflict_id"`
	Type        ConflictType            `json:"type"`
	Description string                  `json:"description"`
	States      map[string]*SharedState `json:"states"`
	Operations  []PendingOperation      `json:"operations"`
	Resolution  ConflictResolution      `json:"resolution"`
	ResolvedAt  time.Time               `json:"resolved_at,omitempty"`
	ResolvedBy  string                  `json:"resolved_by,omitempty"`
	Metadata    map[string]interface{}  `json:"metadata"`
}

type ConflictResolution string

type ConflictRule interface {
	DetectConflict(event StateEvent, currentState *SharedState) (*ConflictInfo, error)
	ResolveConflict(conflict *ConflictInfo, strategy ConflictResolution) (*SharedState, error)
}

type ConflictType string

type ConnectionStatus string

type ConnectionType string

type ConsistencyLevel string

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

type DefaultConflictRule struct{}

type Event struct {
	AgentID string    // 产生事件的 Agent ID
	Type    string    // 事件类型
	Content string    // 事件内容
	Time    time.Time // 事件时间
}

type EventBus interface {
	Subscribe(eventType EventType, handler EventHandler) error
	Unsubscribe(eventType EventType, handler EventHandler) error
	Publish(event StateEvent) error
	PublishAsync(event StateEvent) error
	Close() error
}

type EventHandler interface {
	Handle(ctx context.Context, event StateEvent) error
}

type EventType string

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

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

type Member struct {
	AgentID string   // Agent ID
	Role    Role     // 角色
	Tags    []string // 能力标签（可选）
}

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

type Message struct {
	From string    // 发送者 Agent ID
	To   string    // 接收者 Agent ID（空表示广播）
	Text string    // 消息内容
	Time time.Time // 发送时间
}

type OperationType string

type PendingOperation struct {
	ID        string                 `json:"id"`
	Type      OperationType          `json:"type"`
	Key       string                 `json:"key"`
	Value     interface{}            `json:"value"`
	OldValue  interface{}            `json:"old_value"`
	Timestamp time.Time              `json:"timestamp"`
	AgentID   string                 `json:"agent_id"`
	Retry     int                    `json:"retry"`
	Metadata  map[string]interface{} `json:"metadata"`
}

type PersistenceConfig struct {
	Type             PersistenceType          `json:"type"`
	ConnectionString string                   `json:"connection_string"`
	Timeout          time.Duration            `json:"timeout"`
	MaxConnections   int                      `json:"max_connections"`
	BatchSize        int                      `json:"batch_size"`
	Compression      bool                     `json:"compression"`
	Encryption       bool                     `json:"encryption"`
	EncryptionKey    string                   `json:"encryption_key,omitempty"`
	Retention        map[string]time.Duration `json:"retention"`
}

type PersistenceLayer interface {
	SaveState(ctx context.Context, state *SharedState) error
	LoadState(ctx context.Context, stateID string) (*SharedState, error)
	UpdateState(ctx context.Context, state *SharedState) error
	DeleteState(ctx context.Context, stateID string) error
	ListStates(ctx context.Context, filters map[string]interface{}) ([]*SharedState, error)
	Backup(ctx context.Context, path string) error
	Restore(ctx context.Context, path string) error
	Close() error
}

type PersistenceType string

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

type Role string

type SharedState struct {
	// 基本信息
	ID      string    `json:"id"`
	Name    string    `json:"name"`
	Type    StateType `json:"type"`
	Owners  []string  `json:"owners"`  // 状态拥有者(Agent列表)
	Readers []string  `json:"readers"` // 状态读取者

	// 状态数据
	Data      map[string]interface{} `json:"data"`
	Version   int64                  `json:"version"`
	Timestamp time.Time              `json:"timestamp"`

	// 元数据
	Metadata map[string]interface{} `json:"metadata"`
	Tags     []string               `json:"tags"`

	// 同步信息
	LastSync   time.Time          `json:"last_sync"`
	SyncStatus SyncStatus         `json:"sync_status"`
	PendingOps []PendingOperation `json:"pending_ops"`

	// 访问控制
	AccessPolicy AccessPolicy `json:"access_policy"`
	// contains filtered or unexported fields
}

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

type StateEvent struct {
	Type      EventType              `json:"type"`
	StateID   string                 `json:"state_id"`
	State     *SharedState           `json:"state,omitempty"`
	AgentID   string                 `json:"agent_id,omitempty"`
	Operation *PendingOperation      `json:"operation,omitempty"`
	Conflict  *ConflictInfo          `json:"conflict,omitempty"`
	Timestamp time.Time              `json:"timestamp"`
	Metadata  map[string]interface{} `json:"metadata"`
}

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

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

type StateManagerConfig struct {
	// 同步配置
	SyncInterval time.Duration `json:"sync_interval"`
	MaxRetries   int           `json:"max_retries"`
	RetryDelay   time.Duration `json:"retry_delay"`

	// 持久化配置
	EnablePersistence bool            `json:"enable_persistence"`
	PersistenceType   PersistenceType `json:"persistence_type"`
	FlushInterval     time.Duration   `json:"flush_interval"`

	// 一致性配置
	ConsistencyLevel   ConsistencyLevel   `json:"consistency_level"`
	ConflictResolution ConflictResolution `json:"conflict_resolution"`

	// 监控配置
	EnableMetrics bool `json:"enable_metrics"`
	EnableAudit   bool `json:"enable_audit"`
}

type StateMetrics struct {
	TotalStates       int64         `json:"total_states"`
	ActiveStates      int64         `json:"active_states"`
	PendingOperations int64         `json:"pending_operations"`
	SyncErrors        int64         `json:"sync_errors"`
	Conflicts         int64         `json:"conflicts"`
	ReadOps           int64         `json:"read_ops"`
	WriteOps          int64         `json:"write_ops"`
	DeleteOps         int64         `json:"delete_ops"`
	AverageSyncTime   time.Duration `json:"average_sync_time"`
	LastSyncTime      time.Time     `json:"last_sync_time"`
}

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

type StateType string

type StateUpdate struct {
	ID        string                 `json:"id"`
	StateID   string                 `json:"state_id"`
	AgentID   string                 `json:"agent_id"`
	Type      OperationType          `json:"type"`
	Key       string                 `json:"key"`
	OldValue  interface{}            `json:"old_value"`
	NewValue  interface{}            `json:"new_value"`
	Version   int64                  `json:"version"`
	Timestamp time.Time              `json:"timestamp"`
	Metadata  map[string]interface{} `json:"metadata"`
}

type SyncConfig struct {
	// 基础配置
	SyncInterval time.Duration `json:"sync_interval"`
	MaxRetries   int           `json:"max_retries"`
	RetryDelay   time.Duration `json:"retry_delay"`
	Timeout      time.Duration `json:"timeout"`

	// 批处理配置
	BatchSize     int           `json:"batch_size"`
	FlushInterval time.Duration `json:"flush_interval"`

	// 一致性配置
	ConsistencyLevel ConsistencyLevel   `json:"consistency_level"`
	ConflictStrategy ConflictResolution `json:"conflict_strategy"`

	// 压缩配置
	Compression     bool   `json:"compression"`
	CompressionType string `json:"compression_type"`

	// 安全配置
	Encryption    bool   `json:"encryption"`
	EncryptionKey string `json:"encryption_key"`

	// 性能配置
	MaxConcurrentSyncs int `json:"max_concurrent_syncs"`
	QueueBufferSize    int `json:"queue_buffer_size"`
}

type SyncMetrics struct {
	TotalSyncs        int64         `json:"total_syncs"`
	SuccessfulSyncs   int64         `json:"successful_syncs"`
	FailedSyncs       int64         `json:"failed_syncs"`
	Conflicts         int64         `json:"conflicts"`
	PendingTasks      int64         `json:"pending_tasks"`
	ActiveConnections int64         `json:"active_connections"`
	AverageLatency    time.Duration `json:"average_latency"`
	LastSyncTime      time.Time     `json:"last_sync_time"`
	ThroughputPerSec  float64       `json:"throughput_per_sec"`
}

type SyncStatus string

type SyncTask struct {
	ID           string                 `json:"id"`
	Type         SyncTaskType           `json:"type"`
	Priority     int                    `json:"priority"`
	StateID      string                 `json:"state_id"`
	TargetAgents []string               `json:"target_agents"`
	Updates      []StateUpdate          `json:"updates"`
	CreatedAt    time.Time              `json:"created_at"`
	StartedAt    time.Time              `json:"started_at,omitempty"`
	CompletedAt  time.Time              `json:"completed_at,omitempty"`
	Status       TaskStatus             `json:"status"`
	RetryCount   int                    `json:"retry_count"`
	MaxRetries   int                    `json:"max_retries"`
	Error        string                 `json:"error,omitempty"`
	Metadata     map[string]interface{} `json:"metadata"`
}

type SyncTaskType string

type TaskStatus string