Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

persistence

package

Go to main page

Versions in this module

v1

v1.0.1

Apr 24, 2024

v1.0.0

Mar 25, 2024

v0

v0.0.4

Mar 8, 2024

v0.0.3

Jan 23, 2024

v0.0.2

Jan 20, 2024

Changes in this version

+ var ErrTimeout = errors.New("timeout")

+ func LogDaoErr(ctx context.Context, err *error, params ...interface{})

+ func WithTransaction(ctx context.Context, db *sql.DB, fn SQLTxFunc) (err error)

+ type H2ConnectionPool struct

+ func NewH2ConnectionPool(opts ...Option) (*H2ConnectionPool, error)

+ type H2FilePersistence struct

+ func GetH2FilePersistence() *H2FilePersistence

+ type H2MemoryPersistence struct

+ func GetH2MemoryPersistence() *H2MemoryPersistence

+ type H2Persistence struct

+ func GetH2Persistence() *H2Persistence

+ func NewH2Persistence() *H2Persistence

+ func (rcvr *H2Persistence) BatchUpdateTaskStatus(jobInstanceId int64, status taskstatus.TaskStatus, workerId string, ...) int64

+ func (rcvr *H2Persistence) CheckInstanceStatus(jobInstanceId int64) processor.InstanceStatus

+ func (rcvr *H2Persistence) ClearTasks(jobInstanceId int64) error

+ func (rcvr *H2Persistence) CreateTask(jobId, jobInstanceId, taskId int64, taskName string, taskBody []byte) error

+ func (rcvr *H2Persistence) CreateTasks(containers []*schedulerx.MasterStartContainerRequest, ...) error

+ func (rcvr *H2Persistence) GetDistinctInstanceIds() []int64

+ func (rcvr *H2Persistence) GetTaskStatistics() *common.TaskStatistics

+ func (rcvr *H2Persistence) InitTable()

+ func (rcvr *H2Persistence) IsInited() bool

+ func (rcvr *H2Persistence) Pull(jobInstanceId int64, pageSize int32) ([]*common.TaskInfo, error)

+ func (rcvr *H2Persistence) UpdateTaskStatues(taskStatusInfos []*schedulerx.ContainerReportTaskStatusRequest) error

+ func (rcvr *H2Persistence) UpdateTaskStatus(jobInstanceId int64, taskIds []int64, status taskstatus.TaskStatus, ...) (int64, error)

+ type Option func(o *Options)

+ func WithDataSourceName(dataSourceName string) Option

+ type Options struct

+ type SQLTxFunc func(tx *sql.Tx) error

+ type ServerTaskPersistence struct

+ func NewServerTaskPersistence(groupId string) (rcvr *ServerTaskPersistence)

+ func (rcvr *ServerTaskPersistence) BatchUpdateTaskStatus(jobInstanceId int64, status taskstatus.TaskStatus, workerId string, ...) int64

+ func (rcvr *ServerTaskPersistence) CheckInstanceStatus(jobInstanceId int64) processor.InstanceStatus

+ func (rcvr *ServerTaskPersistence) ClearTasks(jobInstanceId int64) error

+ func (rcvr *ServerTaskPersistence) CreateTask(jobId int64, jobInstanceId int64, taskId int64, taskName string, ...) error

+ func (rcvr *ServerTaskPersistence) CreateTasks(containers []*schedulerx.MasterStartContainerRequest, workerId string, ...) error

+ func (rcvr *ServerTaskPersistence) InitTable()

+ func (rcvr *ServerTaskPersistence) Pull(jobInstanceId int64, pageSize int32) ([]*common.TaskInfo, error)

+ func (rcvr *ServerTaskPersistence) UpdateTaskStatues(taskStatusInfos []*schedulerx.ContainerReportTaskStatusRequest) error

+ func (rcvr *ServerTaskPersistence) UpdateTaskStatus(jobInstanceId int64, taskIds []int64, status taskstatus.TaskStatus, ...) (int64, error)

+ type TaskDao struct

+ func NewTaskDao(h2CP *H2ConnectionPool) *TaskDao

+ func (d *TaskDao) BatchDeleteTasks(jobInstanceId int64, taskIds []int64) (int64, error)

+ func (d *TaskDao) BatchDeleteTasks2(jobInstanceId int64, workerId string, workerAddr string) (int64, error)

+ func (d *TaskDao) BatchInsert(containers []*schedulerx.MasterStartContainerRequest, workerId string, ...) (int64, error)

+ func (d *TaskDao) BatchUpdateStatus(jobInstanceId int64, taskIdList []int64, status int) (int64, error)

+ func (d *TaskDao) BatchUpdateStatus2(jobInstanceId int64, status int, workerId string, workerAddr string) (int64, error)

+ func (d *TaskDao) CreateTable() error

+ func (d *TaskDao) DeleteByJobInstanceId(jobInstanceId int64) (int64, error)

+ func (d *TaskDao) DropTable() error

+ func (d *TaskDao) Exist(jobInstanceId int64) (bool, error)

+ func (d *TaskDao) GetDistinctInstanceIds() ([]int64, error)

+ func (d *TaskDao) GetTaskStatistics() (*common.TaskStatistics, error)

+ func (d *TaskDao) Insert(jobId int64, jobInstanceId int64, taskId int64, taskName string, ...) error

+ func (d *TaskDao) QueryStatus(jobInstanceId int64) ([]int32, error)

+ func (d *TaskDao) QueryTaskCount(jobInstanceId int64) (int64, error)

+ func (d *TaskDao) QueryTaskList(jobInstanceId int64, status int, pageSize int32) ([]*TaskSnapshot, error)

+ func (d *TaskDao) QueryTasks(jobInstanceId int64, pageSize int32) ([]*TaskSnapshot, error)

+ func (d *TaskDao) UpdateStatus(jobInstanceId int64, taskId int64, status int, workerAddr string) (int64, error)

+ func (d *TaskDao) UpdateStatus2(jobInstanceId int64, taskIds []int64, status int, workerId string, ...) (int64, error)

+ func (d *TaskDao) UpdateWorker(jobInstanceId int64, taskId int64, workerId string, workerAddr string) (int64, error)

+ type TaskPersistence interface

+ BatchUpdateTaskStatus func(jobInstanceId int64, status taskstatus.TaskStatus, workerId string, ...) int64

+ CheckInstanceStatus func(jobInstanceId int64) processor.InstanceStatus

+ ClearTasks func(jobInstanceId int64) error

+ CreateTask func(jobId, jobInstanceId, taskId int64, taskName string, taskBody []byte) error

+ CreateTasks func(containers []*schedulerx.MasterStartContainerRequest, ...) error

+ InitTable func()

+ Pull func(jobInstanceId int64, pageSize int32) ([]*common.TaskInfo, error)

+ UpdateTaskStatues func(taskStatusInfos []*schedulerx.ContainerReportTaskStatusRequest) error

+ UpdateTaskStatus func(jobInstanceId int64, taskIds []int64, status taskstatus.TaskStatus, ...) (int64, error)

+ type TaskSnapshot struct

+ GmtCreate time.Time

+ GmtModified time.Time

+ JobId int64

+ JobInstanceId int64

+ Progress float64

+ Status int32

+ TaskBody []byte

+ TaskId int64

+ TaskName string

+ WorkerAddr string

+ WorkerId string

+ func NewTaskSnapshot() (rcvr *TaskSnapshot)

+ func (t *TaskSnapshot) GetGmtCreate() time.Time

+ func (t *TaskSnapshot) GetGmtModified() time.Time

+ func (t *TaskSnapshot) GetJobId() int64

+ func (t *TaskSnapshot) GetJobInstanceId() int64

+ func (t *TaskSnapshot) GetProgress() float64

+ func (t *TaskSnapshot) GetStatus() int32

+ func (t *TaskSnapshot) GetTaskBody() []byte

+ func (t *TaskSnapshot) GetTaskId() int64

+ func (t *TaskSnapshot) GetTaskName() string

+ func (t *TaskSnapshot) GetWorkerAddr() string

+ func (t *TaskSnapshot) GetWorkerId() string

+ func (t *TaskSnapshot) SetGmtCreate(gmtCreate time.Time)

+ func (t *TaskSnapshot) SetGmtModified(gmtModified time.Time)

+ func (t *TaskSnapshot) SetJobId(jobId int64)

+ func (t *TaskSnapshot) SetJobInstanceId(jobInstanceId int64)

+ func (t *TaskSnapshot) SetProgress(progress float64)

+ func (t *TaskSnapshot) SetStatus(Status int32)

+ func (t *TaskSnapshot) SetTaskBody(taskBody []byte)

+ func (t *TaskSnapshot) SetTaskId(taskId int64)

+ func (t *TaskSnapshot) SetTaskName(taskName string)

+ func (t *TaskSnapshot) SetWorker(workerAddr string)

+ func (t *TaskSnapshot) SetWorkerId(workerId string)