- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 449 for ledger (0.74 sec)
-
pilot/pkg/status/distribution/reporter_test.go
out.reverseStatus = make(map[string]sets.String) out.status = make(map[string]string) return } func TestBuildReport(t *testing.T) { RegisterTestingT(t) r := initReporterWithoutStarting() r.ledger = ledger.Make(time.Minute) resources := []*config.Config{ { Meta: config.Meta{ Namespace: "default", Name: "foo", ResourceVersion: "1", }, }, { Meta: config.Meta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 4.4K bytes - Viewed (0) -
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) -
src/cmd/vendor/rsc.io/markdown/emoji.go
"leafy_green": "\U0001f96c", "leaves": "\U0001f343", "lebanon": "\U0001f1f1\U0001f1e7", "ledger": "\U0001f4d2", "left_luggage": "\U0001f6c5", "left_right_arrow": "\u2194\ufe0f", "left_speech_bubble": "\U0001f5e8\ufe0f",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 107.7K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
Mesh *meshconfig.MeshConfig `json:"-"` // PushVersion describes the push version this push context was computed for PushVersion string // LedgerVersion is the version of the configuration ledger LedgerVersion string // JwtKeyResolver holds a reference to the JWT key resolver instance. JwtKeyResolver *JwksResolver // GatewayAPIController holds a reference to the gateway API controller.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K 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) -
logger/logger.go
type Writer interface { Printf(string, ...interface{}) } // Config logger config type Config struct { SlowThreshold time.Duration Colorful bool IgnoreRecordNotFoundError bool ParameterizedQueries bool LogLevel LogLevel } // Interface logger interface type Interface interface { LogMode(LogLevel) Interface
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Nov 07 02:19:41 UTC 2023 - 5.8K 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)