- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,561 for Store2 (0.53 sec)
-
pilot/pkg/config/file/store.go
_, err := s.inner.Update(*r.config) if err != nil { _, err = s.inner.Create(*r.config) if err != nil { return fmt.Errorf("cannot store config %s/%s %s from reader: %s", r.schema.Version(), r.schema.Kind(), r.fullName(), err) } } s.shas[key] = r.sha } newKeys[key] = r.schema.GroupVersionKind() if oldKeys != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 18.2K bytes - Viewed (0) -
src/sync/atomic/type.go
type Bool struct { _ noCopy v uint32 } // Load atomically loads and returns the value stored in x. func (x *Bool) Load() bool { return LoadUint32(&x.v) != 0 } // Store atomically stores val into x. func (x *Bool) Store(val bool) { StoreUint32(&x.v, b32(val)) } // Swap atomically stores new into x and returns the previous value. func (x *Bool) Swap(new bool) (old bool) { return SwapUint32(&x.v, b32(new)) != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:37:29 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/iam-object-store.go
if err == errConfigNotFound { return errNoSuchPolicy } retries-- if retries <= 0 { return err } time.Sleep(500 * time.Millisecond) goto retry } m.Store(name, p) return nil } } func (iamOS *IAMObjectStore) loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error { var p MappedPolicy
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/iam-etcd-store.go
var p MappedPolicy err := ies.loadIAMConfig(ctx, &p, getMappedPolicyPath(name, userType, isGroup)) if err != nil { if err == errConfigNotFound { return errNoSuchPolicy } return err } m.Store(name, p) return nil } func getMappedPolicy(kv *mvccpb.KeyValue, m *xsync.MapOf[string, MappedPolicy], basePrefix string) error { var p MappedPolicy err := getIAMConfig(&p, kv.Value, string(kv.Key))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 13.6K bytes - Viewed (0) -
src/internal/zstd/window.go
} // reset clears stored data and configures window size. func (w *window) reset(size int) { b := w.data[:0] if cap(b) < size { b = make([]byte, 0, size) } w.data = b w.off = 0 w.size = size } // len returns the number of stored bytes. func (w *window) len() uint32 { return uint32(len(w.data)) } // save stores up to size last bytes from the buf. func (w *window) save(buf []byte) { if w.size == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 13:49:23 UTC 2024 - 2K bytes - Viewed (0) -
src/mime/multipart/formdata.go
// ReadForm parses an entire multipart message whose parts have // a Content-Disposition of "form-data". // It stores up to maxMemory bytes + 10MB (reserved for non-file parts) // in memory. File parts which can't be stored in memory will be stored on // disk in temporary files. // It returns [ErrMessageTooLarge] if all non-file parts can't be stored in // memory. func (r *Reader) ReadForm(maxMemory int64) (*Form, error) { return r.readForm(maxMemory) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 7.7K bytes - Viewed (0) -
src/sync/atomic/doc.go
func LoadPointer(addr *unsafe.Pointer) (val unsafe.Pointer) // StoreInt32 atomically stores val into *addr. // Consider using the more ergonomic and less error-prone [Int32.Store] instead. func StoreInt32(addr *int32, val int32) // StoreInt64 atomically stores val into *addr. // Consider using the more ergonomic and less error-prone [Int64.Store] instead // (particularly if you target 32-bit platforms; see the bugs section).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/Store.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.cache.internal; import java.util.function.Supplier; public interface Store<T> { T load(Supplier<T> createIfNotPresent);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 763 bytes - Viewed (0) -
internal/store/store.go
DelList(key []string) error Open() error Delete() error Extension() string } // Key denotes the key present in the store. type Key struct { Name string IsLast bool } // replayItems - Reads the items from the store and replays. func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key { keyCh := make(chan Key) go func() { defer xioutil.SafeClose(keyCh)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 25 16:44:20 UTC 2024 - 3.5K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/CompositeResultsStore.java
import java.util.stream.Collectors; public class CompositeResultsStore implements ResultsStore { private final List<ResultsStore> stores; private Map<PerformanceExperiment, ResultsStore> tests; public CompositeResultsStore(ResultsStore... stores) { this.stores = Arrays.asList(stores); } @Override public List<PerformanceExperiment> getPerformanceExperiments() { buildTests();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.9K bytes - Viewed (0)