Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 1,425 for Func (0.07 sec)

  1. cmd/bootstrap-peer-server_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgServerSystemConfig(b *testing.B) {
    	v := ServerSystemConfig{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgServerSystemConfig(b *testing.B) {
    	v := ServerSystemConfig{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 24 21:36:44 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. cmd/bucket-metadata_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBucketMetadata(b *testing.B) {
    	v := BucketMetadata{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBucketMetadata(b *testing.B) {
    	v := BucketMetadata{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    		DistributionAlgo string `json:"distributionAlgo"`
    	} `json:"xl"`
    	Info DiskInfo `json:"-"`
    }
    
    func (f *formatErasureV3) Drives() (drives int) {
    	for _, set := range f.Erasure.Sets {
    		drives += len(set)
    	}
    	return drives
    }
    
    func (f *formatErasureV3) Clone() *formatErasureV3 {
    	b, err := json.Marshal(f)
    	if err != nil {
    		panic(err)
    	}
    	var dst formatErasureV3
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. cni/pkg/log/uds.go

    func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error {
    	if sockAddress == "" {
    		return nil
    	}
    	log.Debugf("starting UDS server for CNI plugin logs")
    	unixListener, err := uds.NewListener(sockAddress)
    	if err != nil {
    		return fmt.Errorf("failed to create UDS listener: %v", err)
    	}
    	go func() {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. cmd/iam.go

    // SetUsersSysType - sets the users system type, regular or LDAP.
    func (sys *IAMSys) SetUsersSysType(t UsersSysType) {
    	sys.usersSysType = t
    }
    
    // GetUsersSysType - returns the users system type for this IAM
    func (sys *IAMSys) GetUsersSysType() UsersSysType {
    	return sys.usersSysType
    }
    
    // NewIAMSys - creates new config system object.
    func NewIAMSys() *IAMSys {
    	return &IAMSys{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  6. internal/event/config_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"context"
    	"encoding/xml"
    	"reflect"
    	"strings"
    	"testing"
    )
    
    func TestValidateFilterRuleValue(t *testing.T) {
    	testCases := []struct {
    		value     string
    		expectErr bool
    	}{
    		{"foo/.", true},
    		{"../foo", true},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  7. cmd/sftp-server-driver.go

    		Custom: map[string]string{
    			"user":   user,
    			"cmd":    s.Method,
    			"param":  s.Filepath,
    			"source": source,
    		},
    	}
    }
    
    func (m *sftpMetrics) log(s *sftp.Request, user string) func(sz int64, err error) {
    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(sftpTrace(s, startTime, source, user, err, sz))
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. internal/http/response-recorder.go

    // when the request is finished to provide accurate data
    func (lrw *ResponseRecorder) TTFB() time.Duration {
    	if lrw.ttfbBody != 0 {
    		return lrw.ttfbBody
    	}
    	return lrw.ttfbHeader
    }
    
    // NewResponseRecorder - returns a wrapped response writer to trap
    // http status codes for auditing purposes.
    func NewResponseRecorder(w http.ResponseWriter) *ResponseRecorder {
    	rf, _ := w.(io.ReaderFrom)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/prefix.go

    }
    
    // UnmarshalXML - decodes XML data.
    func (p *Prefix) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var s string
    	if err = d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    	*p = Prefix{string: s, set: true}
    	return nil
    }
    
    // MarshalXML - decodes XML data.
    func (p Prefix) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if !p.set {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 14:45:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  10. internal/config/dns/store.go

    type ErrInvalidBucketName Error
    
    func (e ErrInvalidBucketName) Error() string {
    	return e.Bucket + " invalid bucket name error: " + e.Err.Error()
    }
    
    func (e Error) Error() string {
    	return "dns related error: " + e.Err.Error()
    }
    
    // ErrBucketConflict for buckets that already exist
    type ErrBucketConflict Error
    
    func (e ErrBucketConflict) Error() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.6K bytes
    - Viewed (0)
Back to top