- Sort Score
- Num 10 results
- Language All
Results 741 - 750 of 1,053 for struct_ (0.13 seconds)
-
cmd/bucket-replication-stats.go
for _, s := range b.Stats { if s.hasReplicationUsage() { return true } } return false } // ReplicationStats holds the global in-memory replication stats type ReplicationStats struct { // map of site deployment ID to site replication status // for site replication - maintain stats at global level srStats *SRStats // active worker stats workers *ActiveWorkerStat // queue stats cacheCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 13.6K bytes - Click Count (0) -
cmd/xl-storage-format-utils_test.go
"slices" "sort" "testing" "time" "github.com/minio/minio/internal/bucket/lifecycle" xhttp "github.com/minio/minio/internal/http" ) func Test_hashDeterministicString(t *testing.T) { tests := []struct { name string arg map[string]string }{ { name: "zero", arg: map[string]string{}, }, { name: "nil", arg: nil, }, { name: "one",
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.1K bytes - Click Count (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.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (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()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6K bytes - Click Count (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 {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.4K bytes - Click Count (0) -
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) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.2K bytes - Click Count (0) -
apache-maven/src/main/appended-resources/licenses/BSD-2-Clause.txt
TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri May 17 19:14:22 GMT 2024 - 1.2K bytes - Click Count (0) -
docs/config/README.md
list_quorum (string) set the acceptable quorum expected for list operations e.g. "optimal", "reduced", "disk", "strict", "auto" (default: 'strict') replication_priority (string) set replication priority (default: 'auto') replication_max_workers (number) set the maximum number of replication workers (default: '500')
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 18.1K bytes - Click Count (1) -
cmd/object-api-putobject_test.go
data = []byte("hello") fiveMBBytes = bytes.Repeat([]byte("a"), 5*humanize.MiByte) ) invalidMD5 := getMD5Hash([]byte("meh")) invalidMD5Header := md5Header([]byte("meh")) testCases := []struct { bucketName string objName string inputData []byte inputMeta map[string]string inputSHA256 string inputDataSize int64 // expected error output. expectedMd5 stringCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 25.8K bytes - Click Count (0) -
cmd/erasure-object_test.go
if err != nil { t.Fatal(err) } } func TestErasureDeleteObjectBasic(t *testing.T) { testCases := []struct { bucket string object string expectedErr error }{ {".test", "dir/obj", BucketNameInvalid{Bucket: ".test"}}, {"----", "dir/obj", BucketNameInvalid{Bucket: "----"}},Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 38.3K bytes - Click Count (0)