- Sort Score
- Result 10 results
- Languages All
Results 581 - 590 of 1,179 for funcs (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)