Documentation ¶
Index ¶
- func InsertGethProcessJob(gethProcessJob GethProcessJob) (int, error)
- func InsertGethProcessJobList(gethProcessJobList []GethProcessJob) error
- func InsertGethProcessJobTopic(gethProcessJobTopic GethProcessJobTopic) (int, error)
- func InsertGethProcessJobTopicList(gethProcessJobTopicList []GethProcessJobTopic) error
- func InsertGethProcessVlogJob(gethProcessJob GethProcessVlogJob) (int, error)
- func InsertGethProcessVlogJobList(gethProcessJobList []GethProcessVlogJob) error
- func RemoveGethProcessJob(gethProcessJobID *int) error
- func RemoveGethProcessJobTopic(gethProcessJobTopicID *int) error
- func RemoveGethProcessVlogJob(gethProcessJobID *int) error
- func UpdateFailedGethProcessVlogJob(gethProcessVlogJob *GethProcessVlogJob, msg string, doUpdate bool) error
- func UpdateGethProcessJob(gethProcessJob GethProcessJob) error
- func UpdateGethProcessJobTopic(gethProcessJobTopic *GethProcessJobTopic) error
- func UpdateGethProcessVlogJob(gethProcessJob *GethProcessVlogJob) error
- type Attrs
- type GethProcessJob
- type GethProcessJobTopic
- type GethProcessVlogJob
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 RemoveGethProcessJobTopic ¶ added in v1.3.8
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 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)
Click to show internal directories.
Click to hide internal directories.