Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 935 for struct (0.04 seconds)

  1. internal/logger/target/kafka/kafka.go

    const (
    	statusClosed = iota
    	statusOffline
    	statusOnline
    )
    
    // Config - kafka target arguments.
    type Config struct {
    	Enabled bool        `json:"enable"`
    	Brokers []xnet.Host `json:"brokers"`
    	Topic   string      `json:"topic"`
    	Version string      `json:"version"`
    	TLS     struct {
    		Enable        bool               `json:"enable"`
    		RootCAs       *x509.CertPool     `json:"-"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  2. cmd/xl-storage_unix_test.go

    	mask := syscall.Umask(0)
    	syscall.Umask(mask)
    	return mask
    }
    
    // Tests if the directory and file creations happen with proper umask.
    func TestIsValidUmaskVol(t *testing.T) {
    	tmpPath := t.TempDir()
    	testCases := []struct {
    		volName       string
    		expectedUmask int
    	}{
    		{"is-this-valid", getUmask()},
    	}
    	testCase := testCases[0]
    
    	// Initialize a new xlStorage layer.
    	disk, err := newLocalXLStorage(tmpPath)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  3. internal/s3select/json/reader.go

    // https://docs.aws.amazon.com/AmazonS3/latest/userguide/selecting-content-from-objects.html
    const maxDocumentSize = 10 << 20
    
    // Reader - JSON record reader for S3Select.
    type Reader struct {
    	args       *ReaderArgs
    	decoder    *jstream.Decoder
    	valueCh    chan *jstream.MetaValue
    	readCloser io.ReadCloser
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  4. clause/association.go

    	OpUpdate                          // Update association records
    	OpCreate                          // Create association records with assignments
    )
    
    // Association represents an association operation
    type Association struct {
    	Association string            // Association name
    	Type        AssociationOpType // Operation type
    	Conditions  []Expression      // Filter conditions
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 12 05:42:26 GMT 2025
    - 1.2K bytes
    - Click Count (0)
  5. utils/utils_unix_test.go

    //go:build unix
    // +build unix
    
    package utils
    
    import (
    	"testing"
    )
    
    func TestSourceDir(t *testing.T) {
    	cases := []struct {
    		file string
    		want string
    	}{
    		{
    			file: "/Users/name/go/pkg/mod/gorm.io/gorm@v1.2.3/utils/utils.go",
    			want: "/Users/name/go/pkg/mod/gorm.io/",
    		},
    		{
    			file: "/go/work/proj/gorm/utils/utils.go",
    			want: "/go/work/proj/gorm/",
    		},
    		{
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Nov 21 02:48:13 GMT 2022
    - 731 bytes
    - Click Count (0)
  6. internal/bucket/bandwidth/monitor_test.go

    package bandwidth
    
    import (
    	"reflect"
    	"testing"
    	"time"
    )
    
    const (
    	oneMiB uint64 = 1024 * 1024
    )
    
    func TestMonitor_GetReport(t *testing.T) {
    	type fields struct {
    		activeBuckets map[BucketOptions]*bucketMeasurement
    		endTime       time.Time
    		update2       uint64
    		endTime2      time.Time
    	}
    	start := time.Now()
    	m0 := newBucketMeasurement(start)
    	m0.incrementBytes(0)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  7. cmd/admin-handlers.go

    	disks := strings.Split(r.Form.Get("disks"), ",")
    	byDisk := strings.EqualFold(r.Form.Get("by-disk"), "true")
    	var diskMap map[string]struct{}
    	if len(disks) > 0 && disks[0] != "" {
    		diskMap = make(map[string]struct{}, len(disks))
    		for _, k := range disks {
    			if k != "" {
    				diskMap[k] = struct{}{}
    			}
    		}
    	}
    	jobID := r.Form.Get("by-jobID")
    
    	hosts := strings.Split(r.Form.Get("hosts"), ",")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  8. cmd/stserrorcode_string.go

    package cmd
    
    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[ErrSTSNone-0]
    	_ = x[ErrSTSAccessDenied-1]
    	_ = x[ErrSTSMissingParameter-2]
    	_ = x[ErrSTSInvalidParameterValue-3]
    	_ = x[ErrSTSWebIdentityExpiredToken-4]
    	_ = x[ErrSTSClientGrantsExpiredToken-5]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Feb 05 00:29:41 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  9. cmd/admin-handlers_test.go

    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/mux"
    )
    
    // adminErasureTestBed - encapsulates subsystems that need to be setup for
    // admin-handler unit tests.
    type adminErasureTestBed struct {
    	erasureDirs []string
    	objLayer    ObjectLayer
    	router      *mux.Router
    	done        context.CancelFunc
    }
    
    // prepareAdminErasureTestBed - helper function that setups a single-node
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (1)
  10. finisher_api.go

    		if _, ok := tx.Statement.Clauses["ON CONFLICT"]; !ok {
    			tx = tx.Clauses(clause.OnConflict{UpdateAll: true})
    		}
    		tx = tx.callbacks.Create().Execute(tx.Set("gorm:update_track_time", true))
    	case reflect.Struct:
    		if err := tx.Statement.Parse(value); err == nil && tx.Statement.Schema != nil {
    			for _, pf := range tx.Statement.Schema.PrimaryFields {
    				if _, isZero := pf.ValueOf(tx.Statement.Context, reflectValue); isZero {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 19 01:49:06 GMT 2025
    - 22.9K bytes
    - Click Count (0)
Back to Top