Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 1,124 for Nil (0.02 sec)

  1. tests/postgres_test.go

    1. t.Errorf("Failed to create extension pgcrypto, got error %v", err)
    2. }
    3.  
    4. DB.Migrator().DropTable(&Yasuo{})
    5.  
    6. if err := DB.AutoMigrate(&Yasuo{}); err != nil {
    7. t.Fatalf("Failed to migrate for uuid default value, got error: %v", err)
    8. }
    9.  
    10. yasuo := Yasuo{Name: "jinzhu"}
    11. if err := DB.Create(&yasuo).Error; err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Oct 08 09:16:32 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  2. internal/config/dns/operator_dns.go

    1. e, err := c.endpoint(bucket, false)
    2. if err != nil {
    3. return newError(bucket, err)
    4. }
    5. req, err := http.NewRequestWithContext(ctx, http.MethodPost, e, nil)
    6. if err != nil {
    7. return newError(bucket, err)
    8. }
    9. if err = c.addAuthHeader(req); err != nil {
    10. return newError(bucket, err)
    11. }
    12.  
    13. resp, err := c.httpClient.Do(req)
    14. if err != nil {
    15. if derr := c.Delete(bucket); derr != nil {
    16. return newError(bucket, derr)
    17. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  3. internal/s3select/progress.go

    1. }
    2. pr.processedReader = newCountUpReader(r)
    3.  
    4. return &pr, nil
    5. }
    6.  
    7. type nopReadCloser struct {
    8. fn func()
    9. }
    10.  
    11. func (n2 *nopReadCloser) Read(p []byte) (n int, err error) {
    12. panic("should not be called")
    13. }
    14.  
    15. func (n2 *nopReadCloser) Close() error {
    16. if n2.fn != nil {
    17. n2.fn()
    18. }
    19. n2.fn = nil
    20. return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. internal/config/etcd/etcd.go

    1. func New(cfg Config) (*clientv3.Client, error) {
    2. if !cfg.Enabled {
    3. return nil, nil
    4. }
    5. cli, err := clientv3.New(cfg.Config)
    6. if err != nil {
    7. return nil, err
    8. }
    9. cli.KV = namespace.NewKV(cli.KV, cfg.PathPrefix)
    10. cli.Watcher = namespace.NewWatcher(cli.Watcher, cfg.PathPrefix)
    11. cli.Lease = namespace.NewLease(cli.Lease, cfg.PathPrefix)
    12. return cli, nil
    13. }
    14.  
    15. func parseEndpoints(endpoints string) ([]string, bool, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. internal/crypto/metadata.go

    1. }
    2. if IsMultiPart(metadata) {
    3. return nil, true
    4. }
    5. if _, ok := metadata[MetaIV]; ok {
    6. return nil, true
    7. }
    8. if _, ok := metadata[MetaAlgorithm]; ok {
    9. return nil, true
    10. }
    11. if _, ok := metadata[MetaKeyID]; ok {
    12. return nil, true
    13. }
    14. if _, ok := metadata[MetaDataEncryptionKey]; ok {
    15. return nil, true
    16. }
    17. if _, ok := metadata[MetaContext]; ok {
    18. return nil, true
    19. }
    20. return nil, false
    21. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:40:33 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. internal/http/dial_linux.go

    1. if err != nil {
    2. return nil, err
    3. }
    4. if opts.DriveOPTimeout != nil {
    5. // Read deadlines are sufficient for now as per various
    6. // scenarios of hung node detection, we may add Write deadlines
    7. // if needed later on.
    8. return deadlineconn.New(conn).WithReadDeadline(opts.DriveOPTimeout()), nil
    9. }
    10. return conn, nil
    11. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/compare/sds/writer.go

    1. func (w *sdsWriter) printSecretItemsJSON(secrets []SecretItem) error {
    2. out, err := json.MarshalIndent(secrets, "", " ")
    3. if err != nil {
    4. return err
    5. }
    6.  
    7. _, err = w.w.Write(out)
    8. if err != nil {
    9. return err
    10. }
    11.  
    12. return nil
    13. }
    14.  
    15. // PrintDiffs uses the user supplied output format to determine how to display the diffed secrets
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. internal/grid/handlers.go

    1. }
    2.  
    3. func (h *handlers) hasAny(id HandlerID) bool {
    4. if !id.valid() {
    5. return false
    6. }
    7. return h.single[id] != nil || h.stateless[id] != nil || h.streams[id] != nil
    8. }
    9.  
    10. func (h *handlers) hasSubhandler(id subHandlerID) bool {
    11. return h.subSingle[id] != nil || h.subStateless[id] != nil || h.subStreams[id] != nil
    12. }
    13.  
    14. // RoundTripper provides an interface for type roundtrip serialization.
    15. type RoundTripper interface {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  9. internal/kms/kms.go

    1. })
    2. if err != nil {
    3. if errors.Is(err, kms.ErrKeyNotFound) {
    4. return nil, ErrKeyNotFound
    5. }
    6. if errors.Is(err, kms.ErrPermission) {
    7. return nil, ErrPermission
    8. }
    9. return nil, errDecryptionFailed(err)
    10. }
    11. return resp.Plaintext, nil
    12. }
    13.  
    14. // MAC generates the checksum of the given req.Message using the key
    15. // with the req.Name at the KMS.
    16. func (*kmsConn) MAC(context.Context, *MACRequest) ([]byte, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. internal/event/target/mqtt.go

    1. func (target *MQTTTarget) SendFromStore(key store.Key) error {
    2. if err := target.init(); err != nil {
    3. return err
    4. }
    5.  
    6. // Do not send if the connection is not active.
    7. _, err := target.isActive()
    8. if err != nil {
    9. return err
    10. }
    11.  
    12. eventData, err := target.store.Get(key)
    13. if err != nil {
    14. // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top