Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 467 for Uint64 (0.28 sec)

  1. internal/event/target/kafka.go

    	Enable             bool          `json:"enable"`
    	Brokers            []xnet.Host   `json:"brokers"`
    	Topic              string        `json:"topic"`
    	QueueDir           string        `json:"queueDir"`
    	QueueLimit         uint64        `json:"queueLimit"`
    	Version            string        `json:"version"`
    	BatchSize          uint32        `json:"batchSize"`
    	BatchCommitTimeout time.Duration `json:"batchCommitTimeout"`
    	TLS                struct {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. api/go1.4.txt

    pkg debug/plan9obj, type FileHeader struct, HdrSize uint64
    pkg debug/plan9obj, type FileHeader struct, LoadAddress uint64
    
    # CL 122960043 encoding/xml: add InputOffset method to Decoder, Russ Cox <******@****.***>
    pkg encoding/xml, method (*Decoder) InputOffset() int64
    
    # CL 124940043 cmd/go, go/build: implement import comment checking, Russ Cox <******@****.***>
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Dec 12 03:01:01 UTC 2014
    - 34K bytes
    - Viewed (0)
  3. cmd/encryption-v1_test.go

    	}
    }
    
    func TestGetDecryptedRange(t *testing.T) {
    	var (
    		pkgSz     = int64(64) * humanize.KiByte
    		minPartSz = int64(5) * humanize.MiByte
    		maxPartSz = int64(5) * humanize.GiByte
    
    		getEncSize = func(s int64) int64 {
    			v, _ := sio.EncryptedSize(uint64(s))
    			return int64(v)
    		}
    		udMap = func(isMulti bool) map[string]string {
    			m := map[string]string{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    	KeepAlive            time.Duration  `json:"keepAliveInterval"`
    	RootCAs              *x509.CertPool `json:"-"`
    	QueueDir             string         `json:"queueDir"`
    	QueueLimit           uint64         `json:"queueLimit"`
    }
    
    // Validate MQTTArgs fields
    func (m MQTTArgs) Validate() error {
    	if !m.Enable {
    		return nil
    	}
    	u, err := xnet.ParseURL(m.Broker.String())
    	if err != nil {
    		return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  7. internal/event/target/postgresql.go

    	Password           string    `json:"password"` // default: no password
    	Database           string    `json:"database"` // default: same as user
    	QueueDir           string    `json:"queueDir"`
    	QueueLimit         uint64    `json:"queueLimit"`
    	MaxOpenConnections int       `json:"maxOpenConnections"`
    }
    
    // Validate PostgreSQLArgs fields
    func (p PostgreSQLArgs) Validate() error {
    	if !p.Enable {
    		return nil
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. internal/kms/secret-key.go

    	}
    	return &KMS{
    		Type:       Builtin,
    		DefaultKey: keyID,
    		conn: secretKey{
    			keyID: keyID,
    			key:   key,
    		},
    		latencyBuckets: defaultLatencyBuckets,
    		latency:        make([]atomic.Uint64, len(defaultLatencyBuckets)),
    	}, nil
    }
    
    // secretKey is a KMS implementation that derives new DEKs
    // from a single key.
    type secretKey struct {
    	keyID string
    	key   []byte
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. cmd/iam.go

    type IAMSys struct {
    	// Need to keep them here to keep alignment - ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    	// metrics
    	LastRefreshTimeUnixNano         uint64
    	LastRefreshDurationMilliseconds uint64
    	TotalRefreshSuccesses           uint64
    	TotalRefreshFailures            uint64
    
    	sync.Mutex
    
    	iamRefreshInterval time.Duration
    
    	LDAPConfig   xldap.Config  // only valid if usersSysType is LDAPUsers
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 74.6K bytes
    - Viewed (0)
Back to top