- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 277 for mkchan (0.05 sec)
-
schema/schema.go
- BeforeCreate, AfterCreate bool
- BeforeUpdate, AfterUpdate bool
- BeforeDelete, AfterDelete bool
- BeforeSave, AfterSave bool
- AfterFind bool
- err error
- initialized chan struct{}
- namer Namer
- cacheStore *sync.Map
- }
- func (schema Schema) String() string {
- if schema.ModelType.Name() == "" {
- 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) -
cmd/data-usage.go
- dataUsageCacheName = ".usage-cache.bin"
- )
- // storeDataUsageInBackend will store all objects sent on the dui channel until closed.
- func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) {
- attempts := 1
- for dataUsageInfo := range dui {
- json := jsoniter.ConfigCompatibleWithStandardLibrary
- dataUsageJSON, err := json.Marshal(dataUsageInfo)
- if err != nil {
- 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) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/Platform.java
- import jsinterop.annotations.JsType;
- import org.checkerframework.checker.nullness.qual.Nullable;
- /**
- * Minimal GWT emulation of {@code com.google.common.collect.Platform}.
- *
- * @author Hayward Chan
- */
- final class Platform {
- static <K, V> Map<K, V> newHashMapWithExpectedSize(int expectedSize) {
- return Maps.newHashMapWithExpectedSize(expectedSize);
- }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Aug 06 17:52:51 UTC 2024 - 5K bytes - Viewed (0) -
internal/lock/lock_test.go
- // try lock the unlocked file
- dupl, err := LockedOpenFile(f.Name(), os.O_WRONLY|os.O_CREATE, 0o600)
- if err != nil {
- t.Errorf("err = %v, want %v", err, nil)
- }
- // blocking on locked file
- locked := make(chan struct{}, 1)
- go func() {
- bl, blerr := LockedOpenFile(f.Name(), os.O_WRONLY, 0o600)
- if blerr != nil {
- t.Error(blerr)
- return
- }
- locked <- struct{}{}
- 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) -
internal/grid/debug.go
- hosts, listeners, err := getHosts(n)
- if err != nil {
- return nil, err
- }
- dialer := &net.Dialer{
- Timeout: 5 * time.Second,
- }
- var res TestGrid
- res.Hosts = hosts
- ready := make(chan struct{})
- ctx, cancel := context.WithCancel(context.Background())
- res.cancel = cancel
- for i, host := range hosts {
- manager, err := NewManager(ctx, ManagerOptions{
- 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) -
cmd/data-scanner.go
- // cycle will be closed
- cycle chan struct{}
- // isScanner should be set when this is used by the scanner
- // to record metrics.
- isScanner bool
- }
- // newDynamicSleeper
- func newDynamicSleeper(factor float64, maxWait time.Duration, isScanner bool) *dynamicSleeper {
- return &dynamicSleeper{
- factor: factor,
- cycle: make(chan struct{}),
- 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) -
internal/event/target/webhook.go
- id event.TargetID
- args WebhookArgs
- transport *http.Transport
- httpClient *http.Client
- store store.Store[event.Event]
- loggerOnce logger.LogOnce
- cancel context.CancelFunc
- cancelCh <-chan struct{}
- addr string // full address ip/dns with a port number, e.g. x.x.x.x:8080
- }
- // ID - returns target ID.
- func (target *WebhookTarget) ID() event.TargetID {
- return target.id
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
- type ElasticsearchTarget struct {
- initOnce once.Init
- id event.TargetID
- args ElasticsearchArgs
- client esClient
- store store.Store[event.Event]
- loggerOnce logger.LogOnce
- quitCh chan struct{}
- }
- // ID - returns target ID.
- func (target *ElasticsearchTarget) ID() event.TargetID {
- return target.id
- }
- // 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) -
docs/es/docs/features.md
- `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.
- 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) -
internal/ioutil/ioutil.go
- func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) {
- ctx, cancel := context.WithTimeout(ctx, timeout)
- defer cancel()
- c := make(chan ioret[V], 1)
- go func() {
- v, err := work(ctx)
- c <- ioret[V]{val: v, err: err}
- }()
- select {
- case v := <-c:
- return v.val, v.err
- case <-ctx.Done():
- 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)