Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getDriver (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                        }
                    }
                    buf.append('}');
                    buf.append('\n');
                    try {
                        response.getWriter().print(buf.toString());
                    } catch (final IOException e) {
                        throw new IORuntimeException(e);
                    }
                    return true;
                }, OptionalThing.empty());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 50.3K bytes
    - Viewed (0)
Back to top