Documentation
¶
Index ¶
- type DataStore
- type EnhancedDashboardServer
- func (s *EnhancedDashboardServer) BroadcastDiscoveryUpdate(provider string, progress int, message string)
- func (s *EnhancedDashboardServer) BroadcastDriftDetected(driftCount int, severity string)
- func (s *EnhancedDashboardServer) BroadcastRemediationUpdate(planID string, status string, progress int)
- func (s *EnhancedDashboardServer) BroadcastResourceChange(changeType string, resourceID string, provider string)
- func (s *EnhancedDashboardServer) Run()
- func (s *EnhancedDashboardServer) SetAPIServer(apiServer ServerMetricsInterface)
- type EventBridge
- type Job
- type JobManager
- func (jm *JobManager) CreateJob(jobType string) *Job
- func (jm *JobManager) GetActiveJobCount() int
- func (jm *JobManager) GetFilteredJobs(jobType, status string, limit int) []*Job
- func (jm *JobManager) GetJob(id string) (*Job, bool)
- func (jm *JobManager) UpdateJob(id string, updates map[string]interface{}) error
- type ServerMetricsInterface
- type WebSocketClient
- type WebSocketCommand
- type WebSocketMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataStore ¶
type DataStore struct {
// contains filtered or unexported fields
}
DataStore stores server data
func (*DataStore) GetDrifts ¶
func (ds *DataStore) GetDrifts() []interface{}
GetDrifts retrieves drifts
func (*DataStore) GetResourceCount ¶
GetResourceCount retrieves resource count
func (*DataStore) SetCredentialStatus ¶
func (ds *DataStore) SetCredentialStatus(status interface{})
SetCredentialStatus stores credential status
type EnhancedDashboardServer ¶
type EnhancedDashboardServer struct {
// contains filtered or unexported fields
}
EnhancedDashboardServer represents the WebSocket server
func (*EnhancedDashboardServer) BroadcastDiscoveryUpdate ¶
func (s *EnhancedDashboardServer) BroadcastDiscoveryUpdate(provider string, progress int, message string)
BroadcastDiscoveryUpdate broadcasts discovery updates
func (*EnhancedDashboardServer) BroadcastDriftDetected ¶
func (s *EnhancedDashboardServer) BroadcastDriftDetected(driftCount int, severity string)
BroadcastDriftDetected broadcasts drift detection events
func (*EnhancedDashboardServer) BroadcastRemediationUpdate ¶
func (s *EnhancedDashboardServer) BroadcastRemediationUpdate(planID string, status string, progress int)
BroadcastRemediationUpdate broadcasts remediation updates
func (*EnhancedDashboardServer) BroadcastResourceChange ¶
func (s *EnhancedDashboardServer) BroadcastResourceChange(changeType string, resourceID string, provider string)
BroadcastResourceChange broadcasts resource changes
func (*EnhancedDashboardServer) Run ¶
func (s *EnhancedDashboardServer) Run()
Run starts the WebSocket server broadcast processing
func (*EnhancedDashboardServer) SetAPIServer ¶
func (s *EnhancedDashboardServer) SetAPIServer(apiServer ServerMetricsInterface)
SetAPIServer sets the API server reference for metrics tracking
type EventBridge ¶
type EventBridge struct {
// contains filtered or unexported fields
}
EventBridge connects the event bus to WebSocket clients
func NewEventBridge ¶
func NewEventBridge(eventBus *events.EventBus, wsServer *EnhancedDashboardServer) *EventBridge
NewEventBridge creates a new event bridge
func (*EventBridge) BroadcastCustomMessage ¶
func (eb *EventBridge) BroadcastCustomMessage(messageType string, data interface{})
BroadcastCustomMessage sends a custom message to all WebSocket clients
func (*EventBridge) GetConnectedClients ¶
func (eb *EventBridge) GetConnectedClients() int
GetConnectedClients returns the number of connected WebSocket clients
func (*EventBridge) IsActive ¶
func (eb *EventBridge) IsActive() bool
IsActive returns whether the event bridge is active
func (*EventBridge) Start ¶
func (eb *EventBridge) Start() error
Start begins bridging events to WebSocket clients
type Job ¶
type Job struct {
ID string `json:"id"`
Type string `json:"type"`
Status string `json:"status"`
Progress int `json:"progress"`
Result interface{} `json:"result,omitempty"`
Error string `json:"error,omitempty"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
Metadata map[string]interface{} `json:"metadata"`
}
Job represents an async job
type JobManager ¶
type JobManager struct {
// contains filtered or unexported fields
}
JobManager manages async jobs
func (*JobManager) CreateJob ¶
func (jm *JobManager) CreateJob(jobType string) *Job
CreateJob creates a new job
func (*JobManager) GetActiveJobCount ¶
func (jm *JobManager) GetActiveJobCount() int
GetActiveJobCount returns the count of active jobs
func (*JobManager) GetFilteredJobs ¶
func (jm *JobManager) GetFilteredJobs(jobType, status string, limit int) []*Job
GetFilteredJobs returns filtered jobs
type ServerMetricsInterface ¶
type ServerMetricsInterface interface {
IncrementWSMessagesSent()
}
ServerMetricsInterface defines the interface for tracking server metrics
type WebSocketClient ¶
type WebSocketClient struct {
// contains filtered or unexported fields
}
WebSocketClient represents a connected WebSocket client
type WebSocketCommand ¶
type WebSocketCommand struct {
Command string `json:"command"`
Params map[string]interface{} `json:"params"`
ID string `json:"id"`
}
WebSocketCommand represents a command from a WebSocket client