messages

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Sep 23, 2021 License: Apache-2.0, MIT Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockMessage

type BlockMessage struct {
	Height  int64  `pg:",pk,notnull,use_zero"`
	Block   string `pg:",pk,notnull"`
	Message string `pg:",pk,notnull"`
}

func (*BlockMessage) Persist

func (bm *BlockMessage) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type BlockMessages

type BlockMessages []*BlockMessage

func (BlockMessages) Persist

func (bms BlockMessages) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type InternalMessage

type InternalMessage struct {
	Height        int64  `pg:",pk,notnull,use_zero"`
	Cid           string `pg:",pk,notnull"`
	StateRoot     string `pg:",notnull"`
	SourceMessage string
	From          string `pg:",notnull"`
	To            string `pg:",notnull"`
	Value         string `pg:"type:numeric,notnull"`
	Method        uint64 `pg:",use_zero"`
	ActorName     string `pg:",notnull"`
	ActorFamily   string `pg:",notnull"`
	ExitCode      int64  `pg:",use_zero"`
	GasUsed       int64  `pg:",use_zero"`
	// contains filtered or unexported fields
}

func (*InternalMessage) Persist

func (im *InternalMessage) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type InternalMessageList

type InternalMessageList []*InternalMessage

func (InternalMessageList) Persist

type InternalParsedMessage

type InternalParsedMessage struct {
	Height int64  `pg:",pk,notnull,use_zero"`
	Cid    string `pg:",pk,notnull"`
	From   string `pg:",notnull"`
	To     string `pg:",notnull"`
	Value  string `pg:"type:numeric,notnull"`
	Method string `pg:",use_zero"`
	Params string `pg:",type:jsonb"`
	// contains filtered or unexported fields
}

func (*InternalParsedMessage) Persist

func (ipm *InternalParsedMessage) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type InternalParsedMessageList

type InternalParsedMessageList []*InternalParsedMessage

func (InternalParsedMessageList) Persist

type Message

type Message struct {
	Height int64  `pg:",pk,notnull,use_zero"`
	Cid    string `pg:",pk,notnull"`

	From       string `pg:",notnull"`
	To         string `pg:",notnull"`
	Value      string `pg:"type:numeric,notnull"`
	GasFeeCap  string `pg:"type:numeric,notnull"`
	GasPremium string `pg:"type:numeric,notnull"`

	GasLimit  int64  `pg:",use_zero"`
	SizeBytes int    `pg:",use_zero"`
	Nonce     uint64 `pg:",use_zero"`
	Method    uint64 `pg:",use_zero"`
}

func (*Message) AsVersion

func (m *Message) AsVersion(version model.Version) (interface{}, bool)

func (*Message) Persist

func (m *Message) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type MessageGasEconomy

type MessageGasEconomy struct {
	Height    int64  `pg:",pk,notnull,use_zero"`
	StateRoot string `pg:",pk,notnull"`

	BaseFee          float64 `pg:"type:numeric,use_zero"`
	BaseFeeChangeLog float64 `pg:",use_zero"`

	GasLimitTotal       int64 `pg:"type:numeric,use_zero"`
	GasLimitUniqueTotal int64 `pg:"type:numeric,use_zero"`

	GasFillRatio     float64 `pg:",use_zero"`
	GasCapacityRatio float64 `pg:",use_zero"`
	GasWasteRatio    float64 `pg:",use_zero"`
	// contains filtered or unexported fields
}

func (*MessageGasEconomy) AsVersion

func (g *MessageGasEconomy) AsVersion(version model.Version) (interface{}, bool)

func (*MessageGasEconomy) Persist

func (g *MessageGasEconomy) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type MessageGasEconomyV0

type MessageGasEconomyV0 struct {
	Height    int64  `pg:",pk,notnull,use_zero"`
	StateRoot string `pg:",pk,notnull"`

	BaseFee          float64 `pg:",use_zero"`
	BaseFeeChangeLog float64 `pg:",use_zero"`

	GasLimitTotal       int64 `pg:",use_zero"`
	GasLimitUniqueTotal int64 `pg:",use_zero"`

	GasFillRatio     float64 `pg:",use_zero"`
	GasCapacityRatio float64 `pg:",use_zero"`
	GasWasteRatio    float64 `pg:",use_zero"`
	// contains filtered or unexported fields
}

type MessageTaskResult

type MessageTaskResult struct {
	Messages          Messages
	ParsedMessages    ParsedMessages
	BlockMessages     BlockMessages
	Receipts          Receipts
	MessageGasEconomy *MessageGasEconomy
}

func (*MessageTaskResult) Persist

func (mtr *MessageTaskResult) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type MessageV0

type MessageV0 struct {
	Height int64  `pg:",pk,notnull,use_zero"`
	Cid    string `pg:",pk,notnull"`

	From       string `pg:",notnull"`
	To         string `pg:",notnull"`
	Value      string `pg:",notnull"`
	GasFeeCap  string `pg:",notnull"`
	GasPremium string `pg:",notnull"`

	GasLimit  int64  `pg:",use_zero"`
	SizeBytes int    `pg:",use_zero"`
	Nonce     uint64 `pg:",use_zero"`
	Method    uint64 `pg:",use_zero"`
	// contains filtered or unexported fields
}

type Messages

type Messages []*Message

func (Messages) Persist

func (ms Messages) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type ParsedMessage

type ParsedMessage struct {
	Height int64  `pg:",pk,notnull,use_zero"`
	Cid    string `pg:",pk,notnull"`
	From   string `pg:",notnull"`
	To     string `pg:",notnull"`
	Value  string `pg:"type:numeric,notnull"`
	Method string `pg:",notnull"`
	Params string `pg:",type:jsonb"`
}

func (*ParsedMessage) AsVersion

func (pm *ParsedMessage) AsVersion(version model.Version) (interface{}, bool)

func (*ParsedMessage) Persist

func (pm *ParsedMessage) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type ParsedMessageV0

type ParsedMessageV0 struct {
	Height int64  `pg:",pk,notnull,use_zero"`
	Cid    string `pg:",pk,notnull"`
	From   string `pg:",notnull"`
	To     string `pg:",notnull"`
	Value  string `pg:",notnull"`
	Method string `pg:",notnull"`
	Params string `pg:",type:jsonb,notnull"`
	// contains filtered or unexported fields
}

type ParsedMessages

type ParsedMessages []*ParsedMessage

func (ParsedMessages) Persist

func (pms ParsedMessages) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type Receipt

type Receipt struct {
	Height    int64  `pg:",pk,notnull,use_zero"` // note this is the height of the receipt not the message
	Message   string `pg:",pk,notnull"`
	StateRoot string `pg:",pk,notnull"`

	Idx      int   `pg:",use_zero"`
	ExitCode int64 `pg:",use_zero"`
	GasUsed  int64 `pg:",use_zero"`
}

func (*Receipt) Persist

func (r *Receipt) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type Receipts

type Receipts []*Receipt

func (Receipts) Persist

func (rs Receipts) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

Jump to

Keyboard shortcuts

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