Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 714 for Contexto (0.32 sec)

  1. cmd/metrics-v3-cluster-usage.go

    		"Cluster object version count distribution", "range")
    )
    
    // loadClusterUsageObjectMetrics - reads cluster usage metrics.
    //
    // This is a `MetricsLoaderFn`.
    func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    	// data usage has not captured any data yet.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jul 14 18:11:42 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. cmd/bootstrap-peer-server.go

    }
    
    // client to talk to bootstrap NEndpoints.
    type bootstrapRESTClient struct {
    	gridConn *grid.Connection
    }
    
    // Verify function verifies the server config.
    func (client *bootstrapRESTClient) Verify(ctx context.Context, srcCfg *ServerSystemConfig) (err error) {
    	if newObjectLayerFn() != nil {
    		return nil
    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. cmd/sftp-server_test.go

    	if err == nil || !errors.Is(err, errNoSuchUser) {
    		c.Fatalf("expected err(%s) but got (%s)", errNoSuchUser, err)
    	}
    }
    
    func (s *TestSuiteIAM) SFTPInvalidServiceAccountPassword(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
    	defer cancel()
    
    	accessKey, secretKey := mustGenerateCredentials(c)
    	err := s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  4. internal/http/listener_test.go

    	}
    
    nextTest:
    	for i, testCase := range testCases {
    		listener, errs := newHTTPListener(context.Background(),
    			testCase.serverAddrs,
    			TCPOptions{},
    		)
    		for _, err := range errs {
    			if err != nil {
    				if strings.Contains(err.Error(), "The requested address is not valid in its context") {
    					// Ignore if IP is unbindable.
    					continue nextTest
    				}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. cmd/metrics-v3-audit.go

    		"Total number of messages sent since start",
    		targetID)
    )
    
    // loadAuditMetrics - `MetricsLoaderFn` for audit
    // such as failed messages and total messages.
    func loadAuditMetrics(_ context.Context, m MetricValues, c *metricsCache) error {
    	audit := logger.CurrentStats()
    	for id, st := range audit {
    		labels := []string{targetID, id}
    		m.Set(auditFailedMessages, float64(st.FailedMessages), labels...)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 10 14:50:39 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  6. internal/event/target/webhook.go

    		return store.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)
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/helper/QueryHelperTest.java

        }
    
        private void assertQuery(QueryBuilder query1, QueryContext context) {
            assertQuery(query1, null, null, context);
        }
    
        private void assertQuery(QueryBuilder query1, Map<String, List<String>> fieldLogMap, Set<String> highlightedQuerySet,
                QueryContext context) {
            assertEquals(query1.toString(), context.getQueryBuilder().toString());
            assertFieldLogs(fieldLogMap);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Jul 11 08:26:36 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  8. cmd/bootstrap-messages.go

    	bs.mu.RLock()
    	for _, i := range bs.info {
    		traceInfo = append(traceInfo, i)
    	}
    	bs.mu.RUnlock()
    
    	return traceInfo
    }
    
    func (bs *bootstrapTracer) Publish(ctx context.Context, trace *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) {
    	for _, bsEvent := range bs.Events() {
    		if bsEvent.Message != "" {
    			select {
    			case <-ctx.Done():
    			default:
    				trace.Publish(bsEvent)
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  9. cmd/metrics-v3-ilm.go

    )
    
    // loadILMMetrics - `MetricsLoaderFn` for ILM metrics.
    func loadILMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	if globalExpiryState != nil {
    		m.Set(expiryPendingTasks, float64(globalExpiryState.PendingTasks()))
    	}
    	if globalTransitionState != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jun 06 09:36:25 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  10. internal/http/check_port_others.go

    func CheckPortAvailability(host, port string, opts TCPOptions) (err error) {
    	lc := &net.ListenConfig{}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    	// Close the listener and continue check other networks.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
Back to top