- Sort Score
- Result 10 results
- Languages All
Results 981 - 990 of 1,209 for strncat (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)