Documentation
¶
Index ¶
Constants ¶
View Source
const (
// SubscriptionStateTypeURL is the custom type URL for subscription state configurations.
SubscriptionStateTypeURL = "api-platform.wso2.org/v1.SubscriptionState"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SnapshotManager ¶
type SnapshotManager struct {
// contains filtered or unexported fields
}
SnapshotManager manages xDS snapshots for subscription state.
func NewSnapshotManager ¶
func NewSnapshotManager(store storage.Storage, log *slog.Logger) *SnapshotManager
NewSnapshotManager creates a new subscription snapshot manager backed by the given storage.
func (*SnapshotManager) GetCache ¶
func (sm *SnapshotManager) GetCache() cache.Cache
GetCache returns the underlying cache as the generic Cache interface.
func (*SnapshotManager) UpdateSnapshot ¶
func (sm *SnapshotManager) UpdateSnapshot(ctx context.Context) error
UpdateSnapshot generates a new xDS snapshot from all ACTIVE subscriptions for this gateway. Storage I/O is performed without holding the manager lock; the lock is only held when updating the cache to avoid blocking other readers during the full storage sweep.
Source Files
Click to show internal directories.
Click to hide internal directories.