Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 289 for Pkg (0.01 seconds)

  1. docs/debugging/s3-verify/main.go

    import (
    	"bytes"
    	"context"
    	"crypto/sha256"
    	"flag"
    	"fmt"
    	"hash"
    	"io"
    	"log"
    	"net/url"
    	"os"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    var (
    	sourceEndpoint, sourceAccessKey, sourceSecretKey string
    	sourceBucket, sourcePrefix                       string
    	targetEndpoint, targetAccessKey, targetSecretKey string
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 22 15:12:47 GMT 2022
    - 8.4K bytes
    - Click Count (0)
  2. docs/lambda/README.md

    ```go
    package main
    
    import (
    	"context"
    	"log"
    	"net/url"
    	"time"
    	"fmt"
    
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    func main() {
    	s3Client, err := minio.New("localhost:9000", &minio.Options{
    		Creds:  credentials.NewStaticV4("minioadmin", "minioadmin", ""),
    		Secure: false,
    	})
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  3. cmd/endpoint-ellipses_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"reflect"
    	"testing"
    
    	"github.com/minio/pkg/v3/ellipses"
    )
    
    // Tests create endpoints with ellipses and without.
    func TestCreateServerEndpoints(t *testing.T) {
    	testCases := []struct {
    		serverAddr string
    		args       []string
    		success    bool
    	}{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  4. cmd/erasure-server-pool-rebalance.go

    	"github.com/minio/minio/internal/bucket/versioning"
    	"github.com/minio/minio/internal/hash"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	"github.com/minio/pkg/v3/workers"
    )
    
    //go:generate msgp -file $GOFILE -unexported
    
    // rebalanceStats contains per-pool rebalance statistics like number of objects,
    // versions and bytes rebalanced out of a pool
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  5. internal/dsync/drwmutex.go

    	"errors"
    	"math/rand"
    	"slices"
    	"sort"
    	"strconv"
    	"sync"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/mcontext"
    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/env"
    )
    
    // Indicator if logging is enabled.
    var dsyncLog bool
    
    // Retry unit interval
    var lockRetryMinInterval time.Duration
    
    var lockRetryBackOff func(*rand.Rand, uint) time.Duration
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  6. cmd/endpoint.go

    	"slices"
    	"sort"
    	"strconv"
    	"strings"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/mountinfo"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    // EndpointType - enum for endpoint type.
    type EndpointType int
    
    const (
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool-decom.go

    	"github.com/minio/minio/internal/bucket/versioning"
    	"github.com/minio/minio/internal/hash"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/env"
    	"github.com/minio/pkg/v3/workers"
    )
    
    // PoolDecommissionInfo currently decommissioning information
    type PoolDecommissionInfo struct {
    	StartTime   time.Time `json:"startTime" msg:"st"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  8. cmd/object-api-utils.go

    	xhttp "github.com/minio/minio/internal/http"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/trie"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/valyala/bytebufferpool"
    )
    
    const (
    	// MinIO meta bucket.
    	minioMetaBucket = ".minio.sys"
    	// Multipart meta prefix.
    	mpartMetaPrefix = "multipart"
    	// MinIO Multipart meta prefix.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  9. internal/event/target/mysql.go

    	"github.com/go-sql-driver/mysql"
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	mysqlTableExists = `SELECT 1 FROM %s;`
    	// Some MySQL has a 3072 byte limit on key sizes.
    	mysqlCreateNamespaceTable = `CREATE TABLE %s (
                 key_name VARCHAR(3072) NOT NULL,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  10. cmd/kms-handlers.go

    	"encoding/json"
    	"net/http"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/policy"
    )
    
    // KMSStatusHandler - GET /minio/kms/v1/status
    func (a kmsAPIHandlers) KMSStatusHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "KMSStatus")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Aug 18 06:43:03 GMT 2024
    - 10.1K bytes
    - Click Count (0)
Back to Top