- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,650 for publisher (0.19 sec)
-
internal/grid/trace.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
internal/s3select/sql/jsondata/books.json
Json - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.9K bytes - Viewed (0) -
docs/releasing.md
5. Wait for [GitHub Actions][github_actions] to start the publish job. 6. Prepare for ongoing development and push to GitHub. ``` sed -i "" \ "s/version = \".*\"/version = \"$NEXT_VERSION\"/g" \ build.gradle.kts git commit -am "Prepare next development version." git push ``` 7. Confirm the [GitHub Actions][github_actions] publish job succeeded.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Dec 26 22:07:16 GMT 2022 - 1.5K bytes - Viewed (0) -
internal/event/target/amqp.go
return err } if err = ch.Publish(target.args.Exchange, target.args.RoutingKey, target.args.Mandatory, target.args.Immediate, amqp091.Publishing{ Headers: headers, ContentType: "application/json", DeliveryMode: target.args.DeliveryMode, Body: data, }); err != nil { return err } // check for publisher confirms only if its enabled
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
return } } rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/GradleBuildConfigurationDefaults.kt
} } } } fun BuildFeatures.publishBuildStatusToGithub() { commitStatusPublisher { vcsRootExtId = VersionedSettingsBranch.fromDslContext().vcsRootId() publisher = github { githubUrl = "https://api.github.com" authType = personalToken { token = "%github.bot-gradle.token%" } } } }
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 7.9K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
import org.codehaus.plexus.logging.Logger; import org.eclipse.aether.ConfigurationProperties; import org.eclipse.aether.util.ConfigUtils; // TODO remove the update check manager // TODO separate into retriever and publisher // TODO remove hardcoding of checksum logic /** * Manages <a href="https://maven.apache.org/wagon">Wagon</a> related operations in Maven. */ @Named @Singleton @Deprecated
Java - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Thu Sep 14 11:48:15 GMT 2023 - 29.9K bytes - Viewed (0) -
internal/config/notify/help.go
config.HelpKV{ Key: target.NATSStreamingAsync, Description: "[DEPRECATED] set to 'on', to enable asynchronous publish", Optional: true, Type: "on|off", }, config.HelpKV{ Key: target.NATSStreamingMaxPubAcksInFlight, Description: "[DEPRECATED] number of messages to publish without waiting for ACKs", Optional: true, Type: "number", }, config.HelpKV{
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
internal/grid/manager.go
local: o.Local, remote: host, dial: o.Dialer, handlers: &m.handlers, auth: o.AddAuth, blockConnect: o.BlockConnect, tlsConfig: o.TLSConfig, publisher: o.TraceTo, incomingBytes: o.Incoming, outgoingBytes: o.Outgoing, }) } if !found { return nil, fmt.Errorf("grid: local host not found") } return m, nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/grid/connection.go
c.baseFlags |= FlagCRCxxh3 } if !strings.HasPrefix(o.local, "https://") && !strings.HasPrefix(o.local, "wss://") { c.baseFlags |= FlagCRCxxh3 } if o.publisher != nil { c.traceRequests(o.publisher) } if o.local == o.remote { panic("equal hosts") } if c.shouldConnect() { c.side = ws.StateClientSide go func() { if o.blockConnect != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0)