iter - Code Search

go.sum

github.com/lestrrat-go/httpcc v1.0.1 h1:ydWCStUeJLkpYyjLDHihupbn2tYmZ7m22BGkcvZZrIE=
github.com/lestrrat-go/httpcc v1.0.1/go.mod h1:qiltp3Mt56+55GPVCbTdM9MlqhvzyuL6W/NMDA8vA5E=
github.com/lestrrat-go/iter v1.0.2 h1:gMXo1q4c2pHmC3dn8LzRhJfP1ceCbgSiT9lUydIzltI=
github.com/lestrrat-go/iter v1.0.2/go.mod h1:Momfcq3AnRlRjI5b5O8/G5/BvpzrhoFTZcn06fEOPt4=
github.com/lestrrat-go/jwx v1.2.29 h1:QT0utmUJ4/12rmsVQrJ3u55bycPkKqGYuGT4tyRhxSQ=

Plain Text

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Wed May 01 15:22:54 GMT 2024

- 109.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/templates/templates/item.html

<html>
<head>
    <title>Item Details</title>
    <link href="{{ url_for('static', path='/styles.css') }}" rel="stylesheet">
</head>
<body>
    <h1><a href="{{ url_for('read_item', id=id) }}">Item ID: {{ id }}</a></h1>
</body>

HTML

- Registered: Sun Apr 28 07:19:10 GMT 2024

- Last Modified: Thu Jan 11 22:25:37 GMT 2024

- 235 bytes

- Viewed (0)

github.com/minio/minio

cmd/tier.go

	histogram: prometheus.NewHistogramVec(prometheus.HistogramOpts{
		Name:    "tier_ttlb_seconds",
		Help:    "Time taken by requests served by warm tier",
		Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60},
	}, []string{"tier"}),
}

func (t *tierMetrics) Observe(tier string, dur time.Duration) {
	t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds())
}

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Wed Apr 17 05:09:58 GMT 2024

- 15.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/tier_test.go

package cmd

import (
	"testing"
	"time"
)

func TestTierMetrics(t *testing.T) {
	tier := "WARM-1"
	globalTierMetrics.Observe(tier, 200*time.Millisecond)
	expSuccess := 10
	expFailure := 5
	for i := 0; i < expSuccess; i++ {
		globalTierMetrics.logSuccess(tier)
	}
	for i := 0; i < expFailure; i++ {
		globalTierMetrics.logFailure(tier)
	}
	metrics := globalTierMetrics.Report()
	var succ, fail float64

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Thu Dec 21 04:13:40 GMT 2023

- 1.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/tier-handlers.go

)

var (
	// error returned when remote tier already exists
	errTierAlreadyExists = AdminError{
		Code:       "XMinioAdminTierAlreadyExists",
		Message:    "Specified remote tier already exists",
		StatusCode: http.StatusConflict,
	}
	// error returned when remote tier is not found
	errTierNotFound = AdminError{
		Code:       "XMinioAdminTierNotFound",
		Message:    "Specified remote tier was not found",
		StatusCode: http.StatusNotFound,

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Thu Feb 15 19:52:44 GMT 2024

- 7.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/tier-sweeper.go

	os.TransitionTier = info.Tier
	os.TransitionStatus = info.Status
	os.RemoteObject = info.Name
	os.TransitionVersionID = info.VersionID
}

// shouldRemoveRemoteObject determines if a transitioned object should be
// removed from remote tier. If remote object is to be deleted, returns the
// corresponding tier deletion journal entry and true. Otherwise returns empty
// jentry value and false.

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Wed Apr 17 05:09:58 GMT 2024

- 4.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/tier-journal.go

	VersionID string `msg:"vid"`
	TierName  string `msg:"tier"`
}

const (
	tierJournalVersion = 1
	tierJournalHdrLen  = 2 // 2 bytes
)

var errUnsupportedJournalVersion = errors.New("unsupported pending deletes journal version")

func newTierDiskJournal() *tierDiskJournal {
	return &tierDiskJournal{}
}

// NewTierJournal initializes tier deletion journal
func NewTierJournal() *TierJournal {

Go

- Registered: Sun Feb 25 19:28:16 GMT 2024

- Last Modified: Thu Jan 18 07:03:17 GMT 2024

- 7.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/tier-journal_test.go

	}

	var b bytes.Buffer
	for _, item := range readOldToNewCases {
		bs, err := item.je.MarshalMsg(nil)
		if err != nil {
			t.Fatal(err)
		}
		b.Write(bs)
	}

	mr := msgp.NewReader(&b)
	for i, item := range readOldToNewCases {
		var je jentry
		err := je.DecodeMsg(mr)
		if err != nil {
			t.Fatal(err)
		}
		if je != item.exp {
			t.Errorf("Case %d: Expected: %v Got: %v", i, item.exp, je)

Go

- Registered: Sun Feb 25 19:28:16 GMT 2024

- Last Modified: Thu Jun 03 21:26:51 GMT 2021

- 3.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/tier-journal_gen.go

				err = msgp.WrapError(err, "ObjName")
				return
			}
		case "vid":
			z.VersionID, err = dc.ReadString()
			if err != nil {
				err = msgp.WrapError(err, "VersionID")
				return
			}
		case "tier":
			z.TierName, err = dc.ReadString()
			if err != nil {
				err = msgp.WrapError(err, "TierName")
				return
			}
		default:
			err = dc.Skip()
			if err != nil {
				err = msgp.WrapError(err)
				return

Go

- Registered: Sun Feb 25 19:28:16 GMT 2024

- Last Modified: Thu Jun 03 21:26:51 GMT 2021

- 6.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/tier-mem-journal.go

		}
	}
}

func (j *tierMemJournal) AddEntry(je jentry) error {
	select {
	case j.entries <- je:
	default:
		return fmt.Errorf("failed to remove tiered content at %s with version %s from tier %s, will be retried later.",
			je.ObjName, je.VersionID, je.TierName)
	}
	return nil

Go

- Registered: Sun Feb 25 19:28:16 GMT 2024

- Last Modified: Thu Aug 03 21:16:15 GMT 2023

- 1.5K bytes

- Viewed (0)

Search Options