Search Options

Results per page
Sort
Preferred Languages
Advance

Results 841 - 850 of 1,387 for funcs (0.04 sec)

  1. internal/grid/handlers_string.go

    // Code generated by "stringer -type=HandlerID -output=handlers_string.go -trimprefix=Handler msg.go handlers.go"; DO NOT EDIT.
    
    package grid
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[handlerInvalid-0]
    	_ = x[HandlerLockLock-1]
    	_ = x[HandlerLockRLock-2]
    	_ = x[HandlerLockUnlock-3]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. internal/ioutil/hardlimitreader.go

    // This means the source *will* be overread unless EOF is returned prior.
    // The underlying implementation is a *HardLimitedReader.
    // This will ensure that at most n bytes are returned and EOF is reached.
    func HardLimitReader(r io.Reader, n int64) io.Reader { return &HardLimitedReader{r, n} }
    
    // A HardLimitedReader reads from R but limits the amount of
    // data returned to just N bytes. Each call to Read
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 2K bytes
    - Viewed (0)
  3. internal/disk/stat_test.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 disk
    
    import (
    	"os"
    	"reflect"
    	"testing"
    )
    
    func TestReadDriveStats(t *testing.T) {
    	testCases := []struct {
    		stat            string
    		expectedIOStats IOStats
    		expectErr       bool
    	}{
    		{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. cmd/sts-handlers.go

    // registerSTSRouter - registers AWS STS compatible APIs.
    func registerSTSRouter(router *mux.Router) {
    	// Initialize STS.
    	sts := &stsAPIHandlers{}
    
    	// STS Router
    	stsRouter := router.NewRoute().PathPrefix(SlashSeparator).Subrouter()
    
    	// Assume roles with no JWT, handles AssumeRole.
    	stsRouter.Methods(http.MethodPost).MatcherFunc(func(r *http.Request, rm *mux.RouteMatch) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  5. istioctl/pkg/workload/workload.go

    }
    
    func isRevisioned(revision string) bool {
    	return revision != "" && revision != "default"
    }
    
    func IstiodHost(ns string, revision string) string {
    	istiod := "istiod"
    	if isRevisioned(revision) {
    		istiod = fmt.Sprintf("%s-%s", istiod, revision)
    	}
    	return fmt.Sprintf("%s.%s.svc", istiod, ns)
    }
    
    func IstiodAddr(ns, revision string) string {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  6. cmd/metrics-v3-system-process.go

    	processVirtualMemoryBytesMD       = NewGaugeMD(processVirtualMemoryBytes, "Virtual memory size in bytes")
    	processVirtualMemoryMaxBytesMD    = NewGaugeMD(processVirtualMemoryMaxBytes, "Maximum virtual memory size in bytes")
    )
    
    func loadProcStatMetrics(ctx context.Context, stat procfs.ProcStat, m MetricValues) {
    	if stat.CPUTime() > 0 {
    		m.Set(processCPUTotalSeconds, float64(stat.CPUTime()))
    	}
    
    	if stat.ResidentMemory() > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. internal/config/crypto_test.go

    				b.Fatal(err)
    			}
    			plaintext.Reset(data)
    		}
    	}
    	b.Run("1KB", func(b *testing.B) { benchmarkEncrypt(1*1024, b) })
    	b.Run("512KB", func(b *testing.B) { benchmarkEncrypt(512*1024, b) })
    	b.Run("1MB", func(b *testing.B) { benchmarkEncrypt(1024*1024, b) })
    	b.Run("10MB", func(b *testing.B) { benchmarkEncrypt(10*1024*1024, b) })
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. cmd/metacache-walk_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *WalkDirOptions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7K bytes
    - Viewed (0)
  9. cmd/s3-zip-handlers.go

    )
    
    // splitZipExtensionPath splits the S3 path to the zip file and the path inside the zip:
    //
    //	e.g  /path/to/archive.zip/backup-2021/myimage.png => /path/to/archive.zip, backup/myimage.png
    func splitZipExtensionPath(input string) (zipPath, object string, err error) {
    	idx := strings.Index(input, archivePattern)
    	if idx < 0 {
    		// Should never happen
    		return "", "", errors.New("unable to parse zip path")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  10. internal/hash/sha256/sh256.go

    package sha256
    
    import (
    	"crypto/sha256"
    	"hash"
    )
    
    // New initializes a new sha256.New()
    func New() hash.Hash { return sha256.New() }
    
    // Sum256 returns the SHA256 checksum of the data.
    func Sum256(data []byte) [sha256.Size]byte { return sha256.Sum256(data) }
    
    // Size is the size of a SHA256 checksum in bytes.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 26 06:31:35 UTC 2024
    - 1.1K bytes
    - Viewed (0)
Back to top