- Sort Score
- Result 10 results
- Languages All
Results 551 - 560 of 1,179 for funcs (0.1 sec)
-
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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.4K bytes - Viewed (0) -
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)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Nov 06 22:26:08 UTC 2023 - 1.3K bytes - Viewed (0) -
cmd/post-policy_test.go
retStr += conditionStr retStr += "}" return []byte(retStr) } // Wrapper func TestPostPolicyReservedBucketExploit(t *testing.T) { ExecObjectLayerTestWithDirs(t, testPostPolicyReservedBucketExploit) } // testPostPolicyReservedBucketExploit is a test for the exploit fixed in PR // #16849 func testPostPolicyReservedBucketExploit(obj ObjectLayer, instanceType string, dirs []string, t TestErrHandler) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/copy-part-range.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "net/http" "net/url" ) // Writes S3 compatible copy part range error. func writeCopyPartErr(ctx context.Context, w http.ResponseWriter, err error, url *url.URL) { switch err { case errInvalidRange: writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidCopyPartRange), url) return
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 18 03:27:04 UTC 2021 - 2.5K bytes - Viewed (0) -
src/cmd/asm/internal/arch/mips.go
"cmd/internal/obj/mips" ) func jumpMIPS(word string) bool { switch word { case "BEQ", "BFPF", "BFPT", "BGEZ", "BGEZAL", "BGTZ", "BLEZ", "BLTZ", "BLTZAL", "BNE", "JMP", "JAL", "CALL": return true } return false } // IsMIPSCMP reports whether the op (as defined by an mips.A* constant) is // one of the CMP instructions that require special handling. func IsMIPSCMP(op obj.As) bool { switch op {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Mar 04 19:06:44 UTC 2020 - 1.7K bytes - Viewed (0) -
callbacks/helper.go
package callbacks import ( "reflect" "sort" "gorm.io/gorm" "gorm.io/gorm/clause" ) // ConvertMapToValuesForCreate convert map to values func ConvertMapToValuesForCreate(stmt *gorm.Statement, mapValue map[string]interface{}) (values clause.Values) { values.Columns = make([]clause.Column, 0, len(mapValue)) selectColumns, restricted := stmt.SelectAndOmitColumns(true, false) keys := make([]string, 0, len(mapValue))
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Apr 14 12:32:57 UTC 2022 - 3.7K bytes - Viewed (0) -
cmd/healthcheck-handler.go
package cmd import ( "context" "net/http" "strconv" "time" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/kms" ) const unavailable = "offline" func checkHealth(w http.ResponseWriter) ObjectLayer { objLayer := newObjectLayerFn() if objLayer == nil { w.Header().Set(xhttp.MinIOServerStatus, unavailable) writeResponse(w, http.StatusServiceUnavailable, nil, mimeNone)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/httprange.go
func (h *HTTPRangeSpec) String(resourceSize int64) string { if h == nil { return "" } off, length, err := h.GetOffsetLength(resourceSize) if err != nil { return "" } return fmt.Sprintf("%d-%d", off, off+length-1) } // ToHeader returns the Range header value. func (h *HTTPRangeSpec) ToHeader() (string, error) { if h == nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 09 08:44:07 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/metrics-v2.go
} // RegisterRead register the metrics populator function to be used // to populate new values upon cache invalidation. func (g *MetricsGroupV2) RegisterRead(read func(context.Context) []MetricV2) { g.metricsCache = cachevalue.NewFromFunc(g.cacheInterval, cachevalue.Opts{ReturnLastGood: true}, func(ctx context.Context) ([]MetricV2, error) { if g.metricsGroupOpts.dependGlobalObjectAPI { objLayer := newObjectLayerFn()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0) -
callbacks/query.go
"gorm.io/gorm/schema" "gorm.io/gorm/utils" ) func Query(db *gorm.DB) { if db.Error == nil { BuildQuerySQL(db) if !db.DryRun && db.Error == nil { rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...) if err != nil { db.AddError(err) return } defer func() { db.AddError(rows.Close()) }() gorm.Scan(rows, db, 0)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:03:42 UTC 2024 - 10.1K bytes - Viewed (0)