- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for notifier (0.23 sec)
-
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 May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 3.6K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 31 15:36:19 GMT 2023 - 4.1K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/test-utils_test.go
} template := x509.Certificate{ SerialNumber: serialNumber, Subject: pkix.Name{ Organization: []string{"Acme Co"}, }, NotBefore: notBefore, NotAfter: notAfter, KeyUsage: x509.KeyUsageKeyEncipherment | x509.KeyUsageDigitalSignature, ExtKeyUsage: []x509.ExtKeyUsage{x509.ExtKeyUsageServerAuth}, BasicConstraintsValid: true, }
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) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 33.7K bytes - Viewed (0) -
internal/config/certsinfo.go
buf.WriteString(color.Blue("%4sValidity\n", "")) buf.WriteString(color.Bold(fmt.Sprintf("%8sNot Before: %s\n", "", cert.NotBefore.Format(http.TimeFormat)))) buf.WriteString(color.Bold(fmt.Sprintf("%8sNot After : %s\n", "", cert.NotAfter.Format(http.TimeFormat)))) return buf.String()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 3.1K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.8K bytes - Viewed (0)