- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 1,387 for funcs (0.04 sec)
-
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) -
src/cmd/api/testdata/src/pkg/p2/golden.txt
pkg p2, func F() string pkg p2, func F //deprecated pkg p2, func G() Twoer pkg p2, func NewError(string) error pkg p2, type Twoer interface { PackageTwoMeth } pkg p2, type Twoer interface, PackageTwoMeth()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 265 bytes - Viewed (0) -
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) -
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) -
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) -
cmd/notification.go
// returns the slice of errors from all function calls. func (g *NotificationGroup) Wait() []NotificationPeerErr { g.workers.Wait() return g.errs } // Go calls the given function in a new goroutine. // // The first call to return a non-nil error will be // collected in errs slice and returned by Wait(). func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
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) -
cmd/bucket-replication-utils_gen_test.go
} if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 22 23:53:06 UTC 2022 - 23K bytes - Viewed (0) -
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) -
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)