Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2261 - 2270 of 2,532 for created (0.08 sec)

  1. internal/event/target/nsq.go

    		return err
    	}
    
    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	if !yes {
    		return store.ErrNotConnected
    	}
    
    	return nil
    }
    
    // NewNSQTarget - creates new NSQ target.
    func NewNSQTarget(id string, args NSQArgs, loggerOnce logger.LogOnce) (*NSQTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    				return
    			default:
    				// There was error in the REST request, retry after sometime as probably the peer is down.
    				time.Sleep(5 * time.Second)
    			}
    		}
    	}()
    }
    
    // newPeerRestClients creates new peer clients.
    // The two slices will point to the same clients,
    // but 'all' will contain nil entry for local client.
    // The 'all' slice will be in the same order across the cluster.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. common-protos/k8s.io/api/certificates/v1beta1/generated.proto

      optional string type = 1;
    
      // Status of the condition, one of True, False, Unknown.
      // Approved, Denied, and Failed conditions may not be "False" or "Unknown".
      // Defaults to "True".
      // If unset, should be treated as "True".
      // +optional
      optional string status = 6;
    
      // brief reason for the request state
      // +optional
      optional string reason = 2;
    
      // human readable message with details about the request state
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/graph/NetworkBuilder.java

      boolean allowsParallelEdges = false;
      ElementOrder<? super E> edgeOrder = ElementOrder.insertion();
      Optional<Integer> expectedEdgeCount = Optional.absent();
    
      /** Creates a new instance with the specified edge directionality. */
      private NetworkBuilder(boolean directed) {
        super(directed);
      }
    
      /** Returns a {@link NetworkBuilder} for building directed networks. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 03 01:21:31 UTC 2022
    - 7.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/xml/XmlEscapers.java

        Escapers.Builder builder = Escapers.builder();
        // The char values \uFFFE and \uFFFF are explicitly not allowed in XML
        // (Unicode code points above \uFFFF are represented via surrogate pairs
        // which means they are treated as pairs of safe characters).
        builder.setSafeRange(Character.MIN_VALUE, '\uFFFD');
        // Unsafe characters are replaced with the Unicode replacement character.
        builder.setUnsafeReplacement("\uFFFD");
    
        /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 18 20:55:09 UTC 2022
    - 6.5K bytes
    - Viewed (0)
  6. cmd/bucket-lifecycle-handlers.go

    		return
    	}
    
    	// Validate the transition storage ARNs
    	if err = validateTransitionTier(bucketLifecycle); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Create a map of updated set of rules in request
    	updatedRules := make(map[string]lifecycle.Rule, len(bucketLifecycle.Rules))
    	for _, rule := range bucketLifecycle.Rules {
    		updatedRules[rule.ID] = rule
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7K bytes
    - Viewed (0)
  7. helm/minio/templates/statefulset.yaml

          {{- if and .Values.securityContext.enabled .Values.persistence.enabled }}
          securityContext:
            {{- omit .Values.securityContext "enabled" | toYaml | nindent 8 }}
          {{- end }}
          {{- if .Values.serviceAccount.create }}
          serviceAccountName: {{ .Values.serviceAccount.name }}
          {{- end }}
          containers:
            - name: {{ .Chart.Name }}
              image: {{ .Values.image.repository }}:{{ .Values.image.tag }}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 11 12:21:05 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbFileHandleImpl.java

    import jcifs.CIFSException;
    import jcifs.Configuration;
    import jcifs.SmbFileHandle;
    import jcifs.internal.smb1.com.SmbComBlankResponse;
    import jcifs.internal.smb1.com.SmbComClose;
    import jcifs.internal.smb2.create.Smb2CloseRequest;
    import jcifs.util.Hexdump;
    
    
    /**
     * @author mbechler
     *
     */
    class SmbFileHandleImpl implements SmbFileHandle {
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 8.6K bytes
    - Viewed (1)
  9. src/test/java/jcifs/tests/EnumTest.java

            CIFSContext ctx = withAnonymousCredentials();
            try ( SmbFile smbFile = new SmbFile("smb://" + getRequiredProperty(TestProperties.TEST_DOMAIN_SHORT), ctx) ) {
                // if domain is resolved through DNS this will be treated as a server and will enumerate shares instead
                Assume.assumeTrue("Not workgroup", SmbConstants.TYPE_WORKGROUP == smbFile.getType());
                try ( CloseableIterator<SmbResource> it = smbFile.children() ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:09:03 UTC 2023
    - 25.5K bytes
    - Viewed (0)
  10. .teamcity/performance-test-durations.json

      "durations" : [ {
        "testProject" : "archivePerformanceProject",
        "linux" : 299
      } ]
    }, {
      "scenario" : "org.gradle.performance.regression.corefeature.DeprecationCreationPerformanceTest.create many deprecation warnings",
      "durations" : [ {
        "testProject" : "generateLotsOfDeprecationWarnings",
        "linux" : 140
      } ]
    }, {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Sep 12 14:38:24 UTC 2024
    - 27.9K bytes
    - Viewed (0)
Back to top