inmemory

Documentation

Index

• type InMemoryDatastore
  • func NewInMemoryDatastore(opts ...Option) *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) CreateTaskLogPart(ctx context.Context, p *tork.TaskLogPart) 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) GetJobLogParts(ctx context.Context, jobID string, page, size int) (*datastore.Page[*tork.TaskLogPart], error)
  • func (ds *InMemoryDatastore) GetJobs(ctx context.Context, q string, page, size int) (*datastore.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) GetTaskLogParts(ctx context.Context, taskID string, page, size int) (*datastore.Page[*tork.TaskLogPart], 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.Datastore) error) error
• type Option
  • func WithCleanupInterval(ci time.Duration) Option
  • func WithJobExpiration(exp time.Duration) Option
  • func WithNodeExpiration(exp time.Duration) Option

Types

type InMemoryDatastore

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

func NewInMemoryDatastore

func NewInMemoryDatastore(opts ...Option) *InMemoryDatastore

func (*InMemoryDatastore) CreateJob

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

func (*InMemoryDatastore) CreateNode

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

func (*InMemoryDatastore) CreateTask

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

func (*InMemoryDatastore) CreateTaskLogPart

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

func (*InMemoryDatastore) GetActiveNodes

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

func (*InMemoryDatastore) GetActiveTasks

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

func (*InMemoryDatastore) GetJobByID

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

func (*InMemoryDatastore) GetJobLogParts

func (ds *InMemoryDatastore) GetJobLogParts(ctx context.Context, jobID string, page, size int) (*datastore.Page[*tork.TaskLogPart], error)

func (*InMemoryDatastore) GetJobs

func (ds *InMemoryDatastore) GetJobs(ctx context.Context, q string, page, size int) (*datastore.Page[*tork.JobSummary], error)

func (*InMemoryDatastore) GetMetrics

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

func (*InMemoryDatastore) GetNodeByID

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

func (*InMemoryDatastore) GetTaskByID

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

func (*InMemoryDatastore) GetTaskLogParts

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

func (*InMemoryDatastore) HealthCheck

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

func (*InMemoryDatastore) UpdateJob

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

func (*InMemoryDatastore) UpdateNode

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

func (*InMemoryDatastore) UpdateTask

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

func (*InMemoryDatastore) WithTx

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

type Option

type Option = func(ds *InMemoryDatastore)

func WithCleanupInterval

func WithCleanupInterval(ci time.Duration) Option

func WithJobExpiration

func WithJobExpiration(exp time.Duration) Option

func WithNodeExpiration

func WithNodeExpiration(exp time.Duration) Option