- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,441 for gzerror (0.21 sec)
-
cni/pkg/nodeagent/server_test.go
if f.testWG != nil { defer f.testWG.Done() } args := f.Called(ctx, pod, podIPs, netNs) return args.Error(0) } func (f *fakeServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error { if f.testWG != nil { defer f.testWG.Done() } args := f.Called(ctx, pod) return args.Error(0) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
internal/s3select/unused-errors.go
func errExpressionTooLong(err error) *s3Error { return &s3Error{ code: "ExpressionTooLong", message: "The SQL expression is too long: The maximum byte-length for the SQL expression is 256 KB.", statusCode: 400, cause: err, } } func errColumnTooLong(err error) *s3Error { return &s3Error{ code: "ColumnTooLong",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 17.5K bytes - Viewed (0) -
cmd/site-replication.go
} ) func errSRInvalidRequest(err error) SRError { return SRError{ Cause: err, Code: ErrSiteReplicationInvalidRequest, } } func errSRPeerResp(err error) SRError { return SRError{ Cause: err, Code: ErrSiteReplicationPeerResp, } } func errSRBackendIssue(err error) SRError { return SRError{ Cause: err, Code: ErrSiteReplicationBackendIssue, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cni/pkg/log/uds_test.go
log.Warn("warn log") log.Error("error log") // This will error because stdout cannot sync, but the UDS part should sync // Ideally we would fail if the UDS part fails but the error library makes it kind of tricky _ = log.Sync() // Restore os stdout. os.Stdout = stdout assert.NoError(t, log.Configure(loggingOptions)) assert.NoError(t, w.Close()) out, err := io.ReadAll(r) assert.NoError(t, err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
Namespace: "default", })) cmd.SetArgs([]string{ "all", "-f", "testdata/config_dump.json", }) out := bytes.Buffer{} cmd.SetOut(&out) assert.NoError(t, cmd.Execute()) expected := util.ReadFile(t, "testdata/config_dump_summary.txt") if err := assert.Compare(out.String(), string(expected)); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
return err } if resp.GetAck().GetError() != "" { log.Errorf("add-workload: got ack error: %s", resp.GetAck().GetError()) return fmt.Errorf("got ack error: %s", resp.GetAck().GetError()) } return nil } // TODO ctx is unused here // nolint: unparam func (z *ztunnelServer) sendSnapshot(ctx context.Context, conn *ZtunnelConnection) error { snap := z.pods.ReadCurrentPodSnapshot()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
type esClient interface { isAtleastV7() bool createIndex(ElasticsearchArgs) error ping(context.Context, ElasticsearchArgs) (bool, error) stop() entryExists(context.Context, string, string) (bool, error) removeEntry(context.Context, string, string) error updateEntry(context.Context, string, string, event.Event) error addEntry(context.Context, string, event.Event) error } // ElasticsearchArgs - Elasticsearch target arguments.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
// no calls to ztunnel if iptables failed assert.Equal(t, ztunnelServer.addedPods.Load(), 0) // error is not partial error if errors.Is(err, ErrPartialAdd) { t.Fatal("expected not a partial error") } } func TestConstructInitialSnap(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cmd/bucket-encryption-handlers.go
return } vars := mux.Vars(r) bucket := vars["bucket"] if s3Error := checkRequestAuthType(ctx, r, policy.GetBucketEncryptionAction, bucket, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Check if bucket exists var err error if _, err = objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/auth-handler_test.go
} for i, testCase := range testCases { if _, s3Error := checkAdminRequestAuth(ctx, testCase.Request, policy.AllAdminActions, globalSite.Region); s3Error != testCase.ErrCode { t.Errorf("Test %d: Unexpected s3error returned wanted %d, got %d", i, testCase.ErrCode, s3Error) } } } func TestValidateAdminSignature(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0)