Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 1,087 for contextos (0.1 sec)

  1. internal/config/lambda/target/webhook.go

    	if !yes {
    		return errNotConnected
    	}
    
    	return nil
    }
    
    // NewWebhookTarget - creates new Webhook target.
    func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) {
    	ctx, cancel := context.WithCancel(ctx)
    
    	target := &WebhookTarget{
    		id:         event.TargetID{ID: id, Name: "webhook"},
    		args:       args,
    		loggerOnce: loggerOnce,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/IterablesFilterArrayListTest.java

    public final class IterablesFilterArrayListTest
        extends AbstractFilteredIterableTest<Iterable<Integer>> {
      @Override
      Iterable<Integer> createUnfiltered(Iterable<Integer> contents) {
        return Lists.newArrayList(contents);
      }
    
      @Override
      Iterable<Integer> filter(Iterable<Integer> elements, Predicate<? super Integer> predicate) {
        return Iterables.filter(elements, predicate);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Mar 16 21:55:55 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    	// Be sure that they are included in toHealingDisk
    }
    
    // loadHealingTracker will load the healing tracker from the supplied disk.
    // The disk ID will be validated against the loaded one.
    func loadHealingTracker(ctx context.Context, disk StorageAPI) (*healingTracker, error) {
    	if disk == nil {
    		return nil, errors.New("loadHealingTracker: nil drive given")
    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. internal/http/dial_dnscache.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  5. cmd/sftp-server-driver.go

    	}
    	ok, err := clnt.BucketExists(r.Context(), bucket)
    	if err != nil {
    		return nil, err
    	}
    	if !ok {
    		return nil, os.ErrNotExist
    	}
    
    	pr, pw := io.Pipe()
    
    	wa := &writerAt{
    		buffer: make(map[int64][]byte),
    		w:      pw,
    		r:      pr,
    		wg:     &sync.WaitGroup{},
    	}
    	wa.wg.Add(1)
    	go func() {
    		oi, err := clnt.PutObject(r.Context(), bucket, object, pr, -1, minio.PutObjectOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/ProtoSession.java

        }
    
        protected ProtoSession(
                RepositorySystemSession session,
                RepositorySystem repositorySystem,
                List<RemoteRepository> repositories,
                List<org.eclipse.aether.repository.RemoteRepository> resolverRepositories,
                Lookup lookup,
                Context context) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  7. compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/PropertyProfileActivator.java

                        .setLocation(property.getLocation("")));
                return false;
            }
    
            String sysValue = context.getUserProperties().get(name);
            if (sysValue == null) {
                sysValue = context.getSystemProperties().get(name);
            }
    
            String propValue = property.getValue();
            if (propValue != null && !propValue.isEmpty()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    	healingMetricBucket healingMetric = iota
    	healingMetricObject
    	healingMetricCheckAbandonedParts
    )
    
    func (er erasureObjects) listAndHeal(ctx context.Context, bucket, prefix string, scanMode madmin.HealScanMode, healEntry func(string, metaCacheEntry, madmin.HealScanMode) error) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	disks, _ := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  9. cmd/metrics-v3-cluster-config.go

    		"Standard storage class parity")
    )
    
    // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config
    // such as standard and RRS parity.
    func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	clusterDriveMetrics, err := c.clusterDriveMetrics.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/collect/testing/TestContainerGenerator.java

       * its input unmodified. Provided that the test suite is built without {@link
       * com.google.common.collect.testing.features.CollectionFeature#KNOWN_ORDER}, the tests will look
       * only at the returned contents without regard for order.
       */
      Iterable<E> order(List<E> insertionOrder);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 21 16:49:06 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top