Documentation
¶
Overview ¶
Package continuation contains the small durable continuation adapter used by the standard contract tests and local deployments. It owns no goroutines.
Index ¶
- type FileStore
- func (s *FileStore) Close() error
- func (s *FileStore) Delete(ctx context.Context, scope lipcont.Scope, id lipcont.ResponseID) error
- func (s *FileStore) Get(ctx context.Context, scope lipcont.Scope, id lipcont.ResponseID) (lipcont.ContinuationRecord, error)
- func (s *FileStore) PutTerminal(ctx context.Context, record lipcont.ContinuationRecord) error
- func (s *FileStore) Reserve(ctx context.Context, scope lipcont.Scope, policy lipcont.StoragePolicy) (lipcont.ResponseID, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileStore ¶
type FileStore struct {
// contains filtered or unexported fields
}
FileStore is a synchronous, restart-capable Store backed by one atomically replaced JSON file. It is intentionally not a general database. The file requests mode 0600; Windows ACL inheritance is a deployment responsibility, so this adapter does not claim native-reference confidentiality.
func NewFileStore ¶
func NewFileStore(path string, limits lipcont.StorageLimits) (*FileStore, error)
NewFileStore opens or creates path and loads all previously committed state.
func (*FileStore) Get ¶
func (s *FileStore) Get(ctx context.Context, scope lipcont.Scope, id lipcont.ResponseID) (lipcont.ContinuationRecord, error)
Get performs a scoped terminal lookup with lazy expiry cleanup.
func (*FileStore) PutTerminal ¶
PutTerminal commits a completed eligible record and consumes its reservation.
Source Files
Click to show internal directories.
Click to hide internal directories.