- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,087 for contextos (0.07 sec)
-
internal/grid/stream.go
// Canceling the context will cause the context cancellation error to be returned. responses <-chan Response cancel context.CancelCauseFunc // Requests sent to the server. // If the handler is defined with 0 incoming capacity this will be nil. // Channel *must* be closed to signal the end of the stream. // If the request context is canceled, the stream will no longer process requests.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
association.go
relValuesMap, _ := schema.GetIdentityFieldValuesMapFromValues(association.DB.Statement.Context, values, rel.FieldSchema.PrimaryFields) cleanUpDeletedRelations := func(data reflect.Value) { if _, zero := rel.Field.ValueOf(association.DB.Statement.Context, data); !zero { fieldValue := reflect.Indirect(rel.Field.ReflectValueOf(association.DB.Statement.Context, data)) primaryValues := make([]interface{}, len(rel.FieldSchema.PrimaryFields))
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 21.5K bytes - Viewed (0) -
internal/event/targetlist_test.go
return nil } func TestTargetListAdd(t *testing.T) { targetListCase1 := NewTargetList(context.Background()) targetListCase2 := NewTargetList(context.Background()) if err := targetListCase2.Add(&ExampleTarget{TargetID{"2", "testcase"}, false, false}); err != nil { panic(err) } targetListCase3 := NewTargetList(context.Background())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0) -
internal/config/crypto_test.go
) var encryptDecryptTests = []struct { Data []byte Context kms.Context }{ { Data: nil, Context: nil, }, { Data: []byte{1}, Context: nil, }, { Data: []byte{1}, Context: kms.Context{"key": "value"}, }, { Data: make([]byte, 1<<20), Context: kms.Context{"key": "value", "a": "b"}, }, } func TestEncryptDecrypt(t *testing.T) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 3.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/PrefixQueryCommand.java
final FessConfig fessConfig = ComponentUtil.getFessConfig(); final String field = getSearchField(context.getDefaultField(), prefixQuery.getField()); final String text = prefixQuery.getPrefix().text(); if (Constants.DEFAULT_FIELD.equals(field)) { context.addFieldLog(field, text + "*");
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.3K bytes - Viewed (0) -
cmd/site-replication-utils.go
} func newSiteResyncMetrics(ctx context.Context) *siteResyncMetrics { s := siteResyncMetrics{ resyncStatus: make(map[string]SiteResyncStatus), peerResyncMap: make(map[string]resyncState), } go s.save(ctx) go s.init(ctx) return &s } // init site resync metrics func (sm *siteResyncMetrics) init(ctx context.Context) { r := rand.New(rand.NewSource(time.Now().UnixNano()))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/ntlmssp/Type2Message.java
* * @param context The local security context. */ public void setContext(byte[] context) { this.context = context; } public byte[] toByteArray() { try { String targetName = getTarget(); byte[] challenge = getChallenge(); byte[] context = getContext(); byte[] targetInformation = getTargetInformation(); int flags = getFlags();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 12.6K bytes - Viewed (0) -
android/guava/src/com/google/common/base/package-info.java
* the License. */ /** * Basic utility libraries and interfaces. * * <p>This package is a part of the open-source <a href="https://github.com/google/guava">Guava</a> * library. * * <h2>Contents</h2> * * The classes in this package that are most commonly useful are: * * <h3>String utilities</h3> * * <ul> * <li>{@link Ascii} * <li>{@link CaseFormat} * <li>{@link CharMatcher}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jun 26 16:48:06 UTC 2023 - 1.8K bytes - Viewed (0) -
cmd/data-usage.go
cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (map[string]uint64, error) { m := make(map[string]uint64) for _, pool := range z.serverPools { for _, er := range pool.sets { // Load bucket usage prefixes ctx, done := context.WithTimeout(ctx, 2*time.Second) ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil done()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 5.6K bytes - Viewed (0) -
internal/once/init.go
return nil } // DoWithContext is similar to Do except that it accepts a context as an argument to be passed. func (l *Init) DoWithContext(ctx context.Context, f func(context.Context) error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doWithContext(ctx, f) } return nil } func (l *Init) doWithContext(ctx context.Context, f func(context.Context) error) error { l.m.Lock() defer l.m.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 09 04:20:31 UTC 2023 - 2.1K bytes - Viewed (0)