▽

Package workflow

func NewStore ¶

func NewStore(db *gorm.DB) core.WorkflowStore

type WorkflowStore ¶

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

func (*WorkflowStore) DeleteByFinishTime ¶

func (it *WorkflowStore) DeleteByFinishTime(ctx context.Context, ttl time.Duration) error

func (*WorkflowStore) DeleteByUID ¶

func (it *WorkflowStore) DeleteByUID(ctx context.Context, uid string) error

func (*WorkflowStore) DeleteByUIDs ¶

func (it *WorkflowStore) DeleteByUIDs(ctx context.Context, uids []string) error

func (*WorkflowStore) FindByID ¶

func (it *WorkflowStore) FindByID(ctx context.Context, id uint) (*core.WorkflowEntity, error)

func (*WorkflowStore) FindByUID ¶

func (it *WorkflowStore) FindByUID(ctx context.Context, uid string) (*core.WorkflowEntity, error)

func (*WorkflowStore) FindMetaByUID ¶

func (it *WorkflowStore) FindMetaByUID(ctx context.Context, UID string) (*core.WorkflowMeta, error)

func (*WorkflowStore) List ¶

func (it *WorkflowStore) List(ctx context.Context, namespace, name string, archived bool) ([]*core.WorkflowEntity, error)

func (*WorkflowStore) ListMeta ¶

func (it *WorkflowStore) ListMeta(ctx context.Context, namespace, name string, archived bool) ([]*core.WorkflowMeta, error)

func (*WorkflowStore) MarkAsArchived ¶

func (it *WorkflowStore) MarkAsArchived(ctx context.Context, namespace, name string) error

func (*WorkflowStore) MarkAsArchivedWithUID ¶

func (it *WorkflowStore) MarkAsArchivedWithUID(ctx context.Context, uid string) error

func (*WorkflowStore) Save ¶

func (it *WorkflowStore) Save(ctx context.Context, entity *core.WorkflowEntity) error