Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 1,387 for funcs (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top