Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 1,387 for funcs (0.05 sec)

  1. cmd/data-scanner.go

    // When the returned function is called it will wait.
    func (d *dynamicSleeper) Timer(ctx context.Context) func() {
    	t := time.Now()
    	return func() {
    		doneAt := time.Now()
    		d.Sleep(ctx, doneAt.Sub(t))
    	}
    }
    
    // Sleep sleeps the specified time multiplied by the sleep factor.
    // If the factor is updated the sleep will be done again with the new factor.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  2. internal/grid/msg_gen.go

    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *Flags) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = Flags(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z Flags) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint8(uint8(z))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 22.4K bytes
    - Viewed (0)
  3. internal/config/dns/operator_dns.go

    type OperatorOption func(*OperatorDNS)
    
    // Authentication - custom username and password for authenticating at the endpoint
    func Authentication(username, password string) OperatorOption {
    	return func(args *OperatorDNS) {
    		args.username = username
    		args.password = password
    	}
    }
    
    // RootCAs - add custom trust certs pool
    func RootCAs(certPool *x509.CertPool) OperatorOption {
    	return func(args *OperatorDNS) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  4. cmd/leak-detect_test.go

    // function to be run at the end of tests to see whether any
    // goroutines leaked.
    // Usage: `defer DetectTestLeak(t)()` in beginning line of benchmarks or unit tests.
    func DetectTestLeak(t TestErrHandler) func() {
    	initialStackSnapShot := NewLeakDetect()
    	return func() {
    		initialStackSnapShot.DetectLeak(t)
    	}
    }
    
    // list of functions to be ignored from the stack trace.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. cmd/generic-handlers_test.go

    }
    
    func TestSSETLSHandler(t *testing.T) {
    	defer func(isSSL bool) { globalIsTLS = isSSL }(globalIsTLS) // reset globalIsTLS after test
    
    	var okHandler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		w.WriteHeader(http.StatusOK)
    	}
    	for i, test := range sseTLSHandlerTests {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. tensorflow/c/eager/c_api_unified_experimental.cc

    void TF_DeleteAbstractFunction(TF_AbstractFunction* func) {
      unwrap(func)->Unref();
    }
    
    void TF_ExecutionContextRegisterFunction(TF_ExecutionContext* ctx,
                                             TF_AbstractFunction* func,
                                             TF_Status* s) {
      tsl::Set_TF_Status_from_Status(s,
                                     unwrap(ctx)->RegisterFunction(unwrap(func)));
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. clause/limit.go

    package clause
    
    // Limit limit clause
    type Limit struct {
    	Limit  *int
    	Offset int
    }
    
    // Name where clause name
    func (limit Limit) Name() string {
    	return "LIMIT"
    }
    
    // Build build where clause
    func (limit Limit) Build(builder Builder) {
    	if limit.Limit != nil && *limit.Limit >= 0 {
    		builder.WriteString("LIMIT ")
    		builder.AddVar(builder, *limit.Limit)
    	}
    	if limit.Offset > 0 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 942 bytes
    - Viewed (0)
  8. internal/event/targetid.go

    	ID   string
    	Name string
    }
    
    // String - returns string representation.
    func (tid TargetID) String() string {
    	return tid.ID + ":" + tid.Name
    }
    
    // ToARN - converts to ARN.
    func (tid TargetID) ToARN(region string) ARN {
    	return ARN{TargetID: tid, region: region}
    }
    
    // MarshalJSON - encodes to JSON data.
    func (tid TargetID) MarshalJSON() ([]byte, error) {
    	return json.Marshal(tid.String())
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  9. cmd/iam-store.go

    			r = append(r, v)
    		}
    	}
    
    	sort.Slice(r, func(i, j int) bool {
    		return r[i].User < r[j].User
    	})
    
    	return r
    }
    
    // Assumes store is locked by caller. If groups is empty, returns all group mappings.
    func (store *IAMStoreSys) listGroupPolicyMappings(cache *iamCache, groupsSet set.StringSet,
    	groupPredicate func(string) bool, decodeFunc func(string) string,
    ) []madmin.GroupPolicyEntities {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users_test.go

    	client   *minio.Client
    }
    
    func newTestSuiteIAM(c TestSuiteCommon, withEtcdBackend bool) *TestSuiteIAM {
    	etcdStr := ""
    	if withEtcdBackend {
    		etcdStr = " (with etcd backend)"
    	}
    	return &TestSuiteIAM{
    		TestSuiteCommon:       c,
    		ServerTypeDescription: fmt.Sprintf("%s%s", c.serverType, etcdStr),
    		withEtcdBackend:       withEtcdBackend,
    	}
    }
    
    func (s *TestSuiteIAM) iamSetup(c *check) {
    	var err error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
Back to top