- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 392 for jstream (0.18 sec)
-
src/main/java/org/codelibs/fess/dict/DictionaryFile.java
import java.util.Iterator; import java.util.List; import java.util.ListIterator; import org.codelibs.curl.CurlResponse; import org.dbflute.optional.OptionalEntity; import org.lastaflute.web.servlet.request.stream.WrittenStreamOut; public abstract class DictionaryFile<T extends DictionaryItem> { protected DictionaryManager dictionaryManager; protected String id; protected String path;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 6.8K bytes - Viewed (0) -
docs/orchestration/README.md
|:---------------------------------------------------------------------------------------------------| | [`Kubernetes`](https://min.io/docs/minio/kubernetes/upstream/index.html#quickstart-for-kubernetes) | ## Why is MinIO cloud-native?
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 2.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/cache/CacheAction.java
if (content == null) { saveError(messages -> messages.addErrorsDocidNotFound(GLOBAL, form.docId)); return redirect(ErrorAction.class); } final StreamResponse response = asStream(DocumentUtil.getValue(doc, fessConfig.getIndexFieldDocId(), String.class)) .contentType("text/html; charset=UTF-8").data(content.getBytes(Constants.CHARSET_UTF_8));
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.4K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex.go
// the text of the most recently returned token is, and where it was found. // The underlying scanner elides all spaces except newline, so the input looks like a stream of // Tokens; original spacing is lost but we don't need it. type TokenReader interface { // Next returns the next token. Next() ScanToken // The following methods all refer to the most recent token returned by Next.
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 4.1K bytes - Viewed (0) -
internal/http/transports.go
TLSClientConfig: &tlsClientConfig, ForceAttemptHTTP2: s.EnableHTTP2, // Go net/http automatically unzip if content-type is // gzip disable this feature, as we are always interested // in raw stream. DisableCompression: true, } // https://github.com/golang/go/issues/23559 // https://github.com/golang/go/issues/42534 // https://github.com/golang/go/issues/43989 // https://github.com/golang/go/issues/33425
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
cmd/storage-interface.go
StatVol(ctx context.Context, volume string) (vol VolInfo, err error) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr. WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 5.2K 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
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 15 11:55:55 UTC 2020 - 2.7K bytes - Viewed (0) -
docs/bucket/replication/DESIGN.md
"x-minio-internal-tier-free-versionID": "OWZlZjk5N2QtMjMzZi00N2U3LTlkZmMtNWYxNzc3NzdlZTM2" }, "MetaUsr": { "X-Amz-Replication-Status": "COMPLETED", "content-type": "application/octet-stream", "etag": "8315e643ed6a5d7c9962fc0a8ef9c11f" }, ... ``` ### Metadata for object replication - on target ``` ... "MetaSys": { "x-minio-internal-inline-data": "dHJ1ZQ==",
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
internal/grid/muxserver.go
wg.Add(1) go func() { defer wg.Done() var ack message ack.Op = OpAckMux ack.Flags = m.BaseFlags ack.MuxID = m.ID m.send(ack) if debugPrint { fmt.Println("connected stream mux:", ack.MuxID) } }() // Data inbound to the handler var handlerIn chan []byte if inboundCap > 0 { m.inbound = make(chan []byte, inboundCap) handlerIn = make(chan []byte, 1)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
docs/distributed/README.md
Install MinIO either on Kubernetes or Distributed Linux. Install MinIO on Kubernetes: - [MinIO Quickstart Guide for Kubernetes](https://min.io/docs/minio/kubernetes/upstream/index.html#quickstart-for-kubernetes). - [Deploy a Tenant from the MinIO Operator](https://min.io/docs/minio/kubernetes/upstream/operations/install-deploy-manage/deploy-minio-tenant.html) Install Distributed MinIO on Linux:
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.8K bytes - Viewed (0)