Versions in this module Expand all Collapse all v1 v1.3.3 Jan 2, 2023 v1.3.2 Jul 17, 2021 Changes in this version + var ErrConcExports = errors.New("too many concurrent exports. Wait for old export succeeded, and try again") + type Model struct + func NewModel(db *m.Database) Model + func (m Model) EnsureLimitAndCreatePending(ctx context.Context, userID, eventID primitive.ObjectID, name string) (err error) + func (m Model) Get(ctx context.Context, userID primitive.ObjectID, skip, limit uint32) (res []file, err error) + func (m Model) GetFromCompanyID(ctx context.Context, eventID primitive.ObjectID) (companyID string, err error) + func (m Model) GetMasterJob(ctx context.Context, query *parser.GetV2Request, ...) (eventID primitive.ObjectID, err error) + func (m Model) IncCurrentCount(ctx context.Context, eventID primitive.ObjectID, currentCount uint32) (err error) + func (m Model) SetFail(ctx context.Context, eventID primitive.ObjectID) (err error) + func (m Model) SetFromCompanyID(ctx context.Context, eventID primitive.ObjectID, companyID string) (err error) + func (m Model) SetMasterJobInProgress(ctx context.Context, eventID primitive.ObjectID, query *parser.GetV2Request, ...) (err error) + func (m Model) SetSuccess(ctx context.Context, eventID primitive.ObjectID, url string) (err error) + func (m Model) WatchJob(ctx context.Context, masterEventID primitive.ObjectID, ...) (err error)
Go to main page