process

Documentation

Index

• Constants
• type Repository
  • func NewRepository(db dao) *Repository
  • func (r *Repository) Create(ctx context.Context, c *entity.StoreProcess) error
  • func (r *Repository) DeleteByDeletedAt(ctx context.Context) error
  • func (r *Repository) DeleteByProcessID(ctx context.Context, processID string) error
  • func (r *Repository) DeleteByUUID(ctx context.Context, resourceUUID string) error
  • func (r *Repository) Get(ctx context.Context) ([]*entity.StoreProcess, error)
  • func (r *Repository) GetAllByExecutorID(ctx context.Context) ([]*entity.StoreProcess, error)
  • func (r *Repository) GetByProcessID(ctx context.Context, processID string) ([]*entity.StoreProcess, error)
  • func (r *Repository) GetByUUID(ctx context.Context, uuid string) (*entity.StoreProcess, error)
  • func (r *Repository) GetNotFinishedByExecutorID(ctx context.Context, executorID string) ([]*entity.StoreProcess, error)
  • func (r *Repository) GetView(ctx context.Context, pagination *internalEntity.Pagination, ...) ([]*entity.StoreProcess, int, error)
  • func (r *Repository) Update(ctx context.Context, c *entity.StoreProcess) error

Constants

const (
	ProcessesTableName  = "processes"
	ErrProcessExists    = "process exists"
	ErrProcessNotExists = "process not exists"
	ErrResultQueryEmpty = "result query empty"
)

Types

type Repository

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

func NewRepository

func NewRepository(db dao) *Repository

func (*Repository) Create

func (r *Repository) Create(ctx context.Context, c *entity.StoreProcess) error

func (*Repository) DeleteByDeletedAt

func (r *Repository) DeleteByDeletedAt(ctx context.Context) error

func (*Repository) DeleteByProcessID

func (r *Repository) DeleteByProcessID(ctx context.Context, processID string) error

func (*Repository) DeleteByUUID

func (r *Repository) DeleteByUUID(ctx context.Context, resourceUUID string) error

func (*Repository) Get

func (r *Repository) Get(ctx context.Context) ([]*entity.StoreProcess, error)

func (*Repository) GetAllByExecutorID

func (r *Repository) GetAllByExecutorID(ctx context.Context) ([]*entity.StoreProcess, error)

func (*Repository) GetByProcessID

func (r *Repository) GetByProcessID(ctx context.Context, processID string) ([]*entity.StoreProcess, error)

func (*Repository) GetByUUID

func (r *Repository) GetByUUID(ctx context.Context, uuid string) (*entity.StoreProcess, error)

func (*Repository) GetNotFinishedByExecutorID

func (r *Repository) GetNotFinishedByExecutorID(ctx context.Context, executorID string) ([]*entity.StoreProcess, error)

func (*Repository) GetView

func (r *Repository) GetView(ctx context.Context, pagination *internalEntity.Pagination,
	filter *internalEntity.Filter) ([]*entity.StoreProcess, int, error)

func (*Repository) Update

func (r *Repository) Update(ctx context.Context, c *entity.StoreProcess) error