ent

package

v0.0.7 Latest Latest Go to latest Published: Apr 21, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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