Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 71 for ioutilx (0.11 sec)

  1. cmd/utils.go

    	"github.com/minio/minio/internal/fips"
    	"github.com/minio/minio/internal/handlers"
    	"github.com/minio/minio/internal/hash"
    	xhttp "github.com/minio/minio/internal/http"
    	ioutilx "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/logger/message/audit"
    	"github.com/minio/minio/internal/rest"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/certs"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  2. cmd/object-handlers_test.go

    	"sync"
    	"testing"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/hash/sha256"
    	xhttp "github.com/minio/minio/internal/http"
    	ioutilx "github.com/minio/minio/internal/ioutil"
    )
    
    // Type to capture different modifications to API request to simulate failure cases.
    type Fault int
    
    const (
    	None Fault = iota
    	MissingContentLength
    	TooBigObject
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  3. internal/ioutil/ioutil.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 ioutil implements some I/O utility functions which are not covered
    // by the standard library.
    package ioutil
    
    import (
    	"context"
    	"errors"
    	"io"
    	"os"
    	"runtime/debug"
    	"sync"
    	"time"
    
    	"github.com/dustin/go-humanize"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. internal/store/store.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"strconv"
    	"strings"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    const (
    	retryInterval = 3 * time.Second
    )
    
    type logger = func(ctx context.Context, err error, id string, errKind ...interface{})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. internal/grid/muxserver.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package grid
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    type muxServer struct {
    	ID                 uint64
    	LastPing           int64
    	SendSeq, RecvSeq   uint32
    	Resp               chan []byte
    	BaseFlags          Flags
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  6. cmd/warm-backend-gcs.go

    	"fmt"
    	"io"
    
    	"cloud.google.com/go/storage"
    	"github.com/minio/madmin-go/v3"
    	"google.golang.org/api/googleapi"
    	"google.golang.org/api/iterator"
    	"google.golang.org/api/option"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    type warmBackendGCS struct {
    	client       *storage.Client
    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/cachevalue"
    	"github.com/minio/minio/internal/grid"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/ioutil"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/rest"
    	xnet "github.com/minio/pkg/v3/net"
    	xbufio "github.com/philhofer/fwd"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func isNetworkError(err error) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. cmd/erasure.go

    import (
    	"context"
    	"errors"
    	"fmt"
    	"math/rand"
    	"os"
    	"runtime"
    	"sort"
    	"sync"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/dsync"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    // list all errors that can be ignore in a bucket operation.
    var bucketOpIgnoredErrs = append(baseIgnoredErrs, errDiskAccessDenied, errUnformattedDisk)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  9. cmd/xl-storage-disk-id-check.go

    	"runtime"
    	"strconv"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/cachevalue"
    	"github.com/minio/minio/internal/grid"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    )
    
    //go:generate stringer -type=storageMetric -trimprefix=storageMetric $GOFILE
    
    type storageMetric uint8
    
    const (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. cmd/erasure-decode.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"sync"
    	"sync/atomic"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    // Reads in parallel from readers.
    type parallelReader struct {
    	readers       []io.ReaderAt
    	orgReaders    []io.ReaderAt
    	dataBlocks    int
    	offset        int64
    	shardSize     int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
Back to top