Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterProvider(name string, provider Provider)
- type Datastore
- type InMemoryDatastore
- func (ds *InMemoryDatastore) CreateJob(ctx context.Context, j *tork.Job) error
- func (ds *InMemoryDatastore) CreateNode(ctx context.Context, n *tork.Node) error
- func (ds *InMemoryDatastore) CreateTask(ctx context.Context, t *tork.Task) error
- func (ds *InMemoryDatastore) GetActiveNodes(ctx context.Context) ([]*tork.Node, error)
- func (ds *InMemoryDatastore) GetActiveTasks(ctx context.Context, jobID string) ([]*tork.Task, error)
- func (ds *InMemoryDatastore) GetJobByID(ctx context.Context, id string) (*tork.Job, error)
- func (ds *InMemoryDatastore) GetJobs(ctx context.Context, q string, page, size int) (*Page[*tork.JobSummary], error)
- func (ds *InMemoryDatastore) GetMetrics(ctx context.Context) (*tork.Metrics, error)
- func (ds *InMemoryDatastore) GetNodeByID(ctx context.Context, id string) (*tork.Node, error)
- func (ds *InMemoryDatastore) GetTaskByID(ctx context.Context, id string) (*tork.Task, error)
- func (ds *InMemoryDatastore) HealthCheck(ctx context.Context) error
- func (ds *InMemoryDatastore) UpdateJob(ctx context.Context, id string, modify func(u *tork.Job) error) error
- func (ds *InMemoryDatastore) UpdateNode(ctx context.Context, id string, modify func(u *tork.Node) error) error
- func (ds *InMemoryDatastore) UpdateTask(ctx context.Context, id string, modify func(u *tork.Task) error) error
- func (ds *InMemoryDatastore) WithTx(ctx context.Context, f func(tx Datastore) error) error
- type Option
- type Page
- type PostgresDatastore
- 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) CreateTask(ctx context.Context, t *tork.Task) 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) GetJobs(ctx context.Context, q string, page, size int) (*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) GetTaskByID(ctx context.Context, id string) (*tork.Task, error)
- func (ds *PostgresDatastore) HealthCheck(ctx context.Context) 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) error) error
- type Provider
Constants ¶
View Source
const ( DATASTORE_INMEMORY = "inmemory" DATASTORE_POSTGRES = "postgres" )
Variables ¶
View Source
var ( ErrTaskNotFound = errors.New("task not found") ErrNodeNotFound = errors.New("node not found") ErrJobNotFound = errors.New("job not found") ErrContextNotFound = errors.New("context not found") )
View Source
var (
ErrProviderNotFound = errors.Errorf("datastore provider not found")
)
Functions ¶
func RegisterProvider ¶ added in v0.1.2
Types ¶
type Datastore ¶
type Datastore interface { CreateTask(ctx context.Context, t *tork.Task) error UpdateTask(ctx context.Context, id string, modify func(u *tork.Task) error) error GetTaskByID(ctx context.Context, id string) (*tork.Task, error) GetActiveTasks(ctx context.Context, jobID string) ([]*tork.Task, error) CreateNode(ctx context.Context, n *tork.Node) error UpdateNode(ctx context.Context, id string, modify func(u *tork.Node) error) error GetNodeByID(ctx context.Context, id string) (*tork.Node, error) GetActiveNodes(ctx context.Context) ([]*tork.Node, error) CreateJob(ctx context.Context, j *tork.Job) error UpdateJob(ctx context.Context, id string, modify func(u *tork.Job) error) error GetJobByID(ctx context.Context, id string) (*tork.Job, error) GetJobs(ctx context.Context, q string, page, size int) (*Page[*tork.JobSummary], error) GetMetrics(ctx context.Context) (*tork.Metrics, error) WithTx(ctx context.Context, f func(tx Datastore) error) error HealthCheck(ctx context.Context) error }
func NewFromProvider ¶ added in v0.1.2
type InMemoryDatastore ¶
type InMemoryDatastore struct {
// contains filtered or unexported fields
}
func NewInMemoryDatastore ¶
func NewInMemoryDatastore(opts ...Option) *InMemoryDatastore
func (*InMemoryDatastore) CreateNode ¶
func (*InMemoryDatastore) CreateTask ¶
func (*InMemoryDatastore) GetActiveNodes ¶
func (*InMemoryDatastore) GetActiveTasks ¶
func (*InMemoryDatastore) GetJobByID ¶
func (*InMemoryDatastore) GetJobs ¶
func (ds *InMemoryDatastore) GetJobs(ctx context.Context, q string, page, size int) (*Page[*tork.JobSummary], error)
func (*InMemoryDatastore) GetMetrics ¶ added in v0.1.5
func (*InMemoryDatastore) GetNodeByID ¶
func (*InMemoryDatastore) GetTaskByID ¶
func (*InMemoryDatastore) HealthCheck ¶ added in v0.1.13
func (ds *InMemoryDatastore) HealthCheck(ctx context.Context) error
func (*InMemoryDatastore) UpdateNode ¶
func (*InMemoryDatastore) UpdateTask ¶
type Option ¶ added in v0.1.4
type Option = func(ds *InMemoryDatastore)
func WithCleanupInterval ¶ added in v0.1.4
func WithJobExpiration ¶ added in v0.1.4
func WithNodeExpiration ¶ added in v0.1.4
type PostgresDatastore ¶
type PostgresDatastore struct {
// contains filtered or unexported fields
}
func NewPostgresDataStore ¶
func NewPostgresDataStore(dsn string) (*PostgresDatastore, error)
func (*PostgresDatastore) CreateNode ¶
func (*PostgresDatastore) CreateTask ¶
func (*PostgresDatastore) ExecScript ¶
func (ds *PostgresDatastore) ExecScript(script string) error
func (*PostgresDatastore) GetActiveNodes ¶
func (*PostgresDatastore) GetActiveTasks ¶
func (*PostgresDatastore) GetJobByID ¶
func (*PostgresDatastore) GetJobs ¶
func (ds *PostgresDatastore) GetJobs(ctx context.Context, q string, page, size int) (*Page[*tork.JobSummary], error)
func (*PostgresDatastore) GetMetrics ¶ added in v0.1.5
func (*PostgresDatastore) GetNodeByID ¶
func (*PostgresDatastore) GetTaskByID ¶
func (*PostgresDatastore) HealthCheck ¶ added in v0.1.13
func (ds *PostgresDatastore) HealthCheck(ctx context.Context) error
func (*PostgresDatastore) UpdateNode ¶
func (*PostgresDatastore) UpdateTask ¶
Click to show internal directories.
Click to hide internal directories.