- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 1,066 for readOp (0.19 sec)
-
internal/grid/debug.go
hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{ Timeout: 5 * time.Second, } var res TestGrid res.Hosts = hosts ready := make(chan struct{}) ctx, cancel := context.WithCancel(context.Background()) res.cancel = cancel for i, host := range hosts { manager, err := NewManager(ctx, ManagerOptions{ Dialer: ConnectWS(dialer.DialContext,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/object-api-datatypes.go
UserTags string // List of individual parts, maximum size of upto 10,000 Parts []ObjectPartInfo `json:"-"` // Implements writer and reader used by CopyObject API Writer io.WriteCloser `json:"-" msg:"-"` Reader *hash.Reader `json:"-" msg:"-"` PutObjReader *PutObjReader `json:"-" msg:"-"` metadataOnly bool versionOnly bool // adds a new version, only used by CopyObject
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 20.9K bytes - Viewed (0) -
common-protos/k8s.io/api/policy/v1beta1/generated.proto
// readOnlyRootFilesystem when set to true will force containers to run with a read only root file // system. If the container specifically requests to run with a non-read only root file system // the PSP should deny the pod. // If set to false the container may run with a read only root file system if it wishes but it // will not be forced to. // +optional
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.6K bytes - Viewed (0) -
docs/distributed/SIZING.md
# Erasure code sizing guide ## Toy Setups Capacity constrained environments, MinIO will work but not recommended for production. | servers | drives (per node) | stripe_size | parity chosen (default) | tolerance for reads (servers) | tolerance for writes (servers) | |--------:|------------------:|------------:|------------------------:|------------------------------:|-------------------------------:|
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 15 23:04:20 UTC 2023 - 3.9K bytes - Viewed (0) -
api/go1.9.txt
pkg syscall, type Conn interface { SyscallConn } pkg syscall, type Conn interface, SyscallConn() (RawConn, error) pkg syscall, type RawConn interface { Control, Read, Write } pkg syscall, type RawConn interface, Control(func(uintptr)) error pkg syscall, type RawConn interface, Read(func(uintptr) bool) error pkg syscall, type RawConn interface, Write(func(uintptr) bool) error pkg testing, method (*B) Helper() pkg testing, method (*T) Helper()
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Mon Oct 04 20:20:20 UTC 2021 - 10.7K bytes - Viewed (0) -
internal/event/config.go
rulesMap.Add(queue.ToRulesMap()) } return rulesMap } // ParseConfig - parses data in reader to notification configuration. func ParseConfig(reader io.Reader, region string, targetList *TargetList) (*Config, error) { var config Config if err := xml.NewDecoder(reader).Decode(&config); err != nil { return nil, err } if err := config.Validate(region, targetList); err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Nov 16 17:28:29 UTC 2021 - 8.4K bytes - Viewed (0) -
docs/kms/IAM.md
set the env. variable `MINIO_KMS_SECRET_KEY` and start/restart the MinIO server. For more details about KES and how to set it up refer to our [KMS Guide](https://github.com/minio/minio/blob/master/docs/kms/README.md). Instead of configuring an external KMS you can start with a single key by setting the env. variable `MINIO_KMS_SECRET_KEY`. It expects the following format: ```sh MINIO_KMS_SECRET_KEY=<key-name>:<base64-value>
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_gen.go
package bandwidth // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BucketBandwidthReport) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001--
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/store/store.go
} if vals := strings.Split(key.Name, "."); len(vals) == 2 { key.Extension = "." + vals[1] key.Name = strings.TrimSuffix(key.Name, key.Extension) } return } // replayItems - Reads the items from the store and replays. func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key { keyCh := make(chan Key) go func() { defer xioutil.SafeClose(keyCh)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc
} std::unique_ptr<TFE_Op, decltype(&TFE_DeleteOp)> read_op( TFE_NewOp(context.get(), "ReadVariableOp", status.get()), TFE_DeleteOp); ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get()); TFE_OpSetAttrType(read_op.get(), "dtype", TF_FLOAT); parallel_device.Execute(context.get(), handle_inputs, "ReadVariableOp", TFE_OpGetAttrs(read_op.get()),
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Mon Oct 21 04:14:14 UTC 2024 - 15.6K bytes - Viewed (0)