- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 315 for net (0.18 sec)
-
cmd/metrics-realtime.go
} if types.Contains(madmin.MetricNet) { m.Aggregated.Net = &madmin.NetMetrics{ CollectedAt: UTCNow(), InterfaceName: globalInternodeInterface, } netStats, err := net.GetInterfaceNetStats(globalInternodeInterface) if err != nil { m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (nicstats)", byHostName, err.Error())) } else { m.Aggregated.Net.NetStats = netStats } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/http/check_port_linux.go
package http import ( "context" "net" "syscall" "time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
if err != nil { return err } sconfig.Net.TLS.Enable = h.kconfig.TLS.Enable sconfig.Net.TLS.Config = tlsConfig sconfig.Net.TLS.Config.InsecureSkipVerify = h.kconfig.TLS.SkipVerify sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs // These settings are needed to ensure that kafka client doesn't hang on brokers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
internal/config/subnet/config.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package subnet import ( "net/http" "net/url" "os" "strings" "sync" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v2/env" xnet "github.com/minio/pkg/v2/net" ) const ( baseURL = "https://subnet.min.io" baseURLDev = "http://localhost:9000" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:59:35 GMT 2023 - 3.8K bytes - Viewed (0) -
internal/config/identity/openid/jwt_test.go
"context" "encoding/base64" "encoding/json" "fmt" "io" "net/http" "net/http/httptest" "net/url" "sync" "testing" "time" jwtgo "github.com/golang-jwt/jwt/v4" "github.com/minio/minio/internal/arn" "github.com/minio/minio/internal/config" jwtm "github.com/minio/minio/internal/jwt" xnet "github.com/minio/pkg/v2/net" ) func TestUpdateClaimsExpiry(t *testing.T) { testCases := []struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.3K bytes - Viewed (0) -
cmd/http-tracer.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "net" "net/http" "reflect" "regexp" "runtime" "strconv" "strings" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/handlers" xhttp "github.com/minio/minio/internal/http"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig_test.go
// See the License for the specific language governing permissions and // limitations under the License. package admin import ( "net/http" "net/http/httptest" "net/url" "os" "reflect" "testing" ) func Test_newScopeLevelPair(t *testing.T) { validationPattern := `^\w+:(debug|error|warn|info|debug)` type args struct { slp string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 6.2K bytes - Viewed (0) -
cmd/copy-part-range.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "net/http" "net/url" ) // Writes S3 compatible copy part range error. func writeCopyPartErr(ctx context.Context, w http.ResponseWriter, err error, url *url.URL) { switch err { case errInvalidRange:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 2.5K bytes - Viewed (0) -
internal/grid/connection.go
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) -
cmd/warm-backend-azure.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/base64" "errors" "fmt" "io" "net/http" "net/url" "strings" "time" "github.com/Azure/azure-storage-blob-go/azblob" "github.com/Azure/go-autorest/autorest/adal" "github.com/Azure/go-autorest/autorest/azure" "github.com/minio/madmin-go/v3" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1)