- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for serogroup (0.2 sec)
-
cmd/notification.go
func (sys *NotificationSys) LoadPolicyMapping(userOrGroup string, userType IAMUserType, isGroup bool) []NotificationPeerErr { ng := WithNPeers(len(sys.peerClients)).WithRetries(1) for idx, client := range sys.peerClients { client := client ng.Go(GlobalContext, func() error { if client == nil { return errPeerNotReachable } return client.LoadPolicyMapping(userOrGroup, userType, isGroup) }, idx, *client.host) }
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/peer-s3-server.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "github.com/minio/madmin-go/v3" "github.com/minio/pkg/v2/sync/errgroup" ) const ( peerS3Bucket = "bucket" peerS3BucketDeleted = "bucket-deleted" peerS3BucketForceCreate = "force-create" peerS3BucketForceDelete = "force-delete" )
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/peer-s3-client.go
package cmd import ( "context" "errors" "fmt" "sort" "strconv" "sync/atomic" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/grid" "github.com/minio/pkg/v2/sync/errgroup" "golang.org/x/exp/slices" ) var errPeerOffline = errors.New("peer is offline") type peerS3Client interface { ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error)
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleReleaseNotesPlugin.java
TaskProvider<RenderMarkdown> releaseNotesMarkdown = tasks.register("releaseNotesMarkdown", RenderMarkdown.class, task -> { task.setGroup("release notes"); task.setDescription("Generate release notes HTML page from Markdown."); task.getInputEncoding().convention(Charset.defaultCharset().name());
Java - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Fri Mar 10 11:32:18 GMT 2023 - 5.4K bytes - Viewed (0) -
cmd/format-erasure.go
"github.com/minio/minio/internal/config" "github.com/minio/minio/internal/config/storageclass" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/sync/errgroup" ) const ( // Represents Erasure backend. formatBackendErasure = "xl" // Represents Erasure backend - single drive formatBackendErasureSingle = "xl-single"
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 27.8K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
package cmd import ( "context" "fmt" "runtime" "testing" "time" "github.com/minio/madmin-go/v3" minio "github.com/minio/minio-go/v7" "github.com/minio/pkg/v2/sync/errgroup" ) func runAllIAMConcurrencyTests(suite *TestSuiteIAM, c *check) { suite.SetUpSuite(c) suite.TestDeleteUserRace(c) suite.TearDownSuite(c) } func TestIAMInternalIDPConcurrencyServerSuite(t *testing.T) {
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.9K bytes - Viewed (0) -
cmd/iam.go
err = errServerNotInitialized return } userOrGroup := r.User var isGroup bool if userOrGroup == "" { isGroup = true userOrGroup = r.Group } if isGroup { _, err = sys.GetGroupDescription(userOrGroup) if err != nil { return } } else { var isTemp bool isTemp, _, err = sys.IsTempUser(userOrGroup) if err != nil && err != errNoSuchUser { return
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Wed Apr 10 22:37:42 GMT 2024 - 64.4K bytes - Viewed (1) -
cmd/erasure-common.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "fmt" "io" "math/rand" "sync" "time" "github.com/minio/pkg/v2/sync/errgroup" ) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano()))
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleBuildDocumentationPlugin.java
tasks.register("serveDocs", JavaExec.class, task -> { task.setDescription("Runs a local webserver to serve generated documentation."); task.setGroup("documentation"); int webserverPort = 8000; task.getJavaLauncher().set( task.getProject().getExtensions().getByType(JavaToolchainService.class)
Java - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Thu Feb 22 00:59:44 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/erasure-multipart.go
xhttp "github.com/minio/minio/internal/http" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/mimedb" "github.com/minio/pkg/v2/sync/errgroup" ) func (er erasureObjects) getUploadIDDir(bucket, object, uploadID string) string { uploadUUID := uploadID uploadBytes, err := base64.RawURLEncoding.DecodeString(uploadID) if err == nil {
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42K bytes - Viewed (0)