Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1161 - 1170 of 1,405 for rfunc (0.05 sec)

  1. cni/pkg/nodeagent/podcgroupns_other.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package nodeagent
    
    import (
    	"fmt"
    	"io/fs"
    )
    
    func GetInode(fi fs.FileInfo) (uint64, error) {
    	return 0, fmt.Errorf("unable to get inode os not supported")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 781 bytes
    - Viewed (0)
  2. internal/config/ilm/help.go

    	// EnvILMExpirationWorkers env variable to configure number of expiration workers
    	EnvILMExpirationWorkers = "MINIO_ILM_EXPIRATION_WORKERS"
    )
    
    var (
    	defaultHelpPostfix = func(key string) string {
    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	// Help holds configuration keys and their default values for the ILM
    	// subsystem
    	Help = config.HelpKVS{
    		config.HelpKV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 30 08:14:58 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  3. internal/disk/stat_openbsd.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package disk
    
    import (
    	"errors"
    	"fmt"
    	"syscall"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.F_bfree) - uint64(s.F_bavail)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. internal/crypto/sse_test.go

    package crypto
    
    import (
    	"net/http"
    	"testing"
    )
    
    func TestS3String(t *testing.T) {
    	const Domain = "SSE-S3"
    	if domain := S3.String(); domain != Domain {
    		t.Errorf("S3's string method returns wrong domain: got '%s' - want '%s'", domain, Domain)
    	}
    }
    
    func TestSSECString(t *testing.T) {
    	const Domain = "SSE-C"
    	if domain := SSEC.String(); domain != Domain {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/podcgroupns_linux.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package nodeagent
    
    import (
    	"fmt"
    	"io/fs"
    	"syscall"
    )
    
    func GetInode(fi fs.FileInfo) (uint64, error) {
    	if stat, ok := fi.Sys().(*syscall.Stat_t); ok {
    		return stat.Ino, nil
    	}
    	return 0, fmt.Errorf("unable to get inode")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 814 bytes
    - Viewed (0)
  6. internal/config/etcd/etcd_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package etcd
    
    import (
    	"reflect"
    	"testing"
    )
    
    // TestParseEndpoints - tests parseEndpoints function with valid and invalid inputs.
    func TestParseEndpoints(t *testing.T) {
    	testCases := []struct {
    		s         string
    		endpoints []string
    		secure    bool
    		success   bool
    	}{
    		// Invalid inputs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  7. internal/mountinfo/mountinfo_windows.go

    // this is a dummy function and returns nil for now.
    func CheckCrossDevice(paths []string) error {
    	return nil
    }
    
    // mountPointCache contains results of IsLikelyMountPoint
    var mountPointCache sync.Map
    
    // IsLikelyMountPoint determines if a directory is a mountpoint.
    func IsLikelyMountPoint(path string) bool {
    	path = filepath.Dir(path)
    	if v, ok := mountPointCache.Load(path); ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 2K bytes
    - Viewed (0)
  8. internal/rest/client_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package rest
    
    import (
    	"errors"
    	"net"
    	"net/url"
    	"testing"
    )
    
    func TestNetworkError_Unwrap(t *testing.T) {
    	tests := []struct {
    		name   string
    		err    error
    		target interface{}
    		want   bool
    	}{
    		{
    			name:   "url.Error",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 1.9K bytes
    - Viewed (0)
  9. tests/update_belongs_to_test.go

    package tests_test
    
    import (
    	"testing"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestUpdateBelongsTo(t *testing.T) {
    	user := *GetUser("update-belongs-to", Config{})
    
    	if err := DB.Create(&user).Error; err != nil {
    		t.Fatalf("errors happened when create: %v", err)
    	}
    
    	user.Company = Company{Name: "company-belongs-to-association"}
    	user.Manager = &User{Name: "manager-belongs-to-association"}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jul 14 06:55:54 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  10. cmd/metrics-v3-audit.go

    	auditTotalMessagesMD = NewCounterMD(auditTotalMessages,
    		"Total number of messages sent since start",
    		targetID)
    )
    
    // loadAuditMetrics - `MetricsLoaderFn` for audit
    // such as failed messages and total messages.
    func loadAuditMetrics(_ context.Context, m MetricValues, c *metricsCache) error {
    	audit := logger.CurrentStats()
    	for id, st := range audit {
    		labels := []string{targetID, id}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 10 14:50:39 UTC 2024
    - 1.9K bytes
    - Viewed (0)
Back to top