progress

type BatchedReporter struct {
	*Batcher
}

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

type BatcherOption func(*Batcher)

type ConnectionManager interface {
	Send(ctx context.Context, connectionID string, message interface{}) error
	IsActive(ctx context.Context, connectionID string) bool
}

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

type Reporter interface {
	// Report sends a progress update with percentage and message
	Report(percentage float64, message string) error

	// SetMetadata adds metadata to the progress update
	SetMetadata(key string, value interface{}) error

	// Complete marks the request as complete with the result
	Complete(result interface{}) error

	// Fail marks the request as failed with an error
	Fail(err error) error
}

type Update struct {
	RequestID  string
	Percentage float64
	Message    string
	Metadata   map[string]interface{}
	Error      error
	Timestamp  time.Time
}