Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getAaa (0.19 sec)

  1. internal/logger/target/http/http.go

    	}
    
    	return h, nil
    }
    
    // SendFromStore - reads the log from store and sends it to webhook.
    func (h *Target) SendFromStore(key store.Key) (err error) {
    	var eventData []byte
    	eventData, err = h.store.GetRaw(key.Name)
    	if err != nil {
    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    	if err := h.send(context.Background(), eventData, h.payloadType, webhookCallTimeout); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  2. internal/store/queuestore.go

    	}
    	// Generate a new UUID for the key.
    	key, err := uuid.NewRandom()
    	if err != nil {
    		return err
    	}
    	return store.write(key.String(), item)
    }
    
    // GetRaw - gets an item from the store.
    func (store *QueueStore[I]) GetRaw(key string) (raw []byte, err error) {
    	store.RLock()
    
    	defer func(store *QueueStore[I]) {
    		store.RUnlock()
    		if err != nil {
    			// Upon error we remove the entry.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  3. internal/store/store.go

    	Name() string
    	SendFromStore(key Key) error
    }
    
    // Store - Used to persist items.
    type Store[I any] interface {
    	Put(item I) error
    	PutMultiple(item []I) error
    	Get(key string) (I, error)
    	GetRaw(key string) ([]byte, error)
    	Len() int
    	List() ([]string, error)
    	Del(key string) error
    	DelList(key []string) error
    	Open() error
    	Delete() error
    	Extension() string
    }
    
    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)
Back to top