Documentation
¶
Index ¶
- type AnalyticsProjector
- type Config
- type DashboardProjector
- func (p *DashboardProjector) GetBrokerPerformance(ctx context.Context, tenantID, period string) (map[string]interface{}, error)
- func (p *DashboardProjector) GetLeadFunnel(ctx context.Context, tenantID, period string) (map[string]interface{}, error)
- func (p *DashboardProjector) GetOverview(ctx context.Context, tenantID string) (map[string]interface{}, error)
- func (p *DashboardProjector) HandleEvent(event Event)
- func (p *DashboardProjector) RefreshViews()
- type Event
- type Manager
- func (m *Manager) GetBrokerPerformance(ctx context.Context, tenantID, period string) (map[string]interface{}, error)
- func (m *Manager) GetDashboardOverview(ctx context.Context, tenantID string) (map[string]interface{}, error)
- func (m *Manager) GetLeadFunnel(ctx context.Context, tenantID, period string) (map[string]interface{}, error)
- func (m *Manager) GetQueueMetrics(ctx context.Context, tenantID string) (map[string]interface{}, error)
- func (m *Manager) IsReady() bool
- func (m *Manager) Start(ctx context.Context)
- func (m *Manager) Stop()
- type RealtimeProjector
- type ReportProjector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AnalyticsProjector ¶
type AnalyticsProjector struct {
// contains filtered or unexported fields
}
func NewAnalyticsProjector ¶
func NewAnalyticsProjector(db *sql.DB, redis *redis.Client, logger *zap.Logger) *AnalyticsProjector
func (*AnalyticsProjector) HandleEvent ¶
func (p *AnalyticsProjector) HandleEvent(event Event)
func (*AnalyticsProjector) RefreshViews ¶
func (p *AnalyticsProjector) RefreshViews()
type DashboardProjector ¶
type DashboardProjector struct {
// contains filtered or unexported fields
}
func NewDashboardProjector ¶
func NewDashboardProjector(db *sql.DB, redis *redis.Client, logger *zap.Logger) *DashboardProjector
func (*DashboardProjector) GetBrokerPerformance ¶
func (*DashboardProjector) GetLeadFunnel ¶
func (*DashboardProjector) GetOverview ¶
func (*DashboardProjector) HandleEvent ¶
func (p *DashboardProjector) HandleEvent(event Event)
func (*DashboardProjector) RefreshViews ¶
func (p *DashboardProjector) RefreshViews()
type Event ¶
type Event struct {
ID string `json:"id"`
Type string `json:"type"`
TenantID string `json:"tenant_id"`
AggregateID string `json:"aggregate_id"`
Data map[string]interface{} `json:"data"`
Timestamp time.Time `json:"timestamp"`
}
Event represents an event from the broker queue system
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func (*Manager) GetBrokerPerformance ¶
func (*Manager) GetDashboardOverview ¶
func (m *Manager) GetDashboardOverview(ctx context.Context, tenantID string) (map[string]interface{}, error)
Dashboard methods
func (*Manager) GetLeadFunnel ¶
func (*Manager) GetQueueMetrics ¶
type RealtimeProjector ¶
type RealtimeProjector struct {
// contains filtered or unexported fields
}
func NewRealtimeProjector ¶
func NewRealtimeProjector(db *sql.DB, redis *redis.Client, logger *zap.Logger) *RealtimeProjector
func (*RealtimeProjector) GetQueueMetrics ¶
func (*RealtimeProjector) HandleEvent ¶
func (p *RealtimeProjector) HandleEvent(event Event)
func (*RealtimeProjector) RefreshCache ¶
func (p *RealtimeProjector) RefreshCache()
type ReportProjector ¶
type ReportProjector struct {
// contains filtered or unexported fields
}
func NewReportProjector ¶
func NewReportProjector(db *sql.DB, redis *redis.Client, logger *zap.Logger) *ReportProjector
func (*ReportProjector) HandleEvent ¶
func (p *ReportProjector) HandleEvent(event Event)
func (*ReportProjector) RefreshViews ¶
func (p *ReportProjector) RefreshViews()
Source Files
Click to show internal directories.
Click to hide internal directories.