Search Options

Results per page
Sort
Preferred Languages
Advance

Results 801 - 810 of 1,384 for funcs (0.02 sec)

  1. istioctl/pkg/util/configdump/wrapper.go

    	"google.golang.org/protobuf/types/known/emptypb"
    
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    type resolver struct {
    	*protoregistry.Types
    }
    
    var nonStrictResolver = &resolver{protoregistry.GlobalTypes}
    
    func (r *resolver) FindMessageByURL(url string) (protoreflect.MessageType, error) {
    	typ, err := r.Types.FindMessageByURL(url)
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor_gen.go

    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BucketBandwidthReport) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 0
    	_ = z
    	err = en.Append(0x80)
    	if err != nil {
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BucketBandwidthReport) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. cmd/auth-handler.go

    )
    
    // Verify if request has JWT.
    func isRequestJWT(r *http.Request) bool {
    	return strings.HasPrefix(r.Header.Get(xhttp.Authorization), jwtAlgorithm)
    }
    
    // Verify if request has AWS Signature Version '4'.
    func isRequestSignatureV4(r *http.Request) bool {
    	return strings.HasPrefix(r.Header.Get(xhttp.Authorization), signV4Algorithm)
    }
    
    // Verify if request has AWS Signature Version '2'.
    func isRequestSignatureV2(r *http.Request) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. internal/config/config.go

    // to operate on list of key values.
    type KVS []KV
    
    // Empty - return if kv is empty
    func (kvs KVS) Empty() bool {
    	return len(kvs) == 0
    }
    
    // Clone - returns a copy of the KVS
    func (kvs KVS) Clone() KVS {
    	return append(make(KVS, 0, len(kvs)), kvs...)
    }
    
    // GetWithDefault - returns default value if key not set
    func (kvs KVS) GetWithDefault(key string, defaultKVS KVS) string {
    	v := kvs.Get(key)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  5. cmd/xl-storage-free-version_test.go

    )
    
    func (x xlMetaV2) listFreeVersions(volume, path string) ([]FileInfo, error) {
    	fivs, err := x.ListVersions(volume, path, true)
    	if err != nil {
    		return nil, err
    	}
    	n := 0
    	for _, fiv := range fivs {
    		if fiv.TierFreeVersion() {
    			fivs[n] = fiv
    			n++
    		}
    	}
    	fivs = fivs[:n]
    	return fivs, nil
    }
    
    func TestFreeVersion(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  6. internal/grid/grid_types_test.go

    type testRequest struct {
    	Num    int
    	String string
    }
    
    type testResponse struct {
    	OrgNum    int
    	OrgString string
    	Embedded  testRequest
    }
    
    func newTestRequest() *testRequest {
    	return &testRequest{}
    }
    
    func newTestResponse() *testResponse {
    	return &testResponse{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  7. internal/disk/fdatasync_unix.go

    package disk
    
    import (
    	"os"
    	"syscall"
    )
    
    // Fdatasync is fsync on freebsd/darwin
    func Fdatasync(f *os.File) error {
    	return syscall.Fsync(int(f.Fd()))
    }
    
    // FadviseDontNeed is a no-op
    func FadviseDontNeed(f *os.File) error {
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  8. internal/disk/fdatasync_unsupported.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package disk
    
    import (
    	"os"
    )
    
    // Fdatasync is a no-op
    func Fdatasync(f *os.File) error {
    	return nil
    }
    
    // FadviseDontNeed is a no-op
    func FadviseDontNeed(f *os.File) error {
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1K bytes
    - Viewed (0)
  9. internal/once/singleton.go

    	set chan struct{}
    }
    
    // NewSingleton creates a new unset singleton.
    func NewSingleton[T any]() *Singleton[T] {
    	return &Singleton[T]{set: make(chan struct{}), v: nil}
    }
    
    // Get will return the singleton value.
    func (s *Singleton[T]) Get() *T {
    	<-s.set
    	return s.v
    }
    
    // GetNonBlocking will return the singleton value or nil if not set yet.
    func (s *Singleton[T]) GetNonBlocking() *T {
    	select {
    	case <-s.set:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  10. clause/set.go

    package clause
    
    import "sort"
    
    type Set []Assignment
    
    type Assignment struct {
    	Column Column
    	Value  interface{}
    }
    
    func (set Set) Name() string {
    	return "SET"
    }
    
    func (set Set) Build(builder Builder) {
    	if len(set) > 0 {
    		for idx, assignment := range set {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    			builder.WriteQuoted(assignment.Column)
    			builder.WriteByte('=')
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Nov 29 03:02:44 UTC 2021
    - 1.4K bytes
    - Viewed (0)
Back to top