- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 110 for iostream (0.28 sec)
-
docs/debugging/inspect/decrypt-v2.go
} extracted := false for { stream, err := sr.NextStream() if err != nil { if err == io.EOF { if extracted { return nil } return errors.New("no data found on stream") } if errors.Is(err, estream.ErrNoKey) { if stream.Name == "inspect.zip" { return errors.New("incorrect private key") } if err := stream.Skip(); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K bytes - Viewed (0) -
.github/workflows/mint/nginx.conf
sendfile on; keepalive_timeout 65; # include /etc/nginx/conf.d/*.conf; upstream minio { server minio1:9000; server minio2:9000; server minio3:9000; server minio4:9000; } upstream console { ip_hash; server minio1:9001; server minio2:9001; server minio3:9001; server minio4:9001;
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 31 21:38:10 GMT 2023 - 3K bytes - Viewed (0) -
internal/s3select/sql/evaluate.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package sql import ( "encoding/json" "errors" "fmt" "math" "strings" "github.com/bcicen/jstream" "github.com/minio/simdjson-go" ) var ( errInvalidASTNode = errors.New("invalid AST Node") errExpectedBool = errors.New("expected bool")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 12K bytes - Viewed (0) -
.github/workflows/multipart/nginx-site1.conf
sendfile on; keepalive_timeout 65; # include /etc/nginx/conf.d/*.conf; upstream minio { server site1-minio1:9000; server site1-minio2:9000; server site1-minio3:9000; server site1-minio4:9000; } server { listen 9001; listen [::]:9001; server_name localhost;
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Sep 30 10:13:56 GMT 2023 - 1.7K bytes - Viewed (0) -
docs/sts/dex.yaml
skipApprovalScreen: false # If only one authentication method is enabled, the default behavior is to # go directly to it. For connected IdPs, this redirects the browser away # from application to upstream provider such as the Google login page alwaysShowLoginScreen: false # Uncommend the passwordConnector to use a specific connector for password grants passwordConnector: local
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jul 15 11:55:55 GMT 2020 - 2.7K bytes - Viewed (1) -
cmd/erasure.go
// bucketResults channel while the // updates-collector goroutine still // holds a reference to this. wg.Wait() continue } wg.Wait() // Flatten for upstream, but save full state. var root dataUsageEntry if r := cache.root(); r != nil { root = cache.flatten(*r) if root.ReplicationStats.empty() { root.ReplicationStats = nil } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
docs/bigdata/README.md
- Install MinIO Distributed Server using one of the guides below. - [Deployment based on Kubernetes](https://min.io/docs/minio/kubernetes/upstream/index.html#quickstart-for-kubernetes) - [Deployment based on MinIO Helm Chart](https://github.com/helm/charts/tree/master/stable/minio) ## **3. Configure Hadoop, Spark, Hive to use MinIO**
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
cmd/generic-handlers.go
return } else if rec != nil { stack := debug.Stack() logger.Error("panic: \"%s %s\": %v\n%s", r.Method, r.URL, rec, string(stack)) // Try to write an error response, upstream may not have written header. writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrInternalError), r.URL) return } }() h.ServeHTTP(w, r) }) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/metacache-set.go
func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) { disks := opts.disks if len(disks) == 0 { return fmt.Errorf("listPathRaw: 0 drives provided") } // Cancel upstream if we finish before we expect. ctx, cancel := context.WithCancel(ctx) defer cancel() // Keep track of fallback disks var fdMu sync.Mutex fds := opts.fallbackDisks
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/admin-handlers.go
if publicKey != nil { w.WriteHeader(200) stream := estream.NewWriter(w) defer stream.Close() clusterKey, err := bytesToPublicKey(getSubnetAdminPublicKey()) if err != nil { bugLogIf(ctx, stream.AddError(err.Error())) return } err = stream.AddKeyEncrypted(clusterKey) if err != nil { bugLogIf(ctx, stream.AddError(err.Error())) return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2)