Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,214 for Func (0.03 sec)

  1. migrator/table_type.go

    }
    
    // Schema returns the schema of the table.
    func (ct TableType) Schema() string {
    	return ct.SchemaValue
    }
    
    // Name returns the name of the table.
    func (ct TableType) Name() string {
    	return ct.NameValue
    }
    
    // Type returns the type of the table.
    func (ct TableType) Type() string {
    	return ct.TypeValue
    }
    
    // Comment returns the comment of current table.
    func (ct TableType) Comment() (comment string, ok bool) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri May 05 07:58:27 UTC 2023
    - 688 bytes
    - Viewed (0)
  2. internal/config/identity/openid/openid.go

    	ProviderCfgs map[string]*providerCfg
    
    	pubKeys          publicKeys
    	roleArnPolicyMap map[arn.ARN]string
    
    	transport   http.RoundTripper
    	closeRespFn func(io.ReadCloser)
    }
    
    // Clone returns a cloned copy of OpenID config.
    func (r *Config) Clone() Config {
    	if r == nil {
    		return Config{}
    	}
    	cfg := Config{
    		Enabled:            r.Enabled,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. cmd/iam-object-store.go

    	usersSysType UsersSysType
    
    	objAPI ObjectLayer
    }
    
    func newIAMObjectStore(objAPI ObjectLayer, usersSysType UsersSysType) *IAMObjectStore {
    	return &IAMObjectStore{
    		iamCache:     newIamCache(),
    		objAPI:       objAPI,
    		usersSysType: usersSysType,
    	}
    }
    
    func (iamOS *IAMObjectStore) rlock() *iamCache {
    	iamOS.RLock()
    	return iamOS.iamCache
    }
    
    func (iamOS *IAMObjectStore) runlock() {
    	iamOS.RUnlock()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  4. cmd/local-locker_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *localLockMap) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0004 uint32
    	zb0004, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if (*z) == nil {
    		(*z) = make(localLockMap, zb0004)
    	} else if len((*z)) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  5. internal/dsync/drwmutex.go

    type Granted struct {
    	index   int
    	lockUID string // Locked if set with UID string, unlocked if empty
    }
    
    func (g *Granted) isLocked() bool {
    	return isLocked(g.lockUID)
    }
    
    func isLocked(uid string) bool {
    	return len(uid) > 0
    }
    
    // NewDRWMutex - initializes a new dsync RW mutex.
    func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex {
    	restClnts, _ := clnt.GetLockers()
    	sort.Strings(names)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. cmd/sftp-server_test.go

    )
    
    type MockConnMeta struct {
    	username string
    }
    
    func (m *MockConnMeta) User() string {
    	return m.username
    }
    
    func (m *MockConnMeta) SessionID() []byte {
    	return []byte{}
    }
    
    func (m *MockConnMeta) ClientVersion() []byte {
    	return []byte{}
    }
    
    func (m *MockConnMeta) ServerVersion() []byte {
    	return []byte{}
    }
    
    func (m *MockConnMeta) RemoteAddr() net.Addr {
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  7. internal/config/errors-utils.go

    // Msg - Replace the current error's message
    func (u Err) Msg(m string) Err {
    	e := u.Clone()
    	e.msg = m
    	return e
    }
    
    // Msgf - Replace the current error's message
    func (u Err) Msgf(m string, args ...interface{}) Err {
    	e := u.Clone()
    	if len(args) == 0 {
    		e.msg = m
    	} else {
    		e.msg = fmt.Sprintf(m, args...)
    	}
    	return e
    }
    
    // Hint - Replace the current error's message
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  8. src/bufio/example_test.go

    package bufio_test
    
    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"os"
    	"strconv"
    	"strings"
    )
    
    func ExampleWriter() {
    	w := bufio.NewWriter(os.Stdout)
    	fmt.Fprint(w, "Hello, ")
    	fmt.Fprint(w, "world!")
    	w.Flush() // Don't forget to flush!
    	// Output: Hello, world!
    }
    
    func ExampleWriter_AvailableBuffer() {
    	w := bufio.NewWriter(os.Stdout)
    	for _, i := range []int64{1, 2, 3, 4} {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. internal/grid/grid_types_msgp_test.go

    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z testRequest) Msgsize() (s int) {
    	s = 1 + 4 + msgp.IntSize + 7 + msgp.StringPrefixSize + len(z.String)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *testResponse) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 8.1K bytes
    - Viewed (0)
  10. cmd/endpoint.go

    }
    
    // Type - returns type of endpoint.
    func (endpoint Endpoint) Type() EndpointType {
    	if endpoint.Host == "" {
    		return PathEndpointType
    	}
    
    	return URLEndpointType
    }
    
    // HTTPS - returns true if secure for URLEndpointType.
    func (endpoint Endpoint) HTTPS() bool {
    	return endpoint.Scheme == "https"
    }
    
    // GridHost returns the host to be used for grid connections.
    func (endpoint Endpoint) GridHost() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
Back to top