- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for Ying (0.13 sec)
-
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) -
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) -
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) -
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/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) -
internal/config/notify/help.go
Go - Registered: Sun May 05 19:28:20 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 May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K 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 May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 30.2K bytes - Viewed (0)