gethlylejobs

Documentation

Index

• func GetTotalGethProcessJobCount(dbConnPgx utils.PgxIface) (*int, error)
• func InsertGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJob *GethProcessJob) (int, error)
• func InsertGethProcessJobList(dbConnPgx utils.PgxIface, gethProcessJobList []GethProcessJob) error
• func RemoveGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJobID *int) error
• func UpdateGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJob *GethProcessJob) error
• type Attrs
  • func (a *Attrs) Scan(value interface{}) error
  • func (a Attrs) Value() (driver.Value, error)
• type GethProcessJob
  • func GetGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJobID *int) (*GethProcessJob, error)
  • func GetGethProcessJobList(dbConnPgx utils.PgxIface) ([]GethProcessJob, error)
  • func GetGethProcessJobListByPagination(dbConnPgx utils.PgxIface, _start, _end *int, _order, _sort string, ...) ([]GethProcessJob, error)
  • func GetLatestGethProcessJobByImportTypeIDAndAssetID(dbConnPgx utils.PgxIface, importTypeID, assetID *int) (*GethProcessJob, error)

Functions

func GetTotalGethProcessJobCount

func GetTotalGethProcessJobCount(dbConnPgx utils.PgxIface) (*int, error)

func InsertGethProcessJob

func InsertGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJob *GethProcessJob) (int, error)

func InsertGethProcessJobList

func InsertGethProcessJobList(dbConnPgx utils.PgxIface, gethProcessJobList []GethProcessJob) error

func RemoveGethProcessJob

func RemoveGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJobID *int) error

func UpdateGethProcessJob

func UpdateGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJob *GethProcessJob) error

Types

type Attrs

type Attrs map[string]interface{}

func (*Attrs) Scan

func (a *Attrs) Scan(value interface{}) error

func (Attrs) Value

func (a Attrs) Value() (driver.Value, error)

type GethProcessJob

type GethProcessJob struct {
	ID               *int       `json:"id" db:"id"`                               //1
	UUID             string     `json:"uuid" db:"uuid"`                           //2
	Name             string     `json:"name" db:"name"`                           //3
	AlternateName    string     `json:"alternateName" db:"alternate_name"`        //4
	StartDate        time.Time  `json:"startDate" db:"start_date"`                //5
	EndDate          *time.Time `json:"endDate" db:"end_date"`                    //6
	Description      string     `json:"description" db:"description"`             //7
	StatusID         *int       `json:"statusId" db:"status_id"`                  //8
	JobCategoryID    *int       `json:"jobCategoryId" db:"job_category_id"`       //9
	ImportTypeID     *int       `json:"importTypeId" db:"import_type_id"`         //10
	ChainID          *int       `json:"chainId" db:"chain_id"`                    //11
	StartBlockNumber *uint64    `json:"startBlockNumber" db:"start_block_number"` //12
	EndBlockNumber   *uint64    `json:"endBlockNumber" db:"end_block_number"`     //13
	CreatedBy        string     `json:"createdBy" db:"created_by"`                //14
	CreatedAt        time.Time  `json:"createdAt" db:"created_at"`                //15
	UpdatedBy        string     `json:"updatedBy" db:"updated_by"`                //16
	UpdatedAt        time.Time  `json:"updatedAt" db:"updated_at"`                //17
	AssetID          *int       `json:"assetId"  db:"asset_id"`                   //18
}

func GetGethProcessJob

func GetGethProcessJob(dbConnPgx utils.PgxIface, gethProcessJobID *int) (*GethProcessJob, error)

func GetGethProcessJobList

func GetGethProcessJobList(dbConnPgx utils.PgxIface) ([]GethProcessJob, error)

func GetGethProcessJobListByPagination

func GetGethProcessJobListByPagination(dbConnPgx utils.PgxIface, _start, _end *int, _order, _sort string, _filters []string) ([]GethProcessJob, error)

for refinedev

func GetLatestGethProcessJobByImportTypeIDAndAssetID

func GetLatestGethProcessJobByImportTypeIDAndAssetID(dbConnPgx utils.PgxIface, importTypeID, assetID *int) (*GethProcessJob, error)