Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 741 - 750 of 1,053 for struct_ (0.13 seconds)

  1. 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 cache
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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   string
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Click Count (0)
  10. 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)
Back to Top