Versions in this module Expand all Collapse all v0 v0.0.7 Apr 21, 2025 v0.0.6 Apr 15, 2025 Changes in this version + type EntRepository struct + func NewEntRepository(client *gen.Client) *EntRepository + func (r *EntRepository) AddTask(ctx context.Context, param def.TaskUpdateParam) (def.Task, error) + func (r *EntRepository) Cancel(ctx context.Context, id string) error + func (r *EntRepository) CancelDispatched(ctx context.Context) error + func (r *EntRepository) Close() error + func (r *EntRepository) DeleteEnded(ctx context.Context, returning bool, limit int) error + func (r *EntRepository) Find(ctx context.Context, query def.TaskQueryParam, offset, limit int) ([]def.Task, error) + func (r *EntRepository) GetById(ctx context.Context, id string) (def.Task, error) + func (r *EntRepository) GetNext(ctx context.Context) (def.Task, error) + func (r *EntRepository) MarkAsDispatched(ctx context.Context, id string) error + func (r *EntRepository) MarkAsDone(ctx context.Context, id string, err error) error + func (r *EntRepository) RevertDispatched(ctx context.Context) error + func (r *EntRepository) UpdateById(ctx context.Context, id string, param def.TaskUpdateParam) error
Go to main page