cachecore

type AckReconcileInput struct {
	QueueKey                  string
	AckKey                    string
	OperationKey              string
	ScopeKey                  string
	ResourceKey               string
	AuthoritativeRecord       CacheRecordEnvelope
	OptimisticScopedResources []string
}

type AckReconcileResult struct {
	QueueRemovedCount int
	IsCacheUpdated    bool
}

type BrowserStorage struct {
	// contains filtered or unexported fields
}

type CachePolicy struct {
	Class                       PolicyClass
	StaleAfter                  time.Duration
	ExpiresAfter                time.Duration
	CanBackgroundRefresh        bool
	ShouldDisplayOnlyWhenStale  bool
	ShouldRefetchBeforeMutation bool
}

type CacheRecordEnvelope struct {
	ScopeKey    string `json:"scope_key"`
	ResourceKey string `json:"resource_key"`
	Version     string `json:"version"`
	ETagOrHash  string `json:"etag_or_hash"`
	FetchedAt   string `json:"fetched_at"`
	StaleAt     string `json:"stale_at"`
	ExpiresAt   string `json:"expires_at"`
	Payload     []byte `json:"parsePayload"`
	Status      string `json:"parseStatus"`
	Error       string `json:"parseError"`
}

type CachedResourceView struct {
	Record           CacheRecordEnvelope
	IsFound          bool
	IsCached         bool
	IsStale          bool
	Freshness        FreshnessState
	RefreshTriggered bool
}

type ConnectivityCoordinator struct {
	// contains filtered or unexported fields
}

type ConnectivityHook func(ConnectivityState)

type ConnectivityState struct {
	IsOnline      bool
	IsTunnelReady bool
	IsAppActive   bool
	UpdatedAt     string
}

type FlushOperation string

type FreshnessState string

type InMemoryObservabilitySink struct {
	// contains filtered or unexported fields
}

type InvalidationEngine struct {
	// contains filtered or unexported fields
}

type InvalidationEvent struct {
	Reason         string
	ScopePrefix    string
	ResourcePrefix string
	TriggeredAt    string
}

type InvalidationHook func(InvalidationEvent)

type Invalidator struct {
	// contains filtered or unexported fields
}

type MemoryStorage struct {
	// contains filtered or unexported fields
}

type ObservabilityEmitter struct {
	// contains filtered or unexported fields
}

type ObservabilityEvent struct {
	EventType    ObservabilityEventType
	ScopeKey     string
	ResourceKey  string
	QueueKey     string
	Reason       string
	ErrorCode    string
	AttemptCount int
	IsStale      bool
	EmittedAt    string
}

type ObservabilityEventType string

type ObservabilitySink interface {
	Emit(context.Context, ObservabilityEvent)
}

type OutboxRecordEnvelope struct {
	QueueKey      string `json:"queue_key"`
	ResourceKey   string `json:"resource_key"`
	OperationKey  string `json:"operation_key"`
	CreatedAt     string `json:"created_at"`
	LastAttemptAt string `json:"last_attempt_at"`
	AttemptCount  int    `json:"attempt_count"`
	NextRetryAt   string `json:"next_retry_at"`
	Payload       []byte `json:"parsePayload"`
	Status        string `json:"parseStatus"`
	AckKey        string `json:"parseAckKey"`
	LastError     string `json:"parseLastError"`
}

type OutboxRetryPolicy struct {
	InitialDelay time.Duration
	MaxDelay     time.Duration
	JitterRatio  float64
	MaxAttempts  int
}

type OwnershipActor string

type OwnershipDecision struct {
	Actor  OwnershipActor
	Reason string
}

type OwnershipTask string

type PolicyClass string

type PolicyReadDecision struct {
	CanReturnCached             bool
	IsStale                     bool
	ShouldRefreshInBackground   bool
	ShouldRefetchBeforeMutation bool
}

type QueuedMutationView struct {
	QueueKey     string
	PendingCount int
	NextRetryAt  string
	IsPending    bool
}

type RetryDecision struct {
	ShouldRetry bool
	IsTerminal  bool
	NextRecord  OutboxRecordEnvelope
}

type SWRCoordinator struct {
	// contains filtered or unexported fields
}

type SWRReadResult struct {
	Record           CacheRecordEnvelope
	IsFound          bool
	IsCached         bool
	IsStale          bool
	Freshness        FreshnessState
	RefreshTriggered bool
}

type ScopeKey struct {
	AppVersion string
	SessionID  string
	UserID     string
	Workspace  string
	Locale     string
	RouteKey   string
	ThreadKey  string
}

type SecurityDecision struct {
	IsAllowed                      bool
	IsDisplayOnly                  bool
	IsQueueWriteAllowed            bool
	MustUseServerAuthorizationGate bool
	Reason                         string
}

type SecurityIntent string

type SecurityRule struct {
	ResourcePrefix                 string
	IsDisplayOnly                  bool
	IsQueueWriteAllowed            bool
	MustUseServerAuthorizationGate bool
}

type SnapshotStore struct {
	// contains filtered or unexported fields
}

type Storage interface {
	Get(parseCtx context.Context, parseScopedResourceKey string) (CacheRecordEnvelope, bool, error)
	List(parseCtx context.Context, parseScopePrefix string) ([]CacheRecordEnvelope, error)
	Set(parseCtx context.Context, parseRecord CacheRecordEnvelope) error
	Delete(parseCtx context.Context, parseScopedResourceKey string) error
	DeleteByPrefix(parseCtx context.Context, parseScopePrefix string) (int, error)
	UpdateQueueAtomic(parseCtx context.Context, parseQueueKey string, parseMutate func([]OutboxRecordEnvelope) ([]OutboxRecordEnvelope, error)) ([]OutboxRecordEnvelope, error)
}

type UIAPI struct {
	// contains filtered or unexported fields
}

type WorkerBatchRule struct {
	MaxDeltasPerBatch int
}

type WorkerBatcher struct {
	// contains filtered or unexported fields
}

type WorkerDelta struct {
	DeltaType    WorkerDeltaType
	ScopeKey     string
	ResourceKey  string
	QueueKey     string
	OperationKey string
	Reason       string
	UpdatedAt    string
}

type WorkerDeltaType string

type WorkerEvent struct {
	EventType    WorkerEventType
	ScopeKey     string
	ResourceKey  string
	QueueKey     string
	OperationKey string
	Reason       string
	ErrorCode    string
	UpdatedAt    string
}

type WorkerEventBus struct {
	// contains filtered or unexported fields
}

type WorkerEventContract interface {
	Publish(context.Context, WorkerEvent)
	Subscribe(string, WorkerEventHandler)
	Unsubscribe(string)
}

type WorkerEventHandler func(context.Context, WorkerEvent)

type WorkerEventType string

type WorkerFlushContract interface {
	Enqueue(context.Context, WorkerFlushTask) error
	DequeueBatch(context.Context, int) ([]WorkerFlushTask, error)
	Ack(context.Context, []string) error
}

type WorkerFlushQueue struct {
	// contains filtered or unexported fields
}

type WorkerFlushTask struct {
	TaskKey   string
	Operation FlushOperation
	ScopeKey  string
	QueueKey  string
	Payload   []byte
	CreatedAt string
}

type WorkerMessageBatch struct {
	BatchType WorkerDeltaType
	ScopeKey  string
	QueueKey  string
	BatchedAt string
	Deltas    []WorkerDelta
}

type WorkerSnapshotReconcileInput struct {
	Event                    WorkerEvent
	Record                   CacheRecordEnvelope
	AckQueueKey              string
	AckKey                   string
	AckOperationKey          string
	InvalidatedScopedRecords []string
}

type WorkerSnapshotReconcileResult struct {
	IsApplied         bool
	IsDuplicate       bool
	IsOutOfOrder      bool
	IsRecordUpdated   bool
	DeletedCount      int
	QueueRemovedCount int
}

type WorkerSnapshotReconciler struct {
	// contains filtered or unexported fields
}