- Sort Score
- Result 10 results
- Languages All
Results 631 - 640 of 1,384 for funcs (0.02 sec)
-
internal/config/drive/drive.go
MaxTimeout time.Duration `json:"maxTimeout"` } // Update - updates the config with latest values func (c *Config) Update(new Config) error { configLk.Lock() defer configLk.Unlock() c.MaxTimeout = getMaxTimeout(new.MaxTimeout) return nil } // GetMaxTimeout - returns the per call drive operation timeout func (c *Config) GetMaxTimeout() time.Duration { return c.GetOPTimeout() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3K bytes - Viewed (0) -
src/cmd/asm/internal/flags/flags.go
// MultiFlag allows setting a value multiple times to collect a list, as in -I=dir1 -I=dir2. type MultiFlag []string func (m *MultiFlag) String() string { if len(*m) == 0 { return "" } return fmt.Sprint(*m) } func (m *MultiFlag) Set(val string) error { (*m) = append(*m, val) return nil } func Usage() { fmt.Fprintf(os.Stderr, "usage: asm [options] file.s ...\n") fmt.Fprintf(os.Stderr, "Flags:\n")
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Aug 22 19:18:23 UTC 2023 - 2.8K bytes - Viewed (0) -
istioctl/pkg/config/config.go
} // Cmd represents the config subcommand command func Cmd() *cobra.Command { configCmd := &cobra.Command{ Use: "config SUBCOMMAND", Short: "Configure istioctl defaults", Args: cobra.NoArgs, Example: ` # list configuration parameters istioctl experimental config list`, } configCmd.AddCommand(listCommand()) return configCmd } func listCommand() *cobra.Command { listCmd := &cobra.Command{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sun Jul 30 12:16:07 UTC 2023 - 3.1K bytes - Viewed (0) -
internal/config/identity/openid/providercfg.go
DiscoveryDoc DiscoveryDoc ClientID string ClientSecret string RolePolicy string roleArn arn.ARN provider provider.Provider } func newProviderCfgFromConfig(getCfgVal func(cfgName string) string) providerCfg { return providerCfg{ DisplayName: getCfgVal(DisplayName), ClaimName: getCfgVal(ClaimName),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex.go
) // IsRegisterShift reports whether the token is one of the ARM register shift operators. func IsRegisterShift(r ScanToken) bool { return ROT <= r && r <= LSH // Order looks backwards because these are negative. } func (t ScanToken) String() string { switch t { case scanner.EOF: return "EOF" case scanner.Ident: return "identifier" case scanner.Int:
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 4.1K bytes - Viewed (0) -
cmd/erasure-sets_test.go
) var testUUID = uuid.MustParse("f5c58c61-7175-4018-ab5e-a94fe9c2de4e") func BenchmarkCrcHash(b *testing.B) { cases := []struct { key int }{ {16}, {64}, {128}, {256}, {512}, {1024}, } for _, testCase := range cases { testCase := testCase key := randString(testCase.key) b.Run("", func(b *testing.B) { b.SetBytes(1024) b.ReportAllocs() b.ResetTimer()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
internal/bucket/replication/and.go
} var errDuplicateTagKey = Errorf("Duplicate Tag Keys are not allowed") // isEmpty returns true if Tags field is null func (a And) isEmpty() bool { return len(a.Tags) == 0 && a.Prefix == "" } // Validate - validates the And field func (a And) Validate() error { if a.ContainsDuplicateTag() { return errDuplicateTagKey } for _, t := range a.Tags { if err := t.Validate(); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.8K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3" v3 "istio.io/istio/pilot/pkg/xds/v3" ) // GetDynamicClusterDump retrieves a cluster dump with just dynamic active clusters in it func (w *Wrapper) GetDynamicClusterDump(stripVersions bool) (*admin.ClustersConfigDump, error) { clusterDump, err := w.GetClusterConfigDump() if err != nil { return nil, err } dac := clusterDump.GetDynamicActiveClusters()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 2.1K bytes - Viewed (0) -
clause/from.go
package clause // From from clause type From struct { Tables []Table Joins []Join } // Name from clause name func (from From) Name() string { return "FROM" } // Build build from clause func (from From) Build(builder Builder) { if len(from.Tables) > 0 { for idx, table := range from.Tables { if idx > 0 { builder.WriteByte(',') } builder.WriteQuoted(table) } } else {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jul 15 02:25:10 UTC 2020 - 630 bytes - Viewed (0) -
cmd/batch-replicate_gen.go
func (z BatchJobReplicateCredentials) Msgsize() (s int) { s = 1 + 10 + msgp.StringPrefixSize + len(z.AccessKey) + 10 + msgp.StringPrefixSize + len(z.SecretKey) + 13 + msgp.StringPrefixSize + len(z.SessionToken) return } // DecodeMsg implements msgp.Decodable func (z *BatchJobReplicateFlags) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 40.7K bytes - Viewed (0)