Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 714 for Contexto (0.1 sec)

  1. cmd/peer-rest-server.go

    	go func() {
    		err := globalTierConfigMgr.Reload(context.Background(), newObjectLayerFn())
    		if err != nil {
    			peersLogIf(context.Background(), fmt.Errorf("Failed to reload remote tier config %s", err))
    		}
    	}()
    
    	return
    }
    
    // ConsoleLogHandler sends console logs of this node back to peer rest client
    func (s *peerRESTServer) ConsoleLogHandler(ctx context.Context, params *grid.MSS, out chan<- *grid.Bytes) *grid.RemoteErr {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  2. scripts/playwright/query_param_models/image01.py

    def run(playwright: Playwright) -> None:
        browser = playwright.chromium.launch(headless=False)
        # Update the viewport manually
        context = browser.new_context(viewport={"width": 960, "height": 1080})
        browser = playwright.chromium.launch(headless=False)
        context = browser.new_context()
        page = context.new_page()
        page.goto("http://localhost:8000/docs")
        page.get_by_role("button", name="GET /items/ Read Items").click()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  3. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cluster-notification.go

    )
    
    // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics.
    func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	if globalEventNotifier == nil {
    		return nil
    	}
    
    	nstats := globalEventNotifier.targetList.Stats()
    	m.Set(notificationCurrentSendInProgress, float64(nstats.CurrentSendCalls))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Apr 24 04:10:35 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. cmd/metrics-v3-logger-webhook.go

    		allWebhookLabels...)
    )
    
    // loadLoggerWebhookMetrics - `MetricsLoaderFn` for logger webhook
    // such as failed messages and total messages.
    func loadLoggerWebhookMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	tgts := append(logger.SystemTargets(), logger.AuditTargets()...)
    	for _, t := range tgts {
    		labels := []string{nameL, t.String(), endpointL, t.Endpoint()}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 14 07:27:33 UTC 2024
    - 2K bytes
    - Viewed (0)
  6. schema/utils.go

    	if strings.Contains(t, value) {
    		return tag
    	}
    	return reflect.StructTag(fmt.Sprintf(`gorm:"%s;%s"`, value, t))
    }
    
    // GetRelationsValues get relations's values from a reflect value
    func GetRelationsValues(ctx context.Context, reflectValue reflect.Value, rels []*Relationship) (reflectResults reflect.Value) {
    	for _, rel := range rels {
    		reflectResults = reflect.MakeSlice(reflect.SliceOf(reflect.PtrTo(rel.FieldSchema.ModelType)), 0, 1)
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Aug 19 13:35:14 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  7. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  8. internal/grid/benchmark_test.go

    	b.Run("bytes", func(b *testing.B) {
    		for par := 1; par <= 32; par *= 2 {
    			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
    				defer timeout(60 * time.Second)()
    				ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    				b.ResetTimer()
    				t := time.Now()
    				var ops int64
    				var lat int64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/ldap/LdapManager.java

            final Hashtable<String, String> env = new Hashtable<>();
            putEnv(env, Context.INITIAL_CONTEXT_FACTORY, initialContextFactory);
            putEnv(env, Context.SECURITY_AUTHENTICATION, securityAuthentication);
            putEnv(env, Context.PROVIDER_URL, providerUrl);
            putEnv(env, Context.SECURITY_PRINCIPAL, principal);
            putEnv(env, Context.SECURITY_CREDENTIALS, credntials);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 65.9K bytes
    - Viewed (0)
  10. internal/event/targetlist.go

    	currentSendCalls  atomic.Int64
    	totalEvents       atomic.Int64
    	eventsSkipped     atomic.Int64
    	eventsErrorsTotal atomic.Int64
    
    	sync.RWMutex
    	targets map[TargetID]Target
    	queue   chan asyncEvent
    	ctx     context.Context
    
    	statLock    sync.RWMutex
    	targetStats map[TargetID]targetStat
    }
    
    type targetStat struct {
    	// The number of concurrent async Send calls per targets
    	currentSendCalls int64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
Back to top