Versions in this module Expand all Collapse all v0 v0.3.3 Apr 21, 2024 v0.3.2 Feb 10, 2024 Changes in this version + const DeadRequestMarker + const SyncPeriod + type Client interface + AddCollectNotification func(fqn, encodedKeys, bucket string) + AddWriteNotification func(fqn, encodedKeys, bucket string, value *api.Value) + CollectNotifier func() NoLeaderRunnableFunc + WithManager func(mgr manager.Manager) error + WriteNotifier func() NoLeaderRunnableFunc + func NewClient(config ClientConfig) Client + type ClientConfig struct + CollectNotificationWorkers int + CollectNotifier api.Notifier[api.CollectNotification] + Logger logr.Logger + WriteNotificationWorkers int + WriteNotifier api.Notifier[api.WriteNotification] + type FinalizerFunc func(ctx context.Context) + type HandleFn func(ctx context.Context, notification T) error + type LeaderRunnableFunc func(context.Context) error + func (r LeaderRunnableFunc) NeedLeaderElection() bool + func (r LeaderRunnableFunc) Start(ctx context.Context) error + type NoLeaderRunnableFunc func(context.Context) error + func (r NoLeaderRunnableFunc) NeedLeaderElection() bool + func (r NoLeaderRunnableFunc) Start(ctx context.Context) error + type Server interface + Collector func() LeaderRunnableFunc + WithManager func(manager manager.Manager) error + Writer func() LeaderRunnableFunc + func NewServer(config ServerConfig) Server + type ServerConfig struct + CollectNotifier api.Notifier[api.CollectNotification] + HistoricalWriter api.HistoricalWriter + Logger logr.Logger + State api.State + WriteNotifier api.Notifier[api.WriteNotification]
Go to main page