- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 192 for Sync (0.17 sec)
-
internal/s3select/select.go
func init() { parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn } var bufPool = sync.Pool{ New: func() interface{} { // make a buffer with a reasonable capacity. return bytes.NewBuffer(make([]byte, 0, maxRecordSize)) }, } var bufioWriterPool = sync.Pool{ New: func() interface{} { // io.Discard is just used to create the writer. Actual destination
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (1) -
internal/bucket/replication/sourceselectioncriteria.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package replication import ( "encoding/xml" ) // ReplicaModifications specifies if replica modification sync is enabled type ReplicaModifications struct { Status Status `xml:"Status" json:"Status"` } // SourceSelectionCriteria - specifies additional source selection criteria in ReplicationConfiguration.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.5K bytes - Viewed (0) -
internal/rest/rpc-stats.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 rest import ( "net/http" "net/http/httptrace" "sync/atomic" "time" ) var globalStats = struct { errs uint64 tcpDialErrs uint64 tcpDialCount uint64 tcpDialTotalDur uint64 }{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 16:27:58 GMT 2022 - 2.3K bytes - Viewed (0) -
cmd/naughty-disk_test.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" "io" "sync" "time" "github.com/minio/madmin-go/v3" ) // naughtyDisk wraps a POSIX disk and returns programmed errors // specified by the developer. The purpose is to simulate errors
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
import ( "context" "encoding/json" "errors" "fmt" "io" "net/http" "sync" "time" jwtgo "github.com/golang-jwt/jwt/v4" "github.com/minio/minio/internal/arn" "github.com/minio/minio/internal/auth" xnet "github.com/minio/pkg/v2/net" "github.com/minio/pkg/v2/policy" ) type publicKeys struct { *sync.RWMutex // map of kid to public key pkMap map[string]interface{} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 8.3K bytes - Viewed (5) -
cmd/xl-storage-disk-id-check.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "io" "math/rand" "runtime" "strconv" "strings" "sync" "sync/atomic" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/cachevalue" "github.com/minio/minio/internal/grid" xioutil "github.com/minio/minio/internal/ioutil"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/lock/lock_nix.go
lockType |= syscall.LOCK_EX default: return nil, &os.PathError{ Op: "open", Path: path, Err: syscall.EINVAL, } } f, err := os.OpenFile(path, flag|syscall.O_SYNC, perm) if err != nil { return nil, err } if err = syscall.Flock(int(f.Fd()), lockType); err != nil { f.Close() if err == syscall.EWOULDBLOCK { err = ErrAlreadyLocked } return nil, err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 2.8K bytes - Viewed (0) -
cmd/metrics-v2.go
Subsystem: iamSubsystem, Name: "since_last_sync_millis", Help: "Time (in milliseconds) since last successful IAM data sync.", Type: gaugeMetric, }, Value: float64(sinceLastSyncMillis), }, { Description: MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: iamSubsystem, Name: "sync_successes",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package openid import ( "crypto/sha1" "encoding/base64" "errors" "io" "net/http" "sort" "strconv" "strings" "sync" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/arn" "github.com/minio/minio/internal/auth" "github.com/minio/minio/internal/config"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0) -
cmd/os-instrumented.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 ( "os" "strings" "sync/atomic" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/disk" ioutilx "github.com/minio/minio/internal/ioutil" ) //go:generate stringer -type=osMetric -trimprefix=osMetric $GOFILE
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0)