Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 277 for mkchan (0.05 sec)

  1. schema/schema.go

    1. BeforeCreate, AfterCreate bool
    2. BeforeUpdate, AfterUpdate bool
    3. BeforeDelete, AfterDelete bool
    4. BeforeSave, AfterSave bool
    5. AfterFind bool
    6. err error
    7. initialized chan struct{}
    8. namer Namer
    9. cacheStore *sync.Map
    10. }
    11.  
    12. func (schema Schema) String() string {
    13. if schema.ModelType.Name() == "" {
    14. return fmt.Sprintf("%s(%s)", schema.Name, schema.Table)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 12:19:31 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  2. cmd/data-usage.go

    1. dataUsageCacheName = ".usage-cache.bin"
    2. )
    3.  
    4. // storeDataUsageInBackend will store all objects sent on the dui channel until closed.
    5. func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) {
    6. attempts := 1
    7. for dataUsageInfo := range dui {
    8. json := jsoniter.ConfigCompatibleWithStandardLibrary
    9. dataUsageJSON, err := json.Marshal(dataUsageInfo)
    10. if err != nil {
    11. scannerLogIf(ctx, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/Platform.java

    1. import jsinterop.annotations.JsType;
    2. import org.checkerframework.checker.nullness.qual.Nullable;
    3.  
    4. /**
    5. * Minimal GWT emulation of {@code com.google.common.collect.Platform}.
    6. *
    7. * @author Hayward Chan
    8. */
    9. final class Platform {
    10. static <K, V> Map<K, V> newHashMapWithExpectedSize(int expectedSize) {
    11. return Maps.newHashMapWithExpectedSize(expectedSize);
    12. }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:52:51 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. internal/lock/lock_test.go

    1. // try lock the unlocked file
    2. dupl, err := LockedOpenFile(f.Name(), os.O_WRONLY|os.O_CREATE, 0o600)
    3. if err != nil {
    4. t.Errorf("err = %v, want %v", err, nil)
    5. }
    6.  
    7. // blocking on locked file
    8. locked := make(chan struct{}, 1)
    9. go func() {
    10. bl, blerr := LockedOpenFile(f.Name(), os.O_WRONLY, 0o600)
    11. if blerr != nil {
    12. t.Error(blerr)
    13. return
    14. }
    15. locked <- struct{}{}
    16. if blerr = bl.Close(); blerr != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  5. internal/grid/debug.go

    1. hosts, listeners, err := getHosts(n)
    2. if err != nil {
    3. return nil, err
    4. }
    5. dialer := &net.Dialer{
    6. Timeout: 5 * time.Second,
    7. }
    8. var res TestGrid
    9. res.Hosts = hosts
    10. ready := make(chan struct{})
    11. ctx, cancel := context.WithCancel(context.Background())
    12. res.cancel = cancel
    13. for i, host := range hosts {
    14. manager, err := NewManager(ctx, ManagerOptions{
    15. Dialer: ConnectWS(dialer.DialContext,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. cmd/data-scanner.go

    1. // cycle will be closed
    2. cycle chan struct{}
    3.  
    4. // isScanner should be set when this is used by the scanner
    5. // to record metrics.
    6. isScanner bool
    7. }
    8.  
    9. // newDynamicSleeper
    10. func newDynamicSleeper(factor float64, maxWait time.Duration, isScanner bool) *dynamicSleeper {
    11. return &dynamicSleeper{
    12. factor: factor,
    13. cycle: make(chan struct{}),
    14. maxSleep: maxWait,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  7. internal/event/target/webhook.go

    1. id event.TargetID
    2. args WebhookArgs
    3. transport *http.Transport
    4. httpClient *http.Client
    5. store store.Store[event.Event]
    6. loggerOnce logger.LogOnce
    7. cancel context.CancelFunc
    8. cancelCh <-chan struct{}
    9.  
    10. addr string // full address ip/dns with a port number, e.g. x.x.x.x:8080
    11. }
    12.  
    13. // ID - returns target ID.
    14. func (target *WebhookTarget) ID() event.TargetID {
    15. return target.id
    16. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. internal/event/target/elasticsearch.go

    1. type ElasticsearchTarget struct {
    2. initOnce once.Init
    3.  
    4. id event.TargetID
    5. args ElasticsearchArgs
    6. client esClient
    7. store store.Store[event.Event]
    8. loggerOnce logger.LogOnce
    9. quitCh chan struct{}
    10. }
    11.  
    12. // ID - returns target ID.
    13. func (target *ElasticsearchTarget) ID() event.TargetID {
    14. return target.id
    15. }
    16.  
    17. // Name - returns the Name of the target.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  9. docs/es/docs/features.md

    1. `FastAPI` es realmente una sub-clase de `Starlette`. Así que, si ya conoces o usas Starlette, muchas de las características funcionarán de la misma manera.
    2.  
    3. Con **FastAPI** obtienes todas las características de **Starlette** (porque FastAPI es simplemente Starlette en esteroides):
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 19 18:15:21 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  10. internal/ioutil/ioutil.go

    1. func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) {
    2. ctx, cancel := context.WithTimeout(ctx, timeout)
    3. defer cancel()
    4.  
    5. c := make(chan ioret[V], 1)
    6. go func() {
    7. v, err := work(ctx)
    8. c <- ioret[V]{val: v, err: err}
    9. }()
    10.  
    11. select {
    12. case v := <-c:
    13. return v.val, v.err
    14. case <-ctx.Done():
    15. var zero V
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top