- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for populate (0.16 sec)
-
internal/bpool/bpool.go
} return &BytePoolCap{ c: make(chan []byte, maxSize), w: width, wcap: capwidth, } } // Populate - populates and pre-warms the byte pool, this function is non-blocking. func (bp *BytePoolCap) Populate() { for _, buf := range reedsolomon.AllocAligned(cap(bp.c), bp.wcap) { bp.Put(buf[:bp.w]) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
cmd/update-notifier.go
// color characters, the result is incorrect. line1Length := len(fmt.Sprintf(msgLine1Fmt, newerThan)) line2Length := len(fmt.Sprintf(msgLine2Fmt, updateString)) // Populate lines with color coding. line1InColor := fmt.Sprintf(msgLine1Fmt, color.YellowBold(newerThan)) line2InColor := fmt.Sprintf(msgLine2Fmt, color.CyanBold(updateString)) // calculate the rectangular box size.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 3.6K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
pCfg, ok := r.arnProviderCfgsMap[arn] if !ok { return fmt.Errorf("Role %s does not exist", arn) } jwtToken, err := jp.ParseWithClaims(token, &claims, keyFuncCallback) if err != nil { // Re-populate the public key in-case the JWKS // pubkeys are refreshed if err = r.PopulatePublicKey(arn); err != nil { return err } jwtToken, err = jwtgo.ParseWithClaims(token, &claims, keyFuncCallback)
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) -
cni/pkg/nodeagent/informers.go
pods = append(pods, pod) } } return pods } // EnqueueNamespace takes a Namespace and enqueues all Pod objects that make need an update // TODO it is sort of pointless/confusing/implicit to populate Old and New with the same reference here func (s *InformerHandlers) enqueueNamespace(o controllers.Object) { namespace := o.GetName() labels := o.GetLabels()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cmd/streaming-v4-unsigned.go
if err != nil && err != io.EOF { cr.err = err return n, cr.err } cr.offset = copy(buf, cr.buffer) n += cr.offset return n, err } // readTrailers will read all trailers and populate cr.trailers with actual values. func (cr *s3UnsignedChunkedReader) readTrailers() error { var valueBuffer bytes.Buffer // Read value for { v, err := cr.reader.ReadByte() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 06 02:53:12 GMT 2023 - 6.1K bytes - Viewed (1) -
internal/config/cache/remote.go
// canonicalizeETag returns ETag with leading and trailing double-quotes removed, // if any present func canonicalizeETag(etag string) string { return etagRegex.ReplaceAllString(etag, "$1") } // Init - populates the input values, initializes CondCheck // before sending the request remotely. func (r *CondCheck) Init(bucket, object string, header http.Header) { r.Key = object r.Bucket = bucket
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 3.7K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
// DomainPort - is a string version of server port func DomainPort(domainPort string) EtcdOption { return func(args *CoreDNS) { args.domainPort = domainPort } } // CoreDNSPath - custom prefix on etcd to populate DNS // service records, optional and can be empty. // if empty then c.prefixPath is used i.e "/skydns" func CoreDNSPath(prefix string) EtcdOption { return func(args *CoreDNS) { args.prefixPath = prefix } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 8.3K bytes - Viewed (0) -
internal/event/targetlist.go
} // TargetStat is the stats of a single target. type TargetStat struct { CurrentSendCalls int64 // CurrentSendCalls is the number of concurrent async Send calls to all targets CurrentQueue int // Populated if target has a store. TotalEvents int64 FailedEvents int64 // Number of failed events per target } // TargetList - holds list of targets indexed by target ID. type TargetList struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
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 } type CniPluginServer struct { cniListenServer *http.Server
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/event-notification.go
} // NewEventNotifier - creates new event notification object. func NewEventNotifier(ctx context.Context) *EventNotifier { // targetList/bucketRulesMap/bucketRemoteTargetRulesMap are populated by NotificationSys.InitBucketTargets() return &EventNotifier{ targetList: event.NewTargetList(ctx), bucketRulesMap: make(map[string]event.RulesMap), } } // GetARNList - returns available ARNs.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.8K bytes - Viewed (0)