Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 1,950 for func (0.04 sec)

  1. internal/event/target/mysql.go

    	quitCh chan struct{}
    }
    
    // ID - returns target ID.
    func (target *MySQLTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *MySQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *MySQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. cmd/kms-handlers.go

    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/policy"
    )
    
    // KMSStatusHandler - GET /minio/kms/v1/status
    func (a kmsAPIHandlers) KMSStatusHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "KMSStatus")
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. internal/event/target/nats.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NATSTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *NATSTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *NATSTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. internal/rest/client.go

    	TraceOutput io.Writer // Debug trace output
    
    	httpClient *http.Client
    	url        *url.URL
    	auth       func() string
    
    	sync.RWMutex // mutex for lastErr
    	lastErr      error
    	lastErrTime  time.Time
    }
    
    type restError string
    
    func (e restError) Error() string {
    	return string(e)
    }
    
    func (e restError) Timeout() bool {
    	return true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. cmd/server-startup-msg.go

    	"github.com/minio/minio/internal/logger"
    )
    
    // generates format string depending on the string length and padding.
    func getFormatStr(strLen int, padding int) string {
    	formatStr := fmt.Sprintf("%ds", strLen+padding)
    	return "%" + formatStr
    }
    
    // Prints the formatted startup message.
    func printStartupMessage(apiEndpoints []string, err error) {
    	banner := strings.Repeat("-", len(MinioBannerName))
    	if globalIsDistErasure {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  6. internal/logger/utils.go

    var ansiRE = regexp.MustCompile("(\x1b[^m]*m)")
    
    // Print ANSI Control escape
    func ansiEscape(format string, args ...interface{}) {
    	Esc := "\x1b"
    	fmt.Printf("%s%s", Esc, fmt.Sprintf(format, args...))
    }
    
    func ansiMoveRight(n int) {
    	if runtime.GOOS == "windows" {
    		return
    	}
    	if color.IsTerminal() {
    		ansiEscape("[%dC", n)
    	}
    }
    
    func ansiSaveAttributes() {
    	if runtime.GOOS == "windows" {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 04 23:10:08 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  7. internal/logger/target/http/http.go

    }
    
    // Name returns the name of the target
    func (h *Target) Name() string {
    	return "minio-http-" + h.config.Name
    }
    
    // Type - returns type of the target
    func (h *Target) Type() types.TargetType {
    	return types.TargetHTTP
    }
    
    // Endpoint returns the backend endpoint
    func (h *Target) Endpoint() string {
    	return h.config.Endpoint.String()
    }
    
    func (h *Target) String() string {
    	return h.config.Name
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. cmd/data-usage-cache_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"testing"
    
    	"github.com/dustin/go-humanize"
    )
    
    func TestSizeHistogramToMap(t *testing.T) {
    	tests := []struct {
    		sizes []int64
    		want  map[string]uint64
    	}{
    		{
    			sizes: []int64{100, 1000, 72_000, 100_000},
    			want: map[string]uint64{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jan 13 07:51:08 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. cmd/bootstrap-peer-server.go

    	}
    	scfg.CmdLines = cmdLines
    	return scfg
    }
    
    func (s *bootstrapRESTServer) VerifyHandler(params *grid.MSS) (*ServerSystemConfig, *grid.RemoteErr) {
    	return getServerSystemCfg(), nil
    }
    
    var serverVerifyHandler = grid.NewSingleHandler[*grid.MSS, *ServerSystemConfig](grid.HandlerServerVerify, grid.NewMSS, func() *ServerSystemConfig { return &ServerSystemConfig{} })
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users-race_test.go

    			c.Fatalf("Unable to attach policy: %v", err)
    		}
    
    		accessKeys[i] = accessKey
    		secretKeys[i] = secretKey
    	}
    
    	g := errgroup.Group{}
    	for i := 0; i < userCount; i++ {
    		g.Go(func(i int) func() error {
    			return func() error {
    				uClient := s.getUserClient(c, accessKeys[i], secretKeys[i], "")
    				err := s.adm.RemoveUser(ctx, accessKeys[i])
    				if err != nil {
    					return err
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top