Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for sync_events (0.2 sec)

  1. internal/config/api/api.go

    	EnableODirect               bool          `json:"enable_odirect"`
    	GzipObjects                 bool          `json:"gzip_objects"`
    	RootAccess                  bool          `json:"root_access"`
    	SyncEvents                  bool          `json:"sync_events"`
    	ObjectMaxVersions           int64         `json:"object_max_versions"`
    }
    
    // UnmarshalJSON - Validate SS and RRS parity when unmarshalling JSON.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 01:08:07 GMT 2024
    - 11.1K bytes
    - Viewed (1)
  2. cmd/event-notification.go

    	evnot.RLock()
    	targetIDSet := evnot.bucketRulesMap[args.BucketName].Match(args.EventName, args.Object.Name)
    	evnot.RUnlock()
    
    	if len(targetIDSet) == 0 {
    		return
    	}
    
    	// If MINIO_API_SYNC_EVENTS is set, send events synchronously.
    	evnot.targetList.Send(args.ToEvent(true), targetIDSet, globalAPIConfig.isSyncEventsEnabled())
    }
    
    type eventArgs struct {
    	EventName    event.Name
    	BucketName   string
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  3. docs/config/README.md

    root_access                     (boolean)   turn 'off' root credential access for all API calls including s3, admin operations (default: 'on')
    sync_events                     (boolean)   set to enable synchronous bucket notifications (default: 'off')
    ```
    
    or environment variables
    
    ```
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  4. cmd/handler-api.go

    	t.deleteCleanupInterval = cfg.DeleteCleanupInterval
    	t.enableODirect = cfg.EnableODirect
    	t.gzipObjects = cfg.GzipObjects
    	t.rootAccess = cfg.RootAccess
    	t.syncEvents = cfg.SyncEvents
    	t.objectMaxVersions = cfg.ObjectMaxVersions
    }
    
    func (t *apiConfig) odirectEnabled() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.enableODirect
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 09:22:27 GMT 2024
    - 10K bytes
    - Viewed (0)
  5. cmd/testdata/undeleteable-object.tgz

    h"},{"key":"stale_uploads_expiry","value":"24h"},{"key":"delete_cleanup_interval","value":"5m"},{"key":"disable_odirect","value":""},{"key":"odirect","value":"on"},{"key":"gzip_objects","value":"off"},{"key":"root_access","value":"on"},{"key":"sync_events","value":"off"},{"key":"object_max_versions","value":"9223372036854775807"}]},"audit_kafka":{"_":[{"key":"enable","value":"off"},{"key":"topic","value":""},{"key":"brokers","value":""},{"key":"sasl_username","value":""},{"key":"sasl_password","...
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 8.7M bytes
    - Viewed (0)
Back to top