Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 1,387 for funcs (0.04 sec)

  1. soft_delete.go

    }
    
    type SoftDeleteQueryClause struct {
    	ZeroValue sql.NullString
    	Field     *schema.Field
    }
    
    func (sd SoftDeleteQueryClause) Name() string {
    	return ""
    }
    
    func (sd SoftDeleteQueryClause) Build(clause.Builder) {
    }
    
    func (sd SoftDeleteQueryClause) MergeClause(*clause.Clause) {
    }
    
    func (sd SoftDeleteQueryClause) ModifyStatement(stmt *Statement) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 4.5K bytes
    - Viewed (1)
  2. internal/event/target/nsq.go

    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NSQTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *NSQTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *NSQTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/netns_other.go

    package nodeagent
    
    import "errors"
    
    func inodeForFd(n NetnsFd) (uint64, error) {
    	return 0, errors.New("not implemented")
    }
    
    func NetnsSet(n NetnsFd) error {
    	return errors.New("not implemented")
    }
    
    func OpenNetns(nspath string) (NetnsCloser, error) {
    	return nil, errors.New("not implemented")
    }
    
    // inspired by netns.Do() but with an existing fd.
    func NetnsDo(fdable NetnsFd, toRun func() error) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Mar 14 09:32:25 UTC 2024
    - 1K bytes
    - Viewed (0)
  4. clause/set_test.go

    		t.Run(fmt.Sprintf("case #%v", idx), func(t *testing.T) {
    			checkBuildClauses(t, result.Clauses, result.Result, result.Vars)
    		})
    	}
    }
    
    func TestAssignments(t *testing.T) {
    	set := clause.Assignments(map[string]interface{}{
    		"name": "jinzhu",
    		"age":  18,
    	})
    
    	assignments := []clause.Assignment(set)
    
    	sort.Slice(assignments, func(i, j int) bool {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  5. internal/deadlineconn/deadlineconn.go

    func (c *DeadlineConn) WithReadDeadline(d time.Duration) *DeadlineConn {
    	c.readDeadline = d
    	return c
    }
    
    // WithWriteDeadline sets a new write side net.Conn deadline.
    func (c *DeadlineConn) WithWriteDeadline(d time.Duration) *DeadlineConn {
    	c.writeDeadline = d
    	return c
    }
    
    // New - creates a new connection object wrapping net.Conn with deadlines.
    func New(c net.Conn) *DeadlineConn {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. internal/s3select/jstream/scanner.go

    	fillReady chan int64
    	readerErr error // underlying reader error, if any
    }
    
    func newScanner(r io.Reader) *scanner {
    	sr := &scanner{
    		end:       maxInt,
    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    		for range sr.fillReq {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  7. internal/event/rulesmap.go

    func (rulesMap RulesMap) add(eventNames []Name, pattern string, targetID TargetID) {
    	rules := make(Rules)
    	rules.Add(pattern, targetID)
    
    	for _, eventName := range eventNames {
    		for _, name := range eventName.Expand() {
    			rulesMap[name] = rulesMap[name].Union(rules)
    		}
    	}
    }
    
    // Clone - returns copy of this rules map.
    func (rulesMap RulesMap) Clone() RulesMap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  8. internal/ioutil/wait_pipe.go

    	*io.PipeWriter
    	once sync.Once
    	done func()
    }
    
    // CloseWithError close with supplied error the writer end.
    func (w *PipeWriter) CloseWithError(err error) error {
    	err = w.PipeWriter.CloseWithError(err)
    	w.once.Do(func() {
    		w.done()
    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    	*io.PipeReader
    	wait func()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 27 14:55:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  9. cmd/bucket-replication-metrics_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgActiveWorkerStat(b *testing.B) {
    	v := ActiveWorkerStat{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgActiveWorkerStat(b *testing.B) {
    	v := ActiveWorkerStat{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  10. cni/pkg/cmd/root.go

    }
    
    func registerStringParameter(name, value, usage string) {
    	rootCmd.Flags().String(name, value, usage)
    	registerEnvironment(name, value, usage)
    }
    
    func registerIntegerParameter(name string, value int, usage string) {
    	rootCmd.Flags().Int(name, value, usage)
    	registerEnvironment(name, value, usage)
    }
    
    func registerBooleanParameter(name string, value bool, usage string) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top