- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 1,124 for Nil (0.01 sec)
-
cmd/warm-backend-gcs.go
- return nil, errors.New("no bucket name was provided")
- }
- credsJSON, err := conf.GetCredentialJSON()
- if err != nil {
- return nil, err
- }
- client, err := storage.NewClient(context.Background(),
- option.WithCredentialsJSON(credsJSON),
- option.WithScopes(storage.ScopeReadWrite),
- option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
- )
- if err != nil {
- return nil, err
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 6.1K bytes - Viewed (0) -
callbacks.go
- }
- // assign model values
- if stmt.Model == nil {
- stmt.Model = stmt.Dest
- } else if stmt.Dest == nil {
- stmt.Dest = stmt.Model
- }
- // parse model values
- if stmt.Model != nil {
- if err := stmt.Parse(stmt.Model); err != nil && (!errors.Is(err, schema.ErrUnsupportedDataType) || (stmt.Table == "" && stmt.TableExpr == nil && stmt.SQL.Len() == 0)) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Mar 26 03:33:36 UTC 2024 - 8.6K bytes - Viewed (0) -
scan.go
- if db.Statement.Schema != nil {
- for idx, name := range columns {
- if field := db.Statement.Schema.LookUpField(name); field != nil {
- values[idx] = reflect.New(reflect.PtrTo(field.FieldType)).Interface()
- continue
- }
- values[idx] = new(interface{})
- }
- } else if len(columnTypes) > 0 {
- for idx, columnType := range columnTypes {
- if columnType.ScanType() != nil {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Jun 24 09:42:59 UTC 2024 - 10.1K bytes - Viewed (0) -
internal/crypto/sse-s3.go
- if err != nil {
- return nil, err
- }
- keys = append(keys, key)
- }
- return keys, nil
- }
- // CreateMetadata encodes the sealed object key into the metadata and returns
- // the modified metadata. If the keyID and the kmsKey is not empty it encodes
- // both into the metadata as well. It allocates a new metadata map if metadata
- // is nil.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 7.6K bytes - Viewed (0) -
cmd/batch-rotate.go
- }
- }
- return err
- }
- if GlobalKMS == nil {
- return errKMSNotConfigured
- }
- if err := r.Encryption.Validate(); err != nil {
- return err
- }
- for _, tag := range r.Flags.Filter.Tags {
- if err := tag.Validate(); err != nil {
- return err
- }
- }
- for _, meta := range r.Flags.Filter.Metadata {
- if err := meta.Validate(); err != nil {
- return err
- }
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 14.7K bytes - Viewed (0) -
internal/config/crypto.go
- AssociatedData: associatedData,
- })
- if err != nil {
- return nil, err
- }
- stream, err := metadata.Algorithm.Stream(key)
- if err != nil {
- return nil, err
- }
- if stream.NonceSize() != len(metadata.Nonce) {
- return nil, sio.NotAuthentic
- }
- return stream.DecryptReader(ciphertext, metadata.Nonce, nil), nil
- }
- type encryptedObject struct {
- KeyID string `json:"keyid"`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 5K bytes - Viewed (0) -
internal/store/batch_test.go
- import (
- "context"
- "sync"
- "testing"
- "time"
- )
- func TestBatchCommit(t *testing.T) {
- defer func() {
- if err := tearDownQueueStore(); err != nil {
- t.Fatalf("Failed to tear down store; %v", err)
- }
- }()
- store, err := setUpQueueStore(queueDir, 100)
- if err != nil {
- t.Fatalf("Failed to create a queue store; %v", err)
- }
- var limit uint32 = 100
- batch := NewBatch[TestItem](BatchConfig[TestItem]{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0) -
src/bufio/bufio.go
- return
- }
- if b.buf == nil {
- b.buf = make([]byte, defaultBufSize)
- }
- b.err = nil
- b.n = 0
- b.wr = w
- }
- // Flush writes any buffered data to the underlying [io.Writer].
- func (b *Writer) Flush() error {
- if b.err != nil {
- return b.err
- }
- if b.n == 0 {
- return nil
- }
- n, err := b.wr.Write(b.buf[0:b.n])
- if n < b.n && err == nil {
- err = io.ErrShortWrite
- }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
cmd/mrf_gen.go
- if err != nil {
- return
- }
- err = en.WriteString(z.VersionID)
- if err != nil {
- err = msgp.WrapError(err, "VersionID")
- return
- }
- // write "Versions"
- err = en.Append(0xa8, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73)
- if err != nil {
- return
- }
- err = en.WriteBytes(z.Versions)
- if err != nil {
- err = msgp.WrapError(err, "Versions")
- return
- }
- // write "SetIndex"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.8K bytes - Viewed (0) -
tests/callbacks_test.go
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Mar 26 03:33:36 UTC 2024 - 7.2K bytes - Viewed (0)