- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Palmer (0.25 sec)
-
internal/grid/stream.go
"errors" ) // A Stream is a two-way stream. // All responses *must* be read by the caller. // If the call is canceled through the context, // the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
schema/serializer.go
fieldValue interface{} } // Scan implements sql.Scanner interface func (s *serializer) Scan(value interface{}) error { s.value = value return nil } // Value implements driver.Valuer interface func (s serializer) Value() (driver.Value, error) { return s.SerializeValuer.Value(s.Context, s.Field, s.Destination, s.fieldValue) } // SerializerInterface serializer interface
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Mon Mar 18 08:28:46 GMT 2024 - 4.6K bytes - Viewed (0) -
schema/constraint.go
checks[names[0]] = CheckConstraint{Name: names[0], Constraint: strings.Join(names[1:], ","), Field: field} } else { if names[0] == "" { chk = strings.Join(names[1:], ",") } name := schema.namer.CheckerName(schema.Table, field.DBName) checks[name] = CheckConstraint{Name: name, Constraint: chk, Field: field} } } } return checks } type UniqueConstraint struct { Name string Field *Field
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Mon Mar 18 07:33:54 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
Checksum *hash.Checksum MD5Hex string } // fanOutPutObject takes an input source reader and fans out multiple PUT operations // based on the incoming fan-out request, a context cancellation by the caller // would ensure all fan-out operations are canceled.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
r := rand.New(rand.NewSource(time.Now().UnixNano())) retryCtx, cancel := context.WithTimeout(ctx, timeout) defer cancel() for { select { case <-retryCtx.Done(): // Caller context canceled or we timedout, // return false anyways for both situations. return false default: if lm.lock(id, source, isWriteLock) { return true }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/crypto/sse-kms.go
} // There are two possibilities: // - We use a KMS -> There must be non-empty key ID and a KMS data key. // - We use a K/V -> There must be no key ID and no KMS data key. // Otherwise, the caller has passed an invalid argument combination. if keyID == "" && len(kmsKey) != 0 { logger.CriticalIf(context.Background(), errors.New("The key ID must not be empty if a KMS data key is present")) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/os_unix.go
if typ&os.ModeSymlink == os.ModeSymlink && fi.IsDir() { continue } typ = fi.Mode() & os.ModeType } if err = fn(string(name), typ); err == errDoneForNow { // fn() requested to return by caller. return nil } } return err } // Return count entries at the directory dirPath and all entries // if count is set to -1
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
utils/tests/utils.go
t.Errorf("%v: expect: %+v, got %+v", utils.FileWithLineNum(), expect, got) return } if valuer, ok := got.(driver.Valuer); ok { got, _ = valuer.Value() } if valuer, ok := expect.(driver.Valuer); ok { expect, _ = valuer.Value() } if got != nil { got = reflect.Indirect(reflect.ValueOf(got)).Interface() } if expect != nil {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Fri Mar 10 09:21:56 GMT 2023 - 3.9K bytes - Viewed (0) -
istioctl/cmd/options_test.go
) // nolint: lll var expectedOutput = `The following options can be passed to any command: --log_as_json: Whether to format output as JSON or in plain console-friendly format --log_caller: Comma-separated list of scopes for which to include caller information, scopes can be any of \[.*\]
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Sep 14 02:38:54 GMT 2022 - 1.9K bytes - Viewed (0) -
cmd/storage-errors.go
// errLessData - returned when less data available than what was requested. var errLessData = StorageErr("less data available than what was requested") // errMoreData = returned when more data was sent by the caller than what it was supposed to. var errMoreData = StorageErr("more data was sent than what was advertised") // indicates readDirFn to return without further applying the fn() var errDoneForNow = errors.New("done for now")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0)