- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for committed (0.2 sec)
-
tests/connpool_test.go
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Feb 06 02:54:40 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/event/target/kafka.go
func (target *KafkaTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } // If batch is enabled, the event will be batched in memory // and will be committed once the batch is full. if target.batch != nil { return target.addToBatch(key) } eventData, eErr := target.store.Get(key.Name) if eErr != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
finisher_api.go
func (db *DB) Commit() *DB { if committer, ok := db.Statement.ConnPool.(TxCommitter); ok && committer != nil && !reflect.ValueOf(committer).IsNil() { db.AddError(committer.Commit()) } else { db.AddError(ErrInvalidTransaction) } return db } // Rollback rollbacks the changes in a transaction func (db *DB) Rollback() *DB { if committer, ok := db.Statement.ConnPool.(TxCommitter); ok && committer != nil {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 22.7K bytes - Viewed (0) -
src/archive/tar/reader.go
if err != nil || numEntries < 0 || int(2*numEntries) < int(numEntries) { return nil, ErrHeader } // Parse for all member entries. // numEntries is trusted after this since a potential attacker must have // committed resources proportional to what this library used. if err := feedTokens(2 * numEntries); err != nil { return nil, err } spd := make(sparseDatas, 0, numEntries) for i := int64(0); i < numEntries; i++ {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z *DeleteOptions) EncodeMsg(en *msgp.Writer) (err error) { // check for omitted fields zb0001Len := uint32(5) var zb0001Mask uint8 /* 5 bits */ _ = zb0001Mask if z.OldDataDir == "" { zb0001Len-- zb0001Mask |= 0x10 } // variable map header, size zb0001Len
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K bytes - Viewed (0) -
cmd/admin-server-info.go
gcStats.Pause = gcStats.Pause[len(gcStats.Pause)-5:] } props := madmin.ServerProperties{ Endpoint: addr, Uptime: UTCNow().Unix() - globalBootTime.Unix(), Version: Version, CommitID: CommitID, Network: network, MemStats: madmin.MemStats{ Alloc: memstats.Alloc, TotalAlloc: memstats.TotalAlloc, Mallocs: memstats.Mallocs, Frees: memstats.Frees,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/xl-storage-format-v2_gen.go
o = msgp.Require(b, z.Msgsize()) // check for omitted fields zb0001Len := uint32(1) var zb0001Mask uint8 /* 1 bits */ _ = zb0001Mask if z.ObjectV2 == nil { zb0001Len-- zb0001Mask |= 0x1 } // variable map header, size zb0001Len o = append(o, 0x80|uint8(zb0001Len)) if zb0001Len == 0 { return } if (zb0001Mask & 0x1) == 0 { // if not omitted // string "V2Obj"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 53.8K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
// There are some caveats regarding the following: // 1. object lock config - object lock should have been specified at time of bucket creation. Only default retention settings are imported here. // 2. Replication config - is omitted from import as remote target credentials are not available from exported data for security reasons. // 3. lifecycle config - if transition rules are present, tier name needs to have been defined.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/common-main.go
envEntry = strings.TrimSpace(envEntry) if envEntry == "" { // Skip all empty lines return envKV{ Skip: true, }, nil } if strings.HasPrefix(envEntry, "#") { // Skip commented lines return envKV{ Skip: true, }, nil } envTokens := strings.SplitN(strings.TrimSpace(strings.TrimPrefix(envEntry, "export")), config.EnvSeparator, 2) if len(envTokens) != 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/data-usage-cache_gen.go
} if (zb0001Mask & 0x80) == 0 { // if not omitted // string "rs" o = append(o, 0xa2, 0x72, 0x73) if z.ReplicationStats == nil { o = msgp.AppendNil(o) } else { o, err = z.ReplicationStats.MarshalMsg(o) if err != nil { err = msgp.WrapError(err, "ReplicationStats") return } } } if (zb0001Mask & 0x100) == 0 { // if not omitted // string "ats"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 100.8K bytes - Viewed (0)