Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 1,179 for funcs (0.03 sec)

  1. cmd/globals.go

    )
    
    var globalAuthPluginMutex sync.Mutex
    
    func newGlobalAuthNPluginFn() *idplugin.AuthNPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthNPlugin
    }
    
    func newGlobalAuthZPluginFn() *polplugin.AuthZPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthZPlugin
    }
    
    func setGlobalAuthNPlugin(authn *idplugin.AuthNPlugin) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. internal/s3select/csv/args.go

    	AllowQuotedRecordDelimiter bool   `xml:"AllowQuotedRecordDelimiter"`
    	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) (err error) {
    	args.FileHeaderInfo = none
    	args.RecordDelimiter = defaultRecordDelimiter
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. cmd/api-resources.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"encoding/base64"
    	"net/url"
    	"strconv"
    )
    
    // Parse bucket url queries
    func getListObjectsV1Args(values url.Values) (prefix, marker, delimiter string, maxkeys int, encodingType string, errCode APIErrorCode) {
    	errCode = ErrNone
    
    	if values.Get("max-keys") != "" {
    		var err error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 07 18:25:26 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  4. clause/insert_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestInsert(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Insert{}},
    			"INSERT INTO `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Insert{Modifier: "LOW_PRIORITY"}},
    			"INSERT LOW_PRIORITY INTO `users`", nil,
    		},
    		{
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 737 bytes
    - Viewed (0)
  5. cmd/batch-expire_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobExpire(b *testing.B) {
    	v := BatchJobExpire{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobExpire(b *testing.B) {
    	v := BatchJobExpire{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  6. cmd/last-minute_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgAccElem(b *testing.B) {
    	v := AccElem{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgAccElem(b *testing.B) {
    	v := AccElem{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 6.8K bytes
    - Viewed (0)
  7. cmd/warm-backend-minio.go

    		UserMetadata:         meta,
    	})
    	return remoteVersionID(res.VersionID), m.ToObjectError(err, object)
    }
    
    func (m *warmBackendMinIO) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	return m.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func newWarmBackendMinIO(conf madmin.TierMinIO, tier string) (*warmBackendMinIO, error) {
    	// Validation of credentials
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. internal/bucket/replication/filter.go

    	cachedTags map[string]string
    }
    
    // IsEmpty returns true if filter is not set
    func (f Filter) IsEmpty() bool {
    	return f.And.isEmpty() && f.Tag.IsEmpty() && f.Prefix == ""
    }
    
    // MarshalXML - produces the xml representation of the Filter struct
    // only one of Prefix, And and Tag should be present in the output.
    func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 28 18:25:46 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  9. cmd/site-replication-metrics_gen.go

    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z RStat) Msgsize() (s int) {
    	s = 1 + 6 + msgp.Int64Size + 6 + msgp.Int64Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *RTimedMetrics) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  10. src/archive/tar/reader_test.go

    		}
    	}
    }
    
    func TestReadOldGNUSparseMap(t *testing.T) {
    	populateSparseMap := func(sa sparseArray, sps []string) []string {
    		for i := 0; len(sps) > 0 && i < sa.maxEntries(); i++ {
    			copy(sa.entry(i), sps[0])
    			sps = sps[1:]
    		}
    		if len(sps) > 0 {
    			copy(sa.isExtended(), "\x80")
    		}
    		return sps
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
Back to top