Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for notification (0.22 sec)

  1. cmd/api-errors.go

    		Description:    "The transition storage class was not found",
    		HTTPStatusCode: http.StatusNotFound,
    	},
    
    	// Bucket notification related errors.
    	ErrEventNotification: {
    		Code:           "InvalidArgument",
    		Description:    "A specified event is not supported for notifications.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrARNNotification: {
    		Code:           "InvalidArgument",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  2. cmd/iam-store.go

    		return v, ok
    	}
    	return cache.iamUserPolicyMap.Load(name)
    }
    
    // GroupNotificationHandler - updates in-memory cache on notification of
    // change (e.g. peer notification for object storage and etcd watch
    // notification).
    func (store *IAMStoreSys) GroupNotificationHandler(ctx context.Context, group string) error {
    	cache := store.lock()
    	defer store.unlock()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  3. cmd/test-utils_test.go

    	return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{})
    }
    
    // return URL for inserting bucket notification.
    func getPutNotificationURL(endPoint, bucketName string) string {
    	queryValue := url.Values{}
    	queryValue.Set("notification", "")
    	return makeTestTargetURL(endPoint, bucketName, "", queryValue)
    }
    
    // return URL for inserting bucket policy.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. cmd/iam.go

    	}
    	return roleArn, rolePolicy, nil
    }
    
    // DeletePolicy - deletes a canned policy from backend. `notifyPeers` is true
    // whenever this is called via the API. It is false when called via a
    // notification from another peer. This is to avoid infinite loops.
    func (sys *IAMSys) DeletePolicy(ctx context.Context, policyName string, notifyPeers bool) error {
    	if !sys.Initialized() {
    		return errServerNotInitialized
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  5. docs/bucket/notifications/README.md

    notify_webhook        publish bucket notifications to webhook endpoints
    notify_amqp           publish bucket notifications to AMQP endpoints
    notify_kafka          publish bucket notifications to Kafka endpoints
    notify_mqtt           publish bucket notifications to MQTT endpoints
    notify_nats           publish bucket notifications to NATS endpoints
    notify_nsq            publish bucket notifications to NSQ endpoints
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  6. cmd/batch-handlers.go

    	if err != nil {
    		return err
    	}
    
    	xhttp.DrainBody(resp.Body)
    	if resp.StatusCode != http.StatusOK {
    		return errors.New(resp.Status)
    	}
    
    	return nil
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobReplicateV1) Notify(ctx context.Context, ri *batchJobInfo) error {
    	return notifyEndpoint(ctx, ri, r.Flags.Notify.Endpoint, r.Flags.Notify.Token)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top