- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Ying (0.14 sec)
-
internal/event/target/elasticsearch.go
if resp.IsError() { return fmt.Errorf("Create index err: %v", res) } return nil } return nil } func (c *esClientV7) ping(ctx context.Context, _ ElasticsearchArgs) (bool, error) { resp, err := c.Ping( c.Ping.WithContext(ctx), ) if err != nil { return false, store.ErrNotConnected } xhttp.DrainBody(resp.Body) return !resp.IsError(), nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
internal/grid/connection.go
conn.Close() c.handleMsgWg.Done() }() c.connMu.Lock() connPingInterval := c.connPingInterval c.connMu.Unlock() ping := time.NewTicker(connPingInterval) pingFrame := message{ Op: OpPing, DeadlineMS: 5000, } defer ping.Stop() queue := make([][]byte, 0, maxMergeMessages) merged := make([]byte, 0, writeBufferSize) var queueSize int var buf bytes.Buffer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
tests/upsert_test.go
} } func TestUpdateWithMissWhere(t *testing.T) { type User struct { ID uint `gorm:"column:id;<-:create"` Name string `gorm:"column:name"` } user := User{ID: 1, Name: "king"} tx := DB.Session(&gorm.Session{DryRun: true}).Save(&user) if err := tx.Error; err != nil { t.Fatalf("failed to update user,missing where condition,err=%+v", err) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Sep 05 07:39:19 GMT 2022 - 11.4K bytes - Viewed (0) -
internal/event/target/postgresql.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new. if o.ID != "" && !o.Transient { // Create or ping with handout... rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) var c *metacache if rpc == nil { resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o) c = &resp
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/grid/muxclient.go
} case <-pingTimer: if time.Since(time.Unix(atomic.LoadInt64(&m.LastPong), 0)) > clientPingInterval*2 { m.addErrorNonBlockingClose(respHandler, ErrDisconnected) return } // Send new ping. gridLogIf(m.ctx, m.send(message{Op: OpPing, MuxID: m.MuxID})) } } } // responseCh is the channel to that goes to the requester. // internalResp is the channel that comes from the server.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/event/target/nats.go
NATSSubject = "subject" NATSUsername = "username" NATSPassword = "password" NATSToken = "token" NATSTLS = "tls" NATSTLSSkipVerify = "tls_skip_verify" NATSPingInterval = "ping_interval" NATSQueueDir = "queue_dir" NATSQueueLimit = "queue_limit" NATSCertAuthority = "cert_authority" NATSClientCert = "client_cert" NATSClientKey = "client_key"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
gorm.go
ConnPool: db.ConnPool, Context: context.Background(), Clauses: map[string]clause.Clause{}, } if err == nil && !config.DisableAutomaticPing { if pinger, ok := db.ConnPool.(interface{ Ping() error }); ok { err = pinger.Ping() } } if err != nil { config.Logger.Error(context.Background(), "failed to initialize database, got error %v", err) } return } // Session create new db session
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sun Aug 20 11:46:56 GMT 2023 - 11.6K bytes - Viewed (0) -
internal/event/target/mysql.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0) -
src/bytes/buffer.go
}() // TODO(http://golang.org/issue/51462): We should rely on the append-make // pattern so that the compiler can call runtime.growslice. For example: // return append(b, make([]byte, n)...) // This avoids unnecessary zero-ing of the first len(b) bytes of the // allocated slice, but this pattern causes b to escape onto the heap. // // Instead use the append-make pattern with a nil slice to ensure that
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 15.7K bytes - Viewed (0)