Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,653 for publisher (0.23 sec)

  1. internal/s3select/sql/jsondata/books.json

            {
                "year": 1934,
                "publisher": "Collins Crime Club (London)",
                "type": "Hardcover",
                "pages": 256
            },
            {
                "year": 1934,
                "publisher": "Dodd Mead and Company (New York)",
                "type": "Hardcover",
                "pages": 302
            },
            {
                "year": 2011,
                "publisher": "Harper Collins",
                "type": "Paperback",
    Json
    - Registered: 2024-04-21 19:28
    - Last Modified: 2021-06-01 21:59
    - 1.9K bytes
    - Viewed (0)
  2. internal/grid/trace.go

    		trace.Path = fmt.Sprintf("%s?payload=%T", trace.Path, typed)
    	case string:
    		trace.Path = fmt.Sprintf("%s?%s", trace.Path, typed)
    	default:
    	}
    	trace.HTTP.ReqInfo.Path = trace.Path
    
    	t.Publisher.Publish(trace)
    	return resp, err
    Go
    - Registered: 2024-04-21 19:28
    - Last Modified: 2024-02-02 22:54
    - 4K bytes
    - Viewed (0)
  3. 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: 2024-04-19 11:42
    - Last Modified: 2022-12-26 22:07
    - 1.5K bytes
    - Viewed (0)
  4. 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: 2024-04-21 19:28
    - Last Modified: 2023-10-07 15:07
    - 10K bytes
    - Viewed (0)
  5. 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: 2024-04-21 19:28
    - Last Modified: 2024-04-04 12:04
    - 6K bytes
    - Viewed (0)
  6. .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: 2024-04-17 11:36
    - Last Modified: 2024-02-13 13:53
    - 7.7K bytes
    - Viewed (0)
  7. 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: 2024-04-21 03:35
    - Last Modified: 2023-09-14 11:48
    - 29.9K bytes
    - Viewed (0)
  8. 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: 2024-04-21 19:28
    - Last Modified: 2024-04-04 12:04
    - 9.5K bytes
    - Viewed (0)
  9. 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: 2024-04-21 19:28
    - Last Modified: 2024-04-04 12:04
    - 42.6K bytes
    - Viewed (0)
  10. 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: 2024-04-21 19:28
    - Last Modified: 2024-03-19 04:37
    - 18.8K bytes
    - Viewed (0)
Back to top