Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 561 - 570 of 1,171 for func_ (0.18 seconds)

  1. internal/s3select/parquet/args.go

    type ReaderArgs struct {
    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 1.4K bytes
    - Click Count (0)
  2. internal/ioutil/discard.go

    // and as such incurred latencies.
    var Discard io.Writer = discard{}
    
    // discard is /dev/null for Golang.
    type discard struct{}
    
    func (discard) Write(p []byte) (int, error) {
    	return len(p), nil
    }
    
    // DiscardReader discarded reader
    func DiscardReader(r io.Reader) {
    	Copy(Discard, r)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 1.3K bytes
    - Click Count (0)
  3. internal/config/lambda/parse.go

    	"github.com/minio/minio/internal/config/lambda/target"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...any) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  4. src/cmd/asm/internal/lex/lex_test.go

    		}
    	}
    }
    
    // lines joins the arguments together as complete lines.
    func lines(a ...string) string {
    	return strings.Join(a, "\n") + "\n"
    }
    
    // drain returns a single string representing the processed input tokens.
    func drain(input *Input) string {
    	var buf strings.Builder
    	for {
    		tok := input.Next()
    		if tok == scanner.EOF {
    			return buf.String()
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 29 07:48:38 GMT 2023
    - 5.8K bytes
    - Click Count (0)
  5. cmd/admin-handlers-users.go

    // ImportIAM - imports all IAM info into MinIO
    func (a adminAPIHandlers) ImportIAM(w http.ResponseWriter, r *http.Request) {
    	a.importIAM(w, r, "")
    }
    
    // ImportIAMV2 - imports all IAM info into MinIO
    func (a adminAPIHandlers) ImportIAMV2(w http.ResponseWriter, r *http.Request) {
    	a.importIAM(w, r, "v2")
    }
    
    // ImportIAM - imports all IAM info into MinIO
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 90.6K bytes
    - Click Count (0)
  6. internal/logger/target/console/console.go

    	output io.Writer
    }
    
    // Validate - validate if the tty can be written to
    func (c *Target) Validate() error {
    	return nil
    }
    
    // Endpoint returns the backend endpoint
    func (c *Target) Endpoint() string {
    	return ""
    }
    
    func (c *Target) String() string {
    	return "console"
    }
    
    // Send log message 'e' to console
    func (c *Target) Send(e any) error {
    	entry, ok := e.(log.Entry)
    	if !ok {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  7. internal/s3select/sql/stringfuncs.go

    		if len(parts) == 1 {
    			return "", false
    		}
    		res = parts[1]
    	}
    	return res, true
    }
    
    func dropRune(text string) (res string, ok bool) {
    	r := []rune(text)
    	if len(r) == 0 {
    		return "", false
    	}
    	return string(r[1:]), true
    }
    
    func evalSQLSubstring(s string, startIdx, length int) (res string, err error) {
    	rs := []rune(s)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  8. src/bytes/example_test.go

    	// Output:
    	// true
    	// false
    }
    
    func ExampleEqualFold() {
    	fmt.Println(bytes.EqualFold([]byte("Go"), []byte("go")))
    	// Output: true
    }
    
    func ExampleFields() {
    	fmt.Printf("Fields are: %q", bytes.Fields([]byte("  foo bar  baz   ")))
    	// Output: Fields are: ["foo" "bar" "baz"]
    }
    
    func ExampleFieldsFunc() {
    	f := func(c rune) bool {
    		return !unicode.IsLetter(c) && !unicode.IsNumber(c)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon May 12 16:07:54 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  9. tests/embedded_struct_test.go

    	}
    }
    
    type Content struct {
    	Content interface{} `gorm:"type:String"`
    }
    
    func (c Content) Value() (driver.Value, error) {
    	// mssql driver with issue on handling null bytes https://github.com/denisenkom/go-mssqldb/issues/530,
    	b, err := json.Marshal(c)
    	return string(b[:]), err
    }
    
    func (c *Content) Scan(src interface{}) error {
    	var value Content
    	str, ok := src.(string)
    	if !ok {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed May 08 04:07:58 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  10. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 2.6K bytes
    - Click Count (0)
Back to Top