Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,694 for minit (0.03 sec)

  1. cmd/admin-handlers-users-race_test.go

    // and cause context deadline errors.
    
    package cmd
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	minio "github.com/minio/minio-go/v7"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    func runAllIAMConcurrencyTests(suite *TestSuiteIAM, c *check) {
    	suite.SetUpSuite(c)
    	suite.TestDeleteUserRace(c)
    	suite.TearDownSuite(c)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	"sync/atomic"
    	"time"
    
    	"github.com/IBM/sarama"
    	saramatls "github.com/IBM/sarama/tools/tls"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger/target/types"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    // the suffix for the configured queue dir where the logs will be persisted.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. docs/sts/custom-token-identity.go

    package main
    
    import (
    	"context"
    	"flag"
    	"fmt"
    	"log"
    	"net/url"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    var (
    	// LDAP integrated Minio endpoint
    	stsEndpoint string
    
    	// token to use with AssumeRoleWithCustomToken
    	token string
    
    	// Role ARN to use
    	roleArn string
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    	"path/filepath"
    	"time"
    
    	mqtt "github.com/eclipse/paho.mqtt.golang"
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	reconnectInterval = 5 * time.Second
    	storePrefix       = "minio"
    )
    
    // MQTT input constants
    const (
    	MqttBroker            = "broker"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. internal/init/init_darwin_amd64.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 init
    
    import (
    	"os"
    
    	"github.com/klauspost/cpuid/v2"
    )
    
    func init() {
    	// All MinIO operations must be under UTC.
    	os.Setenv("TZ", "UTC")
    
    	// Temporary workaround for
    	// https://github.com/golang/go/issues/49233
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 04 23:44:38 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  6. internal/config/lambda/target/webhook.go

    	"crypto/tls"
    	"encoding/json"
    	"errors"
    	"net/http"
    	"strings"
    	"sync/atomic"
    	"syscall"
    	"time"
    
    	"github.com/minio/minio/internal/config/lambda/event"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/certs"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    // Webhook constants
    const (
    	WebhookEndpoint   = "endpoint"
    	WebhookAuthToken  = "auth_token"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  7. internal/http/server.go

    }
    
    // GetRequestCount - returns number of request in progress.
    func (srv *Server) GetRequestCount() int {
    	return int(atomic.LoadInt32(&srv.requestCount))
    }
    
    // Init - init HTTP server
    func (srv *Server) Init(listenCtx context.Context, listenErrCallback func(listenAddr string, err error)) (serve func() error, err error) {
    	// Take a copy of server fields.
    	var tlsConfig *tls.Config
    	if srv.TLSConfig != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. cmd/server-main.go

    	"github.com/dustin/go-humanize"
    	"github.com/minio/cli"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/bucket/bandwidth"
    	"github.com/minio/minio/internal/color"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/handlers"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  9. cmd/bucket-quota.go

    package cmd
    
    import (
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/cachevalue"
    	"github.com/minio/minio/internal/logger"
    )
    
    // BucketQuotaSys - map of bucket and quota configuration.
    type BucketQuotaSys struct{}
    
    // Get - Get quota configuration.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. src/main/webapp/js/admin/adminlte.min.js

    r(n.default.Event("overlay.removed.lte.cardrefresh"))},t._init=function(){var e=this;n.default(this).find(this._settings.trigger).on("click",(function(){e.load()})),this._settings.loadOnInit&&this.load()},e._jQueryInterface=function(t){var a=n.default(this).data(o),i=n.default.extend({},d,n.default(this).data());a||(a=new e(n.default(this),i),n.default(this).data(o,"string"==typeof t?a:t)),"string"==typeof t&&/load/.test(t)?a[t]():a._init(n.default(this))},e}();n.default(document).on("click",r,(...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 45.3K bytes
    - Viewed (0)
Back to top