Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 341 - 350 of 1,128 for boot (0.02 seconds)

  1. cmd/metacache-bucket.go

    func (b *bucketMetacache) deleteCache(id string) {
    	b.mu.Lock()
    	c, ok := b.caches[id]
    	if ok {
    		// Delete from root map.
    		list := b.cachesRoot[c.root]
    		for i, lid := range list {
    			if id == lid {
    				list = append(list[:i], list[i+1:]...)
    				break
    			}
    		}
    		b.cachesRoot[c.root] = list
    		delete(b.caches, id)
    		b.updated = true
    	}
    	b.mu.Unlock()
    	if ok {
    		c.delete(context.Background())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  2. cmd/peer-rest-client.go

    	resp, err := localStorageInfoRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTMetrics: strconv.FormatBool(metrics),
    	}))
    	return resp.ValueOrZero(), err
    }
    
    // ServerInfo - fetch server information for a remote node.
    func (client *peerRESTClient) ServerInfo(ctx context.Context, metrics bool) (info madmin.ServerProperties, err error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  3. cmd/bucket-lifecycle_test.go

    		}
    	}
    }
    
    // TestRestoreObjOnDisk tests restoreObjStatus' OnDisk method
    func TestRestoreObjOnDisk(t *testing.T) {
    	testCases := []struct {
    		restoreStatus restoreObjStatus
    		ondisk        bool
    	}{
    		{
    			// restore in progress
    			restoreStatus: ongoingRestoreObj(),
    			ondisk:        false,
    		},
    		{
    			// restore completed but expired
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 31 09:57:57 GMT 2022
    - 7K bytes
    - Click Count (0)
  4. cmd/admin-heal-ops.go

    	healLocalDisks map[Endpoint]bool
    	healStatus     map[string]healingTracker // Indexed by disk ID
    }
    
    // newHealState - initialize global heal state management
    func newHealState(ctx context.Context, cleanup bool) *allHealState {
    	hstate := &allHealState{
    		healSeqMap:     make(map[string]*healSequence),
    		healLocalDisks: make(map[Endpoint]bool),
    		healStatus:     make(map[string]healingTracker),
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  5. internal/s3select/sql/record.go

    	SelectFmtParquet
    )
    
    // WriteCSVOpts - encapsulates options for Select CSV output
    type WriteCSVOpts struct {
    	FieldDelimiter rune
    	Quote          rune
    	QuoteEscape    rune
    	AlwaysQuote    bool
    }
    
    // Record - is a type containing columns and their values.
    type Record interface {
    	Get(name string) (*Value, error)
    
    	// Set a value.
    	// Can return a different record type.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  6. src/cmd/api/testdata/src/pkg/p1/p1.go

    	Public     *int
    	private    *int
    	PublicTime Time
    }
    
    // Deprecated: use URI.
    type URL struct{}
    
    type EmbedURLPtr struct {
    	*URL
    }
    
    type S2 struct {
    	// Deprecated: use T.
    	S
    	Extra bool
    }
    
    var X0 int64
    
    var (
    	Y int
    	X I
    )
    
    type Namer interface {
    	Name() string
    }
    
    type I interface {
    	Namer
    	ptwo.Twoer
    	Set(name string, balance int64)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Dec 02 16:29:41 GMT 2022
    - 3.3K bytes
    - Click Count (0)
  7. .editorconfig

    root = true
    
    [*]
    indent_size = 2
    ij_continuation_indent_size = 2
    charset = utf-8
    trim_trailing_whitespace = true
    insert_final_newline = true
    
    [*.{kt, kts}]
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 185 bytes
    - Click Count (0)
  8. internal/pubsub/pubsub.go

    var GetByteBuffer = func() []byte {
    	return make([]byte, 0, 4096)
    }
    
    // Sub - subscriber entity.
    type Sub[T Maskable] struct {
    	ch     chan T
    	types  Mask
    	filter func(entry T) bool
    }
    
    // PubSub holds publishers and subscribers
    type PubSub[T Maskable, M Maskable] struct {
    	// atomics, keep at top:
    	types          uint64
    	numSubscribers int32
    	maxSubscribers int32
    
    	// not atomics:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  9. cmd/postpolicyform.go

    	}
    }
    
    // isString - Safely check if val is of type string without causing panic.
    func isString(val any) bool {
    	_, ok := val.(string)
    	return ok
    }
    
    // ContentLengthRange - policy content-length-range field.
    type contentLengthRange struct {
    	Min   int64
    	Max   int64
    	Valid bool // If content-length-range was part of policy
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 23 15:10:12 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  10. internal/event/target/postgresql.go

    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *PostgreSQLTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *PostgreSQLTarget) isActive() (bool, error) {
    	if err := target.db.Ping(); err != nil {
    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
Back to Top