Documentation
¶
Index ¶
- func FreshnessWindow(cfg RefreshConfig, kind string) time.Duration
- func WithRefreshConfig(ctx context.Context, cfg RefreshConfig) context.Context
- type Projector
- func (p *Projector) RebuildAllReadModels(ctx context.Context) error
- func (p *Projector) RefreshAppAssetSource(ctx context.Context, sourceKind, sourceName string) error
- func (p *Projector) RefreshConnectorSourceState(ctx context.Context) error
- func (p *Projector) RefreshDiscoverySource(ctx context.Context, sourceKind, sourceName string) error
- func (p *Projector) RefreshNonHumanPrincipalSourceReadModels(ctx context.Context, sourceKind, sourceName string) error
- func (p *Projector) StoredReadModelsNeedRebuild(ctx context.Context) (bool, error)
- type RefreshConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FreshnessWindow ¶
func FreshnessWindow(cfg RefreshConfig, kind string) time.Duration
func WithRefreshConfig ¶
func WithRefreshConfig(ctx context.Context, cfg RefreshConfig) context.Context
Types ¶
type Projector ¶
type Projector struct {
// contains filtered or unexported fields
}
func NewProjector ¶
func ProjectorFromContext ¶
func (*Projector) RebuildAllReadModels ¶
func (*Projector) RefreshAppAssetSource ¶
func (*Projector) RefreshConnectorSourceState ¶
func (*Projector) RefreshDiscoverySource ¶
func (*Projector) RefreshNonHumanPrincipalSourceReadModels ¶
type RefreshConfig ¶
type RefreshConfig struct {
SyncInterval time.Duration
SyncOktaInterval time.Duration
SyncEntraInterval time.Duration
SyncGoogleWorkspaceInterval time.Duration
SyncGitHubInterval time.Duration
SyncDatadogInterval time.Duration
SyncAWSInterval time.Duration
}
RefreshConfig carries only the sync interval overrides needed to compute connector freshness windows for read-model refreshes.
func RefreshConfigFromConfig ¶
func RefreshConfigFromConfig(cfg config.Config) RefreshConfig
Source Files
Click to show internal directories.
Click to hide internal directories.