Documentation
¶
Index ¶
- type CSVGenerator
- type DataProcessingParams
- type DataProcessorHandler
- func (h *DataProcessorHandler) EstimatedDuration() time.Duration
- func (h *DataProcessorHandler) Process(ctx context.Context, req *streamer.Request) (*streamer.Result, error)
- func (h *DataProcessorHandler) ProcessWithProgress(ctx context.Context, req *streamer.Request, reporter streamer.ProgressReporter) (*streamer.Result, error)
- func (h *DataProcessorHandler) Validate(req *streamer.Request) error
- type DataSource
- type DataStats
- type EchoAsyncHandler
- func (h *EchoAsyncHandler) EstimatedDuration() time.Duration
- func (h *EchoAsyncHandler) Process(ctx context.Context, req *streamer.Request) (*streamer.Result, error)
- func (h *EchoAsyncHandler) ProcessWithProgress(ctx context.Context, req *streamer.Request, reporter streamer.ProgressReporter) (*streamer.Result, error)
- func (h *EchoAsyncHandler) Validate(req *streamer.Request) error
- type ExcelGenerator
- type FeatureInfo
- type FeatureSet
- type ModelResults
- type OutputConfig
- type PDFGenerator
- type PreprocessedData
- type ProcessedData
- type ProcessingStats
- type QueryResult
- type ReportAsyncHandler
- func (h *ReportAsyncHandler) EstimatedDuration() time.Duration
- func (h *ReportAsyncHandler) Process(ctx context.Context, req *streamer.Request) (*streamer.Result, error)
- func (h *ReportAsyncHandler) ProcessWithProgress(ctx context.Context, req *streamer.Request, reporter streamer.ProgressReporter) (*streamer.Result, error)
- func (h *ReportAsyncHandler) Validate(req *streamer.Request) error
- type ReportGenerator
- type ReportInfo
- type ReportParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CSVGenerator ¶
type CSVGenerator struct {
// contains filtered or unexported fields
}
func (*CSVGenerator) GetEstimatedSize ¶
func (g *CSVGenerator) GetEstimatedSize() int
type DataProcessingParams ¶
type DataProcessingParams struct {
Pipeline string `json:"pipeline"` // classification, regression, clustering, anomaly, transformation
DataSource DataSource `json:"data_source"`
Output OutputConfig `json:"output"`
Options map[string]interface{} `json:"options,omitempty"`
}
type DataProcessorHandler ¶
type DataProcessorHandler struct {
// contains filtered or unexported fields
}
DataProcessorHandler implements async data processing with ML pipeline simulation
func NewDataProcessorHandler ¶
func NewDataProcessorHandler() *DataProcessorHandler
NewDataProcessorHandler creates a new data processor handler
func (*DataProcessorHandler) EstimatedDuration ¶
func (h *DataProcessorHandler) EstimatedDuration() time.Duration
EstimatedDuration returns the expected processing time
func (*DataProcessorHandler) Process ¶
func (h *DataProcessorHandler) Process(ctx context.Context, req *streamer.Request) (*streamer.Result, error)
Process should not be called for async handlers
func (*DataProcessorHandler) ProcessWithProgress ¶
func (h *DataProcessorHandler) ProcessWithProgress( ctx context.Context, req *streamer.Request, reporter streamer.ProgressReporter, ) (*streamer.Result, error)
ProcessWithProgress implements the ML pipeline processing with detailed progress
type DataSource ¶
type EchoAsyncHandler ¶
type EchoAsyncHandler struct{}
EchoAsyncHandler is a simple test handler that echoes the input with progress updates
func NewEchoAsyncHandler ¶
func NewEchoAsyncHandler() *EchoAsyncHandler
NewEchoAsyncHandler creates a new echo async handler
func (*EchoAsyncHandler) EstimatedDuration ¶
func (h *EchoAsyncHandler) EstimatedDuration() time.Duration
EstimatedDuration returns the expected processing time
func (*EchoAsyncHandler) Process ¶
func (h *EchoAsyncHandler) Process(ctx context.Context, req *streamer.Request) (*streamer.Result, error)
Process should not be called for async handlers
func (*EchoAsyncHandler) ProcessWithProgress ¶
func (h *EchoAsyncHandler) ProcessWithProgress( ctx context.Context, req *streamer.Request, reporter streamer.ProgressReporter, ) (*streamer.Result, error)
ProcessWithProgress echoes the input with simulated progress
type ExcelGenerator ¶
type ExcelGenerator struct {
// contains filtered or unexported fields
}
func (*ExcelGenerator) GetEstimatedSize ¶
func (g *ExcelGenerator) GetEstimatedSize() int
type FeatureInfo ¶
type FeatureSet ¶
type FeatureSet struct {
RecordCount int
Features map[string]FeatureInfo
SelectedCount int
}
type ModelResults ¶
type OutputConfig ¶
type PDFGenerator ¶
type PDFGenerator struct {
// contains filtered or unexported fields
}
func (*PDFGenerator) GetEstimatedSize ¶
func (g *PDFGenerator) GetEstimatedSize() int
type PreprocessedData ¶
type ProcessedData ¶
type ProcessingStats ¶
type ReportAsyncHandler ¶
type ReportAsyncHandler struct {
// contains filtered or unexported fields
}
ReportAsyncHandler implements async report generation with progress tracking
func NewReportAsyncHandler ¶
func NewReportAsyncHandler() *ReportAsyncHandler
NewReportAsyncHandler creates a new async report handler
func (*ReportAsyncHandler) EstimatedDuration ¶
func (h *ReportAsyncHandler) EstimatedDuration() time.Duration
EstimatedDuration returns the expected processing time
func (*ReportAsyncHandler) Process ¶
func (h *ReportAsyncHandler) Process(ctx context.Context, req *streamer.Request) (*streamer.Result, error)
Process should not be called for async handlers
func (*ReportAsyncHandler) ProcessWithProgress ¶
func (h *ReportAsyncHandler) ProcessWithProgress( ctx context.Context, req *streamer.Request, reporter streamer.ProgressReporter, ) (*streamer.Result, error)
ProcessWithProgress implements the actual report generation with progress updates
type ReportGenerator ¶
type ReportGenerator interface {
GetEstimatedSize() int
}
Report generators (interfaces for different formats)
type ReportInfo ¶
type ReportParams ¶
type ReportParams struct {
StartDate string `json:"start_date"`
EndDate string `json:"end_date"`
Format string `json:"format"` // pdf, csv, excel
ReportType string `json:"report_type"` // monthly, quarterly, annual, custom
IncludeCharts bool `json:"include_charts"`
Filters map[string]interface{} `json:"filters,omitempty"`
}