You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
39 lines
1.5 KiB
39 lines
1.5 KiB
package server
|
|
|
|
import "time"
|
|
|
|
type SessionRepository interface {
|
|
CreateSession(upstreamKey string, u user, ttl time.Duration) (session, error)
|
|
GetSession(token string) (session, bool, error)
|
|
DeleteSession(token string) error
|
|
RotateSession(oldToken string, ttl time.Duration) (session, bool, error)
|
|
UpdateSessionGatewayBinding(token string, gatewayUserID int, gatewayAccessToken string) error
|
|
}
|
|
|
|
type JobRepository interface {
|
|
CreateJob(record *job) (*job, int, error)
|
|
GetJob(jobID string) (*job, bool, error)
|
|
ListJobs(userID, status, skillID, projectID string, limit, offset int) ([]job, int, error)
|
|
MarkJobRunning(jobID string) (*job, bool, error)
|
|
LinkUpstreamTask(jobID, upstreamTaskID string) error
|
|
FailJob(jobID, code, message string, details map[string]any) error
|
|
CompleteSyncResult(jobID string, refs []resultRef, usage map[string]any) error
|
|
CancelJob(userID, jobID string) (*job, bool, bool, error)
|
|
}
|
|
|
|
type RouteRepository interface {
|
|
GetRoutes(projectID string) (map[string]string, error)
|
|
SetRoute(projectID, routeKey, modelID string) error
|
|
UnsetRoute(projectID, routeKey string) error
|
|
}
|
|
|
|
type MediaRepository interface {
|
|
UpsertMedia(record mediaRecord) error
|
|
GetMedia(mediaID string) (*mediaRecord, bool, error)
|
|
}
|
|
|
|
type ArtifactRepository interface {
|
|
UpsertArtifacts(userID, projectID string, items []artifact) error
|
|
GetArtifact(userID, artifactID string) (*artifact, resultRef, bool, error)
|
|
ListArtifacts(userID, projectID, jobID string, limit, offset int) ([]artifact, int, error)
|
|
}
|
|
|