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
• type WalletAddressRepo
• type WalletRepo

Constants

const (
	NotDeleted = -1
	Deleted    = 1
)

Types

type AddressRepo

type AddressRepo interface {
	HasAddress(ctx context.Context, addr address.Address) (bool, error)
	SaveAddress(ctx context.Context, address *types.Address) error
	UpdateNonce(ctx context.Context, addr address.Address, nonce uint64) error
	GetAddress(ctx context.Context, addr address.Address) (*types.Address, error)
	GetOneRecord(ctx context.Context, addr address.Address) (*types.Address, error)
	ListAddress(ctx context.Context) ([]*types.Address, error)
	DelAddress(ctx context.Context, addr address.Address) error
	UpdateAddress(ctx context.Context, addr *types.Address) 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)
	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)
	ListFilledMessageByWallet(walletName string, addr address.Address) ([]*types.Message, error)
	ListFilledMessageByHeight(height abi.ChainEpoch) ([]*types.Message, error)
	ListUnchainedMsgs() ([]*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
	UpdateUnFilledMessageState(walletName string, addr address.Address, 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

	WalletRepo() WalletRepo
	MessageRepo() MessageRepo
	AddressRepo() AddressRepo
	SharedParamsRepo() SharedParamsRepo
	NodeRepo() NodeRepo
	WalletAddressRepo() WalletAddressRepo
}

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 {
	WalletRepo() WalletRepo
	MessageRepo() MessageRepo
	AddressRepo() AddressRepo
	WalletAddressRepo() WalletAddressRepo
}

type WalletAddressRepo

type WalletAddressRepo interface {
	SaveWalletAddress(wa *types.WalletAddress) error
	GetWalletAddress(walletID, addrID types.UUID) (*types.WalletAddress, error)
	GetOneRecord(walletID, addrID types.UUID) (*types.WalletAddress, error)
	GetWalletAddressByWalletID(walletID types.UUID) ([]*types.WalletAddress, error)
	HasWalletAddress(walletID, addrID types.UUID) (bool, error)
	ListWalletAddress() ([]*types.WalletAddress, error)
	UpdateAddressState(walletID, addrID types.UUID, state types.State) error
	UpdateSelectMsgNum(walletID, addrID types.UUID, selMsgNum uint64) error
	DelWalletAddress(walletID, addrID types.UUID) error
}

type WalletRepo

type WalletRepo interface {
	SaveWallet(wallet *types.Wallet) error
	GetWalletByID(uuid types.UUID) (*types.Wallet, error)
	GetWalletByName(name string) (*types.Wallet, error)
	GetOneRecord(name string) (*types.Wallet, error)
	HasWallet(name string) (bool, error)
	ListWallet() ([]*types.Wallet, error)
	UpdateState(name string, state types.State) error
	DelWallet(name string) error
}