Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 467 for Uint64 (0.09 sec)

  1. internal/logger/target/kafka/kafka.go

    	// Custom logger
    	LogOnce func(ctx context.Context, err error, id string, errKind ...interface{}) `json:"-"`
    }
    
    // Target - Kafka target.
    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. cmd/xl-storage.go

    	return dataUsageInfo, nil
    }
    
    func (s *xlStorage) getDeleteAttribute() uint64 {
    	attr := "user.total_deletes"
    	buf, err := xattr.LGet(s.formatFile, attr)
    	if err != nil {
    		// We start off with '0' if we can read the attributes
    		return 0
    	}
    	return binary.LittleEndian.Uint64(buf[:8])
    }
    
    func (s *xlStorage) getWriteAttribute() uint64 {
    	attr := "user.total_writes"
    	buf, err := xattr.LGet(s.formatFile, attr)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (2)
  3. cmd/object-api-datatypes.go

    	// Name of the object.
    	Name string
    
    	// Date and time when the object was last modified.
    	ModTime time.Time
    
    	// Total object size.
    	Size int64
    
    	// Actual size is the real size of the object uploaded by client.
    	ActualSize *int64
    
    	// IsDir indicates if the object is prefix.
    	IsDir bool
    
    	// Hex encoded unique entity tag of the object.
    	ETag string
    
    	// Version ID of this object.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    		atomic.AddUint64(&p.stats.mrfStats.TotalDroppedBytes, uint64(entry.sz))
    		return
    	}
    
    	select {
    	case <-GlobalContext.Done():
    		return
    	case <-p.mrfStopCh:
    		return
    	default:
    		select {
    		case p.mrfSaveCh <- entry:
    		default:
    			atomic.AddUint64(&p.stats.mrfStats.TotalDroppedCount, 1)
    			atomic.AddUint64(&p.stats.mrfStats.TotalDroppedBytes, uint64(entry.sz))
    		}
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  5. internal/event/target/nats.go

    	CertAuthority   string    `json:"certAuthority"`
    	ClientCert      string    `json:"clientCert"`
    	ClientKey       string    `json:"clientKey"`
    	PingInterval    int64     `json:"pingInterval"`
    	QueueDir        string    `json:"queueDir"`
    	QueueLimit      uint64    `json:"queueLimit"`
    	JetStream       struct {
    		Enable bool `json:"enable"`
    	} `json:"jetStream"`
    	Streaming struct {
    		Enable             bool   `json:"enable"`
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. doc/asm.html

    to lay down explicit data into the instruction stream within a <code>TEXT</code>.
    Here's how the 386 runtime defines the 64-bit atomic load function.
    </p>
    
    <pre>
    // uint64 atomicload64(uint64 volatile* addr);
    // so actually
    // void atomicload64(uint64 *res, uint64 volatile *addr);
    TEXT runtime·atomicload64(SB), NOSPLIT, $0-12
    	MOVL	ptr+0(FP), AX
    	TESTL	$7, AX
    	JZ	2(PC)
    	MOVL	0, AX // crash with nil ptr deref
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Nov 28 19:15:27 UTC 2023
    - 36.3K bytes
    - Viewed (1)
  7. cmd/erasure.go

    				di.HealInfo = &hd
    			}
    			di.Metrics = &madmin.DiskMetrics{
    				LastMinute:              make(map[string]madmin.TimedAction, len(info.Metrics.LastMinute)),
    				APICalls:                make(map[string]uint64, len(info.Metrics.APICalls)),
    				TotalErrorsAvailability: info.Metrics.TotalErrorsAvailability,
    				TotalErrorsTimeout:      info.Metrics.TotalErrorsTimeout,
    				TotalWaiting:            info.Metrics.TotalWaiting,
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  8. cmd/bucket-replication-utils.go

    	// Completed size in bytes
    	ReplicatedSize int64 `json:"completedReplicationSize"`
    	// Failed size in bytes
    	FailedSize int64 `json:"failedReplicationSize"`
    	// Total number of failed operations
    	FailedCount int64 `json:"failedReplicationCount"`
    	// Total number of failed operations
    	ReplicatedCount int64 `json:"replicationCount"`
    	// Last bucket/object replicated.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  9. internal/event/target/mysql.go

    	User               string   `json:"user"`
    	Password           string   `json:"password"`
    	Database           string   `json:"database"`
    	QueueDir           string   `json:"queueDir"`
    	QueueLimit         uint64   `json:"queueLimit"`
    	MaxOpenConnections int      `json:"maxOpenConnections"`
    }
    
    // Validate MySQLArgs fields
    func (m MySQLArgs) Validate() error {
    	if !m.Enable {
    		return nil
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. cmd/admin-handlers-site-replication.go

    	globalSiteNetPerfRX.Connect()
    	defer globalSiteNetPerfRX.Disconnect()
    
    	connectTime := time.Now()
    	for {
    		n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte)
    		atomic.AddUint64(&globalSiteNetPerfRX.RX, uint64(n))
    		if err != nil && err != io.EOF && err != io.ErrUnexpectedEOF {
    			// If there is a disconnection before globalNetPerfMinDuration (we give a margin of error of 1 sec)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top