Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for PubSub (0.15 sec)

  1. internal/grid/connection.go

    	handlers      *handlers
    	auth          AuthFn
    	tlsConfig     *tls.Config
    	incomingBytes func(n int64) // Record incoming bytes.
    	outgoingBytes func(n int64) // Record outgoing bytes.
    	publisher     *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]
    
    	blockConnect chan struct{}
    }
    
    // newConnection will create an unconnected connection to a remote.
    func newConnection(o connectionParams) *Connection {
    	c := &Connection{
    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)
Back to top