Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for subsystem (0.15 sec)

  1. internal/logger/logonce.go

    // on how it is used.
    func LogOnceIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    	if logIgnoreError(err) {
    		return
    	}
    	logOnce.logOnceIf(ctx, subsystem, err, id, errKind...)
    }
    
    // LogOnceConsoleIf - similar to LogOnceIf but exclusively only logs to console target.
    func LogOnceConsoleIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  2. internal/config/ilm/ilm.go

    	"github.com/minio/pkg/v2/env"
    )
    
    // DefaultKVS default configuration values for ILM subsystem
    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   transitionWorkers,
    		Value: "100",
    	},
    	config.KV{
    		Key:   expirationWorkers,
    		Value: "100",
    	},
    }
    
    // Config represents the different configuration values for ILM subsystem
    type Config struct {
    	TransitionWorkers int
    	ExpirationWorkers int
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  3. internal/config/ilm/help.go

    )
    
    var (
    	defaultHelpPostfix = func(key string) string {
    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	// HelpILM holds configuration keys and their default values for the ILM
    	// subsystem
    	HelpILM = config.HelpKVS{
    		config.HelpKV{
    			Key:         transitionWorkers,
    			Type:        "number",
    			Description: `set the number of transition workers` + defaultHelpPostfix(transitionWorkers),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  4. internal/config/api/help.go

    var (
    	defaultHelpPostfix = func(key string) string {
    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	// Help holds configuration keys and their default values for api subsystem.
    	Help = config.HelpKVS{
    		config.HelpKV{
    			Key:         apiRequestsMax,
    			Description: `set the maximum number of concurrent requests` + defaultHelpPostfix(apiRequestsMax),
    			Optional:    true,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 15 01:07:19 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  5. cmd/consolelogger.go

    	if !globalIsDistErasure {
    		sys.nodeName = ""
    		return
    	}
    
    	host, err := xnet.ParseHost(globalLocalNodeName)
    	if err != nil {
    		logger.FatalIf(err, "Unable to start console logging subsystem")
    	}
    
    	sys.nodeName = host.Name
    }
    
    // HasLogListeners returns true if console log listeners are registered
    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    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)
  6. internal/config/lambda/parse.go

    var ErrTargetsOffline = errors.New("one or more targets are offline. Please use `mc admin info --json` to check the offline targets")
    
    // TestSubSysLambdaTargets - tests notification targets of given subsystem
    func TestSubSysLambdaTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) error {
    	if err := checkValidLambdaKeysForSubSys(subSys, cfg[subSys]); err != nil {
    		return err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  7. cmd/bucket-policy.go

    	"github.com/minio/minio/internal/handlers"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v2/policy"
    )
    
    // PolicySys - policy subsystem.
    type PolicySys struct{}
    
    // Get returns stored bucket policy
    func (sys *PolicySys) Get(bucket string) (*policy.BucketPolicy, error) {
    	policy, _, err := globalBucketMetadataSys.GetPolicyConfig(bucket)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 8K bytes
    - Viewed (0)
Back to top