clickhouse_progress.go 439 B

1234567891011121314151617181920212223242526
  1. package clickhouse
  2. type progress struct {
  3. rows uint64
  4. bytes uint64
  5. totalRows uint64
  6. }
  7. func (ch *clickhouse) progress() (*progress, error) {
  8. var (
  9. p progress
  10. err error
  11. )
  12. if p.rows, err = ch.decoder.Uvarint(); err != nil {
  13. return nil, err
  14. }
  15. if p.bytes, err = ch.decoder.Uvarint(); err != nil {
  16. return nil, err
  17. }
  18. if p.totalRows, err = ch.decoder.Uvarint(); err != nil {
  19. return nil, err
  20. }
  21. return &p, nil
  22. }