- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 1,124 for Nil (0.02 sec)
-
tests/postgres_test.go
- t.Errorf("Failed to create extension pgcrypto, got error %v", err)
- }
- DB.Migrator().DropTable(&Yasuo{})
- if err := DB.AutoMigrate(&Yasuo{}); err != nil {
- t.Fatalf("Failed to migrate for uuid default value, got error: %v", err)
- }
- yasuo := Yasuo{Name: "jinzhu"}
- 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) -
internal/config/dns/operator_dns.go
- e, err := c.endpoint(bucket, false)
- if err != nil {
- return newError(bucket, err)
- }
- req, err := http.NewRequestWithContext(ctx, http.MethodPost, e, nil)
- if err != nil {
- return newError(bucket, err)
- }
- if err = c.addAuthHeader(req); err != nil {
- return newError(bucket, err)
- }
- resp, err := c.httpClient.Do(req)
- if err != nil {
- if derr := c.Delete(bucket); derr != nil {
- return newError(bucket, derr)
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Mar 06 16:56:10 UTC 2023 - 6.6K bytes - Viewed (0) -
internal/s3select/progress.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/config/etcd/etcd.go
- func New(cfg Config) (*clientv3.Client, error) {
- if !cfg.Enabled {
- return nil, nil
- }
- cli, err := clientv3.New(cfg.Config)
- if err != nil {
- return nil, err
- }
- cli.KV = namespace.NewKV(cli.KV, cfg.PathPrefix)
- cli.Watcher = namespace.NewWatcher(cli.Watcher, cfg.PathPrefix)
- cli.Lease = namespace.NewLease(cli.Lease, cfg.PathPrefix)
- return cli, nil
- }
- 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) -
internal/crypto/metadata.go
- }
- if IsMultiPart(metadata) {
- return nil, true
- }
- if _, ok := metadata[MetaIV]; ok {
- return nil, true
- }
- if _, ok := metadata[MetaAlgorithm]; ok {
- return nil, true
- }
- if _, ok := metadata[MetaKeyID]; ok {
- return nil, true
- }
- if _, ok := metadata[MetaDataEncryptionKey]; ok {
- return nil, true
- }
- if _, ok := metadata[MetaContext]; ok {
- return nil, true
- }
- return nil, false
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 6.4K bytes - Viewed (0) -
internal/http/dial_linux.go
- if err != nil {
- return nil, err
- }
- if opts.DriveOPTimeout != nil {
- // Read deadlines are sufficient for now as per various
- // scenarios of hung node detection, we may add Write deadlines
- // if needed later on.
- return deadlineconn.New(conn).WithReadDeadline(opts.DriveOPTimeout()), nil
- }
- return conn, nil
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/writer/compare/sds/writer.go
- func (w *sdsWriter) printSecretItemsJSON(secrets []SecretItem) error {
- out, err := json.MarshalIndent(secrets, "", " ")
- if err != nil {
- return err
- }
- _, err = w.w.Write(out)
- if err != nil {
- return err
- }
- return nil
- }
- // 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) -
internal/grid/handlers.go
- }
- func (h *handlers) hasAny(id HandlerID) bool {
- if !id.valid() {
- return false
- }
- return h.single[id] != nil || h.stateless[id] != nil || h.streams[id] != nil
- }
- func (h *handlers) hasSubhandler(id subHandlerID) bool {
- return h.subSingle[id] != nil || h.subStateless[id] != nil || h.subStreams[id] != nil
- }
- // RoundTripper provides an interface for type roundtrip serialization.
- 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) -
internal/kms/kms.go
- })
- if err != nil {
- if errors.Is(err, kms.ErrKeyNotFound) {
- return nil, ErrKeyNotFound
- }
- if errors.Is(err, kms.ErrPermission) {
- return nil, ErrPermission
- }
- return nil, errDecryptionFailed(err)
- }
- return resp.Plaintext, nil
- }
- // MAC generates the checksum of the given req.Message using the key
- // with the req.Name at the KMS.
- 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) -
internal/event/target/mqtt.go
- func (target *MQTTTarget) SendFromStore(key store.Key) error {
- if err := target.init(); err != nil {
- return err
- }
- // Do not send if the connection is not active.
- _, err := target.isActive()
- if err != nil {
- return err
- }
- eventData, err := target.store.Get(key)
- if err != nil {
- // 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)