- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 326 for ledger (0.25 sec)
-
pilot/pkg/status/distribution/reporter.go
dataField = "distribution-report" ) // Init starts all the read only features of the reporter, used for nonce generation // and responding to istioctl wait. func (r *Reporter) Init(ledger ledger.Ledger, stop <-chan struct{}) { r.ledger = ledger if r.clock == nil { r.clock = clock.RealClock{} } r.distributionEventQueue = make(chan distributionEvent, 100_000) r.status = make(map[string]string)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/model/context.go
return } func (e *Environment) ClusterLocal() ClusterLocalProvider { return e.clusterLocalServices } func (e *Environment) GetLedger() ledger.Ledger { return e.ledger } func (e *Environment) SetLedger(l ledger.Ledger) { e.ledger = l } func (e *Environment) GetProxyConfigOrDefault(ns string, labels, annotations map[string]string, meshConfig *meshconfig.MeshConfig) *meshconfig.ProxyConfig {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
pilot/pkg/xds/ads_test.go
return s.Discovery.StatusReporter.QueryLastNonce("test.default-1", ty) }, nonce[:xds.VersionLen]) } ledger := ledger.Make(time.Minute) ledger.Put("key", "value") // If there is no config, ledger would be empty s.Env().SetLedger(ledger) reporter := &distribution.Reporter{ UpdateInterval: features.StatusUpdateInterval, } reporter.Init(s.Env().GetLedger(), test.NewStop(t))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/net/InternetDomainNameTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Mar 05 13:16:00 UTC 2024 - 17.3K bytes - Viewed (0) -
pkg/ledger/smt.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package ledger import ( "bytes" "fmt" "sync" "time" "istio.io/istio/pkg/cache" ) // The smt is derived from https://github.com/aergoio/SMT with modifications
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 14K bytes - Viewed (0) -
src/mdo/merger.vm
specific language governing permissions and limitations under the License. *# #parse ( "common.vm" ) # #set ( $package = "${packageToolV4}" ) #set ( $className = "${model.name}Merger" ) # #set ( $root = $model.getClass( $model.getRoot($version), $version ) ) # #MODELLO-VELOCITY#SAVE-OUTPUT-TO ${package.replace('.','/')}/${className}.java // =================== DO NOT EDIT THIS FILE ====================
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Sep 05 16:06:44 UTC 2023 - 12.2K bytes - Viewed (0) -
src/log/slog/logger.go
} // New creates a new Logger with the given non-nil Handler. func New(h Handler) *Logger { if h == nil { panic("nil Handler") } return &Logger{handler: h} } // With calls [Logger.With] on the default logger. func With(args ...any) *Logger { return Default().With(args...) } // Enabled reports whether l emits log records at the given context and level.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 08 18:26:18 UTC 2024 - 10.2K bytes - Viewed (0) -
src/unicode/letter.go
} return false } // IsUpper reports whether the rune is an upper case letter. func IsUpper(r rune) bool { // See comment in IsGraphic. if uint32(r) <= MaxLatin1 { return properties[uint8(r)]&pLmask == pLu } return isExcludingLatin(Upper, r) } // IsLower reports whether the rune is a lower case letter. func IsLower(r rune) bool { // See comment in IsGraphic. if uint32(r) <= MaxLatin1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 06 20:02:46 UTC 2023 - 10K bytes - Viewed (0) -
src/main/java/org/codelibs/core/log/Logger.java
assertArgumentNotNull("clazz", clazz); if (!initialized) { initialize(); } Logger logger = loggers.get(clazz); if (logger == null) { logger = new Logger(clazz); loggers.put(clazz, logger); } return logger; } /** * フォーマットされたメッセージ文字列を返します。 * * @param messageCode
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 13.2K bytes - Viewed (0) -
internal/logger/logger.go
if len(systemTgts) == 0 { return } // Iterate over all logger targets to send the log entry for _, t := range systemTgts { if err := t.Send(ctx, entry); err != nil { if consoleTgt != nil { // Sending to the console never fails entry.Trace.Message = fmt.Sprintf("event(%#v) was not sent to Logger target (%#v): %#v", entry, t, err) consoleTgt.Send(ctx, entry) } } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.4K bytes - Viewed (0)