- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,758 for yyerror (0.59 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
ztunnelServer := fixture.ztunServer errChan := make(chan error) go func() { errChan <- ztunnelServer.PodDeleted(ctx, uid) }() // read the msg to delete from ztunnel m, fds = readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Del).Del.Uid, uid) sendAck(ztunClient) assert.NoError(t, <-errChan) ztunClient.Close()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
internal/logger/target/console/console.go
} // Validate - validate if the tty can be written to func (c *Target) Validate() error { return nil } // Endpoint returns the backend endpoint func (c *Target) Endpoint() string { return "" } func (c *Target) String() string { return "console" } // Send log message 'e' to console func (c *Target) Send(e interface{}) error { entry, ok := e.(log.Entry) if !ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
*corev1.Pod, int, error, ) { return attachPod(namespace), 1, nil } for _, tt := range tests { t.Run(strings.Split(tt.name, ".")[0], func(t *testing.T) { gotPodName, gotNamespace, err := InferPodInfoFromTypedResource(tt.name, "test", factory) assert.NoError(t, err) if gotPodName != tt.wantPodName || gotNamespace != tt.wantNamespace {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
cmd/auth-handler.go
} // Verify if request has valid AWS Signature Version '2'. func isReqAuthenticatedV2(r *http.Request) (s3Error APIErrorCode) { if isRequestSignatureV2(r) { return doesSignV2Match(r) } return doesPresignV2SignatureMatch(r) } func reqSignatureV4Verify(r *http.Request, region string, stype serviceType) (s3Error APIErrorCode) { sha256sum := getContentSha256Cksum(r, stype) switch { case isRequestSignatureV4(r):
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10PsiTypeProvider.kt
preserveAnnotations: Boolean, ): PsiType? { val kotlinType = (type as KtFe10Type).fe10Type with(typeMapper.typeContext) { if (kotlinType.contains { it.isError() }) { return null } } if (!analysisSession.useSiteModule.platform.has<JvmPlatform>()) return null val typeElement = asPsiTypeElement(
Plain Text - Registered: Fri May 03 08:18:13 GMT 2024 - Last Modified: Thu Mar 28 16:10:07 GMT 2024 - 6.4K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/utils/KtFe10JvmTypeMapperContext.kt
|| typeContext.hasNothingInNonContravariantPosition(type) || type.arguments.isEmpty() || typeDeclaration == null || ErrorUtils.isError(typeDeclaration) if (skipArguments) { writeAsmType(asmType) return } val nestedType = getNestedType(type) if (nestedType.nested.isEmpty()) {
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Fri Mar 10 11:03:45 GMT 2023 - 8.3K bytes - Viewed (0) -
internal/s3select/select.go
"github.com/minio/simdjson-go" "github.com/pierrec/lz4" ) type recordReader interface { // Read a record. // dst is optional but will be used if valid. Read(dst sql.Record) (sql.Record, error) Close() error } const ( csvFormat = "csv" jsonFormat = "json" parquetFormat = "parquet" ) // CompressionType - represents value inside <CompressionType/> in request XML. type CompressionType string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (1) -
istioctl/pkg/writer/ztunnel/configdump/configdump_test.go
} } else if len(cw.ztunnelDump.Workloads) != tt.wantConfigs { t.Errorf("wanted %v configs loaded in got %v", tt.wantConfigs, len(cw.ztunnelDump.Workloads)) } if tt.wantErr { assert.Error(t, err) } else { assert.NoError(t, err) } }) } } func TestConfigWriter_PrintSecretSummary(t *testing.T) { tests := []struct { name string wantOutputSecret string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Feb 02 18:21:48 GMT 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump_test.go
} } else if len(cw.configDump.Configs) != tt.wantConfigs { t.Errorf("wanted %v configs loaded in got %v", tt.wantConfigs, len(cw.configDump.Configs)) } if tt.wantErr { assert.Error(t, err) } else { assert.NoError(t, err) } }) } } func TestConfigWriter_PrintBootstrapDump(t *testing.T) { tests := []struct { name string wantOutputFile string callPrime bool
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 03 23:08:06 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/admin-heal-ops.go
errHealStopSignalled = fmt.Errorf("heal stop signaled") errFnHealFromAPIErr = func(ctx context.Context, err error) error { apiErr := toAdminAPIErr(ctx, err) return fmt.Errorf("Heal internal error: %s: %s", apiErr.Code, apiErr.Description) } ) // healSequenceStatus - accumulated status of the heal sequence type healSequenceStatus struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1)