esyncdao

type EsyncEventDefaultDao struct {
	ID           int64     `gorm:"column:id;primaryKey" structs:"id" json:"id"`
	EventDate    int       `gorm:"column:event_date" structs:"event_date" json:"event_date"`
	EventType    string    `gorm:"column:event_type" structs:"event_type" json:"event_type"`
	UniqKey      string    `gorm:"column:uniq_key" structs:"uniq_key" json:"uniq_key"`
	UniqKeyCRC32 int64     `gorm:"column:uniq_key_crc32" structs:"uniq_key_crc32" json:"uniq_key_crc32"`
	EventOption  string    `gorm:"column:event_option" structs:"event_option" json:"event_option"`
	EventData    string    `gorm:"column:event_data" structs:"event_data" json:"event_data"`
	EStatus      int       `gorm:"column:e_status" structs:"e_status" json:"e_status"`
	HandlerInfo  string    `gorm:"column:handler_info" structs:"handler_info" json:"handler_info"`
	CreatedAt    time.Time `gorm:"column:created_at" structs:"created_at" json:"created_at"`
	UpdatedAt    time.Time `gorm:"column:updated_at" structs:"updated_at" json:"updated_at"`
	// contains filtered or unexported fields
}

type EventOption struct {
	DelaySeconds    []int `json:"delay_seconds"`     // 延迟执行的秒数 [5, 15, 45]:第5秒开始执行,如失败15,45秒重试
	MaxRunNum       int   `json:"max_run_num"`       // 最多执行的次数
	StartAt         int64 `json:"start_at"`          // 能开始执行的时间戳
	MaxAliveSeconds int   `json:"max_alive_seconds"` // 最大存活的时间
	Persistent      bool  `json:"persistent"`        // 是否持久化， true false
}

type HandlerInfo struct {
	FailCount       int      `json:"fail_count"`
	RunTS           []int64  `json:"run_ts"`           // 执行的时间戳
	SucceedHandlers []string `json:"succeed_handlers"` // 已成功的handlers
}

type Storage struct {
	// contains filtered or unexported fields
}