Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 676 for timer (0.01 seconds)

  1. api/go1.7.txt

    pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc)
    pkg context, func WithTimeout(Context, time.Duration) (Context, CancelFunc)
    pkg context, func WithValue(Context, interface{}, interface{}) Context
    pkg context, type CancelFunc func()
    pkg context, type Context interface { Deadline, Done, Err, Value }
    pkg context, type Context interface, Deadline() (time.Time, bool)
    pkg context, type Context interface, Done() <-chan struct
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jun 28 15:08:11 GMT 2016
    - 13.6K bytes
    - Click Count (0)
  2. internal/http/dial_others.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"syscall"
    	"time"
    )
    
    // TODO: if possible implement for non-linux platforms, not a priority at the moment
    //
    //nolint:unused
    func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  3. cmd/data-usage.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"strings"
    	"time"
    
    	jsoniter "github.com/json-iterator/go"
    	"github.com/minio/minio/internal/cachevalue"
    )
    
    const (
    	dataUsageRoot   = SlashSeparator
    	dataUsageBucket = minioMetaBucket + SlashSeparator + bucketMetaPrefix
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu May 09 00:51:34 GMT 2024
    - 5.6K bytes
    - Click Count (0)
  4. docs/bucket/replication/setup_ilm_expiry_replication.sh

    ## Setup site replication
    ./mc admin replicate add sitea siteb --replicate-ilm-expiry
    
    sleep 10s
    
    ## Add warm tier
    ./mc ilm tier add minio sitea WARM-TIER --endpoint http://localhost:9006 --access-key minio --secret-key minio123 --bucket bucket
    
    ## Add ILM rules
    ./mc ilm add sitea/bucket --transition-days 0 --transition-tier WARM-TIER --transition-days 0 --noncurrent-expire-days 2 --expire-days 3 --prefix "myprefix" --tags "tag1=val1&tag2=val2"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 09:42:21 GMT 2024
    - 12.8K bytes
    - Click Count (0)
  5. internal/logger/logonce.go

    		logIf(ctx, subsystem, err, errKind...)
    	}
    }
    
    // Cleanup the map every one hour so that the log message is printed again for the user to notice.
    func (l *logOnceType) cleanupRoutine() {
    	for {
    		time.Sleep(time.Hour)
    
    		l.Lock()
    		l.IDMap = make(map[string]onceErr)
    		l.Unlock()
    	}
    }
    
    // Returns logOnceType
    func newLogOnceType() *logOnceType {
    	l := &logOnceType{IDMap: make(map[string]onceErr)}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  6. internal/event/target/mysql.go

    	close(target.quitCh)
    	if target.updateStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.updateStmt.Close()
    	}
    
    	if target.deleteStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.deleteStmt.Close()
    	}
    
    	if target.insertStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.insertStmt.Close()
    	}
    
    	if target.db != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  7. api/go1.24.txt

    pkg testing, method (*T) Context() context.Context #36532
    pkg testing, type TB interface, Chdir(string) #62516
    pkg testing, type TB interface, Context() context.Context #36532
    pkg time, method (Time) AppendBinary([]uint8) ([]uint8, error) #62384
    pkg time, method (Time) AppendText([]uint8) ([]uint8, error) #62384
    pkg weak, func Make[$0 interface{}](*$0) Pointer[$0] #67552
    pkg weak, method (Pointer[$0]) Value() *$0 #67552
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Dec 17 21:28:29 GMT 2024
    - 14.2K bytes
    - Click Count (0)
  8. internal/config/identity/openid/openid.go

    	return nil
    }
    
    // GetDefaultExpiration - returns the expiration seconds expected.
    func GetDefaultExpiration(dsecs string) (time.Duration, error) {
    	timeout := env.Get(config.EnvMinioStsDuration, "")
    	defaultExpiryDuration, err := time.ParseDuration(timeout)
    	if err != nil {
    		defaultExpiryDuration = time.Hour
    	}
    	if timeout == "" && dsecs != "" {
    		expirySecs, err := strconv.ParseInt(dsecs, 10, 64)
    		if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  9. cmd/iam-etcd-store.go

    					return
    				case watchResp, ok := <-watchCh:
    					if !ok {
    						time.Sleep(1 * time.Second)
    						// Upon an error on watch channel
    						// re-init the watch channel.
    						goto outerLoop
    					}
    					if err := watchResp.Err(); err != nil {
    						iamLogIf(ctx, err)
    						// log and retry.
    						time.Sleep(1 * time.Second)
    						// Upon an error on watch channel
    						// re-init the watch channel.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (0)
  10. soft_delete.go

    	if !n.Valid {
    		return nil, nil
    	}
    	return n.Time, nil
    }
    
    func (n DeletedAt) MarshalJSON() ([]byte, error) {
    	if n.Valid {
    		return json.Marshal(n.Time)
    	}
    	return json.Marshal(nil)
    }
    
    func (n *DeletedAt) UnmarshalJSON(b []byte) error {
    	if string(b) == "null" {
    		n.Valid = false
    		return nil
    	}
    	err := json.Unmarshal(b, &n.Time)
    	if err == nil {
    		n.Valid = true
    	}
    	return err
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed Feb 01 06:40:55 GMT 2023
    - 4.5K bytes
    - Click Count (1)
Back to Top