Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for eclipse (0.26 sec)

  1. internal/event/target/mqtt.go

    package target
    
    import (
    	"crypto/tls"
    	"crypto/x509"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"net/url"
    	"os"
    	"path/filepath"
    	"time"
    
    	mqtt "github.com/eclipse/paho.mqtt.golang"
    	"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/v2/net"
    )
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 8.2K bytes
    - Viewed (0)
  2. cmd/common-main.go

    		for _, endpoint := range strings.Split(env.Get(kms.EnvKESEndpoint, ""), ",") {
    			if strings.TrimSpace(endpoint) == "" {
    				continue
    			}
    			if !ellipses.HasEllipses(endpoint) {
    				endpoints = append(endpoints, endpoint)
    				continue
    			}
    			patterns, err := ellipses.FindEllipsesPatterns(endpoint)
    			if err != nil {
    				logger.Fatal(err, fmt.Sprintf("Invalid KES endpoint %q", endpoint))
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 35.5K bytes
    - Viewed (2)
  3. docs/debugging/reorder-disks/main.go

    package main
    
    import (
    	"bufio"
    	"encoding/json"
    	"errors"
    	"flag"
    	"fmt"
    	"log"
    	"net/url"
    	"os"
    	"path/filepath"
    	"strings"
    	"syscall"
    
    	"github.com/minio/pkg/v2/ellipses"
    )
    
    type xl struct {
    	This string     `json:"this"`
    	Sets [][]string `json:"sets"`
    }
    
    type format struct {
    	ID string `json:"id"`
    	XL xl     `json:"xl"`
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  4. cmd/endpoint-ellipses.go

    	"github.com/minio/minio/internal/config"
    	"github.com/minio/pkg/v2/ellipses"
    	"github.com/minio/pkg/v2/env"
    )
    
    // This file implements and supports ellipses pattern for
    // `minio server` command line arguments.
    
    // Endpoint set represents parsed ellipses values, also provides
    // methods to get the sets of endpoints.
    type endpointSet struct {
    	argPatterns []ellipses.ArgPattern
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 21:22:47 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  5. cmd/endpoint-ellipses_test.go

    			"{1...27}",
    			endpointSet{
    				[]ellipses.ArgPattern{
    					[]ellipses.Pattern{
    						{
    							Prefix: "",
    							Suffix: "",
    							Seq:    getSequences(1, 27, 0),
    						},
    					},
    				},
    				nil,
    				[][]uint64{{9, 9, 9}},
    			},
    			true,
    		},
    		{
    			"/export/set{1...64}",
    			endpointSet{
    				[]ellipses.ArgPattern{
    					[]ellipses.Pattern{
    						{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Dec 07 09:33:56 GMT 2023
    - 15.2K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    			// No ellipses pattern. Anonymize host name from every pool arg
    			pools := strings.Fields(poolsArgs)
    			anonPools = make([]string, len(pools))
    			for index, arg := range pools {
    				anonPools[index] = anonAddr(arg)
    			}
    			return cmdLineWithoutPools + strings.Join(anonPools, " ")
    		}
    
    		// Ellipses pattern in pool args. Regex groups:
    		// 1 - server prefix
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  7. cmd/admin-handlers-pools.go

    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.DecommissionAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	// Legacy args style such as non-ellipses style is not supported with this API.
    	if globalEndpoints.Legacy() {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	z, ok := objectAPI.(*erasureServerPools)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  8. cmd/endpoint.go

    		DiskIdx: -1,
    	}, nil
    }
    
    // PoolEndpoints represent endpoints in a given pool
    // along with its setCount and setDriveCount.
    type PoolEndpoints struct {
    	// indicates if endpoints are provided in non-ellipses style
    	Legacy       bool
    	SetCount     int
    	DrivesPerSet int
    	Endpoints    Endpoints
    	CmdLine      string
    	Platform     string
    }
    
    // EndpointServerPools - list of list of endpoints
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
Back to top