Documentation ¶
Index ¶
- func NewStore(db *gorm.DB) core.WorkflowStore
- type WorkflowStore
- func (it *WorkflowStore) DeleteByFinishTime(ctx context.Context, ttl time.Duration) error
- func (it *WorkflowStore) DeleteByUID(ctx context.Context, uid string) error
- func (it *WorkflowStore) DeleteByUIDs(ctx context.Context, uids []string) error
- func (it *WorkflowStore) FindByID(ctx context.Context, id uint) (*core.WorkflowEntity, error)
- func (it *WorkflowStore) FindByUID(ctx context.Context, uid string) (*core.WorkflowEntity, error)
- func (it *WorkflowStore) FindMetaByUID(ctx context.Context, UID string) (*core.WorkflowMeta, error)
- func (it *WorkflowStore) List(ctx context.Context, namespace, name string, archived bool) ([]*core.WorkflowEntity, error)
- func (it *WorkflowStore) ListMeta(ctx context.Context, namespace, name string, archived bool) ([]*core.WorkflowMeta, error)
- func (it *WorkflowStore) MarkAsArchived(ctx context.Context, namespace, name string) error
- func (it *WorkflowStore) MarkAsArchivedWithUID(ctx context.Context, uid string) error
- func (it *WorkflowStore) Save(ctx context.Context, entity *core.WorkflowEntity) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type WorkflowStore ¶
type WorkflowStore struct {
// contains filtered or unexported fields
}
func (*WorkflowStore) DeleteByFinishTime ¶
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
Click to show internal directories.
Click to hide internal directories.