Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,613 for Messages (0.07 sec)

  1. CONTRIBUTING.md

    see [this guide](./platforms/documentation/docs/README.md).
    
    ### Creating commits and writing commit messages
    
    The commit messages that accompany your code changes are an important piece of documentation. Please follow these guidelines when creating commits:
    
    * [Write good commit messages.](https://cbea.ms/git-commit/#seven-rules)
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Nov 05 15:15:33 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  2. istioctl/pkg/util/proto/messageslice.go

    	"google.golang.org/protobuf/proto"
    
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    // MessageSlice allows us to marshal slices of protobuf messages like clusters/listeners/routes/endpoints correctly
    type MessageSlice []proto.Message
    
    // MarshalJSON handles marshaling of slices of proto messages
    func (pSlice MessageSlice) MarshalJSON() ([]byte, error) {
    	buffer := bytes.NewBufferString("[")
    	sliceLength := len(pSlice)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 19 21:53:59 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/core/exception/ClRuntimeException.java

            return args;
        }
    
        @Override
        public String getMessage() {
            return message;
        }
    
        /**
         * Returns a simple message without a message code.
         *
         * @return simple message without message code
         */
        public final String getSimpleMessage() {
            return simpleMessage;
        }
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. internal/grid/benchmark_test.go

    					case b, ok := <-in:
    						if !ok {
    							if got != messages {
    								return NewRemoteErrf("wrong number of requests. want %d, got %d", messages, got)
    							}
    							return nil
    						}
    						out <- b
    						got++
    					}
    				}
    			},
    
    			Subroute:    "some-subroute",
    			OutCapacity: 1,
    			InCapacity:  1, // Only one message buffered.
    		}))
    		errFatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. internal/logger/target/types/types.go

    )
    
    // TargetStats contains statistics for a target.
    type TargetStats struct {
    	// QueueLength is the queue length if any messages are queued.
    	QueueLength int
    
    	// TotalMessages is the total number of messages sent in the lifetime of the target
    	TotalMessages int64
    
    	// FailedMessages should log message count that failed to send.
    	FailedMessages int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/query/BoostQueryCommand.java

                    logger.debug("{}:{}", query, boost);
                }
                return getQueryProcessor().execute(context, boostQuery.getQuery(), boostQuery.getBoost());
            }
            throw new InvalidQueryException(messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY),
                    "Unknown q: " + query.getClass() + " => " + query);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  7. internal/logger/help.go

    			Description: "configure channel queue size for webhook targets",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueDir,
    			Description: `staging dir for undelivered logger messages e.g. '/home/logger-events'`,
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         Proxy,
    			Description: "proxy url endpoint e.g. http(s)://proxy",
    			Optional:    true,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    		}
    		if m.Op != OpMerged {
    			c.inMessages.Add(1)
    			c.handleMsg(ctx, m, subID)
    			continue
    		}
    		// Handle merged messages.
    		messages := int(m.Seq)
    		c.inMessages.Add(int64(messages))
    		for i := 0; i < messages; i++ {
    			if atomic.LoadUint32((*uint32)(&c.state)) != StateConnected {
    				return
    			}
    			var next []byte
    			next, remain, err = msgp.ReadBytesZC(remain)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/query/BooleanQueryCommand.java

                    logger.debug("{}:{}", query, boost);
                }
                return convertBooleanQuery(context, booleanQuery, boost);
            }
            throw new InvalidQueryException(messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY),
                    "Unknown q: " + query.getClass() + " => " + query);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/log/AdminLogAction.java

                    try (InputStream in = Files.newInputStream(path)) {
                        out.write(in);
                    }
                });
            }
            throwValidationError(messages -> messages.addErrorsCouldNotFindLogFile(GLOBAL, filename), this::asIndexHtml);
            return redirect(getClass()); // no-op
        }
    
        public static List<Map<String, Object>> getLogFileItems() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top