- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 2,250 for Mirror (0.05 sec)
-
cmd/notification.go
allPeerClients []*peerRESTClient // Includes nil client for self } // NotificationPeerErr returns error associated for a remote peer. type NotificationPeerErr struct { Host xnet.Host // Remote host on which the rpc call was initiated Err error // Error returned by the remote peer for an rpc call } // A NotificationGroup is a collection of goroutines working on subtasks that are part of
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/prepare-storage.go
printOnce[endpoint] = m if once { m[err.Error()]++ peersLogAlwaysIf(ctx, err) return } } // Once is set and we are here means error was already // printed once. if once { return } // once not set, check if same error occurred 3 times in // a row, then make sure we print it to call attention. if m[err.Error()] > 2 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
internal/event/targetlist_test.go
return errors.New("send error") } return nil } // SendFromStore - interface compatible method does no-op. func (target *ExampleTarget) SendFromStore(_ store.Key) error { return nil } func (target ExampleTarget) Close() error { if target.closeErr { return errors.New("close error") } return nil } func (target ExampleTarget) IsActive() (bool, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0) -
internal/event/target/postgresql.go
} // send - sends an event to the PostgreSQL. func (target *PostgreSQLTarget) send(eventData event.Event) error { if target.args.Format == event.NamespaceFormat { objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.3K 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.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 15K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/ArtifactMetadata.java
} public void setWhy(String why) { this.why = why; } public String getError() { return error; } public void setError(String error) { this.error = error; } public boolean isError() { return error == null; } public String getDependencyConflictId() { return groupId + ":" + artifactId; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.6K bytes - Viewed (0) -
internal/s3select/jstream/decoder_test.go
} err := decoder.Err() t.Logf("got error: %s", err) if err == nil { t.Fatalf("missing expected decoder error") } derr, ok := err.(DecoderError) if !ok { t.Fatalf("expected error of type DecoderError, got %T", err) } if derr.ReaderErr() == nil { t.Fatalf("missing expected underlying reader error") } } func TestDecoderMaxDepth(t *testing.T) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.6K bytes - Viewed (0) -
tests/test_response_code_no_body.py
class JsonApiResponse(JSONResponse): media_type = "application/vnd.api+json" class Error(BaseModel): status: str title: str class JsonApiError(BaseModel): errors: typing.List[Error] @app.get( "/a", status_code=204, response_class=JsonApiResponse, responses={500: {"description": "Error", "model": JsonApiError}}, ) async def a(): pass
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Jun 30 18:25:16 UTC 2023 - 3.2K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
return s.ztunnelServer.PodAdded(ctx, pod, netns) } // ConstructInitialSnapshot takes a "snapshot" of current ambient pods and // // 1. Constructs a ztunnel state message to initialize ztunnel // 2. Syncs the host ipset func (s *NetServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error { var consErr []error
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
internal/s3select/select.go
"github.com/minio/simdjson-go" "github.com/pierrec/lz4/v4" ) 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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 21.2K bytes - Viewed (0)