Search Options

Results per page
Sort
Preferred Languages
Advance

Results 981 - 990 of 1,385 for _func (0.04 sec)

  1. cmd/handler-utils_test.go

    	"bytes"
    	"context"
    	"encoding/xml"
    	"io"
    	"net/http"
    	"net/textproto"
    	"os"
    	"reflect"
    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    // Tests validate bucket LocationConstraint.
    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. cmd/data-scanner_test.go

    	"testing"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/versioning"
    )
    
    func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) {
    	objAPI, disks, err := prepareErasure(context.Background(), 8)
    	if err != nil {
    		t.Fatalf("Failed to initialize object layer: %v", err)
    	}
    	defer removeRoots(disks)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/arch/ppc64.go

    	"cmd/internal/obj/ppc64"
    )
    
    func jumpPPC64(word string) bool {
    	switch word {
    	case "BC", "BCL", "BEQ", "BGE", "BGT", "BL", "BLE", "BLT", "BNE", "BR", "BVC", "BVS", "BDNZ", "BDZ", "CALL", "JMP":
    		return true
    	}
    	return false
    }
    
    // IsPPC64CMP reports whether the op (as defined by an ppc64.A* constant) is
    // one of the CMP instructions that require special handling.
    func IsPPC64CMP(op obj.As) bool {
    	switch op {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri May 17 21:53:50 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. callbacks/create_test.go

    package callbacks
    
    import (
    	"reflect"
    	"sync"
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/clause"
    	"gorm.io/gorm/schema"
    )
    
    var schemaCache = &sync.Map{}
    
    func TestConvertToCreateValues_DestType_Slice(t *testing.T) {
    	type user struct {
    		ID    int `gorm:"primaryKey"`
    		Name  string
    		Email string `gorm:"default:(-)"`
    		Age   int    `gorm:"default:(-)"`
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:48:42 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  5. internal/mountinfo/mountinfo_others.go

    package mountinfo
    
    // CheckCrossDevice - check if any input path has multiple sub-mounts.
    // this is a dummy function and returns nil for now.
    func CheckCrossDevice(paths []string) error {
    	return nil
    }
    
    // IsLikelyMountPoint determines if a directory is a mountpoint.
    func IsLikelyMountPoint(file string) bool {
    	return false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  6. cni/cmd/install-cni/main.go

    	"os"
    	"os/signal"
    	"syscall"
    
    	"istio.io/istio/cni/pkg/cmd"
    	"istio.io/istio/pkg/log"
    )
    
    func main() {
    	// Create context that cancels on termination signal
    	ctx, cancel := context.WithCancel(context.Background())
    	sigChan := make(chan os.Signal, 1)
    	signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM)
    	go func(sigChan chan os.Signal, cancel context.CancelFunc) {
    		sig := <-sigChan
    		log.Infof("Exit signal received: %s", sig)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  7. cmd/admin-bucket-handlers.go

    // ----------
    // Places a quota configuration on the specified bucket. The quota
    // specified in the quota configuration will be applied by default
    // to enforce total quota for the specified bucket.
    func (a adminAPIHandlers) PutBucketQuotaConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.SetBucketQuotaAdminAction)
    	if objectAPI == nil {
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. cmd/httprange_test.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 cmd
    
    import (
    	"testing"
    )
    
    func TestHTTPRequestRangeSpec(t *testing.T) {
    	resourceSize := int64(10)
    	validRangeSpecs := []struct {
    		spec                 string
    		expOffset, expLength int64
    	}{
    		{"bytes=0-", 0, 10},
    		{"bytes=1-", 1, 9},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 05 16:56:21 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. cni/pkg/install/kubeconfig.go

    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pkg/file"
    )
    
    type kubeconfig struct {
    	// The full kubeconfig
    	Full string
    	// Kubeconfig with confidential data redacted.
    	Redacted string
    }
    
    func createKubeConfig(cfg *config.InstallConfig) (kubeconfig, error) {
    	if len(cfg.K8sServiceHost) == 0 {
    		return kubeconfig{}, fmt.Errorf("KUBERNETES_SERVICE_HOST not set. Is this not running within a pod?")
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/informers.go

    	s.namespaces.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) {
    		s.queue.Add(o)
    	}))
    
    	return s
    }
    
    // GetPodIfAmbient looks up a pod. It returns:
    // * An error if the pod cannot be found
    // * nil if the pod is found, but does not have ambient enabled
    // * the pod, if it is found and ambient is enabled
    func (s *InformerHandlers) GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top