Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1161 - 1170 of 1,387 for funcs (0.02 sec)

  1. cmd/object-handlers.go

    }
    
    // getRemoteInstanceTransport contains a roundtripper for external (not peers) servers
    var remoteInstanceTransport atomic.Value
    
    func setRemoteInstanceTransport(tr http.RoundTripper) {
    	remoteInstanceTransport.Store(tr)
    }
    
    func getRemoteInstanceTransport() http.RoundTripper {
    	rt, ok := remoteInstanceTransport.Load().(http.RoundTripper)
    	if ok {
    		return rt
    	}
    	return nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  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. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. api/next/67813.txt

    pkg net/http, type HTTP2Config struct #67813
    pkg net/http, type HTTP2Config struct, CountError func(string) #67813
    pkg net/http, type HTTP2Config struct, MaxConcurrentStreams int #67813
    pkg net/http, type HTTP2Config struct, MaxDecoderHeaderTableSize int #67813
    pkg net/http, type HTTP2Config struct, MaxEncoderHeaderTableSize int #67813
    pkg net/http, type HTTP2Config struct, MaxReadFrameSize int #67813
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Aug 29 17:38:46 UTC 2024
    - 989 bytes
    - Viewed (0)
Back to top