Search Options

Results per page
Sort
Preferred Languages
Advance

Results 981 - 990 of 1,209 for strncat (0.17 sec)

  1. internal/s3select/select_benchmark_test.go

    		csvWriter.Write([]string{
    			strconv.Itoa(i),
    			newRandString(10),
    			newRandString(5),
    			newRandString(10),
    		})
    	}
    
    	csvWriter.Flush()
    	return buf.Bytes()
    }
    
    type nullResponseWriter struct{}
    
    func (w *nullResponseWriter) Header() http.Header {
    	return nil
    }
    
    func (w *nullResponseWriter) Write(p []byte) (int, error) {
    	return len(p), nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  2. cmd/update-notifier_test.go

    import (
    	"fmt"
    	"strings"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/color"
    )
    
    // Tests update notifier string builder.
    func TestPrepareUpdateMessage(t *testing.T) {
    	testCases := []struct {
    		older time.Duration
    		dlURL string
    
    		expectedSubStr string
    	}{
    		// Testcase index 0
    		{72 * time.Hour, "my_download_url", "3 days before the latest release"},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 31 15:36:19 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  3. cmd/os-instrumented.go

    	osMetricLast
    )
    
    var globalOSMetrics osMetrics
    
    func init() {
    	// Inject metrics.
    	ioutilx.OsOpenFile = OpenFile
    	ioutilx.OpenFileDirectIO = OpenFileDirectIO
    	ioutilx.OsOpen = Open
    }
    
    type osMetrics struct {
    	// All fields must be accessed atomically and aligned.
    	operations [osMetricLast]uint64
    	latency    [osMetricLast]lockedLastMinuteLatency
    }
    
    // time an os action.
    func (o *osMetrics) time(s osMetric) func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. cmd/warm-backend-gcs.go

    	"github.com/minio/madmin-go/v3"
    	"google.golang.org/api/googleapi"
    	"google.golang.org/api/iterator"
    	"google.golang.org/api/option"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    type warmBackendGCS struct {
    	client       *storage.Client
    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (gcs *warmBackendGCS) getDest(object string) string {
    	destObj := object
    	if gcs.Prefix != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. tests/soft_delete_test.go

    		t.Fatalf("invalid sql generated, got %v", actualSQL)
    	}
    }
    
    func TestSoftDeleteZeroValue(t *testing.T) {
    	type SoftDeleteBook struct {
    		ID        uint
    		Name      string
    		Pages     uint
    		DeletedAt gorm.DeletedAt `gorm:"zeroValue:'1970-01-01 00:00:01'"`
    	}
    	DB.Migrator().DropTable(&SoftDeleteBook{})
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  6. istioctl/pkg/internaldebug/internal-debug.go

    		"Send the same request to all instances of Istiod. Only applicable for in-cluster deployment.")
    	return debugCommand
    }
    
    var internalDebugAllIstiod bool
    
    type DebugWriter struct {
    	Writer                 io.Writer
    	Namespace              string
    	InternalDebugAllIstiod bool
    }
    
    func (s *DebugWriter) PrintAll(drs map[string]*discovery.DiscoveryResponse) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 12 11:30:24 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/cluster.go

    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/config/host"
    )
    
    // ClusterFilter is used to pass filter information into cluster based config writer print functions
    type ClusterFilter struct {
    	FQDN      host.Name
    	Port      int
    	Subset    string
    	Direction model.TrafficDirection
    }
    
    // Verify returns true if the passed cluster matches the filter fields
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu May 11 05:38:17 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  8. internal/logger/target/http/http.go

    const (
    	statusOffline = iota
    	statusOnline
    	statusClosed
    )
    
    var (
    	logChBuffers = make(map[string]chan interface{})
    	logChLock    = sync.Mutex{}
    )
    
    // Config http logger target
    type Config struct {
    	Enabled     bool              `json:"enabled"`
    	Name        string            `json:"name"`
    	UserAgent   string            `json:"userAgent"`
    	Endpoint    *xnet.URL         `json:"endpoint"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. internal/ringbuffer/ring_buffer.go

    // It operates like a buffered pipe, where data written to a RingBuffer
    // and can be read back from another goroutine.
    // It is safe to concurrently read and write RingBuffer.
    type RingBuffer struct {
    	buf       []byte
    	size      int
    	r         int // next position to read
    	w         int // next position to write
    	isFull    bool
    	err       error
    	block     bool
    	mu        sync.Mutex
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. common/Makefile.common.mk

    lint-helm:
    	@${FINDFILES} -name 'Chart.yaml' -print0 | ${XARGS} -L 1 dirname | xargs -r helm lint --strict
    
    lint-copyright-banner:
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 14:37:27 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top