Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 173 for Jasmin (0.19 sec)

  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)
  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)
  3. cmd/tier_gen.go

    				err = msgp.WrapError(err, "Tiers")
    				return
    			}
    			if z.Tiers == nil {
    				z.Tiers = make(map[string]madmin.TierConfig, zb0002)
    			} else if len(z.Tiers) > 0 {
    				for key := range z.Tiers {
    					delete(z.Tiers, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    				var za0002 madmin.TierConfig
    				za0001, err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "Tiers")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 20 00:53:08 GMT 2023
    - 4K bytes
    - Viewed (0)
  4. 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)
  5. cmd/data-usage-utils.go

    }
    
    func (dui DataUsageInfo) tierStats() []madmin.TierInfo {
    	if dui.TierStats == nil {
    		return nil
    	}
    
    	if globalTierConfigMgr.Empty() {
    		return nil
    	}
    
    	ts := make(map[string]madmin.TierStats)
    	dui.TierStats.populateStats(ts)
    
    	infos := make([]madmin.TierInfo, 0, len(ts))
    	for tier, stats := range ts {
    		infos = append(infos, madmin.TierInfo{
    			Name:  tier,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  6. cmd/config.go

    	[]madmin.ConfigHistoryEntry, error,
    ) {
    	var configHistory []madmin.ConfigHistoryEntry
    
    	// List all kvs
    	marker := ""
    	for {
    		res, err := objAPI.ListObjects(ctx, minioMetaBucket, minioConfigHistoryPrefix, marker, "", maxObjectList)
    		if err != nil {
    			return nil, err
    		}
    		for _, obj := range res.Objects {
    			cfgEntry := madmin.ConfigHistoryEntry{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
  7. 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)
  8. istioctl/pkg/writer/envoy/clusters/clusters.go

    		}
    	}
    	return "unknown"
    }
    
    func retrieveEndpointPort(l *admin.HostStatus) uint32 {
    	addr := l.Address.GetSocketAddress()
    	if addr != nil {
    		return addr.GetPortValue()
    	}
    	return 0
    }
    
    func retrieveEndpointStatus(l *admin.HostStatus) core.HealthStatus {
    	return l.HealthStatus.GetEdsHealthStatus()
    }
    
    func retrieveFailedOutlierCheck(l *admin.HostStatus) bool {
    	return l.HealthStatus.GetFailedOutlierCheck()
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 5.8K bytes
    - Viewed (0)
  9. istioctl/pkg/util/configdump/wrapper.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package configdump
    
    import (
    	admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3"
    	exprpb "google.golang.org/genproto/googleapis/api/expr/v1alpha1"
    	"google.golang.org/protobuf/reflect/protoreflect"
    	"google.golang.org/protobuf/reflect/protoregistry"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  10. cmd/erasure-healing-common_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"fmt"
    	"os"
    	"path/filepath"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    // Returns the latest updated FileInfo files and error in case of failure.
    func getLatestFileInfo(ctx context.Context, partsMetadata []FileInfo, defaultParityCount int, errs []error) (FileInfo, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
Back to top