- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 56 for martin (0.17 sec)
-
cmd/site-replication.go
sites, err := c.GetClusterInfo(ctx) if err != nil { return madmin.ReplicateEditStatus{}, errSRBackendIssue(err) } if !sites.Enabled { return madmin.ReplicateEditStatus{}, errSRNotEnabled } var ( found bool admClient *madmin.AdminClient )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
internal/config/identity/ldap/config.go
func (l *Config) GetConfigList(s config.Config) ([]madmin.IDPListItem, error) { ldapConfigs, err := s.GetAvailableTargets(config.IdentityLDAPSubSys) if err != nil { return nil, err } // For now, ldapConfigs will only have a single entry for the default // configuration. var res []madmin.IDPListItem for _, cfg := range ldapConfigs { res = append(res, madmin.IDPListItem{ Type: "ldap", Name: cfg,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 7.9K bytes - Viewed (2) -
cmd/metrics-resource.go
updateResourceMetrics(driveSubsystem, totalInodes, float64(di.FreeInodes+di.UsedInodes), labels, false) } } } func collectLocalResourceMetrics() { var types madmin.MetricType = madmin.MetricsDisk | madmin.MetricNet | madmin.MetricsMem | madmin.MetricsCPU m := collectLocalMetrics(types, collectMetricsOpts{ hosts: map[string]struct{}{ globalLocalNodeName: {}, }, })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/consolelogger.go
sync.RWMutex pubsub *pubsub.PubSub[log.Info, madmin.LogMask] console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
// // We encode the xml bytes as base64 to ensure there are no encoding // errors. cfgStr := base64.StdEncoding.EncodeToString(configData) replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{ Type: madmin.SRBucketMetaTypeVersionConfig, Bucket: bucket, Versioning: &cfgStr, UpdatedAt: updatedAt, })) writeSuccessResponseHeadersOnly(w) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
cmd/bucket-replication.go
if opts.VersionSuspended { return &madmin.BucketTargets{} } if opts.ProxyRequest || (opts.ProxyHeaderSet && !opts.ProxyRequest) { return &madmin.BucketTargets{} } cfg, err := getReplicationConfig(ctx, bucket) if err != nil || cfg == nil { replLogOnceIf(ctx, err, bucket) return &madmin.BucketTargets{} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/warm-backend-minio.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "io" "math" "net/url" "strings" "github.com/minio/madmin-go/v3" minio "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/credentials" ) type warmBackendMinIO struct { warmBackendS3 } var _ WarmBackend = (*warmBackendMinIO)(nil) const (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/common-main.go
gob.Register(StorageErr("")) gob.Register(madmin.TimeInfo{}) gob.Register(madmin.XFSErrorConfigs{}) gob.Register(map[string]string{}) gob.Register(map[string]interface{}{}) // All minio-go and madmin-go API operations shall be performed only once, // another way to look at this is we are turning off retries. minio.MaxRetry = 1 madmin.MaxRetry = 1 currentReleaseTime, _ = GetCurrentReleaseTime()
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/admin-bucket-handlers.go
case bucketLifecycleConfig: st.Lifecycle = madmin.MetaStatus{IsSet: true, Err: errMsg} case bucketSSEConfig: st.SSEConfig = madmin.MetaStatus{IsSet: true, Err: errMsg} case bucketTaggingConfig: st.Tagging = madmin.MetaStatus{IsSet: true, Err: errMsg} case bucketQuotaConfigFile: st.Quota = madmin.MetaStatus{IsSet: true, Err: errMsg} case objectLockConfig:
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/warm-backend.go
// checkWarmBackend on it. func newWarmBackend(ctx context.Context, tier madmin.TierConfig, probe bool) (d WarmBackend, err error) { switch tier.Type { case madmin.S3: d, err = newWarmBackendS3(*tier.S3, tier.Name) case madmin.Azure: d, err = newWarmBackendAzure(*tier.Azure, tier.Name) case madmin.GCS: d, err = newWarmBackendGCS(*tier.GCS, tier.Name) case madmin.MinIO: d, err = newWarmBackendMinIO(*tier.MinIO, tier.Name)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0)