- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for getDriver (0.69 sec)
-
cmd/tier.go
binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion) // Marshal the tier config return config.MarshalMsg(data) } // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName func (config *TierConfigMgr) getDriver(ctx context.Context, tierName string) (d WarmBackend, err error) { config.Lock() defer config.Unlock() var ok bool
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/tier-sweeper.go
type jentry struct { ObjName string VersionID string TierName string } func deleteObjectFromRemoteTier(ctx context.Context, objName, rvID, tierName string) error { w, err := globalTierConfigMgr.getDriver(ctx, tierName) if err != nil { return err } return w.Remove(ctx, objName, remoteVersionID(rvID))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 17 05:09:58 UTC 2024 - 4.7K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
func getTransitionedObjectReader(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, oi ObjectInfo, opts ObjectOptions) (gr *GetObjectReader, err error) { tgtClient, err := globalTierConfigMgr.getDriver(ctx, oi.TransitionedObject.Tier) if err != nil { return nil, fmt.Errorf("transition storage class not configured: %w", err) } fn, off, length, err := NewGetObjectReader(rs, oi, opts, h) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0) -
cmd/erasure-object.go
} // TransitionObject - transition object content to target tier. func (er erasureObjects) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error { tgtClient, err := globalTierConfigMgr.getDriver(ctx, opts.Transition.Tier) if err != nil { return err } if !opts.NoLock { // Acquire write lock before starting to transition the object. lk := er.NewNSLock(bucket, object)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/XmlWriterRequest.java
*/ @Experimental public interface XmlWriterRequest<T> { @Nullable Path getPath(); @Nullable OutputStream getOutputStream(); @Nullable Writer getWriter(); @Nonnull T getContent(); @Nullable Function<Object, String> getInputLocationFormatter(); static <T> XmlWriterRequestBuilder<T> builder() {
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Aug 10 22:21:50 UTC 2024 - 4.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/WebApiResponse.java
* * @return A PrintWriter for response output * @throws IOException If an I/O error occurs */ @Override public PrintWriter getWriter() throws IOException { // dummy stream return new PrintWriter(new ByteArrayOutputStream()); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 1.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/DriverManagerUtil.java
/** * Deregisters all JDBC drivers associated with the current class loader. */ public static synchronized void deregisterAllDrivers() { for (final Enumeration<Driver> e = DriverManager.getDrivers(); e.hasMoreElements();) { deregisterDriver(e.nextElement()); } }
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 3.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/api/WebApiManagerTest.java
public void process(HttpServletRequest request, HttpServletResponse response, FilterChain chain) throws IOException, ServletException { response.setStatus(200); response.getWriter().write(responseContent); } } private static class ErrorWebApiManager implements WebApiManager { @Override public boolean matches(HttpServletRequest request) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 26.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/cors/CorsHandlerTest.java
@Override public jakarta.servlet.ServletOutputStream getOutputStream() { return null; } @Override public java.io.PrintWriter getWriter() { return null; } @Override public void setCharacterEncoding(String charset) { } @Override
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 25.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/filter/CorsFilterTest.java
} @Override public jakarta.servlet.ServletOutputStream getOutputStream() { return null; } @Override public java.io.PrintWriter getWriter() { return null; } @Override public void setCharacterEncoding(String charset) { } @Override public void setContentLength(int len) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 22.1K bytes - Viewed (0)