- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 914 for readFn (0.07 sec)
-
internal/bucket/versioning/versioning.go
func (v Versioning) PrefixesExcluded() bool { return len(v.ExcludedPrefixes) > 0 || v.ExcludeFolders } // ParseConfig - parses data in given reader to VersioningConfiguration. func ParseConfig(reader io.Reader) (*Versioning, error) { var v Versioning if err := xml.NewDecoder(reader).Decode(&v); err != nil { return nil, err } if err := v.Validate(); err != nil { return nil, err } return &v, nil
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/EncryptInvoker.java
import org.apache.maven.cling.invoker.LookupContext; import org.apache.maven.cling.invoker.LookupInvoker; import org.apache.maven.cling.utils.CLIReportingUtils; import org.jline.reader.LineReaderBuilder; import org.jline.reader.UserInterruptException; import org.jline.terminal.Terminal; import org.jline.utils.AttributedStyle; import org.jline.utils.Colors; /** * mvnenc invoker implementation. */
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jun 11 13:14:09 UTC 2025 - 4.5K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/UpgradeInvoker.java
import org.apache.maven.cling.invoker.LookupContext; import org.apache.maven.cling.invoker.LookupInvoker; import org.apache.maven.cling.utils.CLIReportingUtils; import org.jline.reader.LineReaderBuilder; import org.jline.reader.UserInterruptException; import org.jline.terminal.Terminal; import org.jline.utils.AttributedStyle; import org.jline.utils.Colors; /** * mvnup invoker implementation. */
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jun 11 13:14:09 UTC 2025 - 4.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/DefaultMetadataReader.java
public class DefaultMetadataReader implements MetadataReader { @Override public Metadata read(File input, Map<String, ?> options) throws IOException { Objects.requireNonNull(input, "input cannot be null"); return read(Files.newInputStream(input.toPath()), options); } @Override public Metadata read(Reader input, Map<String, ?> options) throws IOException {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 2.9K bytes - Viewed (0) -
CONTRIBUTING.md
The [Kubernetes community repo](https://github.com/kubernetes/community) contains information about how to get started, how the community organizes, and more. ## Sign the CLA
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Nov 18 13:04:48 UTC 2020 - 525 bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsElevateWordCA.java
} public void setReading_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) { setReading_Terms("reading", opLambda, null); } public void setReading_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsElevateWordCA> aggsLambda) { setReading_Terms("reading", opLambda, aggsLambda); }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 54.6K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
return } data, err := io.ReadAll(r.Body) if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL) return } reader := bytes.NewReader(data) zr, err := zip.NewReader(reader, int64(len(data))) if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL) return } rpt := importMetaReport{ madmin.BucketMetaImportErrs{
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 33.3K bytes - Viewed (0) -
src/main/java/jcifs/pac/Pac.java
int bufferCount = pacStream.readInt(); int version = pacStream.readInt(); if (version != PacConstants.PAC_VERSION) { throw new PACDecodingException("Unrecognized PAC version " + version); } for (int bufferIndex = 0; bufferIndex < bufferCount; bufferIndex++) { int bufferType = pacStream.readInt();Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.3K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) { // This is not timing the actual read operation, but the time it takes to prepare the reader. stopFn := globalSftpMetrics.log(r, f.AccessKey()) defer stopFn(0, err) flags := r.Pflags() if !flags.Read { // sanity check return nil, os.ErrInvalid } bucket, object := path2BucketObject(r.Filepath) if bucket == "" {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0) -
internal/ioutil/ioutil.go
for s.skipCount > 0 { if l > s.skipCount { l = s.skipCount } n, err := s.Reader.Read(tmp[:l]) if err != nil { return 0, err } s.skipCount -= int64(n) } } return s.Reader.Read(p) } // NewSkipReader - creates a SkipReader func NewSkipReader(r io.Reader, n int64) io.Reader { return &SkipReader{r, n} }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 11.1K bytes - Viewed (0)