Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 272 for eventbus (0.17 sec)

  1. internal/event/target/amqp.go

    		confirmed := <-confirms
    		if !confirmed.Ack {
    			return fmt.Errorf("failed delivery of delivery tag: %d", confirmed.DeliveryTag)
    		}
    	}
    
    	return nil
    }
    
    // Save - saves the events to the store which will be replayed when the amqp connection is active.
    func (target *AMQPTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. .github/workflows/codeql-analysis.yml

    permissions: {}
    
    jobs:
      CodeQL-Build:
        permissions:
          actions: read  # for github/codeql-action/init to get workflow details
          contents: read  # for actions/checkout to fetch code
          security-events: write  # for github/codeql-action/analyze to upload SARIF results
        runs-on: ubuntu-latest
    
        strategy:
          fail-fast: false
          matrix:
            # Override automatic language detection by changing the below list
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Oct 11 18:32:33 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. internal/logger/target/testlogger/testlogger.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    // Package testlogger contains an autoregistering logger that can be used to capture logging events
    // for individual tests.
    // This package should only be included by test files.
    // To enable logging for a test, use:
    //
    //	func TestSomething(t *testing.T) {
    //		defer testlogger.T.SetLogTB(t)()
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. internal/event/target/nats.go

    			if connErr.Error() == nats.ErrNoServers.Error() {
    				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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. internal/config/lambda/event/targetlist.go

    	list.RLock()
    	defer list.RUnlock()
    
    	ntargets := make(map[TargetID]Target, len(list.targets))
    	for k, v := range list.targets {
    		ntargets[k] = v
    	}
    	return ntargets
    }
    
    // Send - sends events to targets identified by target IDs.
    func (list *TargetList) Send(event Event, id TargetID) (*http.Response, error) {
    	list.RLock()
    	target, ok := list.targets[id]
    	list.RUnlock()
    	if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  6. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

    import okhttp3.Handshake
    import okhttp3.HttpUrl
    import okhttp3.OkHttpClient
    import okhttp3.Protocol
    import okhttp3.Request
    import okhttp3.Response
    
    /**
     * An OkHttp EventListener, which logs call events. Can be applied as an
     * [event listener factory][OkHttpClient.eventListenerFactory].
     *
     * The format of the logs created by this class should not be considered stable and may change
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java

    import okhttp3.EventListener;
    import okhttp3.Handshake;
    import okhttp3.HttpUrl;
    import okhttp3.OkHttpClient;
    import okhttp3.Protocol;
    import okhttp3.Request;
    import okhttp3.Response;
    
    /**
     * This prints events for a single in-flight call. It won't work for multiple concurrent calls
     * because we don't know what callStartNanos refers to.
     */
    public final class PrintEventsNonConcurrent {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 16 23:20:49 UTC 2020
    - 5.3K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DebugResolutionListener.java

    import java.util.Objects;
    import java.util.Set;
    
    import org.apache.maven.artifact.Artifact;
    import org.apache.maven.artifact.versioning.VersionRange;
    import org.codehaus.plexus.logging.Logger;
    
    /**
     * Send resolution events to the debug log.
     *
     */
    @Deprecated
    public class DebugResolutionListener implements ResolutionListener, ResolutionListenerForDepMgmt {
        private Logger logger;
    
        private String indent = "";
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  9. docs/en/docs/advanced/openapi-webhooks.md

    ## Webhooks steps
    
    The process normally is that **you define** in your code what is the message that you will send, the **body of the request**.
    
    You also define in some way at which **moments** your app will send those requests or events.
    
    And **your users** define in some way (for example in a web dashboard somewhere) the **URL** where your app should send those requests.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:38:23 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  10. docs/changelogs/changelog_4x.md

        been received. Previously these events were incorrectly sent too early, when OkHttp was ready to
        read the response headers or body, which mislead tracing tools. Note that the `responseFailed()`
        event always used to follow one of these events; now it may be sent without them.
    
     *  New: Upgrade to Kotlin 1.3.61.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
Back to top