postgres

Documentation

Index

• Variables
• type Option
  • func WithDisableCleanup(val bool) Option
  • func WithTaskLogRetentionPeriod(dur time.Duration) Option
• type PostgresDatastore
  • func NewPostgresDataStore(dsn string, opts ...Option) (*PostgresDatastore, 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) 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, 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) 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) 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.Datastore) error) error

Variables

var (
	DefaultTaskLogsRetentionPeriod = time.Hour * 24 * 7
)

Types

type Option

type Option = func(ds *PostgresDatastore)

func WithDisableCleanup

func WithDisableCleanup(val bool) Option

func WithTaskLogRetentionPeriod

func WithTaskLogRetentionPeriod(dur time.Duration) Option

type PostgresDatastore

type PostgresDatastore struct {
	// contains filtered or unexported fields
}

func NewPostgresDataStore

func NewPostgresDataStore(dsn string, opts ...Option) (*PostgresDatastore, error)

func (*PostgresDatastore) CreateJob

func (ds *PostgresDatastore) CreateJob(ctx context.Context, j *tork.Job) error

func (*PostgresDatastore) CreateNode

func (ds *PostgresDatastore) CreateNode(ctx context.Context, n *tork.Node) error

func (*PostgresDatastore) CreateTask

func (ds *PostgresDatastore) CreateTask(ctx context.Context, t *tork.Task) error

func (*PostgresDatastore) CreateTaskLogPart

func (ds *PostgresDatastore) CreateTaskLogPart(ctx context.Context, p *tork.TaskLogPart) error

func (*PostgresDatastore) CreateUser

func (ds *PostgresDatastore) CreateUser(ctx context.Context, u *tork.User) error

func (*PostgresDatastore) ExecScript

func (ds *PostgresDatastore) ExecScript(script string) error

func (*PostgresDatastore) GetActiveNodes

func (ds *PostgresDatastore) GetActiveNodes(ctx context.Context) ([]*tork.Node, error)

func (*PostgresDatastore) GetActiveTasks

func (ds *PostgresDatastore) GetActiveTasks(ctx context.Context, jobID string) ([]*tork.Task, error)

func (*PostgresDatastore) GetJobByID

func (ds *PostgresDatastore) GetJobByID(ctx context.Context, id string) (*tork.Job, error)

func (*PostgresDatastore) GetJobLogParts

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, q string, page, size int) (*datastore.Page[*tork.JobSummary], error)

func (*PostgresDatastore) GetMetrics

func (ds *PostgresDatastore) GetMetrics(ctx context.Context) (*tork.Metrics, error)

func (*PostgresDatastore) GetNodeByID

func (ds *PostgresDatastore) GetNodeByID(ctx context.Context, id string) (*tork.Node, error)

func (*PostgresDatastore) GetTaskByID

func (ds *PostgresDatastore) GetTaskByID(ctx context.Context, id string) (*tork.Task, error)

func (*PostgresDatastore) GetTaskLogParts

func (ds *PostgresDatastore) GetTaskLogParts(ctx context.Context, taskID string, page, size int) (*datastore.Page[*tork.TaskLogPart], error)

func (*PostgresDatastore) GetUser

func (ds *PostgresDatastore) GetUser(ctx context.Context, uid string) (*tork.User, error)

func (*PostgresDatastore) HealthCheck

func (ds *PostgresDatastore) HealthCheck(ctx context.Context) error

func (*PostgresDatastore) UpdateJob

func (ds *PostgresDatastore) UpdateJob(ctx context.Context, id string, modify func(u *tork.Job) error) error

func (*PostgresDatastore) UpdateNode

func (ds *PostgresDatastore) UpdateNode(ctx context.Context, id string, modify func(u *tork.Node) error) error

func (*PostgresDatastore) UpdateTask

func (ds *PostgresDatastore) UpdateTask(ctx context.Context, id string, modify func(t *tork.Task) error) error

func (*PostgresDatastore) WithTx

func (ds *PostgresDatastore) WithTx(ctx context.Context, f func(tx datastore.Datastore) error) error