Documentation
¶
Index ¶
- Variables
- type Option
- type PostgresDatastore
- func (ds *PostgresDatastore) AssignRole(ctx context.Context, userID, roleID string) error
- func (ds *PostgresDatastore) CreateJob(ctx context.Context, j *tork.Job) error
- func (ds *PostgresDatastore) CreateNode(ctx context.Context, n *tork.Node) error
- func (ds *PostgresDatastore) CreateRole(ctx context.Context, r *tork.Role) error
- func (ds *PostgresDatastore) CreateTask(ctx context.Context, t *tork.Task) error
- func (ds *PostgresDatastore) CreateTaskLogPart(ctx context.Context, p *tork.TaskLogPart) error
- func (ds *PostgresDatastore) CreateUser(ctx context.Context, u *tork.User) error
- func (ds *PostgresDatastore) ExecScript(script string) error
- func (ds *PostgresDatastore) GetActiveNodes(ctx context.Context) ([]*tork.Node, error)
- func (ds *PostgresDatastore) GetActiveTasks(ctx context.Context, jobID string) ([]*tork.Task, error)
- func (ds *PostgresDatastore) GetJobByID(ctx context.Context, id string) (*tork.Job, error)
- func (ds *PostgresDatastore) GetJobLogParts(ctx context.Context, jobID string, page, size int) (*datastore.Page[*tork.TaskLogPart], error)
- func (ds *PostgresDatastore) GetJobs(ctx context.Context, currentUser, q string, page, size int) (*datastore.Page[*tork.JobSummary], error)
- func (ds *PostgresDatastore) GetMetrics(ctx context.Context) (*tork.Metrics, error)
- func (ds *PostgresDatastore) GetNodeByID(ctx context.Context, id string) (*tork.Node, error)
- func (ds *PostgresDatastore) GetRole(ctx context.Context, id string) (*tork.Role, error)
- func (ds *PostgresDatastore) GetRoles(ctx context.Context) ([]*tork.Role, error)
- func (ds *PostgresDatastore) GetTaskByID(ctx context.Context, id string) (*tork.Task, error)
- func (ds *PostgresDatastore) GetTaskLogParts(ctx context.Context, taskID string, page, size int) (*datastore.Page[*tork.TaskLogPart], error)
- func (ds *PostgresDatastore) GetUser(ctx context.Context, uid string) (*tork.User, error)
- func (ds *PostgresDatastore) GetUserRoles(ctx context.Context, userID string) ([]*tork.Role, error)
- func (ds *PostgresDatastore) HealthCheck(ctx context.Context) error
- func (ds *PostgresDatastore) UnassignRole(ctx context.Context, userID, roleID string) error
- func (ds *PostgresDatastore) UpdateJob(ctx context.Context, id string, modify func(u *tork.Job) error) error
- func (ds *PostgresDatastore) UpdateNode(ctx context.Context, id string, modify func(u *tork.Node) error) error
- func (ds *PostgresDatastore) UpdateTask(ctx context.Context, id string, modify func(t *tork.Task) error) error
- func (ds *PostgresDatastore) WithTx(ctx context.Context, f func(tx datastore.Datastore) error) error
Constants ¶
This section is empty.
Variables ¶
View Source
var (
DefaultTaskLogsRetentionPeriod = time.Hour * 24 * 7
)
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option = func(ds *PostgresDatastore)
func WithDisableCleanup ¶
type PostgresDatastore ¶
type PostgresDatastore struct {
// contains filtered or unexported fields
}
func NewPostgresDataStore ¶
func NewPostgresDataStore(dsn string, opts ...Option) (*PostgresDatastore, error)
func (*PostgresDatastore) AssignRole ¶ added in v0.1.80
func (ds *PostgresDatastore) AssignRole(ctx context.Context, userID, roleID string) error
func (*PostgresDatastore) CreateNode ¶
func (*PostgresDatastore) CreateRole ¶ added in v0.1.80
func (*PostgresDatastore) CreateTask ¶
func (*PostgresDatastore) CreateTaskLogPart ¶
func (ds *PostgresDatastore) CreateTaskLogPart(ctx context.Context, p *tork.TaskLogPart) error
func (*PostgresDatastore) CreateUser ¶ added in v0.1.75
func (*PostgresDatastore) ExecScript ¶
func (ds *PostgresDatastore) ExecScript(script string) error
func (*PostgresDatastore) GetActiveNodes ¶
func (*PostgresDatastore) GetActiveTasks ¶
func (*PostgresDatastore) GetJobByID ¶
func (*PostgresDatastore) GetJobLogParts ¶ added in v0.1.70
func (ds *PostgresDatastore) GetJobLogParts(ctx context.Context, jobID string, page, size int) (*datastore.Page[*tork.TaskLogPart], error)
func (*PostgresDatastore) GetJobs ¶
func (ds *PostgresDatastore) GetJobs(ctx context.Context, currentUser, q string, page, size int) (*datastore.Page[*tork.JobSummary], error)
func (*PostgresDatastore) GetMetrics ¶
func (*PostgresDatastore) GetNodeByID ¶
func (*PostgresDatastore) GetTaskByID ¶
func (*PostgresDatastore) GetTaskLogParts ¶
func (ds *PostgresDatastore) GetTaskLogParts(ctx context.Context, taskID string, page, size int) (*datastore.Page[*tork.TaskLogPart], error)
func (*PostgresDatastore) GetUserRoles ¶ added in v0.1.80
func (*PostgresDatastore) HealthCheck ¶
func (ds *PostgresDatastore) HealthCheck(ctx context.Context) error
func (*PostgresDatastore) UnassignRole ¶ added in v0.1.80
func (ds *PostgresDatastore) UnassignRole(ctx context.Context, userID, roleID string) error
func (*PostgresDatastore) UpdateNode ¶
func (*PostgresDatastore) UpdateTask ¶
Click to show internal directories.
Click to hide internal directories.