- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Ying (0.15 sec)
-
internal/event/target/redis.go
return false, err } return target.isActive() } func (target *RedisTarget) isActive() (bool, error) { conn := target.pool.Get() defer conn.Close() _, pingErr := conn.Do("PING") if pingErr != nil { if xnet.IsConnRefusedErr(pingErr) { return false, store.ErrNotConnected } return false, pingErr } return true, nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/grid/muxserver.go
if m.outBlock == nil { // Closed return } select { case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } } func (m *muxServer) ping(seq uint32) pongMsg { if !m.checkSeq(seq) { msg := fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq) return pongMsg{Err: &msg} } select { case <-m.ctx.Done():
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
docs/bucket/notifications/README.md
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
internal/config/notify/help.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
internal/event/target/mysql.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0) -
internal/grid/grid.go
biggerBufMin = 32 << 10 // This is the maximum size of bigger buffers. biggerBufMax = maxBufferSize // If there is a queue, merge up to this many messages. maxMergeMessages = 30 // clientPingInterval will ping the remote handler every 15 seconds. // Clients disconnect when we exceed 2 intervals. clientPingInterval = 15 * time.Second // Deadline for single (non-streaming) requests to complete.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/testdata/xl-meta-merge.zip
‘¢µI~Xs^°¸.mqò ² ò ï@ªBz{}Õmp TßtlgZk²mx„À¬»ÆPsIT¢o}yrû(}¼ / ¢rxpZª—1‘²“2”¸ š ¨¡‚¸šŠ olH ~sM¸Iò¨SWV`¾|be¼~ñs@¨å\CnwX^SqjI. m{{ˆgqn S_mˆv\e††p[_EïT†Ü]ªAp}}@}¼hÇåckH_²ˆßHjwu~¼ þþmyTÕ°Šedfˆær{yM}¦^P}¾y¥VVMXNqªñb²zPK² QZ ]evBqd ÂЫ+M¼7=òŽq\EñêAsTXKoÜæA]ing<ã>U„µŸ‡M{kXiTûn~CªDoQn¾¼}ßgd¨ãu„BpE¦?il ‰ ~[wln :ey2þå_e_sò&PyTE„Vñ7jº²)aïª1>kMV¨ßÏûTIª i~ ¢ lI÷¦r²Hgåb§,¿NsGF EÁûle7ßûz_c›oRûOxx7-w§ò4ñpªS]\K<û `{Ö 9Ng#, ;V¢y _xéæBpe >[oDŒw{Y óbD\[TÛ>Âkch.² ï^¾evÎniyqBåi`¼F_ÄqT{tm~Gª¼sñi¾˜~V|xs »•u]X–që·rywI¿ëkZai#...
ZIP Archive - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 30.2K bytes - Viewed (0) -
internal/http/transports.go
// // ReadIdleTimeout is the timeout after which a health check using ping // // frame will be carried out if no frame is received on the // // connection. 5 minutes is sufficient time for any idle connection. // trhttp2.ReadIdleTimeout = 5 * time.Minute // // PingTimeout is the timeout after which the connection will be closed // // if a response to Ping is not received. // trhttp2.PingTimeout = dialTimeout
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 00:50:37 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/grid/msg.go
const ( // OpConnect is a connect request. OpConnect Op = iota + 1 // OpConnectResponse is a response to a connect request. OpConnectResponse // OpPing is a ping request. // If a mux id is specified that mux is pinged. // Clients send ping requests. OpPing // OpPong is a OpPing response returned by the server. OpPong // OpConnectMux will connect a new mux with optional payload. OpConnectMux
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/event/target/postgresql.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 12.2K bytes - Viewed (0)