Documentation ¶
Index ¶
- Variables
- func NewService(client *elasticsearch.Client, scrollPageSize uint, scrollTtl time.Duration) recurring.Service
- type EsService
- func (e *EsService) All(ctx context.Context) ([]recurring.Task, error)
- func (e *EsService) Create(ctx context.Context, task *recurring.NewTask) (*recurring.Task, error)
- func (e *EsService) Delete(ctx context.Context, id task.RecurringTaskId) (*recurring.Task, error)
- func (e *EsService) Get(ctx context.Context, id task.RecurringTaskId, includeSoftDeleted bool) (*recurring.Task, error)
- func (e *EsService) MarkLoaded(ctx context.Context, toMarks []recurring.Task) (*recurring.MultiUpdateResult, error)
- func (e *EsService) NotLoaded(ctx context.Context) ([]recurring.Task, error)
- func (e *EsService) SetUTCGetter(getter func() time.Time)
- func (e *EsService) Update(ctx context.Context, update *recurring.Task) (*recurring.Task, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var TasquesRecurringTasksIndex = ".tasques_recurring_tasks"
Functions ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.