- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for wrappers (0.15 sec)
-
internal/lock/lock.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. // Package lock - implements filesystem locking wrappers around an // open file descriptor. package lock import ( "errors" "os" "sync" ) // ErrAlreadyLocked is returned if the underlying fd is already locked.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K bytes - Viewed (0) -
cmd/peer-rest-server.go
"github.com/minio/minio/internal/pubsub" "github.com/minio/mux" "github.com/minio/pkg/v2/logger/message/log" ) // To abstract a node over network. type peerRESTServer struct{} var ( // Types & Wrappers aoBucketInfo = grid.NewArrayOf[*BucketInfo](func() *BucketInfo { return &BucketInfo{} }) aoMetricsGroup = grid.NewArrayOf[*MetricV2](func() *MetricV2 { return &MetricV2{} })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/object_api_suite_test.go
eof bool data []byte } func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) { if r.eof { return 0, io.EOF } n = copy(p, r.data) r.eof = true return n, nil } // Wrapper for calling testMakeBucket for both Erasure and FS. func TestMakeBucket(t *testing.T) { ExecObjectLayerTest(t, testMakeBucket) } // Tests validate bucket creation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/object-api-deleteobject_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "crypto/md5" "encoding/hex" "strings" "testing" ) // Wrapper for calling DeleteObject tests for both Erasure multiple disks and single node setup. func TestDeleteObject(t *testing.T) { ExecObjectLayerTest(t, testDeleteObject) } // Unit test for DeleteObject in general.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/object-api-getobjectinfo_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "testing" ) // Wrapper for calling GetObjectInfo tests for both Erasure multiple disks and single node setup. func TestGetObjectInfo(t *testing.T) { ExecObjectLayerTest(t, testGetObjectInfo) } // Testing GetObjectInfo().
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 5.6K bytes - Viewed (0) -
internal/grid/types.go
var t T return &t }, }, emptySz: sz, } } func (p *JSONPool[T]) new() *T { var zero T t := p.pool.Get().(*T) *t = zero return t } // JSON is a wrapper around a T object that can be serialized. // There is an internal value type JSON[T any] struct { p *JSONPool[T] val *T } // NewJSON returns a new JSONPool. // No initial value is set.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} n, err := d.w.Write(p) if err == nil && n == len(p) { d.tracker.logSuccess() } return n, err } // diskHealthReader provides a wrapper that will update disk health on // ctx, on every successful read. // This should only be used directly at the os/syscall level, // otherwise buffered operations may return false health checks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/globals.go
globalSiteResyncMetrics *siteResyncMetrics // Is set to true when Bucket federation is requested // and is 'true' when etcdConfig.PathPrefix is empty globalBucketFederation bool // Allocated DNS config wrapper over etcd client. globalDNSConfig dns.Store // GlobalKMS initialized KMS configuration GlobalKMS kms.KMS // Common lock for various subsystems performing the leader tasks globalLeaderLock *sharedLock
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/erasure-object.go
case mrfCheck <- fi.ShallowCopy(): case <-ctx.Done(): return fi, onlineMeta, onlineDisks, toObjectErr(ctx.Err(), bucket, object) } return fi, onlineMeta, onlineDisks, nil } // getObjectInfo - wrapper for reading object metadata and constructs ObjectInfo. func (er erasureObjects) getObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/iam.go
} select { case <-sys.configLoaded: return sys.store.ListSTSAccounts(ctx, accessKey) case <-ctx.Done(): return nil, ctx.Err() } } // GetServiceAccount - wrapper method to get information about a service account func (sys *IAMSys) GetServiceAccount(ctx context.Context, accessKey string) (auth.Credentials, *policy.Policy, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1)