Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 281 for stone (0.02 sec)

  1. docs/pt/docs/virtual-environments.md

    ```mermaid
    flowchart LR
        subgraph global[global env]
            harry-1[harry v1]
        end
        subgraph stone-project[philosophers-stone project]
            stone(philosophers-stone) -->|requires| harry-1
        end
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 10 10:37:13 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  2. docs/en/docs/virtual-environments.md

    ```mermaid
    flowchart LR
        subgraph global[global env]
            harry-1[harry v1]
        end
        subgraph stone-project[philosophers-stone project]
            stone(philosophers-stone) -->|requires| harry-1
        end
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 24 03:16:23 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  3. docs/en/docs/deployment/docker.md

    Then you could want to have **a single container** with a **process manager** starting **several worker processes** inside.
    
    ---
    
    The main point is, **none** of these are **rules written in stone** that you have to blindly follow. You can use these ideas to **evaluate your own use case** and decide what is the best approach for your system, checking out how to manage the concepts of:
    
    * Security - HTTPS
    * Running on startup
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  4. cmd/iam-object-store.go

    		logger.Info("IAM expired STS purge took %.2fs", took)
    	}
    
    	// Store the newly populated map in the iam cache. This takes care of
    	// removing stale entries from the existing map.
    	cache.iamSTSAccountsMap = stsAccountsFromStore
    
    	stsAccPoliciesFromStore.Range(func(k string, v MappedPolicy) bool {
    		cache.iamSTSPolicyMap.Store(k, v)
    		return true
    	})
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  5. cmd/iam-etcd-store.go

    	var p MappedPolicy
    	err := ies.loadIAMConfig(ctx, &p, getMappedPolicyPath(name, userType, isGroup))
    	if err != nil {
    		if err == errConfigNotFound {
    			return errNoSuchPolicy
    		}
    		return err
    	}
    	m.Store(name, p)
    	return nil
    }
    
    func getMappedPolicy(kv *mvccpb.KeyValue, m *xsync.MapOf[string, MappedPolicy], basePrefix string) error {
    	var p MappedPolicy
    	err := getIAMConfig(&p, kv.Value, string(kv.Key))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  6. internal/event/target/mysql.go

    // Name - returns the Name of the target.
    func (target *MySQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *MySQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *MySQLTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. internal/event/target/nats.go

    			return nil, fmt.Errorf("unable to initialize the queue store of NATS `%s`: %w", id, err)
    		}
    	}
    
    	target := &NATSTarget{
    		id:         event.TargetID{ID: id, Name: "nats"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    		quitCh:     make(chan struct{}),
    	}
    
    	if target.store != nil {
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  8. internal/event/target/kafka.go

    	if target.store != nil {
    		if args.BatchSize > 1 {
    			target.batch = store.NewBatch[event.Event](store.BatchConfig[event.Event]{
    				Limit:         args.BatchSize,
    				Log:           loggerOnce,
    				Store:         queueStore,
    				CommitTimeout: args.BatchCommitTimeout,
    			})
    		}
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    	}
    
    	return target, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. internal/logger/target/http/http.go

    	queueStore := store.NewQueueStore[interface{}](
    		filepath.Join(h.config.QueueDir, h.Name()),
    		uint64(h.config.QueueSize),
    		httpLoggerExtension,
    	)
    
    	if err := queueStore.Open(); err != nil {
    		return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err)
    	}
    
    	h.store = queueStore
    	store.StreamItems(h.store, h, ctx.Done(), h.config.LogOnceIf)
    
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. internal/event/target/elasticsearch.go

    func (target *ElasticsearchTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *ElasticsearchTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *ElasticsearchTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
Back to top