- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for Schile (0.15 sec)
-
internal/config/lambda/event/targetlist.go
// any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
internal/logger/targets.go
var ( // systemTargets is the set of enabled loggers. // Must be immutable at all times. // Can be swapped to another while holding swapMu systemTargets = []Target{} swapSystemMuRW sync.RWMutex // auditTargets is the list of enabled audit loggers // Must be immutable at all times. // Can be swapped to another while holding swapMu auditTargets = []Target{} swapAuditMuRW sync.RWMutex
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/api-utils.go
return false } switch c { case '-', '_', '.', '/', '*': return false } return true } // s3URLEncode is based on Golang's url.QueryEscape() code, // while considering some S3 exceptions: // - Avoid encoding '/' and '*' // - Force encoding of '~' func s3URLEncode(s string) string { spaceCount, hexCount := 0, 0 for i := 0; i < len(s); i++ { c := s[i]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/config/api/help.go
Optional: true, Type: "csv", }, config.HelpKV{ Key: apiRemoteTransportDeadline, Description: `set the deadline for API requests on remote transports while proxying between federated instances e.g. "2h"` + defaultHelpPostfix(apiRemoteTransportDeadline), Optional: true, Type: "duration", }, config.HelpKV{ Key: apiListQuorum,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 15 01:07:19 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/config/etcd/etcd.go
"github.com/minio/pkg/v2/env" xnet "github.com/minio/pkg/v2/net" clientv3 "go.etcd.io/etcd/client/v3" "go.etcd.io/etcd/client/v3/namespace" "go.uber.org/zap" ) const ( // Default values used while communicating with etcd. defaultDialTimeout = 5 * time.Second defaultDialKeepAlive = 30 * time.Second ) // etcd environment values const ( Endpoints = "endpoints" PathPrefix = "path_prefix"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/disk/stat_linux.go
stats, err := readStat(statsFile) if err != nil { return IOStats{}, err } if len(stats) < 11 { return IOStats{}, fmt.Errorf("found invalid format while reading %v", statsFile) } // refer https://www.kernel.org/doc/Documentation/block/stat.txt iostats = IOStats{ ReadIOs: stats[0], ReadMerges: stats[1], ReadSectors: stats[2],
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
istioctl/cmd/root_test.go
} _ = parent.PersistentFlags().String(childFlag2, "", childFlag2) parent.AddCommand(child) // verify both parent flags and the child flag are visible by default parent.SetArgs([]string{"child", "--help"}) if err := parent.Execute(); err != nil { t.Fatal(err) } got := out.String() out.Reset() checkHelpForFlag(t, got, parentFlag0, true) checkHelpForFlag(t, got, parentFlag1, true)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 15 17:59:55 GMT 2021 - 2.4K bytes - Viewed (0) -
tests/tests_test.go
} return } func RunMigrations() { var err error allModels := []interface{}{&User{}, &Account{}, &Pet{}, &Company{}, &Toy{}, &Language{}, &Coupon{}, &CouponProduct{}, &Order{}, &Parent{}, &Child{}, &Tools{}} rand.Seed(time.Now().UnixNano()) rand.Shuffle(len(allModels), func(i, j int) { allModels[i], allModels[j] = allModels[j], allModels[i] }) DB.Migrator().DropTable("user_friends", "user_speaks")
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Dec 15 08:36:08 GMT 2023 - 3.3K bytes - Viewed (1) -
internal/s3select/simdj/reader.go
return &Reader{ args: args, decoded: ch, err: err, readCloser: nil, } } // safeCloser will wrap a Reader as a ReadCloser. // It is safe to call Close while the reader is being used. type safeCloser struct { closed uint32 r io.Reader } func (s *safeCloser) Read(p []byte) (n int, err error) { if atomic.LoadUint32(&s.closed) == 1 { return 0, io.EOF
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
internal/s3select/json/reader.go
return &Reader{ args: args, decoder: d, valueCh: d.Stream(), readCloser: readCloser, } } // syncReadCloser will wrap a readcloser and make it safe to call Close while // reads are running. type syncReadCloser struct { rc io.ReadCloser mu sync.Mutex } func (pr *syncReadCloser) Read(p []byte) (n int, err error) { // This ensures that Close will block until Read has completed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0)