Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 964 for stores (0.13 sec)

  1. internal/store/batch_test.go

    		if err := tearDownQueueStore(); err != nil {
    			t.Fatalf("Failed to tear down store; %v", err)
    		}
    	}()
    	store, err := setUpQueueStore(queueDir, 100)
    	if err != nil {
    		t.Fatalf("Failed to create a queue store; %v", err)
    	}
    
    	var limit uint32 = 100
    
    	batch := NewBatch[TestItem](BatchConfig[TestItem]{
    		Limit:         limit,
    		Store:         store,
    		CommitTimeout: 5 * time.Minute,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. internal/event/target/kafka.go

    	if target.store != nil {
    		if args.BatchSize > 1 {
    			target.batch = store.NewBatch[event.Event](store.BatchConfig[event.Event]{
    				Limit:         args.BatchSize,
    				Log:           loggerOnce,
    				Store:         queueStore,
    				CommitTimeout: args.BatchCommitTimeout,
    			})
    		}
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    	}
    
    	return target, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. internal/event/target/webhook.go

    	}
    	return target.isActive()
    }
    
    // Store returns any underlying store if set.
    func (target *WebhookTarget) Store() event.TargetStore {
    	return target.store
    }
    
    func (target *WebhookTarget) isActive() (bool, error) {
    	conn, err := net.DialTimeout("tcp", target.addr, 5*time.Second)
    	if err != nil {
    		if xnet.IsNetworkOrHostDown(err, false) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  4. internal/event/target/redis.go

    // Name - returns the Name of the target.
    func (target *RedisTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *RedisTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *RedisTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. internal/logger/target/http/http.go

    	queueStore := store.NewQueueStore[interface{}](
    		filepath.Join(h.config.QueueDir, h.Name()),
    		uint64(h.config.QueueSize),
    		httpLoggerExtension,
    	)
    
    	if err := queueStore.Open(); err != nil {
    		return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err)
    	}
    
    	h.store = queueStore
    	store.StreamItems(h.store, h, ctx.Done(), h.config.LogOnceIf)
    
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  6. internal/event/target/elasticsearch.go

    func (target *ElasticsearchTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *ElasticsearchTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *ElasticsearchTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  7. internal/event/target/postgresql.go

    }
    
    // Name - returns the Name of the target.
    func (target *PostgreSQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *PostgreSQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *PostgreSQLTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/RegularImmutableMap.java

       * equivalent to RegularImmutableSet, save that instead of having a hash table containing the
       * elements directly and null for empty positions, we store indices of the keys in the hash table,
       * and ABSENT for empty positions.  We then look up the keys in alternatingKeysAndValues.
       *
       * (The index actually stored is the index of the key in alternatingKeysAndValues, which is
       * double the index of the entry in entrySet.asList.)
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 15 22:32:14 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  9. internal/logger/target/kafka/kafka.go

    	queueStore := store.NewQueueStore[interface{}](queueDir, uint64(h.kconfig.QueueSize), kafkaLoggerExtension)
    	if err = queueStore.Open(); err != nil {
    		return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err)
    	}
    	ctx, cancel := context.WithCancel(ctx)
    	h.store = queueStore
    	h.storeCtxCancel = cancel
    	store.StreamItems(h.store, h, ctx.Done(), h.kconfig.LogOnce)
    	return
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  10. internal/event/target/amqp.go

    	connMutex  sync.Mutex
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    
    	quitCh chan struct{}
    }
    
    // ID - returns TargetID.
    func (target *AMQPTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *AMQPTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top