repo

Documentation

Index

• Constants
• type AddressRepo
• type ISqlField
• type MessageRepo
• type NodeRepo
• type Repo
• type SharedParamsRepo
• type SqlMsgReceipt
  • func FromMsgReceipt(receipt *types.MessageReceipt) *SqlMsgReceipt
  • func (s *SqlMsgReceipt) MsgReceipt() *types.MessageReceipt
• type SqlSignature
  • func (s *SqlSignature) Scan(value interface{}) error
  • func (s *SqlSignature) Value() (driver.Value, error)
• type TxRepo

Constants

const (
	NotDeleted = -1
	Deleted    = 1
)

Types

type AddressRepo

type AddressRepo interface {
	SaveAddress(ctx context.Context, address *types.Address) error
	GetAddress(ctx context.Context, addr address.Address) (*types.Address, error)
	GetAddressByID(ctx context.Context, id types.UUID) (*types.Address, error)
	GetOneRecord(ctx context.Context, addr address.Address) (*types.Address, error)
	HasAddress(ctx context.Context, addr address.Address) (bool, error)
	ListAddress(ctx context.Context) ([]*types.Address, error)
	DelAddress(ctx context.Context, addr address.Address) error
	UpdateNonce(ctx context.Context, addr address.Address, nonce uint64) error
	UpdateState(ctx context.Context, addr address.Address, state types.State) error
	UpdateSelectMsgNum(ctx context.Context, addr address.Address, num uint64) error
	UpdateFeeParams(ctx context.Context, addr address.Address, gasOverEstimation float64, maxFee, maxFeeCap big.Int) error
}

type ISqlField

type ISqlField interface {
	Scan(value interface{}) error
	Value() (driver.Value, error)
}

type MessageRepo

type MessageRepo interface {
	ExpireMessage(msg []*types.Message) error
	BatchSaveMessage(msg []*types.Message) error
	CreateMessage(msg *types.Message) error
	SaveMessage(msg *types.Message) error

	GetMessageByFromAndNonce(from address.Address, nonce uint64) (*types.Message, error)
	GetMessageByFromNonceAndState(from address.Address, nonce uint64, state types.MessageState) (*types.Message, error)
	GetMessageByUid(id string) (*types.Message, error)
	HasMessageByUid(id string) (bool, error)
	GetMessageState(id string) (types.MessageState, error)
	GetMessageByCid(unsignedCid cid.Cid) (*types.Message, error)
	GetMessageBySignedCid(signedCid cid.Cid) (*types.Message, error)
	GetSignedMessageByTime(start time.Time) ([]*types.Message, error)
	GetSignedMessageByHeight(height abi.ChainEpoch) ([]*types.Message, error)
	ListMessage() ([]*types.Message, error)
	ListMessageByFromState(from address.Address, state types.MessageState, pageIndex, pageSize int) ([]*types.Message, error)
	ListMessageByAddress(addr address.Address) ([]*types.Message, error)
	ListFailedMessage() ([]*types.Message, error)
	ListBlockedMessage(addr address.Address, d time.Duration) ([]*types.Message, error)
	ListUnChainMessageByAddress(addr address.Address, topN int) ([]*types.Message, error)
	ListFilledMessageByAddress(addr address.Address) ([]*types.Message, error)
	ListFilledMessageByHeight(height abi.ChainEpoch) ([]*types.Message, error)
	ListUnFilledMessage(addr address.Address) ([]*types.Message, error)
	ListSignedMsgs() ([]*types.Message, error)
	ListFilledMessageBelowNonce(addr address.Address, nonce uint64) ([]*types.Message, error)

	UpdateMessageInfoByCid(unsignedCid string, receipt *venustypes.MessageReceipt, height abi.ChainEpoch, state types.MessageState, tsKey venustypes.TipSetKey) error
	UpdateMessageStateByCid(unsignedCid string, state types.MessageState) error
	UpdateMessageStateByID(id string, state types.MessageState) error
	MarkBadMessage(id string) (struct{}, error)
	UpdateReturnValue(id string, returnVal string) error
}

type NodeRepo

type NodeRepo interface {
	CreateNode(node *types.Node) error
	SaveNode(node *types.Node) error
	GetNode(name string) (*types.Node, error)
	HasNode(name string) (bool, error)
	ListNode() ([]*types.Node, error)
	DelNode(name string) error
}

type Repo

type Repo interface {
	GetDb() *gorm.DB
	Transaction(func(txRepo TxRepo) error) error
	DbClose() error
	AutoMigrate() error

	MessageRepo() MessageRepo
	AddressRepo() AddressRepo
	SharedParamsRepo() SharedParamsRepo
	NodeRepo() NodeRepo
}

type SharedParamsRepo

type SharedParamsRepo interface {
	GetSharedParams(ctx context.Context) (*types.SharedParams, error)
	SetSharedParams(ctx context.Context, params *types.SharedParams) (uint, error)
}

type SqlMsgReceipt

type SqlMsgReceipt struct {
	ExitCode    exitcode.ExitCode `gorm:"column:exit_code;default:-1"`
	ReturnValue []byte            `gorm:"column:return_value;type:blob;"`
	GasUsed     int64             `gorm:"column:gas_used;type:bigint;"`
}

func FromMsgReceipt

func FromMsgReceipt(receipt *types.MessageReceipt) *SqlMsgReceipt

func (*SqlMsgReceipt) MsgReceipt

func (s *SqlMsgReceipt) MsgReceipt() *types.MessageReceipt

type SqlSignature

type SqlSignature crypto.Signature

func (*SqlSignature) Scan

func (s *SqlSignature) Scan(value interface{}) error

func (*SqlSignature) Value

func (s *SqlSignature) Value() (driver.Value, error)

type TxRepo

type TxRepo interface {
	MessageRepo() MessageRepo
	AddressRepo() AddressRepo
}