Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Sync (0.2 sec)

  1. internal/s3select/simdj/reader.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package simdj
    
    import (
    	"fmt"
    	"io"
    	"sync"
    	"sync/atomic"
    
    	"github.com/minio/minio/internal/s3select/json"
    	"github.com/minio/minio/internal/s3select/sql"
    	"github.com/minio/simdjson-go"
    )
    
    // Reader - JSON record reader for S3Select.
    type Reader struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader.go

    	err          error            // global error state, only touched by Reader.Read
    	bufferPool   sync.Pool        // pool of []byte objects for input
    	csvDstPool   sync.Pool        // pool of [][]string used for output
    	close        chan struct{}    // used for shutting down the splitter before end of stream
    	readerWg     sync.WaitGroup   // used to keep track of async reader.
    }
    
    // queueItem is an item in the queue.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  3. src/archive/zip/reader.go

    package zip
    
    import (
    	"bufio"
    	"encoding/binary"
    	"errors"
    	"hash"
    	"hash/crc32"
    	"internal/godebug"
    	"io"
    	"io/fs"
    	"os"
    	"path"
    	"path/filepath"
    	"sort"
    	"strings"
    	"sync"
    	"time"
    )
    
    var zipinsecurepath = godebug.New("zipinsecurepath")
    
    var (
    	ErrFormat       = errors.New("zip: not a valid zip file")
    	ErrAlgorithm    = errors.New("zip: unsupported compression algorithm")
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
Back to top