Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 116 of 116 for Deployed (0.08 sec)

  1. internal/event/target/mqtt.go

    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // 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 {
    		_, err := target.store.Put(eventData)
    		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)
  2. internal/event/target/mysql.go

    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the SQL connection is active.
    func (target *MySQLTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. internal/logger/target/kafka/kafka.go

    }
    
    // Send log message 'e' to kafka target.
    func (h *Target) Send(ctx context.Context, entry interface{}) error {
    	if h.store != nil {
    		// save the entry to the queue store which will be replayed to the target.
    		_, err := h.store.Put(entry)
    		return err
    	}
    	h.logChMu.RLock()
    	defer h.logChMu.RUnlock()
    	if h.logCh == nil {
    		// We are closing...
    		return nil
    	}
    
    	select {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. internal/event/target/nats.go

    				return false, store.ErrNotConnected
    			}
    			return false, connErr
    		}
    	}
    
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the Nats connection is active.
    func (target *NATSTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. internal/event/target/elasticsearch.go

    	if err != nil {
    		return false, err
    	}
    
    	return target.client.ping(ctx, target.args)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will be replayed when the elasticsearch connection is active.
    func (target *ElasticsearchTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. docs/en/docs/release-notes.md

    * Add docs for [Debugging FastAPI applications in editors](https://fastapi.tiangolo.com/tutorial/debugging/).
    
    * Clarify [Bigger Applications deployed with Docker](https://fastapi.tiangolo.com/deployment/#bigger-applications).
    
    * Fix typos in docs.
    
    * Add section about [History, Design and Future](https://fastapi.tiangolo.com/history-design-future/).
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sat Oct 26 16:51:17 UTC 2024
    - 449.4K bytes
    - Viewed (0)
Back to top