- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,690 for Weaver (0.23 sec)
-
internal/crypto/sse.go
return } // EncryptSinglePart encrypts an io.Reader which must be the // body of a single-part PUT request. func EncryptSinglePart(r io.Reader, key ObjectKey) io.Reader { r, err := sio.EncryptReader(r, sio.Config{MinVersion: sio.Version20, Key: key[:], CipherSuites: fips.DARECiphers()}) if err != nil { logger.CriticalIf(context.Background(), errors.New("Unable to encrypt io.Reader using object key")) } return r }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/bucket/object/lock/lock.go
// Maximum 4KiB size per object lock config. const maxObjectLockConfigSize = 1 << 12 // ParseObjectLockConfig parses ObjectLockConfig from xml func ParseObjectLockConfig(reader io.Reader) (*Config, error) { config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil { return nil, err } return &config, nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
cases := []struct { file string recordDelimiter string fieldDelimiter string header bool wantColumns []string wantTenFields string totalFields int }{ { file: "nyc-taxi-data-100k.csv", recordDelimiter: "\n", fieldDelimiter: ",", header: true,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 38.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
return probeSet, nil } func (s *Server) Start() { log.Info("CNI ambient server starting") s.kubeClient.RunAndWait(s.ctx.Done()) log.Info("CNI ambient server kubeclient started") pods := s.handlers.GetAmbientPods() err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err) } log.Info("CNI ambient server marking ready") s.Ready()
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 01:42:30 GMT 2024 - 7.1K bytes - Viewed (0) -
cmd/data-usage-cache.go
if total < limit { return } // Appears to be printed with _MINIO_SERVER_DEBUG=off // console.Debugf(" %d children found, compacting %v\n", total, path) leaves := make([]struct { objects uint64 path dataUsageHash }, total) // Collect current leaves that have children. leaves = leaves[:0] remove := total - limit var add func(path dataUsageHash) add = func(path dataUsageHash) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 41.3K bytes - Viewed (1) -
docs/changelogs/changelog_4x.md
The upcoming Android Studio runs in a JVM but has classes from Android and that confused OkHttp! * Fix: Include the header `Accept: text/event-stream` for SSE calls. This header is not added if the request already contains an `Accept` header. * Fix: Don't crash with a `NullPointerException` if a server sends a close while we're sending a ping. OkHttp had a race condition bug. ## Version 4.6.0 _2020-04-28_
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
tests/test_security_http_bearer.py
client = TestClient(app) def test_security_http_bearer(): response = client.get("/users/me", headers={"Authorization": "Bearer foobar"}) assert response.status_code == 200, response.text assert response.json() == {"scheme": "Bearer", "credentials": "foobar"} def test_security_http_bearer_no_credentials(): response = client.get("/users/me")
Python - Registered: Sun Apr 21 07:19:11 GMT 2024 - Last Modified: Fri Jun 30 18:25:16 GMT 2023 - 2K bytes - Viewed (0) -
tensorflow/c/eager/tfe_monitoring_reader_internal.h
limitations under the License. ==============================================================================*/ #ifndef TENSORFLOW_C_EAGER_TFE_MONITORING_READER_INTERNAL_H_ #define TENSORFLOW_C_EAGER_TFE_MONITORING_READER_INTERNAL_H_ #include <memory> #include "tensorflow/core/lib/monitoring/cell_reader.h" struct TFE_MonitoringCounterReader { explicit TFE_MonitoringCounterReader(const char* name) { counter = std::make_unique<
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Apr 20 03:14:47 GMT 2023 - 1.3K bytes - Viewed (0) -
cmd/handler-utils.go
var validSSEReplicationHeaders = map[string]string{ "X-Minio-Internal-Server-Side-Encryption-Sealed-Key": "X-Minio-Replication-Server-Side-Encryption-Sealed-Key", "X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm": "X-Minio-Replication-Server-Side-Encryption-Seal-Algorithm", "X-Minio-Internal-Server-Side-Encryption-Iv": "X-Minio-Replication-Server-Side-Encryption-Iv",
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
tensorflow/c/eager/c_api_experimental_reader.cc
return result; } int64_t TFE_MonitoringReadCounter0(TFE_MonitoringCounterReader* cell_reader) { int64_t result = cell_reader->Read(); return result; } int64_t TFE_MonitoringReadCounter1(TFE_MonitoringCounterReader* cell_reader, const char* label) { int64_t result = cell_reader->Read(label); return result;
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Apr 20 03:14:47 GMT 2023 - 1.4K bytes - Viewed (0)