- Sort Score
- Result 10 results
- Languages All
Results 381 - 390 of 1,425 for Func (0.03 sec)
-
cmd/metrics-resource.go
} // Describe sends the super-set of all possible descriptors of metrics func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 23:30:33 UTC 2024 - 17.2K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
currentPodSnapshot *podNetnsCache podIptables *iptables.IptablesConfigurator podNs PodNetnsFinder // allow overriding for tests netnsRunner func(fdable NetnsFd, toRun func() error) error } var _ MeshDataplane = &NetServer{} func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache, podIptables *iptables.IptablesConfigurator, podNs PodNetnsFinder) *NetServer { return &NetServer{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
clause/on_conflict.go
Columns []Column Where Where TargetWhere Where OnConstraint string DoNothing bool DoUpdates Set UpdateAll bool } func (OnConflict) Name() string { return "ON CONFLICT" } // Build build onConflict clause func (onConflict OnConflict) Build(builder Builder) { if onConflict.OnConstraint != "" { builder.WriteString("ON CONSTRAINT ") builder.WriteString(onConflict.OnConstraint)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Fri Oct 07 05:46:20 UTC 2022 - 1.3K bytes - Viewed (0) -
cmd/batch-rotate_gen.go
// Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z BatchJobKeyRotateEncryption) Msgsize() (s int) { s = 1 + 5 + msgp.StringPrefixSize + len(string(z.Type)) + 4 + msgp.StringPrefixSize + len(z.Key) + 8 + msgp.StringPrefixSize + len(z.Context) return } // DecodeMsg implements msgp.Decodable func (z *BatchJobKeyRotateFlags) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 02 10:51:33 UTC 2023 - 27.1K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
if toComplete == "" || strings.HasPrefix(pod.Name, toComplete) { podsName = append(podsName, pod.Name) } } return podsName, nil } func ValidPodsNameArgs(ctx cli.Context) func(_ *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) { return func(_ *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) { if len(args) != 0 { return nil, cobra.ShellCompDirectiveNoFileComp
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 4.9K bytes - Viewed (0) -
internal/event/config.go
type FilterRule struct { Name string `xml:"Name"` Value string `xml:"Value"` } func (filter FilterRule) isEmpty() bool { return filter.Name == "" && filter.Value == "" } // MarshalXML implements a custom marshaller to support `omitempty` feature. func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error { if filter.isEmpty() { return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 16 17:28:29 UTC 2021 - 8.4K bytes - Viewed (0) -
api/go1.19.txt
pkg go/doc, func Synopsis //deprecated #51082 pkg go/doc, func ToHTML //deprecated #51082 pkg go/doc, func ToText //deprecated #51082 pkg io/ioutil, func NopCloser //deprecated #42026 pkg io/ioutil, func ReadAll //deprecated #42026 pkg io/ioutil, func ReadDir //deprecated #42026 pkg io/ioutil, func ReadFile //deprecated #42026 pkg io/ioutil, func TempDir //deprecated #42026
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 17.9K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
var _ pflag.Value = (*RemoteSecretAuthType)(nil) func (at *RemoteSecretAuthType) String() string { return string(*at) } func (at *RemoteSecretAuthType) Type() string { return "RemoteSecretAuthType" } func (at *RemoteSecretAuthType) Set(in string) error { *at = RemoteSecretAuthType(in) return nil } func (at *SecretType) String() string { return string(*at) } func (at *SecretType) Type() string { return "SecretType" }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 15 16:31:46 UTC 2024 - 23.3K bytes - Viewed (0) -
internal/bucket/lifecycle/and.go
Tags []Tag `xml:"Tag,omitempty"` } // isEmpty returns true if Tags field is null func (a And) isEmpty() bool { return len(a.Tags) == 0 && !a.Prefix.set && a.ObjectSizeGreaterThan == 0 && a.ObjectSizeLessThan == 0 } // Validate - validates the And field func (a And) Validate() error { // > This is used in a Lifecycle Rule Filter to apply a logical AND to two or more predicates.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/bucket/lifecycle/filter_test.go
t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) { var filter Filter err := xml.Unmarshal([]byte(tc.inputXML), &filter) if err != nil { t.Fatalf("%d: Expected no error but got %v", i+1, err) } err = filter.Validate() if err != tc.expectedErr { t.Fatalf("%d: Expected %v but got %v", i+1, tc.expectedErr, err) } }) } } func TestObjectSizeFilters(t *testing.T) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 27 00:01:20 UTC 2024 - 7.2K bytes - Viewed (0)