datarepos

README

repo

Persistent Repository

• 仓库接口

Documentation

Overview

Package datarepos Code generated by ikaiguang. <https://github.com/ikaiguang>

Package datarepos Code generated by ikaiguang. <https://github.com/ikaiguang>

Index

• type NodeIdDataRepo
• type NodeSerialDataRepo

Types

type NodeIdDataRepo

type NodeIdDataRepo interface {
	NewTransaction(ctx context.Context, opts ...*sql.TxOptions) gormpkg.TransactionInterface
	Create(ctx context.Context, dataModel *po.NodeId) error
	CreateWithTransaction(ctx context.Context, tx gormpkg.TransactionInterface, dataModel *po.NodeId) (err error)
	ExistCreate(ctx context.Context, dataModel *po.NodeId) (anotherModel *po.NodeId, isNotFound bool, err error)
	CreateInBatches(ctx context.Context, dataModels []*po.NodeId, batchSize int) error
	Insert(ctx context.Context, dataModels []*po.NodeId) error
	Update(ctx context.Context, dataModel *po.NodeId) error
	ExistUpdate(ctx context.Context, dataModel *po.NodeId) (anotherModel *po.NodeId, isNotFound bool, err error)
	RenewalNodeID(ctx context.Context, dataModel *po.NodeId) (err error)
	RenewalNodeIDWithTransaction(ctx context.Context, tx gormpkg.TransactionInterface, dataModel *po.NodeId) (err error)
	ReleaseNodeID(ctx context.Context, dataModel *po.NodeId) (err error)
	QueryOneById(ctx context.Context, id uint64) (dataModel *po.NodeId, isNotFound bool, err error)
	QueryOneByInstanceNodeID(ctx context.Context, instanceID string, nodeID int64) (dataModel *po.NodeId, isNotFound bool, err error)
	QueryOneIdleNodeIdByInstanceId(ctx context.Context, instanceID string) (dataModel *po.NodeId, isNotFound bool, err error)
	QueryOneExpiredNodeIdByInstanceId(ctx context.Context, instanceID string, expiredTime time.Time) (dataModel *po.NodeId, isNotFound bool, err error)
	QueryOneByConditions(ctx context.Context, conditions map[string]interface{}) (dataModel *po.NodeId, isNotFound bool, err error)
	QueryAllByConditions(ctx context.Context, conditions map[string]interface{}) (dataModels []*po.NodeId, err error)
	List(ctx context.Context, conditions map[string]interface{}, paginatorArgs *gormpkg.PaginatorArgs) (dataModels []*po.NodeId, totalNumber int64, err error)
	Delete(ctx context.Context, dataModel *po.NodeId) error
	DeleteByIds(ctx context.Context, ids interface{}) error
}

NodeIdDataRepo repo

type NodeSerialDataRepo

type NodeSerialDataRepo interface {
	NewTransaction(ctx context.Context, opts ...*sql.TxOptions) gormpkg.TransactionInterface
	Create(ctx context.Context, dataModel *po.NodeSerial) error
	ExistCreate(ctx context.Context, dataModel *po.NodeSerial) (anotherModel *po.NodeSerial, isNotFound bool, err error)
	CreateInBatches(ctx context.Context, dataModels []*po.NodeSerial, batchSize int) error
	Insert(ctx context.Context, dataModels []*po.NodeSerial) error
	Update(ctx context.Context, dataModel *po.NodeSerial) error
	UpdateNodeIDWithTransaction(ctx context.Context, tx gormpkg.TransactionInterface, dataModel *po.NodeSerial) (err error)
	ExistUpdate(ctx context.Context, dataModel *po.NodeSerial) (anotherModel *po.NodeSerial, isNotFound bool, err error)
	FirstOrCreate(ctx context.Context, dataModel *po.NodeSerial) (*po.NodeSerial, error)
	QueryOneById(ctx context.Context, id interface{}) (dataModel *po.NodeSerial, isNotFound bool, err error)
	QueryOneByIdForUpdate(ctx context.Context, tx gormpkg.TransactionInterface, id uint64) (dataModel *po.NodeSerial, err error)
	QueryOneByConditions(ctx context.Context, conditions map[string]interface{}) (dataModel *po.NodeSerial, isNotFound bool, err error)
	QueryAllByConditions(ctx context.Context, conditions map[string]interface{}) (dataModels []*po.NodeSerial, err error)
	List(ctx context.Context, conditions map[string]interface{}, paginatorArgs *gormpkg.PaginatorArgs) (dataModels []*po.NodeSerial, totalNumber int64, err error)
	Delete(ctx context.Context, dataModel *po.NodeSerial) error
	DeleteByIds(ctx context.Context, ids interface{}) error
}

NodeSerialDataRepo repo