- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 48 for Started (0.19 sec)
-
internal/s3select/csv/reader.go
const csvSplitSize = 128 << 10 // startReaders will read the header if needed and spin up a parser // and a number of workers based on GOMAXPROCS. // If an error is returned no goroutines have been started and r.err will have been set. func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error { if r.args.FileHeaderInfo != none { // Read column names // Get one line. b, err := r.nextSplit(0, nil)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
EndTime time.Time `msg:"stopTs"` // Time at which rebalance operation completed or rebalance-stop was called Status rebalStatus `msg:"status"` // Current state of rebalance operation. One of Started|Stopped|Completed|Failed. } // rebalanceMeta contains information pertaining to an ongoing rebalance operation. type rebalanceMeta struct { cancel context.CancelFunc `msg:"-"` // to be invoked on rebalance-stop
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/globals.go
globalHTTPStats = newHTTPStats() // Global bucket network and API statistics globalBucketConnStats = newBucketConnStats() globalBucketHTTPStats = newBucketHTTPStats() // Time when the server is started globalBootTime = UTCNow() globalActiveCred auth.Credentials globalSiteReplicatorCred siteReplicatorCred // Captures if root credentials are set via ENV. globalCredViaEnv bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} return p.Pools[idx].Decommission != nil } func (p *poolMeta) validate(pools []*erasureSets) (bool, error) { type poolInfo struct { position int completed bool decomStarted bool // started but not finished yet } rememberedPools := make(map[string]poolInfo) for idx, pool := range p.Pools { complete := false decomStarted := false if pool.Decommission != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cni/pkg/nodeagent/cni-watcher.go
type CNIPluginAddEvent struct { Netns string PodName string PodNamespace string IPs []IPConfig } // IPConfig contains an interface/gateway/address combo defined for a newly-started pod by CNI. // This is "from the horse's mouth" so to speak and will be populated before Kube is informed of the // pod IP. type IPConfig struct { Interface *int Address net.IPNet Gateway net.IP }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
return } case "User": z.User, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "User") return } case "Started": z.Started, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "Started") return } case "Replicate": if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err, "Replicate") return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 18:58:22 GMT 2024 - 18.1K bytes - Viewed (0) -
cmd/batch-rotate.go
func (r *BatchJobKeyRotateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error { ri := &batchJobInfo{ JobID: job.ID, JobType: string(job.Type()), StartTime: job.Started, } if err := ri.load(ctx, api, job); err != nil { return err } if ri.Complete { return nil } globalBatchJobsMetrics.save(job.ID, ri) lastObject := ri.Object
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/metrics-resource.go
// The metrics are collected from all servers periodically // and stored in the resource metrics map. // It also maintains the count of number of times this metric // was collected since the server started, and the sum, // average and max values across the same. type ResourceMetric struct { Name MetricName Labels map[string]string // value captured in current cycle Current float64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
if len(outputMsgs) == 0 { fmt.Fprintf(cmd.ErrOrStderr(), color.New(color.FgGreen).Sprint("✔")+" No issues found when checking the cluster. Istio is safe to install or upgrade!\n"+ " To get started, check out https://istio.io/latest/docs/setup/getting-started/\n") } else { fmt.Fprintln(cmd.OutOrStdout(), output) } for _, m := range msgs { if m.Type.Level().IsWorseThanOrEqualTo(diag.Warning) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/service.go
// restartProcess starts a new process passing it the active fd's. It // doesn't fork, but starts a new process using the same environment and // arguments as when it was originally started. This allows for a newly // deployed binary to be started. It returns the pid of the newly started // process when successful. func restartProcess() error { if runtime.GOOS == globalWindowsOSName { cmd := exec.Command(os.Args[0], os.Args[1:]...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0)