Documentation
¶
Index ¶
- func ApplyEventFilterRenames(exprs []query.Expression, renames map[string]string) []query.Expression
- func BuildJsonPathExpr(baseField string, path string) (string, error)
- func ExtractEventCreationNum(resourceData map[string]any, eventFieldPath string) (string, error)
- func ExtractTimestampFilter(expressions []query.Expression) (uint64, bool)
- func IsNumeric(value any) bool
- func MaybeRenameFields(jsonValue any, renames map[string]config.RenamedField) error
- func RenameMapFields(jsonData map[string]any, renames map[string]config.RenamedField) error
- func UnwrapSlice(value any) ([]any, bool)
- type Any2AptosRampMessage
- type Any2AptosTokenTransfer
- type ConfigSet
- type ExecutionReport
- type MessageHasherV1
- type RampMessageHeader
- type SourceChainConfig
- type SourceChainConfigSet
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApplyEventFilterRenames ¶
func ApplyEventFilterRenames(exprs []query.Expression, renames map[string]string) []query.Expression
func BuildJsonPathExpr ¶
buildJsonPathExpr constructs a PostgreSQL JSON path expression for accessing nested fields Example: "Header.SourceChainSelector" becomes data->'Header'->>'SourceChainSelector'
func ExtractEventCreationNum ¶
func ExtractTimestampFilter ¶
func ExtractTimestampFilter(expressions []query.Expression) (uint64, bool)
func MaybeRenameFields ¶
func MaybeRenameFields(jsonValue any, renames map[string]config.RenamedField) error
func RenameMapFields ¶
func UnwrapSlice ¶
Types ¶
type Any2AptosRampMessage ¶
type Any2AptosRampMessage struct {
Header RampMessageHeader
Sender []byte
Data []byte
Receiver aptos.AccountAddress
GasLimit *big.Int
TokenAmounts []Any2AptosTokenTransfer
}
type Any2AptosTokenTransfer ¶
type ExecutionReport ¶
type ExecutionReport struct {
SourceChainSelector uint64
Message Any2AptosRampMessage
OffchainTokenData [][]byte
Proofs [][]byte
}
func DeserializeExecutionReport ¶
func DeserializeExecutionReport(data []byte) (*ExecutionReport, error)
type MessageHasherV1 ¶
type MessageHasherV1 struct {
// contains filtered or unexported fields
}
func NewMessageHasherV1 ¶
func NewMessageHasherV1(lggr logger.Logger) *MessageHasherV1
func (*MessageHasherV1) Hash ¶
func (h *MessageHasherV1) Hash(ctx context.Context, report *ExecutionReport, onRampAddress []byte) ([32]byte, error)
type RampMessageHeader ¶
type SourceChainConfig ¶
type SourceChainConfigSet ¶
type SourceChainConfigSet struct {
SourceChainSelector uint64
SourceChainConfig SourceChainConfig
}
Click to show internal directories.
Click to hide internal directories.