- Sort Score
- Result 10 results
- Languages All
Results 391 - 400 of 1,387 for funcs (0.03 sec)
-
istioctl/pkg/writer/envoy/configdump/configdump.go
} // includeConfigType is a flag to indicate whether to include the config type in the output var includeConfigType bool func SetPrintConfigTypeInSummary(p bool) { includeConfigType = p } // Prime loads the config dump into the writer ready for printing func (c *ConfigWriter) Prime(b []byte) error { w := &configdump.Wrapper{} err := w.UnmarshalJSON(b) if err != nil {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Feb 29 20:46:41 UTC 2024 - 7.4K 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/warm-backend-s3.go
core *minio.Core Bucket string Prefix string StorageClass string } func (s3 *warmBackendS3) ToObjectError(err error, params ...string) error { object := "" if len(params) >= 1 { object = params[0] } return ErrorRespToObjectError(err, s3.Bucket, s3.getDest(object)) } func (s3 *warmBackendS3) getDest(object string) string { destObj := object if s3.Prefix != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 5.7K 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) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
"strings" "github.com/IBM/sarama" "github.com/xdg/scram" "github.com/minio/minio/internal/hash/sha256" ) func initScramClient(cfg Config, config *sarama.Config) { switch strings.ToLower(cfg.SASL.Mechanism) { case "sha512": config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: KafkaSHA512} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Nov 09 04:04:01 UTC 2023 - 3.3K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump_test.go
"istio.io/istio/pkg/test/util/assert" ) func TestConfigWriter_Prime(t *testing.T) { tests := []struct { name string wantConfigs int inputFile string wantErr bool }{ { name: "errors if unable to unmarshal bytes", inputFile: "", wantConfigs: 0, wantErr: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { cw := &ConfigWriter{}
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jan 03 23:08:06 UTC 2024 - 3.5K 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) -
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) -
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)