- Sort Score
- Num 10 results
- Language All
Results 591 - 600 of 691 for changes (0.04 seconds)
-
internal/event/target/kafka.go
return err } switch { case key.ItemCount == 1: var event event.Event event, err = target.store.Get(key) if err != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil } return err } err = target.send(event)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0) -
cmd/auth-handler.go
func getClaimsFromTokenWithSecret(token, secret string) (*xjwt.MapClaims, error) { // JWT token for x-amz-security-token is signed with admin // secret key, temporary credentials become invalid if // server admin credentials change. This is done to ensure // that clients cannot decode the token using the temp // secret keys and generate an entirely new claim by essentially // hijacking the policies. We need to make sure that this is
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataSource.java
&& !artifact.getDependencyFilter().include(artifact)) { return null; } // MNG-2861: the artifact data has changed. If the available versions where previously // retrieved, we need to update it. // TODO shouldn't the versions be merged across relocations?
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Sep 25 12:03:50 GMT 2025 - 30.4K bytes - Click Count (0) -
impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/PluginUpgradeStrategyTest.java
UpgradeResult result = strategy.doApply(context, pomMap); assertTrue(result.success(), "Plugin upgrade should succeed"); // Verify the version was not changed Editor editor = new Editor(document); Element root = editor.root(); String version = root.path("build", "plugins", "plugin", "version") .map(Element::textContentTrimmed)
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Nov 18 18:03:26 GMT 2025 - 27.8K bytes - Click Count (0) -
internal/etag/etag.go
// Package etag provides an implementation of S3 ETags. // // Each S3 object has an associated ETag that can be // used to e.g. quickly compare objects or check whether // the content of an object has changed. // // In general, an S3 ETag is an MD5 checksum of the object // content. However, there are many exceptions to this rule. // // # Single-part Upload //
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 16 14:27:42 GMT 2025 - 13.2K bytes - Click Count (0) -
docs/fr/docs/index.md
* Fournir directement 2 interfaces web de documentation interactive. --- Nous n'avons fait qu'effleurer la surface, mais vous avez déjà une idée de la façon dont tout cela fonctionne. Essayez de changer la ligne contenant : ```Python return {"item_name": item.name, "item_id": item_id} ``` ... de : ```Python ... "item_name": item.name ... ``` ... vers :
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 22K bytes - Click Count (0) -
internal/event/target/postgresql.go
return store.ErrNotConnected } return err } } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 13.3K bytes - Click Count (0) -
docs/en/docs/deployment/https.md
You would probably get a cloud server (a virtual machine) or something similar, and it would have a <abbr title="That doesn't change">fixed</abbr> **public IP address**. In the DNS server(s) you would configure a record (an "`A record`") to point **your domain** to the public **IP address of your server**.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 19:34:08 GMT 2025 - 14.3K bytes - Click Count (0) -
internal/s3select/select.go
break OuterLoop } } else { var outputRecord sql.Record // We will attempt to reuse the records in the table. // The type of these should not change. // The queue should always have at least one entry left for this to work. outputQueue = outputQueue[:len(outputQueue)+1] if t := outputQueue[len(outputQueue)-1]; t != nil {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 21.2K bytes - Click Count (0) -
cmd/peer-rest-server.go
} rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) // Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write() ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0)