memory

package
v1.8.27 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 9, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

扩展仓储内存实现（v1.1.0，测试用）

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExtRepository added in v1.1.0 

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

ExtRepository 是 ProcessExtRepository 的内存实现（测试/演示用）。

func NewExt added in v1.1.0 

func NewExt() *ExtRepository

func (*ExtRepository) FindDesignByID added in v1.1.0 

func (r *ExtRepository) FindDesignByID(ctx context.Context, id int64) (*model.ProcessDesign, error)

func (*ExtRepository) FindSurrogateByID added in v1.1.0 

func (r *ExtRepository) FindSurrogateByID(ctx context.Context, id int64) (*model.ProcessSurrogate, error)

func (*ExtRepository) GetSurrogate added in v1.1.0 

func (r *ExtRepository) GetSurrogate(ctx context.Context, operator, processName string, at time.Time) (*model.ProcessSurrogate, error)

func (*ExtRepository) ListDesignHis added in v1.1.0 

func (r *ExtRepository) ListDesignHis(ctx context.Context, designID int64) ([]*model.ProcessDesignHis, error)

func (*ExtRepository) PageDesigns added in v1.1.0 

func (r *ExtRepository) PageDesigns(ctx context.Context, query spi.PageQuery) ([]*model.ProcessDesign, int, error)

func (*ExtRepository) PageSurrogates added in v1.1.0 

func (r *ExtRepository) PageSurrogates(ctx context.Context, query spi.PageQuery) ([]*model.ProcessSurrogate, int, error)

func (*ExtRepository) RemoveDesign added in v1.1.0 

func (r *ExtRepository) RemoveDesign(ctx context.Context, id int64) error

func (*ExtRepository) RemoveSurrogate added in v1.1.0 

func (r *ExtRepository) RemoveSurrogate(ctx context.Context, id int64) error

func (*ExtRepository) SaveDesign added in v1.1.0 

func (r *ExtRepository) SaveDesign(ctx context.Context, d *model.ProcessDesign) error

func (*ExtRepository) SaveDesignHis added in v1.1.0 

func (r *ExtRepository) SaveDesignHis(ctx context.Context, his *model.ProcessDesignHis) error

func (*ExtRepository) SaveSurrogate added in v1.1.0 

func (r *ExtRepository) SaveSurrogate(ctx context.Context, s *model.ProcessSurrogate) error

func (*ExtRepository) UpdateDesign added in v1.1.0 

func (r *ExtRepository) UpdateDesign(ctx context.Context, d *model.ProcessDesign) error

func (*ExtRepository) UpdateSurrogate added in v1.1.0 

func (r *ExtRepository) UpdateSurrogate(ctx context.Context, s *model.ProcessSurrogate) error

type Repository 

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

func New 

func New() *Repository

func (*Repository) AddDefine 

func (r *Repository) AddDefine(def *model.ProcessDefine)

func (*Repository) AddTaskActor 

func (r *Repository) AddTaskActor(ctx context.Context, taskID int64, actors []string) error

func (*Repository) AllDefines 

func (r *Repository) AllDefines() []*model.ProcessDefine

func (*Repository) AllInstances 

func (r *Repository) AllInstances() []*model.ProcessInstance

func (*Repository) AllTasks 

func (r *Repository) AllTasks() []*model.ProcessTask

func (*Repository) CreateCcInstance 

func (r *Repository) CreateCcInstance(ctx context.Context, instanceID int64, creator string, actorIDs ...string) error

func (*Repository) FindDefineByID 

func (r *Repository) FindDefineByID(ctx context.Context, id int64) (*model.ProcessDefine, error)

func (*Repository) FindDefineByName added in v1.1.0 

func (r *Repository) FindDefineByName(ctx context.Context, name string) (*model.ProcessDefine, error)

FindDefineByName 按流程编码查最新一条定义（id 倒序取首条）

func (*Repository) FindDoingTasks 

func (r *Repository) FindDoingTasks(ctx context.Context, instanceID int64, taskNames []string) ([]*model.ProcessTask, error)

func (*Repository) FindDoneTasks 

func (r *Repository) FindDoneTasks(ctx context.Context, instanceID int64, taskNames []string) ([]*model.ProcessTask, error)

func (*Repository) FindHistoryTasks 

func (r *Repository) FindHistoryTasks(ctx context.Context, instanceID int64) ([]*model.ProcessTask, error)

func (*Repository) FindInstanceByID 

func (r *Repository) FindInstanceByID(ctx context.Context, id int64) (*model.ProcessInstance, error)

func (*Repository) FindTaskActors 

func (r *Repository) FindTaskActors(ctx context.Context, taskID int64) ([]string, error)

func (*Repository) FindTaskByID 

func (r *Repository) FindTaskByID(ctx context.Context, taskID int64) (*model.ProcessTask, error)

func (*Repository) PageCcInstances added in v1.3.0 

func (r *Repository) PageCcInstances(ctx context.Context, query spi.PageQuery, actorID string) ([]*model.CcInstanceRow, int, error)

PageCcInstances 我的抄送分页（v1.3.0）：按抄送人 actorID 过滤，join 实例 + 定义

func (*Repository) PageDefines added in v1.5.0 

func (r *Repository) PageDefines(ctx context.Context, query spi.PageQuery) ([]*model.DefineRow, int, error)

PageDefines 流程定义分页

func (*Repository) PageDoneTasks added in v1.5.0 

func (r *Repository) PageDoneTasks(ctx context.Context, query spi.PageQuery, operator string) ([]*model.TaskRow, int, error)

PageDoneTasks 我的已办分页（operator 过滤，非进行中任务）

func (*Repository) PageInstances added in v1.5.0 

func (r *Repository) PageInstances(ctx context.Context, query spi.PageQuery, operator string) ([]*model.InstanceRow, int, error)

PageInstances 我发起的流程实例分页（operator 过滤，join 定义名）

func (*Repository) PageTodoTasks added in v1.5.0 

func (r *Repository) PageTodoTasks(ctx context.Context, query spi.PageQuery, actorID string) ([]*model.TaskRow, int, error)

PageTodoTasks 我的待办分页（actorID 过滤，仅进行中任务）

func (*Repository) QueryInstancesForStats added in v1.8.25 

func (r *Repository) QueryInstancesForStats(_ context.Context, stateIn []int, timeField string, start, end *time.Time) ([]model.InstanceStatsRow, error)

func (*Repository) QueryTasksForStats added in v1.8.25 

func (r *Repository) QueryTasksForStats(_ context.Context, state *int, start, end *time.Time) ([]model.TaskStatsRow, error)

func (*Repository) RemoveDefine added in v1.1.0 

func (r *Repository) RemoveDefine(ctx context.Context, defineID int64) error

func (*Repository) RemoveTaskActor 

func (r *Repository) RemoveTaskActor(ctx context.Context, taskID int64, actors []string) error

func (*Repository) SaveDefine added in v1.1.0 

func (r *Repository) SaveDefine(ctx context.Context, def *model.ProcessDefine) error

func (*Repository) SaveInstance 

func (r *Repository) SaveInstance(ctx context.Context, inst *model.ProcessInstance) error

func (*Repository) SaveTask 

func (r *Repository) SaveTask(ctx context.Context, task *model.ProcessTask) error

func (*Repository) StatsAvgCompletedDurationSeconds added in v1.8.25 

func (r *Repository) StatsAvgCompletedDurationSeconds(_ context.Context, start, end *time.Time) (int, error)

func (*Repository) StatsCompletedInstanceDurations added in v1.8.25 

func (r *Repository) StatsCompletedInstanceDurations(_ context.Context, start, end *time.Time) ([]int, error)

func (*Repository) StatsCompletedTaskAggregate added in v1.8.25 

func (r *Repository) StatsCompletedTaskAggregate(_ context.Context) (total, countersign, onTime, onTimeDenom int, err error)

func (*Repository) StatsDefineGroup added in v1.8.25 

func (r *Repository) StatsDefineGroup(_ context.Context, start, end *time.Time, limit int) ([]map[string]interface{}, error)

func (*Repository) StatsPendingAndOverdueCount added in v1.8.25 

func (r *Repository) StatsPendingAndOverdueCount(_ context.Context) (pending int, overdue int, err error)

func (*Repository) StatsStuckApproverGroup added in v1.8.25 

func (r *Repository) StatsStuckApproverGroup(_ context.Context, limit int) ([]map[string]interface{}, error)

func (*Repository) StatsStuckNodeGroup added in v1.8.25 

func (r *Repository) StatsStuckNodeGroup(_ context.Context, limit int) ([]map[string]interface{}, error)

func (*Repository) UpdateCcStatus 

func (r *Repository) UpdateCcStatus(ctx context.Context, instanceID int64, actorID string) error

func (*Repository) UpdateDefine added in v1.1.0 

func (r *Repository) UpdateDefine(ctx context.Context, def *model.ProcessDefine) error

func (*Repository) UpdateDefineState added in v1.1.0 

func (r *Repository) UpdateDefineState(ctx context.Context, defineID int64, state int) error

func (*Repository) UpdateInstance 

func (r *Repository) UpdateInstance(ctx context.Context, inst *model.ProcessInstance) error

func (*Repository) UpdateTask 

func (r *Repository) UpdateTask(ctx context.Context, task *model.ProcessTask) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.