- Sort Score
- Result 10 results
- Languages All
Results 661 - 670 of 1,039 for struct (1.45 sec)
-
internal/s3select/json/record.go
// MarshalJSON instance for []byte that assumes that byte-slice is // already serialized JSON func (b RawJSON) MarshalJSON() ([]byte, error) { return b, nil } // Record - is JSON record. type Record struct { // Used in Set(), Marshal*() KVS jstream.KVS SelectFormat sql.SelectObjectFormat } // Get - gets the value for a column name. func (r *Record) Get(name string) (*sql.Value, error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.2K bytes - Viewed (0) -
internal/s3select/simdj/record.go
"github.com/minio/minio/internal/s3select/jstream" "github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Record - is JSON record. type Record struct { // object object simdjson.Object } // Get - gets the value for a column name. func (r *Record) Get(name string) (*sql.Value, error) { elem := r.object.FindKey(name, nil) if elem == nil {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.4K bytes - Viewed (0) -
internal/http/server.go
DefaultMaxHeaderBytes = 1 * humanize.MiByte ) // Server - extended http.Server supports multiple addresses to serve and enhanced connection handling. type Server struct { http.Server Addrs []string // addresses on which the server listens for new connection. TCPOptions TCPOptions // all the configurable TCP conn specific configurable options.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.5K bytes - Viewed (0) -
internal/logger/targets.go
Stats() types.TargetStats Init(ctx context.Context) error IsOnline(ctx context.Context) bool Cancel() Send(ctx context.Context, entry any) error Type() types.TargetType } type targetsList struct { list []Target mu sync.RWMutex } func newTargetsList() *targetsList { return &targetsList{} } func (tl *targetsList) get() []Target { tl.mu.RLock() defer tl.mu.RUnlock()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6K bytes - Viewed (0) -
cmd/metacache_test.go
lastHandout: metaCacheTestsetTimestamp.Add(-7 * 24 * time.Hour), dataVersion: metacacheStreamVersion, }, } func Test_baseDirFromPrefix(t *testing.T) { tests := []struct { name string prefix string want string }{ { name: "root", prefix: "object.ext", want: "", }, { name: "rootdotslash", prefix: "./object.ext",
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Sep 08 18:06:45 UTC 2021 - 6.8K bytes - Viewed (0) -
internal/config/scanner/scanner.go
EnvDelayLegacy = "MINIO_CRAWLER_DELAY" EnvMaxWait = "MINIO_SCANNER_MAX_WAIT" EnvMaxWaitLegacy = "MINIO_CRAWLER_MAX_WAIT" ) // Config represents the heal settings. type Config struct { // Delay is the sleep multiplier. Delay float64 `json:"delay"` // Sleep always or based on incoming S3 requests. IdleMode int32 // 0 => on, 1 => off // Alert upon this many excess object versions
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
schema/naming_test.go
} columdName := ns.ColumnName("", "NameCID") if columdName != "name_cid" { t.Errorf("invalid column name generated, got %v", columdName) } } type CustomReplacer struct { f func(string) string } func (r CustomReplacer) Replace(name string) string { return r.f(name) } func TestCustomReplacer(t *testing.T) { ns := NamingStrategy{ TablePrefix: "public.",
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Tue May 30 02:00:48 UTC 2023 - 7K bytes - Viewed (0) -
cmd/object-lambda-handlers_test.go
levent "github.com/minio/minio/internal/config/lambda/event" xhttp "github.com/minio/minio/internal/http" ) func TestGetObjectLambdaHandler(t *testing.T) { testCases := []struct { name string statusCode int body string contentType string expectStatus int }{ { name: "Success 206 Partial Content", statusCode: 206,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jul 18 21:56:31 UTC 2025 - 5.2K bytes - Viewed (0) -
tests/scopes_test.go
} if err := DB.Scopes(userTable).Select("max(id)").Scan(&maxId).Error; err != nil { t.Errorf("select max(id)") } } func TestComplexScopes(t *testing.T) { tests := []struct { name string queryFn func(tx *gorm.DB) *gorm.DB expected string }{ { name: "depth_1", queryFn: func(tx *gorm.DB) *gorm.DB { return tx.Scopes(
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Jan 12 08:42:21 UTC 2024 - 3.3K bytes - Viewed (0) -
src/cmd/asm/internal/asm/operand_test.go
t.Errorf("fail at %s as function address: got %s, %v; expected %s, %v", test.input, name, ok, wantName, isFuncSym) } } }) } } type operandTest struct { input, output string } type badOperandTest struct { input, error string } // Examples collected by scanning all the assembly in the standard repo. var amd64OperandTests = []operandTest{ {"$(-1.0)", "$(-1.0)"},
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 23.9K bytes - Viewed (0)