sent_bytes - Code Search

cmd/metrics-v3-bucket-replication.go

	bucketReplProxiedPutTaggingRequestsFailures    = "proxied_put_tagging_requests_failures"
	bucketReplProxiedPutTaggingRequestsTotal       = "proxied_put_tagging_requests_total"
	bucketReplSentBytes                            = "sent_bytes"
	bucketReplSentCount                            = "sent_count"
	bucketReplTotalFailedBytes                     = "total_failed_bytes"
	bucketReplTotalFailedCount                     = "total_failed_count"

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Wed Jun 04 20:45:31 UTC 2025

- 8.3K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/docs/reference/websockets.md

            - receive_text
            - receive_bytes
            - receive_json
            - iter_text
            - iter_bytes
            - iter_json
            - send_text
            - send_bytes
            - send_json
            - close

When a client disconnects, a `WebSocketDisconnect` exception is raised, you can catch it.

You can import it directly form `fastapi`:

```python

Registered: Sun Sep 07 07:19:17 UTC 2025

- Last Modified: Tue Aug 06 04:48:30 UTC 2024

- 1.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-handlers_gen_test.go

	bts := make([]byte, 0, v.Msgsize())
	bts, _ = v.MarshalMsg(bts[0:0])
	b.SetBytes(int64(len(bts)))
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		bts, _ = v.MarshalMsg(bts[0:0])
	}
}

func BenchmarkUnmarshalBatchJobPrefix(b *testing.B) {
	v := BatchJobPrefix{}
	bts, _ := v.MarshalMsg(nil)
	b.ReportAllocs()
	b.SetBytes(int64(len(bts)))
	b.ResetTimer()
	for i := 0; i < b.N; i++ {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Thu Aug 01 12:53:30 UTC 2024

- 6.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/local-locker_gen_test.go

	bts := make([]byte, 0, v.Msgsize())
	bts, _ = v.MarshalMsg(bts[0:0])
	b.SetBytes(int64(len(bts)))
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		bts, _ = v.MarshalMsg(bts[0:0])
	}
}

func BenchmarkUnmarshallocalLockMap(b *testing.B) {
	v := localLockMap{}
	bts, _ := v.MarshalMsg(nil)
	b.ReportAllocs()
	b.SetBytes(int64(len(bts)))
	b.ResetTimer()
	for i := 0; i < b.N; i++ {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Mon Feb 19 22:54:46 UTC 2024

- 6.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/storage-rest-common_gen_test.go

	bts := make([]byte, 0, v.Msgsize())
	bts, _ = v.MarshalMsg(bts[0:0])
	b.SetBytes(int64(len(bts)))
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		bts, _ = v.MarshalMsg(bts[0:0])
	}
}

func BenchmarkUnmarshalnsScannerOptions(b *testing.B) {
	v := nsScannerOptions{}
	bts, _ := v.MarshalMsg(nil)
	b.ReportAllocs()
	b.SetBytes(int64(len(bts)))
	b.ResetTimer()
	for i := 0; i < b.N; i++ {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Tue Nov 21 01:09:35 UTC 2023

- 4.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache_gen_test.go

	bts := make([]byte, 0, v.Msgsize())
	bts, _ = v.MarshalMsg(bts[0:0])
	b.SetBytes(int64(len(bts)))
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		bts, _ = v.MarshalMsg(bts[0:0])
	}
}

func BenchmarkUnmarshalmetacache(b *testing.B) {
	v := metacache{}
	bts, _ := v.MarshalMsg(nil)
	b.ReportAllocs()
	b.SetBytes(int64(len(bts)))
	b.ResetTimer()
	for i := 0; i < b.N; i++ {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Apr 23 18:58:53 UTC 2021

- 2.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/metrics-v2_gen_test.go

	bts := make([]byte, 0, v.Msgsize())
	bts, _ = v.MarshalMsg(bts[0:0])
	b.SetBytes(int64(len(bts)))
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		bts, _ = v.MarshalMsg(bts[0:0])
	}
}

func BenchmarkUnmarshalMetricDescription(b *testing.B) {
	v := MetricDescription{}
	bts, _ := v.MarshalMsg(nil)
	b.ReportAllocs()
	b.SetBytes(int64(len(bts)))
	b.ResetTimer()
	for i := 0; i < b.N; i++ {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Sun Mar 10 09:15:15 UTC 2024

- 4.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/background-newdisks-heal-ops_gen_test.go

	bts := make([]byte, 0, v.Msgsize())
	bts, _ = v.MarshalMsg(bts[0:0])
	b.SetBytes(int64(len(bts)))
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		bts, _ = v.MarshalMsg(bts[0:0])
	}
}

func BenchmarkUnmarshalhealingTracker(b *testing.B) {
	v := healingTracker{}
	bts, _ := v.MarshalMsg(nil)
	b.ReportAllocs()
	b.SetBytes(int64(len(bts)))
	b.ResetTimer()
	for i := 0; i < b.N; i++ {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Apr 23 18:58:53 UTC 2021

- 2.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/metrics-v3-api.go

		recvBytes := inOut.In
		if recvBytes > 0 {
			m.Set(apiTrafficSentBytes, float64(recvBytes), "bucket", bucket, "type", "s3")
		}
		sentBytes := inOut.Out
		if sentBytes > 0 {
			m.Set(apiTrafficRecvBytes, float64(sentBytes), "bucket", bucket, "type", "s3")
		}

		httpStats := globalBucketHTTPStats.load(bucket)
		for k, v := range httpStats.currentS3Requests.Load(false) {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Tue Sep 24 17:13:00 UTC 2024

- 9.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/last-minute_gen_test.go

	v := AccElem{}
	bts := make([]byte, 0, v.Msgsize())
	bts, _ = v.MarshalMsg(bts[0:0])
	b.SetBytes(int64(len(bts)))
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		bts, _ = v.MarshalMsg(bts[0:0])
	}
}

func BenchmarkUnmarshalAccElem(b *testing.B) {
	v := AccElem{}
	bts, _ := v.MarshalMsg(nil)
	b.ReportAllocs()
	b.SetBytes(int64(len(bts)))
	b.ResetTimer()
	for i := 0; i < b.N; i++ {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Tue Jul 05 21:45:49 UTC 2022

- 6.8K bytes

- Viewed (0)

Search Options