Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1001 - 1010 of 2,444 for ErrorS (0.06 sec)

  1. internal/bucket/lifecycle/delmarker-expiration.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lifecycle
    
    import (
    	"encoding/xml"
    	"time"
    )
    
    var errInvalidDaysDelMarkerExpiration = Errorf("Days must be a positive integer with DelMarkerExpiration")
    
    // DelMarkerExpiration used to xml encode/decode ILM action by the same name
    type DelMarkerExpiration struct {
    	XMLName xml.Name `xml:"DelMarkerExpiration"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. internal/bucket/replication/filter.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package replication
    
    import (
    	"encoding/xml"
    
    	"github.com/minio/minio-go/v7/pkg/tags"
    )
    
    var errInvalidFilter = Errorf("Filter must have exactly one of Prefix, Tag, or And specified")
    
    // Filter - a filter for a replication configuration Rule.
    type Filter struct {
    	XMLName xml.Name `xml:"Filter" json:"Filter"`
    	Prefix  string
    	And     And
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 28 18:25:46 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/ztunnel/configdump/workload.go

    	zDump := c.ztunnelDump
    	filteredWorkloads := []*ZtunnelWorkload{}
    	for _, workload := range zDump.Workloads {
    		if filter.Verify(workload) {
    			filteredWorkloads = append(filteredWorkloads, workload)
    		}
    	}
    	out, err := json.MarshalIndent(filteredWorkloads, "", "    ")
    	if err != nil {
    		return fmt.Errorf("failed to marshal workloads: %v", err)
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 24 09:07:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. internal/config/certs_test.go

    			t.Setenv(EnvCertPassword, testCase.password)
    		}
    		_, err = LoadX509KeyPair(certificate, privateKey)
    		if err != nil && !testCase.shouldFail {
    			t.Errorf("Test %d: test should succeed but it failed: %v", i, err)
    		}
    		if err == nil && testCase.shouldFail {
    			t.Errorf("Test %d: test should fail but it succeed", i)
    		}
    		os.Remove(privateKey)
    		os.Remove(certificate)
    	}
    }
    
    var loadX509KeyPairTests = []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 21.6K bytes
    - Viewed (0)
  5. internal/bucket/lifecycle/and.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lifecycle
    
    import (
    	"encoding/xml"
    )
    
    var errDuplicateTagKey = Errorf("Duplicate Tag Keys are not allowed")
    
    // And - a tag to combine a prefix and multiple tags for lifecycle configuration rule.
    type And struct {
    	XMLName               xml.Name `xml:"And"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. schema/relationship.go

    	}
    
    	if relation.Polymorphic.PolymorphicType == nil {
    		schema.err = fmt.Errorf("invalid polymorphic type %v for %v on field %s, missing field %s",
    			relation.FieldSchema, schema, field.Name, polymorphic+"Type")
    	}
    
    	if relation.Polymorphic.PolymorphicID == nil {
    		schema.err = fmt.Errorf("invalid polymorphic type %v for %v on field %s, missing field %s",
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 03:46:59 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  7. internal/event/target/nsq_test.go

    			n := NSQArgs{
    				Enable:      tt.fields.Enable,
    				NSQDAddress: tt.fields.NSQDAddress,
    				Topic:       tt.fields.Topic,
    			}
    			if err := n.Validate(); (err != nil) != tt.wantErr {
    				t.Errorf("NSQArgs.Validate() error = %v, wantErr %v", err, tt.wantErr)
    			}
    		})
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  8. internal/lock/lock_test.go

    	if err != nil {
    		t.Errorf("err = %v, want %v", err, nil)
    	}
    
    	// blocking on locked file
    	locked := make(chan struct{}, 1)
    	go func() {
    		bl, blerr := LockedOpenFile(f.Name(), os.O_WRONLY, 0o600)
    		if blerr != nil {
    			t.Error(blerr)
    			return
    		}
    		locked <- struct{}{}
    		if blerr = bl.Close(); blerr != nil {
    			t.Error(blerr)
    			return
    		}
    	}()
    
    	select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  9. cni/pkg/plugin/kubernetes.go

    }
    
    // newK8sClient returns a Kubernetes client
    func newK8sClient(conf Config) (kubernetes.Interface, error) {
    	// Some config can be passed in a kubeconfig file
    	kubeconfig := filepath.Join(conf.CNIAgentRunDir, constants.CNIPluginKubeconfName)
    
    	config, err := kube.DefaultRestConfig(kubeconfig, "")
    	if err != nil {
    		log.Errorf("Failed setting up kubernetes client with kubeconfig %s", kubeconfig)
    		return nil, err
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  10. istioctl/pkg/authz/analyzer.go

    }
    
    // NewAnalyzer creates a new analyzer for a given pod based on its envoy config.
    func NewAnalyzer(envoyConfig *configdump.Wrapper) (*Analyzer, error) {
    	listeners, err := envoyConfig.GetDynamicListenerDump(true)
    	if err != nil {
    		return nil, fmt.Errorf("failed to get dynamic listener dump: %s", err)
    	}
    
    	return &Analyzer{listenerDump: listeners}, nil
    }
    
    // Print print the analysis results.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 13 01:59:17 UTC 2022
    - 2.1K bytes
    - Viewed (0)
Back to top