- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for getDriver (0.08 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 15.7K 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 Nov 03 19:28:11 UTC 2024 - 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K 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 Nov 03 03:35:11 UTC 2024 - Last Modified: Sat Aug 10 22:21:50 UTC 2024 - 4.1K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractorTest.java
if (!isMultipartRequest(request) || !request.getMethod().equals(HttpMethods.POST)) { response.setStatus(HttpServletResponse.SC_BAD_REQUEST); response.getWriter().println(HttpServletResponse.SC_BAD_REQUEST); HttpConnection.getCurrentConnection().getRequest().setHandled(true); return; } try {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 5.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/WebApiResponse.java
public class WebApiResponse extends HttpServletResponseWrapper { public WebApiResponse(final HttpServletResponse response) { super(response); } @Override public PrintWriter getWriter() throws IOException { // dummy stream return new PrintWriter(new ByteArrayOutputStream()); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 1.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/DriverManagerUtil.java
} } /** * 現在のクラスローダに結びつけられている全てのJDBCドライバを登録解除します。 */ public static synchronized void deregisterAllDrivers() { for (final Enumeration<Driver> e = DriverManager.getDrivers(); e.hasMoreElements();) { deregisterDriver(e.nextElement()); } }
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 3.3K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultPluginXmlFactory.java
PluginDescriptor content = nonNull(request.getContent(), "content"); Path path = request.getPath(); OutputStream outputStream = request.getOutputStream(); Writer writer = request.getWriter(); if (writer == null && outputStream == null && path == null) { throw new IllegalArgumentException("writer, outputStream or path must be non null"); } try {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 12 01:54:46 UTC 2024 - 50.3K bytes - Viewed (0)