Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 111 for containers (0.14 sec)

  1. internal/cachevalue/cache.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cachevalue
    
    import (
    	"sync"
    	"sync/atomic"
    	"time"
    )
    
    // Opts contains options for the cache.
    type Opts struct {
    	// When set to true, return the last cached value
    	// even if updating the value errors out.
    	// Returns the last good value AND the error.
    	ReturnLastGood bool
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/pod_cache.go

    		ns, err := OpenNetns(nspathInContainer)
    		if err != nil {
    			err = fmt.Errorf("failed to open netns: %w. Make sure that the netns host path %s is mounted in under %s in the container", err, nspath, hostMountsPath)
    			log.Error(err.Error())
    		}
    		return ns, err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/delmarker-expiration.go

    type DelMarkerExpiration struct {
    	XMLName xml.Name `xml:"DelMarkerExpiration"`
    	Days    int      `xml:"Days,omitempty"`
    }
    
    // Empty returns if a DelMarkerExpiration XML element is empty.
    // Used to detect if lifecycle.Rule contained a DelMarkerExpiration element.
    func (de DelMarkerExpiration) Empty() bool {
    	return de.Days == 0
    }
    
    // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  4. internal/config/identity/ldap/config.go

    	defaultLDAPExpiry = time.Hour * 1
    
    	minLDAPExpiry time.Duration = 15 * time.Minute
    	maxLDAPExpiry time.Duration = 365 * 24 * time.Hour
    )
    
    // Config contains AD/LDAP server connectivity information.
    type Config struct {
    	LDAP ldap.Config
    
    	stsExpiryDuration time.Duration // contains converted value
    }
    
    // Enabled returns if LDAP is enabled.
    func (l *Config) Enabled() bool {
    	return l.LDAP.Enabled
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 7.9K bytes
    - Viewed (2)
  5. cmd/consolelogger.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"container/ring"
    	"context"
    	"io"
    	"sync"
    	"sync/atomic"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/logger/target/console"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  6. istioctl/pkg/workload/workload_test.go

    	"root-cert.pem": true,
    	"cluster.env":   true,
    }
    
    const goldenSuffix = ".golden"
    
    // TestWorkloadEntryConfigure enumerates test cases based on subdirectories of testdata/vmconfig.
    // Each subdirectory contains two input files: workloadgroup.yaml and meshconfig.yaml that are used
    // to generate golden outputs from the VM command.
    func TestWorkloadEntryConfigure(t *testing.T) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Mar 27 16:59:05 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  7. src/bytes/example_test.go

    		// Found it!
    	}
    }
    
    func ExampleContains() {
    	fmt.Println(bytes.Contains([]byte("seafood"), []byte("foo")))
    	fmt.Println(bytes.Contains([]byte("seafood"), []byte("bar")))
    	fmt.Println(bytes.Contains([]byte("seafood"), []byte("")))
    	fmt.Println(bytes.Contains([]byte(""), []byte("")))
    	// Output:
    	// true
    	// false
    	// true
    	// true
    }
    
    func ExampleContainsAny() {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Mar 04 15:54:40 GMT 2024
    - 15K bytes
    - Viewed (1)
  8. cmd/metacache-entries.go

    		for _, o := range m.o {
    			ext := strings.TrimPrefix(o.name, prefix)
    			if len(ext) != len(o.name) {
    				if !strings.Contains(ext, separator) {
    					dst = append(dst, o)
    				}
    			}
    		}
    	} else {
    		// No prefix, simpler
    		for _, o := range m.o {
    			if !strings.Contains(o.name, separator) {
    				dst = append(dst, o)
    			}
    		}
    	}
    	m.o = dst
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  9. chainable_api.go

    //
    //	// Get a user
    //	db.Table("users").Take(&result)
    func (db *DB) Table(name string, args ...interface{}) (tx *DB) {
    	tx = db.getInstance()
    	if strings.Contains(name, " ") || strings.Contains(name, "`") || len(args) > 0 {
    		tx.Statement.TableExpr = &clause.Expr{SQL: name, Vars: args}
    		if results := tableRegexp.FindStringSubmatch(name); len(results) == 3 {
    			if results[1] != "" {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Wed Apr 17 03:38:55 GMT 2024
    - 14.3K bytes
    - Viewed (1)
  10. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    	w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0)
    	fmt.Fprintln(w, "CERTIFICATE NAME\tTYPE\tSTATUS\tVALID CERT\tSERIAL NUMBER\tNOT AFTER\tNOT BEFORE")
    
    	for _, secret := range secretDump {
    		if strings.Contains(secret.State, "Unavailable") {
    			secret.State = "Unavailable"
    		}
    		if len(secret.CertChain) == 0 {
    			fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\n",
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 25 16:38:16 GMT 2024
    - 3.2K bytes
    - Viewed (0)
Back to top