Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 1,590 for go (0.01 seconds)

  1. src/archive/tar/stat_actime2.go

    // Copyright 2012 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    //go:build darwin || freebsd || netbsd
    
    package tar
    
    import (
    	"syscall"
    	"time"
    )
    
    func statAtime(st *syscall.Stat_t) time.Time {
    	return time.Unix(st.Atimespec.Unix())
    }
    
    func statCtime(st *syscall.Stat_t) time.Time {
    	return time.Unix(st.Ctimespec.Unix())
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Oct 28 18:17:57 GMT 2021
    - 421 bytes
    - Click Count (0)
  2. internal/grid/grid_types_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package grid
    
    //go:generate msgp -unexported -file=$GOFILE -tests=false -o=grid_types_msgp_test.go
    
    type testRequest struct {
    	Num    int
    	String string
    }
    
    type testResponse struct {
    	OrgNum    int
    	OrgString string
    	Embedded  testRequest
    }
    
    func newTestRequest() *testRequest {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 1.1K bytes
    - Click Count (0)
  3. internal/logger/target/loggertypes/targettype_string.go

    // Code generated by "stringer -type=TargetType -trimprefix=Target types.go"; DO NOT EDIT.
    
    package loggertypes
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[TargetConsole-1]
    	_ = x[TargetHTTP-2]
    	_ = x[TargetKafka-3]
    }
    
    const _TargetType_name = "ConsoleHTTPKafka"
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 18 21:56:31 GMT 2025
    - 709 bytes
    - Click Count (0)
  4. src/bytes/reader.go

    // Copyright 2012 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package bytes
    
    import (
    	"errors"
    	"io"
    	"unicode/utf8"
    )
    
    // A Reader implements the [io.Reader], [io.ReaderAt], [io.WriterTo], [io.Seeker],
    // [io.ByteScanner], and [io.RuneScanner] interfaces by reading from
    // a byte slice.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jul 16 18:17:37 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  5. cmd/postpolicyform_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"encoding/base64"
    	"net/http"
    	"strings"
    	"testing"
    
    	minio "github.com/minio/minio-go/v7"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestParsePostPolicyForm(t *testing.T) {
    	testCases := []struct {
    		policy  string
    		success bool
    	}{
    		// missing expiration, will fail.
    		{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  6. src/cmd/asm/internal/arch/s390x.go

    // Copyright 2016 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // This file encapsulates some of the odd characteristics of the
    // s390x instruction set, to minimize its interaction
    // with the core of the assembler.
    
    package arch
    
    import (
    	"cmd/internal/obj/s390x"
    )
    
    func jumpS390x(word string) bool {
    	switch word {
    	case "BRC",
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Oct 17 14:55:25 GMT 2019
    - 1.2K bytes
    - Click Count (0)
  7. internal/config/identity/ldap/ldap.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package ldap
    
    import (
    	"errors"
    	"fmt"
    	"strconv"
    	"strings"
    	"time"
    
    	ldap "github.com/go-ldap/ldap/v3"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/auth"
    	xldap "github.com/minio/pkg/v3/ldap"
    )
    
    // LookupUserDN searches for the full DN and groups of a given short/login
    // username.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 01:04:53 GMT 2024
    - 12.4K bytes
    - Click Count (1)
  8. internal/init/init_darwin_amd64.go

    import (
    	"os"
    
    	"github.com/klauspost/cpuid/v2"
    )
    
    func init() {
    	// All MinIO operations must be under UTC.
    	os.Setenv("TZ", "UTC")
    
    	// Temporary workaround for
    	// https://github.com/golang/go/issues/49233
    	// Keep until upstream has been fixed.
    	cpuid.CPU.Disable(cpuid.AVX512F, cpuid.AVX512BW, cpuid.AVX512CD, cpuid.AVX512DQ,
    		cpuid.AVX512ER, cpuid.AVX512FP16, cpuid.AVX512IFMA, cpuid.AVX512PF, cpuid.AVX512VBMI,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Nov 04 23:44:38 GMT 2022
    - 1.3K bytes
    - Click Count (0)
  9. cmd/utils.go

    	"runtime/trace"
    	"slices"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/coreos/go-oidc/v3/oidc"
    	"github.com/dustin/go-humanize"
    	"github.com/felixge/fgprof"
    	"github.com/minio/madmin-go/v3"
    	xaudit "github.com/minio/madmin-go/v3/logger/audit"
    	"github.com/minio/minio-go/v7"
    	miniogopolicy "github.com/minio/minio-go/v7/pkg/policy"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/config/api"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  10. internal/bucket/bandwidth/monitor.go

    		bucketsThrottle:       make(map[BucketOptions]*bucketThrottle),
    		bucketMovingAvgTicker: time.NewTicker(2 * time.Second),
    		ctx:                   ctx,
    		NodeCount:             numNodes,
    	}
    	go m.trackEWMA()
    	return m
    }
    
    func (m *Monitor) updateMeasurement(opts BucketOptions, bytes uint64) {
    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    
    	tm, ok := m.bucketsMeasurement[opts]
    	if !ok {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top