gethlylejobs

package
v1.3.57 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InsertGethProcessJob

func InsertGethProcessJob(gethProcessJob GethProcessJob) (int, error)

func InsertGethProcessJobList

func InsertGethProcessJobList(gethProcessJobList []GethProcessJob) error

func InsertGethProcessJobTopic added in v1.3.8

func InsertGethProcessJobTopic(gethProcessJobTopic GethProcessJobTopic) (int, error)

func InsertGethProcessJobTopicList added in v1.3.8

func InsertGethProcessJobTopicList(gethProcessJobTopicList []GethProcessJobTopic) error

func InsertGethProcessVlogJob

func InsertGethProcessVlogJob(gethProcessJob GethProcessVlogJob) (int, error)

func InsertGethProcessVlogJobList

func InsertGethProcessVlogJobList(gethProcessJobList []GethProcessVlogJob) error

func RemoveGethProcessJob

func RemoveGethProcessJob(gethProcessJobID *int) error

func RemoveGethProcessJobTopic added in v1.3.8

func RemoveGethProcessJobTopic(gethProcessJobTopicID *int) error

func RemoveGethProcessVlogJob

func RemoveGethProcessVlogJob(gethProcessJobID *int) error

func UpdateFailedGethProcessVlogJob

func UpdateFailedGethProcessVlogJob(gethProcessVlogJob *GethProcessVlogJob, msg string, doUpdate bool) error

func UpdateGethProcessJob

func UpdateGethProcessJob(gethProcessJob GethProcessJob) error

func UpdateGethProcessJobTopic added in v1.3.8

func UpdateGethProcessJobTopic(gethProcessJobTopic *GethProcessJobTopic) error

func UpdateGethProcessVlogJob

func UpdateGethProcessVlogJob(gethProcessJob *GethProcessVlogJob) 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"`
	UUID             string    `json:"uuid"`
	Name             string    `json:"name"`
	AlternateName    string    `json:"alternateName"`
	StartDate        time.Time `json:"startDate"`
	EndDate          time.Time `json:"endDate"`
	Description      string    `json:"description"`
	StatusID         *int      `json:"statusId"`
	JobCategoryID    *int      `json:"jobCategoryId"`
	ImportTypeID     *int      `json:"importTypeId"`
	ChainID          *int      `json:"chainId"`
	StartBlockNumber *uint64   `json:"startBlockNumber"`
	EndBlockNumber   *uint64   `json:"endBlockNumber"`
	CreatedBy        string    `json:"createdBy"`
	CreatedAt        time.Time `json:"createdAt"`
	UpdatedBy        string    `json:"updatedBy"`
	UpdatedAt        time.Time `json:"updatedAt"`
	AssetID          *int      `json:"assetId"`
}

func GetGethProcessJob

func GetGethProcessJob(gethProcessJobID int) (*GethProcessJob, error)

func GetGethProcessJobList

func GetGethProcessJobList() ([]GethProcessJob, error)

func GetLatestGethProcessJobByImportTypeIDAndAssetID added in v1.3.0

func GetLatestGethProcessJobByImportTypeIDAndAssetID(importTypeID int, assetID int) (*GethProcessJob, error)

type GethProcessJobTopic added in v1.3.8

type GethProcessJobTopic struct {
	ID               *int      `json:"id"`
	GethProcessJobID *int      `json:"gethProcessJobId"`
	UUID             string    `json:"uuid"`
	Name             string    `json:"name"`
	AlternateName    string    `json:"alternateName"`
	Description      string    `json:"description"`
	StatusID         *int      `json:"statusId"`
	TopicStr         string    `json:"topicStr"`
	CreatedBy        string    `json:"createdBy"`
	CreatedAt        time.Time `json:"createdAt"`
	UpdatedBy        string    `json:"updatedBy"`
	UpdatedAt        time.Time `json:"updatedAt"`
}

func GetGethProcessJobTopic added in v1.3.8

func GetGethProcessJobTopic(gethProcessJobTopicID int) (*GethProcessJobTopic, error)

func GetGethProcessJobTopicList added in v1.3.8

func GetGethProcessJobTopicList() ([]GethProcessJobTopic, error)

type GethProcessVlogJob

type GethProcessVlogJob struct {
	ID               *int `json:"id"`
	GethProcessJobID *int `json:"gethProcessJobId"`

	UUID          string    `json:"uuid"`
	Name          string    `json:"name"`
	AlternateName string    `json:"alternateName"`
	StartDate     time.Time `json:"startDate"`
	EndDate       time.Time `json:"endDate"`
	Description   string    `json:"description"`
	StatusID      *int      `json:"statusId"`
	JobCategoryID *int      `json:"jobCategoryId"`

	AssetID     *int     `json:"assetId"`
	ChainID     *int     `json:"chainId"`
	TxnHash     string   `json:"txnHash"`
	AddressID   *int     `json:"addressId"`
	BlockNumber *uint64  `json:"blockNumber"`
	IndexNumber *uint    `json:"indexNumber"`
	TopicsStr   []string `json:"topicsStr"`

	CreatedBy string    `json:"createdBy"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedBy string    `json:"updatedBy"`
	UpdatedAt time.Time `json:"updatedAt"`
}

func GetGethProcessVlogJob

func GetGethProcessVlogJob(gethProcessJobID int) (*GethProcessVlogJob, error)

func GetGethProcessVlogJobList

func GetGethProcessVlogJobList() ([]GethProcessVlogJob, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL