Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 53 for store (0.13 sec)

  1. internal/store/store.go

    	DelList(key []string) error
    	Open() error
    	Delete() error
    	Extension() string
    }
    
    // Key denotes the key present in the store.
    type Key struct {
    	Name   string
    	IsLast bool
    }
    
    // replayItems - Reads the items from the store and replays.
    func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key {
    	keyCh := make(chan Key)
    
    	go func() {
    		defer xioutil.SafeClose(keyCh)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  2. internal/event/target/nsq.go

    			return nil, fmt.Errorf("unable to initialize the queue store of NSQ `%s`: %w", id, err)
    		}
    	}
    
    	target := &NSQTarget{
    		id:         event.TargetID{ID: id, Name: "nsq"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    		quitCh:     make(chan struct{}),
    	}
    
    	if target.store != nil {
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 7.1K 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
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key.Name)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will
    // be replayed when the mqtt connection is active.
    func (target *MQTTTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		return target.store.Put(eventData)
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 8.2K bytes
    - Viewed (0)
  5. internal/event/targetlist.go

    // Target - event target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Save(Event) error
    	SendFromStore(store.Key) error
    	Close() error
    	Store() TargetStore
    }
    
    // TargetStore is a shallow version of a target.Store
    type TargetStore interface {
    	Len() int
    }
    
    // Stats is a collection of stats for multiple targets.
    type Stats struct {
    	TotalEvents        int64 // Deprecated
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  6. internal/cachevalue/cache.go

    	if err != nil {
    		if t.opts.ReturnLastGood {
    			// Keep last good value.
    			v := t.valErr.Load()
    			if v != nil {
    				val = v.v
    			}
    		}
    	}
    	t.valErr.Store(&struct {
    		v T
    		e error
    	}{v: val, e: err})
    	t.lastUpdateMs.Store(time.Now().UnixMilli())
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/healthServer.go

    	}()
    
    	return
    }
    
    func initRouter(router *http.ServeMux) (installReady *atomic.Value, watchReady *atomic.Value) {
    	installReady = &atomic.Value{}
    	watchReady = &atomic.Value{}
    	installReady.Store(false)
    	watchReady.Store(false)
    
    	router.HandleFunc(constants.LivenessEndpoint, healthz)
    	router.HandleFunc(constants.ReadinessEndpoint, readyz(installReady, watchReady))
    
    	return
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  8. internal/logger/target/testlogger/testlogger.go

    	return t.setTB(tb, fatalMessage)
    }
    
    func (t *testLogger) setTB(tb testing.TB, action int32) func() {
    	old := t.action.Swap(action)
    	t.current.Store(&tb)
    	return func() {
    		t.current.Store(nil)
    		t.action.Store(old)
    	}
    }
    
    func (t *testLogger) String() string {
    	tb := t.current.Load()
    	if tb != nil {
    		tbb := *tb
    		return tbb.Name()
    	}
    	return ""
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 4K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/server.go

    		return nil, fmt.Errorf("error starting cni server: %w", err)
    	}
    	s.cniServerStopFunc = cniServer.Stop
    
    	return s, nil
    }
    
    func (s *Server) Ready() {
    	s.isReady.Store(true)
    }
    
    func (s *Server) NotReady() {
    	s.isReady.Store(false)
    }
    
    // buildKubeClient creates the kube client
    func buildKubeClient(kubeConfig string) (kube.Client, error) {
    	// Used by validation
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  10. lib/time/mkzip.go

    			log.Fatalf("unexpected file during walk: %s", path)
    		}
    		name := filepath.ToSlash(path)
    		w, err := zw.CreateRaw(&zip.FileHeader{
    			Name:               name,
    			Method:             zip.Store,
    			CompressedSize64:   uint64(len(data)),
    			UncompressedSize64: uint64(len(data)),
    			CRC32:              crc32.ChecksumIEEE(data),
    		})
    		if err != nil {
    			log.Fatal(err)
    		}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Mar 04 17:32:07 GMT 2024
    - 2.1K bytes
    - Viewed (0)
Back to top