Documentation
¶
Index ¶
Constants ¶
View Source
const (
InitialVersion = "initial"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service interface {
pubsub.Suscriber[File]
Create(ctx context.Context, sessionID, path, content string) (File, error)
CreateVersion(ctx context.Context, sessionID, path, content string) (File, error)
Get(ctx context.Context, id string) (File, error)
GetByPathAndSession(ctx context.Context, path, sessionID string) (File, error)
ListBySession(ctx context.Context, sessionID string) ([]File, error)
ListLatestSessionFiles(ctx context.Context, sessionID string) ([]File, error)
Update(ctx context.Context, file File) (File, error)
Delete(ctx context.Context, id string) error
DeleteSessionFiles(ctx context.Context, sessionID string) error
}
func NewService ¶
NewService builds the file history service on q. Pass the same querier the session and message services use (app.DBQuerier): on an IPC secondary that is the *dbproxy.DBProxy, so file versions are written directly first and forwarded to the primary on lock contention instead of failing on the secondary's short busy timeout.
Click to show internal directories.
Click to hide internal directories.