- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 988 for message2 (0.14 sec)
-
pkg/config/analysis/incluster/controller.go
}) } oldmsgs := map[string]diag.Messages{} pushFn := func(combinedKinds sets.Set[config.GroupVersionKind]) { res, err := c.analyzer.ReAnalyzeSubset(combinedKinds, stop) if err != nil { log.Errorf("In-cluster analysis has failed: %s", err) return } // reorganize messages to map index := map[status.Resource]diag.Messages{} for _, m := range res.Messages {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0) -
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: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 1.8K bytes - Viewed (0) -
docs/en/docs/advanced/websockets.md
**FastAPI** provides the same `WebSocket` directly just as a convenience for you, the developer. But it comes directly from Starlette. ## Await for messages and send messages In your WebSocket route you can `await` for messages and send messages. ```Python hl_lines="48-52" {!../../../docs_src/websockets/tutorial001.py!} ``` You can receive and send binary, text, and JSON data. ## Try it
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu May 02 22:37:31 UTC 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/log/uds.go
return } messages := make([]cniLog, 0, len(cniLogs)) for _, l := range cniLogs { msg, ok := parseCniLog(l) if !ok { continue } messages = append(messages, msg) } // Lock log message printing to prevent log messages from different CNI // processes interleave. l.mu.Lock() defer l.mu.Unlock() for _, m := range messages { logger := pluginLog
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/config/analysis/local/context.go
func (i *istiodContext) Report(c config.GroupVersionKind, m diag.Message) { msgs := i.messages[i.currentAnalyzer] if msgs == nil { msgs = &diag.Messages{} i.messages[i.currentAnalyzer] = msgs } msgs.Add(m) } func (i *istiodContext) SetAnalyzer(analyzerName string) { i.currentAnalyzer = analyzerName } func (i *istiodContext) GetMessages(analyzerNames ...string) diag.Messages { result := diag.Messages{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/ide/problems-api/src/main/java/org/gradle/api/problems/internal/DocLink.java
*/ public interface DocLink extends Serializable { /** * The URL to the documentation page. */ String getUrl(); /** * A message that tells the user to consult the documentation. * There are currently 2 different messages used for this, hence this method. */ String getConsultDocumentationMessage();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 15:24:26 UTC 2024 - 1.2K bytes - Viewed (0) -
src/cmd/compile/internal/types2/errsupport.go
// license that can be found in the LICENSE file. // This file implements support functions for error messages. package types2 // lookupError returns a case-specific error when a lookup of selector sel in the // given type fails but an object with alternative spelling (case folding) is found. // If structLit is set, the error message is specifically for struct literal fields.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 07 16:41:56 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/plugin/ApiAdminPluginAction.java
@Execute public JsonResponse<ApiResult> put$index(final InstallBody body) { validateApi(body, messages -> {}); final Artifact artifact = ComponentUtil.getPluginHelper().getArtifact(body.name, body.version); if (artifact == null) { return asJson( new ApiResult.ApiErrorResponse().message("invalid name or version").status(ApiResult.Status.BAD_REQUEST).result()); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/QueryProcessor.java
if (queryCommand != null) { return queryCommand.execute(context, query, boost); } throw new InvalidQueryException(messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY), "Unknown q: " + query.getClass() + " => " + query); }; } public interface Filter {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/config/analysis/analyzers/multicluster_analyzers_test.go
result, err := runAnalyzer(sa) if err != nil { t.Fatalf("Error running analysis on testcase %s: %v", tc.name, err) } g.Expect(extractFields(result.Messages)).To(ConsistOf(tc.expected), "%v", prettyPrintMessages(result.Messages)) }) } } func setupMultiClusterEnvironmentForCase(tc mcTestCase, cr local.CollectionReporterFn) (*local.IstiodAnalyzer, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.5K bytes - Viewed (0)