Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 514 for Uint64 (0.06 sec)

  1. internal/event/target/amqp.go

    	NoWait            bool     `json:"noWait"`
    	AutoDeleted       bool     `json:"autoDeleted"`
    	PublisherConfirms bool     `json:"publisherConfirms"`
    	QueueDir          string   `json:"queueDir"`
    	QueueLimit        uint64   `json:"queueLimit"`
    }
    
    //lint:file-ignore ST1003 We cannot change these exported names.
    
    // AMQP input constants.
    const (
    	AmqpQueueDir   = "queue_dir"
    	AmqpQueueLimit = "queue_limit"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. internal/store/queuestore_test.go

    	// Sample test item.
    	testItem = TestItem{Name: "test-item", Property: "property"}
    	// Ext for test item
    	testItemExt = ".test"
    )
    
    // Initialize the queue store.
    func setUpQueueStore(directory string, limit uint64) (Store[TestItem], error) {
    	queueStore := NewQueueStore[TestItem](queueDir, limit, testItemExt)
    	if oErr := queueStore.Open(); oErr != nil {
    		return nil, oErr
    	}
    	return queueStore, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. 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 Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Nov 28 19:15:27 UTC 2023
    - 36.3K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. internal/logger/target/http/http.go

    // buffer is full, new logs are just ignored and an error
    // is returned to the caller.
    type Target struct {
    	totalMessages  atomic.Int64
    	failedMessages atomic.Int64
    	status         atomic.Int32
    
    	// Worker control
    	workers    atomic.Int64
    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. internal/grid/types.go

    		j.val = nil
    	}
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (j *Array[T]) MarshalMsg(b []byte) (o []byte, err error) {
    	if j.val == nil {
    		return msgp.AppendNil(b), nil
    	}
    	if uint64(len(j.val)) > math.MaxUint32 {
    		return b, errors.New("array: length of array exceeds math.MaxUint32")
    	}
    	b = msgp.AppendArrayHeader(b, uint32(len(j.val)))
    	for _, v := range j.val {
    		b, err = v.MarshalMsg(b)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. internal/event/target/elasticsearch.go

    	Format     string          `json:"format"`
    	URL        xnet.URL        `json:"url"`
    	Index      string          `json:"index"`
    	QueueDir   string          `json:"queueDir"`
    	QueueLimit uint64          `json:"queueLimit"`
    	Transport  *http.Transport `json:"-"`
    	Username   string          `json:"username"`
    	Password   string          `json:"password"`
    }
    
    // Validate ElasticsearchArgs fields
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
Back to top