Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Notifier (0.2 sec)

  1. cmd/update-notifier.go

    	}
    
    	// Return the nicely colored and formatted update message.
    	return colorizeUpdateMessage(downloadURL, newerThan)
    }
    
    // colorizeUpdateMessage - inspired from Yeoman project npm package https://github.com/yeoman/update-notifier
    func colorizeUpdateMessage(updateString string, newerThan string) string {
    	msgLine1Fmt := " You are running an older version of MinIO released %s "
    	msgLine2Fmt := " Update: %s "
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  2. cmd/update-notifier_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"strings"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/color"
    )
    
    // Tests update notifier string builder.
    func TestPrepareUpdateMessage(t *testing.T) {
    	testCases := []struct {
    		older time.Duration
    		dlURL string
    
    		expectedSubStr string
    	}{
    		// Testcase index 0
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jul 31 15:36:19 GMT 2023
    - 4.1K bytes
    - Viewed (0)
  3. cmd/batch-rotate.go

    	Prefix     string                      `yaml:"prefix" json:"prefix"`
    	Encryption BatchJobKeyRotateEncryption `yaml:"encryption" json:"encryption"`
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobKeyRotateV1) Notify(ctx context.Context, ri *batchJobInfo) error {
    	return notifyEndpoint(ctx, ri, r.Flags.Notify.Endpoint, r.Flags.Notify.Token)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  4. cmd/batch-expire.go

    	var tmp expireJob
    	err := val.Decode(&tmp)
    	if err != nil {
    		return err
    	}
    
    	*r = BatchJobExpire(tmp)
    	r.line, r.col = val.Line, val.Column
    	return nil
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
    	if r.NotificationCfg.Endpoint == "" {
    		return nil
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  5. LICENSE

    holder fails to notify you of the violation by some reasonable means
    prior to 60 days after the cessation.
    
      Moreover, your license from a particular copyright holder is
    reinstated permanently if the copyright holder notifies you of the
    violation by some reasonable means, this is the first time you have
    received notice of violation of this License (for any work) from that
    copyright holder, and you cure the violation prior to 30 days after
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 33.7K bytes
    - Viewed (0)
  6. cmd/event-notification.go

    	"github.com/minio/minio/internal/event"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/pubsub"
    	"github.com/minio/pkg/v2/policy"
    )
    
    // EventNotifier - notifies external systems about events in MinIO.
    type EventNotifier struct {
    	sync.RWMutex
    	targetList     *event.TargetList
    	bucketRulesMap map[string]event.RulesMap
    }
    
    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)
  7. cmd/notification.go

    		reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", nErr.Host.String())
    		if nErr.Err != nil {
    			peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), nErr.Err, nErr.Host.String())
    		}
    	}
    }
    
    // StopRebalance notifies all MinIO nodes to signal any ongoing rebalance
    // goroutine to stop.
    func (sys *NotificationSys) StopRebalance(ctx context.Context) {
    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  8. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  9. CREDITS

    non-compliance by some reasonable means prior to 60 days after You have
    come back into compliance. Moreover, Your grants from a particular
    Contributor are reinstated on an ongoing basis if such Contributor
    notifies You of the non-compliance by some reasonable means, this is the
    first time You have received notice of non-compliance with this License
    from such Contributor, and You become compliant prior to 30 days after
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:31:35 GMT 2024
    - 1.6M bytes
    - Viewed (0)
  10. cmd/iam.go

    		msgs = append(msgs, color.Bold(arn))
    	}
    
    	logger.Info(fmt.Sprintf("%s %s", color.Blue("IAM Roles:"), strings.Join(msgs, " ")))
    }
    
    // HasWatcher - returns if the IAM system has a watcher to be notified of
    // changes.
    func (sys *IAMSys) HasWatcher() bool {
    	return sys.store.HasWatcher()
    }
    
    func (sys *IAMSys) loadWatchedEvent(ctx context.Context, event iamWatchEvent) (err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
Back to top