Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 1,179 for funcs (0.07 sec)

  1. internal/grid/muxclient.go

    		m.closed = true
    	}
    }
    
    // respHandler
    func (m *muxClient) handleOneWayStream(respHandler chan<- Response, respServer <-chan Response) {
    	if debugPrint {
    		start := time.Now()
    		defer func() {
    			fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond))
    		}()
    	}
    	defer func() {
    		// addErrorNonBlockingClose will close the response channel
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. tests/table_test.go

    	gorm.Model
    	Name string
    }
    
    func (UserWithTableNamer) TableName(namer schema.Namer) string {
    	return namer.TableName("user")
    }
    
    func TestTableWithNamer(t *testing.T) {
    	db, _ := gorm.Open(tests.DummyDialector{}, &gorm.Config{
    		NamingStrategy: schema.NamingStrategy{
    			TablePrefix: "t_",
    		},
    	})
    
    	sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Mar 09 09:31:28 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. 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)
  4. docs/debugging/pprofgoparser/main.go

    	goTime, less, margin time.Duration
    )
    
    func init() {
    	flag.DurationVar(&less, "less", 0, "goroutine waiting less than the specified time")
    	flag.DurationVar(&goTime, "time", 0, "goroutine waiting for exactly the specified time")
    	flag.DurationVar(&margin, "margin", 0, "margin time")
    	flag.StringVar(&searchText, "search", "", "Regex to search for a text in one goroutine stacktrace")
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Mar 06 11:43:16 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. cmd/postpolicyform.go

    )
    
    // toString - Safely convert interface to string without causing panic.
    func toString(val interface{}) string {
    	switch v := val.(type) {
    	case string:
    		return v
    	default:
    		return ""
    	}
    }
    
    // toLowerString - safely convert interface to lower string
    func toLowerString(val interface{}) string {
    	return strings.ToLower(toString(val))
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. schema/callbacks_test.go

    import (
    	"reflect"
    	"sync"
    	"testing"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/schema"
    )
    
    type UserWithCallback struct{}
    
    func (UserWithCallback) BeforeSave(*gorm.DB) error {
    	return nil
    }
    
    func (UserWithCallback) AfterCreate(*gorm.DB) error {
    	return nil
    }
    
    func TestCallback(t *testing.T) {
    	user, err := schema.Parse(&UserWithCallback{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 939 bytes
    - Viewed (0)
  7. cmd/hasher.go

    // getSHA256Hash returns SHA-256 hash in hex encoding of given data.
    func getSHA256Hash(data []byte) string {
    	return hex.EncodeToString(getSHA256Sum(data))
    }
    
    // getSHA256Hash returns SHA-256 sum of given data.
    func getSHA256Sum(data []byte) []byte {
    	hash := sha256.New()
    	hash.Write(data)
    	return hash.Sum(nil)
    }
    
    // getMD5Sum returns MD5 sum of given data.
    func getMD5Sum(data []byte) []byte {
    	hash := md5.New()
    	hash.Write(data)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 27 13:00:19 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  8. internal/config/identity/openid/ecdsa-sha3_contrib.go

    	SigningMethodES3384 *jwt.SigningMethodECDSA
    	SigningMethodES3512 *jwt.SigningMethodECDSA
    )
    
    func init() {
    	// ES256
    	SigningMethodES3256 = &jwt.SigningMethodECDSA{Name: "ES3256", Hash: crypto.SHA3_256, KeySize: 32, CurveBits: 256}
    	jwt.RegisterSigningMethod(SigningMethodES3256.Alg(), func() jwt.SigningMethod {
    		return SigningMethodES3256
    	})
    
    	// ES384
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  9. 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)
  10. internal/http/request-recorder.go

    	buf bytes.Buffer
    	// total bytes read including header size
    	bytesRead int
    }
    
    // Close is a no operation closer
    func (r *RequestRecorder) Close() error {
    	// no-op
    	return nil
    }
    
    // Read reads from the internal reader and counts/save the body in the memory
    func (r *RequestRecorder) Read(p []byte) (n int, err error) {
    	n, err = r.Reader.Read(p)
    	r.bytesRead += n
    
    	if r.LogBody {
    		r.buf.Write(p[:n])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top