Search Options

Results per page
Sort
Preferred Languages
Advance

Results 711 - 720 of 1,425 for Func (0.07 sec)

  1. src/cmd/asm/internal/lex/input.go

    // enabled reports whether the input is enabled by an ifdef, or is at the top level.
    func (in *Input) enabled() bool {
    	return len(in.ifdefStack) == 0 || in.ifdefStack[len(in.ifdefStack)-1]
    }
    
    func (in *Input) expectNewline(directive string) {
    	tok := in.Stack.Next()
    	if tok != '\n' {
    		in.expectText("expected newline after", directive)
    	}
    }
    
    func (in *Input) Next() ScanToken {
    	if in.peek {
    		in.peek = false
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  2. internal/auth/credentials.go

    func ContainsReservedChars(s string) bool {
    	return strings.ContainsAny(s, reservedChars)
    }
    
    // IsAccessKeyValid - validate access key for right length.
    func IsAccessKeyValid(accessKey string) bool {
    	return len(accessKey) >= accessKeyMinLen
    }
    
    // IsSecretKeyValid - validate secret key for right length.
    func IsSecretKeyValid(secretKey string) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 17:14:16 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. internal/grid/manager.go

    func (m *Manager) AddToMux(router *mux.Router, authReq func(r *http.Request) error) {
    	router.Handle(m.routePath, m.Handler(authReq))
    }
    
    // Handler returns a handler that can be used to serve grid requests.
    // This should be connected on RoutePath to the main server.
    func (m *Manager) Handler(authReq func(r *http.Request) error) http.HandlerFunc {
    	return func(w http.ResponseWriter, req *http.Request) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. src/cmd/api/main_test.go

    }
    
    func (w *Walker) emitFunc(f *types.Func) {
    	sig := f.Type().(*types.Signature)
    	if sig.Recv() != nil {
    		panic("method considered a regular function: " + f.String())
    	}
    	if w.isDeprecated(f) {
    		w.emitf("func %s //deprecated", f.Name())
    	}
    	w.emitf("func %s%s", f.Name(), w.signatureString(sig))
    }
    
    func (w *Walker) emitMethod(m *types.Selection) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 31.4K bytes
    - Viewed (0)
  5. cmd/site-replication-metrics_gen.go

    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z RStat) Msgsize() (s int) {
    	s = 1 + 6 + msgp.Int64Size + 6 + msgp.Int64Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *RTimedMetrics) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  6. internal/config/callhome/callhome.go

    }
    
    var configLock sync.RWMutex
    
    // Enabled - indicates if callhome is enabled or not
    func (c *Config) Enabled() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return c.Enable
    }
    
    // FrequencyDur - returns the currently configured callhome frequency
    func (c *Config) FrequencyDur() time.Duration {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.Frequency == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. logger/logger.go

    	SQL          string
    	RowsAffected int64
    	Err          error
    }
    
    // New trace recorder
    func (l *traceRecorder) New() *traceRecorder {
    	return &traceRecorder{Interface: l.Interface, BeginAt: time.Now()}
    }
    
    // Trace implement logger interface
    func (l *traceRecorder) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error) {
    	l.BeginAt = begin
    	l.SQL, l.RowsAffected = fc()
    	l.Err = err
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Nov 07 02:19:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  8. cmd/lock-rest-server.go

    )
    
    func newLockHandler(h grid.HandlerID) *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp] {
    	return grid.NewSingleHandler[*dsync.LockArgs, *dsync.LockResp](h, func() *dsync.LockArgs {
    		return &dsync.LockArgs{}
    	}, func() *dsync.LockResp {
    		return &dsync.LockResp{}
    	})
    }
    
    // registerLockRESTHandlers - register lock rest router.
    func registerLockRESTHandlers(gm *grid.Manager) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    	data, err := readFile(filename)
    	if err != nil {
    		return nil, err
    	}
    	return setupConfigdumpZtunnelConfigWriter(data, out)
    }
    
    func runConfigDump(ctx cli.Context, common *commonFlags, f func(cw *ztunnelDump.ConfigWriter) error) func(c *cobra.Command, args []string) error {
    	return func(c *cobra.Command, args []string) error {
    		var podName, podNamespace string
    		kubeClient, err := ctx.CLIClient()
    		if err != nil {
    			return err
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 19:17:45 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  10. internal/config/storageclass/storage-class_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package storageclass
    
    import (
    	"errors"
    	"reflect"
    	"testing"
    )
    
    func TestParseStorageClass(t *testing.T) {
    	tests := []struct {
    		storageClassEnv string
    		wantSc          StorageClass
    		expectedError   error
    	}{
    		{
    			"EC:3",
    			StorageClass{
    				Parity: 3,
    			},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 4.3K bytes
    - Viewed (0)
Back to top