Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for confirmats (0.08 sec)

  1. internal/event/target/amqp.go

    	if target.args.PublisherConfirms {
    		confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1))
    		if err := ch.Confirm(false); err != nil {
    			ch.Close()
    			return nil, nil, err
    		}
    		return ch, confirms, nil
    	}
    
    	return ch, nil, nil
    }
    
    // send - sends an event to the AMQP091.
    func (target *AMQPTarget) send(eventData event.Event, ch *amqp091.Channel, confirms chan amqp091.Confirmation) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. istioctl/pkg/workload/workload_test.go

    				}, metav1.CreateOptions{})
    				client.Kube().CoreV1().ConfigMaps("bar").Create(context.Background(), &v1.ConfigMap{
    					ObjectMeta: metav1.ObjectMeta{Namespace: "bar", Name: "istio-ca-root-cert"},
    					Data:       map[string]string{"root-cert.pem": string(fakeCACert)},
    				}, metav1.CreateOptions{})
    				client.Kube().CoreV1().ConfigMaps("istio-system").Create(context.Background(), &v1.ConfigMap{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. istioctl/pkg/kubeinject/kubeinject.go

    	}
    
    	if meshConfigMapName == defaultMeshConfigMapName && revision != "" {
    		meshConfigMapName = fmt.Sprintf("%s-%s", defaultMeshConfigMapName, revision)
    	}
    	meshConfigMap, err := client.Kube().CoreV1().ConfigMaps(ctx.IstioNamespace()).Get(context.TODO(), meshConfigMapName, metav1.GetOptions{})
    	if err != nil {
    		return nil, fmt.Errorf("could not read valid configmap %q from namespace %q: %v - "+
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  4. istioctl/pkg/injector/injector-list.go

    	retval := map[string]string{}
    
    	// All configs in all namespaces that are Istio revisioned
    	configMaps, err := client.Kube().CoreV1().ConfigMaps("").List(ctx, metav1.ListOptions{LabelSelector: label.IoIstioRev.Name})
    	if err != nil {
    		return retval, err
    	}
    
    	for _, configMap := range configMaps.Items {
    		image := injection.GetIstioProxyImage(&configMap)
    		if image != "" {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Oct 18 11:39:52 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. istioctl/pkg/precheck/precheck.go

    		configMapName := "istio"
    		if rev := deployment.Labels[label.IoIstioRev.Name]; rev != "default" {
    			configMapName += fmt.Sprintf("-%s", rev)
    		}
    		configMap, err := cli.Kube().CoreV1().ConfigMaps(namespace).Get(context.TODO(), configMapName, metav1.GetOptions{})
    		if err != nil {
    			fmt.Printf("Error getting configmap %s: %v\n", configMapName, err)
    		}
    		meshData := make(map[string]interface{})
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 02:31:32 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  6. istioctl/pkg/workload/workload.go

    func createCertsTokens(kubeClient kube.CLIClient, wg *clientnetworking.WorkloadGroup, dir string, out io.Writer) error {
    	rootCert, err := kubeClient.Kube().CoreV1().ConfigMaps(wg.Namespace).Get(context.Background(), controller.CACertNamespaceConfigMap, metav1.GetOptions{})
    	// errors if the requested configmap does not exist in the given namespace
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  7. build.gradle.kts

        toolVersion = rootProject.libs.versions.checkStyle.get()
        sourceSets = listOf(project.sourceSets["main"])
      }
    
      // Animal Sniffer confirms we generally don't use APIs not on Java 8.
      configure<AnimalSnifferExtension> {
        annotation = "okhttp3.internal.SuppressSignatureCheck"
        sourceSets = listOf(project.sourceSets["main"])
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jun 23 17:02:02 UTC 2024
    - 9K bytes
    - Viewed (0)
  8. docs/pt/docs/how-to/separate-openapi-schemas.md

    ```
    
    </details>
    
    ////
    
    ... então o campo `description` não será obrigatório. Porque ele tem um valor padrão de `None`.
    
    ### Modelo de Entrada na Documentação
    
    Você pode confirmar que na documentação, o campo `description` não tem um **asterisco vermelho**, não é marcado como obrigatório:
    
    <div class="screenshot">
    <img src="/img/tutorial/separate-openapi-schemas/image01.png">
    </div>
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 24 18:52:36 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  9. docs/en/docs/how-to/custom-docs-ui-assets.md

     *   Version: "2.0.0-rc.18"
     *   Repo: https://github.com/Redocly/redoc
     */
    !function(e,t){"object"==typeof exports&&"object"==typeof m
    
    ...
    ```
    
    That confirms that you are being able to serve static files from your app, and that you placed the static files for the docs in the correct place.
    
    Now we can configure the app to use those static files for the docs.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:42:34 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  10. docs/pt/docs/how-to/custom-docs-ui-assets.md

     *   Version: "2.0.0-rc.18"
     *   Repo: https://github.com/Redocly/redoc
     */
    !function(e,t){"object"==typeof exports&&"object"==typeof m
    
    ...
    ```
    
    Isso confirma que você está conseguindo fornecer arquivos estáticos do seu aplicativo e que você colocou os arquivos estáticos para a documentação no local correto.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Oct 18 12:02:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top